package com.stylefeng.guns.modular.system.controller.specialTrain;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.stylefeng.guns.core.base.controller.BaseController;
import com.stylefeng.guns.core.common.constant.factory.PageFactory;
import com.stylefeng.guns.core.shiro.ShiroKit;
import com.stylefeng.guns.core.shiro.ShiroUser;
import com.stylefeng.guns.core.util.SinataUtil;
import com.stylefeng.guns.core.util.ToolUtil;
import com.stylefeng.guns.modular.system.dao.OrderCancelMapper;
import com.stylefeng.guns.modular.system.model.*;
import com.stylefeng.guns.modular.system.service.*;
import com.stylefeng.guns.modular.system.util.*;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 小件物流订单控制器
 *
 * @author fengshuonan
 * @Date 2020-09-24 14:20:41
 */
@Controller
@RequestMapping("/tOrderLogistics")
public class TOrderLogisticsController extends BaseController {

    private String PREFIX = "/system/tOrderLogistics/";

    @Autowired
    private ITOrderLogisticsService tOrderLogisticsService;

    @Resource
    private OrderCancelMapper orderCancelMapper;

    @Autowired
    private ITUserService userService;

    @Autowired
    private ITransactionDetailsService transactionDetailsService;

    @Autowired
    private IPaymentRecordService paymentRecordService;

    @Autowired
    private IIncomeService incomeService;
    
    @Autowired
    private ITDriverService tDriverService;
    
    @Autowired
    private ITTimeoutAppealService timeoutAppealService;
    
    @Autowired
    private PayMoneyUtil payMoneyUtil;
    @Autowired
    private IUserCouponRecordService userCouponRecordService;
    
    /**
     * 跳转到小件物流订单首页
     */
    @RequestMapping("")
    public String index() {
        return PREFIX + "tOrderLogistics.html";
    }
    
    /**
     * 跳转到添加小件物流订单
     */
    @RequestMapping("/tOrderLogistics_add")
    public String tOrderLogisticsAdd() {
        return PREFIX + "tOrderLogistics_add.html";
    }

    /**
     * 跳转到查看小件物流订单
     */
    @RequestMapping("/tOrderLogistics_detail/{tOrderLogisticsId}")
    public String tOrderLogistics_detail(@PathVariable Integer tOrderLogisticsId, Model model) {
        Map<String,Object> tOrderLogistics = tOrderLogisticsService.getLogisticsOrderDetailById(tOrderLogisticsId);
        TTimeoutAppeal tTimeoutAppeal = timeoutAppealService.selectOne(new EntityWrapper<TTimeoutAppeal>().eq("orderId",tOrderLogistics.get("id")));
        if (ToolUtil.isNotEmpty(tTimeoutAppeal) && ToolUtil.isNotEmpty(tTimeoutAppeal.getReturnMoney())){
            tOrderLogistics.put("returnMoney",tTimeoutAppeal.getReturnMoney());
        }else {
            tOrderLogistics.put("returnMoney","0.00");
        }
        model.addAttribute("item",tOrderLogistics);
        return PREFIX + "tOrderLogistics_detail.html";
    }

    /**
     * 获取小件物流订单列表
     */
    @RequestMapping(value = "/list")
    @ResponseBody
    public Object list(String insertTime,
                       String orderNum,
                       Integer type,
                       Integer orderSource,
                       String userName,
                       String userPhone,
                       String recipient,
                       String recipientPhone,
                       String driver,
                       Integer state, String travelId) {
        String beginTime = null;
        String endTime = null;
        if (SinataUtil.isNotEmpty(insertTime)) {
            String[] timeArray = insertTime.split(" - ");
            beginTime = timeArray[0];
            endTime = timeArray[1];
        }
        Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
        page.setRecords(tOrderLogisticsService.getLogisticsOrderList(page, beginTime, endTime, ShiroKit.getUser().getRoleType(), ShiroKit.getUser().getObjectId(),
                orderNum, orderSource, type, userName, userPhone, recipient, recipientPhone, driver, state, travelId));
        return super.packForBT(page);
    }

