package com.mzl.flower.service.payment;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.mzl.flower.component.SequenceNo;
import com.mzl.flower.config.PyamentV3Configurer;
import com.mzl.flower.config.exception.ValidationException;
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.constant.Constants;
import com.mzl.flower.dto.request.payment.*;
import com.mzl.flower.dto.response.payment.*;
import com.mzl.flower.entity.customer.Customer;
import com.mzl.flower.entity.payment.*;
import com.mzl.flower.entity.system.User;
import com.mzl.flower.entity.system.UserWechat;
import com.mzl.flower.mapper.payment.*;
import com.mzl.flower.mapper.system.UserWechatMapper;
import com.mzl.flower.service.BaseService;
import com.mzl.flower.utils.UUIDGenerator;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Slf4j
@Service
@Transactional
public class OrderSalesService extends BaseService {

    @Autowired
    private OrderSalesMapper salesMapper;

    @Autowired
    private OrderSalesItemMapper salesItemMapper;

    @Autowired
    private SequenceNo sequenceNo;

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private OrderItemMapper orderItemMapper;

    @Autowired
    private UserWechatMapper wechatMapper;

    @Autowired
    private UserPaymentSybService paymentSybService;

    @Autowired
    private OrderRefundMapper orderRefundMapper;

    public String createSales(OrderSalesCreateDTO dto){
        List<String> orderItems = dto.getOrderItems();
        if(orderItems == null || orderItems.size() == 0){
            throw new ValidationException("商品列表不能为空");
        }

        //收货前可以申请售后，售后最多申请两次
        Order o = orderMapper.selectById(dto.getOrderId());
        String status = o.getStatus();
        if(!Constants.ORDER_STATUS.RECEIVE.name().equals(status)){
            throw new ValidationException("无法申请售后");
        }

        String userId = SecurityUtils.getUserId();
        int count = salesMapper.selectCount(new QueryWrapper<OrderSales>()
                .eq("create_by", userId).eq("order_id", dto.getOrderId()));
        if(count >= 2){
            throw new ValidationException("售后申请超过限额");
        }

        count = salesMapper.selectCount(new QueryWrapper<OrderSales>()
                .eq("create_by", userId)
                .eq("order_id", dto.getOrderId())
                .eq("status", Constants.SALES_STATUS.PENDING.name())
        );
        if(count > 0){
            throw new ValidationException("有未处理售后，无法申请");
        }

        OrderSales s = new OrderSales();
        s.setId(UUIDGenerator.getUUID());
        s.setOrderId(dto.getOrderId());
        s.setSalesNo(getSalesNo());
        s.setImages(toJSONString(dto.getImageList()));
        s.setVideos(toJSONString(dto.getVideoList()));
        s.setReason(dto.getReason());
        s.setStatus(Constants.SALES_STATUS.PENDING.name());
        s.create(userId);
        salesMapper.insert(s);

        for(String i : orderItems){
            OrderSalesItem si = new OrderSalesItem();
            si.setId(UUIDGenerator.getUUID());
            si.setOrderId(dto.getOrderId());
            si.setOrderItemId(i);
            si.setSalesId(s.getId());
            si.create(userId);
            salesItemMapper.insert(si);
        }

        return s.getId();
    }

    private String getSalesNo(){
        String seq  = sequenceNo.getSeqNo(SequenceNo.ORDER_SALES);
        return "SH" + format(LocalDateTime.now(), "yyyyMMdd") + seq;
    }

    public void cancelSales(String id){
        OrderSales s = salesMapper.selectById(id);
        String userId = SecurityUtils.getUserId();
        if(!userId.equals(s.getCreateBy())){
            throw new ValidationException("无权操作");
        }

        String status = s.getStatus();
        if(!Constants.SALES_STATUS.PENDING.name().equals(status)){
            throw new ValidationException("已处理完成不用取消");
        }

        s.setStatus(Constants.SALES_STATUS.CANCEL.name());
        s.update(userId);
        salesMapper.updateById(s);
    }

    public Page<OrderSalesListDTO> selectSalesList(Page page, OrderSalesQueryDTO dto){
        List<OrderSalesListDTO> ls = salesMapper.selectSalesList(page, dto);

        page.setRecords(ls);
        return page;
    }

