package com.xzx.gc.order.service;

import cn.hutool.core.codec.Base64;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.DateUtils;
import com.xzx.gc.common.utils.IdUtils;
import com.xzx.gc.common.utils.StringUtils;
import com.xzx.gc.entity.CityPartner;
import com.xzx.gc.entity.OrderComplaint;
import com.xzx.gc.entity.OrderInfo;
import com.xzx.gc.entity.OtherUserInfo;
import com.xzx.gc.model.admin.*;
import com.xzx.gc.order.dto.ComplaintFindDto;
import com.xzx.gc.order.dto.ComplaintFindResDto;
import com.xzx.gc.order.mapper.AccountMapper;
import com.xzx.gc.order.mapper.OrderComplaintMapper;
import com.xzx.gc.order.mapper.OrderMapper;
import com.xzx.gc.util.DoubleUtil;
import com.xzx.gc.util.SessionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;

@Service
@Transactional
public class OrderComplaintService {
    @Autowired
    SessionUtil platformService;
    @Autowired
    private CityPartnerService cityPartnerService;
    @Autowired
    private BusinessUtil businessUtil;
    @Autowired
    private OrderService  orderService;
    @Autowired
    private PayInfoService  payInfoService;
    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private OrderComplaintMapper orderComplaintMapper;
    @Autowired
    private AccountMapper accountMapper;
    @Autowired
    private OtherUserService otherUserService;
    @Autowired
    private IdUtils idUtils;
    public int add(OrderComplaint orderComplaint) {
        if(StringUtils.isNotBlank(orderComplaint.getComplaintReason())){
            orderComplaint.setComplaintReason(Base64.encode(orderComplaint.getComplaintReason()));
        }
        return orderComplaintMapper.insertSelective(orderComplaint);
    }



    public List<ComplaintFindResDto> find(ComplaintFindDto complaintFindDto) {
        List<ComplaintFindResDto> complaintFindResDtos = orderComplaintMapper.find(complaintFindDto);
        if(CollUtil.isNotEmpty(complaintFindResDtos)){
            for (ComplaintFindResDto complaintFindResDto : complaintFindResDtos) {
                String receiver = complaintFindResDto.getReceiver();
                OtherUserInfo byId = otherUserService.findById(receiver);
                if(byId!=null){
                    complaintFindResDto.setReceiverName(byId.getName());
                }else {
                    if(StrUtil.isNotBlank(complaintFindResDto.getReceiverName())){
                        complaintFindResDto.setReceiverName(Base64.decodeStr(complaintFindResDto.getReceiverName()));
                    }
                }
            }
        }
        return complaintFindResDtos;
    }

    public List<ComplaintFindResDto> detail(String orderId) {
        List<ComplaintFindResDto> complaintFindResDtos = orderComplaintMapper.detail(orderId);
        if(CollUtil.isNotEmpty(complaintFindResDtos)){
            for (ComplaintFindResDto complaintFindResDto : complaintFindResDtos) {
                String receiver = complaintFindResDto.getReceiver();
                OtherUserInfo byId = otherUserService.findById(receiver);
                if(byId!=null){
                    complaintFindResDto.setReceiverName(byId.getName());
                }else {
                    if(StrUtil.isNotBlank(complaintFindResDto.getReceiverName())){
                        complaintFindResDto.setReceiverName(Base64.decodeStr(complaintFindResDto.getReceiverName()));
                    }
                }
            }
        }
        return complaintFindResDtos;
    }




