OrderServiceImpl.java 97 KB

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