OrderController.java 59 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240
  1. package com.kmall.admin.controller;
  2. import com.kmall.admin.dto.OrderExpressDto;
  3. import com.kmall.admin.entity.*;
  4. import com.kmall.admin.fromcomm.entity.SysUserEntity;
  5. import com.kmall.admin.service.*;
  6. import com.kmall.admin.utils.ParamUtils;
  7. import com.kmall.admin.utils.ShiroUtils;
  8. import com.kmall.common.constant.Dict;
  9. import com.kmall.common.constant.JxlsXmlTemplateName;
  10. import com.kmall.common.utils.*;
  11. import com.kmall.common.utils.excel.ExcelExport;
  12. import com.kmall.common.utils.excel.ExcelUtil;
  13. import com.kmall.common.utils.print.ticket.item.Ticket;
  14. import com.kmall.common.utils.wechat.WechatMicropayApiResult;
  15. import com.kmall.common.utils.wechat.WechatRefundApiResult;
  16. import com.kmall.common.utils.wechat.WechatReverseApiResult;
  17. import com.kmall.manager.manager.alipay.AliPayMicropayApiResult;
  18. import com.kmall.manager.manager.alipay.AliPayUtil;
  19. import com.kmall.manager.manager.merch.OmsMerchPropertiesBuilder;
  20. import com.kmall.manager.manager.pingan.PinganUtil;
  21. import com.kmall.manager.manager.pingan.dto.PinganResponseDto;
  22. import com.kmall.manager.manager.wechat.WechatGlobalUtil;
  23. import com.kmall.manager.manager.wechat.WechatUtil;
  24. import com.kmall.manager.manager.wechat.wxglobal.dto.WechatGlobalRefundApiResult;
  25. import net.sf.json.JSONObject;
  26. import org.apache.commons.lang3.StringUtils;
  27. import org.apache.commons.logging.Log;
  28. import org.apache.commons.logging.LogFactory;
  29. import org.apache.shiro.authz.annotation.RequiresPermissions;
  30. import org.springframework.beans.factory.annotation.Autowired;
  31. import org.springframework.web.bind.annotation.*;
  32. import org.springframework.web.multipart.MultipartFile;
  33. import javax.servlet.http.HttpServletRequest;
  34. import javax.servlet.http.HttpServletResponse;
  35. import java.io.IOException;
  36. import java.math.BigDecimal;
  37. import java.math.RoundingMode;
  38. import java.text.Bidi;
  39. import java.text.SimpleDateFormat;
  40. import java.util.*;
  41. /**
  42. * @author Scott
  43. * @email
  44. * @date 2017-08-13 10:41:09
  45. */
  46. @RestController
  47. @RequestMapping("order")
  48. public class OrderController {
  49. private Log logger = LogFactory.getLog(OrderController.class);
  50. @Autowired
  51. private OrderService orderService;
  52. @Autowired
  53. private OrderGoodsService orderGoodsService;
  54. @Autowired
  55. private OrderProcessRecordService orderProcessRecordService;
  56. @Autowired
  57. private OrderRefundService orderRefundService;
  58. @Autowired
  59. private OrderExceptionRecordService orderExceptionRecordService;
  60. @Autowired
  61. private StoreService storeService;
  62. @Autowired
  63. private OrderWXPayRecordService orderWXPayRecordService;
  64. @Autowired
  65. private PinganResponseService pinganResponseService;
  66. @Autowired
  67. private ExcelUtil excelUtil;
  68. @Autowired
  69. private ShippingService shippingService;
  70. private volatile Integer code = 1;
  71. @Autowired
  72. private UserService userService;
  73. /**
  74. * 列表
  75. */
  76. @RequestMapping("/list")
  77. @RequiresPermissions("order:list")
  78. public R list(@RequestParam Map<String, Object> params) {
  79. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  80. params = ParamUtils.setTimeMap(params);
  81. //查询列表数据
  82. Query query = new Query(params);
  83. query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_0.getItem());
  84. List<OrderEntity> orderList = orderService.queryList(query);
  85. int total = orderService.queryTotal(query);
  86. PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage());
  87. return R.ok().put("page", pageUtil);
  88. }
  89. /**
  90. * 信息
  91. */
  92. @RequestMapping("/info/{id}")
  93. @RequiresPermissions("order:info")
  94. public R info(@PathVariable("id") Long id) {
  95. OrderEntity order = orderService.queryObject(id);
  96. return R.ok().put("order", order);
  97. }
  98. /**
  99. * 信息
  100. */
  101. @RequestMapping("/infos/{id}")
  102. @RequiresPermissions("order:infos")
  103. public R infos(@PathVariable("id") Long id) {
  104. OrderEntity order = orderService.queryInfos(id);
  105. return R.ok().put("order", order);
  106. }
  107. /**
  108. * 保存
  109. */
  110. @RequestMapping("/save")
  111. @RequiresPermissions("order:save")
  112. public R save(@RequestBody OrderEntity order) {
  113. orderService.save(order);
  114. return R.ok();
  115. }
  116. /**
  117. * 修改
  118. */
  119. @RequestMapping("/update")
  120. @RequiresPermissions("order:update")
  121. public R update(@RequestBody OrderEntity order) {
  122. orderService.update(order);
  123. return R.ok();
  124. }
  125. /**
  126. * 删除
  127. */
  128. @RequestMapping("/delete")
  129. @RequiresPermissions("order:delete")
  130. public R delete(@RequestBody Long[] ids) {
  131. orderService.deleteBatch(ids);
  132. return R.ok();
  133. }
  134. /**
  135. * 查看所有列表
  136. */
  137. @RequestMapping("/queryAll")
  138. public R queryAll(@RequestParam Map<String, Object> params) {
  139. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  140. List<OrderEntity> list = orderService.queryList(params);
  141. return R.ok().put("list", list);
  142. }
  143. /**
  144. * 总计
  145. */
  146. @RequestMapping("/queryTotal")
  147. public R queryTotal(@RequestParam Map<String, Object> params) {
  148. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  149. int sum = orderService.queryTotal(params);
  150. return R.ok().put("sum", sum);
  151. }
  152. /**
  153. * 确定收货
  154. *
  155. * @param id
  156. * @return
  157. */
  158. @RequestMapping("/confirm")
  159. @RequiresPermissions("order:confirm")
  160. public R confirm(@RequestBody Long id) {
  161. orderService.confirm(id);
  162. return R.ok();
  163. }
  164. /**
  165. * 发货
  166. *
  167. * @param order
  168. * @return
  169. */
  170. @RequestMapping("/sendGoods")
  171. @RequiresPermissions("order:sendGoods")
  172. public R sendGoods(@RequestBody OrderEntity order) {
  173. orderService.sendGoods(order);
  174. return R.ok();
  175. }
  176. /**
  177. * 跟踪快递轨迹
  178. *
  179. * @param id
  180. * @return
  181. */
  182. @RequestMapping("/getLogistics/{id}")
  183. @RequiresPermissions("order:getLogistics")
  184. public R getLogistics(@PathVariable("id") Long id) {
  185. Map result = orderService.getLogistics(id);
  186. return R.ok().put("result", result);
  187. }
  188. /**
  189. * 获取订单清关信息
  190. *
  191. * @param orderSn
  192. * @return
  193. */
  194. @RequestMapping("/getProcess/{orderSn}")
  195. @RequiresPermissions("order:getProcess")
  196. public R getProcess(@PathVariable("orderSn") String orderSn) {
  197. OrderProcessRecordEntity orderProcessRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderSn);
  198. if (orderProcessRecordEntity != null) {
  199. if (orderProcessRecordEntity.getShipmentStartTime() != null) {
  200. orderProcessRecordEntity.setShipmentStartTimeStr(
  201. DateUtils.format(orderProcessRecordEntity.getShipmentStartTime(), DateUtils.DATE_TIME_PATTERN));
  202. }
  203. if (orderProcessRecordEntity.getShipmentSuccTime() != null) {
  204. orderProcessRecordEntity.setShipmentSuccTimeStr(
  205. DateUtils.format(orderProcessRecordEntity.getShipmentSuccTime(), DateUtils.DATE_TIME_PATTERN));
  206. }
  207. if (orderProcessRecordEntity.getCustomsStartTime() != null) {
  208. orderProcessRecordEntity.setCustomsStartTimeStr(
  209. DateUtils.format(orderProcessRecordEntity.getCustomsStartTime(), DateUtils.DATE_TIME_PATTERN));
  210. }
  211. if (orderProcessRecordEntity.getCustomsSuccTime() != null) {
  212. orderProcessRecordEntity.setCustomsSuccTimeStr(
  213. DateUtils.format(orderProcessRecordEntity.getCustomsSuccTime(), DateUtils.DATE_TIME_PATTERN));
  214. }
  215. if (orderProcessRecordEntity.getWaybillStartTime() != null) {
  216. orderProcessRecordEntity.setWaybillStartTimeStr(
  217. DateUtils.format(orderProcessRecordEntity.getWaybillStartTime(), DateUtils.DATE_TIME_PATTERN));
  218. }
  219. if (orderProcessRecordEntity.getWaybillSuccTime() != null) {
  220. orderProcessRecordEntity.setWaybillSuccTimeStr(
  221. DateUtils.format(orderProcessRecordEntity.getWaybillSuccTime(), DateUtils.DATE_TIME_PATTERN));
  222. }
  223. if (orderProcessRecordEntity.getEleOrderStartTime() != null) {
  224. orderProcessRecordEntity.setEleOrderStartTimeStr(
  225. DateUtils.format(orderProcessRecordEntity.getEleOrderStartTime(), DateUtils.DATE_TIME_PATTERN));
  226. }
  227. if (orderProcessRecordEntity.getEleOrderSuccTime() != null) {
  228. orderProcessRecordEntity.setEleOrderSuccTimeStr(
  229. DateUtils.format(orderProcessRecordEntity.getEleOrderSuccTime(), DateUtils.DATE_TIME_PATTERN));
  230. }
  231. if (orderProcessRecordEntity.getAddOrderStartTime() != null) {
  232. orderProcessRecordEntity.setAddOrderStartTimeStr(
  233. DateUtils.format(orderProcessRecordEntity.getAddOrderStartTime(), DateUtils.DATE_TIME_PATTERN));
  234. }
  235. if (orderProcessRecordEntity.getAddOrderSuccTime() != null) {
  236. orderProcessRecordEntity.setAddOrderSuccTimeStr(
  237. DateUtils.format(orderProcessRecordEntity.getAddOrderSuccTime(), DateUtils.DATE_TIME_PATTERN));
  238. }
  239. if (orderProcessRecordEntity.getPaySuccTime() != null) {
  240. orderProcessRecordEntity.setPaySuccTimeStr(
  241. DateUtils.format(orderProcessRecordEntity.getPaySuccTime(), DateUtils.DATE_TIME_PATTERN));
  242. }
  243. if (orderProcessRecordEntity.getPayStartTime() != null) {
  244. orderProcessRecordEntity.setPayStartTimeStr(
  245. DateUtils.format(orderProcessRecordEntity.getPayStartTime(), DateUtils.DATE_TIME_PATTERN));
  246. }
  247. if (orderProcessRecordEntity.getPaymentStartTime() != null) {
  248. orderProcessRecordEntity.setPaymentStartTimeStr(
  249. DateUtils.format(orderProcessRecordEntity.getPaymentStartTime(), DateUtils.DATE_TIME_PATTERN));
  250. }
  251. if (orderProcessRecordEntity.getPaymentSuccTime() != null) {
  252. orderProcessRecordEntity.setPaymentSuccTimeStr(
  253. DateUtils.format(orderProcessRecordEntity.getPaymentSuccTime(), DateUtils.DATE_TIME_PATTERN));
  254. }
  255. }
  256. return R.ok().put("orderProcessRecordEntity", orderProcessRecordEntity);
  257. }
  258. /**
  259. * 打印小票
  260. *
  261. * @param id
  262. * @return
  263. */
  264. @RequestMapping("/printMsg")
  265. public R printMsg(@RequestBody Long id) {
  266. Ticket ticket = orderService.printMsg(id);
  267. return R.ok().put("ticket", ticket);
  268. }
  269. @RequestMapping("/printMsgAndChangeCode")
  270. public R printMsgAndChangeCode(@RequestBody Map param) {
  271. Integer id = (Integer) param.get("id");
  272. String sessionId = (String) param.get("sessionId");
  273. Ticket ticket = orderService.printMsg(id.longValue(),sessionId);
  274. return R.ok().put("ticket", ticket);
  275. }
  276. @RequestMapping("/printCode")
  277. public R printMsg(){
  278. Map map = new HashMap();
  279. map.put("code",code++); // 系统中累加
  280. map.put("shopName","深圳xxxxxxCW店"); // 根据门店编号查询
  281. map.put("time",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  282. map.put("orderNo",UUID.randomUUID().toString().replace("//-","")); //
  283. return R.ok().put("ticket", map);
  284. }
  285. /**
  286. * 订单取消请求
  287. */
  288. @RequiresPermissions(value = {"order:refund"})
  289. @RequestMapping(value = "cancel", method = RequestMethod.POST)
  290. public Object cancel(Long orderId) {
  291. OrderEntity orderInfo = orderService.queryObject(orderId);
  292. if (null == orderInfo) {
  293. return R.error("订单不存在");
  294. }
  295. if (orderInfo.getOrderStatus() != 0) {
  296. return R.error("订单状态不支持取消");
  297. }
  298. orderService.cancelOrder(orderInfo);
  299. return R.ok();
  300. }
  301. /**
  302. * 订单退款请求
  303. */
  304. @RequiresPermissions(value = {"order:refund"})
  305. @RequestMapping(value = "refund", method = RequestMethod.POST)
  306. public Object refund(Long orderId, String refundId, BigDecimal refundMoney) {
  307. OrderEntity orderInfo = orderService.queryObject(orderId);
  308. if (null == orderInfo) {
  309. return R.error("订单不存在");
  310. }
  311. if (orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_401.getItem()) ||
  312. orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_402.getItem())) {
  313. return R.error("订单已退款");
  314. }
  315. Double totalActualPrice = orderService.getTotalActualPrice(orderInfo.getMerchOrderSn());
  316. if (totalActualPrice == null) {
  317. totalActualPrice = 0d;
  318. }
  319. OrderProcessRecordEntity processRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderInfo.getOrderSn());
  320. if(org.apache.commons.lang.StringUtils.isNotEmpty(processRecordEntity.getIsCustomsSend())) {
  321. if (processRecordEntity.getIsCustomsSend().equalsIgnoreCase("2")) {
  322. return R.error("订单正在清关中,不能退款");
  323. }
  324. if (processRecordEntity.getIsCustomsSend().equalsIgnoreCase("1")) {
  325. return R.error("订单已清关完成,不能退款");
  326. }
  327. }
  328. String refundResult = "";
  329. if (orderInfo.getOrderStatus() != Integer.parseInt(Dict.orderStatus.item_0.getItem())) {
  330. if (orderInfo.getPayFlag().equalsIgnoreCase(Dict.payFlag.item_wxglobalpay.getItem())) {
  331. refundResult = wxGlobalRefund(orderInfo, totalActualPrice);
  332. if (StringUtils.isNotBlank(refundResult)) {
  333. return R.error(refundResult);
  334. }
  335. } else if (orderInfo.getPayFlag().equalsIgnoreCase(Dict.payFlag.item_pingan.getItem())) {
  336. refundResult = pinganRefund(orderInfo, refundId);
  337. if (StringUtils.isNotBlank(refundResult)) {
  338. return R.error(refundResult);
  339. }
  340. } else{
  341. refundResult = wxRefund(orderInfo,totalActualPrice);
  342. if(StringUtils.isNotBlank(refundResult)){
  343. return R.error(refundResult);
  344. }
  345. }
  346. }
  347. return R.ok("退款成功");
  348. }
  349. /**
  350. * 平安申请退款
  351. * @param orderInfo
  352. * @return
  353. */
  354. private String pinganRefund(OrderEntity orderInfo, String refundId){
  355. Integer refundAmount = orderInfo.getActualPrice().multiply(new BigDecimal(100)).intValue();
  356. PinganResponseDto responseDto = PinganUtil.pinganPayRefund(orderInfo.getMerchOrderSn(), refundId, refundAmount, null);
  357. if (!Objects.isNull(responseDto)) {
  358. responseDto.setOutNo(orderInfo.getMerchOrderSn());
  359. responseDto.setCreateTime(new Date());
  360. pinganResponseService.save(responseDto);
  361. if ("0".equals(responseDto.getErrcode())) {
  362. JSONObject tradeResult = JSONObject.fromObject(responseDto.getDatajson());
  363. if (Dict.pinganRefundStatus.item_1.getItem().equals(tradeResult.getString("status"))) {
  364. orderService.pinganRefund(orderInfo, tradeResult, refundId);
  365. } else {
  366. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  367. OrderRefundEntity orderRefund = new OrderRefundEntity();
  368. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  369. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  370. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  371. SysUserEntity user = ShiroUtils.getUserEntity();
  372. orderRefund.setModerSn(user.getUsername());
  373. orderRefund.setModTime(new Date());
  374. orderRefund.setOutRefundNo(tradeResult.getString("ord_no"));
  375. if (mallOrderRefund != null) {
  376. orderRefund.setId(mallOrderRefund.getId());
  377. orderRefundService.update(orderRefund);//退款记录
  378. }
  379. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  380. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  381. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  382. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  383. mallOrderExceptionRecord.setExceptionContent("退款失败");
  384. mallOrderExceptionRecord.setCreateTime(new Date());
  385. orderExceptionRecordService.save(mallOrderExceptionRecord);
  386. return "发起平安支付退款失败!";
  387. }
  388. } else {
  389. return responseDto.getMsg();
  390. }
  391. }
  392. return "";
  393. }
  394. /**
  395. * 微信申请退款
  396. * @param orderInfo
  397. * @param totalActualPrice
  398. * @return
  399. */
  400. private String wxRefund(OrderEntity orderInfo,Double totalActualPrice){
  401. WechatRefundApiResult result = WechatUtil.wxRefund(orderInfo.getMerchOrderSn().toString(), totalActualPrice,
  402. orderInfo.getActualPrice().doubleValue());
  403. if (result.getResult_code().equals(WechatUtil.WXTradeState.SUCCESS.getCode())) {
  404. orderService.refund(orderInfo, result);
  405. } else {
  406. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  407. OrderRefundEntity orderRefund = new OrderRefundEntity();
  408. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  409. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  410. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  411. SysUserEntity user = ShiroUtils.getUserEntity();
  412. orderRefund.setModerSn(user.getUsername());
  413. orderRefund.setModTime(new Date());
  414. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  415. if (mallOrderRefund != null) {
  416. orderRefund.setId(mallOrderRefund.getId());
  417. orderRefundService.update(orderRefund);//退款记录
  418. }
  419. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  420. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  421. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  422. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  423. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des());
  424. mallOrderExceptionRecord.setCreateTime(new Date());
  425. orderExceptionRecordService.save(mallOrderExceptionRecord);
  426. return result.getErr_code_des();
  427. }
  428. return "";
  429. }
  430. /**
  431. * 微信国际申请退款
  432. * @param orderInfo
  433. * @param totalActualPrice
  434. * @return
  435. */
  436. private String wxGlobalRefund(OrderEntity orderInfo,Double totalActualPrice){
  437. WechatGlobalRefundApiResult result = WechatGlobalUtil.wxRefund(orderInfo.getMerchOrderSn().toString(), totalActualPrice,
  438. orderInfo.getActualPrice().doubleValue());
  439. if (result.getResult_code().equals(WechatUtil.WXTradeState.SUCCESS.getCode())) {
  440. orderService.globalRefund(orderInfo, result);
  441. } else {
  442. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  443. OrderRefundEntity orderRefund = new OrderRefundEntity();
  444. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  445. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  446. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  447. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  448. orderRefund.setModTime(new Date());
  449. if (mallOrderRefund != null) {
  450. orderRefund.setId(mallOrderRefund.getId());
  451. orderRefundService.update(orderRefund);//退款记录
  452. }
  453. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  454. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  455. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  456. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  457. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des());
  458. mallOrderExceptionRecord.setCreateTime(new Date());
  459. orderExceptionRecordService.save(mallOrderExceptionRecord);
  460. return result.getErr_code_des();
  461. }
  462. return "";
  463. }
  464. /**
  465. * 订单退款请求
  466. */
  467. @RequiresPermissions(value = {"order:offilineRefund"})
  468. @RequestMapping(value = "offilineRefund", method = RequestMethod.POST)
  469. public Object offilineRefund(Long orderId) {
  470. OrderEntity orderInfo = orderService.queryObject(orderId);
  471. if (null == orderInfo) {
  472. return R.error("订单不存在");
  473. }
  474. if (orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_401.getItem()) ||
  475. orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_402.getItem())) {
  476. return R.error("订单已退款");
  477. }
  478. if (orderInfo.getOrderStatus() != Integer.parseInt(Dict.orderStatus.item_0.getItem())) {
  479. if (Dict.payFlag.item_cash.getItem().equals(orderInfo.getPayFlag())) {
  480. //现金支付,直接修改订单状态
  481. orderService.refund(orderInfo);
  482. } else if (Dict.payFlag.item_weixin.getItem().equals(orderInfo.getPayFlag())) {
  483. //微信线下扫码支付
  484. WechatRefundApiResult result = WechatUtil
  485. .wxRefund(orderInfo.getOrderSnWx(), orderInfo.getActualPrice().doubleValue(),
  486. orderInfo.getActualPrice().doubleValue());
  487. if (result.getResult_code().equals(WechatUtil.WXTradeState.SUCCESS.getCode())) {
  488. orderService.refund(orderInfo, result);
  489. } else {
  490. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  491. OrderRefundEntity orderRefund = new OrderRefundEntity();
  492. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  493. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  494. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  495. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  496. SysUserEntity user = ShiroUtils.getUserEntity();
  497. orderRefund.setModerSn(user.getUsername());
  498. orderRefund.setModTime(new Date());
  499. if (mallOrderRefund != null) {
  500. orderRefund.setId(mallOrderRefund.getId());
  501. orderRefundService.update(orderRefund);//退款记录
  502. }
  503. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  504. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  505. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  506. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  507. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des());
  508. mallOrderExceptionRecord.setCreateTime(new Date());
  509. orderExceptionRecordService.save(mallOrderExceptionRecord);
  510. return R.error(result.getErr_code_des());
  511. }
  512. }else if(Dict.payFlag.item_alipay.getItem().equals(orderInfo.getPayFlag())){
  513. // 支付宝线下扫码支付
  514. AliPayMicropayApiResult result = null;
  515. try {
  516. result = AliPayUtil.aliTradeRefund(orderInfo.getOrderSn(),orderInfo.getActualPrice()+"",
  517. "顾客退款",orderInfo.getStoreId().toString());
  518. } catch (Exception e) {
  519. e.printStackTrace();
  520. }
  521. if (result.getCode().equals(AliPayUtil.AliPayTradeState.SUCC.getCode())) {
  522. orderService.refund(orderInfo, result);
  523. } else {
  524. OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId());
  525. OrderRefundEntity orderRefund = new OrderRefundEntity();
  526. orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem()));
  527. orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue()));
  528. orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem()));
  529. // orderRefund.setOutRefundNo(result.getOut_refund_no());
  530. SysUserEntity user = ShiroUtils.getUserEntity();
  531. orderRefund.setModerSn(user.getUsername());
  532. orderRefund.setModTime(new Date());
  533. if (mallOrderRefund != null) {
  534. orderRefund.setId(mallOrderRefund.getId());
  535. orderRefundService.update(orderRefund);//退款记录
  536. }
  537. OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity();
  538. mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + ""));
  539. mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn());
  540. mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem());
  541. mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getSubMsg());
  542. mallOrderExceptionRecord.setCreateTime(new Date());
  543. orderExceptionRecordService.save(mallOrderExceptionRecord);
  544. return R.error(result.getSubMsg());
  545. }
  546. } else{
  547. return R.ok("退款成功");
  548. }
  549. }
  550. return R.ok("退款成功");
  551. }
  552. /**
  553. * 获取首页展示信息--会员购买率相关
  554. *
  555. * @param params
  556. * @return
  557. */
  558. @RequestMapping("/getUserOrderInfo")
  559. public R getUserOrderInfo(@RequestParam Map<String, Object> params) {
  560. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  561. int result = orderService.getUserOrderInfo(params);
  562. return R.ok().put("result", result);
  563. }
  564. @RequiresPermissions(value = {"order:orderSubmit"})
  565. @RequestMapping(value = "orderSubmit", method = RequestMethod.POST)
  566. @ResponseBody
  567. public R orderSubmit(@RequestBody List<OfflineCartEntity> offlineCartEntityList) {
  568. Map resultObj = null;
  569. try {
  570. SysUserEntity user = ShiroUtils.getUserEntity();
  571. resultObj = orderService.orderSubmit(offlineCartEntityList, user);
  572. if (((Integer) resultObj.get("errno")) != 0) {
  573. return R.error((String) resultObj.get("errmsg"));
  574. }
  575. } catch (Exception e) {
  576. e.printStackTrace();
  577. }
  578. return R.ok("订单提交成功");
  579. }
  580. /**
  581. * 确认付款
  582. *
  583. * @param id
  584. * @return
  585. */
  586. @RequestMapping("/confirmPay")
  587. @RequiresPermissions("order:confirmPay")
  588. public R confirmPay(@RequestBody Long id) {
  589. orderService.confirmPay(id, Dict.payFlag.item_cash.getItem(), null);
  590. return R.ok();
  591. }
  592. @RequestMapping("/offilineOrderList")
  593. @RequiresPermissions("order:offilineOrderList")
  594. public R offilineOrderList(@RequestParam Map<String, Object> params) {
  595. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  596. params = ParamUtils.setTimeMap(params);
  597. //查询列表数据
  598. Query query = new Query(params);
  599. query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  600. List<OrderEntity> orderList = orderService.queryOffilineOrderList(query);
  601. int total = orderService.queryOffilineOrderTotal(query);
  602. for(OrderEntity orderEntity : orderList) {
  603. BigDecimal tax = new BigDecimal(0);
  604. Map map = new HashMap();
  605. map.put("orderId", orderEntity.getId());
  606. List<OrderGoodsEntity> goodsList = orderGoodsService.queryList(map);
  607. for (OrderGoodsEntity orderGoodsEntity : goodsList) {
  608. tax = tax
  609. .add(orderGoodsEntity.getMarketPrice() // 商品价格
  610. .multiply(orderGoodsEntity.getGoodsRate()) // 商品税率
  611. .multiply(new BigDecimal(orderGoodsEntity.getNumber()))).setScale(2,RoundingMode.HALF_UP); // 商品数量
  612. }
  613. orderEntity.setTax(tax);
  614. }
  615. // 遍历循环订单是哪个店员销售的,根据订单号查询
  616. PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage());
  617. return R.ok().put("page", pageUtil);
  618. }
  619. @RequestMapping("/offlineInfos/{id}")
  620. @RequiresPermissions("order:offlineInfos")
  621. public R queryObjectBySysUser(@PathVariable("id") Long id) {
  622. OrderEntity order = orderService.queryObjectBySysUser(id);
  623. List<OrderWXPayRecordEntity> payRecords = orderWXPayRecordService.getRecordsByOutTradeNo(order.getOrderSn());
  624. BigDecimal tax = new BigDecimal(0);
  625. List<OrderGoodsEntity> goodsList = order.getOrderGoodsEntityList();
  626. for (OrderGoodsEntity orderGoodsEntity : goodsList) {
  627. BigDecimal goodsTax = orderGoodsEntity.getMarketPrice() // 商品价格
  628. .multiply(orderGoodsEntity.getGoodsRate()) // 商品税率
  629. .multiply(new BigDecimal(orderGoodsEntity.getNumber()));// 商品数量
  630. orderGoodsEntity.setTax(goodsTax);
  631. tax = tax.add(goodsTax).setScale(2,RoundingMode.HALF_UP);
  632. orderGoodsEntity.setTax(goodsTax);
  633. }
  634. order.setTax(tax);
  635. order.setPayRecordList(payRecords);
  636. return R.ok().put("order", order);
  637. }
  638. @RequestMapping("/pickUpCodeList")
  639. public R pickUpCodeList(@RequestBody Map<String, Object> params) {
  640. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  641. //查询列表数据
  642. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  643. List<OrderEntity> orderList = orderService.queryPickUpCodeList(params);
  644. return R.ok().put("list", orderList);
  645. }
  646. @RequestMapping("/wxMicropayPay")
  647. @RequiresPermissions("order:wxMicropayPay")
  648. public R wxMicropayPay(Long id, String auth_code) {
  649. R r = null;
  650. SysUserEntity user = ShiroUtils.getUserEntity();
  651. if (user == null) {
  652. throw new RRException("用户登录超时,请重新登录");
  653. }
  654. if (!user.getRoleType().equalsIgnoreCase("2")) {
  655. throw new RRException("该操作只允许店员账户操作");
  656. }
  657. OrderEntity orderEntity = orderService.queryObject(id);
  658. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_201.getItem())) {
  659. throw new RRException("此订单已付款!");
  660. }
  661. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_301.getItem())) {
  662. throw new RRException("此订单已完成!");
  663. }
  664. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_101.getItem())) {
  665. throw new RRException("此订单已取消!");
  666. }
  667. if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_102.getItem())) {
  668. throw new RRException("此订单已删除!");
  669. }
  670. //保存支付记录
  671. OrderWXPayRecordEntity orderWXPayRecordCurrent = orderWXPayRecordService.saveRecord(orderEntity);
  672. StoreEntity store = storeService.queryObject(orderEntity.getStoreId());
  673. WechatMicropayApiResult wechatMicropayApiResult = WechatUtil
  674. .wxMicropay(store.getMerchName() + "-" + store.getStoreName(), orderEntity.getOrderBizType(), null,
  675. orderWXPayRecordCurrent.getOutTradeNoWX(), orderEntity.getActualPrice().doubleValue(),
  676. "127.0.0.1", auth_code);
  677. orderWXPayRecordService.updateRecord(orderWXPayRecordCurrent.getId(), wechatMicropayApiResult);
  678. //当支付成功时,修改订单,并把其他支付记录撤销
  679. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatMicropayApiResult.getTrade_state())) {
  680. //查询当前订单所有的支付记录
  681. List<OrderWXPayRecordEntity> orderWXPayRecordEntitys =
  682. orderWXPayRecordService.getRecordsByOutTradeNo(orderEntity.getOrderSn());
  683. for (OrderWXPayRecordEntity orderWXPayRecordTemp : orderWXPayRecordEntitys) {
  684. //查询出来的记录排除当前已支付成功的记录,对其他记录交易状态为未撤销,未关闭的订单,调用撤销订单
  685. if (orderWXPayRecordTemp.getId() != orderWXPayRecordCurrent.getId() &&
  686. (!WechatUtil.WXTradeState.REVOKED.getCode().equals(orderWXPayRecordTemp.getTradeState()) ||
  687. !WechatUtil.WXTradeState.CLOSED.getCode().equals(orderWXPayRecordTemp.getTradeState()))) {
  688. WechatReverseApiResult wechatReverseApiResult =
  689. WechatUtil.wxReverse(orderWXPayRecordTemp.getOutTradeNoWX());
  690. //撤销订单成功
  691. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getReturn_code()) &&
  692. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getResult_code())) {
  693. //调用订单查询接口
  694. WechatRefundApiResult wechatRefundApiResult =
  695. WechatUtil.wxOrderQuery(orderWXPayRecordTemp.getOutTradeNoWX());
  696. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getReturn_code()) &&
  697. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getResult_code())) {
  698. // 修改订单支付记录
  699. orderWXPayRecordService
  700. .updateWXPayRecordTradeState(orderWXPayRecordTemp.getId(), wechatRefundApiResult);
  701. }
  702. }
  703. }
  704. }
  705. orderService.confirmPay(id, Dict.payFlag.item_weixin.getItem(), orderWXPayRecordCurrent.getOutTradeNoWX());
  706. r = R.ok();
  707. //用户支付中
  708. } else if (WechatUtil.WXTradeState.USERPAYING.getCode().equals(wechatMicropayApiResult.getTrade_state())) {
  709. r = R.error(WechatUtil.WXTradeState.USERPAYING.getCodeZn() + ",稍等片刻后请刷新页面重新查看订单状态");
  710. //用户支付失败
  711. } else if (WechatUtil.WXTradeState.PAYERROR.getCode().equals(wechatMicropayApiResult.getTrade_state())) {
  712. WechatReverseApiResult wechatReverseApiResult =
  713. WechatUtil.wxReverse(orderWXPayRecordCurrent.getOutTradeNoWX());
  714. //撤销订单成功
  715. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getReturn_code()) &&
  716. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatReverseApiResult.getResult_code())) {
  717. //调用订单查询接口
  718. WechatRefundApiResult wechatRefundApiResult =
  719. WechatUtil.wxOrderQuery(orderWXPayRecordCurrent.getOutTradeNoWX());
  720. if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getReturn_code()) &&
  721. WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatRefundApiResult.getResult_code())) {
  722. // 修改订单支付记录
  723. orderWXPayRecordService
  724. .updateWXPayRecordTradeState(orderWXPayRecordCurrent.getId(), wechatRefundApiResult);
  725. }
  726. r = R.error(orderWXPayRecordCurrent.getErrCodeDes());
  727. } else {
  728. r = R.error(wechatReverseApiResult.getErr_code_des());
  729. }
  730. }
  731. return r;
  732. }
  733. /**
  734. * 线上订单导出请求
  735. */
  736. @RequiresPermissions(value = {"order:export"})
  737. @RequestMapping(value = "export")
  738. public Object export(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  739. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  740. params = ParamUtils.setTimeMap(params);
  741. //查询列表数据
  742. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_0.getItem());
  743. ExcelExport ee = new ExcelExport("线上订单信息");
  744. // =================================================线上订单明细导出开始=====================================
  745. List<OrderEntity> orderList = orderService.queryExportList(params);
  746. String[] header = new String[]{"订单编号", "商户订单编号", "所属门店", "供应商", "供应商第三方商户代码", "订单状态", "SKU", "商品名称", "数量",
  747. "销售价", "促销价", "实际支付金额", "保税模式", "快递公司", "配送单号", "快递费用", "发货状态", "修改人",
  748. "海关清单编号", "收货人姓名", "收件人手机", "收件人省份", "收件人城市", "收件人区县", "收件人地址", "下单时间", "支付流水号", "身份证号"
  749. , "原产国", "规格型号", "品牌", "单位", "毛重(kg)", "净重"};
  750. List<Map<String, Object>> list = new ArrayList<>();
  751. if (orderList != null && orderList.size() != 0) {
  752. for (OrderEntity orderEntity : orderList) {
  753. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  754. Integer orderStatus = orderEntity.getOrderStatus();
  755. String orderBizType = orderEntity.getOrderBizType();
  756. Integer shippingStatus = orderEntity.getShippingStatus();
  757. map.put("OrderSn", orderEntity.getOrderSn());
  758. map.put("MerchOrderSn", orderEntity.getMerchOrderSn());
  759. map.put("StoreName", orderEntity.getStoreName());
  760. map.put("SupplierThirdPartyMerchName", orderEntity.getSupplierThirdPartyMerchName());
  761. map.put("SupplierThirdPartyMerchCode", orderEntity.getSupplierThirdPartyMerchCode());
  762. map.put("OrderStatus", StringUtils.isEmpty(orderStatus.toString())? "":Dict.orderStatus.valueOf("item_"+ orderStatus).getItemName());
  763. map.put("SKU", orderEntity.getSku());
  764. map.put("GoodsName", orderEntity.getGoodsName());
  765. map.put("Number", orderEntity.getNumber());
  766. map.put("RetailPrice", orderEntity.getRetailPrice());
  767. map.put("TopicPrice", orderEntity.getTopicPrice());
  768. map.put("ActualPrice", orderEntity.getActualPrice());
  769. map.put("OrderBizType", StringUtils.isEmpty(orderBizType)? "":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  770. map.put("ShippingName", orderEntity.getShippingName());
  771. map.put("ShippingNo", orderEntity.getShippingNo());
  772. map.put("ShippingFee", orderEntity.getShippingFee());
  773. map.put("ShippingStatus", Dict.shippingStatus.valueOf("item_"+shippingStatus).getItemName());
  774. map.put("ModerSn", orderEntity.getModerSn());
  775. map.put("InvtNo", orderEntity.getOrderProcessRecord()==null?"":orderEntity.getOrderProcessRecord().getInvtNo());
  776. map.put("Consignee", orderEntity.getConsignee());
  777. map.put("Mobile", orderEntity.getMobile());
  778. map.put("Province", orderEntity.getProvince());
  779. map.put("City", orderEntity.getCity());
  780. map.put("District", orderEntity.getDistrict());
  781. map.put("Address", orderEntity.getAddress());
  782. map.put("OrderStartTime", orderEntity.getOrderProcessRecord()==null?"":DateUtils.format(orderEntity.getOrderProcessRecord().getAddOrderStartTime(),"yyyy-MM-dd HH:mm:ss"));
  783. map.put("PayId", orderEntity.getPayTransactionId());
  784. map.put("IdNo", orderEntity.getIdNo());
  785. map.put("OriCntCode", orderEntity.getOriCntCode());
  786. map.put("CiqProdModel", orderEntity.getCiqProdModel());
  787. map.put("Brand", orderEntity.getBrand());
  788. map.put("UnitCode", orderEntity.getUnitCode());
  789. map.put("GrossWeight", orderEntity.getGrossWeight());
  790. map.put("NetWeight", orderEntity.getNetWeight());
  791. // 零售价\促销价\成交价
  792. // map.put("SellPrice",orderEntity.getRetailPrice());
  793. //
  794. // map.put("FinalPrice",orderEntity.getActualPrice());
  795. list.add(map);
  796. }
  797. }
  798. // =================================================线上订单明细导出开始=====================================
  799. // =================================================线上订单导出开始=====================================
  800. List<OrderEntity> masterOrderList = orderService.queryMasterExportList(params);
  801. String[] headerMatser = new String[]{"所属门店", "订单号", "会员", "支付类型", "商户订单号", "订单业务类型", "订单状态", "订付人核验", "付款状态",
  802. "实际支付", "订单总价", "下单时间", "快递公司", "配送单号", "快递费用", "发货状态", "修改人",};
  803. List<Map<String, Object>> listMaster = new ArrayList<>();
  804. if (masterOrderList != null && masterOrderList.size() > 0) {
  805. for (OrderEntity orderEntity : masterOrderList) {
  806. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  807. String orderBizType = orderEntity.getOrderBizType();
  808. Integer orderStatus = orderEntity.getOrderStatus();
  809. String isMergePay = orderEntity.getIsMergePay();
  810. String buyerPayCheck = orderEntity.getBuyerPayCheck();
  811. map.put("StoreName",orderEntity.getStoreName());
  812. map.put("OrderSn",orderEntity.getOrderSn());
  813. map.put("UserName",orderEntity.getUserName());
  814. map.put("IsMergePay",StringUtils.isEmpty(isMergePay)?"-":Dict.isMergePay.valueOf("item_"+isMergePay).getItemName());
  815. map.put("MerchOrderSn",orderEntity.getMerchOrderSn());
  816. map.put("OrderBizType",StringUtils.isEmpty(orderBizType)? "":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  817. map.put("OrderStatus",Dict.orderStatus.valueOf("item_"+ orderStatus).getItemName());
  818. map.put("BuyerPayCheck",StringUtils.isEmpty(buyerPayCheck)?"":Dict.merchReturnSubjectChecked.valueOf("item_"+buyerPayCheck).getItemName());
  819. map.put("PayStatus",Dict.payStatus.valueOf("item_"+orderEntity.getPayStatus()).getItemName());
  820. map.put("ActualPrice",orderEntity.getActualPrice());
  821. map.put("OrderPrice",orderEntity.getOrderPrice());
  822. map.put("AddTime",orderEntity.getAddTime());
  823. map.put("ShippingName",orderEntity.getShippingName());
  824. map.put("ShippingNo",orderEntity.getShippingNo());
  825. map.put("ShippingFee",orderEntity.getShippingFee());
  826. map.put("ShippingStatus",Dict.shippingStatus.valueOf("item_"+orderEntity.getShippingStatus()).getItemName());
  827. map.put("ModerSn",orderEntity.getModerSn());
  828. listMaster.add(map);
  829. }
  830. }
  831. // =================================================线上订单导出结束=====================================
  832. ee.addSheetByMap("线上订单信息", listMaster, headerMatser);
  833. ee.addSheetByMap("线上订单明细信息", list, header);
  834. ee.export(response);
  835. return R.ok();
  836. }
  837. /**
  838. * 订单修改已发货的快递信息
  839. */
  840. @RequestMapping("/updateExpressInfo")
  841. @RequiresPermissions("order:updateExpressInfo")
  842. public Object updateExpressInfo(@RequestBody OrderEntity orderEntity) {
  843. OrderEntity orderInfo = orderService.queryObject(orderEntity.getId());
  844. if (orderInfo != null){
  845. if(orderInfo.getShippingStatus() == Integer.parseInt(Dict.shippingStatus.item_1.getItem())) {
  846. OrderEntity order = new OrderEntity();
  847. order.setId(orderInfo.getId());
  848. order.setShippingCode(orderEntity.getShippingCode());
  849. Map map = new HashMap();
  850. map.put("code", orderEntity.getShippingCode());
  851. ShippingEntity shippingEntity = shippingService.queryObjectByCode(orderEntity.getShippingCode());
  852. if(shippingEntity != null) {
  853. order.setShippingName(shippingEntity.getName());
  854. }else{
  855. throw new RRException("此订单修改的快递公司信息不存在!不能操作");
  856. }
  857. order.setShippingNo(orderEntity.getShippingNo());
  858. order.setModerSn(ShiroUtils.getUserEntity().getUsername());
  859. order.setModTime(new Date());
  860. orderService.update(order);
  861. }else{
  862. throw new RRException("此订单"+Dict.shippingStatus.valueOf("item_"+orderInfo.getShippingStatus()).getItemName()+"!不能操作");
  863. }
  864. }
  865. return R.ok();
  866. }
  867. /**
  868. * 上传文件
  869. */
  870. @RequestMapping("/expressUpload")
  871. @ResponseBody
  872. public R expressUpload(@RequestParam("file") MultipartFile file) {
  873. List<OrderExpressDto> orderExpressList = new ArrayList<>();//快递信息
  874. try {
  875. Map<String, Object> beans = new HashMap<String, Object>();
  876. beans.put("OrderExpressList", orderExpressList);
  877. if (file.isEmpty()) {
  878. return R.error("文件不能为空!");
  879. }
  880. excelUtil.readExcel(JxlsXmlTemplateName.ORDER_EXPRESS_LIST, beans, file.getInputStream());
  881. } catch (Exception e) {
  882. e.printStackTrace();
  883. return R.error("导入失败!");
  884. }
  885. orderService.uploadExcel(orderExpressList);
  886. //上传文件
  887. return R.ok();
  888. }
  889. /**
  890. * 获取ccnet需要重发的订单数据
  891. */
  892. @RequestMapping("/wxOrderResendQueryAllList")
  893. public R wxOrderResendQueryAllList(@RequestParam Map<String, Object> params) {
  894. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  895. //查询列表数据
  896. Query query = new Query(params);
  897. List<WxOrderEntity> orderList = orderService.wxOrderResendQueryAllList(query);
  898. PageUtils pageUtil = new PageUtils(orderList, orderList.size(), query.getLimit(), query.getPage());
  899. return R.ok().put("page", pageUtil);
  900. }
  901. /**
  902. * 收银端支付
  903. * @param param
  904. * @return
  905. * @throws IOException
  906. */
  907. @RequestMapping("/orderConfirm")
  908. public R orderConfirm(@RequestBody Map param) throws IOException {
  909. SysUserEntity user = ShiroUtils.getUserEntity();
  910. Map resultObj = null;
  911. try {
  912. // throw new RuntimeException("系统异常");
  913. resultObj = orderService.offlineRetailSubmit(param,user);
  914. if(resultObj.get("errno") != null && ((Integer)resultObj.get("errno")) == 400){
  915. return R.error((String) resultObj.get("errmsg"));
  916. }
  917. return R.ok().put("resultObj", resultObj);
  918. }catch (Exception e) {
  919. if (e.getMessage().contains("java.lang.IllegalStateException: invalid auth_code!")){
  920. return R.error("付款码异常,请重新输入!");
  921. }
  922. return R.error(e.getMessage());
  923. }
  924. }
  925. /**
  926. *
  927. * @param param
  928. * @return
  929. * @throws IOException
  930. */
  931. @RequestMapping("/orderRefund")
  932. public R orderRefund( @RequestBody Map param) {
  933. Integer orderId = (Integer) param.get("orderId");
  934. OrderEntity orderInfo = orderService.queryObject(orderId.longValue());
  935. String sessionId = (String) param.get("sessionId");
  936. try {
  937. return orderService.orderRefund(orderInfo,sessionId);
  938. } catch (Exception e) {
  939. e.printStackTrace();
  940. }
  941. return R.ok();
  942. }
  943. @RequestMapping("/resendOrderToCCNET/{orderSn}/{resendType}")
  944. public String resendWayBill(@PathVariable("orderSn") String orderSn, @PathVariable("resendType") String resendType){
  945. String response = null;
  946. Map map = new HashMap();
  947. map.put("orderSn",orderSn);
  948. try {
  949. String url = "";
  950. if("waybill".equals(resendType)){
  951. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/resendWaybill/"+orderSn;
  952. }else if("payment".equals(resendType)){
  953. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/resendPayment/"+orderSn;
  954. }else if("notice".equals(resendType)){
  955. url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/notice/"+orderSn;
  956. }
  957. // 同步访问,返回结果字符串
  958. response = OkHttpUtils.post(map, url, "SSL");
  959. ResponseData responseData = JacksonUtils.fromStringJson(response, ResponseData.class);
  960. if(responseData.getCode().equalsIgnoreCase("0")){
  961. List<WxOrderEntity> list = responseData.getData().getRows();
  962. }
  963. } catch (Exception e) {
  964. logger.error("查询失败。"+e.getMessage());
  965. }
  966. return response;
  967. }
  968. @RequestMapping("/orderDetail/{orderSn}")
  969. public R orderDetail(@PathVariable("orderSn") String orderSn) throws IOException {
  970. OrderProcessRecordEntity orderProcessRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderSn);
  971. OrderEntity orderEntity = orderService.queryObjectByOrderSn(orderSn);
  972. Map map = new HashMap();
  973. map.put("orderId",orderEntity.getId());
  974. List<OrderGoodsEntity> goodsList = orderGoodsService.queryList(map);
  975. BigDecimal tax = new BigDecimal(0);
  976. for(OrderGoodsEntity orderGoodsEntity : goodsList){
  977. BigDecimal retailPrice = orderGoodsEntity.getRetailPrice();
  978. BigDecimal goodsRate = orderGoodsEntity.getGoodsRate();
  979. Integer number = orderGoodsEntity.getNumber();
  980. BigDecimal goodsTax = retailPrice.divide(new BigDecimal(1).add(goodsRate),2,RoundingMode.HALF_DOWN).multiply(goodsRate).multiply(new BigDecimal(number)).setScale(0,RoundingMode.HALF_DOWN);
  981. orderGoodsEntity.setTax(goodsTax);
  982. tax = tax.add(goodsTax);
  983. }
  984. String response = null;
  985. try {
  986. // 查询失败原因
  987. String url = OmsMerchPropertiesBuilder.instance().getWxOrderResendUrl() + "/"+orderSn;
  988. // 同步访问,返回结果字符串
  989. response = OkHttpUtils.post(map, url, "SSL");
  990. ResponseData responseData = JacksonUtils.fromStringJson(response, ResponseData.class);
  991. if(responseData.getCode().equalsIgnoreCase("0")){
  992. List<WxOrderEntity> list = responseData.getData().getRows();
  993. }
  994. } catch (Exception e) {
  995. logger.error("查询失败。"+e.getMessage());
  996. }
  997. Map<String,Object> result = new HashMap<>();
  998. result.put("orderProcessRecordEntity",orderProcessRecordEntity);
  999. result.put("orderEntity",orderEntity);
  1000. result.put("goodsList",goodsList);
  1001. result.put("tax",tax.setScale(2, RoundingMode.HALF_DOWN).toString());
  1002. result.put("response",response);
  1003. return R.ok().put("resultObj", result);
  1004. }
  1005. @RequestMapping("/queryIDCardInfo/{mobile}")
  1006. public R queryIDCardInfo(@PathVariable("mobile")String mobile) throws IOException {
  1007. UserEntity userEntity = userService.queryByMobile(mobile);
  1008. if (userEntity == null) {
  1009. return R.error("该手机号未找到对应信息");
  1010. }
  1011. return R.ok().put("userEntity",userEntity);
  1012. }
  1013. @RequestMapping("/purchaseSalesInStockDetail")
  1014. // @RequiresPermissions("order:offilineOrderList")
  1015. public R purchaseSalesInStockDetail(@RequestParam Map<String, Object> params) {
  1016. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  1017. //查询列表数据
  1018. Query query = new Query(params);
  1019. List<PurchaseSalesInStockDetail> orderList = orderService.purchaseSalesInStockDetailList(query);
  1020. int total = orderService.purchaseSalesInStockDetailTotal(query);
  1021. // 遍历循环订单是哪个店员销售的,根据订单号查询
  1022. PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage());
  1023. return R.ok().put("page", pageUtil);
  1024. }
  1025. /**
  1026. * 线下订单导出请求
  1027. */
  1028. @RequiresPermissions("order:exportOffilineOrder")
  1029. @RequestMapping(value = "exportOffilineOrder")
  1030. public R exportOffilineOrder(@RequestParam Map<String, Object> params, HttpServletResponse response, HttpServletRequest request) {
  1031. ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", "thirdPartyMerchCode");
  1032. params = ParamUtils.setTimeMap(params);
  1033. params.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
  1034. ExcelExport ee = new ExcelExport("线下订单信息");
  1035. //查询列表数据
  1036. // =================================================线下订单明细导出开始=====================================
  1037. List<OrderEntity> orderEntityList = orderService.queryExportOffilineOrderList(params);
  1038. String[] header = new String[]{"订单号", "操作店员", "购买类型", "订单业务类型", "订单状态",
  1039. "付款状态", "sku", "商品名称", "数量", "实际支付", /*"订单总价",*/ "下单时间", "付款时间", "零售价", "优惠金额", "成交价"};
  1040. List<Map<String, Object>> list = new ArrayList<>();
  1041. if (orderEntityList != null && orderEntityList.size() > 0) {
  1042. for (OrderEntity orderEntity : orderEntityList) {
  1043. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  1044. // 订单业务类型
  1045. String orderBizType = orderEntity.getOrderBizType();
  1046. // 订单状态
  1047. Integer orderStatus = orderEntity.getOrderStatus();
  1048. // 付款状态
  1049. Integer payStatus = orderEntity.getPayStatus();
  1050. map.put("OrderSn", orderEntity.getOrderSn());
  1051. map.put("UserName", orderEntity.getUserName());
  1052. map.put("IsOnfflineOrder", Dict.isOnfflineOrder.item_1.getItem().equals(orderEntity.getIsOnfflineOrder()) ? "线下购买" : "线上购买");
  1053. map.put("OrderBizType", StringUtils.isEmpty(orderBizType)?"":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  1054. map.put("OrderStatus", Dict.orderStatus.valueOf("item_"+orderStatus).getItemName());
  1055. map.put("PayStatus", Dict.payStatus.valueOf("item_"+payStatus).getItemName());
  1056. map.put("Sku", orderEntity.getSku());
  1057. map.put("GoodsName", orderEntity.getGoodsName());
  1058. map.put("Number", orderEntity.getNumber());
  1059. map.put("ActualPrice", orderEntity.getActualPrice()); // 实际支付价
  1060. // map.put("OrderPrice", orderEntity.getOrderPrice()); // 订单总价
  1061. map.put("AddTime", orderEntity.getAddTime());
  1062. map.put("PayTime", orderEntity.getPayTime());
  1063. map.put("SellPrice", orderEntity.getRetailPrice()); // 零售价
  1064. map.put("CouponPrice", orderEntity.getCouponPrice()); // 促销价
  1065. map.put("FinalPrice", orderEntity.getActualPrice()); // 成交价
  1066. list.add(map);
  1067. }
  1068. }
  1069. // =================================================线下订单明细导出结束=====================================
  1070. // =================================================线下订单导出开始=====================================
  1071. List<OrderEntity> masterOrderEntityList = orderService.queryMasterExportOffilineOrderList(params);
  1072. String[] headerMaster = new String[]{"订单号", "操作店员", "购买类型", "订单业务类型", "订单状态",
  1073. "付款状态", "实际支付", "订单总价", "下单时间", "付款时间"};
  1074. List<Map<String, Object>> listMaster = new ArrayList<>();
  1075. if (masterOrderEntityList != null && masterOrderEntityList.size() > 0) {
  1076. for (OrderEntity orderEntity : masterOrderEntityList) {
  1077. LinkedHashMap<String, Object> map = new LinkedHashMap<>();
  1078. // 订单业务类型
  1079. String orderBizType = orderEntity.getOrderBizType();
  1080. // 订单状态
  1081. Integer orderStatus = orderEntity.getOrderStatus();
  1082. // 付款状态
  1083. Integer payStatus = orderEntity.getPayStatus();
  1084. map.put("OrderSn", orderEntity.getOrderSn());
  1085. map.put("UserName", orderEntity.getUserName());
  1086. map.put("IsOnfflineOrder", Dict.isOnfflineOrder.item_1.getItem().equals(orderEntity.getIsOnfflineOrder()) ? "线下购买" : "线上购买");
  1087. map.put("OrderBizType", StringUtils.isEmpty(orderBizType)?"":Dict.orderBizType.valueOf("item_"+orderBizType).getItemName());
  1088. map.put("OrderStatus", Dict.orderStatus.valueOf("item_"+orderStatus).getItemName());
  1089. map.put("PayStatus", Dict.payStatus.valueOf("item_"+payStatus).getItemName());
  1090. map.put("ActualPrice", orderEntity.getActualPrice());
  1091. map.put("OrderPrice", orderEntity.getOrderPrice());
  1092. map.put("AddTime", orderEntity.getAddTime());
  1093. map.put("PayTime", orderEntity.getPayTime());
  1094. listMaster.add(map);
  1095. }
  1096. }
  1097. // =================================================线下订单导出结束=====================================
  1098. ee.addSheetByMap("线下订单信息", listMaster, headerMaster);
  1099. ee.addSheetByMap("线下订单明细信息", list, header);
  1100. ee.export(response);
  1101. return R.ok();
  1102. }
  1103. }