    /**
     * 根据条件查询投诉列表
     * @param model
     * @return
     */
    public Map<String, Object> queryComplaintApiList(XzxOrderComplaintModel model) {
        String afterSaleFlag = model.getAfterSaleFlag();
        String startTime = model.getStartTime();
        String endTime = model.getEndTime();
        //int p = (model.getPage() - 1) * model.getLimit();
        Map<String, Object> m = new HashMap<>();
        String[] x = null;
        if (!org.apache.commons.lang3.StringUtils.isEmpty(afterSaleFlag)) {
            if (afterSaleFlag.equals("1")) {
                //完成包含 1 未处理 2 取消订单 3重新派单
                afterSaleFlag = "1,2,3";
            }
            x = afterSaleFlag.split(",");
        }
        if (null != startTime && !"".equals(startTime)) {
            startTime = startTime + " 00:00:00";
        }
        if (null != endTime && !"".equals(endTime)) {
            endTime = endTime + " 23:59:59";
        }
        List<String> partnerIds = new ArrayList<>();
        if(null!=model.getPartnerId()&&!"".equals(model.getPartnerId())){
            partnerIds.add(model.getPartnerId());
        }else{
            partnerIds = cityPartnerService.queryPartnerByCurrent();
        }
        PageHelper.startPage(model.getPage(),model.getLimit());
        List<XzxOrderComplaintModel> list =orderComplaintMapper.queryComplaintApiList(x, startTime, endTime, model.getOrderId(),model.getUserPhone(),model.getCollectorName(),model.getCollectorPhone(),partnerIds);
        PageInfo<XzxOrderComplaintModel> pageInfo=new PageInfo<>(list);

        for (XzxOrderComplaintModel orderModel:list) {
            if(orderModel.getNickName()!=null&&!"".equals(orderModel.getNickName())){
                String nickName ="";
                nickName =Base64.decodeStr(orderModel.getNickName());
                orderModel.setNickName(nickName);
            }
            if(orderModel.getComplaintReason()!=null&&!"".equals(orderModel.getComplaintReason())){
                String complaintReason ="";
                complaintReason = Base64.decodeStr(orderModel.getComplaintReason());
                orderModel.setComplaintReason(complaintReason);
            }

        }
        m.put("data", list);
        m.put("count",pageInfo.getTotal());
        m.put("code", 0);
        return m;
    }

    /**
     * 根据ID更新投诉单状态
     * @param model
     */
    public int updateComplaintFlagApi(XzxOrderComplaintModel model){
        // OrderManageService为2是取消订单，需要更新订单状态为6
        if(model.getAfterSaleFlag().equals("2")){
            orderMapper.updateOrderStatus(model.getOrderId(), null, "6");
        }
        return orderComplaintMapper.updateComplaintFlagApi(model.getId().toString(), model.getComplaintPlan(), model.getAfterSaleFlag());
    }



    public PageInfo<ComplaintModel> queryComplaintList(ComplaintModel model) {
        if(null!=model.getStartTime()&&!"".equals(model.getStartTime())){
            model.setStartTime(DateUtils.changeTimeBigin(model.getStartTime()));
        }
        if(null!=model.getEndTime()&&!"".equals(model.getEndTime())){
            model.setEndTime(DateUtils.changeTimeEnd(model.getEndTime()));
        }
        PageHelper.startPage(model.getPage(),model.getLimit());
        List<ComplaintModel> list = orderComplaintMapper.queryAdminComplaintList(model);
        for (ComplaintModel cModel:list) {
            if(StrUtil.isNotBlank(cModel.getMoney())) {
                cModel.setMoney(businessUtil.changeMoney(cModel.getMoney()));
            }
            if(StrUtil.isNotBlank(cModel.getWeight())) {
                cModel.setWeight(businessUtil.changeWeight(cModel.getWeight()));
            }
            String partnerId = cModel.getPartnerId();
            if(null!=partnerId&&!"".equals(partnerId)){
                CityPartner partner = cityPartnerService.queryById(Long.parseLong(partnerId));
                cModel.setPartnerName(partner.getPartnerName());
            }
        }
        PageInfo<ComplaintModel> pageInfo=new PageInfo<>(list);
        return pageInfo;
    }