    public OrderSalesDTO getSalesInfo(String id, Long supplierId){
        OrderSalesDTO rr = new OrderSalesDTO();
        OrderSales sl = salesMapper.selectById(id);
        BeanUtils.copyProperties(sl, rr);

        rr.setImageList(parseArray(sl.getImages(), String.class));
        rr.setVideoList(parseArray(sl.getVideos(), String.class));

        User user = userMapper.selectById(sl.getCreateBy());
        rr.setCreateName(user.getNickName());

        Order o = orderMapper.selectById(sl.getOrderId());
        rr.setOrderNo(o.getOrderNo());
        rr.setCustomer(o.getCustomer());
        rr.setCustomerTel(o.getCustomerTel());
        rr.setCustomerProvince(o.getCustomerProvince());
        rr.setCustomerCity(o.getCustomerCity());
        rr.setCustomerRegion(o.getCustomerRegion());
        rr.setCustomerAddress(o.getCustomerAddress());
        rr.setTotalOrderAmount(o.getTotalAmount());

        String transferId = sl.getTransferId();
        if(!StringUtils.isEmpty(transferId)){
            OrderRefund t = orderRefundMapper.selectById(transferId);
            rr.setTransferStatus(t == null ? "" : t.getStatus());
        }

        OrderSalesItemQueryDTO queryDTO = new OrderSalesItemQueryDTO();
        queryDTO.setSalesId(id);
        queryDTO.setSupplierId(supplierId);
        List<OrderItemSalesListDTO> result = salesItemMapper.selectSalesItemList(queryDTO);
        if(result != null && result.size() > 0){
            for(OrderItemSalesListDTO r : result){
                r.setChargePersonList(parseArray(r.getChargePersons(), OrderSalesItemChargeDTO.class));
            }
        }
        rr.setItems(result);

        return rr;
    }

    public void setSalesItemAmount(OrderSalesItemAmountDTO dto){
        OrderSalesItem item = salesItemMapper.selectById(dto.getId());
        BeanUtils.copyProperties(dto, item);

        item.setChargePersons(toJSONString(dto.getChargePersonList()));

        salesItemMapper.updateById(item);
    }

    public void doAudit(OrderSalesAuditDTO dto) throws Exception {
        OrderSales s = salesMapper.selectById(dto.getId());
        s.setAuditRemarks(dto.getAuditRemarks());
        s.setAuditStatus(dto.getAuditStatus());
        s.setStatus(Constants.SALES_STATUS.COMPLETED.name());
        s.setAuditTime(LocalDateTime.now());

        List<OrderSalesItemAmountDTO> items = dto.getItems();
        BigDecimal totalAmount = new BigDecimal(0);
        if(items != null && items.size() > 0){
            for(OrderSalesItemAmountDTO i : items){
                setSalesItemAmount(i);
                BigDecimal a = i.getAmount() == null ? new BigDecimal(0) : i.getAmount();
                totalAmount = totalAmount.add(a);
            }
        }

        s.setTotalAmount(totalAmount);

        if(Constants.SALES_AUDIT_STATUS.AGREE.name().equals(s.getAuditStatus())){
            if(totalAmount.doubleValue() > 0) {
                Order o = orderMapper.selectById(s.getOrderId());
                String transferId = paymentSybService.refundOrderSub(o, totalAmount);
                s.setTransferId(transferId);

                /*if(totalAmount.doubleValue() > o.getTotalAmount().doubleValue()){
                    throw new ValidationException("赔款金额不能大于订单金额");
                }

                String remarks = "售后理赔";
                String openId = o.getPayOpenid();

                List<TransferDetailReqDTO> details = new ArrayList<>();
                TransferDetailReqDTO dr = new TransferDetailReqDTO();
                dr.setAmount(totalAmount.multiply(new BigDecimal(100)).longValue());
                dr.setOpenId(openId);
                dr.setRemarks(remarks);
                if(totalAmount.doubleValue() >= 2000){
                    Customer p = customerMapper.selectOne(new QueryWrapper<Customer>()
                            .eq("user_id", s.getCreateBy()));
                    dr.setUserName(p.getName());
                }
                details.add(dr);

                TransferReqDTO transferReqDTO = new TransferReqDTO();
                transferReqDTO.setDetails(details);
                transferReqDTO.setAppId(PyamentV3Configurer.customer_app_id);
                transferReqDTO.setName(s.getSalesNo());
                transferReqDTO.setRemarks(remarks);

                String transferId = paymentV3Service.doBatchTransfer(transferReqDTO, SecurityUtils.getUserId()); //发起转账
                s.setTransferId(transferId);*/
            }
        }

        s.update(SecurityUtils.getUserId());
        salesMapper.updateById(s);
    }
}