    @Autowired
    private ITDriverService itDriverService;

    /**
     * 取消小件物流订单
     */
    @RequestMapping(value = "/cancel")
    @ResponseBody
    public Object cancel(@RequestParam Integer tOrderLogisticsId) {
        try {
            ShiroUser user = ShiroKit.getUser();
            TOrderLogistics tOrderLogistics = tOrderLogisticsService.selectById(tOrderLogisticsId);
            tOrderLogistics.setState(10);
    
            //已支付的情况下进行退款操作
            if (null != tOrderLogistics.getPayType() && null != tOrderLogistics.getPayMoney()) {
                if (tOrderLogistics.getPayType() == 3) {//余额支付
                    TUser tUser = userService.selectById(tOrderLogistics.getUserId());
                    tUser.setBalance(tUser.getBalance().add(tOrderLogistics.getPayMoney()));
                    userService.updateById(tUser);
                } else {
                    System.out.println("其他支付");
                    if(tOrderLogistics.getOrderSource()==4){
                        System.out.println("退司机");
                        TDriver driver = itDriverService.selectById(tOrderLogistics.getDriverId());
                        driver.setBalance(driver.getBalance().add(tOrderLogistics.getPayMoney()));
                        itDriverService.updateById(driver);
                    }else {
                        System.out.println("退用户");
//                        TUser tUser = userService.selectById(tOrderLogistics.getUserId());
//                        tUser.setBalance(tUser.getBalance().add(tOrderLogistics.getPayMoney()));
//                        userService.updateById(tUser);
//                        if(tOrderLogistics.getPayMoney().doubleValue()>0) {
//                            createAllocationReqUser(1, tUser.getId(), 1, tOrderLogistics.getPayMoney().doubleValue());
//                        }
                        List<PaymentRecord> querys = paymentRecordService.query_(1, tOrderLogistics.getUserId(), 1, tOrderLogistics.getId(), tOrderLogistics.getType(), tOrderLogistics.getPayType(), 2);
                        System.out.println(querys);
                        boolean b = false;
                        for (PaymentRecord query : querys) {
                            System.out.println("支付方式："+query.getPayType());
                            if(query.getPayType() == 1){//微信
                                Map<String, String> map = payMoneyUtil.wxRefund(query.getCode(), tOrderLogistics.getId() + "_" + tOrderLogistics.getType() + "_" + UUIDUtil.getRandomCode(5), query.getAmount().toString(), query.getAmount().toString(), "/base/cancleOrderWXPay");
                                System.out.println("map:"+map);
                                if(!"SUCCESS".equals(map.get("return_code"))){
                                    return ResultUtil.error(map.get("return_msg"));
                                }
                            }
                        }
                    }
                    List<PaymentRecord> paymentRecords = paymentRecordService.query(1, null, null, tOrderLogisticsId, tOrderLogistics.getType(), null, 2);
                    if (paymentRecords.size() == 0) {
                        return ResultUtil.error("订单还未进行支付");
                    }
                    boolean b = false;
                    for(PaymentRecord query : paymentRecords){
//                        Map<String, Object> merrefund = icbcPayUtil.merrefund(query.getCode(), "", query.getAmount(), tOrderLogistics.getId() + "_" + tOrderLogistics.getType(), tOrderLogistics.getOrderNum());
//                        if (Integer.valueOf(merrefund.get("code").toString()) == 0) {
//                            Map<String, Object> refundqry = icbcPayUtil.refundqry("", query.getCode(), tOrderLogistics.getOrderNum());
//                            if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 0) {//成功
//                                b = true;
//                            }
//                            if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 1) {//失败
//                                return ResultUtil.error("订单取消失败（退款不成功）");
//                            }
//                            if (Integer.valueOf(refundqry.get("code").toString()) == 0 && Integer.valueOf(refundqry.get("pay_status").toString()) == 2) {//未知
//                                return ResultUtil.error("退款返回未知异常");
//                            }
//                        }
                    }
                    if(b){
                        //添加交易明细

                    }
                }

                transactionDetailsService.saveData(tOrderLogistics.getUserId(), "小件订单取消退款", tOrderLogistics.getPayMoney().doubleValue(), 1, 1, 1, 4, tOrderLogistics.getId());

                //添加负的收入明细
                List<Income> incomes = incomeService.selectList(new EntityWrapper<Income>().eq("type", 2).eq("incomeId", tOrderLogistics.getId()).eq("orderType", tOrderLogistics.getType()));
                for(Income income : incomes){
                    if(income.getUserType() == 2){//处理司机的收入
                        TDriver driver = tDriverService.selectById(income.getObjectId());
                        driver.setBalance(driver.getBalance().subtract(new BigDecimal(income.getMoney())));
                        driver.setLaveBusinessMoney(new BigDecimal(driver.getLaveBusinessMoney()).subtract(new BigDecimal(income.getMoney())).doubleValue());
                        driver.setBusinessMoney(new BigDecimal(driver.getBusinessMoney()).subtract(new BigDecimal(income.getMoney())).doubleValue());
                        tDriverService.updateById(driver);
                    }
                    Income income1 = new Income();
                    BeanUtils.copyProperties(income, income1);
                    income1.setMoney(income.getMoney() * -1);
                    income1.setId(null);
                    income1.setInsertTime(new Date());
                    incomeService.insert(income1);
                }
            }
            tOrderLogisticsService.updateById(tOrderLogistics);

            //添加取消记录
            OrderCancel orderCancel = new OrderCancel();
            orderCancel.setOrderId(tOrderLogistics.getId());
            orderCancel.setOrderType(tOrderLogistics.getType());
            orderCancel.setReason("调度端取消订单");
            orderCancel.setRemark("调度“" + user.getName() + "-" + user.getId() + "”执行取消操作");
            orderCancel.setState(2);
            orderCancel.setInsertTime(new Date());
            orderCancel.setUserType(3);
            orderCancel.setUserId(user.getId());
            orderCancelMapper.insert(orderCancel);

            //增加推送
            Map<String,String> map = new HashMap<>();
            map.put("id", tOrderLogistics.getId().toString());
            map.put("orderType", tOrderLogistics.getType().toString());
            String result = HttpRequestUtil.postRequest(PushURL.cancel_order_url, map);
            System.out.println("小件物流取消:【orderId="+tOrderLogistics.getId().toString()+"】,调用接口:"+result);
        }catch (Exception e){
            e.printStackTrace();
        }

        return SUCCESS_TIP;
    }

