OrderController.java 77 KB

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