OrderServiceImpl.java 106 KB

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