    @Autowired
    private ITEnterpriseWithdrawalService tEnterpriseWithdrawalService;
    @Autowired
    private IUserWithdrawalService userWithdrawalService;


    /**
     * 删除小件物流订单
     */
    @RequestMapping(value = "/delete")
    @ResponseBody
    public Object delete(@RequestParam Integer tOrderLogisticsId) {
        TOrderLogistics tOrderLogistics = tOrderLogisticsService.selectById(tOrderLogisticsId);
        tOrderLogistics.setIsDelete(2);
        tOrderLogisticsService.updateById(tOrderLogistics);
        return SUCCESS_TIP;
    }


    /**
     * 修改收件人
     * @param id
     * @param name
     * @param phone
     * @return
     */
    @RequestMapping(value = "/updateRecipient")
    @ResponseBody
    public ResultUtil updateRecipient(Integer id, String name, String phone){
        try {
            TOrderLogistics tOrderLogistics = tOrderLogisticsService.selectById(id);
            if(ToolUtil.isNotEmpty(name)){
                tOrderLogistics.setRecipient(name);
            }
            if(ToolUtil.isNotEmpty(phone)){
                tOrderLogistics.setRecipientPhone(phone);
            }
            tOrderLogisticsService.updateById(tOrderLogistics);
            if(tOrderLogistics.getState() == 4 || tOrderLogistics.getState() == 6){
                Map<String,String> map = new HashMap<>();
                map.put("orderId", id.toString());
                String result = HttpRequestUtil.postRequest(PushURL.zull_user_url + "/driver/base/order/sendVerificationCode1", map);
            }
            return ResultUtil.success();
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr();
        }
    }

