OrderController.java 56 KB

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