OrderServiceImpl.java 96 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119
  1. package com.fuint.common.service.impl;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  5. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  6. import com.fuint.common.Constants;
  7. import com.fuint.common.dto.*;
  8. import com.fuint.common.enums.*;
  9. import com.fuint.common.param.OrderListParam;
  10. import com.fuint.common.param.SettlementParam;
  11. import com.fuint.common.service.*;
  12. import com.fuint.common.util.CommonUtil;
  13. import com.fuint.common.util.DateUtil;
  14. import com.fuint.common.util.SeqUtil;
  15. import com.fuint.common.util.TokenUtil;
  16. import com.fuint.framework.annoation.OperationServiceLog;
  17. import com.fuint.framework.exception.BusinessCheckException;
  18. import com.fuint.framework.pagination.PaginationResponse;
  19. import com.fuint.framework.web.ResponseObject;
  20. import com.fuint.repository.mapper.*;
  21. import com.fuint.repository.model.*;
  22. import com.fuint.utils.PropertiesUtil;
  23. import com.fuint.utils.StringUtil;
  24. import com.github.pagehelper.Page;
  25. import com.github.pagehelper.PageHelper;
  26. import lombok.AllArgsConstructor;
  27. import org.apache.commons.lang.StringUtils;
  28. import org.slf4j.Logger;
  29. import org.slf4j.LoggerFactory;
  30. import org.springframework.beans.BeanUtils;
  31. import org.springframework.context.annotation.Lazy;
  32. import org.springframework.data.domain.PageImpl;
  33. import org.springframework.data.domain.PageRequest;
  34. import org.springframework.stereotype.Service;
  35. import org.springframework.transaction.annotation.Transactional;
  36. import weixin.popular.util.JsonUtil;
  37. import javax.servlet.http.HttpServletRequest;
  38. import java.math.BigDecimal;
  39. import java.util.*;
  40. import java.util.stream.Collectors;
  41. /**
  42. * 订单接口实现类
  43. *
  44. * Created by FSQ
  45. * CopyRight https://www.fuint.cn
  46. */
  47. @Service
  48. @AllArgsConstructor(onConstructor_= {@Lazy})
  49. public class OrderServiceImpl extends ServiceImpl<MtOrderMapper, MtOrder> implements OrderService {
  50. private static final Logger logger = LoggerFactory.getLogger(OrderServiceImpl.class);
  51. private MtOrderMapper mtOrderMapper;
  52. private MtGoodsMapper mtGoodsMapper;
  53. private MtOrderGoodsMapper mtOrderGoodsMapper;
  54. private MtCartMapper mtCartMapper;
  55. private MtOrderAddressMapper mtOrderAddressMapper;
  56. private MtConfirmLogMapper mtConfirmLogMapper;
  57. private MtUserCouponMapper mtUserCouponMapper;
  58. private MtGoodsSkuMapper mtGoodsSkuMapper;
  59. private MtRegionMapper mtRegionMapper;
  60. private MtUserGradeMapper mtUserGradeMapper;
  61. private MtCouponGoodsMapper mtCouponGoodsMapper;
  62. /**
  63. * 系统设置服务接口
  64. * */
  65. private SettingService settingService;
  66. /**
  67. * 卡券服务接口
  68. * */
  69. private CouponService couponService;
  70. /**
  71. * 会员卡券服务接口
  72. * */
  73. private UserCouponService userCouponService;
  74. /**
  75. * 收货地址服务接口
  76. * */
  77. private AddressService addressService;
  78. /**
  79. * 会员服务接口
  80. * */
  81. private MemberService memberService;
  82. /**
  83. * 积分服务接口
  84. * */
  85. private PointService pointService;
  86. /**
  87. * 购物车服务接口
  88. * */
  89. private CartService cartService;
  90. /**
  91. * 商品服务接口
  92. * */
  93. private GoodsService goodsService;
  94. /**
  95. * 店铺服务接口
  96. * */
  97. private StoreService storeService;
  98. /**
  99. * 会员等级服务接口
  100. * */
  101. private UserGradeService userGradeService;
  102. /**
  103. * 售后服务接口
  104. * */
  105. private RefundService refundService;
  106. /**
  107. * 余额服务接口
  108. * */
  109. private BalanceService balanceService;
  110. /**
  111. * 微信相关服务接口
  112. * */
  113. private WeixinService weixinService;
  114. /**
  115. * 支付宝服务接口
  116. * */
  117. private AlipayService alipayService;
  118. /**
  119. * 短信发送服务接口
  120. * */
  121. private SendSmsService sendSmsService;
  122. /**
  123. * 开卡赠礼服务接口
  124. * */
  125. private OpenGiftService openGiftService;
  126. /**
  127. * 商户服务接口
  128. * */
  129. private MerchantService merchantService;
  130. /**
  131. * 店铺员工服务接口
  132. * */
  133. private StaffService staffService;
  134. /**
  135. * 支付服务接口
  136. * */
  137. private PaymentService paymentService;
  138. /**
  139. * 获取用户订单列表
  140. * @param orderListParam
  141. * @throws BusinessCheckException
  142. * */
  143. @Override
  144. @Transactional(rollbackFor = Exception.class)
  145. public PaginationResponse getUserOrderList(OrderListParam orderListParam) throws BusinessCheckException {
  146. Integer pageNumber = orderListParam.getPage() == null ? Constants.PAGE_NUMBER : orderListParam.getPage();
  147. Integer pageSize = orderListParam.getPageSize() == null ? Constants.PAGE_SIZE : orderListParam.getPageSize();
  148. String userId = orderListParam.getUserId() == null ? "" : orderListParam.getUserId();
  149. Integer merchantId = orderListParam.getMerchantId() == null ? 0 : orderListParam.getMerchantId();
  150. Integer storeId = orderListParam.getStoreId() == null ? 0 : orderListParam.getStoreId();
  151. String status = orderListParam.getStatus() == null ? "": orderListParam.getStatus();
  152. String payStatus = orderListParam.getPayStatus() == null ? "": orderListParam.getPayStatus();
  153. String settleStatus = orderListParam.getSettleStatus() == null ? "": orderListParam.getSettleStatus();
  154. String dataType = orderListParam.getDataType() == null ? "": orderListParam.getDataType();
  155. String type = orderListParam.getType() == null ? "": orderListParam.getType();
  156. String orderSn = orderListParam.getOrderSn() == null ? "": orderListParam.getOrderSn();
  157. String mobile = orderListParam.getMobile() == null ? "": orderListParam.getMobile();
  158. String orderMode = orderListParam.getOrderMode() == null ? "": orderListParam.getOrderMode();
  159. String staffId = orderListParam.getStaffId() == null ? "" : orderListParam.getStaffId();
  160. String couponId = orderListParam.getCouponId() == null ? "" : orderListParam.getCouponId();
  161. String storeIds = orderListParam.getStoreIds() == null ? "" : orderListParam.getStoreIds();
  162. String startTime = orderListParam.getStartTime() == null ? "" : orderListParam.getStartTime();
  163. String endTime = orderListParam.getEndTime() == null ? "" : orderListParam.getEndTime();
  164. if (dataType.equals("toPay")) {
  165. status = OrderStatusEnum.CREATED.getKey(); // 待支付
  166. } else if(dataType.equals("paid")) {
  167. status = "";
  168. payStatus = PayStatusEnum.SUCCESS.getKey(); // 已支付
  169. } else if(dataType.equals("cancel")) {
  170. status = OrderStatusEnum.CANCEL.getKey(); // 已取消
  171. }
  172. Page<MtOpenGift> pageHelper = PageHelper.startPage(pageNumber, pageSize);
  173. LambdaQueryWrapper<MtOrder> lambdaQueryWrapper = Wrappers.lambdaQuery();
  174. if (StringUtil.isNotEmpty(orderSn)) {
  175. lambdaQueryWrapper.eq(MtOrder::getOrderSn, orderSn);
  176. }
  177. if (StringUtil.isNotEmpty(status)) {
  178. lambdaQueryWrapper.eq(MtOrder::getStatus, status);
  179. }
  180. if (StringUtil.isNotEmpty(payStatus)) {
  181. lambdaQueryWrapper.eq(MtOrder::getPayStatus, payStatus);
  182. }
  183. if (StringUtil.isNotEmpty(settleStatus)) {
  184. lambdaQueryWrapper.eq(MtOrder::getSettleStatus, settleStatus);
  185. }
  186. if (StringUtil.isNotEmpty(mobile)) {
  187. MtUser userInfo = memberService.queryMemberByMobile(merchantId, mobile);
  188. if (userInfo != null) {
  189. userId = userInfo.getId() + "";
  190. } else {
  191. userId = "0";
  192. }
  193. }
  194. if (StringUtil.isNotEmpty(userId)) {
  195. lambdaQueryWrapper.eq(MtOrder::getUserId, userId);
  196. }
  197. if (merchantId != null && merchantId > 0) {
  198. lambdaQueryWrapper.eq(MtOrder::getMerchantId, merchantId);
  199. }
  200. if (storeId != null && storeId > 0) {
  201. lambdaQueryWrapper.eq(MtOrder::getStoreId, storeId);
  202. }
  203. if (StringUtil.isNotEmpty(staffId)) {
  204. lambdaQueryWrapper.eq(MtOrder::getStaffId, staffId);
  205. }
  206. if (StringUtil.isNotEmpty(type)) {
  207. lambdaQueryWrapper.eq(MtOrder::getType, type);
  208. }
  209. if (StringUtil.isNotEmpty(orderMode)) {
  210. lambdaQueryWrapper.eq(MtOrder::getOrderMode, orderMode);
  211. }
  212. if (StringUtils.isNotBlank(couponId)) {
  213. lambdaQueryWrapper.eq(MtOrder::getCouponId, couponId);
  214. }
  215. if (StringUtils.isNotBlank(storeIds)) {
  216. List<String> idList = Arrays.asList(storeIds.split(","));
  217. if (idList.size() > 0) {
  218. lambdaQueryWrapper.in(MtOrder::getStoreId, idList);
  219. }
  220. }
  221. if (StringUtil.isNotEmpty(startTime)) {
  222. lambdaQueryWrapper.ge(MtOrder::getCreateTime, startTime);
  223. }
  224. if (StringUtil.isNotEmpty(endTime)) {
  225. lambdaQueryWrapper.le(MtOrder::getCreateTime, endTime);
  226. }
  227. lambdaQueryWrapper.orderByDesc(MtOrder::getId);
  228. List<MtOrder> orderList = mtOrderMapper.selectList(lambdaQueryWrapper);
  229. List<UserOrderDto> dataList = new ArrayList<>();
  230. if (orderList.size() > 0) {
  231. for (MtOrder order : orderList) {
  232. UserOrderDto dto = getOrderDetail(order,false, false);
  233. dataList.add(dto);
  234. }
  235. }
  236. PageRequest pageRequest = PageRequest.of(pageNumber, pageSize);
  237. PageImpl pageImpl = new PageImpl(dataList, pageRequest, pageHelper.getTotal());
  238. PaginationResponse<UserOrderDto> paginationResponse = new PaginationResponse(pageImpl, UserOrderDto.class);
  239. paginationResponse.setTotalPages(pageHelper.getPages());
  240. paginationResponse.setTotalElements(pageHelper.getTotal());
  241. paginationResponse.setContent(dataList);
  242. return paginationResponse;
  243. }
  244. /**
  245. * 保存订单信息
  246. *
  247. * @param orderDto 订单参数
  248. * @throws BusinessCheckException
  249. * @return
  250. */
  251. @Override
  252. @Transactional(rollbackFor = Exception.class)
  253. @OperationServiceLog(description = "提交订单信息")
  254. public MtOrder saveOrder(OrderDto orderDto) throws BusinessCheckException {
  255. logger.info("orderService.saveOrder orderDto = {}", JsonUtil.toJSONString(orderDto));
  256. MtOrder mtOrder;
  257. if (null != orderDto.getId() && orderDto.getId() > 0) {
  258. mtOrder = mtOrderMapper.selectById(orderDto.getId());
  259. } else {
  260. mtOrder = new MtOrder();
  261. }
  262. // 检查店铺是否已被禁用
  263. if (orderDto.getStoreId() != null && orderDto.getStoreId() > 0) {
  264. MtStore storeInfo = storeService.queryStoreById(orderDto.getStoreId());
  265. if (storeInfo != null) {
  266. if (!storeInfo.getStatus().equals(StatusEnum.ENABLED.getKey())) {
  267. orderDto.setStoreId(0);
  268. }
  269. }
  270. }
  271. String orderSn;
  272. if (orderDto.getId() == null || orderDto.getId() < 1) {
  273. orderSn = CommonUtil.createOrderSN(orderDto.getUserId() + "");
  274. mtOrder.setOrderSn(orderSn);
  275. } else {
  276. orderSn = mtOrder.getOrderSn();
  277. }
  278. mtOrder.setUserId(orderDto.getUserId());
  279. mtOrder.setMerchantId(orderDto.getMerchantId());
  280. mtOrder.setStoreId(orderDto.getStoreId());
  281. mtOrder.setCouponId(orderDto.getCouponId());
  282. mtOrder.setParam(orderDto.getParam());
  283. mtOrder.setRemark(orderDto.getRemark());
  284. mtOrder.setStatus(OrderStatusEnum.CREATED.getKey());
  285. mtOrder.setType(orderDto.getType());
  286. mtOrder.setAmount(orderDto.getAmount());
  287. mtOrder.setPayAmount(orderDto.getPayAmount());
  288. mtOrder.setDiscount(orderDto.getDiscount());
  289. mtOrder.setPayStatus(PayStatusEnum.WAIT.getKey());
  290. mtOrder.setPointAmount(orderDto.getPointAmount());
  291. mtOrder.setUsePoint(orderDto.getUsePoint());
  292. mtOrder.setOrderMode(orderDto.getOrderMode());
  293. mtOrder.setPayType(orderDto.getPayType());
  294. mtOrder.setOperator(orderDto.getOperator());
  295. mtOrder.setStaffId(orderDto.getStaffId());
  296. mtOrder.setIsVisitor(orderDto.getIsVisitor());
  297. mtOrder.setUpdateTime(new Date());
  298. mtOrder.setDeliveryFee(orderDto.getDeliveryFee() == null ? new BigDecimal(0) : orderDto.getDeliveryFee());
  299. mtOrder.setSettleStatus(SettleStatusEnum.WAIT.getKey());
  300. if (mtOrder.getId() == null || mtOrder.getId() <= 0) {
  301. mtOrder.setCreateTime(new Date());
  302. }
  303. // 核销码
  304. if (orderDto.getPlatform() == null) {
  305. orderDto.setPlatform("");
  306. }
  307. if (mtOrder.getVerifyCode() == null && !orderDto.getPlatform().equals(PlatformTypeEnum.PC.getCode())) {
  308. mtOrder.setVerifyCode(SeqUtil.getRandomNumber(6));
  309. }
  310. // 首先生成订单
  311. mtOrderMapper.insert(mtOrder);
  312. MtOrder orderInfo = mtOrderMapper.selectById(mtOrder.getId());
  313. mtOrder.setId(orderInfo.getId());
  314. // 会员相关信息
  315. MtUser userInfo = memberService.queryMemberById(orderDto.getUserId());
  316. MtUserGrade userGrade = userGradeService.queryUserGradeById(orderDto.getMerchantId(), userInfo.getGradeId() != null ? Integer.parseInt(userInfo.getGradeId()) : 1, orderDto.getUserId());
  317. BigDecimal percent = new BigDecimal("0");
  318. if (userGrade != null && userGrade.getDiscount() != null && userGrade.getDiscount() > 0) {
  319. // 会员折扣
  320. percent = new BigDecimal(userGrade.getDiscount()).divide(new BigDecimal("10"), BigDecimal.ROUND_CEILING, 3);
  321. if (percent.compareTo(new BigDecimal("0")) <= 0) {
  322. percent = new BigDecimal("1");
  323. }
  324. }
  325. // 如果没有指定店铺,则读取默认的店铺
  326. if (orderDto.getStoreId() == null || orderDto.getStoreId() <= 0) {
  327. Map<String, Object> params = new HashMap<>();
  328. params.put("status", StatusEnum.ENABLED.getKey());
  329. params.put("is_default", YesOrNoEnum.YES.getKey());
  330. List<MtStore> storeList = storeService.queryStoresByParams(params);
  331. if (storeList.size() > 0) {
  332. mtOrder.setStoreId(storeList.get(0).getId());
  333. } else {
  334. mtOrder.setStoreId(0);
  335. }
  336. }
  337. mtOrder.setUpdateTime(new Date());
  338. if (mtOrder.getCreateTime() == null) {
  339. mtOrder.setCreateTime(new Date());
  340. }
  341. // 计算商品订单总金额
  342. List<MtCart> cartList = new ArrayList<>();
  343. Map<String, Object> cartData = new HashMap<>();
  344. if (orderDto.getType().equals(OrderTypeEnum.GOOGS.getKey())) {
  345. Map<String, Object> param = new HashMap<>();
  346. param.put("status", StatusEnum.ENABLED.getKey());
  347. if (StringUtil.isNotEmpty(orderDto.getCartIds())) {
  348. param.put("ids", orderDto.getCartIds());
  349. }
  350. if (orderDto.getGoodsId() < 1) {
  351. cartList = cartService.queryCartListByParams(param);
  352. if (cartList.size() < 1) {
  353. throw new BusinessCheckException("生成订单失败,请稍后重试");
  354. }
  355. } else {
  356. // 直接购买
  357. MtCart mtCart = new MtCart();
  358. mtCart.setGoodsId(orderDto.getGoodsId());
  359. mtCart.setSkuId(orderDto.getSkuId());
  360. mtCart.setNum(orderDto.getBuyNum());
  361. mtCart.setId(0);
  362. mtCart.setUserId(orderDto.getUserId());
  363. mtCart.setStatus(StatusEnum.ENABLED.getKey());
  364. cartList.add(mtCart);
  365. }
  366. boolean isUsePoint = orderDto.getUsePoint() > 0 ? true : false;
  367. cartData = calculateCartGoods(orderInfo.getMerchantId(), orderDto.getUserId(), cartList, orderDto.getCouponId(), isUsePoint, orderDto.getPlatform(), orderInfo.getOrderMode());
  368. mtOrder.setAmount(new BigDecimal(cartData.get("totalPrice").toString()));
  369. mtOrder.setUsePoint(Integer.parseInt(cartData.get("usePoint").toString()));
  370. mtOrder.setDiscount(new BigDecimal(cartData.get("couponAmount").toString()));
  371. // 实付金额
  372. BigDecimal payAmount = mtOrder.getAmount().subtract(mtOrder.getPointAmount()).subtract(mtOrder.getDiscount());
  373. if (payAmount.compareTo(new BigDecimal("0")) > 0) {
  374. mtOrder.setPayAmount(payAmount);
  375. } else {
  376. mtOrder.setPayAmount(new BigDecimal("0"));
  377. }
  378. // 购物使用了卡券
  379. if (mtOrder.getCouponId() > 0) {
  380. // 查询是否适用商品
  381. MtUserCoupon userCoupon = mtUserCouponMapper.selectById(mtOrder.getCouponId());
  382. if (userCoupon != null) {
  383. MtCoupon couponInfo = couponService.queryCouponById(userCoupon.getCouponId());
  384. if (couponInfo.getApplyGoods() != null && couponInfo.getApplyGoods().equals(ApplyGoodsEnum.PARK_GOODS.getKey())) {
  385. List<MtCouponGoods> couponGoodsList = mtCouponGoodsMapper.getCouponGoods(couponInfo.getId());
  386. if (couponGoodsList != null && couponGoodsList.size() > 0 && cartList.size() > 0) {
  387. List<Integer> applyGoodsIds = new ArrayList<>();
  388. List<Integer> goodsIds = new ArrayList<>();
  389. for (MtCouponGoods mtCouponGoods : couponGoodsList) {
  390. applyGoodsIds.add(mtCouponGoods.getGoodsId());
  391. }
  392. for (MtCart mtCart : cartList) {
  393. goodsIds.add(mtCart.getGoodsId());
  394. }
  395. List<Integer> intersection = applyGoodsIds.stream()
  396. .filter(goodsIds::contains)
  397. .collect(Collectors.toList());
  398. if (intersection.size() == 0) {
  399. throw new BusinessCheckException("该卡券不适用于购买的商品列表");
  400. }
  401. }
  402. }
  403. }
  404. updateOrder(mtOrder);
  405. String useCode = couponService.useCoupon(mtOrder.getCouponId(), mtOrder.getUserId(), mtOrder.getStoreId(), mtOrder.getId(), mtOrder.getDiscount(), "购物使用卡券");
  406. // 卡券使用失败
  407. if (StringUtil.isEmpty(useCode)) {
  408. mtOrder.setDiscount(new BigDecimal("0"));
  409. mtOrder.setCouponId(0);
  410. }
  411. }
  412. }
  413. // 会员付款类订单
  414. if (orderDto.getType().equals(OrderTypeEnum.PAYMENT.getKey())) {
  415. if (userInfo != null && userInfo.getGradeId() != null && orderDto.getIsVisitor().equals(YesOrNoEnum.NO.getKey())) {
  416. if (percent.compareTo(new BigDecimal("0")) > 0) {
  417. // 会员折扣
  418. BigDecimal payAmountDiscount = mtOrder.getPayAmount().multiply(percent);
  419. if (payAmountDiscount.compareTo(new BigDecimal("0")) > 0) {
  420. mtOrder.setDiscount(mtOrder.getDiscount().add(mtOrder.getPayAmount().subtract(payAmountDiscount)));
  421. mtOrder.setPayAmount(payAmountDiscount);
  422. } else {
  423. mtOrder.setPayAmount(new BigDecimal("0"));
  424. }
  425. }
  426. }
  427. }
  428. // 再次更新订单
  429. try {
  430. orderInfo = updateOrder(mtOrder);
  431. } catch (Exception e) {
  432. logger.error("OrderService 生成订单失败...");
  433. throw new BusinessCheckException("生成订单失败,请稍后重试");
  434. }
  435. // 扣减积分
  436. if (orderDto.getUsePoint() > 0) {
  437. try {
  438. MtPoint reqPointDto = new MtPoint();
  439. reqPointDto.setUserId(orderDto.getUserId());
  440. reqPointDto.setAmount(-orderDto.getUsePoint());
  441. reqPointDto.setOrderSn(orderSn);
  442. reqPointDto.setDescription("支付扣除" + orderDto.getUsePoint() + "积分");
  443. reqPointDto.setOperator("");
  444. pointService.addPoint(reqPointDto);
  445. } catch (BusinessCheckException e) {
  446. logger.error("OrderService 扣减积分失败...{}", e.getMessage());
  447. throw new BusinessCheckException("扣减积分失败,请稍后重试");
  448. }
  449. }
  450. // 如果是商品订单,生成订单商品
  451. if (orderDto.getType().equals(OrderTypeEnum.GOOGS.getKey()) && cartList.size() > 0) {
  452. Object listObject = cartData.get("list");
  453. List<ResCartDto> lists =(ArrayList<ResCartDto>)listObject;
  454. BigDecimal memberDiscount = new BigDecimal("0");
  455. for (ResCartDto cart : lists) {
  456. MtOrderGoods orderGoods = new MtOrderGoods();
  457. orderGoods.setOrderId(orderInfo.getId());
  458. orderGoods.setGoodsId(cart.getGoodsId());
  459. orderGoods.setSkuId(cart.getSkuId());
  460. orderGoods.setNum(cart.getNum());
  461. // 计算会员折扣
  462. BigDecimal price = cart.getGoodsInfo().getPrice();
  463. boolean isDiscount = cart.getGoodsInfo().getIsMemberDiscount().equals(YesOrNoEnum.YES.getKey()) ? true : false;
  464. if (percent.compareTo(new BigDecimal("0")) > 0 && isDiscount) {
  465. orderGoods.setPrice(price.multiply(percent));
  466. BigDecimal discount = price.subtract(price.multiply(percent)).multiply(new BigDecimal(cart.getNum()));
  467. orderGoods.setDiscount(discount);
  468. memberDiscount = memberDiscount.add(discount);
  469. } else {
  470. orderGoods.setPrice(price);
  471. orderGoods.setDiscount(new BigDecimal("0"));
  472. }
  473. orderGoods.setStatus(StatusEnum.ENABLED.getKey());
  474. orderGoods.setCreateTime(new Date());
  475. orderGoods.setUpdateTime(new Date());
  476. mtOrderGoodsMapper.insert(orderGoods);
  477. // 扣减库存
  478. MtGoods goodsInfo = mtGoodsMapper.selectById(cart.getGoodsId());
  479. if (goodsInfo.getIsSingleSpec().equals(YesOrNoEnum.YES.getKey())) {
  480. // 单规格减去库存
  481. Integer stock = goodsInfo.getStock() - cart.getNum();
  482. if (stock < 0) {
  483. throw new BusinessCheckException("商品“" + goodsInfo.getName() + "”库存不足,订单提交失败");
  484. }
  485. goodsInfo.setStock(stock);
  486. mtGoodsMapper.updateById(goodsInfo);
  487. } else {
  488. // 多规格减去库存
  489. MtGoodsSku mtGoodsSku = mtGoodsSkuMapper.selectById(cart.getSkuId());
  490. if (mtGoodsSku != null) {
  491. Integer stock = mtGoodsSku.getStock() - cart.getNum();
  492. if (stock < 0) {
  493. throw new BusinessCheckException("商品sku编码“" + mtGoodsSku.getSkuNo() +"”库存不足,订单提交失败");
  494. }
  495. mtGoodsSku.setStock(stock);
  496. mtGoodsSkuMapper.updateById(mtGoodsSku);
  497. if (goodsInfo.getStock() != null && goodsInfo.getStock() > 0) {
  498. Integer goodsStock = goodsInfo.getStock() - cart.getNum();
  499. if (goodsStock >= 0) {
  500. goodsInfo.setStock(goodsStock);
  501. mtGoodsMapper.updateById(goodsInfo);
  502. }
  503. }
  504. }
  505. }
  506. if (cart.getId() > 0) {
  507. mtCartMapper.deleteById(cart.getId());
  508. }
  509. }
  510. // 会员折扣
  511. if (memberDiscount.compareTo(new BigDecimal("0")) > 0) {
  512. orderInfo.setDiscount(orderInfo.getDiscount().add(memberDiscount));
  513. if (orderInfo.getPayAmount().subtract(memberDiscount).compareTo(new BigDecimal("0")) > 0) {
  514. orderInfo.setPayAmount(orderInfo.getPayAmount().subtract(memberDiscount));
  515. } else {
  516. orderInfo.setPayAmount(new BigDecimal("0"));
  517. }
  518. orderInfo.setUpdateTime(new Date());
  519. orderInfo = updateOrder(orderInfo);
  520. }
  521. // 需要配送的订单,生成配送地址
  522. if (orderDto.getOrderMode().equals(OrderModeEnum.EXPRESS.getKey())) {
  523. Map<String, Object> params = new HashMap<>();
  524. params.put("userId", orderDto.getUserId().toString());
  525. params.put("isDefault", YesOrNoEnum.YES.getKey());
  526. List<MtAddress> addressList = addressService.queryListByParams(params);
  527. MtAddress mtAddress;
  528. if (addressList.size() > 0) {
  529. mtAddress = addressList.get(0);
  530. } else {
  531. throw new BusinessCheckException("配送地址出错了,请重新选择配送地址");
  532. }
  533. MtOrderAddress orderAddress = new MtOrderAddress();
  534. orderAddress.setOrderId(orderInfo.getId());
  535. orderAddress.setUserId(orderDto.getUserId());
  536. orderAddress.setName(mtAddress.getName());
  537. orderAddress.setMobile(mtAddress.getMobile());
  538. orderAddress.setCityId(mtAddress.getCityId());
  539. orderAddress.setProvinceId(mtAddress.getProvinceId());
  540. orderAddress.setRegionId(mtAddress.getRegionId());
  541. orderAddress.setDetail(mtAddress.getDetail());
  542. orderAddress.setCreateTime(new Date());
  543. mtOrderAddressMapper.insert(orderAddress);
  544. }
  545. }
  546. return orderInfo;
  547. }
  548. /**
  549. * 订单结算
  550. * @param request
  551. * @param param 结算参数
  552. * @throws BusinessCheckException
  553. * @return
  554. * */
  555. @Override
  556. @Transactional(rollbackFor = Exception.class)
  557. public Map<String, Object> doSettle(HttpServletRequest request, SettlementParam param) throws BusinessCheckException {
  558. String token = request.getHeader("Access-Token");
  559. Integer storeId = request.getHeader("storeId") == null ? 0 : Integer.parseInt(request.getHeader("storeId"));
  560. String platform = request.getHeader("platform") == null ? "" : request.getHeader("platform");
  561. String merchantNo = request.getHeader("merchantNo") == null ? "" : request.getHeader("merchantNo");
  562. String isWechat = param.getIsWechat() == null ? YesOrNoEnum.NO.getKey() : param.getIsWechat();
  563. String cartIds = param.getCartIds() == null ? "" : param.getCartIds();
  564. Integer targetId = param.getTargetId() == null ? 0 : Integer.parseInt(param.getTargetId()); // 储值卡、升级等级必填
  565. String selectNum = param.getSelectNum() == null ? "" : param.getSelectNum(); // 储值卡必填
  566. String remark = param.getRemark() == null ? "" : param.getRemark();
  567. String type = param.getType() == null ? "" : param.getType(); // 订单类型
  568. String payAmount = param.getPayAmount() == null ? "0" : StringUtil.isEmpty(param.getPayAmount()) ? "0" : param.getPayAmount(); // 支付金额
  569. Integer usePoint = param.getUsePoint() == null ? 0 : param.getUsePoint(); // 使用积分数量
  570. Integer couponId = param.getCouponId() == null ? 0 : param.getCouponId(); // 会员卡券ID
  571. String payType = param.getPayType() == null ? PayTypeEnum.JSAPI.getKey() : param.getPayType();
  572. String authCode = param.getAuthCode() == null ? "" : param.getAuthCode();
  573. Integer userId = param.getUserId() == null ? 0 : param.getUserId(); // 指定下单会员 eg:收银功能
  574. String cashierPayAmount = param.getCashierPayAmount() == null ? "" : param.getCashierPayAmount(); // 收银台实付金额
  575. String cashierDiscountAmount = param.getCashierDiscountAmount() == null ? "" : param.getCashierDiscountAmount(); // 收银台优惠金额
  576. Integer goodsId = param.getGoodsId() == null ? 0 : param.getGoodsId(); // 立即购买商品ID
  577. Integer skuId = param.getSkuId() == null ? 0 : param.getSkuId(); // 立即购买商品skuId
  578. Integer buyNum = param.getBuyNum() == null ? 1 : param.getBuyNum(); // 立即购买商品数量
  579. String orderMode = param.getOrderMode()== null ? OrderModeEnum.ONESELF.getKey() : param.getOrderMode(); // 订单模式(配送or自取)
  580. Integer orderId = param.getOrderId() == null ? null : param.getOrderId(); // 订单ID
  581. Integer merchantId = merchantService.getMerchantId(merchantNo);
  582. UserInfo loginInfo = TokenUtil.getUserInfoByToken(token);
  583. MtUser userInfo = null;
  584. if (loginInfo != null) {
  585. userInfo = memberService.queryMemberById(loginInfo.getId());
  586. }
  587. // 后台管理员或店员操作
  588. String operator = null;
  589. Integer staffId = 0;
  590. String isVisitor = YesOrNoEnum.NO.getKey();
  591. AccountInfo accountInfo = TokenUtil.getAccountInfoByToken(token);
  592. if (accountInfo != null) {
  593. operator = accountInfo.getAccountName();
  594. staffId = accountInfo.getStaffId() == null ? 0 : accountInfo.getStaffId();
  595. storeId = accountInfo.getStoreId();
  596. merchantId = accountInfo.getMerchantId();
  597. if (storeId <= 0) {
  598. MtMerchant mtMerchant = merchantService.queryMerchantById(merchantId);
  599. if (mtMerchant != null) {
  600. MtStore mtStore = storeService.getDefaultStore(mtMerchant.getNo());
  601. if (mtStore != null) {
  602. storeId = mtStore.getId();
  603. }
  604. }
  605. }
  606. if (userId < 1) {
  607. isVisitor = YesOrNoEnum.YES.getKey();
  608. }
  609. }
  610. if (userInfo == null) {
  611. MtUser user = memberService.getCurrentUserInfo(request, userId, token);
  612. if (user != null) {
  613. userInfo = memberService.queryMemberById(user.getId());
  614. }
  615. } else {
  616. MtStaff mtStaff = staffService.queryStaffByUserId(userInfo.getId());
  617. if (mtStaff == null) {
  618. mtStaff = staffService.queryStaffByMobile(userInfo.getMobile());
  619. }
  620. if (mtStaff != null) {
  621. operator = mtStaff.getRealName();
  622. }
  623. }
  624. MtSetting config = settingService.querySettingByName(merchantId, OrderSettingEnum.IS_CLOSE.getKey());
  625. if (config != null && config.getValue().equals(YesOrNoEnum.TRUE.getKey())) {
  626. throw new BusinessCheckException("系统已关闭交易功能,请稍后再试!");
  627. }
  628. // 收银台通过手机号自动注册会员信息
  629. if ((userInfo == null || StringUtil.isEmpty(token))) {
  630. String mobile = param.getMobile() == null ? "" : param.getMobile();
  631. if (StringUtil.isNotEmpty(operator) && StringUtil.isNotEmpty(mobile)) {
  632. userInfo = memberService.queryMemberByMobile(merchantId, mobile);
  633. // 自动注册会员
  634. if (userInfo == null) {
  635. userInfo = memberService.addMemberByMobile(merchantId, mobile);
  636. }
  637. }
  638. }
  639. if (userInfo == null) {
  640. if (StringUtil.isNotEmpty(operator)) {
  641. throw new BusinessCheckException("该管理员还未关联店铺员工");
  642. } else {
  643. throw new BusinessCheckException("请先登录");
  644. }
  645. }
  646. if (userId <= 0) {
  647. userId = userInfo.getId();
  648. } else {
  649. if (StringUtil.isNotEmpty(operator)) {
  650. userInfo = memberService.queryMemberById(userId);
  651. }
  652. }
  653. param.setUserId(userId);
  654. // 订单所属店铺
  655. if (storeId < 1) {
  656. if (userInfo.getStoreId() > 0) {
  657. storeId = userInfo.getStoreId();
  658. }
  659. }
  660. // 生成订单数据
  661. OrderDto orderDto = new OrderDto();
  662. orderDto.setId(orderId);
  663. orderDto.setRemark(remark);
  664. orderDto.setUserId(userId);
  665. orderDto.setMerchantId(merchantId);
  666. orderDto.setStoreId(storeId);
  667. orderDto.setType(type);
  668. orderDto.setGoodsId(goodsId);
  669. orderDto.setSkuId(skuId);
  670. orderDto.setBuyNum(buyNum);
  671. orderDto.setOrderMode(orderMode);
  672. orderDto.setOperator(operator);
  673. orderDto.setPayType(payType);
  674. orderDto.setCouponId(0);
  675. orderDto.setStaffId(staffId);
  676. orderDto.setIsVisitor(isVisitor);
  677. orderDto.setPlatform(platform);
  678. MtSetting pointSetting = settingService.querySettingByName(merchantId, PointSettingEnum.CAN_USE_AS_MONEY.getKey());
  679. // 使用积分数量
  680. if (pointSetting != null && pointSetting.getValue().equals(YesOrNoEnum.TRUE.getKey())) {
  681. orderDto.setUsePoint(usePoint);
  682. } else {
  683. orderDto.setUsePoint(0);
  684. usePoint = 0;
  685. }
  686. orderDto.setPointAmount(new BigDecimal("0"));
  687. orderDto.setDiscount(new BigDecimal("0"));
  688. orderDto.setPayAmount(new BigDecimal("0"));
  689. orderDto.setAmount(new BigDecimal("0"));
  690. orderDto.setCartIds(cartIds);
  691. // 储值卡的订单
  692. if (orderDto.getType().equals(OrderTypeEnum.PRESTORE.getKey())) {
  693. orderDto.setCouponId(targetId);
  694. String orderParam = "";
  695. BigDecimal totalAmount = new BigDecimal(0);
  696. MtCoupon couponInfo = couponService.queryCouponById(targetId);
  697. String inRule = couponInfo.getInRule();
  698. String[] selectNumArr = selectNum.split(",");
  699. String[] ruleArr = inRule.split(",");
  700. for (int i = 0; i < ruleArr.length; i++) {
  701. String item = ruleArr[i] + "_" + (StringUtil.isNotEmpty(selectNumArr[i]) ? selectNumArr[i] : 0);
  702. String[] itemArr = item.split("_");
  703. // 预存金额
  704. BigDecimal price = new BigDecimal(itemArr[0]);
  705. // 预存数量
  706. BigDecimal num = new BigDecimal(selectNumArr[i]);
  707. BigDecimal amount = price.multiply(num);
  708. totalAmount = totalAmount.add(amount);
  709. orderParam = StringUtil.isEmpty(orderParam) ? item : orderParam + ","+item;
  710. }
  711. orderDto.setParam(orderParam);
  712. orderDto.setAmount(totalAmount);
  713. payAmount = totalAmount.toString();
  714. }
  715. // 付款订单
  716. if (orderDto.getType().equals(OrderTypeEnum.PAYMENT.getKey())) {
  717. orderDto.setAmount(new BigDecimal(payAmount));
  718. orderDto.setPayAmount(new BigDecimal(payAmount));
  719. orderDto.setDiscount(new BigDecimal("0"));
  720. }
  721. // 会员升级订单
  722. if (orderDto.getType().equals(OrderTypeEnum.MEMBER.getKey())) {
  723. orderDto.setParam(targetId.toString());
  724. orderDto.setCouponId(couponId);
  725. MtUserGrade userGrade = userGradeService.queryUserGradeById(merchantId, targetId, orderDto.getUserId());
  726. if (userGrade != null) {
  727. orderDto.setRemark("付费升级" + userGrade.getName());
  728. orderDto.setAmount(new BigDecimal(userGrade.getCatchValue().toString()));
  729. }
  730. }
  731. // 商品订单
  732. if (orderDto.getType().equals(OrderTypeEnum.GOOGS.getKey())) {
  733. orderDto.setCouponId(couponId);
  734. }
  735. // 商品订单且配送要加上配送费用
  736. if (orderDto.getType().equals(OrderTypeEnum.GOOGS.getKey()) && orderDto.getOrderMode().equals(OrderModeEnum.EXPRESS.getKey())) {
  737. MtSetting mtSetting = settingService.querySettingByName(merchantId, OrderSettingEnum.DELIVERY_FEE.getKey());
  738. if (mtSetting != null && StringUtil.isNotEmpty(mtSetting.getValue())) {
  739. BigDecimal deliveryFee = new BigDecimal(mtSetting.getValue());
  740. if (deliveryFee.compareTo(new BigDecimal("0")) > 0) {
  741. orderDto.setDeliveryFee(deliveryFee);
  742. }
  743. }
  744. }
  745. // 使用积分抵扣
  746. if (usePoint > 0) {
  747. List<MtSetting> settingList = settingService.getSettingList(merchantId, SettingTypeEnum.POINT.getKey());
  748. String canUsedAsMoney = YesOrNoEnum.FALSE.getKey();
  749. String exchangeNeedPoint = "0";
  750. for (MtSetting setting : settingList) {
  751. if (setting.getName().equals("canUsedAsMoney")) {
  752. canUsedAsMoney = setting.getValue();
  753. } else if (setting.getName().equals("exchangeNeedPoint")) {
  754. exchangeNeedPoint = setting.getValue();
  755. }
  756. }
  757. // 是否可以使用积分,并且积分数量足够
  758. if (canUsedAsMoney.equals(YesOrNoEnum.TRUE.getKey()) && Float.parseFloat(exchangeNeedPoint) > 0 && (userInfo.getPoint() >= usePoint)) {
  759. orderDto.setUsePoint(usePoint);
  760. orderDto.setPointAmount(new BigDecimal(usePoint).divide(new BigDecimal(exchangeNeedPoint), BigDecimal.ROUND_CEILING, 3));
  761. if (orderDto.getPayAmount().compareTo(orderDto.getPointAmount()) > 0) {
  762. orderDto.setPayAmount(orderDto.getPayAmount().subtract(orderDto.getPointAmount()));
  763. } else {
  764. orderDto.setPayAmount(new BigDecimal("0"));
  765. }
  766. }
  767. }
  768. // 首先生成订单,拿到订单ID
  769. MtOrder orderInfo;
  770. try {
  771. orderInfo = saveOrder(orderDto);
  772. } catch (BusinessCheckException e) {
  773. throw new BusinessCheckException(e.getMessage() == null ? "生成订单失败" : e.getMessage());
  774. }
  775. orderDto.setId(orderInfo.getId());
  776. param.setOrderId(orderInfo.getId());
  777. // 收银台实付金额、优惠金额
  778. if ((StringUtil.isNotEmpty(cashierPayAmount) || StringUtil.isNotEmpty(cashierDiscountAmount)) && StringUtil.isNotEmpty(operator)) {
  779. OrderDto reqOrder = new OrderDto();
  780. reqOrder.setId(orderInfo.getId());
  781. if (orderInfo.getAmount().compareTo(new BigDecimal("0")) <= 0) {
  782. reqOrder.setAmount(new BigDecimal(cashierPayAmount).add(new BigDecimal(cashierDiscountAmount)));
  783. } else {
  784. reqOrder.setAmount(orderInfo.getAmount());
  785. }
  786. if (new BigDecimal(cashierDiscountAmount).compareTo(new BigDecimal("0")) > 0) {
  787. reqOrder.setDiscount(new BigDecimal(cashierDiscountAmount).add(orderInfo.getDiscount()));
  788. } else {
  789. reqOrder.setDiscount(orderInfo.getDiscount());
  790. }
  791. BigDecimal realPayAmount = reqOrder.getAmount().subtract(reqOrder.getDiscount());
  792. if (realPayAmount.compareTo(new BigDecimal("0")) < 0) {
  793. realPayAmount = new BigDecimal("0");
  794. }
  795. reqOrder.setPayAmount(realPayAmount);
  796. updateOrder(reqOrder);
  797. orderInfo = getOrderInfo(orderInfo.getId());
  798. }
  799. // 订单中使用卡券抵扣(付款订单、会员升级订单)
  800. if (couponId > 0 && (orderDto.getType().equals(OrderTypeEnum.PAYMENT.getKey())) || orderDto.getType().equals(OrderTypeEnum.MEMBER.getKey())) {
  801. if (orderDto.getAmount().compareTo(new BigDecimal("0")) > 0) {
  802. MtUserCoupon userCouponInfo = userCouponService.getUserCouponDetail(couponId);
  803. if (userCouponInfo != null) {
  804. MtCoupon couponInfo = couponService.queryCouponById(userCouponInfo.getCouponId());
  805. if (couponInfo != null) {
  806. boolean isEffective = couponService.isCouponEffective(couponInfo, userCouponInfo);
  807. if (isEffective && userCouponInfo.getUserId().equals(orderDto.getUserId())) {
  808. // 优惠券,直接减去优惠券金额
  809. if (couponInfo.getType().equals(CouponTypeEnum.COUPON.getKey())) {
  810. // 检查是否会员升级专用卡券
  811. boolean canUse = true;
  812. if (couponInfo.getUseFor() != null && StringUtil.isNotEmpty(couponInfo.getUseFor())) {
  813. if (orderDto.getType().equals(OrderTypeEnum.MEMBER.getKey())) {
  814. if (!couponInfo.getUseFor().equals(CouponUseForEnum.MEMBER_GRADE.getKey())) {
  815. canUse = false;
  816. }
  817. }
  818. }
  819. if (canUse) {
  820. String useCode = couponService.useCoupon(couponId, orderDto.getUserId(), orderDto.getStoreId(), orderInfo.getId(), userCouponInfo.getAmount(), "核销");
  821. if (StringUtil.isNotEmpty(useCode)) {
  822. orderDto.setCouponId(couponId);
  823. orderDto.setDiscount(orderInfo.getDiscount().add(userCouponInfo.getAmount()));
  824. updateOrder(orderDto);
  825. }
  826. }
  827. } else if(couponInfo.getType().equals(CouponTypeEnum.PRESTORE.getKey())) {
  828. // 储值卡,减去余额
  829. BigDecimal useCouponAmount = userCouponInfo.getBalance();
  830. if (orderInfo.getPayAmount().compareTo(userCouponInfo.getBalance()) <= 0) {
  831. useCouponAmount = orderInfo.getPayAmount();
  832. }
  833. try {
  834. String useCode = couponService.useCoupon(couponId, orderDto.getUserId(), orderDto.getStoreId(), orderInfo.getId(), useCouponAmount, "核销");
  835. if (StringUtil.isNotEmpty(useCode)) {
  836. orderDto.setCouponId(couponId);
  837. orderDto.setDiscount(orderInfo.getDiscount().add(useCouponAmount));
  838. orderDto.setPayAmount(orderInfo.getPayAmount().subtract(useCouponAmount));
  839. updateOrder(orderDto);
  840. }
  841. } catch (BusinessCheckException e) {
  842. throw new BusinessCheckException(e.getMessage() == null ? "生成订单失败" : e.getMessage());
  843. }
  844. }
  845. }
  846. }
  847. }
  848. }
  849. }
  850. // 生成支付订单
  851. orderInfo = getOrderInfo(orderInfo.getId());
  852. String ip = CommonUtil.getIPFromHttpRequest(request);
  853. BigDecimal realPayAmount = orderInfo.getAmount().subtract(new BigDecimal(orderInfo.getDiscount().toString())).subtract(new BigDecimal(orderInfo.getPointAmount().toString())).add(orderInfo.getDeliveryFee());
  854. // 支付类的订单,检查余额是否充足
  855. if (type.equals(OrderTypeEnum.PAYMENT.getKey()) && payType.equals(PayTypeEnum.BALANCE.getKey())) {
  856. if (userInfo.getBalance() == null || realPayAmount.compareTo(userInfo.getBalance()) > 0) {
  857. throw new BusinessCheckException("会员余额不足");
  858. }
  859. if (StringUtil.isNotEmpty(cashierPayAmount)) {
  860. if (userInfo.getBalance() == null || new BigDecimal(cashierPayAmount).compareTo(userInfo.getBalance()) > 0) {
  861. throw new BusinessCheckException("会员余额不足");
  862. }
  863. }
  864. }
  865. ResponseObject paymentInfo = null;
  866. String errorMessage = "";
  867. // 应付金额大于0才提交微信支付
  868. if (realPayAmount.compareTo(new BigDecimal("0")) > 0) {
  869. if (payType.equals(PayTypeEnum.CASH.getKey()) && StringUtil.isNotEmpty(operator)) {
  870. // 收银台现金支付,更新为已支付
  871. setOrderPayed(orderInfo.getId(), null);
  872. } else if(payType.equals(PayTypeEnum.BALANCE.getKey())) {
  873. // 余额支付
  874. MtBalance balance = new MtBalance();
  875. balance.setMobile(userInfo.getMobile());
  876. balance.setOrderSn(orderInfo.getOrderSn());
  877. balance.setUserId(userInfo.getId());
  878. balance.setMerchantId(userInfo.getMerchantId());
  879. BigDecimal balanceAmount = realPayAmount.subtract(realPayAmount).subtract(realPayAmount);
  880. balance.setAmount(balanceAmount);
  881. boolean isPay = balanceService.addBalance(balance, true);
  882. if (isPay) {
  883. setOrderPayed(orderInfo.getId(), realPayAmount);
  884. } else {
  885. errorMessage = PropertiesUtil.getResponseErrorMessageByCode(5001);
  886. }
  887. } else {
  888. BigDecimal wxPayAmount = realPayAmount.multiply(new BigDecimal("100"));
  889. // 扫码支付,先返回不处理,后面拿到支付二维码再处理
  890. if ((payType.equals(PayTypeEnum.MICROPAY.getKey()) || payType.equals(PayTypeEnum.ALISCAN.getKey())) && StringUtil.isEmpty(authCode)) {
  891. paymentInfo = new ResponseObject(200, "请求成功", new HashMap<>());
  892. } else {
  893. paymentInfo = paymentService.createPrepayOrder(userInfo, orderInfo, (wxPayAmount.intValue()), authCode, 0, ip, platform, isWechat);
  894. }
  895. if (paymentInfo.getData() == null) {
  896. errorMessage = StringUtil.isNotEmpty(paymentInfo.getMessage()) ? paymentInfo.getMessage() : PropertiesUtil.getResponseErrorMessageByCode(3000);
  897. }
  898. }
  899. } else {
  900. // 应付金额是0,直接更新为已支付
  901. setOrderPayed(orderInfo.getId(), null);
  902. }
  903. orderInfo = getOrderInfo(orderInfo.getId());
  904. Map<String, Object> outParams = new HashMap();
  905. outParams.put("isCreated", true);
  906. outParams.put("orderInfo", orderInfo);
  907. if (paymentInfo != null) {
  908. outParams.put("payment", paymentInfo.getData());
  909. outParams.put("payType", payType);
  910. } else {
  911. outParams.put("payment", null);
  912. outParams.put("payType", "BALANCE");
  913. }
  914. // 1分钟后发送小程序订阅消息
  915. Date nowTime = new Date();
  916. Date sendTime = new Date(nowTime.getTime() + 60000);
  917. Map<String, Object> params = new HashMap<>();
  918. String dateTime = DateUtil.formatDate(Calendar.getInstance().getTime(), "yyyy-MM-dd HH:mm");
  919. params.put("time", dateTime);
  920. params.put("orderSn", orderInfo.getOrderSn());
  921. params.put("remark", "您的订单已生成,请留意~");
  922. weixinService.sendSubscribeMessage(merchantId, userInfo.getId(), userInfo.getOpenId(), WxMessageEnum.ORDER_CREATED.getKey(), "pages/order/index", params, sendTime);
  923. if (StringUtil.isNotEmpty(errorMessage)) {
  924. throw new BusinessCheckException(errorMessage);
  925. } else {
  926. return outParams;
  927. }
  928. }
  929. /**
  930. * 获取订单详情
  931. *
  932. * @param orderId 订单ID
  933. * @throws BusinessCheckException
  934. * @return
  935. */
  936. @Override
  937. public MtOrder getOrderInfo(Integer orderId) {
  938. return mtOrderMapper.selectById(orderId);
  939. }
  940. /**
  941. * 根据ID获取订单详情
  942. *
  943. * @param orderId 订单ID
  944. * @throws BusinessCheckException
  945. * @return
  946. */
  947. @Override
  948. public UserOrderDto getOrderById(Integer orderId) throws BusinessCheckException {
  949. MtOrder mtOrder = mtOrderMapper.selectById(orderId);
  950. return getOrderDetail(mtOrder, true, true);
  951. }
  952. /**
  953. * 根据ID获取我的订单详情
  954. *
  955. * @param orderId 订单ID
  956. * @throws BusinessCheckException
  957. * @return
  958. */
  959. @Override
  960. public UserOrderDto getMyOrderById(Integer orderId) throws BusinessCheckException {
  961. MtOrder mtOrder = mtOrderMapper.selectById(orderId);
  962. UserOrderDto orderInfo = getOrderDetail(mtOrder, true, true);
  963. // 售后订单
  964. MtRefund refund = refundService.getRefundByOrderId(orderId);
  965. orderInfo.setRefundInfo(refund);
  966. orderInfo.setVerifyCode(mtOrder.getVerifyCode());
  967. return orderInfo;
  968. }
  969. /**
  970. * 取消订单
  971. *
  972. * @param orderId 订单ID
  973. * @param remark 取消备注
  974. * @throws BusinessCheckException
  975. * @return
  976. * */
  977. @Override
  978. @Transactional(rollbackFor = Exception.class)
  979. @OperationServiceLog(description = "取消订单")
  980. public MtOrder cancelOrder(Integer orderId, String remark) throws BusinessCheckException {
  981. MtOrder mtOrder = mtOrderMapper.selectById(orderId);
  982. logger.info("orderService.cancelOrder orderId = {}, remark = {}", orderId, remark);
  983. if (mtOrder != null && mtOrder.getStatus().equals(OrderStatusEnum.CREATED.getKey()) && mtOrder.getPayStatus().equals(PayStatusEnum.WAIT.getKey())) {
  984. if (StringUtil.isNotEmpty(remark)) {
  985. mtOrder.setRemark(remark);
  986. }
  987. mtOrder.setStatus(OrderStatusEnum.CANCEL.getKey());
  988. mtOrderMapper.updateById(mtOrder);
  989. // 返还积分
  990. if (mtOrder.getPointAmount() != null && mtOrder.getUsePoint() > 0) {
  991. MtPoint reqPointDto = new MtPoint();
  992. reqPointDto.setUserId(mtOrder.getUserId());
  993. reqPointDto.setAmount(mtOrder.getUsePoint());
  994. reqPointDto.setDescription("订单取消" + mtOrder.getOrderSn() + "退回"+ mtOrder.getUsePoint() +"积分");
  995. reqPointDto.setOrderSn(mtOrder.getOrderSn());
  996. reqPointDto.setOperator("");
  997. pointService.addPoint(reqPointDto);
  998. }
  999. // 返还卡券
  1000. List<MtConfirmLog> confirmLogList = mtConfirmLogMapper.getOrderConfirmLogList(mtOrder.getId());
  1001. if (confirmLogList.size() > 0) {
  1002. for (MtConfirmLog log : confirmLogList) {
  1003. MtCoupon couponInfo = couponService.queryCouponById(log.getCouponId());
  1004. MtUserCoupon userCouponInfo = mtUserCouponMapper.selectById(log.getUserCouponId());
  1005. if (userCouponInfo != null) {
  1006. // 优惠券直接置为未使用
  1007. if (couponInfo.getType().equals(CouponTypeEnum.COUPON.getKey())) {
  1008. userCouponInfo.setStatus(UserCouponStatusEnum.UNUSED.getKey());
  1009. mtUserCouponMapper.updateById(userCouponInfo);
  1010. }
  1011. // 储值卡把余额加回去
  1012. if (couponInfo.getType().equals(CouponTypeEnum.PRESTORE.getKey())) {
  1013. BigDecimal balance = userCouponInfo.getBalance();
  1014. BigDecimal newBalance = balance.add(log.getAmount());
  1015. if (newBalance.compareTo(userCouponInfo.getAmount()) <= 0) {
  1016. userCouponInfo.setBalance(newBalance);
  1017. userCouponInfo.setStatus(UserCouponStatusEnum.UNUSED.getKey());
  1018. }
  1019. mtUserCouponMapper.updateById(userCouponInfo);
  1020. }
  1021. // 撤销核销记录
  1022. log.setStatus(StatusEnum.DISABLE.getKey());
  1023. mtConfirmLogMapper.updateById(log);
  1024. }
  1025. }
  1026. }
  1027. // 返还库存
  1028. Map<String, Object> params = new HashMap<>();
  1029. params.put("ORDER_ID", mtOrder.getId());
  1030. List<MtOrderGoods> orderGoodsList = mtOrderGoodsMapper.selectByMap(params);
  1031. if (orderGoodsList != null && orderGoodsList.size() > 0) {
  1032. for (MtOrderGoods mtOrderGoods : orderGoodsList) {
  1033. MtGoods mtGoods = mtGoodsMapper.selectById(mtOrderGoods.getGoodsId());
  1034. // 商品已不存在
  1035. if (mtGoods == null) {
  1036. continue;
  1037. }
  1038. mtGoods.setStock(mtOrderGoods.getNum() + mtGoods.getStock());
  1039. mtGoodsMapper.updateById(mtGoods);
  1040. if (mtOrderGoods.getSkuId() != null && mtOrderGoods.getSkuId() > 0) {
  1041. MtGoodsSku mtGoodsSku = mtGoodsSkuMapper.selectById(mtOrderGoods.getSkuId());
  1042. if (mtGoodsSku != null && mtGoodsSku.getStock() != null && mtOrderGoods.getNum() != null) {
  1043. mtGoodsSku.setStock(mtGoodsSku.getStock() + mtOrderGoods.getNum());
  1044. mtGoodsSkuMapper.updateById(mtGoodsSku);
  1045. }
  1046. }
  1047. }
  1048. }
  1049. }
  1050. return mtOrder;
  1051. }
  1052. /**
  1053. * 根据订单ID删除
  1054. *
  1055. * @param orderId 订单ID
  1056. * @param operator 操作人
  1057. * @return
  1058. */
  1059. @Override
  1060. @OperationServiceLog(description = "删除订单信息")
  1061. public void deleteOrder(Integer orderId, String operator) {
  1062. logger.info("orderService.deleteOrder orderId = {}, operator = {}", orderId, operator);
  1063. MtOrder mtOrder = mtOrderMapper.selectById(orderId);
  1064. if (mtOrder == null) {
  1065. return;
  1066. }
  1067. mtOrder.setStatus(OrderStatusEnum.DELETED.getKey());
  1068. mtOrder.setUpdateTime(new Date());
  1069. mtOrder.setOperator(operator);
  1070. mtOrderMapper.updateById(mtOrder);
  1071. }
  1072. /**
  1073. * 根据订单号获取订单详情
  1074. *
  1075. * @param orderSn 订单号
  1076. * @throws BusinessCheckException
  1077. * @return
  1078. */
  1079. @Override
  1080. public UserOrderDto getOrderByOrderSn(String orderSn) throws BusinessCheckException {
  1081. MtOrder orderInfo = mtOrderMapper.findByOrderSn(orderSn);
  1082. if (orderInfo == null) {
  1083. return null;
  1084. }
  1085. return getOrderDetail(orderInfo, true, true);
  1086. }
  1087. /**
  1088. * 更新订单
  1089. *
  1090. * @param orderDto 订单参数
  1091. * @throws BusinessCheckException
  1092. * @return
  1093. */
  1094. @Override
  1095. @Transactional(rollbackFor = Exception.class)
  1096. @OperationServiceLog(description = "更新订单信息")
  1097. public MtOrder updateOrder(OrderDto orderDto) throws BusinessCheckException {
  1098. logger.info("orderService.updateOrder orderDto = {}", JsonUtil.toJSONString(orderDto));
  1099. MtOrder mtOrder = mtOrderMapper.selectById(orderDto.getId());
  1100. if (null == mtOrder || OrderStatusEnum.DELETED.getKey().equals(mtOrder.getStatus())) {
  1101. throw new BusinessCheckException("该订单状态异常");
  1102. }
  1103. mtOrder.setId(orderDto.getId());
  1104. mtOrder.setUpdateTime(new Date());
  1105. if (null != orderDto.getOperator()) {
  1106. mtOrder.setOperator(orderDto.getOperator());
  1107. }
  1108. if (null != orderDto.getStatus()) {
  1109. if (orderDto.getStatus().equals(OrderStatusEnum.CANCEL.getKey()) || orderDto.getStatus().equals(OrderStatusEnum.CREATED.getKey())) {
  1110. orderDto.setPayStatus(PayStatusEnum.WAIT.getKey());
  1111. }
  1112. if (orderDto.getStatus().equals(OrderStatusEnum.CANCEL.getKey())) {
  1113. cancelOrder(orderDto.getId(), "取消订单");
  1114. } else {
  1115. mtOrder.setStatus(orderDto.getStatus());
  1116. }
  1117. if (orderDto.getStatus().equals(OrderStatusEnum.PAID.getKey())) {
  1118. mtOrder.setPayStatus(PayStatusEnum.SUCCESS.getKey());
  1119. mtOrder.setPayTime(new Date());
  1120. }
  1121. }
  1122. if (null != orderDto.getPayAmount()) {
  1123. mtOrder.setPayAmount(orderDto.getPayAmount());
  1124. }
  1125. if (null != orderDto.getAmount()) {
  1126. mtOrder.setAmount(orderDto.getAmount());
  1127. }
  1128. if (null != orderDto.getVerifyCode() && StringUtil.isNotEmpty(orderDto.getVerifyCode())) {
  1129. if (orderDto.getVerifyCode().equals(mtOrder.getVerifyCode())) {
  1130. mtOrder.setStatus(OrderStatusEnum.DELIVERED.getKey());
  1131. mtOrder.setVerifyCode("");
  1132. } else {
  1133. throw new BusinessCheckException("核销码错误,请确认!");
  1134. }
  1135. }
  1136. if (null != orderDto.getDiscount()) {
  1137. mtOrder.setDiscount(orderDto.getDiscount());
  1138. }
  1139. if (null != orderDto.getPayTime()) {
  1140. mtOrder.setPayTime(orderDto.getPayTime());
  1141. }
  1142. if (null != orderDto.getPayStatus()) {
  1143. mtOrder.setPayStatus(orderDto.getPayStatus());
  1144. }
  1145. if (null != orderDto.getExpressInfo()) {
  1146. mtOrder.setExpressInfo(JSONObject.toJSONString(orderDto.getExpressInfo()));
  1147. }
  1148. if (null != orderDto.getOrderMode()) {
  1149. mtOrder.setOrderMode(orderDto.getOrderMode());
  1150. }
  1151. if (null != orderDto.getRemark()) {
  1152. mtOrder.setRemark(orderDto.getRemark());
  1153. }
  1154. mtOrderMapper.updateById(mtOrder);
  1155. return mtOrder;
  1156. }
  1157. /**
  1158. * 更新订单
  1159. *
  1160. * @param mtOrder 订单信息
  1161. * @return
  1162. * */
  1163. @Override
  1164. @Transactional(rollbackFor = Exception.class)
  1165. public MtOrder updateOrder(MtOrder mtOrder) {
  1166. mtOrder.setUpdateTime(new Date());
  1167. Integer id = mtOrderMapper.updateById(mtOrder);
  1168. if (id > 0) {
  1169. mtOrder = mtOrderMapper.selectById(mtOrder.getId());
  1170. }
  1171. return mtOrder;
  1172. }
  1173. /**
  1174. * 把订单置为已支付
  1175. *
  1176. * @param orderId 订单ID
  1177. * @param payAmount 支付金额
  1178. * @throws BusinessCheckException
  1179. * @return
  1180. * */
  1181. @Override
  1182. @Transactional(rollbackFor = Exception.class)
  1183. @OperationServiceLog(description = "修改订单为已支付")
  1184. public Boolean setOrderPayed(Integer orderId, BigDecimal payAmount) throws BusinessCheckException {
  1185. MtOrder mtOrder = mtOrderMapper.selectById(orderId);
  1186. if (mtOrder == null) {
  1187. return false;
  1188. }
  1189. if (mtOrder.getPayStatus().equals(PayStatusEnum.SUCCESS.getKey())) {
  1190. return true;
  1191. }
  1192. OrderDto reqDto = new OrderDto();
  1193. reqDto.setId(orderId);
  1194. reqDto.setStatus(OrderStatusEnum.PAID.getKey());
  1195. reqDto.setPayStatus(PayStatusEnum.SUCCESS.getKey());
  1196. if (payAmount != null) {
  1197. reqDto.setPayAmount(payAmount);
  1198. }
  1199. reqDto.setPayTime(new Date());
  1200. reqDto.setUpdateTime(new Date());
  1201. updateOrder(reqDto);
  1202. // 处理会员升级订单
  1203. if (mtOrder.getType().equals(OrderTypeEnum.MEMBER.getKey())) {
  1204. openGiftService.openGift(mtOrder.getUserId(), Integer.parseInt(mtOrder.getParam()), false);
  1205. }
  1206. // 处理购物订单
  1207. UserOrderDto orderInfo = getOrderByOrderSn(mtOrder.getOrderSn());
  1208. if (orderInfo.getType().equals(OrderTypeEnum.GOOGS.getKey())) {
  1209. try {
  1210. List<OrderGoodsDto> goodsList = orderInfo.getGoods();
  1211. if (goodsList != null && goodsList.size() > 0) {
  1212. for (OrderGoodsDto goodsDto : goodsList) {
  1213. MtGoods mtGoods = goodsService.queryGoodsById(goodsDto.getGoodsId());
  1214. if (mtGoods != null) {
  1215. // 购买虚拟卡券商品发放处理
  1216. if (mtGoods.getType().equals(GoodsTypeEnum.COUPON.getKey()) && mtGoods.getCouponIds() != null && StringUtil.isNotEmpty(mtGoods.getCouponIds())) {
  1217. String couponIds[] = mtGoods.getCouponIds().split(",");
  1218. if (couponIds.length > 0) {
  1219. for (int i = 0; i < couponIds.length; i++) {
  1220. userCouponService.buyCouponItem(orderInfo.getId(), Integer.parseInt(couponIds[i]), orderInfo.getUserId(), orderInfo.getUserInfo().getMobile());
  1221. }
  1222. }
  1223. }
  1224. // 将已销售数量+1
  1225. goodsService.updateInitSale(mtGoods.getId());
  1226. }
  1227. }
  1228. }
  1229. } catch (BusinessCheckException e) {
  1230. logger.error("会员购买的卡券发送给会员失败......" + e.getMessage());
  1231. }
  1232. }
  1233. // 处理消费返积分,查询返1积分所需消费金额
  1234. MtSetting setting = settingService.querySettingByName(mtOrder.getMerchantId(), PointSettingEnum.POINT_NEED_CONSUME.getKey());
  1235. if (setting != null && !orderInfo.getPayType().equals(PayTypeEnum.BALANCE.getKey()) && orderInfo.getIsVisitor().equals(YesOrNoEnum.NO.getKey())) {
  1236. String needPayAmount = setting.getValue();
  1237. Integer needPayAmountInt = Math.round(Integer.parseInt(needPayAmount));
  1238. Double pointNum = 0d;
  1239. if (needPayAmountInt > 0 && orderInfo.getPayAmount().compareTo(new BigDecimal(needPayAmountInt)) > 0) {
  1240. BigDecimal point = orderInfo.getPayAmount().divide(new BigDecimal(needPayAmountInt), BigDecimal.ROUND_CEILING, 3);
  1241. pointNum = Math.ceil(point.doubleValue());
  1242. }
  1243. logger.info("PaymentService paymentCallback Point orderSn = {} , pointNum ={}", orderInfo.getOrderSn(), pointNum);
  1244. if (pointNum > 0) {
  1245. MtUser userInfo = memberService.queryMemberById(orderInfo.getUserId());
  1246. MtUserGrade userGrade = userGradeService.queryUserGradeById(orderInfo.getMerchantId(), Integer.parseInt(userInfo.getGradeId()), orderInfo.getUserId());
  1247. // 是否会员积分加倍
  1248. if (userGrade != null && userGrade.getSpeedPoint() > 1) {
  1249. pointNum = pointNum * userGrade.getSpeedPoint();
  1250. }
  1251. MtPoint reqPointDto = new MtPoint();
  1252. reqPointDto.setAmount(pointNum.intValue());
  1253. reqPointDto.setUserId(orderInfo.getUserId());
  1254. reqPointDto.setOrderSn(orderInfo.getOrderSn());
  1255. reqPointDto.setDescription("支付¥"+orderInfo.getPayAmount()+"返"+pointNum+"积分");
  1256. reqPointDto.setOperator("系统");
  1257. pointService.addPoint(reqPointDto);
  1258. }
  1259. }
  1260. // 计算是否要升级(购物订单、付款订单、充值订单)
  1261. if (orderInfo.getIsVisitor().equals(YesOrNoEnum.NO.getKey()) && orderInfo.getType().equals(OrderTypeEnum.GOOGS.getKey()) || orderInfo.getType().equals(OrderTypeEnum.PAYMENT.getKey()) || orderInfo.getType().equals(OrderTypeEnum.RECHARGE.getKey())) {
  1262. try {
  1263. if (orderInfo.getIsVisitor().equals(YesOrNoEnum.NO.getKey())) {
  1264. Map<String, Object> param = new HashMap<>();
  1265. param.put("status", StatusEnum.ENABLED.getKey());
  1266. MtUser mtUser = memberService.queryMemberById(orderInfo.getUserId());
  1267. MtUserGrade mtUserGrade = mtUserGradeMapper.selectById(mtUser.getGradeId());
  1268. if (mtUserGrade == null) {
  1269. mtUserGrade = userGradeService.getInitUserGrade(orderInfo.getMerchantId());
  1270. }
  1271. List<MtUserGrade> userGradeList = mtUserGradeMapper.selectByMap(param);
  1272. if (mtUserGrade != null && userGradeList != null && userGradeList.size() > 0) {
  1273. // 会员已支付金额
  1274. BigDecimal payMoney = getUserPayMoney(orderInfo.getUserId());
  1275. // 会员支付订单笔数
  1276. Integer payOrderCount = getUserPayOrderCount(orderInfo.getUserId());
  1277. BigDecimal payOrderCountValue = new BigDecimal(payOrderCount);
  1278. for (MtUserGrade grade : userGradeList) {
  1279. if (grade.getCatchValue() != null && grade.getCatchType() != null) {
  1280. // 累计消费金额已达到
  1281. if (grade.getCatchType().equals(UserGradeCatchTypeEnum.AMOUNT.getKey())) {
  1282. if (grade.getGrade().compareTo(mtUserGrade.getGrade()) > 0 && payMoney.compareTo(grade.getCatchValue()) >= 0) {
  1283. openGiftService.openGift(mtOrder.getUserId(), grade.getId(), false);
  1284. }
  1285. }
  1286. // 累计消费次数已达到
  1287. if (grade.getCatchType().equals(UserGradeCatchTypeEnum.FREQUENCY.getKey()) && payOrderCountValue.compareTo(grade.getCatchValue()) >= 0) {
  1288. if (grade.getGrade().compareTo(mtUserGrade.getGrade()) > 0) {
  1289. openGiftService.openGift(mtOrder.getUserId(), grade.getId(), false);
  1290. }
  1291. }
  1292. }
  1293. }
  1294. }
  1295. }
  1296. } catch (Exception ex) {
  1297. logger.error("会员升级出错啦,userId = {},message = {}", orderInfo.getUserId(), ex.getMessage());
  1298. }
  1299. }
  1300. // 给商家发送通知短信
  1301. try {
  1302. MtStore mtStore = storeService.queryStoreById(mtOrder.getStoreId());
  1303. if (mtStore != null && orderInfo.getIsVisitor().equals(YesOrNoEnum.NO.getKey())) {
  1304. Map<String, String> params = new HashMap<>();
  1305. params.put("orderSn", mtOrder.getOrderSn());
  1306. List<String> mobileList = new ArrayList<>();
  1307. mobileList.add(mtStore.getPhone());
  1308. sendSmsService.sendSms(mtOrder.getMerchantId(), "new-order", mobileList, params);
  1309. }
  1310. } catch (Exception e) {
  1311. logger.error("给商家发送短信出错啦,message = {}", e.getMessage());
  1312. }
  1313. return true;
  1314. }
  1315. /**
  1316. * 根据条件搜索订单
  1317. *
  1318. * @param params 查询参数
  1319. * @return
  1320. * */
  1321. @Override
  1322. public List<MtOrder> getOrderListByParams(Map<String, Object> params) {
  1323. List<MtOrder> result = mtOrderMapper.selectByMap(params);
  1324. return result;
  1325. }
  1326. /**
  1327. * 处理订单详情
  1328. *
  1329. * @param orderInfo 订单信息
  1330. * @param needAddress 是否获取订单地址
  1331. * @param getPayStatus 是否获取支付状态
  1332. * @return UserOrderDto
  1333. * */
  1334. private UserOrderDto getOrderDetail(MtOrder orderInfo, boolean needAddress, boolean getPayStatus) throws BusinessCheckException {
  1335. UserOrderDto userOrderDto = new UserOrderDto();
  1336. userOrderDto.setId(orderInfo.getId());
  1337. userOrderDto.setMerchantId(orderInfo.getMerchantId());
  1338. userOrderDto.setUserId(orderInfo.getUserId());
  1339. userOrderDto.setCouponId(orderInfo.getCouponId());
  1340. userOrderDto.setOrderSn(orderInfo.getOrderSn());
  1341. userOrderDto.setRemark(orderInfo.getRemark());
  1342. userOrderDto.setType(orderInfo.getType());
  1343. userOrderDto.setPayType(orderInfo.getPayType());
  1344. userOrderDto.setOrderMode(orderInfo.getOrderMode());
  1345. userOrderDto.setCreateTime(DateUtil.formatDate(orderInfo.getCreateTime(), "yyyy.MM.dd HH:mm"));
  1346. userOrderDto.setUpdateTime(DateUtil.formatDate(orderInfo.getUpdateTime(), "yyyy.MM.dd HH:mm"));
  1347. userOrderDto.setAmount(orderInfo.getAmount());
  1348. userOrderDto.setIsVisitor(orderInfo.getIsVisitor());
  1349. userOrderDto.setStaffId(orderInfo.getStaffId());
  1350. userOrderDto.setVerifyCode("");
  1351. userOrderDto.setDeliveryFee(orderInfo.getDeliveryFee());
  1352. // 核销码为空,说明已经核销
  1353. if (orderInfo.getVerifyCode() == null || StringUtil.isEmpty(orderInfo.getVerifyCode())) {
  1354. userOrderDto.setIsVerify(true);
  1355. } else {
  1356. userOrderDto.setIsVerify(false);
  1357. }
  1358. if (orderInfo.getPayAmount() != null) {
  1359. userOrderDto.setPayAmount(orderInfo.getPayAmount());
  1360. } else {
  1361. userOrderDto.setPayAmount(new BigDecimal("0"));
  1362. }
  1363. if (orderInfo.getDiscount() != null) {
  1364. userOrderDto.setDiscount(orderInfo.getDiscount());
  1365. } else {
  1366. userOrderDto.setDiscount(new BigDecimal("0"));
  1367. }
  1368. if (orderInfo.getPointAmount() != null) {
  1369. userOrderDto.setPointAmount(orderInfo.getPointAmount());
  1370. } else {
  1371. userOrderDto.setPointAmount(new BigDecimal("0"));
  1372. }
  1373. userOrderDto.setStatus(orderInfo.getStatus());
  1374. userOrderDto.setParam(orderInfo.getParam());
  1375. userOrderDto.setPayStatus(orderInfo.getPayStatus());
  1376. if (orderInfo.getUsePoint() != null) {
  1377. userOrderDto.setUsePoint(orderInfo.getUsePoint());
  1378. } else {
  1379. userOrderDto.setUsePoint(0);
  1380. }
  1381. if (orderInfo.getPayTime() != null) {
  1382. userOrderDto.setPayTime(DateUtil.formatDate(orderInfo.getPayTime(), "yyyy.MM.dd HH:mm"));
  1383. }
  1384. if (userOrderDto.getType().equals(OrderTypeEnum.PRESTORE.getKey())) {
  1385. userOrderDto.setTypeName(OrderTypeEnum.PRESTORE.getValue());
  1386. } else if(userOrderDto.getType().equals(OrderTypeEnum.PAYMENT.getKey())) {
  1387. userOrderDto.setTypeName(OrderTypeEnum.PAYMENT.getValue());
  1388. } else if(userOrderDto.getType().equals(OrderTypeEnum.GOOGS.getKey())) {
  1389. userOrderDto.setTypeName(OrderTypeEnum.GOOGS.getValue());
  1390. } else if(userOrderDto.getType().equals(OrderTypeEnum.MEMBER.getKey())) {
  1391. userOrderDto.setTypeName(OrderTypeEnum.MEMBER.getValue());
  1392. } else if(userOrderDto.getType().equals(OrderTypeEnum.RECHARGE.getKey())) {
  1393. userOrderDto.setTypeName(OrderTypeEnum.RECHARGE.getValue());
  1394. }
  1395. if (userOrderDto.getStatus().equals(OrderStatusEnum.CREATED.getKey())) {
  1396. userOrderDto.setStatusText(OrderStatusEnum.CREATED.getValue());
  1397. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.CANCEL.getKey())) {
  1398. userOrderDto.setStatusText(OrderStatusEnum.CANCEL.getValue());
  1399. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.PAID.getKey())) {
  1400. userOrderDto.setStatusText(OrderStatusEnum.PAID.getValue());
  1401. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.DELIVERY.getKey())) {
  1402. userOrderDto.setStatusText(OrderStatusEnum.DELIVERY.getValue());
  1403. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.DELIVERED.getKey())) {
  1404. userOrderDto.setStatusText(OrderStatusEnum.DELIVERED.getValue());
  1405. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.RECEIVED.getKey())) {
  1406. userOrderDto.setStatusText(OrderStatusEnum.RECEIVED.getValue());
  1407. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.DELETED.getKey())) {
  1408. userOrderDto.setStatusText(OrderStatusEnum.DELETED.getValue());
  1409. } else if(userOrderDto.getStatus().equals(OrderStatusEnum.REFUND.getKey())) {
  1410. userOrderDto.setStatusText(OrderStatusEnum.REFUND.getValue());
  1411. }
  1412. // 订单所属店铺
  1413. MtStore storeInfo = storeService.queryStoreById(orderInfo.getStoreId());
  1414. userOrderDto.setStoreInfo(storeInfo);
  1415. // 下单用户信息直接取会员个人信息
  1416. OrderUserDto userInfo = new OrderUserDto();
  1417. MtUser user = memberService.queryMemberById(orderInfo.getUserId());
  1418. if (user != null) {
  1419. userInfo.setId(user.getId());
  1420. userInfo.setName(user.getName());
  1421. userInfo.setMobile(user.getMobile());
  1422. userInfo.setCardNo(user.getCarNo());
  1423. userInfo.setAddress(user.getAddress());
  1424. userOrderDto.setUserInfo(userInfo);
  1425. }
  1426. List<OrderGoodsDto> goodsList = new ArrayList<>();
  1427. String baseImage = settingService.getUploadBasePath();
  1428. // 储值卡的订单
  1429. if (orderInfo.getType().equals(OrderTypeEnum.PRESTORE.getKey())) {
  1430. MtCoupon coupon = couponService.queryCouponById(orderInfo.getCouponId());
  1431. String[] paramArr = orderInfo.getParam().split(",");
  1432. for(int i = 0; i < paramArr.length; i++) {
  1433. String[] item = paramArr[i].split("_");
  1434. if (Integer.parseInt(item[2]) > 0) {
  1435. OrderGoodsDto goodsDto = new OrderGoodsDto();
  1436. goodsDto.setId(coupon.getId());
  1437. goodsDto.setType(OrderTypeEnum.PRESTORE.getKey());
  1438. goodsDto.setName("预存¥" + item[0] + "到账¥" + item[1]);
  1439. goodsDto.setNum(Integer.parseInt(item[2]));
  1440. goodsDto.setPrice(item[0]);
  1441. goodsDto.setDiscount("0");
  1442. if (coupon.getImage().indexOf(baseImage) == -1) {
  1443. goodsDto.setImage(baseImage + coupon.getImage());
  1444. }
  1445. goodsList.add(goodsDto);
  1446. }
  1447. }
  1448. }
  1449. // 商品订单
  1450. if (orderInfo.getType().equals(OrderTypeEnum.GOOGS.getKey())) {
  1451. Map<String, Object> params = new HashMap<>();
  1452. params.put("ORDER_ID", orderInfo.getId());
  1453. List<MtOrderGoods> orderGoodsList = mtOrderGoodsMapper.selectByMap(params);
  1454. for (MtOrderGoods orderGoods : orderGoodsList) {
  1455. MtGoods goodsInfo = mtGoodsMapper.selectById(orderGoods.getGoodsId());
  1456. if (goodsInfo != null) {
  1457. OrderGoodsDto orderGoodsDto = new OrderGoodsDto();
  1458. orderGoodsDto.setId(orderGoods.getId());
  1459. orderGoodsDto.setName(goodsInfo.getName());
  1460. if (goodsInfo.getLogo().indexOf(baseImage) == -1) {
  1461. orderGoodsDto.setImage(baseImage + goodsInfo.getLogo());
  1462. }
  1463. orderGoodsDto.setType(OrderTypeEnum.GOOGS.getKey());
  1464. orderGoodsDto.setNum(orderGoods.getNum());
  1465. orderGoodsDto.setSkuId(orderGoods.getSkuId());
  1466. orderGoodsDto.setPrice(orderGoods.getPrice().toString());
  1467. orderGoodsDto.setDiscount(orderGoods.getDiscount().toString());
  1468. orderGoodsDto.setGoodsId(orderGoods.getGoodsId());
  1469. if (orderGoods.getSkuId() > 0) {
  1470. List<GoodsSpecValueDto> specList = goodsService.getSpecListBySkuId(orderGoods.getSkuId());
  1471. orderGoodsDto.setSpecList(specList);
  1472. }
  1473. goodsList.add(orderGoodsDto);
  1474. }
  1475. }
  1476. }
  1477. // 配送地址
  1478. if (orderInfo.getOrderMode().equals(OrderModeEnum.EXPRESS.getKey()) && needAddress) {
  1479. List<MtOrderAddress> orderAddressList = mtOrderAddressMapper.getOrderAddress(orderInfo.getId());
  1480. MtOrderAddress orderAddress = null;
  1481. if (orderAddressList.size() > 0) {
  1482. orderAddress = orderAddressList.get(0);
  1483. }
  1484. if (orderAddress != null) {
  1485. AddressDto address = new AddressDto();
  1486. address.setId(orderAddress.getId());
  1487. address.setName(orderAddress.getName());
  1488. address.setMobile(orderAddress.getMobile());
  1489. address.setDetail(orderAddress.getDetail());
  1490. address.setProvinceId(orderAddress.getProvinceId());
  1491. address.setCityId(orderAddress.getCityId());
  1492. address.setRegionId(orderAddress.getRegionId());
  1493. if (orderAddress.getProvinceId() > 0) {
  1494. MtRegion mtProvince = mtRegionMapper.selectById(orderAddress.getProvinceId());
  1495. if (mtProvince != null) {
  1496. address.setProvinceName(mtProvince.getName());
  1497. }
  1498. }
  1499. if (orderAddress.getCityId() > 0) {
  1500. MtRegion mtCity = mtRegionMapper.selectById(orderAddress.getCityId());
  1501. if (mtCity != null) {
  1502. address.setCityName(mtCity.getName());
  1503. }
  1504. }
  1505. if (orderAddress.getRegionId() > 0) {
  1506. MtRegion mtRegion = mtRegionMapper.selectById(orderAddress.getRegionId());
  1507. if (mtRegion != null) {
  1508. address.setRegionName(mtRegion.getName());
  1509. }
  1510. }
  1511. userOrderDto.setAddress(address);
  1512. }
  1513. }
  1514. // 物流信息
  1515. if (StringUtil.isNotEmpty(orderInfo.getExpressInfo())) {
  1516. JSONObject express = JSONObject.parseObject(orderInfo.getExpressInfo());
  1517. ExpressDto expressInfo = new ExpressDto();
  1518. expressInfo.setExpressNo(express.get("expressNo").toString());
  1519. expressInfo.setExpressCompany(express.get("expressCompany").toString());
  1520. expressInfo.setExpressTime(express.get("expressTime").toString());
  1521. userOrderDto.setExpressInfo(expressInfo);
  1522. }
  1523. // 使用的卡券
  1524. if (userOrderDto.getCouponId() != null && userOrderDto.getCouponId() > 0) {
  1525. MtUserCoupon mtUserCoupon = userCouponService.getUserCouponDetail(userOrderDto.getCouponId());
  1526. if (mtUserCoupon != null) {
  1527. MtCoupon mtCoupon = couponService.queryCouponById(mtUserCoupon.getCouponId());
  1528. if (mtCoupon != null) {
  1529. UserCouponDto couponInfo = new UserCouponDto();
  1530. couponInfo.setId(mtUserCoupon.getId());
  1531. couponInfo.setCouponId(mtCoupon.getId());
  1532. couponInfo.setName(mtCoupon.getName());
  1533. couponInfo.setAmount(mtUserCoupon.getAmount());
  1534. couponInfo.setBalance(mtUserCoupon.getBalance());
  1535. couponInfo.setStatus(mtUserCoupon.getStatus());
  1536. couponInfo.setType(mtCoupon.getType());
  1537. userOrderDto.setCouponInfo(couponInfo);
  1538. }
  1539. }
  1540. }
  1541. // 查询支付状态
  1542. if (getPayStatus && !orderInfo.getPayStatus().equals(PayStatusEnum.SUCCESS.getKey())) {
  1543. // 微信支付
  1544. if (orderInfo.getPayType().equals(PayTypeEnum.MICROPAY.getKey()) || orderInfo.getPayType().equals(PayTypeEnum.JSAPI.getKey())) {
  1545. try {
  1546. Map<String, String> payResult = weixinService.queryPaidOrder(orderInfo.getStoreId(), "", orderInfo.getOrderSn());
  1547. if (payResult != null && payResult.get("trade_state").equals("SUCCESS")) {
  1548. BigDecimal payAmount = new BigDecimal(payResult.get("total_fee")).divide(new BigDecimal("100"));
  1549. setOrderPayed(orderInfo.getId(), payAmount);
  1550. userOrderDto.setPayStatus(PayStatusEnum.SUCCESS.getKey());
  1551. }
  1552. } catch (Exception e) {
  1553. // empty
  1554. }
  1555. }
  1556. // 支付宝支付
  1557. if (orderInfo.getPayType().equals(PayTypeEnum.ALISCAN.getKey())) {
  1558. try {
  1559. Map<String, String> payResult = alipayService.queryPaidOrder(orderInfo.getStoreId(), "", orderInfo.getOrderSn());
  1560. if (payResult != null) {
  1561. BigDecimal payAmount = new BigDecimal(payResult.get("payAmount"));
  1562. setOrderPayed(orderInfo.getId(), payAmount);
  1563. userOrderDto.setPayStatus(PayStatusEnum.SUCCESS.getKey());
  1564. }
  1565. } catch (Exception e) {
  1566. // empty
  1567. }
  1568. }
  1569. }
  1570. userOrderDto.setGoods(goodsList);
  1571. return userOrderDto;
  1572. }
  1573. /**
  1574. * 获取订单总数
  1575. *
  1576. * @param merchantId 商户ID
  1577. * @param storeId 店铺ID
  1578. * @return
  1579. * */
  1580. @Override
  1581. public BigDecimal getOrderCount(Integer merchantId, Integer storeId) {
  1582. if (storeId > 0) {
  1583. return mtOrderMapper.getStoreOrderCount(storeId);
  1584. } else {
  1585. return mtOrderMapper.getOrderCount(merchantId);
  1586. }
  1587. }
  1588. /**
  1589. * 获取订单数量
  1590. *
  1591. * @param merchantId 商户ID
  1592. * @param storeId 店铺ID
  1593. * @param beginTime 开始时间
  1594. * @param endTime 结束时间
  1595. * @return
  1596. * */
  1597. @Override
  1598. public BigDecimal getOrderCount(Integer merchantId, Integer storeId, Date beginTime, Date endTime) {
  1599. if (storeId > 0) {
  1600. return mtOrderMapper.getStoreOrderCountByTime(storeId, beginTime, endTime);
  1601. } else {
  1602. return mtOrderMapper.getOrderCountByTime(merchantId, beginTime, endTime);
  1603. }
  1604. }
  1605. /**
  1606. * 获取支付金额
  1607. *
  1608. * @param merchantId 商户ID
  1609. * @param storeId 店铺ID
  1610. * @param beginTime 开始时间
  1611. * @param endTime 结束时间
  1612. * @return
  1613. * */
  1614. @Override
  1615. public BigDecimal getPayMoney(Integer merchantId, Integer storeId, Date beginTime, Date endTime) {
  1616. BigDecimal payMoney;
  1617. if (storeId > 0) {
  1618. payMoney = mtOrderMapper.getStorePayMoneyByTime(storeId, beginTime, endTime);
  1619. } else {
  1620. payMoney = mtOrderMapper.getPayMoneyByTime(merchantId, beginTime, endTime);
  1621. }
  1622. if (payMoney == null) {
  1623. return new BigDecimal("0");
  1624. }
  1625. return payMoney;
  1626. }
  1627. /**
  1628. * 获取支付人数
  1629. *
  1630. * @param merchantId 商户ID
  1631. * @param storeId 店铺ID
  1632. * @return
  1633. * */
  1634. @Override
  1635. public Integer getPayUserCount(Integer merchantId, Integer storeId) {
  1636. if (storeId > 0) {
  1637. return mtOrderMapper.getStorePayUserCount(storeId);
  1638. } else {
  1639. return mtOrderMapper.getPayUserCount(merchantId);
  1640. }
  1641. }
  1642. /**
  1643. * 获取支付总金额
  1644. *
  1645. * @param merchantId 商户ID
  1646. * @param storeId 店铺ID
  1647. * @return
  1648. * */
  1649. @Override
  1650. public BigDecimal getPayMoney(Integer merchantId, Integer storeId) {
  1651. if (storeId > 0) {
  1652. return mtOrderMapper.getStorePayMoney(storeId);
  1653. } else {
  1654. return mtOrderMapper.getPayMoney(merchantId);
  1655. }
  1656. }
  1657. /**
  1658. * 计算商品总价
  1659. *
  1660. * @param merchantId 商户ID
  1661. * @param userId 会员ID
  1662. * @param cartList 购物车列表
  1663. * @param couponId 卡券ID
  1664. * @param isUsePoint 使用积分数量
  1665. * @param orderMode 订单模式
  1666. * @throws BusinessCheckException
  1667. * @return
  1668. * */
  1669. @Override
  1670. public Map<String, Object> calculateCartGoods(Integer merchantId, Integer userId, List<MtCart> cartList, Integer couponId, boolean isUsePoint, String platform, String orderMode) throws BusinessCheckException {
  1671. MtUser userInfo = memberService.queryMemberById(userId);
  1672. // 设置是否不能用积分抵扣
  1673. MtSetting pointSetting = settingService.querySettingByName(merchantId, PointSettingEnum.CAN_USE_AS_MONEY.getKey());
  1674. if (pointSetting != null && !pointSetting.getValue().equals(YesOrNoEnum.TRUE.getKey())) {
  1675. isUsePoint = false;
  1676. }
  1677. List<ResCartDto> cartDtoList = new ArrayList<>();
  1678. String basePath = settingService.getUploadBasePath();
  1679. Integer totalNum = 0;
  1680. BigDecimal totalPrice = new BigDecimal("0");
  1681. BigDecimal totalCanUsePointAmount = new BigDecimal("0");
  1682. if (cartList.size() > 0) {
  1683. for (MtCart cart : cartList) {
  1684. // 购物车商品信息
  1685. MtGoods mtGoodsInfo = goodsService.queryGoodsById(cart.getGoodsId());
  1686. if (mtGoodsInfo == null || !mtGoodsInfo.getStatus().equals(StatusEnum.ENABLED.getKey())) {
  1687. continue;
  1688. }
  1689. totalNum = totalNum + cart.getNum();
  1690. ResCartDto cartDto = new ResCartDto();
  1691. cartDto.setId(cart.getId());
  1692. cartDto.setGoodsId(cart.getGoodsId());
  1693. cartDto.setNum(cart.getNum());
  1694. cartDto.setSkuId(cart.getSkuId());
  1695. cartDto.setUserId(cart.getUserId());
  1696. // 购物车是否有效
  1697. Boolean isEffect = true;
  1698. if (cart.getSkuId() > 0) {
  1699. List<GoodsSpecValueDto> specList = goodsService.getSpecListBySkuId(cart.getSkuId());
  1700. cartDto.setSpecList(specList);
  1701. }
  1702. if (StringUtil.isNotEmpty(mtGoodsInfo.getLogo()) && (mtGoodsInfo.getLogo().indexOf(basePath) == -1)) {
  1703. mtGoodsInfo.setLogo(basePath + mtGoodsInfo.getLogo());
  1704. }
  1705. // 读取sku的数据
  1706. if (cart.getSkuId() > 0) {
  1707. MtGoods mtGoods = new MtGoods();
  1708. BeanUtils.copyProperties(mtGoodsInfo, mtGoods);
  1709. MtGoodsSku mtGoodsSku = mtGoodsSkuMapper.selectById(cart.getSkuId());
  1710. if (mtGoodsSku != null) {
  1711. if (StringUtil.isNotEmpty(mtGoodsSku.getLogo()) && (mtGoodsSku.getLogo().indexOf(basePath) == -1)) {
  1712. mtGoods.setLogo(basePath + mtGoodsSku.getLogo());
  1713. }
  1714. if (mtGoodsSku.getWeight().compareTo(new BigDecimal("0")) > 0) {
  1715. mtGoods.setWeight(mtGoodsSku.getWeight());
  1716. }
  1717. mtGoods.setPrice(mtGoodsSku.getPrice());
  1718. mtGoods.setLinePrice(mtGoodsSku.getLinePrice());
  1719. mtGoods.setStock(mtGoodsSku.getStock());
  1720. }
  1721. cartDto.setGoodsInfo(mtGoods);
  1722. } else {
  1723. cartDto.setGoodsInfo(mtGoodsInfo);
  1724. }
  1725. if (mtGoodsInfo.getStock() != null && mtGoodsInfo.getStock() < cartDto.getNum()) {
  1726. isEffect = false;
  1727. }
  1728. cartDto.setIsEffect(isEffect);
  1729. // 计算总价
  1730. totalPrice = totalPrice.add(cartDto.getGoodsInfo().getPrice().multiply(new BigDecimal(cart.getNum())));
  1731. // 累加可用积分去抵扣的金额
  1732. if (mtGoodsInfo.getCanUsePoint() != null && mtGoodsInfo.getCanUsePoint().equals(YesOrNoEnum.YES.getKey())) {
  1733. totalCanUsePointAmount = totalCanUsePointAmount.add(cartDto.getGoodsInfo().getPrice().multiply(new BigDecimal(cart.getNum())));
  1734. }
  1735. cartDtoList.add(cartDto);
  1736. }
  1737. }
  1738. Map<String, Object> result = new HashMap<>();
  1739. // 可用卡券列表
  1740. List<CouponDto> couponList = new ArrayList<>();
  1741. List<String> statusList = Arrays.asList(UserCouponStatusEnum.UNUSED.getKey());
  1742. List<MtUserCoupon> userCouponList = userCouponService.getUserCouponList(userId, statusList);
  1743. if (userCouponList.size() > 0) {
  1744. for (MtUserCoupon userCoupon : userCouponList) {
  1745. MtCoupon couponInfo = couponService.queryCouponById(userCoupon.getCouponId());
  1746. // 优惠券和储值卡才能使用
  1747. if (couponInfo.getType().equals(CouponTypeEnum.COUPON.getKey()) || couponInfo.getType().equals(CouponTypeEnum.PRESTORE.getKey())) {
  1748. CouponDto couponDto = new CouponDto();
  1749. couponDto.setId(couponInfo.getId());
  1750. couponDto.setUserCouponId(userCoupon.getId());
  1751. couponDto.setName(couponInfo.getName());
  1752. couponDto.setAmount(userCoupon.getAmount());
  1753. couponDto.setStatus(UserCouponStatusEnum.DISABLE.getKey());
  1754. // 购物不能用专用的卡券
  1755. if (couponInfo.getUseFor() != null && StringUtil.isNotEmpty(couponInfo.getUseFor())) {
  1756. if (couponInfo.getUseFor().equals(CouponUseForEnum.MEMBER_GRADE.getKey())) {
  1757. continue;
  1758. }
  1759. if (couponInfo.getUseFor().equals(CouponUseForEnum.OFF_LINE_PAYMENT.getKey())) {
  1760. // 只有PC收银端能用
  1761. if (!platform.equals(PlatformTypeEnum.PC.getCode())) {
  1762. continue;
  1763. }
  1764. }
  1765. }
  1766. boolean isEffective = couponService.isCouponEffective(couponInfo, userCoupon);
  1767. // 优惠券
  1768. if (couponInfo.getType().equals(CouponTypeEnum.COUPON.getKey())) {
  1769. couponDto.setType(CouponTypeEnum.COUPON.getValue());
  1770. if (StringUtil.isEmpty(couponInfo.getOutRule()) || couponInfo.getOutRule().equals("0")) {
  1771. couponDto.setDescription("无使用门槛");
  1772. if (isEffective) {
  1773. couponDto.setStatus(UserCouponStatusEnum.UNUSED.getKey());
  1774. }
  1775. } else {
  1776. couponDto.setDescription("满" + couponInfo.getOutRule() + "元可用");
  1777. BigDecimal conditionAmount = new BigDecimal(couponInfo.getOutRule());
  1778. if (totalPrice.compareTo(conditionAmount) > 0 && isEffective) {
  1779. couponDto.setStatus(UserCouponStatusEnum.UNUSED.getKey());
  1780. }
  1781. }
  1782. } else if (couponInfo.getType().equals(CouponTypeEnum.PRESTORE.getKey())) {
  1783. // 储值卡
  1784. couponDto.setType(CouponTypeEnum.PRESTORE.getValue());
  1785. couponDto.setDescription("无使用门槛");
  1786. couponDto.setAmount(userCoupon.getBalance());
  1787. // 余额须大于0
  1788. if (isEffective && (userCoupon.getBalance().compareTo(new BigDecimal("0")) > 0)) {
  1789. couponDto.setStatus(UserCouponStatusEnum.UNUSED.getKey());
  1790. }
  1791. }
  1792. // 适用商品
  1793. if (userCoupon != null) {
  1794. if (couponInfo.getApplyGoods() != null && couponInfo.getApplyGoods().equals(ApplyGoodsEnum.PARK_GOODS.getKey())) {
  1795. List<MtCouponGoods> couponGoodsList = mtCouponGoodsMapper.getCouponGoods(couponInfo.getId());
  1796. if (couponGoodsList != null && couponGoodsList.size() > 0 && cartList.size() > 0) {
  1797. List<Integer> applyGoodsIds = new ArrayList<>();
  1798. List<Integer> goodsIds = new ArrayList<>();
  1799. for (MtCouponGoods mtCouponGoods : couponGoodsList) {
  1800. applyGoodsIds.add(mtCouponGoods.getGoodsId());
  1801. }
  1802. for (MtCart mtCart : cartList) {
  1803. goodsIds.add(mtCart.getGoodsId());
  1804. }
  1805. List<Integer> intersection = applyGoodsIds.stream()
  1806. .filter(goodsIds::contains)
  1807. .collect(Collectors.toList());
  1808. if (intersection.size() == 0) {
  1809. couponDto.setStatus(UserCouponStatusEnum.DISABLE.getKey());
  1810. }
  1811. }
  1812. }
  1813. }
  1814. if (couponInfo.getExpireType().equals(CouponExpireTypeEnum.FIX.getKey())) {
  1815. couponDto.setEffectiveDate(DateUtil.formatDate(couponInfo.getBeginTime(), "yyyy.MM.dd HH:mm") + "~" + DateUtil.formatDate(couponInfo.getEndTime(), "yyyy.MM.dd HH:mm"));
  1816. }
  1817. if (couponInfo.getExpireType().equals(CouponExpireTypeEnum.FLEX.getKey())) {
  1818. couponDto.setEffectiveDate(DateUtil.formatDate(userCoupon.getCreateTime(), "yyyy.MM.dd HH:mm") + "~" + DateUtil.formatDate(userCoupon.getExpireTime(), "yyyy.MM.dd HH:mm"));
  1819. }
  1820. couponList.add(couponDto);
  1821. }
  1822. }
  1823. }
  1824. // 使用的卡券
  1825. MtCoupon useCouponInfo = null;
  1826. BigDecimal couponAmount = new BigDecimal("0");
  1827. if (couponId > 0) {
  1828. MtUserCoupon userCouponInfo = userCouponService.getUserCouponDetail(couponId);
  1829. if (userCouponInfo != null) {
  1830. useCouponInfo = couponService.queryCouponById(userCouponInfo.getCouponId());
  1831. boolean isEffective = couponService.isCouponEffective(useCouponInfo, userCouponInfo);
  1832. if (isEffective) {
  1833. if (useCouponInfo.getType().equals(CouponTypeEnum.COUPON.getKey())) {
  1834. couponAmount = useCouponInfo.getAmount();
  1835. } else if(useCouponInfo.getType().equals(CouponTypeEnum.PRESTORE.getKey())) {
  1836. BigDecimal couponTotalAmount = userCouponInfo.getBalance();
  1837. if (couponTotalAmount.compareTo(totalPrice) > 0) {
  1838. couponAmount = totalPrice;
  1839. useCouponInfo.setAmount(totalPrice);
  1840. } else {
  1841. couponAmount = couponTotalAmount;
  1842. useCouponInfo.setAmount(couponTotalAmount);
  1843. }
  1844. }
  1845. }
  1846. }
  1847. }
  1848. // 支付金额 = 商品总额 - 卡券抵扣金额
  1849. BigDecimal payPrice = totalPrice.subtract(couponAmount);
  1850. // 可用积分、可用积分金额
  1851. Integer myPoint = userInfo.getPoint() == null ? 0 : userInfo.getPoint();
  1852. Integer usePoint = 0;
  1853. BigDecimal usePointAmount = new BigDecimal("0");
  1854. MtSetting setting = settingService.querySettingByName(merchantId, PointSettingEnum.EXCHANGE_NEED_POINT.getKey());
  1855. if (myPoint > 0 && setting != null && isUsePoint) {
  1856. if (StringUtil.isNotEmpty(setting.getValue()) && !setting.getValue().equals("0")) {
  1857. BigDecimal usePoints = new BigDecimal(myPoint);
  1858. usePointAmount = usePoints.divide(new BigDecimal(setting.getValue()), BigDecimal.ROUND_CEILING, 3);
  1859. usePoint = myPoint;
  1860. if (usePointAmount.compareTo(totalCanUsePointAmount) >= 0) {
  1861. usePointAmount = totalCanUsePointAmount;
  1862. usePoint = totalCanUsePointAmount.multiply(new BigDecimal(setting.getValue())).intValue();
  1863. }
  1864. }
  1865. }
  1866. // 积分金额不能大于支付金额
  1867. if (usePointAmount.compareTo(payPrice) > 0 && isUsePoint) {
  1868. usePointAmount = payPrice;
  1869. BigDecimal usePoints = payPrice.multiply(new BigDecimal(setting.getValue()));
  1870. usePoint = usePoints.intValue();
  1871. }
  1872. // 支付金额 = 商品总额 - 积分抵扣金额
  1873. payPrice = payPrice.subtract(usePointAmount);
  1874. if (payPrice.compareTo(new BigDecimal("0")) < 0) {
  1875. payPrice = new BigDecimal("0");
  1876. }
  1877. // 配送费用
  1878. BigDecimal deliveryFee = new BigDecimal("0");
  1879. MtSetting mtSetting = settingService.querySettingByName(merchantId, OrderSettingEnum.DELIVERY_FEE.getKey());
  1880. if (mtSetting != null && StringUtil.isNotEmpty(mtSetting.getValue()) && orderMode.equals(OrderModeEnum.EXPRESS.getKey())) {
  1881. deliveryFee = new BigDecimal(mtSetting.getValue());
  1882. }
  1883. // 会员折扣
  1884. BigDecimal payDiscount = new BigDecimal("1");
  1885. MtUserGrade userGrade = userGradeService.queryUserGradeById(merchantId, Integer.parseInt(userInfo.getGradeId()), userInfo.getId());
  1886. if (userGrade != null) {
  1887. if (userGrade.getDiscount() > 0) {
  1888. payDiscount = new BigDecimal(userGrade.getDiscount()).divide(new BigDecimal("10"), BigDecimal.ROUND_CEILING, 3);
  1889. if (payDiscount.compareTo(new BigDecimal("0")) <= 0) {
  1890. payDiscount = new BigDecimal("1");
  1891. }
  1892. }
  1893. }
  1894. payPrice = payPrice.multiply(payDiscount).add(deliveryFee);
  1895. result.put("list", cartDtoList);
  1896. result.put("totalNum", totalNum);
  1897. result.put("totalPrice", totalPrice);
  1898. result.put("payPrice", payPrice);
  1899. result.put("couponList", couponList);
  1900. result.put("useCouponInfo", useCouponInfo);
  1901. result.put("usePoint", usePoint);
  1902. result.put("myPoint", myPoint);
  1903. result.put("couponAmount", couponAmount);
  1904. result.put("usePointAmount", usePointAmount);
  1905. result.put("deliveryFee", deliveryFee);
  1906. return result;
  1907. }
  1908. /**
  1909. * 获取会员支付金额
  1910. *
  1911. * @param userId 会员ID
  1912. * @return
  1913. * */
  1914. @Override
  1915. public BigDecimal getUserPayMoney(Integer userId) {
  1916. return mtOrderMapper.getUserPayMoney(userId);
  1917. }
  1918. /**
  1919. * 获取会员订单数
  1920. *
  1921. * @param userId 会员ID
  1922. * @return
  1923. * */
  1924. @Override
  1925. public Integer getUserPayOrderCount(Integer userId) {
  1926. return mtOrderMapper.getUserPayOrderCount(userId);
  1927. }
  1928. /**
  1929. * 获取等待分佣的订单列表
  1930. *
  1931. * @param dateTime 时间
  1932. * @return
  1933. * */
  1934. @Override
  1935. public List<MtOrder> getTobeCommissionOrderList(String dateTime) {
  1936. return mtOrderMapper.getTobeCommissionOrderList(dateTime);
  1937. }
  1938. }