OrderController.java 79 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598
  1. package com.kmall.admin.controller;
  2. import com.kmall.admin.dto.OrderExpressDto;
  3. import com.kmall.admin.dto.SystemFormatDto;
  4. import com.kmall.admin.entity.*;
  5. import com.kmall.admin.fromcomm.entity.SysUserEntity;
  6. import com.kmall.admin.haikong.vo.CalculateOrderDiscountPriceResponseVO;
  7. import com.kmall.admin.service.*;
  8. import com.kmall.admin.utils.CalculateTax;
  9. import com.kmall.admin.utils.ParamUtils;
  10. import com.kmall.admin.utils.ShiroUtils;
  11. import com.kmall.admin.haikong.vo.CalculateOrderDiscountPriceVO;
  12. import com.kmall.common.constant.Dict;
  13. import com.kmall.common.constant.JxlsXmlTemplateName;
  14. import com.kmall.common.utils.*;
  15. import com.kmall.common.utils.excel.Entry;
  16. import com.kmall.common.utils.excel.ExcelExport;
  17. import com.kmall.common.utils.excel.ExcelUtil;
  18. import com.kmall.common.utils.print.ticket.item.Ticket;
  19. import com.kmall.common.utils.wechat.WechatMicropayApiResult;
  20. import com.kmall.common.utils.wechat.WechatRefundApiResult;
  21. import com.kmall.common.utils.wechat.WechatReverseApiResult;
  22. import com.kmall.manager.manager.alipay.AliPayMicropayApiResult;
  23. import com.kmall.manager.manager.alipay.AliPayUtil;
  24. import com.kmall.manager.manager.dto.PayOriginInfoDTO;
  25. import com.kmall.manager.manager.express.sf.ServiceException;
  26. import com.kmall.manager.manager.merch.OmsMerchPropertiesBuilder;
  27. import com.kmall.manager.manager.pingan.PinganUtil;
  28. import com.kmall.manager.manager.pingan.dto.PinganResponseDto;
  29. import com.kmall.manager.manager.wechat.WechatGlobalUtil;
  30. import com.kmall.manager.manager.wechat.WechatUtil;
  31. import com.kmall.manager.manager.wechat.wxglobal.dto.WechatGlobalRefundApiResult;
  32. import net.sf.json.JSONObject;
  33. import org.apache.commons.lang3.StringUtils;
  34. import org.apache.commons.logging.Log;
  35. import org.apache.commons.logging.LogFactory;
  36. import org.apache.shiro.authz.annotation.RequiresPermissions;
  37. import org.springframework.beans.factory.annotation.Autowired;
  38. import org.springframework.web.bind.annotation.*;
  39. import org.springframework.web.multipart.MultipartFile;
  40. import javax.servlet.http.HttpServletRequest;
  41. import javax.servlet.http.HttpServletResponse;
  42. import java.io.IOException;
  43. import java.math.BigDecimal;
  44. import java.math.RoundingMode;
  45. import java.text.ParseException;
  46. import java.text.SimpleDateFormat;
  47. import java.util.*;
  48. /**
  49. * @author Scott
  50. * @email
  51. * @date 2017-08-13 10:41:09
  52. */
  53. @RestController
  54. @RequestMapping("order")
  55. public class OrderController {
  56. private Log logger = LogFactory.getLog(OrderController.class);
  57. @Autowired
  58. private OrderService orderService;
  59. @Autowired
  60. private OrderGoodsService orderGoodsService;
  61. @Autowired
  62. private OrderProcessRecordService orderProcessRecordService;
  63. @Autowired
  64. private OrderRefundService orderRefundService;
  65. @Autowired
  66. private OrderExceptionRecordService orderExceptionRecordService;
  67. @Autowired
  68. private StoreService storeService;
  69. @Autowired
  70. private OrderWXPayRecordService orderWXPayRecordService;
  71. @Autowired
  72. private PinganResponseService pinganResponseService;
  73. @Autowired
  74. private ExcelUtil excelUtil;
  75. @Autowired
  76. private ShippingService shippingService;
  77. private volatile Integer code = 1;
  78. @Autowired
  79. private UserService userService;
  80. @Autowired
  81. private GoodsService goodsService;
  82. /**
  83. * 列表
  84. */
  85. @RequestMapping("/list")
  86. @RequiresPermissions("order:list")
  87. public R list(@RequestParam Map<String, Object> params) {
  88. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  89. params = ParamUtils.setTimeMap(params);
  90. //查询列表数据
  91. Query query = new Query(params);
  92. query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_0.getItem());
  93. List<OrderEntity> orderList = orderService.queryList(query);
  94. int total = orderService.queryTotal(query);
  95. PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage());
  96. return R.ok().put("page", pageUtil);
  97. }
  98. /**
  99. * 信息
  100. */
  101. @RequestMapping("/info/{id}")
  102. @RequiresPermissions("order:info")
  103. public R info(@PathVariable("id") Long id) {
  104. OrderEntity order = orderService.queryObject(id);
  105. return R.ok().put("order", order);
  106. }
  107. /**
  108. * 信息
  109. */
  110. @RequestMapping("/infos/{id}")
  111. @RequiresPermissions("order:infos")
  112. public R infos(@PathVariable("id") Long id) {
  113. OrderEntity order = orderService.queryInfos(id);
  114. return R.ok().put("order", order);
  115. }
  116. /**
  117. * 保存
  118. */
  119. @RequestMapping("/save")
  120. @RequiresPermissions("order:save")
  121. public R save(@RequestBody OrderEntity order) {
  122. orderService.save(order);
  123. return R.ok();
  124. }
  125. /**
  126. * 修改
  127. */
  128. @RequestMapping("/update")
  129. @RequiresPermissions("order:update")
  130. public R update(@RequestBody OrderEntity order) {
  131. orderService.update(order);
  132. return R.ok();
  133. }
  134. /**
  135. * 删除
  136. */
  137. @RequestMapping("/delete")
  138. @RequiresPermissions("order:delete")
  139. public R delete(@RequestBody Long[] ids) {
  140. orderService.deleteBatch(ids);
  141. return R.ok();
  142. }
  143. /**
  144. * 查看所有列表
  145. */
  146. @RequestMapping("/queryAll")
  147. public R queryAll(@RequestParam Map<String, Object> params) {
  148. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  149. List<OrderEntity> list = orderService.queryList(params);
  150. return R.ok().put("list", list);
  151. }
  152. /**
  153. * 总计
  154. */
  155. @RequestMapping("/queryTotal")
  156. public R queryTotal(@RequestParam Map<String, Object> params) {
  157. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  158. int sum = orderService.queryTotal(params);
  159. return R.ok().put("sum", sum);
  160. }
  161. /**
  162. * 确定收货
  163. *
  164. * @param id
  165. * @return
  166. */
  167. @RequestMapping("/confirm")
  168. @RequiresPermissions("order:confirm")
  169. public R confirm(@RequestBody Long id) {
  170. orderService.confirm(id);
  171. return R.ok();
  172. }
  173. /**
  174. * 发货
  175. *
  176. * @param order
  177. * @return
  178. */
  179. @RequestMapping("/sendGoods")
  180. @RequiresPermissions("order:sendGoods")
  181. public R sendGoods(@RequestBody OrderEntity order) {
  182. orderService.sendGoods(order);
  183. return R.ok();
  184. }
  185. /**
  186. * 跟踪快递轨迹
  187. *
  188. * @param id
  189. * @return
  190. */
  191. @RequestMapping("/getLogistics/{id}")
  192. @RequiresPermissions("order:getLogistics")
  193. public R getLogistics(@PathVariable("id") Long id) {
  194. Map result = orderService.getLogistics(id);
  195. return R.ok().put("result", result);
  196. }
  197. /**
  198. * 获取订单清关信息
  199. *
  200. * @param orderSn
  201. * @return
  202. */
  203. @RequestMapping("/getProcess/{orderSn}")
  204. @RequiresPermissions("order:getProcess")
  205. public R getProcess(@PathVariable("orderSn") String orderSn) {
  206. OrderProcessRecordEntity orderProcessRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderSn);
  207. if (orderProcessRecordEntity != null) {
  208. if (orderProcessRecordEntity.getShipmentStartTime() != null) {
  209. orderProcessRecordEntity.setShipmentStartTimeStr(
  210. DateUtils.format(orderProcessRecordEntity.getShipmentStartTime(), DateUtils.DATE_TIME_PATTERN));
  211. }
  212. if (orderProcessRecordEntity.getShipmentSuccTime() != null) {
  213. orderProcessRecordEntity.setShipmentSuccTimeStr(
  214. DateUtils.format(orderProcessRecordEntity.getShipmentSuccTime(), DateUtils.DATE_TIME_PATTERN));
  215. }
  216. if (orderProcessRecordEntity.getCustomsStartTime() != null) {
  217. orderProcessRecordEntity.setCustomsStartTimeStr(
  218. DateUtils.format(orderProcessRecordEntity.getCustomsStartTime(), DateUtils.DATE_TIME_PATTERN));
  219. }
  220. if (orderProcessRecordEntity.getCustomsSuccTime() != null) {
  221. orderProcessRecordEntity.setCustomsSuccTimeStr(
  222. DateUtils.format(orderProcessRecordEntity.getCustomsSuccTime(), DateUtils.DATE_TIME_PATTERN));
  223. }
  224. if (orderProcessRecordEntity.getWaybillStartTime() != null) {
  225. orderProcessRecordEntity.setWaybillStartTimeStr(
  226. DateUtils.format(orderProcessRecordEntity.getWaybillStartTime(), DateUtils.DATE_TIME_PATTERN));
  227. }
  228. if (orderProcessRecordEntity.getWaybillSuccTime() != null) {
  229. orderProcessRecordEntity.setWaybillSuccTimeStr(
  230. DateUtils.format(orderProcessRecordEntity.getWaybillSuccTime(), DateUtils.DATE_TIME_PATTERN));
  231. }
  232. if (orderProcessRecordEntity.getEleOrderStartTime() != null) {
  233. orderProcessRecordEntity.setEleOrderStartTimeStr(
  234. DateUtils.format(orderProcessRecordEntity.getEleOrderStartTime(), DateUtils.DATE_TIME_PATTERN));
  235. }
  236. if (orderProcessRecordEntity.getEleOrderSuccTime() != null) {
  237. orderProcessRecordEntity.setEleOrderSuccTimeStr(
  238. DateUtils.format(orderProcessRecordEntity.getEleOrderSuccTime(), DateUtils.DATE_TIME_PATTERN));
  239. }
  240. if (orderProcessRecordEntity.getAddOrderStartTime() != null) {
  241. orderProcessRecordEntity.setAddOrderStartTimeStr(
  242. DateUtils.format(orderProcessRecordEntity.getAddOrderStartTime(), DateUtils.DATE_TIME_PATTERN));
  243. }
  244. if (orderProcessRecordEntity.getAddOrderSuccTime() != null) {
  245. orderProcessRecordEntity.setAddOrderSuccTimeStr(
  246. DateUtils.format(orderProcessRecordEntity.getAddOrderSuccTime(), DateUtils.DATE_TIME_PATTERN));
  247. }
  248. if (orderProcessRecordEntity.getPaySuccTime() != null) {
  249. orderProcessRecordEntity.setPaySuccTimeStr(
  250. DateUtils.format(orderProcessRecordEntity.getPaySuccTime(), DateUtils.DATE_TIME_PATTERN));
  251. }
  252. if (orderProcessRecordEntity.getPayStartTime() != null) {
  253. orderProcessRecordEntity.setPayStartTimeStr(
  254. DateUtils.format(orderProcessRecordEntity.getPayStartTime(), DateUtils.DATE_TIME_PATTERN));
  255. }
  256. if (orderProcessRecordEntity.getPaymentStartTime() != null) {
  257. orderProcessRecordEntity.setPaymentStartTimeStr(
  258. DateUtils.format(orderProcessRecordEntity.getPaymentStartTime(), DateUtils.DATE_TIME_PATTERN));
  259. }
  260. if (orderProcessRecordEntity.getPaymentSuccTime() != null) {
  261. orderProcessRecordEntity.setPaymentSuccTimeStr(
  262. DateUtils.format(orderProcessRecordEntity.getPaymentSuccTime(), DateUtils.DATE_TIME_PATTERN));
  263. }
  264. }
  265. return R.ok().put("orderProcessRecordEntity", orderProcessRecordEntity);
  266. }
  267. /**
  268. * 打印小票
  269. *
  270. * @param id
  271. * @return
  272. */
  273. @RequestMapping("/printMsg")
  274. public R printMsg(@RequestBody Long id) {
  275. Ticket ticket = orderService.printMsg(id);
  276. return R.ok().put("ticket", ticket);
  277. }
  278. @RequestMapping("/printMsgAndChangeCode")
  279. public R printMsgAndChangeCode(@RequestBody Map param) {
  280. Ticket ticket = null;
  281. try{
  282. Integer id = (Integer) param.get("id");
  283. String sessionId = (String) param.get("sessionId");
  284. ticket = orderService.printMsg(id.longValue(),sessionId);
  285. return R.ok().put("ticket", ticket);
  286. }catch (Exception e){
  287. logger.error("[printMsgAndChangeCode-----核销小票打印失败]",e);
  288. }
  289. return R.ok().put("ticket", ticket);
  290. }
  291. /**
  292. * 打印快递面单
  293. * @param param
  294. * @return
  295. */
  296. @RequestMapping("/printMsgChangeEwb")
  297. public R printMsgChangeEwb(@RequestBody Map param) {
  298. Integer id = (Integer) param.get("id");
  299. String sessionId = (String) param.get("sessionId");
  300. Ticket ticket = orderService.printMsgEwb(id.longValue(),sessionId);
  301. return R.ok().put("ticket", ticket);
  302. }
  303. @RequestMapping("/printCode")
  304. public R printMsg(){
  305. Map map = new HashMap();
  306. map.put("code",code++); // 系统中累加
  307. map.put("shopName","深圳xxxxxxCW店"); // 根据门店编号查询
  308. map.put("time",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  309. map.put("orderNo",UUID.randomUUID().toString().replace("//-","")); //
  310. return R.ok().put("ticket", map);
  311. }
  312. /**
  313. * 订单取消请求
  314. */
  315. @RequiresPermissions(value = {"order:refund"})
  316. @RequestMapping(value = "cancel", method = RequestMethod.POST)
  317. public Object cancel(Long orderId) {
  318. OrderEntity orderInfo = orderService.queryObject(orderId);
  319. if (null == orderInfo) {
  320. return R.error("订单不存在");
  321. }
  322. if (orderInfo.getOrderStatus() != 0) {
  323. return R.error("订单状态不支持取消");
  324. }
  325. orderService.cancelOrder(orderInfo);
  326. return R.ok();
  327. }
  328. /**
  329. * 订单退款请求
  330. */
  331. @RequiresPermissions(value = {"order:refund"})
  332. @RequestMapping(value = "refund", method = RequestMethod.POST)
  333. public Object refund(Long orderId, String refundId, BigDecimal refundMoney) {
  334. OrderEntity orderInfo = orderService.queryObject(orderId);
  335. if (null == orderInfo) {
  336. return R.error("订单不存在");
  337. }
  338. if (orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_401.getItem()) ||
  339. orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_402.getItem())) {
  340. return R.error("订单已退款");
  341. }
  342. Double totalActualPrice = orderService.getTotalActualPrice(orderInfo.getMerchOrderSn());
  343. if (totalActualPrice == null) {
  344. totalActualPrice = 0d;
  345. }
  346. OrderProcessRecordEntity processRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderInfo.getOrderSn());
  347. if(org.apache.commons.lang.StringUtils.isNotEmpty(processRecordEntity.getIsCustomsSend())) {
  348. if (processRecordEntity.getIsCustomsSend().equalsIgnoreCase("2")) {
  349. return R.error("订单正在清关中,不能退款");
  350. }
  351. if (processRecordEntity.getIsCustomsSend().equalsIgnoreCase("1")) {
  352. return R.error("订单已清关完成,不能退款");
  353. }
  354. }
  355. String refundResult = "";
  356. if (orderInfo.getOrderStatus() != Integer.parseInt(Dict.orderStatus.item_0.getItem())) {
  357. if (orderInfo.getPayFlag().equalsIgnoreCase(Dict.payFlag.item_wxglobalpay.getItem())) {
  358. refundResult = wxGlobalRefund(orderInfo, totalActualPrice);
  359. if (StringUtils.isNotBlank(refundResult)) {
  360. return R.error(refundResult);
  361. }
  362. } else if (orderInfo.getPayFlag().equalsIgnoreCase(Dict.payFlag.item_pingan.getItem())) {
  363. refundResult = pinganRefund(orderInfo, refundId);
  364. if (StringUtils.isNotBlank(refundResult)) {
  365. return R.error(refundResult);
  366. }
  367. } else{
  368. refundResult = wxRefund(orderInfo,totalActualPrice);
  369. if(StringUtils.isNotBlank(refundResult)){
  370. return R.error(refundResult);
  371. }
  372. }
  373. }
  374. return R.ok("退款成功");
  375. }
  376. /**
  377. * 平安申请退款
  378. * @param orderInfo
  379. * @return
  380. */
  381. private String pinganRefund(OrderEntity orderInfo, String refundId){
  382. Integer refundAmount = orderInfo.getActualPrice().multiply(new BigDecimal(100)).intValue();
  383. PinganResponseDto responseDto = PinganUtil.pinganPayRefund(orderInfo.getMerchOrderSn(), refundId, refundAmount, null);
  384. if (!Objects.isNull(responseDto)) {
  385. responseDto.setOutNo(orderInfo.getMerchOrderSn());
  386. responseDto.setCreateTime(new Date());
  387. pinganResponseService.save(responseDto);
  388. if ("0".equals(responseDto.getErrcode())) {
  389. JSONObject tradeResult = JSONObject.fromObject(responseDto.getDatajson());
  390. if (Dict.pinganRefundStatus.item_1.getItem().equals(tradeResult.getString("status"))) {
  391. orderService.pinganRefund(orderInfo, tradeResult, refundId);
  392. } else {
  393. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  394. OrderRefundEntity orderRefund = new OrderRefundEntity();
  395. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  396. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  397. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  398. SysUserEntity user = ShiroUtils.getUserEntity();
  399. orderRefund.setModerSn(user.getUsername());
  400. orderRefund.setModTime(new Date());
  401. orderRefund.setOutRefundNo(tradeResult.getString("ord_no"));
  402. if (mallOrderRefund != null) {
  403. orderRefund.setId(mallOrderRefund.getId());
  404. orderRefundService.update(orderRefund);//退款记录
  405. }
  406. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  407. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  408. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  409. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  410. mallOrderExceptionRecord.setExceptionContent("退款失败");
  411. mallOrderExceptionRecord.setCreateTime(new Date());
  412. orderExceptionRecordService.save(mallOrderExceptionRecord);
  413. return "发起平安支付退款失败!";
  414. }
  415. } else {
  416. return responseDto.getMsg();
  417. }
  418. }
  419. return "";
  420. }
  421. /**
  422. * 微信申请退款
  423. * @param orderInfo
  424. * @param totalActualPrice
  425. * @return
  426. */
  427. private String wxRefund(OrderEntity orderInfo,Double totalActualPrice){
  428. WechatRefundApiResult result = WechatUtil.wxRefund(orderInfo.getMerchOrderSn().toString(), totalActualPrice,
  429. orderInfo.getActualPrice().doubleValue());
  430. if (result.getResult_code().equals(WechatUtil.WXTradeState.SUCCESS.getCode())) {
  431. orderService.refund(orderInfo, result);
  432. } else {
  433. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  434. OrderRefundEntity orderRefund = new OrderRefundEntity();
  435. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  436. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  437. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  438. SysUserEntity user = ShiroUtils.getUserEntity();
  439. orderRefund.setModerSn(user.getUsername());
  440. orderRefund.setModTime(new Date());
  441. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  442. if (mallOrderRefund != null) {
  443. orderRefund.setId(mallOrderRefund.getId());
  444. orderRefundService.update(orderRefund);//退款记录
  445. }
  446. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  447. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  448. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  449. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  450. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des());
  451. mallOrderExceptionRecord.setCreateTime(new Date());
  452. orderExceptionRecordService.save(mallOrderExceptionRecord);
  453. return result.getErr_code_des();
  454. }
  455. return "";
  456. }
  457. /**
  458. * 微信国际申请退款
  459. * @param orderInfo
  460. * @param totalActualPrice
  461. * @return
  462. */
  463. private String wxGlobalRefund(OrderEntity orderInfo,Double totalActualPrice){
  464. WechatGlobalRefundApiResult result = WechatGlobalUtil.wxRefund(orderInfo.getMerchOrderSn().toString(), totalActualPrice,
  465. orderInfo.getActualPrice().doubleValue());
  466. if (result.getResult_code().equals(WechatUtil.WXTradeState.SUCCESS.getCode())) {
  467. orderService.globalRefund(orderInfo, result);
  468. } else {
  469. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  470. OrderRefundEntity orderRefund = new OrderRefundEntity();
  471. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  472. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  473. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  474. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  475. orderRefund.setModTime(new Date());
  476. if (mallOrderRefund != null) {
  477. orderRefund.setId(mallOrderRefund.getId());
  478. orderRefundService.update(orderRefund);//退款记录
  479. }
  480. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  481. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  482. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  483. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  484. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des());
  485. mallOrderExceptionRecord.setCreateTime(new Date());
  486. orderExceptionRecordService.save(mallOrderExceptionRecord);
  487. return result.getErr_code_des();
  488. }
  489. return "";
  490. }
  491. /**
  492. * 订单退款请求
  493. */
  494. @RequiresPermissions(value = {"order:offilineRefund"})
  495. @RequestMapping(value = "offilineRefund", method = RequestMethod.POST)
  496. public Object offilineRefund(Long orderId) {
  497. OrderEntity orderInfo = orderService.queryObject(orderId);
  498. if (null == orderInfo) {
  499. return R.error("订单不存在");
  500. }
  501. if (orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_401.getItem()) ||
  502. orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_402.getItem())) {
  503. return R.error("订单已退款");
  504. }
  505. if (orderInfo.getOrderStatus() != Integer.parseInt(Dict.orderStatus.item_0.getItem())) {
  506. if (Dict.payFlag.item_cash.getItem().equals(orderInfo.getPayFlag())) {
  507. //现金支付,直接修改订单状态
  508. orderService.refund(orderInfo);
  509. } else if (Dict.payFlag.item_weixin.getItem().equals(orderInfo.getPayFlag())) {
  510. //微信线下扫码支付
  511. WechatRefundApiResult result = WechatUtil
  512. .wxRefund(orderInfo.getOrderSnWx(), orderInfo.getActualPrice().doubleValue(),
  513. orderInfo.getActualPrice().doubleValue());
  514. if (result.getResult_code().equals(WechatUtil.WXTradeState.SUCCESS.getCode())) {
  515. orderService.refund(orderInfo, result);
  516. } else {
  517. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  518. OrderRefundEntity orderRefund = new OrderRefundEntity();
  519. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  520. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  521. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  522. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  523. SysUserEntity user = ShiroUtils.getUserEntity();
  524. orderRefund.setModerSn(user.getUsername());
  525. orderRefund.setModTime(new Date());
  526. if (mallOrderRefund != null) {
  527. orderRefund.setId(mallOrderRefund.getId());
  528. orderRefundService.update(orderRefund);//退款记录
  529. }
  530. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  531. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  532. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  533. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  534. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des());
  535. mallOrderExceptionRecord.setCreateTime(new Date());
  536. orderExceptionRecordService.save(mallOrderExceptionRecord);
  537. return R.error(result.getErr_code_des());
  538. }
  539. }else if(Dict.payFlag.item_alipay.getItem().equals(orderInfo.getPayFlag())){
  540. // 支付宝线下扫码支付
  541. AliPayMicropayApiResult result = null;
  542. try {
  543. result = AliPayUtil.aliTradeRefund(orderInfo.getOrderSn(),orderInfo.getActualPrice()+"",
  544. "顾客退款",orderInfo.getStoreId().toString());
  545. } catch (Exception e) {
  546. e.printStackTrace();
  547. }
  548. if (result.getCode().equals(AliPayUtil.AliPayTradeState.SUCC.getCode())) {
  549. orderService.refund(orderInfo, result);
  550. } else {
  551. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  552. OrderRefundEntity orderRefund = new OrderRefundEntity();
  553. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  554. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  555. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  556. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  557. SysUserEntity user = ShiroUtils.getUserEntity();
  558. orderRefund.setModerSn(user.getUsername());
  559. orderRefund.setModTime(new Date());
  560. if (mallOrderRefund != null) {
  561. orderRefund.setId(mallOrderRefund.getId());
  562. orderRefundService.update(orderRefund);//退款记录
  563. }
  564. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  565. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  566. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  567. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  568. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getSubMsg());
  569. mallOrderExceptionRecord.setCreateTime(new Date());
  570. orderExceptionRecordService.save(mallOrderExceptionRecord);
  571. return R.error(result.getSubMsg());
  572. }
  573. } else{
  574. return R.ok("退款成功");
  575. }
  576. }
  577. return R.ok("退款成功");
  578. }
  579. /**
  580. * 获取首页展示信息--会员购买率相关
  581. *
  582. * @param params
  583. * @return
  584. */
  585. @RequestMapping("/getUserOrderInfo")
  586. public R getUserOrderInfo(@RequestParam Map<String, Object> params) {
  587. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  588. int result = orderService.getUserOrderInfo(params);
  589. return R.ok().put("result", result);
  590. }
  591. @RequiresPermissions(value = {"order:orderSubmit"})
  592. @RequestMapping(value = "orderSubmit", method = RequestMethod.POST)
  593. @ResponseBody
  594. public R orderSubmit(@RequestBody List<OfflineCartEntity> offlineCartEntityList) {
  595. Map resultObj = null;
  596. try {
  597. SysUserEntity user = ShiroUtils.getUserEntity();
  598. resultObj = orderService.orderSubmit(offlineCartEntityList, user);
  599. if (((Integer) resultObj.get("errno")) != 0) {
  600. return R.error((String) resultObj.get("errmsg"));
  601. }
  602. } catch (Exception e) {
  603. e.printStackTrace();
  604. }
  605. return R.ok("订单提交成功");
  606. }
  607. /**
  608. * 确认付款
  609. *
  610. * @param id
  611. * @return
  612. */
  613. @RequestMapping("/confirmPay")
  614. @RequiresPermissions("order:confirmPay")
  615. public R confirmPay(@RequestBody Long id) {
  616. orderService.confirmPay(id, Dict.payFlag.item_cash.getItem(), null);
  617. return R.ok();
  618. }
  619. @RequestMapping("/offilineOrderList")
  620. @RequiresPermissions("order:offilineOrderList")
  621. public R offilineOrderList(@RequestParam Map<String, Object> params) {
  622. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  623. params = ParamUtils.setTimeMap(params);
  624. //查询列表数据
  625. Query query = new Query(params);
  626. query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  627. List<OrderEntity> orderList = orderService.queryOffilineOrderList(query);
  628. int total = orderService.queryOffilineOrderTotal(query);
  629. for(OrderEntity orderEntity : orderList) {
  630. BigDecimal tax = new BigDecimal(0);
  631. Map map = new HashMap();
  632. map.put("orderId", orderEntity.getId());
  633. List<OrderGoodsEntity> goodsList = orderGoodsService.queryList(map);
  634. for (OrderGoodsEntity orderGoodsEntity : goodsList) {
  635. GoodsEntity goodsEntity = goodsService.queryObject(orderGoodsEntity.getGoodsId());
  636. BigDecimal goodsTax = CalculateTax.calculateFinalTax(goodsEntity,orderGoodsEntity.getMarketPrice(),goodsService).setScale(3,RoundingMode.HALF_UP);
  637. goodsTax = goodsTax.multiply(new BigDecimal(orderGoodsEntity.getNumber())).setScale(2,RoundingMode.HALF_UP);
  638. orderGoodsEntity.setTax(goodsTax);
  639. tax = tax.add(goodsTax).setScale(2,RoundingMode.HALF_UP);
  640. // BigDecimal goodsTax = orderGoodsEntity.getMarketPrice().divide(new BigDecimal(1).add(orderGoodsEntity.getGoodsRate()),2,RoundingMode.HALF_DOWN).multiply(orderGoodsEntity.getGoodsRate())
  641. // .multiply(new BigDecimal(orderGoodsEntity.getNumber())).setScale(2,RoundingMode.HALF_DOWN);
  642. // tax = tax.add(goodsTax).setScale(2,RoundingMode.HALF_UP);
  643. }
  644. orderEntity.setTax(tax);
  645. }
  646. // 遍历循环订单是哪个店员销售的,根据订单号查询
  647. PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage());
  648. return R.ok().put("page", pageUtil);
  649. }
  650. /**
  651. * 当查验单从保税仓发货时, 会导致门店库存不还原
  652. * 还原查验单库存
  653. * @param orderSns 查验单单号
  654. * @return 请求结果
  655. */
  656. @RequestMapping(value = "/restore", method = RequestMethod.POST)
  657. public R restore (@RequestBody String orderSns) {
  658. if (StringUtils.isEmpty(orderSns)) {
  659. return R.error("订单编号不能为空!");
  660. }
  661. try {
  662. Boolean restore = orderService.restore(orderSns);
  663. if (restore) {
  664. return R.ok("恢复【" + orderSns + "】这些查验订单的库存成功");
  665. }
  666. } catch (RRException e) {
  667. return R.error(e.getMsg());
  668. } catch (Exception e) {
  669. return R.error("恢复【 " + orderSns + " 】这些查验订单的库存失败!");
  670. }
  671. return R.error("恢复【 " + orderSns + " 】这些查验订单的库存失败!");
  672. }
  673. @RequestMapping("/offlineInfos/{id}")
  674. @RequiresPermissions("order:offlineInfos")
  675. public R queryObjectBySysUser(@PathVariable("id") Long id) {
  676. OrderEntity order = orderService.queryObjectBySysUser(id);
  677. List<OrderWXPayRecordEntity> payRecords = orderWXPayRecordService.getRecordsByOutTradeNo(order.getOrderSn());
  678. BigDecimal tax = new BigDecimal(0);
  679. List<OrderGoodsEntity> goodsList = order.getOrderGoodsEntityList();
  680. for (OrderGoodsEntity orderGoodsEntity : goodsList) {
  681. GoodsEntity goodsEntity = goodsService.queryObject(orderGoodsEntity.getGoodsId());
  682. BigDecimal goodsTax = CalculateTax.calculateFinalTax(goodsEntity,orderGoodsEntity.getMarketPrice(),goodsService).setScale(3,RoundingMode.HALF_UP);
  683. goodsTax = goodsTax.multiply(new BigDecimal(orderGoodsEntity.getNumber())).setScale(2,RoundingMode.HALF_UP);
  684. orderGoodsEntity.setTax(goodsTax);
  685. tax = tax.add(goodsTax).setScale(2,RoundingMode.HALF_UP);
  686. // BigDecimal goodsTax = orderGoodsEntity.getMarketPrice().divide(new BigDecimal(1).add(orderGoodsEntity.getGoodsRate()),2,RoundingMode.HALF_DOWN).multiply(orderGoodsEntity.getGoodsRate())
  687. // .multiply(new BigDecimal(orderGoodsEntity.getNumber())).setScale(2,RoundingMode.HALF_DOWN);
  688. // orderGoodsEntity.setTax(goodsTax);
  689. //
  690. // tax = tax.add(goodsTax).setScale(2,RoundingMode.HALF_UP);
  691. }
  692. order.setTax(tax);
  693. order.setPayRecordList(payRecords);
  694. return R.ok().put("order", order);
  695. }
  696. @RequestMapping("/pickUpCodeList")
  697. public R pickUpCodeList(@RequestBody Map<String, Object> params) {
  698. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  699. //查询列表数据
  700. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  701. List<OrderEntity> orderList = orderService.queryPickUpCodeList(params);
  702. return R.ok().put("list", orderList);
  703. }
  704. @RequestMapping("/wxMicropayPay")
  705. @RequiresPermissions("order:wxMicropayPay")
  706. public R wxMicropayPay(Long id, String auth_code) {
  707. R r = null;
  708. SysUserEntity user = ShiroUtils.getUserEntity();
  709. if (user == null) {
  710. throw new RRException("用户登录超时,请重新登录");
  711. }
  712. if (!user.getRoleType().equalsIgnoreCase("2")) {
  713. throw new RRException("该操作只允许店员账户操作");
  714. }
  715. OrderEntity orderEntity = orderService.queryObject(id);
  716. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_201.getItem())) {
  717. throw new RRException("此订单已付款!");
  718. }
  719. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_301.getItem())) {
  720. throw new RRException("此订单已完成!");
  721. }
  722. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_101.getItem())) {
  723. throw new RRException("此订单已取消!");
  724. }
  725. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_102.getItem())) {
  726. throw new RRException("此订单已删除!");
  727. }
  728. //保存支付记录
  729. OrderWXPayRecordEntity orderWXPayRecordCurrent = orderWXPayRecordService.saveRecord(orderEntity);
  730. PayOriginInfoDTO payOriginInfoDTO = new PayOriginInfoDTO();
  731. StoreEntity store = storeService.queryObject(orderEntity.getStoreId());
  732. WechatMicropayApiResult wechatMicropayApiResult = WechatUtil
  733. .wxMicropay(store.getMerchName() + "-" + store.getStoreName(), orderEntity.getOrderBizType(), null,
  734. orderWXPayRecordCurrent.getOutTradeNoWX(), orderEntity.getActualPrice().doubleValue(),
  735. "127.0.0.1", auth_code, payOriginInfoDTO);
  736. orderWXPayRecordService.updateRecord(orderWXPayRecordCurrent.getId(), wechatMicropayApiResult);
  737. //当支付成功时,修改订单,并把其他支付记录撤销
  738. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatMicropayApiResult.getTrade_state())) {
  739. //查询当前订单所有的支付记录
  740. List<OrderWXPayRecordEntity> orderWXPayRecordEntitys =
  741. orderWXPayRecordService.getRecordsByOutTradeNo(orderEntity.getOrderSn());
  742. for (OrderWXPayRecordEntity orderWXPayRecordTemp : orderWXPayRecordEntitys) {
  743. //查询出来的记录排除当前已支付成功的记录,对其他记录交易状态为未撤销,未关闭的订单,调用撤销订单
  744. if (!orderWXPayRecordTemp.getId().equals(orderWXPayRecordCurrent.getId()) &&
  745. (!WechatUtil.WXTradeState.REVOKED.getCode().equals(orderWXPayRecordTemp.getTradeState()) ||
  746. !WechatUtil.WXTradeState.CLOSED.getCode().equals(orderWXPayRecordTemp.getTradeState()))) {
  747. WechatReverseApiResult wechatReverseApiResult =
  748. WechatUtil.wxReverse(orderWXPayRecordTemp.getOutTradeNoWX());
  749. //撤销订单成功
  750. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getReturn_code()) &&
  751. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getResult_code())) {
  752. //调用订单查询接口
  753. WechatRefundApiResult wechatRefundApiResult =
  754. WechatUtil.wxOrderQuery(orderWXPayRecordTemp.getOutTradeNoWX());
  755. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getReturn_code()) &&
  756. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getResult_code())) {
  757. // 修改订单支付记录
  758. orderWXPayRecordService
  759. .updateWXPayRecordTradeState(orderWXPayRecordTemp.getId(), wechatRefundApiResult);
  760. }
  761. }
  762. }
  763. }
  764. orderService.confirmPay(id, Dict.payFlag.item_weixin.getItem(), orderWXPayRecordCurrent.getOutTradeNoWX());
  765. r = R.ok();
  766. //用户支付中
  767. } else if (WechatUtil.WXTradeState.USERPAYING.getCode().equals(wechatMicropayApiResult.getTrade_state())) {
  768. r = R.error(WechatUtil.WXTradeState.USERPAYING.getCodeZn() + ",稍等片刻后请刷新页面重新查看订单状态");
  769. //用户支付失败
  770. } else if (WechatUtil.WXTradeState.PAYERROR.getCode().equals(wechatMicropayApiResult.getTrade_state())) {
  771. WechatReverseApiResult wechatReverseApiResult =
  772. WechatUtil.wxReverse(orderWXPayRecordCurrent.getOutTradeNoWX());
  773. //撤销订单成功
  774. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getReturn_code()) &&
  775. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getResult_code())) {
  776. //调用订单查询接口
  777. WechatRefundApiResult wechatRefundApiResult =
  778. WechatUtil.wxOrderQuery(orderWXPayRecordCurrent.getOutTradeNoWX());
  779. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getReturn_code()) &&
  780. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getResult_code())) {
  781. // 修改订单支付记录
  782. orderWXPayRecordService
  783. .updateWXPayRecordTradeState(orderWXPayRecordCurrent.getId(), wechatRefundApiResult);
  784. }
  785. r = R.error(orderWXPayRecordCurrent.getErrCodeDes());
  786. } else {
  787. r = R.error(wechatReverseApiResult.getErr_code_des());
  788. }
  789. }
  790. return r;
  791. }
  792. /**
  793. * 线上订单导出请求
  794. */
  795. @RequiresPermissions(value = {"order:export"})
  796. @RequestMapping(value = "export")
  797. public Object export(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  798. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  799. params = ParamUtils.setTimeMap(params);
  800. //查询列表数据
  801. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_0.getItem());
  802. ExcelExport ee = new ExcelExport("线上订单信息");
  803. // =================================================线上订单明细导出开始=====================================
  804. List<OrderEntity> orderList = orderService.queryExportList(params);
  805. String[] header = new String[]{"订单编号", "商户订单编号", "所属门店", "供应商", "供应商第三方商户代码", "订单状态", "SKU", "商品名称", "数量",
  806. "销售价", "促销价", "实际支付金额", "保税模式", "快递公司", "配送单号", "快递费用", "发货状态", "修改人",
  807. "海关清单编号", "收货人姓名", "收件人手机", "收件人省份", "收件人城市", "收件人区县", "收件人地址", "下单时间", "支付流水号", "身份证号"
  808. , "原产国", "规格型号", "品牌", "单位", "毛重(kg)", "净重"};
  809. List<Map<String, Object>> list = new ArrayList<>();
  810. if (orderList != null && orderList.size() != 0) {
  811. for (OrderEntity orderEntity : orderList) {
  812. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  813. Integer orderStatus = orderEntity.getOrderStatus();
  814. String orderBizType = orderEntity.getOrderBizType();
  815. Integer shippingStatus = orderEntity.getShippingStatus();
  816. map.put("OrderSn", orderEntity.getOrderSn());
  817. map.put("MerchOrderSn", orderEntity.getMerchOrderSn());
  818. map.put("StoreName", orderEntity.getStoreName());
  819. map.put("SupplierThirdPartyMerchName", orderEntity.getSupplierThirdPartyMerchName());
  820. map.put("SupplierThirdPartyMerchCode", orderEntity.getSupplierThirdPartyMerchCode());
  821. map.put("OrderStatus", StringUtils.isEmpty(orderStatus.toString())? "":Dict.orderStatus.valueOf("item_"+ orderStatus).getItemName());
  822. map.put("SKU", orderEntity.getSku());
  823. map.put("GoodsName", orderEntity.getGoodsName());
  824. map.put("Number", orderEntity.getNumber());
  825. map.put("RetailPrice", orderEntity.getRetailPrice());
  826. map.put("TopicPrice", orderEntity.getTopicPrice());
  827. map.put("ActualPrice", orderEntity.getActualPrice());
  828. map.put("OrderBizType", StringUtils.isEmpty(orderBizType)? "":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  829. map.put("ShippingName", orderEntity.getShippingName());
  830. map.put("ShippingNo", orderEntity.getShippingNo());
  831. map.put("ShippingFee", orderEntity.getShippingFee());
  832. map.put("ShippingStatus", Dict.shippingStatus.valueOf("item_"+shippingStatus).getItemName());
  833. map.put("ModerSn", orderEntity.getModerSn());
  834. map.put("InvtNo", orderEntity.getOrderProcessRecord()==null?"":orderEntity.getOrderProcessRecord().getInvtNo());
  835. map.put("Consignee", orderEntity.getConsignee());
  836. map.put("Mobile", orderEntity.getMobile());
  837. map.put("Province", orderEntity.getProvince());
  838. map.put("City", orderEntity.getCity());
  839. map.put("District", orderEntity.getDistrict());
  840. map.put("Address", orderEntity.getAddress());
  841. map.put("OrderStartTime", orderEntity.getOrderProcessRecord()==null?"":DateUtils.format(orderEntity.getOrderProcessRecord().getAddOrderStartTime(),"yyyy-MM-dd HH:mm:ss"));
  842. map.put("PayId", orderEntity.getPayTransactionId());
  843. map.put("IdNo", orderEntity.getIdNo());
  844. map.put("OriCntCode", orderEntity.getOriCntCode());
  845. map.put("CiqProdModel", orderEntity.getCiqProdModel());
  846. map.put("Brand", orderEntity.getBrand());
  847. map.put("UnitCode", orderEntity.getUnitCode());
  848. map.put("GrossWeight", orderEntity.getGrossWeight());
  849. map.put("NetWeight", orderEntity.getNetWeight());
  850. // 零售价\促销价\成交价
  851. // map.put("SellPrice",orderEntity.getRetailPrice());
  852. //
  853. // map.put("FinalPrice",orderEntity.getActualPrice());
  854. list.add(map);
  855. }
  856. }
  857. // =================================================线上订单明细导出开始=====================================
  858. // =================================================线上订单导出开始=====================================
  859. List<OrderEntity> masterOrderList = orderService.queryMasterExportList(params);
  860. String[] headerMatser = new String[]{"所属门店", "订单号", "会员", "支付类型", "商户订单号", "订单业务类型", "订单状态", "订付人核验", "付款状态",
  861. "实际支付", "订单总价", "下单时间", "快递公司", "配送单号", "快递费用", "发货状态", "修改人",};
  862. List<Map<String, Object>> listMaster = new ArrayList<>();
  863. if (masterOrderList != null && masterOrderList.size() > 0) {
  864. for (OrderEntity orderEntity : masterOrderList) {
  865. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  866. String orderBizType = orderEntity.getOrderBizType();
  867. Integer orderStatus = orderEntity.getOrderStatus();
  868. String isMergePay = orderEntity.getIsMergePay();
  869. String buyerPayCheck = orderEntity.getBuyerPayCheck();
  870. map.put("StoreName",orderEntity.getStoreName());
  871. map.put("OrderSn",orderEntity.getOrderSn());
  872. map.put("UserName",orderEntity.getUserName());
  873. map.put("IsMergePay",StringUtils.isEmpty(isMergePay)?"-":Dict.isMergePay.valueOf("item_"+isMergePay).getItemName());
  874. map.put("MerchOrderSn",orderEntity.getMerchOrderSn());
  875. map.put("OrderBizType",StringUtils.isEmpty(orderBizType)? "":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  876. map.put("OrderStatus",Dict.orderStatus.valueOf("item_"+ orderStatus).getItemName());
  877. map.put("BuyerPayCheck",StringUtils.isEmpty(buyerPayCheck)?"":Dict.merchReturnSubjectChecked.valueOf("item_"+buyerPayCheck).getItemName());
  878. map.put("PayStatus",Dict.payStatus.valueOf("item_"+orderEntity.getPayStatus()).getItemName());
  879. map.put("ActualPrice",orderEntity.getActualPrice());
  880. map.put("OrderPrice",orderEntity.getOrderPrice());
  881. map.put("AddTime",orderEntity.getAddTime());
  882. map.put("ShippingName",orderEntity.getShippingName());
  883. map.put("ShippingNo",orderEntity.getShippingNo());
  884. map.put("ShippingFee",orderEntity.getShippingFee());
  885. map.put("ShippingStatus",Dict.shippingStatus.valueOf("item_"+orderEntity.getShippingStatus()).getItemName());
  886. map.put("ModerSn",orderEntity.getModerSn());
  887. listMaster.add(map);
  888. }
  889. }
  890. // =================================================线上订单导出结束=====================================
  891. ee.addSheetByMap("线上订单信息", listMaster, headerMatser);
  892. ee.addSheetByMap("线上订单明细信息", list, header);
  893. ee.export(response);
  894. return R.ok();
  895. }
  896. /**
  897. * 订单修改已发货的快递信息
  898. */
  899. @RequestMapping("/updateExpressInfo")
  900. @RequiresPermissions("order:updateExpressInfo")
  901. public Object updateExpressInfo(@RequestBody OrderEntity orderEntity) {
  902. OrderEntity orderInfo = orderService.queryObject(orderEntity.getId());
  903. if (orderInfo != null){
  904. if(orderInfo.getShippingStatus() == Integer.parseInt(Dict.shippingStatus.item_1.getItem())) {
  905. OrderEntity order = new OrderEntity();
  906. order.setId(orderInfo.getId());
  907. order.setShippingCode(orderEntity.getShippingCode());
  908. Map map = new HashMap();
  909. map.put("code", orderEntity.getShippingCode());
  910. ShippingEntity shippingEntity = shippingService.queryObjectByCode(orderEntity.getShippingCode());
  911. if(shippingEntity != null) {
  912. order.setShippingName(shippingEntity.getName());
  913. }else{
  914. throw new RRException("此订单修改的快递公司信息不存在!不能操作");
  915. }
  916. order.setShippingNo(orderEntity.getShippingNo());
  917. order.setModerSn(ShiroUtils.getUserEntity().getUsername());
  918. order.setModTime(new Date());
  919. orderService.update(order);
  920. }else{
  921. throw new RRException("此订单"+Dict.shippingStatus.valueOf("item_"+orderInfo.getShippingStatus()).getItemName()+"!不能操作");
  922. }
  923. }
  924. return R.ok();
  925. }
  926. /**
  927. * 上传文件
  928. */
  929. @RequestMapping("/expressUpload")
  930. @ResponseBody
  931. public R expressUpload(@RequestParam("file") MultipartFile file) {
  932. List<OrderExpressDto> orderExpressList = new ArrayList<>();//快递信息
  933. try {
  934. Map<String, Object> beans = new HashMap<String, Object>();
  935. beans.put("OrderExpressList", orderExpressList);
  936. if (file.isEmpty()) {
  937. return R.error("文件不能为空!");
  938. }
  939. excelUtil.readExcel(JxlsXmlTemplateName.ORDER_EXPRESS_LIST, beans, file.getInputStream());
  940. } catch (Exception e) {
  941. e.printStackTrace();
  942. return R.error("导入失败!");
  943. }
  944. orderService.uploadExcel(orderExpressList);
  945. //上传文件
  946. return R.ok();
  947. }
  948. /**
  949. * 获取ccnet需要重发的订单数据
  950. */
  951. @RequestMapping("/wxOrderResendQueryAllList")
  952. public R wxOrderResendQueryAllList(@RequestParam Map<String, Object> params) {
  953. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  954. //查询列表数据
  955. Query query = new Query(params);
  956. List<WxOrderEntity> orderList = orderService.wxOrderResendQueryAllList(query);
  957. PageUtils pageUtil = new PageUtils(orderList, orderList.size(), query.getLimit(), query.getPage());
  958. return R.ok().put("page", pageUtil);
  959. }
  960. /**
  961. * 收银端支付
  962. * @param param
  963. * @return
  964. * @throws IOException
  965. */
  966. @RequestMapping("/orderConfirm")
  967. public R orderConfirm(@RequestBody Map param) throws IOException {
  968. SysUserEntity user = ShiroUtils.getUserEntity();
  969. Map resultObj = null;
  970. try {
  971. // throw new RuntimeException("系统异常");
  972. resultObj = orderService.offlineRetailSubmit(param,user);
  973. if(resultObj.get("errno") != null && ((Integer)resultObj.get("errno")) == 400){
  974. return R.error((String) resultObj.get("errmsg"));
  975. }
  976. return R.ok().put("resultObj", resultObj);
  977. } catch (ServiceException e) {
  978. return R.error(e.getMessage());
  979. } catch (Exception e) {
  980. if (e.getMessage().contains("java.lang.IllegalStateException: invalid auth_code!")){
  981. return R.error("付款码异常,请重新输入!");
  982. }
  983. return R.error(e.getMessage());
  984. }
  985. }
  986. /**
  987. * 海控退款
  988. * @param param
  989. * @return
  990. * @throws IOException
  991. */
  992. @RequestMapping("/orderHkRefund")
  993. public R orderRefund( @RequestBody Map param) {
  994. SysUserEntity user = ShiroUtils.getUserEntity();
  995. Integer orderId = (Integer) param.get("orderId");
  996. OrderEntity orderInfo = orderService.queryObject(orderId.longValue());
  997. String sessionId = (String) param.get("sessionId");
  998. try {
  999. return orderService.orderRefund(orderInfo,sessionId,user);
  1000. } catch (Exception e) {
  1001. e.printStackTrace();
  1002. logger.error("[orderHkRefund-----海控退款异常]"+orderInfo.getOrderSn(),e);
  1003. return R.error(500,"退款失败");
  1004. }
  1005. }
  1006. @RequestMapping("/resendOrderToCCNET/{orderSn}/{resendType}")
  1007. public R resendWayBill(@PathVariable("orderSn") String orderSn, @PathVariable("resendType") String resendType){
  1008. String response = null;
  1009. Map map = new HashMap();
  1010. map.put("orderSn",orderSn);
  1011. try {
  1012. String url = "";
  1013. if("waybill".equals(resendType)){
  1014. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/resendWaybill/"+orderSn;
  1015. }else if("payment".equals(resendType)){
  1016. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/resendPayment/"+orderSn;
  1017. }else if("notice".equals(resendType)){
  1018. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/notice/"+orderSn;
  1019. }else if("clsOrder".equals(resendType)){
  1020. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/clsOrder/"+orderSn;
  1021. }else if("forceSend".equals(resendType)){
  1022. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/forceSend/"+orderSn;
  1023. }else if("resendOrder".equals(resendType)){
  1024. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/resendOrder/"+orderSn;
  1025. }
  1026. // 同步访问,返回结果字符串
  1027. response = OkHttpUtils.post(map, url, "SSL");
  1028. ResponseData responseData = JacksonUtils.fromStringJson(response, ResponseData.class);
  1029. if(responseData.getCode().equalsIgnoreCase("0")){
  1030. List<WxOrderEntity> list = responseData.getData().getRows();
  1031. }
  1032. } catch (Exception e) {
  1033. logger.error("查询失败。"+e.getMessage());
  1034. }
  1035. return R.ok(response);
  1036. }
  1037. @RequestMapping("/orderDetail/{orderSn}")
  1038. public R orderDetail(@PathVariable("orderSn") String orderSn) throws IOException {
  1039. OrderProcessRecordEntity orderProcessRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderSn);
  1040. OrderEntity orderEntity = orderService.queryObjectByOrderSn(orderSn);
  1041. Map map = new HashMap();
  1042. map.put("orderId",orderEntity.getId());
  1043. List<OrderGoodsEntity> goodsList = orderGoodsService.queryList(map);
  1044. BigDecimal tax = new BigDecimal(0);
  1045. for(OrderGoodsEntity orderGoodsEntity : goodsList){
  1046. BigDecimal retailPrice = orderGoodsEntity.getRetailPrice();
  1047. BigDecimal goodsRate = orderGoodsEntity.getGoodsRate();
  1048. Integer number = orderGoodsEntity.getNumber();
  1049. GoodsEntity goodsEntity = goodsService.queryObject(orderGoodsEntity.getGoodsId());
  1050. BigDecimal goodsTax = CalculateTax.calculateFinalTax(goodsEntity,retailPrice,goodsService).setScale(3,RoundingMode.HALF_UP);
  1051. goodsTax = goodsTax.multiply(new BigDecimal(number)).setScale(2,RoundingMode.HALF_UP);
  1052. orderGoodsEntity.setTax(goodsTax);
  1053. tax = tax.add(goodsTax).setScale(2,RoundingMode.HALF_UP);
  1054. // BigDecimal goodsTax = retailPrice.divide(new BigDecimal(1).add(goodsRate),2,RoundingMode.HALF_DOWN).multiply(goodsRate).multiply(new BigDecimal(number)).setScale(0,RoundingMode.HALF_DOWN);
  1055. }
  1056. String response = null;
  1057. try {
  1058. // 查询失败原因
  1059. String url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/"+orderSn;
  1060. // 同步访问,返回结果字符串
  1061. response = OkHttpUtils.post(map, url, "SSL");
  1062. } catch (Exception e) {
  1063. logger.error("查询失败。"+e.getMessage());
  1064. }
  1065. Map<String,Object> result = new HashMap<>();
  1066. result.put("orderProcessRecordEntity",orderProcessRecordEntity);
  1067. result.put("orderEntity",orderEntity);
  1068. result.put("goodsList",goodsList);
  1069. result.put("tax",tax.setScale(2, RoundingMode.HALF_DOWN).toString());
  1070. result.put("response",response);
  1071. return R.ok().put("resultObj", result);
  1072. }
  1073. @RequestMapping("/queryIDCardInfo/{mobile}")
  1074. public R queryIDCardInfo(@PathVariable("mobile")String mobile) throws IOException {
  1075. UserEntity userEntity = userService.queryByMobile(mobile);
  1076. if (userEntity == null) {
  1077. return R.error("该手机号未找到对应信息");
  1078. }
  1079. return R.ok().put("userEntity",userEntity);
  1080. }
  1081. @RequestMapping("/purchaseSalesInStockDetail")
  1082. // @RequiresPermissions("order:offilineOrderList")
  1083. public R purchaseSalesInStockDetail(@RequestParam Map<String, Object> params) {
  1084. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  1085. //查询列表数据
  1086. Query query = new Query(params);
  1087. List<PurchaseSalesInStockDetail> orderList = orderService.purchaseSalesInStockDetailList(query);
  1088. int total = orderService.purchaseSalesInStockDetailTotal(query);
  1089. // 遍历循环订单是哪个店员销售的,根据订单号查询
  1090. PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage());
  1091. return R.ok().put("page", pageUtil);
  1092. }
  1093. /**
  1094. * 线下订单导出请求
  1095. */
  1096. @RequiresPermissions("order:exportOffilineOrder")
  1097. @RequestMapping(value = "exportOffilineOrder")
  1098. public R exportOffilineOrder(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  1099. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  1100. params = ParamUtils.setTimeMap(params);
  1101. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  1102. ExcelExport ee = new ExcelExport("线下订单信息");
  1103. //查询列表数据
  1104. // =================================================线下订单明细导出开始=====================================
  1105. List<OrderEntity> orderEntityList = orderService.queryExportOffilineOrderList(params);
  1106. String[] header = new String[]{"订单号", "操作店员", "购买类型", "订单业务类型", "订单状态",
  1107. "付款状态", "sku", "商品名称", "数量", "实际支付", /*"订单总价",*/ "下单时间", "付款时间", "零售价", "优惠金额", "成交价"};
  1108. List<Map<String, Object>> list = new LinkedList<>();
  1109. if (orderEntityList != null && orderEntityList.size() > 0) {
  1110. for (OrderEntity orderEntity : orderEntityList) {
  1111. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  1112. // 订单业务类型
  1113. String orderBizType = orderEntity.getOrderBizType();
  1114. // 订单状态
  1115. Integer orderStatus = orderEntity.getOrderStatus();
  1116. // 付款状态
  1117. Integer payStatus = orderEntity.getPayStatus();
  1118. map.put("OrderSn", orderEntity.getOrderSn());
  1119. map.put("UserName", orderEntity.getUserName());
  1120. map.put("IsOnfflineOrder", Dict.isOnfflineOrder.item_1.getItem().equals(orderEntity.getIsOnfflineOrder()) ? "线下购买" : "线上购买");
  1121. map.put("OrderBizType", StringUtils.isEmpty(orderBizType)?"":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  1122. map.put("OrderStatus", Dict.orderStatus.valueOf("item_"+orderStatus).getItemName());
  1123. map.put("PayStatus", Dict.payStatus.valueOf("item_"+payStatus).getItemName());
  1124. map.put("Sku", orderEntity.getSku());
  1125. map.put("GoodsName", orderEntity.getGoodsName());
  1126. map.put("Number", orderEntity.getNumber());
  1127. map.put("ActualPrice", orderEntity.getActualPrice()); // 实际支付价
  1128. // map.put("OrderPrice", orderEntity.getOrderPrice()); // 订单总价
  1129. map.put("AddTime", orderEntity.getAddTime());
  1130. map.put("PayTime", orderEntity.getPayTime());
  1131. map.put("SellPrice", orderEntity.getRetailPrice()); // 零售价
  1132. map.put("CouponPrice", orderEntity.getCouponPrice()); // 促销价
  1133. map.put("FinalPrice", orderEntity.getActualPrice()); // 成交价
  1134. list.add(map);
  1135. }
  1136. }
  1137. // =================================================线下订单明细导出结束=====================================
  1138. // =================================================线下订单导出开始=====================================
  1139. List<OrderEntity> masterOrderEntityList = orderService.queryMasterExportOffilineOrderList(params);
  1140. String[] headerMaster = new String[]{"订单号", "操作店员", "购买类型", "订单业务类型", "订单状态",
  1141. "付款状态", "实际支付", "订单总价", "下单时间", "付款时间"};
  1142. List<Map<String, Object>> listMaster = new LinkedList<>();
  1143. if (masterOrderEntityList != null && masterOrderEntityList.size() > 0) {
  1144. for (OrderEntity orderEntity : masterOrderEntityList) {
  1145. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  1146. // 订单业务类型
  1147. String orderBizType = orderEntity.getOrderBizType();
  1148. // 订单状态
  1149. Integer orderStatus = orderEntity.getOrderStatus();
  1150. // 付款状态
  1151. Integer payStatus = orderEntity.getPayStatus();
  1152. map.put("OrderSn", orderEntity.getOrderSn());
  1153. map.put("UserName", orderEntity.getUserName());
  1154. map.put("IsOnfflineOrder", Dict.isOnfflineOrder.item_1.getItem().equals(orderEntity.getIsOnfflineOrder()) ? "线下购买" : "线上购买");
  1155. map.put("OrderBizType", StringUtils.isEmpty(orderBizType)?"":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  1156. map.put("OrderStatus", Dict.orderStatus.valueOf("item_"+orderStatus).getItemName());
  1157. map.put("PayStatus", Dict.payStatus.valueOf("item_"+payStatus).getItemName());
  1158. map.put("ActualPrice", orderEntity.getActualPrice());
  1159. map.put("OrderPrice", orderEntity.getOrderPrice());
  1160. map.put("AddTime", orderEntity.getAddTime());
  1161. map.put("PayTime", orderEntity.getPayTime());
  1162. listMaster.add(map);
  1163. }
  1164. }
  1165. // =================================================线下订单导出结束=====================================
  1166. ee.addSheetByMap("线下订单信息", listMaster, headerMaster);
  1167. ee.addSheetByMap("线下订单明细信息", list, header);
  1168. ee.export(response);
  1169. return R.ok();
  1170. }
  1171. @RequestMapping("/queryOrderStatus/{orderSn}")
  1172. public R queryOrderStatus(@PathVariable("orderSn")String orderSn){
  1173. try {
  1174. // 根据订单查询是什么支付方式
  1175. OrderEntity order = orderService.queryObjectByOrderSn(orderSn);
  1176. if(order == null){
  1177. return R.error("该订单不存在");
  1178. }
  1179. String payFlag = order.getPayFlag();
  1180. if("alipay".equals(payFlag)){
  1181. AliPayMicropayApiResult aliPayMicropayApiResult = AliPayUtil.aliTradeQuery(orderSn, "");
  1182. String tradeStatus = aliPayMicropayApiResult.getTradeStatus();
  1183. if(StringUtils.isBlank(tradeStatus)){
  1184. return R.error("交易不存在");
  1185. }
  1186. return R.ok("订单号:" +orderSn + "支付方式为:支付宝支付,"+
  1187. "订单支付状态:"+tradeStatus);
  1188. }else if("weixin".equals(payFlag)){
  1189. WechatRefundApiResult wechatRefundApiResult = WechatUtil.wxOrderQuery(orderSn);
  1190. String tradeState = wechatRefundApiResult.getTrade_state();
  1191. String tradeStateDesc = wechatRefundApiResult.getTrade_state_desc();
  1192. if(StringUtils.isBlank(tradeState)){
  1193. return R.error("交易不存在");
  1194. }
  1195. return R.ok("订单号:" +orderSn + "支付方式为:微信支付,"+
  1196. "订单支付状态:"+tradeState+"。 交易详情:"+tradeStateDesc);
  1197. }else{
  1198. return R.ok();
  1199. }
  1200. } catch (Exception e) {
  1201. e.printStackTrace();
  1202. return R.error();
  1203. }
  1204. }
  1205. @RequestMapping("/queryInveResponse/{orderSn}")
  1206. public R queryInveResponse(@PathVariable("orderSn")String orderSn){
  1207. try {
  1208. // 查询订单是否存在
  1209. // OrderEntity order = orderService.queryObjectByOrderSn(orderSn);
  1210. // if(order == null){
  1211. // return R.error("该订单不存在");
  1212. // }
  1213. List<String> resultMessage = orderService.queryInveResponse(orderSn);
  1214. if(resultMessage == null || resultMessage.size() == 0){
  1215. resultMessage.add("暂无回执");
  1216. }
  1217. return R.ok().put("resultMessage",resultMessage);
  1218. } catch (Exception e) {
  1219. e.printStackTrace();
  1220. return R.error("系统异常:"+e.getMessage());
  1221. }
  1222. }
  1223. @PostMapping("/calculateOrderDiscountPrice")
  1224. public R calculateOrderDiscountPrice(@RequestBody CalculateOrderDiscountPriceVO calculateOrderDiscountPriceVo) {
  1225. try {
  1226. CalculateOrderDiscountPriceResponseVO calculateOrderDiscountPriceResponseVO = orderService.calculateOrderDiscountPrice(calculateOrderDiscountPriceVo);
  1227. return R.ok().put("data", calculateOrderDiscountPriceResponseVO);
  1228. } catch (ServiceException e) {
  1229. logger.error("计算优惠价出现异常!", e);
  1230. return R.error(e.getMessage());
  1231. } catch (Exception e) {
  1232. logger.error("计算优惠价出现异常!请联系管理员!", e);
  1233. return R.error("计算出错!请联系管理员!" + e.getMessage());
  1234. }
  1235. }
  1236. /**
  1237. * System Format 导出请求
  1238. */
  1239. @RequestMapping(value = "exportSystemFormat")
  1240. public R exportSystemFormat(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) throws ParseException {
  1241. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  1242. params = ParamUtils.setTimeMap(params);
  1243. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  1244. ExcelExport ee = new ExcelExport("Daily sales report");
  1245. //查询列表数据
  1246. // =================================================System Format导出开始=====================================
  1247. List<SystemFormatDto> systemFormatList = orderService.queryExportSystemFormatList(params);
  1248. String[] header = new String[]{"Receipt No.","Store Name", "Cash Register No.", "Time Stamp Details (Date & Time)", "Staff ID", "Staff Name","Pay Flag","Order Status","Order SnWx","Order SnAli",
  1249. "HS Code", "HS Code Name", "E-matou Code", "PLU", "MychemID", "Product Name (EN)","Product Name (CN)", "Barcode", "Pack Size", "Product Specification",
  1250. "Brand","EDLP","Current Price","Cost Price",/*"Prime Cost","Goods Number",*/"Deduction Rate","Unit Sold","Sales","Tax amount","Total Sales incl. Tax","Tax Rate",
  1251. "GP ¥","GP %","Product Category","Supplier Name","Transaction Type","Sale Return Type","Remark"};
  1252. // LinkedHashMap<String, Object> headerMap = initHeaderMap();
  1253. List<Entry> headerMap = initHeaderMap();
  1254. // List<Map<String, Object>> list = new LinkedList<>();
  1255. List<List<Entry>> list = new ArrayList<>();
  1256. list.add(headerMap);
  1257. if (systemFormatList != null && systemFormatList.size() > 0) {
  1258. for (SystemFormatDto systemFormat : systemFormatList) {
  1259. List<Entry> entries = new ArrayList<>();
  1260. if (Objects.nonNull(systemFormat.getTaxRate()) && Objects.nonNull(systemFormat.getTotalSalesInclTax())){
  1261. BigDecimal unitSold = new BigDecimal(systemFormat.getUnitSold());
  1262. // 设置综合税额
  1263. BigDecimal totalSalesIncTax = new BigDecimal(systemFormat.getTotalSalesInclTax());
  1264. BigDecimal taxRate = new BigDecimal(systemFormat.getTaxRate());
  1265. // GoodsEntity goodsEntity = goodsService.queryObject(systemFormat.getGoodsId());
  1266. // BigDecimal goodsTax = CalculateTax.calculateFinalTax(goodsEntity,totalSalesIncTax.divide(unitSold,2,RoundingMode.HALF_UP),goodsService).setScale(3,RoundingMode.HALF_UP);
  1267. // goodsTax = goodsTax.multiply(unitSold).setScale(2,RoundingMode.HALF_UP);
  1268. String goodsTax = systemFormat.getTaxPrice();
  1269. systemFormat.setSales(totalSalesIncTax.subtract(new BigDecimal(goodsTax)).setScale(2,BigDecimal.ROUND_HALF_UP).toString());
  1270. systemFormat.setTaxAmount(totalSalesIncTax.subtract(new BigDecimal(systemFormat.getSales())).setScale(2,BigDecimal.ROUND_HALF_UP).toString());
  1271. // 设置实际销售额
  1272. systemFormat.setCurrentPrice(totalSalesIncTax.divide(unitSold,2,BigDecimal.ROUND_HALF_UP).setScale(2,BigDecimal.ROUND_HALF_UP).toEngineeringString());
  1273. if (Dict.orderStatus.item_401.getItem().equals(systemFormat.getOrderStatus())){
  1274. systemFormat.setUnitSold("-"+ unitSold);
  1275. systemFormat.setSales("-"+systemFormat.getSales());
  1276. systemFormat.setTaxAmount("-"+systemFormat.getTaxAmount());
  1277. systemFormat.setTotalSalesInclTax("-"+systemFormat.getTotalSalesInclTax());
  1278. }
  1279. }
  1280. if (Objects.nonNull(systemFormat.getCurrentPrice()) && Objects.nonNull(systemFormat.getEdlp())){
  1281. // 设置扣率
  1282. BigDecimal edlp = new BigDecimal(systemFormat.getEdlp());
  1283. BigDecimal currentPrice = new BigDecimal(systemFormat.getCurrentPrice());
  1284. if (!"0".equals(systemFormat.getEdlp()) && edlp.compareTo(BigDecimal.ZERO)!=0) {
  1285. systemFormat.setDeductionRate(new BigDecimal(1).subtract(currentPrice.divide(edlp, 4, BigDecimal.ROUND_HALF_UP)).multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_UP).toString()+"%");
  1286. }
  1287. if (Objects.nonNull(systemFormat.getCostPrice())){
  1288. // 设置GP ¥
  1289. systemFormat.setGp1(currentPrice.subtract(new BigDecimal(systemFormat.getCostPrice())).setScale(2,BigDecimal.ROUND_HALF_UP).toString());
  1290. // 设置GP %
  1291. if (!"0".equals(systemFormat.getCurrentPrice()) && StringUtils.isNotEmpty(systemFormat.getCurrentPrice())
  1292. && currentPrice.compareTo(BigDecimal.ZERO)!=0) {
  1293. BigDecimal gp1 = new BigDecimal(systemFormat.getGp1());
  1294. systemFormat.setGp2(gp1.divide(currentPrice, 4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_UP).toString() + "%");
  1295. }
  1296. if (Dict.orderStatus.item_401.getItem().equals(systemFormat.getOrderStatus())){
  1297. if (!systemFormat.getGp1().contains("-")) {
  1298. systemFormat.setGp1("-" + systemFormat.getGp1());
  1299. }
  1300. if (StringUtils.isNotEmpty(systemFormat.getGp2()) && !systemFormat.getGp2().contains("-")) {
  1301. systemFormat.setGp2("-" + systemFormat.getGp2());
  1302. }
  1303. }
  1304. }
  1305. }
  1306. // 如果是退货
  1307. String orderStatus = systemFormat.getOrderStatus();
  1308. if (Dict.orderStatus.item_401.getItem().equals(orderStatus)){
  1309. systemFormat.setSaleReturnType("整单退货");
  1310. systemFormat.setTransactionType("退货");
  1311. }else{
  1312. systemFormat.setTransactionType("销售");
  1313. }
  1314. orderStatus = Dict.orderStatus.valueOf("item_"+orderStatus).getItemName();
  1315. if (Objects.nonNull(systemFormat.getPrimeCost()) && Objects.nonNull(systemFormat.getGoodsNumber())) {
  1316. String primeCost = systemFormat.getPrimeCost();
  1317. BigDecimal gp = new BigDecimal(primeCost);
  1318. primeCost = gp.setScale(2,BigDecimal.ROUND_HALF_UP).toString();
  1319. systemFormat.setPrimeCost(primeCost);
  1320. }
  1321. entries.add(new Entry("ReceiptNo",systemFormat.getReceiptNo()));
  1322. entries.add(new Entry("StoreName",systemFormat.getStoreName()));
  1323. entries.add(new Entry("CashRegisterNo",systemFormat.getCashRegisterNo()));
  1324. entries.add(new Entry("TimeStampDetails",systemFormat.getTimeStampDetails()));
  1325. entries.add(new Entry("StaffID",systemFormat.getStaffID()));
  1326. entries.add(new Entry("StaffName",systemFormat.getStaffName()));
  1327. entries.add(new Entry("PayFlag",systemFormat.getPayFlag()));
  1328. entries.add(new Entry("OrderStatus",orderStatus));
  1329. entries.add(new Entry("OrderSnWx",systemFormat.getOrderSnWx()));
  1330. entries.add(new Entry("OrderSnAli",systemFormat.getOrderSnAli()));
  1331. entries.add(new Entry("HSCode",systemFormat.getHsCode()));
  1332. entries.add(new Entry("HSCodeName",systemFormat.getHsCodeName()));
  1333. entries.add(new Entry("EmatouCode",systemFormat.getEmatouCode()));
  1334. entries.add(new Entry("PLU",systemFormat.getPlu()));
  1335. entries.add(new Entry("MychemID",systemFormat.getMychemID()));
  1336. entries.add(new Entry("ProductNameEN",systemFormat.getProductNameEN()));
  1337. entries.add(new Entry("ProductNameCN",systemFormat.getProductNameCN()));
  1338. entries.add(new Entry("Barcode",systemFormat.getBarcode()));
  1339. entries.add(new Entry("PackSize",systemFormat.getPackSize()));
  1340. entries.add(new Entry("ProductSpecification",systemFormat.getProductSpecification()));
  1341. entries.add(new Entry("Brand",systemFormat.getBrand()));
  1342. entries.add(new Entry("EDLP",systemFormat.getEdlp()));
  1343. entries.add(new Entry("CurrentPrice",systemFormat.getCurrentPrice()));
  1344. entries.add(new Entry("CostPrice",systemFormat.getCostPrice()));
  1345. // entries.add(new Entry("PrimeCost",systemFormat.getPrimeCost()));
  1346. // entries.add(new Entry("GoodsNumber",systemFormat.getGoodsNumber()));
  1347. entries.add(new Entry("DeductionRate",systemFormat.getDeductionRate()));
  1348. entries.add(new Entry("UnitSold",systemFormat.getUnitSold()));
  1349. entries.add(new Entry("Sales",systemFormat.getSales()));
  1350. entries.add(new Entry("TaxAmount",systemFormat.getTaxAmount()));
  1351. entries.add(new Entry("TotalSalesInclTax",systemFormat.getTotalSalesInclTax()));
  1352. entries.add(new Entry("TaxRate",systemFormat.getTaxRate()));
  1353. entries.add(new Entry("GP1",systemFormat.getGp1()));
  1354. entries.add(new Entry("GP2",systemFormat.getGp2()));
  1355. entries.add(new Entry("ProductCategory",systemFormat.getProductCategory()));
  1356. entries.add(new Entry("SupplierName",systemFormat.getSupplierName()));
  1357. entries.add(new Entry("TransactionType",systemFormat.getTransactionType()));
  1358. entries.add(new Entry("SaleReturnType",systemFormat.getSaleReturnType()));
  1359. entries.add(new Entry("Remark",systemFormat.getRemark()));
  1360. list.add(entries);
  1361. }
  1362. }
  1363. // =================================================System Format导出结束=====================================
  1364. ee.addSheetByList("Daily sales report", list, header);
  1365. ee.export(response);
  1366. return R.ok();
  1367. }
  1368. private ArrayList<Entry> initHeaderMap() {
  1369. // LinkedHashMap<String, Object> headerMap = new LinkedHashMap<>();
  1370. ArrayList<Entry> entries = new ArrayList<>();
  1371. entries.add(new Entry("ReceiptNo","销售单号"));
  1372. entries.add(new Entry("StoreName","门店名称"));
  1373. entries.add(new Entry("CashRegisterNo","收银台"));
  1374. entries.add(new Entry("TimeStampDetails","销售时间"));
  1375. entries.add(new Entry("StaffID","收银员"));
  1376. entries.add(new Entry("StaffName","收银员姓名"));
  1377. entries.add(new Entry("PayFlag","支付方式"));
  1378. entries.add(new Entry("OrderStatus","支付状态"));
  1379. entries.add(new Entry("OrderSnWx","微信流水号"));
  1380. entries.add(new Entry("OrderSnAli","支付宝流水号"));
  1381. entries.add(new Entry("HSCode","海关商品编码"));
  1382. entries.add(new Entry("HSCodeName","品类名称"));
  1383. entries.add(new Entry("EmatouCode","料件号"));
  1384. entries.add(new Entry("PLU","PLU"));
  1385. entries.add(new Entry("MychemID","MychemID"));
  1386. entries.add(new Entry("ProductNameEN","商品名称(英文)"));
  1387. entries.add(new Entry("ProductNameCN","商品名称(中文)"));
  1388. entries.add(new Entry("Barcode","商品主条码"));
  1389. entries.add(new Entry("PackSize","规格"));
  1390. entries.add(new Entry("ProductSpecification","单位"));
  1391. entries.add(new Entry("Brand","品牌"));
  1392. entries.add(new Entry("EDLP","日常价"));
  1393. entries.add(new Entry("CurrentPrice","实际销售价"));
  1394. entries.add(new Entry("CostPrice","进货价"));
  1395. // entries.add(new Entry("PrimeCost","成本价");
  1396. // entries.add(new Entry("GoodsNumber","可用库存数");
  1397. entries.add(new Entry("DeductionRate","扣率 (EDLP vs 实际销售价)"));
  1398. entries.add(new Entry("UnitSold","销售数量"));
  1399. entries.add(new Entry("Sales","销售额"));
  1400. entries.add(new Entry("TaxAmount","综合税额"));
  1401. entries.add(new Entry("TotalSalesInclTax","总销售额"));
  1402. entries.add(new Entry("TaxRate","综合税率"));
  1403. entries.add(new Entry("GP1","预估毛利额"));
  1404. entries.add(new Entry("GP2","预估毛利率"));
  1405. entries.add(new Entry("ProductCategory","商品类型"));
  1406. entries.add(new Entry("SupplierName","主供应商名称"));
  1407. entries.add(new Entry("TransactionType","销售类型"));
  1408. entries.add(new Entry("SaleReturnType","退货类型"));
  1409. entries.add(new Entry("Remark","备注"));
  1410. return entries;
  1411. }
  1412. /**
  1413. * 重发订单
  1414. * @param orderSn
  1415. * @return
  1416. */
  1417. @RequestMapping("/resendOrderHkMall/{orderSn}")
  1418. public R resendOrderHkMall(@PathVariable("orderSn") String orderSn){
  1419. return orderService.resendOrderHkMall(orderSn);
  1420. }
  1421. }