package com.kmall.admin.controller; import com.kmall.admin.entity.*; import com.kmall.admin.service.*; import com.kmall.admin.service.OrderExceptionRecordService; import com.kmall.admin.service.OrderProcessRecordService; import com.kmall.admin.service.OrderService; import com.kmall.api.contants.Dict; import com.kmall.common.entity.SysUserEntity; import com.kmall.common.utils.*; import com.kmall.common.utils.print.ticket.item.Ticket; import com.kmall.common.utils.wechat.WechatMicropayApiResult; import com.kmall.common.utils.wechat.WechatRefundApiResult; import com.kmall.common.utils.wechat.WechatReverseApiResult; import com.kmall.common.utils.wechat.WechatUtil; import org.apache.shiro.authz.annotation.RequiresPermissions; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Map; /** * @author Scott * @email * @date 2017-08-13 10:41:09 */ @RestController @RequestMapping("order") public class OrderController { @Autowired private OrderService orderService; @Autowired private OrderProcessRecordService orderProcessRecordService; @Autowired private OrderRefundService orderRefundService; @Autowired private OrderExceptionRecordService orderExceptionRecordService; @Autowired private StoreService storeService; @Autowired private OrderWXPayRecordService orderWXPayRecordService; /** * 列表 */ @RequestMapping("/list") @RequiresPermissions("order:list") public R list(@RequestParam Map params) { SysUserEntity user = ShiroUtils.getUserEntity(); if (user != null) { if (user.getRoleType().equalsIgnoreCase("2")) { params.put("storeId", user.getStoreId()); } } //查询列表数据 Query query = new Query(params); query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_0.getItem()); List orderList = orderService.queryList(query); int total = orderService.queryTotal(query); PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage()); return R.ok().put("page", pageUtil); } /** * 信息 */ @RequestMapping("/info/{id}") @RequiresPermissions("order:info") public R info(@PathVariable("id") Long id) { OrderEntity order = orderService.queryObject(id); return R.ok().put("order", order); } /** * 信息 */ @RequestMapping("/infos/{id}") @RequiresPermissions("order:infos") public R infos(@PathVariable("id") Long id) { OrderEntity order = orderService.queryInfos(id); return R.ok().put("order", order); } /** * 保存 */ @RequestMapping("/save") @RequiresPermissions("order:save") public R save(@RequestBody OrderEntity order) { orderService.save(order); return R.ok(); } /** * 修改 */ @RequestMapping("/update") @RequiresPermissions("order:update") public R update(@RequestBody OrderEntity order) { orderService.update(order); return R.ok(); } /** * 删除 */ @RequestMapping("/delete") @RequiresPermissions("order:delete") public R delete(@RequestBody Long[] ids) { orderService.deleteBatch(ids); return R.ok(); } /** * 查看所有列表 */ @RequestMapping("/queryAll") public R queryAll(@RequestParam Map params) { List list = orderService.queryList(params); return R.ok().put("list", list); } /** * 总计 */ @RequestMapping("/queryTotal") public R queryTotal(@RequestParam Map params) { int sum = orderService.queryTotal(params); return R.ok().put("sum", sum); } /** * 确定收货 * * @param id * @return */ @RequestMapping("/confirm") @RequiresPermissions("order:confirm") public R confirm(@RequestBody Long id) { orderService.confirm(id); return R.ok(); } /** * 发货 * * @param order * @return */ @RequestMapping("/sendGoods") @RequiresPermissions("order:sendGoods") public R sendGoods(@RequestBody OrderEntity order) { orderService.sendGoods(order); return R.ok(); } /** * 跟踪快递轨迹 * * @param id * @return */ @RequestMapping("/getLogistics/{id}") @RequiresPermissions("order:getLogistics") public R getLogistics(@PathVariable("id") Long id) { Map result = orderService.getLogistics(id); return R.ok().put("result", result); } /** * 获取订单清关信息 * * @param orderSn * @return */ @RequestMapping("/getProcess/{orderSn}") @RequiresPermissions("order:getProcess") public R getProcess(@PathVariable("orderSn") String orderSn) { OrderProcessRecordEntity orderProcessRecordEntity = orderProcessRecordService.queryObjectByOrderSn(orderSn); if(orderProcessRecordEntity != null){ if(orderProcessRecordEntity.getShipmentStartTime()!=null){ orderProcessRecordEntity.setShipmentStartTimeStr(DateUtils.format(orderProcessRecordEntity.getShipmentStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getShipmentSuccTime()!=null){ orderProcessRecordEntity.setShipmentSuccTimeStr(DateUtils.format(orderProcessRecordEntity.getShipmentSuccTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getCustomsStartTime()!=null){ orderProcessRecordEntity.setCustomsStartTimeStr(DateUtils.format(orderProcessRecordEntity.getCustomsStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getCustomsSuccTime()!=null){ orderProcessRecordEntity.setCustomsSuccTimeStr(DateUtils.format(orderProcessRecordEntity.getCustomsSuccTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getWaybillStartTime()!=null){ orderProcessRecordEntity.setWaybillStartTimeStr(DateUtils.format(orderProcessRecordEntity.getWaybillStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getWaybillSuccTime()!=null){ orderProcessRecordEntity.setWaybillSuccTimeStr(DateUtils.format(orderProcessRecordEntity.getWaybillSuccTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getEleOrderStartTime()!=null){ orderProcessRecordEntity.setEleOrderStartTimeStr(DateUtils.format(orderProcessRecordEntity.getEleOrderStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getEleOrderSuccTime()!=null){ orderProcessRecordEntity.setEleOrderSuccTimeStr(DateUtils.format(orderProcessRecordEntity.getEleOrderSuccTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getAddOrderStartTime()!=null){ orderProcessRecordEntity.setAddOrderStartTimeStr(DateUtils.format(orderProcessRecordEntity.getAddOrderStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getAddOrderSuccTime()!=null){ orderProcessRecordEntity.setAddOrderSuccTimeStr(DateUtils.format(orderProcessRecordEntity.getAddOrderSuccTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getPaySuccTime()!=null){ orderProcessRecordEntity.setPaySuccTimeStr(DateUtils.format(orderProcessRecordEntity.getPaySuccTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getPayStartTime()!=null){ orderProcessRecordEntity.setPayStartTimeStr(DateUtils.format(orderProcessRecordEntity.getPayStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getPaymentStartTime()!=null){ orderProcessRecordEntity.setPaymentStartTimeStr(DateUtils.format(orderProcessRecordEntity.getPaymentStartTime(),DateUtils.DATE_TIME_PATTERN)); } if(orderProcessRecordEntity.getPaymentSuccTime()!=null){ orderProcessRecordEntity.setPaymentSuccTimeStr(DateUtils.format(orderProcessRecordEntity.getPaymentSuccTime(),DateUtils.DATE_TIME_PATTERN)); } } return R.ok().put("orderProcessRecordEntity", orderProcessRecordEntity); } /** * 打印小票 * * @param id * @return */ @RequestMapping("/printMsg") public R printMsg(@RequestBody Long id) { Ticket ticket = orderService.printMsg(id); return R.ok().put("ticket", ticket); } /** * 订单取消请求 */ @RequiresPermissions(value = {"order:refund"}) @RequestMapping(value = "cancel", method = RequestMethod.POST) public Object cancel(Long orderId) { OrderEntity orderInfo = orderService.queryObject(orderId); if (null == orderInfo) { return R.error("订单不存在"); } if (orderInfo.getOrderStatus() != 0) { return R.error("订单状态不支持取消"); } orderService.cancelOrder(orderInfo); return R.ok(); } /** * 订单退款请求 */ @RequiresPermissions(value = {"order:refund"}) @RequestMapping(value = "refund", method = RequestMethod.POST) public Object refund(Long orderId, BigDecimal refundMoney) { OrderEntity orderInfo = orderService.queryObject(orderId); if (null == orderInfo) { return R.error("订单不存在"); } if (orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_401.getItem()) || orderInfo.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_402.getItem())) { return R.error("订单已退款"); } Double totalActualPrice = orderService.getTotalActualPrice(orderInfo.getMerchOrderSn()); if (totalActualPrice == null) { totalActualPrice = 0d; } if (orderInfo.getOrderStatus() != 0) { // todo 退款 // WechatRefundApiResult result = WechatUtil.wxRefund(orderInfo.getOrderSn().toString(), // orderInfo.getActualPrice().doubleValue(), refundMoney.doubleValue()); WechatRefundApiResult result = WechatUtil.wxRefund(orderInfo.getMerchOrderSn().toString(), totalActualPrice, orderInfo.getActualPrice().doubleValue()); if (result.getResult_code().equals("SUCCESS")) { orderService.refund(orderInfo, result); } else { OrderRefundEntity mallOrderRefund = orderRefundService.queryObjectByOrderId(orderInfo.getId()); OrderRefundEntity orderRefund = new OrderRefundEntity(); orderRefund.setRefundType(Integer.parseInt(Dict.RefundType.item_1.getItem())); orderRefund.setRefundMoney(BigDecimal.valueOf(orderInfo.getActualPrice().doubleValue())); orderRefund.setRefundStatus(Integer.parseInt(Dict.RefundStatus.item_4.getItem())); orderRefund.setModTime(new Date()); orderRefund.setOutRefundNo(result.getOut_refund_no()); if (mallOrderRefund != null) { orderRefund.setId(mallOrderRefund.getId()); orderRefundService.update(orderRefund);//退款记录 } OrderExceptionRecordEntity mallOrderExceptionRecord = new OrderExceptionRecordEntity(); mallOrderExceptionRecord.setUserId(Integer.parseInt(orderInfo.getUserId() + "")); mallOrderExceptionRecord.setOrderSn(orderInfo.getOrderSn()); mallOrderExceptionRecord.setExceptionStatus(Dict.exceptionStatus.item_03.getItem()); mallOrderExceptionRecord.setExceptionContent("退款失败" + result.getErr_code_des()); mallOrderExceptionRecord.setCreateTime(new Date()); orderExceptionRecordService.save(mallOrderExceptionRecord); return R.error(result.getErr_code_des()); } } return R.ok("退款成功"); } /** * 获取首页展示信息--会员购买率相关 * * @param params * @return */ @RequestMapping("/getUserOrderInfo") public R getUserOrderInfo(@RequestParam Map params) { int result = orderService.getUserOrderInfo(params); return R.ok().put("result", result); } @RequiresPermissions(value = {"order:orderSubmit"}) @RequestMapping(value = "orderSubmit", method = RequestMethod.POST) @ResponseBody public R orderSubmit(@RequestBody List offlineCartEntityList) { Map resultObj = null; try { SysUserEntity user = ShiroUtils.getUserEntity(); resultObj = orderService.orderSubmit(offlineCartEntityList,user); if (((Integer)resultObj.get("errno")) != 0) { return R.error((String)resultObj.get("errmsg")); } } catch (Exception e) { e.printStackTrace(); } return R.ok("订单提交成功"); } /** * 确认付款 * * @param id * @return */ @RequestMapping("/confirmPay") @RequiresPermissions("order:confirmPay") public R confirmPay(@RequestBody Long id) { orderService.confirmPay(id); return R.ok(); } @RequestMapping("/offilineOrderList") @RequiresPermissions("order:offilineOrderList") public R offilineOrderList(@RequestParam Map params) { SysUserEntity user = ShiroUtils.getUserEntity(); if (user != null) { if (user.getRoleType().equalsIgnoreCase("2")) { params.put("storeId", user.getStoreId()); } } //查询列表数据 Query query = new Query(params); query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem()); List orderList = orderService.queryOffilineOrderList(query); int total = orderService.queryTotal(query); PageUtils pageUtil = new PageUtils(orderList, total, query.getLimit(), query.getPage()); return R.ok().put("page", pageUtil); } @RequestMapping("/offlineInfos/{id}") @RequiresPermissions("order:offlineInfos") public R queryObjectBySysUser(@PathVariable("id") Long id) { OrderEntity order = orderService.queryObjectBySysUser(id); List payRecords = orderWXPayRecordService.getRecordsByOutTradeNo(order.getOrderSn()); order.setPayRecordList(payRecords); return R.ok().put("order", order); } @RequestMapping("/wxMicropayPay") @RequiresPermissions("order:wxMicropayPay") public R wxMicropayPay(Long id, String auth_code) { R r = null; SysUserEntity user = ShiroUtils.getUserEntity(); if (user == null) { throw new RRException("用户登录超时，请重新登录"); } if (!user.getRoleType().equalsIgnoreCase("2")) { throw new RRException("该操作只允许店员账户操作"); } OrderEntity orderEntity = orderService.queryObject(id); if (orderEntity.getOrderStatus() == Integer.valueOf(Dict.orderStatus.item_201.getItem())) { throw new RRException("此订单已付款！"); } if (orderEntity.getOrderStatus() == Integer.valueOf(Dict.orderStatus.item_301.getItem())) { throw new RRException("此订单已完成！"); } if (orderEntity.getOrderStatus() == Integer.valueOf(Dict.orderStatus.item_101.getItem())) { throw new RRException("此订单已取消！"); } if (orderEntity.getOrderStatus() == Integer.valueOf(Dict.orderStatus.item_102.getItem())) { throw new RRException("此订单已删除！"); } //保存支付记录 OrderWXPayRecordEntity orderWXPayRecordCurrent = orderWXPayRecordService.saveRecord(orderEntity); StoreEntity store = storeService.queryObject(orderEntity.getStoreId()); WechatMicropayApiResult wechatMicropayApiResult = WechatUtil .wxMicropay(store.getMerchName() + "-" + store.getStoreName(), orderEntity.getOrderBizType(), null, orderWXPayRecordCurrent.getOutTradeNoWX(), orderEntity.getActualPrice().doubleValue(), "127.0.0.1", auth_code); System.out.println("orderWXPayRecordEntity.id=" + orderWXPayRecordCurrent.getId()); orderWXPayRecordService.updateRecord(orderWXPayRecordCurrent.getId(), wechatMicropayApiResult); System.out.println(wechatMicropayApiResult); //当支付成功时,修改订单,并把其他支付记录撤销 if (WechatUtil.WXTradeState.SUCCESS.getCode().equals(wechatMicropayApiResult.getTrade_state())) { //查询当前订单所有的支付记录 List orderWXPayRecordEntitys = orderWXPayRecordService.getRecordsByOutTradeNo(orderEntity.getOrderSn()); for (OrderWXPayRecordEntity orderWXPayRecordTemp : orderWXPayRecordEntitys) { //查询出来的记录不等于当前记录,并且未撤销,未关闭时,撤销订单 if (orderWXPayRecordTemp.getId() != orderWXPayRecordCurrent.getId() && (!WechatUtil.WXTradeState.REVOKED.getCode().equals(orderWXPayRecordTemp.getTradeState()) || !WechatUtil.WXTradeState.CLOSED.getCode().equals(orderWXPayRecordTemp.getTradeState()))) { WechatReverseApiResult wechatReverseApiResult = WechatUtil.wxReverse(orderWXPayRecordTemp.getOutTradeNoWX()); //撤销订单成功 if ("SUCCESS".equals(wechatReverseApiResult.getReturn_code()) && "SUCCESS".equals(wechatReverseApiResult.getResult_code())) { //调用订单查询接口 WechatRefundApiResult wechatRefundApiResult = WechatUtil.wxOrderQuery(orderWXPayRecordTemp.getOutTradeNoWX()); if ("SUCCESS".equals(wechatRefundApiResult.getReturn_code()) && "SUCCESS".equals(wechatRefundApiResult.getResult_code())) { // 修改订单支付记录 orderWXPayRecordService .updateWXPayRecordTradeState(orderWXPayRecordTemp.getId(), wechatRefundApiResult); } } } } orderService.confirmPay(id); r = R.ok(); //用户支付中 } else if (WechatUtil.WXTradeState.USERPAYING.getCode().equals(wechatMicropayApiResult.getTrade_state())) { r = R.error(WechatUtil.WXTradeState.USERPAYING.getCodeZn() + ",稍等片刻后请刷新页面重新查看订单状态"); //用户支付失败 } else if (WechatUtil.WXTradeState.PAYERROR.getCode().equals(wechatMicropayApiResult.getTrade_state())) { WechatReverseApiResult wechatReverseApiResult = WechatUtil.wxReverse(orderWXPayRecordCurrent.getOutTradeNoWX()); //撤销订单成功 if ("SUCCESS".equals(wechatReverseApiResult.getReturn_code()) && "SUCCESS".equals(wechatReverseApiResult.getResult_code())) { //调用订单查询接口 WechatRefundApiResult wechatRefundApiResult = WechatUtil.wxOrderQuery(orderWXPayRecordCurrent.getOutTradeNoWX()); if ("SUCCESS".equals(wechatRefundApiResult.getReturn_code()) && "SUCCESS".equals(wechatRefundApiResult.getResult_code())) { // 修改订单支付记录 orderWXPayRecordService .updateWXPayRecordTradeState(orderWXPayRecordCurrent.getId(), wechatRefundApiResult); } r = R.error(orderWXPayRecordCurrent.getErrCodeDes()); } else { r = R.error(wechatReverseApiResult.getErr_code_des()); } } return r; } }