ApiOrderService.java 56 KB

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