OrderServiceImpl.java 96 KB

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