    /**
     * 取消订单微信退款成功回调
     * @param request
     * @param response
     */
//    @ResponseBody
//    @PostMapping("/base/cancleOrderWXPay")
//    public void cancleOrderWXPay(HttpServletRequest request, HttpServletResponse response){
//        try {
//            System.out.println("小件物流取消");
//            Map<String, String> map = payMoneyUtil.wxRefundCallback(request);
//            if(null != map){
//                String order_id = map.get("refund_id");
//                String out_refund_no = map.get("out_refund_no");
//                String result = map.get("result");
//                if(ToolUtil.isNotEmpty(out_refund_no) && ToolUtil.isNotEmpty(order_id)){
//                    PrintWriter out = response.getWriter();
//                    out.write(result);
//                    out.flush();
//                    out.close();
//
//                    String[] split = out_refund_no.split("_");
//                    Integer id = Integer.valueOf(split[0]);
//                    Integer type = Integer.valueOf(split[1]);
//                    System.out.println("取消回调："+type);
//                    switch (type){
//                        case 1:
//                            break;
//                        case 2:
//                            break;
//                        case 3:
//                            TOrderLogistics orderCrossCity = tOrderLogisticsService.selectById(id);
//                            PaymentRecord query = paymentRecordService.query_(1, orderCrossCity.getUserId(), 1, id, 3, orderCrossCity.getPayType(), 2);
//                            //添加交易明细
//                            transactionDetailsService.saveData(orderCrossCity.getUserId(), "跨城出行取消退款", query.getAmount(), 1, 1, 1, 3, id);
//                            break;
//                        case 4:
//                            TOrderLogistics orderLogistics1 = tOrderLogisticsService.selectById(id);
//                            PaymentRecord query1 = paymentRecordService.query_(1, orderLogistics1.getUserId(), 1, id, 4, orderLogistics1.getPayType(), 2);
//                            //添加交易明细
//                            transactionDetailsService.saveData(orderLogistics1.getUserId(), "同城小件物流取消退款", query1.getAmount(), 1, 1, 1, 4, id);
//                            UserCouponRecord userCouponRecord1 = userCouponRecordService.selectById(orderLogistics1.getCouponId());
//                            userCouponRecord1.setState(1);
//                            userCouponRecordService.updateById(userCouponRecord1);
//                            orderLogistics1.setCouponMoney(BigDecimal.ZERO);
//                            tOrderLogisticsService.updateById(orderLogistics1);
//                            break;
//                        case 5:
//                            TOrderLogistics orderLogistics2 = tOrderLogisticsService.selectById(id);
//                            PaymentRecord query2 = paymentRecordService.query_(1, orderLogistics2.getUserId(), 1, id, 5, orderLogistics2.getPayType(), 2);
//                            //添加交易明细
//                            transactionDetailsService.saveData(orderLogistics2.getUserId(), "跨城小件物流取消退款", query2.getAmount(), 1, 1, 1, 5, id);
//                            UserCouponRecord userCouponRecord2 = userCouponRecordService.selectById(orderLogistics2.getCouponId());
//                            userCouponRecord2.setState(1);
//                            userCouponRecordService.updateById(userCouponRecord2);
//                            orderLogistics2.setCouponMoney(BigDecimal.ZERO);
//                            tOrderLogisticsService.updateById(orderLogistics2);
//                            break;
//                    }
//                }
////                cloudPay(map.get("total_fee"),map.get("transaction_id"),1);
//            }
//        }catch (Exception e){
//            e.printStackTrace();
//        }
//    }

}