kmall-pt/kmall-admin/src/main/java/com/kmall/admin/controller/OrderController.java

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.admin.utils.ParamUtils;
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<String, Object> params) {
        ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", false);
        //查询列表数据
        Query query = new Query(params);
        query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_0.getItem());
        List<OrderEntity> 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<String, Object> params) {
        ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", false);
        List<OrderEntity> list = orderService.queryList(params);

        return R.ok().put("list", list);
    }

    /**
     * 总计
     */
    @RequestMapping("/queryTotal")
    public R queryTotal(@RequestParam Map<String, Object> params) {
        ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", false);
        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("退款成功");
    }


    /**
     * 订单退款请求
     */
    @RequiresPermissions(value = {"order:offilineRefund"})
    @RequestMapping(value = "offilineRefund", method = RequestMethod.POST)
    public Object offilineRefund(Long orderId) {
        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("订单已退款");
        }

        if (orderInfo.getOrderStatus() != 0) {

            List<OrderWXPayRecordEntity> orderWXPayRecords =
                    orderWXPayRecordService.getRecordsByOutTradeNo(orderInfo.getOrderSn());
            //支付成功的发送到微信的订单编号
            String paySuccessOutTradeNoWX = null;
            if (orderWXPayRecords != null) {
                for (OrderWXPayRecordEntity orderWXPayRecord : orderWXPayRecords) {
                    if ("SUCCESS".equals(orderWXPayRecord.getTradeState())) {
                        paySuccessOutTradeNoWX = orderWXPayRecord.getOutTradeNoWX();
                        break;
                    }
                }
            }

            // todo 退款
            WechatRefundApiResult result = WechatUtil
                    .wxRefund(paySuccessOutTradeNoWX, orderInfo.getActualPrice().doubleValue(),
                              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<String, Object> 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<OfflineCartEntity> 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<String, Object> params) {
        ParamUtils.setQueryPowerByRoleType(params, "storeId", "merchSn", false);
        //查询列表数据
        Query query = new Query(params);
        query.put("isOnfiilineOrder", Dict.isOnfflineOrder.item_1.getItem());
        List<OrderEntity> 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<OrderWXPayRecordEntity> 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.parseInt(Dict.orderStatus.item_201.getItem())) {
            throw new RRException("此订单已付款！");
        }
        if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_301.getItem())) {
            throw new RRException("此订单已完成！");
        }
        if (orderEntity.getOrderStatus() == Integer.parseInt(Dict.orderStatus.item_101.getItem())) {
            throw new RRException("此订单已取消！");
        }
        if (orderEntity.getOrderStatus() == Integer.parseInt(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<OrderWXPayRecordEntity> 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;
    }
}