    private void insertUserAccountLog(String userId,BigDecimal money,String type,String payOrderId,String userType){
        UserAccountModel userAccountModel = cityPartnerService.queryPartnerAccountByUserId(userId);
        if(userType.equals("1")){
            cityPartnerService.insertAccountLogByPartner(userAccountModel,type,money,payOrderId);

        }else{
            cityPartnerService.insertAccountLogByHsy(userAccountModel,type,money,payOrderId);

        }
        if(type.equals("16")){

        }else{
            PayInfoModel payInfoModel = new PayInfoModel();
            payInfoModel.setPayOrderId(payOrderId);
            payInfoModel.setCreateUserId(userId);
            payInfoModel.setMoney(DoubleUtil.roundTwo(money.toString()));
            payInfoModel.setAccountId(userAccountModel.getAccountId());
            payInfoModel.setStatus("3");
            payInfoModel.setPayTime(DateUtil.now());
            payInfoService.addPayInfo(payInfoModel);
        }

    }
    public String updateComplaintMoney(ComplaintModel model) {
        String orderMoney = orderService.queryMoneyByOrderId(model.getOrderId());
        OrderInfo order = orderService.findById(model.getOrderId());
        BigDecimal totalMoney = new BigDecimal(orderMoney);
        BigDecimal money= new BigDecimal("0");
        if(model.getType().equals("1")){
            money = totalMoney.multiply(new BigDecimal("0.1"));
        }else{
            money = totalMoney.multiply(new BigDecimal("0.05"));
        }
        String payOrderId=idUtils.generate("ZF",0);
        String partnerId="";
        String userId = order.getCreateUserId();
        if(model.getWithholdingAgent().equals("1")){
            //扣合伙人
            partnerId = cityPartnerService.queryPidByTownId(model.getOrderId());
            CityPartner partner = cityPartnerService.queryPartnerById(Long.parseLong(partnerId));
            if(null!=partner){
                PartnerAccountModel partnerAccount = cityPartnerService.queryAccountIdByUserId(partner.getUserId());
                BigDecimal hbb = new BigDecimal(partnerAccount.getHbb());
                BigDecimal fl = hbb.subtract(money);
                if(fl.compareTo(BigDecimal.ZERO)==-1){
                    return "合伙人账户余额不足，无法扣款!";
                }else{
                    insertUserAccountLog(order.getCreateUserId(),money,"16",payOrderId,"1");
                    cityPartnerService.insertPartnerLogByPartner(partnerAccount,"13",DoubleUtil.roundTwo(money.toString()),payOrderId,partner,DoubleUtil.roundTwo(fl.toString()));
                    partnerAccount.setHbb(DoubleUtil.roundTwo(fl.toString()));
                    cityPartnerService.updatePartnerAccount(partnerAccount);
                }
            }else{
                return "合伙人缺失账户！";
            }
        }else{
            //扣骑手
            UserAccountModel userAccountModel = cityPartnerService.queryPartnerAccountByUserId(order.getReceiver());
            if(null!=userAccountModel){
                BigDecimal hbb = new BigDecimal(userAccountModel.getMoney());
                BigDecimal fl = hbb.subtract(money);
                if(fl.compareTo(BigDecimal.ZERO)==-1){
                    return "骑手账户余额不足，无法扣款!";
                }else{
                    insertUserAccountLog(order.getCreateUserId(),money,"16",payOrderId,"1");
                    insertUserAccountLog(order.getReceiver(),money,"16",payOrderId,"2");
                    UserAccountModel recAccount = accountMapper.getAccountByUserId(order.getReceiver());
                    BigDecimal oldAccMoney = new BigDecimal(recAccount.getMoney());
                    BigDecimal newAccMoney =oldAccMoney.subtract(money);
                    updateComplanitUserMoney(order.getReceiver(),DoubleUtil.roundTwo(newAccMoney.toString()));

                }
            }else{
                return "没有该骑手账号！";
            }
        }
        UserAccountModel accountModel = accountMapper.getAccountByUserId(userId);
        BigDecimal oldMoney = new BigDecimal(accountModel.getMoney());
        BigDecimal newMoney =oldMoney.add(money);
        updateComplanitUserMoney(userId,DoubleUtil.roundTwo(newMoney.toString()));
        OrderComplaint orderComplaint = new OrderComplaint();
        orderComplaint.setOrderId(order.getOrderId());
        List<OrderComplaint> oldList = orderComplaintMapper.select(orderComplaint);
        if(null!=oldList&&oldList.size()>0){
            for (OrderComplaint old:oldList) {
                old.setAfterSaleFlag(1);
                orderComplaintMapper.updateByPrimaryKey(old);
            }
        }else{
            orderComplaint.setAfterSaleFlag(1);
            orderComplaint.setDelFlag(0);
            orderComplaint.setCreateTime(DateUtil.now());
            orderComplaint.setPartnerId(partnerId);
            orderComplaint.setComplaintPlan("平台处理");
            orderComplaint.setComplaintType(5);
            orderComplaintMapper.insert(orderComplaint);
        }


        return null;
    }

    public void updateByPrimaryKeySelective(OrderComplaint orderComplaint) {
        orderComplaintMapper.updateByPrimaryKeySelective(orderComplaint);
    }

    public void updateComplanitUserMoney(String userId,String newMoney){
        UserAccountModel uaccount = new UserAccountModel();
        uaccount.setUserId(userId);
        uaccount.setMoney(Double.parseDouble(newMoney));
        cityPartnerService.updateAccountPartner(uaccount);
    }

    public int queryByOrderNoCount(String orderId) {
       return  orderComplaintMapper.queryByOrderNoCount(orderId);
    }

}