ApiOrderService.java 58 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178
  1. package com.kmall.api.service;
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.google.common.collect.Maps;
  5. import com.kmall.api.dao.mk.ApiMkStoreCampMinusMapper;
  6. import com.kmall.api.dao.mk.ApiMkStoreTicketDiscountMapper;
  7. import com.kmall.api.dto.CampMinusDto;
  8. import com.kmall.api.dto.CheckOutDto;
  9. import com.kmall.api.entity.mk.MkStoreCampMinusVo;
  10. import com.kmall.api.entity.mk.MkStoreTicketDiscountVo;
  11. import com.kmall.api.fromcomm.entity.FormIdsEntity;
  12. import com.kmall.api.service.mk.ApiMkStorePromStatService;
  13. import com.kmall.api.service.mk.ApiMkStoreTopicStatService;
  14. import com.kmall.api.util.StockUtil;
  15. import com.kmall.common.utils.*;
  16. import com.kmall.manager.dao.TemplateConfDao;
  17. import com.kmall.manager.entity.pay.TemplateConfVo;
  18. import com.kmall.manager.manager.print.ticket.PrintTicketPropertiesBuilder;
  19. import com.kmall.manager.manager.print.ticket.TicketPrintUtil;
  20. import com.kmall.api.fromcomm.service.FormIdsService;
  21. import com.kmall.common.constant.Dict;
  22. import com.kmall.api.dao.*;
  23. import com.kmall.api.dto.IdCardMsgVo;
  24. import com.kmall.api.entity.*;
  25. import com.kmall.manager.manager.merch.OmsMerchPropertiesBuilder;
  26. import com.kmall.api.util.CommonUtil;
  27. import com.kmall.api.util.IdCardUtil;
  28. import com.kmall.common.utils.print.ticket.item.*;
  29. import com.kmall.manager.manager.wechat.wxtemplate.TemplateData;
  30. import com.kmall.manager.manager.wechat.wxtemplate.WxTemplate;
  31. import org.apache.commons.logging.Log;
  32. import org.apache.commons.logging.LogFactory;
  33. import org.springframework.beans.factory.annotation.Autowired;
  34. import org.springframework.stereotype.Service;
  35. import org.springframework.transaction.annotation.Transactional;
  36. import java.math.BigDecimal;
  37. import java.text.SimpleDateFormat;
  38. import java.util.*;
  39. @Service
  40. public class ApiOrderService {
  41. private Log logger = LogFactory.getLog(ApiOrderService.class);
  42. @Autowired
  43. private ApiProductMapper apiProductMapper;
  44. @Autowired
  45. private ApiCartMapper apiCartMapper;
  46. @Autowired
  47. private ApiOrderMapper apiOrderMapper;
  48. @Autowired
  49. private ApiOrderGoodsMapper apiOrderGoodsMapper;
  50. @Autowired
  51. private ApiUserCouponMapper apiUserCouponMapper;
  52. @Autowired
  53. private TemplateConfDao apiTemplateConfMapper;
  54. @Autowired
  55. private ApiUserMapper apiUserMapper;
  56. @Autowired
  57. private FormIdsService formIdsService;
  58. @Autowired
  59. private ApiGoodsMapper apiGoodsMapper;
  60. @Autowired
  61. private ApiFreightService apiFreightService;
  62. @Autowired
  63. private ApiOrderProcessRecordMapper orderProcessRecordMapper;
  64. @Autowired
  65. private ApiStoreMapper apiStoreMapper;
  66. @Autowired
  67. private ApiMerchMapper apiMerchMapper;
  68. @Autowired
  69. private ApiMngChangeMapper apiMngChangeMapper;
  70. @Autowired
  71. private ApiStoreMngChangeMapper apiStoreMngChangeMapper;
  72. @Autowired
  73. private ApiMkStorePromStatService apiMkStorePromStatService;
  74. @Autowired
  75. private ApiMkStoreTicketDiscountMapper apiMkStoreTicketDiscountMapper;
  76. @Autowired
  77. private ApiCartService cartService;
  78. @Autowired
  79. private ApiMkStoreTopicStatService apiMkStoreTopicStatService;
  80. @Autowired
  81. private ApiMkStoreCampMinusMapper apiMkStoreCampMinusMapper;
  82. @Autowired
  83. private ApiUserCampMinusMapper apiUserCampMinusMapper;
  84. public OrderVo queryObject(Long id) {
  85. return apiOrderMapper.queryObject(id);
  86. }
  87. public OrderVo queryObjectByOrderSn(String order_sn) {
  88. return apiOrderMapper.queryObjectByOrderSn(order_sn);
  89. }
  90. public Map queryUcenterMap(Map<String, Object> map) {
  91. return apiOrderMapper.queryUcenterMap(map);
  92. }
  93. public List<OrderVo> queryList(Map<String, Object> map) {
  94. return apiOrderMapper.queryList(map);
  95. }
  96. public int queryTotal(Map<String, Object> map) {
  97. return apiOrderMapper.queryTotal(map);
  98. }
  99. public void save(OrderVo order) {
  100. apiOrderMapper.save(order);
  101. }
  102. @Transactional
  103. public void cancelOrder(Long userId, OrderVo order) {
  104. Map orderGoodsParam = Maps.newHashMap();
  105. orderGoodsParam.put("order_id", order.getId());
  106. String userName = "";
  107. if(userId != null){
  108. UserVo userVo = apiUserMapper.queryObject(userId);
  109. userName = userVo != null ? userVo.getUsername():"";
  110. }
  111. //订单的商品
  112. List<OrderGoodsVo> goodsList = apiOrderGoodsMapper.queryList(orderGoodsParam);
  113. for (OrderGoodsVo orderGoodsVo : goodsList) {
  114. ProductVo productInfo = apiProductMapper.queryByStoreId(orderGoodsVo.getProduct_id(), order.getStore_id());
  115. GoodsVo goodsInfo = apiGoodsMapper.queryObjectByStoreId(orderGoodsVo.getGoods_id(), order.getStore_id());
  116. if (null == goodsInfo || goodsInfo.getIs_delete() == 1 || goodsInfo.getIs_on_sale() == 0) {
  117. throw new RRException("订单提交失败:商品不存在");
  118. }
  119. // Integer stockNum = StockUtil.setStockNumByGoodsVo(goodsInfo);
  120. // String isStockShare = StockUtil.getIsStockShareByGoodsVo(goodsInfo);
  121. // TODO: 2019/3/5 普通商品不受共享库存影响,直接取门店配置库存
  122. //还原门店库存
  123. resetStoreGoodsStock(goodsInfo.getStockNum(), productInfo, goodsInfo, orderGoodsVo, userName);
  124. //还原商户商品库存
  125. resetGoodsStock(goodsInfo.getGoods_number(), productInfo, goodsInfo, orderGoodsVo, userName);
  126. }
  127. update(order);
  128. // 判断是否有优惠券
  129. UserCouponVo couponVo = apiUserCouponMapper.queryByOrderId(order.getId());
  130. if (null != couponVo) {
  131. apiUserCouponMapper.cancelOrder(couponVo);
  132. }
  133. //释放促销满减券
  134. UserCampMinusVo userCampMinusVo = apiUserCampMinusMapper.queryUserCampByOrderId(order.getId());
  135. if (null != userCampMinusVo) {
  136. apiUserCampMinusMapper.cancelUserCampOrder(userCampMinusVo);
  137. }
  138. }
  139. /**
  140. * 还原商户商品总库存
  141. */
  142. private void resetGoodsStock(Integer stockNum, ProductVo productInfo, GoodsVo goodsInfo, OrderGoodsVo orderGoodsVo, String userName){
  143. stockNum = stockNum == null? 0 : stockNum;
  144. goodsInfo.setGoods_number(stockNum + orderGoodsVo.getNumber());
  145. // goodsInfo.setSell_volume(goodsInfo.getGoods_sell_volume() - orderGoodsVo.getNumber());
  146. apiGoodsMapper.updateGoodsStock(goodsInfo);
  147. // productInfo.setSell_volume(productInfo.getSell_volume() - orderGoodsVo.getNumber());
  148. // productInfo.setGoods_id(goodsInfo.getId());
  149. // apiProductMapper.updateStockNum(productInfo);
  150. MngChangeVo mngChangeVo = new MngChangeVo();
  151. mngChangeVo.setGoodsId(Integer.parseInt(String.valueOf(goodsInfo.getId())));
  152. mngChangeVo.setThirdPartyMerchCode(goodsInfo.getThirdPartyMerchCode());
  153. mngChangeVo.setChangeReason("小程序取消订单");
  154. mngChangeVo.setChangeType(Dict.changeType.item_0.getItem());
  155. mngChangeVo.setChangeNum(orderGoodsVo.getNumber());//变化数
  156. mngChangeVo.setOriginalNum(stockNum);//原库存数
  157. mngChangeVo.setValidNum(stockNum + orderGoodsVo.getNumber());//可用数
  158. mngChangeVo.setCreateTime(new Date());
  159. mngChangeVo.setModTime(new Date());
  160. mngChangeVo.setCreaterSn("小程序用户"+userName);
  161. mngChangeVo.setModerSn("小程序用户"+userName);
  162. mngChangeVo.setIsValid(0);
  163. mngChangeVo.setMerchSn(goodsInfo.getMerchSn());
  164. apiMngChangeMapper.save(mngChangeVo);
  165. }
  166. /**
  167. * 还原门店商品库存
  168. */
  169. private void resetStoreGoodsStock(Integer stockNum, ProductVo productInfo, GoodsVo goodsInfo, OrderGoodsVo orderGoodsVo, String userName){
  170. stockNum = stockNum == null? 0 : stockNum;
  171. productInfo.setStock_num(stockNum + orderGoodsVo.getNumber());
  172. productInfo.setGoods_id(goodsInfo.getId());
  173. productInfo.setSell_volume(productInfo.getSell_volume() - orderGoodsVo.getNumber());
  174. apiProductMapper.updateStockNum(productInfo);
  175. StoreMngChangeVo storeMngChangeVo = new StoreMngChangeVo();
  176. storeMngChangeVo.setChangeType(Dict.changeType.item_0.getItem());
  177. storeMngChangeVo.setChangeReason("小程序取消订单");
  178. storeMngChangeVo.setGoodsId(Integer.parseInt(String.valueOf(goodsInfo.getId())));
  179. storeMngChangeVo.setStoreId(Integer.parseInt(String.valueOf(productInfo.getStore_id())));
  180. storeMngChangeVo.setMerchSn(goodsInfo.getMerchSn());
  181. storeMngChangeVo.setStoreChangeNum(orderGoodsVo.getNumber());
  182. storeMngChangeVo.setStoreOriginalNum(stockNum);
  183. storeMngChangeVo.setStoreValidNum(stockNum + orderGoodsVo.getNumber());
  184. storeMngChangeVo.setCreateTime(new Date());
  185. storeMngChangeVo.setModTime(new Date());
  186. storeMngChangeVo.setCreaterSn("小程序用户"+userName);
  187. storeMngChangeVo.setModerSn("小程序用户"+userName);
  188. storeMngChangeVo.setIsValid(0);
  189. apiStoreMngChangeMapper.save(storeMngChangeVo);
  190. }
  191. public void update(OrderVo order) {
  192. order.setIsScan("0");
  193. order.setModTime(new Date());
  194. apiOrderMapper.update(order);
  195. }
  196. public void updateOrderByMerchOrderSn(OrderVo order) {
  197. apiOrderMapper.updateOrderByMerchOrderSn(order);
  198. }
  199. public void updateBatch(List<OrderVo> list) {
  200. for (OrderVo order : list) {
  201. order.setIsScan("0");
  202. order.setModTime(new Date());
  203. }
  204. apiOrderMapper.updateBatch(list);
  205. }
  206. public void delete(Integer id) {
  207. apiOrderMapper.delete(id);
  208. }
  209. public void deleteBatch(Integer[] ids) {
  210. apiOrderMapper.deleteBatch(ids);
  211. }
  212. @Transactional
  213. public Map submit(JSONObject jsonParam, UserVo loginUser, Long storeId) {
  214. Map resultObj = Maps.newHashMap();
  215. AddressVo addressVo = jsonParam.getObject("checkedAddress", AddressVo.class);
  216. if (addressVo == null) {
  217. resultObj.put("errno", 400);
  218. resultObj.put("errmsg", "地址不能为空");
  219. return resultObj;
  220. }
  221. String formId = jsonParam.getString("formId");
  222. String idNo = jsonParam.getString("idNo");
  223. String userName = jsonParam.getString("userName");
  224. String postscript00 = jsonParam.getString("postscript00");
  225. String postscript02 = jsonParam.getString("postscript02");
  226. String postscript10 = jsonParam.getString("postscript10");
  227. String postscript11 = jsonParam.getString("postscript11");//留言备注
  228. String checkCart = jsonParam.getString("checkCart");//业务区分,11为普通商品,00为保税商品
  229. Integer tickDiscId00 = jsonParam.getInteger("tickDiscId00");//优惠券id
  230. Integer tickDiscId02 = jsonParam.getInteger("tickDiscId02");//优惠券id
  231. Integer tickDiscId10 = jsonParam.getInteger("tickDiscId10");//优惠券id
  232. Integer tickDiscId11 = jsonParam.getInteger("tickDiscId11");//优惠券id
  233. Integer campId00 = jsonParam.getInteger("campId00");//促销id
  234. Integer campId02 = jsonParam.getInteger("campId02");//促销id
  235. Integer campId10 = jsonParam.getInteger("campId10");//促销id
  236. Integer campId11 = jsonParam.getInteger("campId11");//促销id
  237. Integer isLoadStatus = jsonParam.getInteger("isLoadStatus");
  238. UserVo user = apiUserMapper.queryObjectByIdNoAndName(idNo, userName);
  239. UserVo userVo = new UserVo();
  240. userVo.setId(loginUser.getId());
  241. userVo.setIdNo(idNo);
  242. userVo.setUsername(userName);
  243. logger.info("param userId:"+ loginUser.getId());
  244. logger.info("param idNo:"+ userVo.getIdNo());
  245. logger.info("param userName:"+ userVo.getUsername());
  246. if(user != null){
  247. logger.info("query userId:"+ user.getId());
  248. if(loginUser.getId().compareTo(user.getId()) != 0){
  249. logger.info("该身份证信息已被绑定,登陆用户:"+ user.getId()+",查询用户:"+ user.getId());
  250. resultObj.put("errno", 400);
  251. resultObj.put("errmsg", "该身份证信息已被绑定");
  252. return resultObj;
  253. }
  254. }
  255. // 实名认证身份证信息,认证成功更新到用户表
  256. String result = IdCardUtil.checkIdCard(userVo.getIdNo(), userVo.getUsername());
  257. IdCardMsgVo vo = JSON.parseObject(result,IdCardMsgVo.class);
  258. if(vo.getRespCode().equalsIgnoreCase("0000")){
  259. apiUserMapper.update(userVo);
  260. }else{
  261. logger.info(vo.getRespMessage());
  262. resultObj.put("errno", 400);
  263. resultObj.put("errmsg", vo.getRespMessage());
  264. return resultObj;
  265. }
  266. //获取要购买的商品
  267. Map<String, Object> cartData = cartService.getCartMoney(loginUser,checkCart,storeId);
  268. List<CartVo> checkedGoodsList = (List<CartVo>) cartData.get("cartList");
  269. // Map param = Maps.newHashMap();
  270. // param.put("user_id", loginUser.getId());
  271. // param.put("store_id", storeId);
  272. // param.put("checked", 1);
  273. // param.put("checkCart", checkCart);
  274. // List<CartVo> checkedGoodsList = apiCartMapper.queryList(param);
  275. if (null == checkedGoodsList) {
  276. resultObj.put("errno", 400);
  277. resultObj.put("errmsg", "请选择商品");
  278. logger.error("请选择商品");
  279. return resultObj;
  280. }
  281. // 检查库存和更新库存
  282. checkStock(checkedGoodsList, storeId, userName);
  283. CheckOutDto checkOutDto = new CheckOutDto();
  284. checkOutDto.setCheckCart(checkCart);
  285. checkOutDto.setLoginUser(loginUser);
  286. if(tickDiscId00 != null){
  287. checkOutDto.setTickDiscId00(Long.valueOf(tickDiscId00));
  288. }
  289. if(tickDiscId02 != null){
  290. checkOutDto.setTickDiscId02(Long.valueOf(tickDiscId02));
  291. }
  292. if(tickDiscId10 != null){
  293. checkOutDto.setTickDiscId10(Long.valueOf(tickDiscId10));
  294. }
  295. if(tickDiscId11 != null){
  296. checkOutDto.setTickDiscId11(Long.valueOf(tickDiscId11));
  297. }
  298. if(campId00 != null){
  299. checkOutDto.setCampId00(campId00);
  300. }
  301. if(campId02 != null){
  302. checkOutDto.setCampId02(campId02);
  303. }
  304. if(campId10 != null){
  305. checkOutDto.setCampId10(campId10);
  306. }
  307. if(campId11 != null){
  308. checkOutDto.setCampId11(campId11);
  309. }
  310. checkOutDto.setIsLoadStatus(isLoadStatus);
  311. checkOutDto.setStoreId(storeId);
  312. checkOutDto.setCartData(cartData);
  313. Map<String, Object> cartResultObj = cartService.getCheckOut(checkOutDto);
  314. Boolean isBizType00 = (Boolean) cartResultObj.get("isBizType00");
  315. Boolean isBizType02 = (Boolean) cartResultObj.get("isBizType02");
  316. Boolean isBizType10 = (Boolean) cartResultObj.get("isBizType10");
  317. Boolean isBizType11 = (Boolean) cartResultObj.get("isBizType11");
  318. List<OrderVo> orderInfoList = new ArrayList();
  319. String merchOrderSn = "EMATO" + CommonUtil.generateOrderNumber();
  320. //订单按业务类型进行分单
  321. if(isBizType00){
  322. OrderVo order00 = setOrderVo(jsonParam, loginUser, storeId, cartResultObj, Dict.orderBizType.item_00.getItem());
  323. order00.setOrderBizType(Dict.orderBizType.item_00.getItem());
  324. order00.setMerchOrderSn(merchOrderSn);
  325. if(org.apache.commons.lang.StringUtils.isNotEmpty(postscript00)) {
  326. order00.setPostscript(postscript00);
  327. }
  328. orderInfoList.add(order00);
  329. }
  330. if(isBizType02){
  331. OrderVo order02 = setOrderVo(jsonParam, loginUser, storeId, cartResultObj, Dict.orderBizType.item_02.getItem());
  332. order02.setOrderBizType(Dict.orderBizType.item_02.getItem());
  333. order02.setMerchOrderSn(merchOrderSn);
  334. if(org.apache.commons.lang.StringUtils.isNotEmpty(postscript02)) {
  335. order02.setPostscript(postscript02);
  336. }
  337. orderInfoList.add(order02);
  338. }
  339. if(isBizType10){
  340. OrderVo order10 = setOrderVo(jsonParam, loginUser, storeId, cartResultObj, Dict.orderBizType.item_10.getItem());
  341. order10.setOrderBizType(Dict.orderBizType.item_10.getItem());
  342. order10.setMerchOrderSn(merchOrderSn);
  343. if(org.apache.commons.lang.StringUtils.isNotEmpty(postscript10)) {
  344. order10.setPostscript(postscript10);
  345. }
  346. orderInfoList.add(order10);
  347. }
  348. if(isBizType11){
  349. OrderVo order11 = setOrderVo(jsonParam, loginUser, storeId, cartResultObj, Dict.orderBizType.item_11.getItem());
  350. order11.setOrderBizType(Dict.orderBizType.item_11.getItem());
  351. order11.setMerchOrderSn(merchOrderSn);
  352. if(org.apache.commons.lang.StringUtils.isNotEmpty(postscript11)) {
  353. order11.setPostscript(postscript11);
  354. }
  355. orderInfoList.add(order11);
  356. }
  357. //开启事务,插入订单信息和订单商品
  358. if(orderInfoList != null && orderInfoList.size() > 0) {
  359. apiOrderMapper.saveBatch(orderInfoList);
  360. List<OrderProcessRecordEntity> processRecordEntityList = new ArrayList<>();
  361. for (OrderVo orderInfo : orderInfoList) {
  362. if (null == orderInfo.getId()) {
  363. logger.error("订单提交失败");
  364. throw new RRException("订单提交失败");
  365. }
  366. //新增订单详情
  367. for (CartVo goodsItem : checkedGoodsList) {
  368. //统计商品总价
  369. if (orderInfo.getOrderBizType().equalsIgnoreCase(goodsItem.getGoodsBizType())) {
  370. GoodsVo goodsVo = apiGoodsMapper.queryObjectByStoreId(goodsItem.getGoods_id(), storeId);
  371. if (goodsVo == null) {
  372. logger.error("订单提交失败:商品不存在");
  373. throw new RRException("订单提交失败:商品不存在");
  374. }
  375. OrderGoodsVo orderGoodsVo = setOrderGoodsVo(orderInfo, goodsItem, goodsVo);
  376. apiOrderGoodsMapper.save(orderGoodsVo);
  377. Integer cartId = Integer.parseInt(String.valueOf(goodsItem.getId()));
  378. //更新渠道追踪统计下单量数据
  379. apiMkStorePromStatService.updateMkStorePromStat(orderGoodsVo, orderInfo, loginUser, cartId);
  380. }
  381. }
  382. //记录优惠券活动营销统计下单量数据
  383. apiMkStoreTopicStatService.saveTicketTopicStatBySubmitData(orderInfo.getCoupon_id());
  384. //记录促销满减活动营销统计下单量数据
  385. apiMkStoreTopicStatService.saveCampTopicStatBySubmitData(orderInfo.getActivity_id(), orderInfo.getCampMinusId());
  386. OrderProcessRecordEntity entity = new OrderProcessRecordEntity();
  387. entity.setOrderSn(orderInfo.getOrder_sn());
  388. entity.setUserId(Integer.valueOf(loginUser.getId()+""));
  389. entity.setAddOrderStartTime(orderInfo.getAdd_time());
  390. entity.setAddOrderSuccTime(orderInfo.getAdd_time());
  391. entity.setIsAddOrderSend(Dict.isSend.item_1.getItem());
  392. entity.setOrderBizType(orderInfo.getOrderBizType());
  393. processRecordEntityList.add(entity);
  394. }
  395. orderProcessRecordMapper.saveBatch(processRecordEntityList);//新增订单流转信息
  396. //清空已购买的商品
  397. apiCartMapper.deleteByCart(loginUser.getId(), storeId, 1, checkCart);
  398. if (apiOrderMapper.queryCountByMerchOrderSn(merchOrderSn) > 1) {//不止一笔订单则为拆单订单
  399. OrderVo orderVo = new OrderVo();
  400. orderVo.setIsMergePay("2");//多笔订单单笔支付
  401. orderVo.setMerchOrderSn(merchOrderSn);
  402. apiOrderMapper.updateOrderByMerchOrderSn(orderVo);
  403. }
  404. resultObj.put("errno", 0);
  405. resultObj.put("errmsg", "订单提交成功");
  406. //
  407. Map orderInfoMap = Maps.newHashMap();
  408. orderInfoMap.put("orderInfo", orderInfoList);
  409. resultObj.put("data", orderInfoMap);
  410. // 优惠券标记已用,或促销满减活动保存已用
  411. for (OrderVo orderInfo : orderInfoList) {
  412. if(orderInfo.getOrderBizType().equalsIgnoreCase(Dict.orderBizType.item_00.getItem())){
  413. updateCoupon(orderInfo);
  414. saveUserCamp(orderInfo);
  415. }
  416. if(orderInfo.getOrderBizType().equalsIgnoreCase(Dict.orderBizType.item_02.getItem())){
  417. updateCoupon(orderInfo);
  418. saveUserCamp(orderInfo);
  419. }
  420. if(orderInfo.getOrderBizType().equalsIgnoreCase(Dict.orderBizType.item_10.getItem())){
  421. updateCoupon(orderInfo);
  422. saveUserCamp(orderInfo);
  423. }
  424. if(orderInfo.getOrderBizType().equalsIgnoreCase(Dict.orderBizType.item_11.getItem())){
  425. updateCoupon(orderInfo);
  426. saveUserCamp(orderInfo);
  427. }
  428. }
  429. }
  430. return resultObj;
  431. }
  432. /**
  433. * 标记优惠券使用的订单id
  434. * @param orderInfo
  435. */
  436. private void updateCoupon(OrderVo orderInfo){
  437. if (null != orderInfo.getCoupon_id() && 0 != orderInfo.getCoupon_id()) {
  438. UserCouponVo userCouponVo = apiUserCouponMapper.queryObject(orderInfo.getCoupon_id());
  439. //如未使用
  440. if (null != userCouponVo && (null == userCouponVo.getOrderId() || 0 == userCouponVo.getOrderId())) {
  441. userCouponVo.setUsedTime(new Date());
  442. userCouponVo.setOrderId(orderInfo.getId());
  443. userCouponVo.setIsUsed(Dict.isUsed.item_1.getItem());
  444. apiUserCouponMapper.update(userCouponVo);
  445. }
  446. }
  447. }
  448. /**
  449. * 订单提交成功后,新增用户促销满减活动信息为已使用
  450. * @param orderInfo
  451. */
  452. private void saveUserCamp(OrderVo orderInfo){
  453. if (null != orderInfo.getActivity_id() && 0 != orderInfo.getActivity_id()) {
  454. UserCampMinusVo campMinusVo = apiUserCampMinusMapper.queryCampByStoreTopicId(orderInfo.getActivity_id());
  455. //如未使用
  456. if (null == campMinusVo) {
  457. UserCampMinusVo userCampMinusVo = new UserCampMinusVo();
  458. userCampMinusVo.setUsedTime(new Date());
  459. userCampMinusVo.setOrderId(Integer.parseInt(String.valueOf(orderInfo.getId())));
  460. userCampMinusVo.setIsUsed(Dict.isUsed.item_1.getItem());
  461. userCampMinusVo.setStoreTopicId(Integer.parseInt(String.valueOf(orderInfo.getActivity_id())));
  462. userCampMinusVo.setCreateTime(new Date());
  463. userCampMinusVo.setUserId(Integer.parseInt(String.valueOf(orderInfo.getUser_id())));
  464. apiUserCampMinusMapper.save(userCampMinusVo);
  465. }else {
  466. campMinusVo.setUsedTime(new Date());
  467. campMinusVo.setOrderId(Integer.parseInt(String.valueOf(orderInfo.getId())));
  468. campMinusVo.setIsUsed(Dict.isUsed.item_1.getItem());
  469. campMinusVo.setUserId(Integer.parseInt(String.valueOf(orderInfo.getUser_id())));
  470. apiUserCampMinusMapper.update(campMinusVo);
  471. }
  472. }
  473. }
  474. /**
  475. * 扣减商户商品总库存
  476. * @param goodsVo
  477. * @param goodsItem
  478. * @param userName
  479. */
  480. private void updateGoodsStock(GoodsVo goodsVo, CartVo goodsItem,String userName){
  481. goodsVo.setGoods_number(goodsVo.getGoods_number() - goodsItem.getNumber());
  482. goodsVo.setId(goodsVo.getId());
  483. apiGoodsMapper.updateGoodsStock(goodsVo);
  484. // //修改门店商品销量
  485. // productInfo.setSell_volume(productInfo.getSell_volume() + goodsItem.getNumber());
  486. // productInfo.setGoods_id(goodsVo.getId());
  487. // apiProductMapper.updateStockNum(productInfo);
  488. MngChangeVo mngChangeVo = new MngChangeVo();
  489. mngChangeVo.setGoodsId(Integer.parseInt(String.valueOf(goodsVo.getId())));
  490. mngChangeVo.setThirdPartyMerchCode(goodsVo.getThirdPartyMerchCode());
  491. mngChangeVo.setChangeReason("小程序购买商品");
  492. mngChangeVo.setChangeType(Dict.changeType.item_1.getItem());
  493. mngChangeVo.setChangeNum(goodsItem.getNumber());//变化数
  494. mngChangeVo.setOriginalNum(goodsVo.getGoods_number());//原库存数
  495. mngChangeVo.setValidNum(goodsVo.getGoods_number() - goodsItem.getNumber());//可用数
  496. mngChangeVo.setCreateTime(new Date());
  497. mngChangeVo.setModTime(new Date());
  498. mngChangeVo.setCreaterSn("小程序用户"+userName);
  499. mngChangeVo.setModerSn("小程序用户"+userName);
  500. mngChangeVo.setIsValid(0);
  501. mngChangeVo.setMerchSn(goodsVo.getMerchSn());
  502. apiMngChangeMapper.save(mngChangeVo);
  503. }
  504. /**
  505. * 扣减商户门店商品库存
  506. * @param productInfo
  507. * @param goodsVo
  508. * @param stockNum
  509. * @param goodsItem
  510. * @param storeId
  511. * @param userName
  512. */
  513. private void updateStock(ProductVo productInfo,GoodsVo goodsVo,Integer stockNum,CartVo goodsItem,Long storeId,String userName){
  514. //修改门店商品库存
  515. productInfo.setStock_num(stockNum - goodsItem.getNumber());
  516. productInfo.setStore_id(storeId);
  517. //修改门店商品销量
  518. productInfo.setSell_volume(productInfo.getSell_volume() + goodsItem.getNumber());
  519. productInfo.setGoods_id(goodsVo.getId());
  520. // productVos.add(productInfo);
  521. apiProductMapper.updateStockNum(productInfo);
  522. StoreMngChangeVo storeMngChangeVo = new StoreMngChangeVo();
  523. storeMngChangeVo.setChangeType(Dict.changeType.item_1.getItem());
  524. storeMngChangeVo.setChangeReason("小程序购买商品");
  525. storeMngChangeVo.setGoodsId(Integer.parseInt(String.valueOf(goodsVo.getId())));
  526. storeMngChangeVo.setStoreId(Integer.parseInt(String.valueOf(storeId)));
  527. storeMngChangeVo.setMerchSn(goodsVo.getMerchSn());
  528. storeMngChangeVo.setStoreChangeNum(goodsItem.getNumber());
  529. storeMngChangeVo.setStoreOriginalNum(stockNum);
  530. storeMngChangeVo.setStoreValidNum(stockNum - goodsItem.getNumber());
  531. storeMngChangeVo.setCreateTime(new Date());
  532. storeMngChangeVo.setModTime(new Date());
  533. storeMngChangeVo.setCreaterSn("小程序用户"+userName);
  534. storeMngChangeVo.setModerSn("小程序用户"+userName);
  535. storeMngChangeVo.setIsValid(0);
  536. apiStoreMngChangeMapper.save(storeMngChangeVo);
  537. }
  538. /**
  539. * 检查库存和更新库存
  540. * @param checkedGoodsList
  541. * @param storeId
  542. * @param userName
  543. */
  544. private void checkStock(List<CartVo> checkedGoodsList,Long storeId,String userName){
  545. for (CartVo goodsItem : checkedGoodsList) {
  546. Integer stockNum = 0;
  547. //取得规格的信息,判断规格库存
  548. GoodsVo goodsInfo = apiGoodsMapper.queryObjectByStoreId(goodsItem.getGoods_id(), storeId);
  549. if (null == goodsInfo || goodsInfo.getIs_delete() == 1 || goodsInfo.getIs_on_sale() == 0) {
  550. logger.error("订单提交失败:商品不存在");
  551. throw new RRException("订单提交失败:商品不存在");
  552. }
  553. ProductVo productInfo = apiProductMapper.queryByStoreId(goodsItem.getProduct_id(), storeId);
  554. synchronized (productInfo){
  555. if (null == productInfo) {
  556. logger.error("订单提交失败:商品已下架");
  557. throw new RRException("订单提交失败:商品已下架");
  558. }
  559. // String isStockShare = StockUtil.getIsStockShareByGoodsVo(goodsInfo);
  560. // TODO: 2019/3/5 普通商品不受共享库存影响,直接取门店配置库存
  561. stockNum = StockUtil.setStockNumByGoodsVo(goodsInfo);
  562. /*if(goodsInfo.getGoodsBizType().equalsIgnoreCase(Dict.orderBizType.item_00.getItem())){
  563. if (goodsInfo.getIsStockShare().equalsIgnoreCase(Dict.isStockShare.item_1.getItem())) {
  564. stockNum = goodsInfo.getGoods_number();
  565. }
  566. if (goodsInfo.getIsStockShare().equalsIgnoreCase(Dict.isStockShare.item_0.getItem())) {
  567. stockNum = productInfo.getStock_num();
  568. }
  569. }else {
  570. stockNum = productInfo.getStock_num();
  571. }*/
  572. if (null == stockNum || stockNum < goodsItem.getNumber() || stockNum <= 0) {
  573. logger.error("订单提交失败:库存不足,仅剩余" + stockNum);
  574. throw new RRException("订单提交失败:库存不足,仅剩余" + stockNum);
  575. }else{
  576. productInfo.setStore_id(storeId);
  577. //扣减商户商品总库存
  578. updateGoodsStock(goodsInfo, goodsItem, userName);
  579. //扣减门店库存
  580. updateStock(productInfo,goodsInfo,stockNum,goodsItem,storeId,userName);
  581. }
  582. }
  583. }
  584. }
  585. /**
  586. * 设置订单数据
  587. * @param jsonParam
  588. * @param loginUser
  589. * @param storeId
  590. * @param cartResultObj
  591. * @param bizType
  592. * @return
  593. */
  594. public OrderVo setOrderVo(JSONObject jsonParam, UserVo loginUser, Long storeId, Map<String, Object> cartResultObj, String bizType){
  595. OrderVo orderInfo = new OrderVo();
  596. Integer tickDiscId = 0;
  597. Integer campId = 0;
  598. Long couponId = 0L;
  599. Long storeTopicId = 0L;
  600. String campName = "";
  601. BigDecimal fullCutCouponDec = Constant.ZERO;
  602. BigDecimal cond = Constant.ZERO;
  603. BigDecimal money = Constant.ZERO;
  604. BigDecimal goodsTotalPrice = new BigDecimal(0.00);
  605. BigDecimal freightPrice = Constant.ZERO;
  606. //实付金额:商品销售价*数量-优惠金额+运费的总和
  607. BigDecimal actualPrice = new BigDecimal(0.00);
  608. CampMinusDto campMinusDto = new CampMinusDto();
  609. Integer tickDiscId00 = jsonParam.getInteger("tickDiscId00");//优惠券id
  610. Integer tickDiscId02 = jsonParam.getInteger("tickDiscId02");//优惠券id
  611. Integer tickDiscId10 = jsonParam.getInteger("tickDiscId10");//优惠券id
  612. Integer tickDiscId11 = jsonParam.getInteger("tickDiscId11");//优惠券id
  613. Integer campId00 = jsonParam.getInteger("campId00");//促销满减id
  614. Integer campId02 = jsonParam.getInteger("campId02");//促销满减id
  615. Integer campId10 = jsonParam.getInteger("campId10");//促销满减id
  616. Integer campId11 = jsonParam.getInteger("campId11");//促销满减id
  617. CampMinusDto campMinusDto00 = (CampMinusDto)cartResultObj.get("campMinusDto00");
  618. CampMinusDto campMinusDto02 = (CampMinusDto)cartResultObj.get("campMinusDto02");
  619. CampMinusDto campMinusDto10 = (CampMinusDto)cartResultObj.get("campMinusDto10");
  620. CampMinusDto campMinusDto11 = (CampMinusDto)cartResultObj.get("campMinusDto11");
  621. String postscript = jsonParam.getString("postscript");
  622. AddressVo addressVo = jsonParam.getObject("checkedAddress", AddressVo.class);
  623. Date delivery_date = jsonParam.getDate("delivery_date");
  624. String merchSn = (String)jsonParam.get("merchSn");
  625. String delivery_remark = jsonParam.getString("delivery_remark");
  626. BigDecimal freightPrice00 = MapUtils.getBigDecimal("freightPrice00", cartResultObj);
  627. BigDecimal freightPrice02 = MapUtils.getBigDecimal("freightPrice02", cartResultObj);
  628. BigDecimal freightPrice10 = MapUtils.getBigDecimal("freightPrice10", cartResultObj);
  629. BigDecimal freightPrice11 = MapUtils.getBigDecimal("freightPrice11", cartResultObj);
  630. BigDecimal goodsTotalPrice00 = MapUtils.getBigDecimal("goodsTotalPrice00", cartResultObj);
  631. BigDecimal goodsTotalPrice02 = MapUtils.getBigDecimal("goodsTotalPrice02", cartResultObj);
  632. BigDecimal goodsTotalPrice10 = MapUtils.getBigDecimal("goodsTotalPrice10", cartResultObj);
  633. BigDecimal goodsTotalPrice11 = MapUtils.getBigDecimal("goodsTotalPrice11", cartResultObj);
  634. //实付金额:商品销售价*数量-优惠金额+运费的总和
  635. BigDecimal actualPrice00 = MapUtils.getBigDecimal("actualPrice00", cartResultObj);
  636. BigDecimal actualPrice02 = MapUtils.getBigDecimal("actualPrice02", cartResultObj);
  637. BigDecimal actualPrice10 = MapUtils.getBigDecimal("actualPrice10", cartResultObj);
  638. BigDecimal actualPrice11 = MapUtils.getBigDecimal("actualPrice11", cartResultObj);
  639. if(bizType.equalsIgnoreCase(Dict.orderBizType.item_00.getItem())){
  640. tickDiscId = tickDiscId00;
  641. freightPrice = freightPrice00;
  642. goodsTotalPrice = goodsTotalPrice00;
  643. actualPrice = actualPrice00;
  644. campId = campId00;
  645. campMinusDto = campMinusDto00;
  646. }
  647. if(bizType.equalsIgnoreCase(Dict.orderBizType.item_02.getItem())){
  648. tickDiscId = tickDiscId02;
  649. freightPrice = freightPrice02;
  650. goodsTotalPrice = goodsTotalPrice02;
  651. actualPrice = actualPrice02;
  652. campId = campId02;
  653. campMinusDto = campMinusDto02;
  654. }
  655. if(bizType.equalsIgnoreCase(Dict.orderBizType.item_10.getItem())){
  656. tickDiscId = tickDiscId10;
  657. freightPrice = freightPrice10;
  658. goodsTotalPrice = goodsTotalPrice10;
  659. actualPrice = actualPrice10;
  660. campId = campId10;
  661. campMinusDto = campMinusDto10;
  662. }
  663. if(bizType.equalsIgnoreCase(Dict.orderBizType.item_11.getItem())){
  664. tickDiscId = tickDiscId11;
  665. freightPrice = freightPrice11;
  666. goodsTotalPrice = goodsTotalPrice11;
  667. actualPrice = actualPrice11;
  668. campId = campId11;
  669. campMinusDto = campMinusDto11;
  670. }
  671. // goodsTotalPrice = MapUtils.getBigDecimal("goodsTotalPrice", cartResultObj);//整个订单商品总价,不包含运费和优惠金额
  672. MkStoreTicketDiscountVo mkStoreTicketDiscountVo = null;
  673. if (null != tickDiscId && 0 != tickDiscId && campId == 0) {
  674. //校验该订单所选的优惠券
  675. mkStoreTicketDiscountVo = apiMkStoreTicketDiscountMapper.queryObject(tickDiscId);
  676. if(mkStoreTicketDiscountVo != null) {
  677. if (mkStoreTicketDiscountVo.getTickDiscType().equalsIgnoreCase(Dict.tickDiscType.item_00.getItem())) {
  678. cond = mkStoreTicketDiscountVo.getVoucherCond();
  679. money = mkStoreTicketDiscountVo.getVoucherMoney();
  680. }
  681. if (mkStoreTicketDiscountVo.getTickDiscType().equalsIgnoreCase(Dict.tickDiscType.item_01.getItem())) {
  682. cond = mkStoreTicketDiscountVo.getDiscCond();
  683. money = mkStoreTicketDiscountVo.getDiscRatio();//满多少打几折
  684. }
  685. // TODO: 2019/5/21 代金券暂时无用
  686. /*if (mkStoreTicketDiscountVo.getTickDiscType().equalsIgnoreCase(Dict.tickDiscType.item_02.getItem())) {
  687. cond = mkStoreTicketDiscountVo.getExchCond();
  688. money = mkStoreTicketDiscountVo.getExchCond();
  689. }*/
  690. }
  691. }
  692. String couponName = "";
  693. UserCouponVo couponVo = null;
  694. //扣减金额
  695. BigDecimal couponPrice = new BigDecimal(0.00);
  696. if (null != tickDiscId && 0 != tickDiscId && campId == 0) {
  697. //查询未使用且未过期的优惠券
  698. List<UserCouponVo> couponVoList = apiUserCouponMapper.queryObjectByIdAndUsed(tickDiscId, loginUser.getId());
  699. if(couponVoList!= null && couponVoList.size() > 0){
  700. couponVo = couponVoList.get(0);
  701. }
  702. if (null != couponVo && null != couponVo.getTypeMoney()) {
  703. //判断不同业务的订单总金额是否满足优惠条件,满足则标记该订单已使用优惠券
  704. if(goodsTotalPrice.compareTo(cond) >= 0){
  705. //标记该订单已使用优惠券
  706. if(couponVo != null){
  707. couponVo.setUsedTime(new Date());
  708. couponVo.setIsUsed(Dict.isUsed.item_1.getItem());
  709. apiUserCouponMapper.update(couponVo);
  710. if(mkStoreTicketDiscountVo != null) {
  711. if (mkStoreTicketDiscountVo.getTickDiscType().equalsIgnoreCase(Dict.tickDiscType.item_00.getItem())) {
  712. couponPrice = money;
  713. }
  714. if (mkStoreTicketDiscountVo.getTickDiscType().equalsIgnoreCase(Dict.tickDiscType.item_01.getItem())) { //折扣
  715. //商品销售价 - 扣减优惠折扣金额后的实付金额 = 订单优惠金额
  716. couponPrice = goodsTotalPrice.subtract(actualPrice);
  717. }
  718. // TODO: 2019/5/21 代金券暂时无用
  719. /*if (mkStoreTicketDiscountVo.getTickDiscType().equalsIgnoreCase(Dict.tickDiscType.item_02.getItem())) {
  720. cond = mkStoreTicketDiscountVo.getExchCond();
  721. money = mkStoreTicketDiscountVo.getExchCond();
  722. }*/
  723. }
  724. couponId = couponVo.getId();
  725. couponName = couponVo.getCouponName();
  726. Map map = apiUserCouponMapper.queryStoreTopicByDictId(tickDiscId);
  727. storeTopicId = MapUtils.getLong("storeTopicId", map);
  728. }
  729. }else{
  730. couponId = 0L;
  731. storeTopicId = 0L;
  732. }
  733. }
  734. }
  735. MkStoreCampMinusVo mkStoreCampMinusVo = null;
  736. if(null != campId && 0 != campId){
  737. mkStoreCampMinusVo = apiMkStoreCampMinusMapper.queryObject(campId);
  738. if(mkStoreCampMinusVo != null) {
  739. storeTopicId = Long.valueOf(mkStoreCampMinusVo.getStoreTopicId());
  740. campName = mkStoreCampMinusVo.getCampName();
  741. if (mkStoreCampMinusVo.getCampMinusType().equalsIgnoreCase(Dict.campMinusType.item_00.getItem()) || mkStoreCampMinusVo.getCampMinusType().equalsIgnoreCase(Dict.campMinusType.item_01.getItem())) {
  742. fullCutCouponDec = campMinusDto.getMoney();
  743. }
  744. if (mkStoreCampMinusVo.getCampMinusType().equalsIgnoreCase(Dict.campMinusType.item_10.getItem()) || mkStoreCampMinusVo.getCampMinusType().equalsIgnoreCase(Dict.campMinusType.item_11.getItem())) {
  745. //商品销售价 - 扣减优惠折扣金额后的实付金额 = 订单优惠金额
  746. fullCutCouponDec = goodsTotalPrice.subtract(actualPrice);
  747. }
  748. }
  749. }
  750. if (null == delivery_date) {
  751. delivery_date = new Date();
  752. }
  753. if (StringUtils.isNullOrEmpty(delivery_remark)) {
  754. delivery_remark = "尽快送达";
  755. }
  756. //订单价格计算:订单的总价+运费
  757. BigDecimal orderTotalPrice = goodsTotalPrice.add(freightPrice);
  758. // BigDecimal orderTotalPrice = MapUtils.getBigDecimal("orderTotalPrice", cartResultObj);
  759. // actualPrice = cartService.mathActualPrice(couponVo, actualPrice);
  760. // BigDecimal actualPrice = orderTotalPrice.subtract(fullCutCouponDec).subtract(couponPrice);
  761. String thirdMerchSn = "";
  762. StoreVo storeVo = apiStoreMapper.queryObject(storeId);
  763. if(storeVo != null){
  764. thirdMerchSn = storeVo.getThirdPartyMerchCode()==null?"":storeVo.getThirdPartyMerchCode();
  765. }
  766. //一级商户 + 三级商户(拼音首字母) + 业务类型 + 编号
  767. String orderSn = "ZW" + thirdMerchSn + bizType + CommonUtil.generateOrderNumber();
  768. orderInfo.setOrder_sn(orderSn);
  769. orderInfo.setMerchSn(merchSn);
  770. orderInfo.setUser_id(loginUser.getId());
  771. //收货地址和运费
  772. orderInfo.setConsignee(addressVo.getUserName());
  773. orderInfo.setMobile(addressVo.getTelNumber());
  774. orderInfo.setCountry(addressVo.getNationalCode());
  775. orderInfo.setProvince(addressVo.getProvinceName());
  776. orderInfo.setCity(addressVo.getCityName());
  777. orderInfo.setDistrict(addressVo.getCountyName());
  778. orderInfo.setAddress(addressVo.getDetailInfo());
  779. orderInfo.setAddress_id(addressVo.getId());
  780. orderInfo.setDelivery_date(delivery_date);
  781. orderInfo.setDelivery_remark(delivery_remark);
  782. orderInfo.setStore_id(storeId);
  783. orderInfo.setFreight_price(freightPrice.intValue());
  784. orderInfo.setCoupon_id(Integer.parseInt(String.valueOf(couponId)));
  785. orderInfo.setCoupon_price(couponPrice);
  786. orderInfo.setCoupon_name(couponName);
  787. orderInfo.setActivity_id(storeTopicId);
  788. //使用的促销费用
  789. orderInfo.setFull_cut_price(fullCutCouponDec);
  790. orderInfo.setCampMinusId(campId);
  791. orderInfo.setCampName(campName);
  792. //留言
  793. orderInfo.setPostscript(postscript);
  794. orderInfo.setAdd_time(new Date());
  795. orderInfo.setGoods_price(goodsTotalPrice);
  796. orderInfo.setOrder_price(orderTotalPrice);
  797. orderInfo.setActual_price(actualPrice);
  798. orderInfo.setOrder_type("1");
  799. // 待付款
  800. orderInfo.setOrder_status(0);
  801. orderInfo.setShipping_status(0);
  802. orderInfo.setPay_status(0);
  803. orderInfo.setShipping_id(0L);
  804. orderInfo.setShipping_fee(Constant.ZERO);
  805. orderInfo.setIntegral(0);
  806. orderInfo.setIntegral_money(Constant.ZERO);
  807. orderInfo.setCreateTime(new Date());
  808. orderInfo.setModTime(new Date());
  809. orderInfo.setPayMobile(loginUser.getMobile());
  810. orderInfo.setPayTransactionId("");
  811. orderInfo.setIsScan("0");//默认未扫描
  812. UserVo userVo = apiUserMapper.queryObject(orderInfo.getUser_id());
  813. orderInfo.setPayMobile(userVo.getMobile());
  814. orderInfo.setPay_name(userVo.getUsername());
  815. orderInfo.setIsOnfflineOrder(Dict.isOnfflineOrder.item_0.getItem());
  816. return orderInfo;
  817. }
  818. public OrderGoodsVo setOrderGoodsVo(OrderVo orderInfo,CartVo goodsItem,GoodsVo goodsVo){
  819. OrderGoodsVo orderGoodsVo = new OrderGoodsVo();
  820. orderGoodsVo.setOrder_id(orderInfo.getId());
  821. orderGoodsVo.setGoods_id(goodsItem.getGoods_id());
  822. orderGoodsVo.setGoods_sn(goodsItem.getGoods_sn());
  823. orderGoodsVo.setProduct_id(goodsItem.getProduct_id());
  824. orderGoodsVo.setGoods_name(goodsItem.getGoods_name());
  825. orderGoodsVo.setList_pic_url(goodsItem.getList_pic_url());
  826. orderGoodsVo.setMarket_price(goodsItem.getMarket_price());
  827. orderGoodsVo.setRetail_price(goodsItem.getRetail_price());
  828. orderGoodsVo.setNumber(goodsItem.getNumber());
  829. orderGoodsVo.setGoods_specification_name_value(goodsItem.getGoods_specification_name_value());
  830. orderGoodsVo.setGoods_specification_ids(goodsItem.getGoods_specification_ids());
  831. orderGoodsVo.setOrderBizType(goodsItem.getGoodsBizType());
  832. orderGoodsVo.setCreateTime(new Date());
  833. orderGoodsVo.setModTime(new Date());
  834. orderGoodsVo.setGoodsRate(goodsVo.getGoodsRate());
  835. BigDecimal number = new BigDecimal(Long.valueOf(goodsItem.getNumber()));
  836. BigDecimal goodsTotal = goodsItem.getRetail_price().multiply(number);//单商品总价
  837. BigDecimal rate = goodsTotal.divide(orderInfo.getGoods_price(),2, BigDecimal.ROUND_HALF_UP);//单商品总价/订单总价(不含运费、不含优惠券)
  838. BigDecimal freightPrice = BigDecimal.valueOf(orderInfo.getFreight_price());
  839. BigDecimal settlePrice = Constant.ZERO;
  840. if(orderInfo.getFreight_price() != 0 && !"0".equalsIgnoreCase(orderInfo.getCoupon_price()+"")){
  841. //运费-优惠券
  842. BigDecimal rateTotal = freightPrice.subtract(orderInfo.getCoupon_price());
  843. //商品结算平摊价格(含优惠券、运费金额) = 单商品总价 + 单商品总价/订单总价(不含运费、不含优惠券) * 运费与优惠券合计税率
  844. settlePrice = goodsTotal.add(rate.multiply(rateTotal));
  845. }else{
  846. if(orderInfo.getFreight_price()!=0){
  847. //运费税率 = 单商品总价/订单总价(不含运费)* 运费金额
  848. BigDecimal freightRate = rate.multiply(freightPrice);
  849. //商品结算平摊价格(含运费金额) = 单商品总价+运费税率
  850. settlePrice = goodsTotal.add(freightRate);
  851. }
  852. if(!"0".equalsIgnoreCase(orderInfo.getCoupon_price()+"")){
  853. //优惠券税率 = 单商品总价/订单总价(不含优惠券)* 优惠券金额
  854. BigDecimal couponRate = rate.multiply(orderInfo.getCoupon_price());
  855. //商品结算平摊价格(含优惠券金额) = 单商品总价-优惠券税率
  856. settlePrice = goodsTotal.subtract(couponRate);
  857. }
  858. }
  859. if(settlePrice.compareTo(BigDecimal.valueOf(0)) == 0){
  860. orderGoodsVo.setSettlePrice(goodsTotal);//商品结算平摊价格
  861. }else{
  862. orderGoodsVo.setSettlePrice(settlePrice);//商品结算平摊价格
  863. }
  864. orderGoodsVo.setSku(goodsVo.getSku());
  865. return orderGoodsVo;
  866. }
  867. /**
  868. * 支付成功通知
  869. */
  870. @Transactional
  871. public void notifyPaySuccess(OrderVo orderInfo) {
  872. WxTemplate tem = new WxTemplate();
  873. FormIdsEntity formIdsEntity = formIdsService.getFormIdsByMerchOrderSn(orderInfo.getMerchOrderSn());
  874. if (null == formIdsEntity || !StringUtils.isNotEmpty(formIdsEntity.getFormId())) {
  875. return;
  876. }
  877. if (orderInfo.getOrder_type().equals("1")) { // 订单类型 1:普通订单 2:团购订单
  878. TemplateConfVo templateConfVo = apiTemplateConfMapper.queryByTypeId(1); // 模板类型 1订单付款成功 2团购成功 3拼团失败通知 4拼团进度 5 6 7订单配送 8订单评价提醒
  879. if (null == templateConfVo) {
  880. return;
  881. }
  882. UserVo userVo = apiUserMapper.queryObject(orderInfo.getUser_id());
  883. tem.setTemplate_id(templateConfVo.getTemplateId());
  884. // tem.setTopcolor("#00DD00");
  885. tem.setTouser(userVo.getWeixin_openid());
  886. tem.setPage("/pages/ucenter/orderDetail/orderDetail?id=" + orderInfo.getId());
  887. tem.setForm_id(formIdsEntity.getFormId());
  888. List<TemplateData> paras = new ArrayList<TemplateData>();
  889. paras.add(new TemplateData("first", templateConfVo.getDesc(), "#000000"));
  890. paras.add(new TemplateData("keyword1", orderInfo.getMerchOrderSn(), "#000000"));
  891. //订单的商品
  892. Map orderGoodsParam = Maps.newHashMap();
  893. orderGoodsParam.put("order_id", orderInfo.getId());
  894. List<OrderGoodsVo> orderGoods = apiOrderGoodsMapper.queryList(orderGoodsParam);
  895. String body = "";
  896. if (null != orderGoods) {
  897. for (OrderGoodsVo goodsVo : orderGoods) {
  898. body = body + goodsVo.getGoods_name() + "、";
  899. }
  900. if (body.length() > 0) {
  901. body = body.substring(0, body.length() - 1);
  902. }
  903. }
  904. paras.add(new TemplateData("keyword2", body, "#000000"));
  905. paras.add(new TemplateData("keyword3", orderInfo.getActual_price().setScale(2, BigDecimal.ROUND_HALF_DOWN).toString(), "#000000"));
  906. paras.add(new TemplateData("keyword4", DateUtils.format(orderInfo.getAdd_time(), DateUtils.DATE_TIME_PATTERN), "#000000"));
  907. tem.setData(paras);
  908. }
  909. // TODO: 2018/10/25 暂时不实现团购订单
  910. /*if (orderInfo.getOrder_type().equals("2")) { // 订单类型 1:普通订单 2:团购订单
  911. TemplateConfVo templateConfVo = apiTemplateConfMapper.queryByTypeId(2); // 模板类型 1订单付款成功 2团购成功 3拼团失败通知 4拼团进度 5 6 7订单配送 8订单评价提醒
  912. if (null == templateConfVo) {
  913. return;
  914. }
  915. UserVo userVo = apiUserMapper.queryObject(orderInfo.getUser_id());
  916. // 团购明细
  917. GoodsGroupOpenDetailVo openDetailVo = apiGoodsGroupOpenDetailMapper.queryObject(orderInfo.getActivity_id());
  918. // 获取团购
  919. GoodsGroupOpenVo groupOpenVo = apiGoodsGroupOpenMapper.queryObject(openDetailVo.getOpen_id());
  920. tem.setTemplate_id(templateConfVo.getTemplateId());
  921. tem.setTopcolor("#00DD00");
  922. tem.setTouser(userVo.getWeixin_openid());
  923. tem.setPage("/pages/ucenter/orderDetail/orderDetail?id=" + orderInfo.getId());
  924. tem.setForm_id(formIdsEntity.getFormId());
  925. List<TemplateData> paras = new ArrayList<TemplateData>();
  926. paras.add(new TemplateData("keyword1", groupOpenVo.getTitle(), "#000000"));
  927. paras.add(new TemplateData("keyword2", DateUtils.format(groupOpenVo.getOpen_time(), DateUtils.DATE_TIME_PATTERN), "#000000"));
  928. //订单的商品
  929. Map orderGoodsParam = Maps.newHashMap();
  930. orderGoodsParam.put("order_id", orderInfo.getId());
  931. List<OrderGoodsVo> orderGoods = apiOrderGoodsMapper.queryList(orderGoodsParam);
  932. String body = "";
  933. if (null != orderGoods) {
  934. for (OrderGoodsVo goodsVo : orderGoods) {
  935. body = body + goodsVo.getGoods_name() + "、";
  936. }
  937. if (body.length() > 0) {
  938. body = body.substring(0, body.length() - 1);
  939. }
  940. }
  941. paras.add(new TemplateData("keyword3", body, "#000000"));
  942. // 团成员
  943. Map groupParam = Maps.newHashMap();
  944. groupParam.put("open_id", orderInfo.getActivity_id());
  945. List<GoodsGroupOpenDetailVo> openDetailVos = apiGoodsGroupOpenDetailMapper.queryList(groupParam);
  946. String attendMember = "";
  947. if (null != openDetailVos) {
  948. for (GoodsGroupOpenDetailVo detailVo : openDetailVos) {
  949. attendMember = attendMember + detailVo.getNickname() + "、";
  950. }
  951. if (attendMember.length() > 0) {
  952. attendMember = attendMember.substring(0, attendMember.length() - 1);
  953. }
  954. }
  955. paras.add(new TemplateData("keyword4", attendMember, "#000000"));
  956. paras.add(new TemplateData("keyword5", orderInfo.getActual_price().setScale(2, BigDecimal.ROUND_HALF_DOWN).toString(), "#000000"));
  957. paras.add(new TemplateData("keyword5", templateConfVo.getDesc(), "#000000"));
  958. tem.setData(paras);
  959. }*/
  960. try {
  961. // WxTemplateUtil.sendMessage(tem);
  962. formIdsService.releaseFormIds(formIdsEntity);
  963. } catch (Exception e) {
  964. e.printStackTrace();
  965. }
  966. }
  967. /**
  968. * 确认收货
  969. *
  970. * @param orderId
  971. */
  972. @Transactional
  973. public void confirmOrder(Long orderId) {
  974. OrderVo orderVo = apiOrderMapper.queryObject(orderId);
  975. orderVo.setOrder_status(301);
  976. orderVo.setShipping_status(2);
  977. orderVo.setConfirm_time(new Date());
  978. orderVo.setModTime(new Date());
  979. apiOrderMapper.update(orderVo);
  980. }
  981. /*public String printMsgs(Long orderId) {
  982. OrderVo orderEntity = queryObject(orderId);
  983. Map<String, Object> map = new HashMap<String, Object>();
  984. map.put("order_id", orderEntity.getId());
  985. List<OrderGoodsVo> orderGoodsEntities = apiOrderGoodsMapper.queryList(map);
  986. UserVo userVo = apiUserMapper.queryObject(orderEntity.getUser_id());
  987. String content = "<CB>商城超市</CB><BR>";
  988. content += "名称/商品编码 单价 数量 金额<BR>";
  989. for (OrderGoodsVo orderGoodsEntity : orderGoodsEntities) {
  990. content += "--------------------------------<BR>";
  991. content += orderGoodsEntity.getGoods_name() + "<BR>" + orderGoodsEntity.getGoods_sn() + " " + orderGoodsEntity.getRetail_price() + " " + orderGoodsEntity.getNumber()
  992. + " " + orderGoodsEntity.getRetail_price().multiply(new BigDecimal(orderGoodsEntity.getNumber())) + "<BR>";
  993. }
  994. content += "--------------------------------<BR>";
  995. content += "备注:" + orderEntity.getPostscript() + "<BR>";
  996. content += "--------------------------------<BR>";
  997. content += "订单编号:" + orderEntity.getOrder_sn() + "<BR>";
  998. content += "配送配用:" + orderEntity.getShipping_fee() + "元<BR>";
  999. content += "优惠价格:" + orderEntity.getCoupon_price() + "元<BR>";
  1000. content += "合计:" + orderEntity.getOrder_price() + "元<BR>";
  1001. content += "实付:" + orderEntity.getActual_price() + "元<BR>";
  1002. content += "姓名:" + null != userVo.getNickname() ? userVo.getNickname() : "" + "<BR>";
  1003. content += "送货地点:" + orderEntity.getProvince() + orderEntity.getCity() + orderEntity.getDistrict() + orderEntity.getAddress() + "<BR>";
  1004. content += "联系电话:" + orderEntity.getMobile() + "<BR>";
  1005. content += "付款时间:" + DateUtils.format(orderEntity.getPay_time(), DateUtils.DATE_TIME_PATTERN) + "<BR>";
  1006. content += "<QR>" + orderEntity.getId() + "</QR>";
  1007. if ("2".equals(orderEntity.getOrder_type())) {
  1008. content += "<RIGHT><BOLD>【团购】</BOLD></RIGHT>";
  1009. }
  1010. //所属门店
  1011. Long storeId = orderEntity.getStore_id();
  1012. //获取门店的打印机编号,每个门店只有一个打票机
  1013. Map<String, Object> printParams = new HashMap<String, Object>();
  1014. List<SysPrinterVo> printerEntities = apiSysPrinterMapper.queryList(printParams);
  1015. printParams.put("storeId", storeId);
  1016. String sn = "";
  1017. if (printerEntities != null && printerEntities.size() != 0) {
  1018. sn = printerEntities.get(0).getSn();
  1019. }
  1020. return FeiGeUtils.printMsg(sn, content, "1");
  1021. }*/
  1022. public Ticket printMsg(Long orderId) {
  1023. OrderVo orderEntity = queryObject(orderId);
  1024. if(orderEntity != null) {
  1025. if (orderEntity.getOrderBizType().equalsIgnoreCase(Dict.orderBizType.item_10.getItem())
  1026. || orderEntity.getOrderBizType().equalsIgnoreCase(Dict.orderBizType.item_02.getItem())) {
  1027. Map<String, Object> map = new HashMap<String, Object>();
  1028. map.put("order_id", orderEntity.getId());
  1029. List<OrderGoodsVo> orderGoodsEntityList = apiOrderGoodsMapper.queryList(map);
  1030. // 获取门店
  1031. StoreVo storeEntity = apiStoreMapper.queryObject(orderEntity.getStore_id());
  1032. // 获取清关信息
  1033. OrderProcessRecordEntity orderProcessRecordEntity = orderProcessRecordMapper.queryObjectByOrderSn(orderEntity.getOrder_sn());
  1034. UserVo userVo = apiUserMapper.queryObject(orderEntity.getUser_id());
  1035. // 小票头
  1036. TicketHead head = new TicketHead();
  1037. head.setTitle(OmsMerchPropertiesBuilder.instance().getMerchName() + storeEntity.getStoreName());
  1038. head.setMemberId(userVo.getUsername().toString());
  1039. head.setOrderId(orderEntity.getOrder_sn());
  1040. head.setTradeTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss EEE").format(new Date()));
  1041. // 商品信息
  1042. Integer goodsTotal = 0; // 商品总个数
  1043. BigDecimal total = Constant.ZERO; // 商品总计
  1044. List<Goods> goodsList = new ArrayList<>();
  1045. for (OrderGoodsVo orderGoods : orderGoodsEntityList) {
  1046. goodsTotal += orderGoods.getNumber();
  1047. total = total.add(orderGoods.getRetail_price().subtract(new BigDecimal(orderGoods.getNumber()))).setScale(2, BigDecimal.ROUND_HALF_UP);
  1048. Goods goods = new Goods(orderGoods.getGoods_name(), orderGoods.getRetail_price().toString(), orderGoods.getNumber().toString()
  1049. ,orderGoods.getRetail_price().multiply(new BigDecimal(orderGoods.getNumber())).setScale(2,BigDecimal.ROUND_HALF_UP).toString());
  1050. goodsList.add(goods);
  1051. }
  1052. // 收银信息
  1053. CashInfo cashInfo = new CashInfo();
  1054. cashInfo.setGoodsTotal(goodsTotal.toString());
  1055. cashInfo.setTotal(total.setScale(2, BigDecimal.ROUND_HALF_UP).toString());
  1056. cashInfo.setReceipts(orderEntity.getActual_price().setScale(2, BigDecimal.ROUND_HALF_UP).toString());
  1057. cashInfo.setOddChange("0.00");
  1058. cashInfo.setCoupon(orderEntity.getCoupon_price().setScale(2, BigDecimal.ROUND_HALF_UP).toString());
  1059. cashInfo.setFreight(new BigDecimal(orderEntity.getFreight_price()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
  1060. cashInfo.setPaymentMode("微信支付");
  1061. // 海关清单
  1062. CusListing cusListing = new CusListing();
  1063. cusListing.setOrderId(orderEntity.getOrder_sn());
  1064. cusListing.setWaybillId(orderProcessRecordEntity.getLogisticsNo());
  1065. cusListing.setInvtNo(orderProcessRecordEntity.getInvtNo());
  1066. cusListing.setConsignee(orderEntity.getConsignee());
  1067. cusListing.setConsigneeTel(orderEntity.getMobile());
  1068. cusListing.setOriginAddress(PrintTicketPropertiesBuilder.instance().getAddress());
  1069. cusListing.setDeliveryAddress(storeEntity.getStoreAddress());
  1070. return TicketPrintUtil.print(head, goodsList, cashInfo, cusListing);
  1071. }else{
  1072. return null;
  1073. }
  1074. }else{
  1075. return null;
  1076. }
  1077. }
  1078. public List<OrderVo> queryObjectByIdList(List<Long> orderIdList){
  1079. return apiOrderMapper.queryObjectByIdList(orderIdList);
  1080. }
  1081. public List<OrderVo> queryObjectByMerchOrderSn(String merchOrderSn){
  1082. return apiOrderMapper.queryObjectByMerchOrderSn(merchOrderSn);
  1083. }
  1084. public int queryCountByMerchOrderSn(String merchOrderSn){
  1085. return apiOrderMapper.queryCountByMerchOrderSn(merchOrderSn);
  1086. }
  1087. public int queryCountByPayId(String payId){
  1088. return apiOrderMapper.queryCountByPayId(payId);
  1089. }
  1090. public List<OrderVo> queryOrderByMerchOrderSnAndRefundStatus(String merchOrderSn){
  1091. return apiOrderMapper.queryOrderByMerchOrderSnAndRefundStatus(merchOrderSn);
  1092. }
  1093. }