package com.supersavedriving.user.modular.system.util;


import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.supersavedriving.user.modular.system.model.*;
import com.supersavedriving.user.modular.system.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Date;
import java.util.List;
import java.util.Objects;


/**
 * 定时任务工具类
 */
@Component
public class TaskUtil {

    @Autowired
    private IUserToCouponService userToCouponService;
    @Resource
    private ICompanyFundFlowService companyFundFlowService;

    @Autowired
    private IBranchOfficeService branchOfficeService;
    @Autowired
    private IDriverService driverService;
    @Autowired
    private ISystemConfigService systemConfigService;
    @Autowired
    private IAccountChangeDetailService accountChangeDetailService;
    @Autowired
    private IRevenueService revenueService;
    /**
     * 每隔一分钟去处理的定时任务
     */
    @Scheduled(fixedRate = 1000 * 60)
    public void taskMinute(){
        try {

        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    /**
     * 每天的凌晨执行的任务
     */
    @Scheduled(cron = "0 0 0 * * *")
    public void taskDay(){
        try {
            userToCouponService.delUserCoupon();
        }catch (Exception e){
            e.printStackTrace();
        }
    }


    /**
     * 每月1日凌晨执行的任务
     */
    @Scheduled(cron = "0 0 0 1 * *")
    public void taskMonth1(){
        try {
            List<Driver> drivers = driverService.selectList(new EntityWrapper<Driver>().eq("status", 1));
            for (Driver driver : drivers) {
                SystemConfig systemConfig3= systemConfigService.selectOne(new EntityWrapper<SystemConfig>().eq("type", 3)
                        .eq("companyType",1)
                        .eq("companyId",1)
                        .eq("branchOfficeId",driver.getBranchOfficeId())
                        .last("LIMIT 1"));
                if(Objects.isNull(systemConfig3)){
                    continue;
                }
                JSONObject jsonObject3 = JSON.parseObject(systemConfig3.getContent());
                // 按单分佣
                Double nu2 = jsonObject3.getDouble("num2");
                Double nu4 = jsonObject3.getDouble("num4");
                //处理平台抽佣
                if(Objects.nonNull(nu2) && nu2 > 0 && nu4 == 1){
                    //先平台抽佣
//                        num4_ = (num3 >= num4_ ? num4_ : num3);
                    Revenue revenue = new Revenue();
                    revenue.setType(2);
                    revenue.setUserType(4);
                    revenue.setUserId(1);
//                    revenue.setOrderId(order.getId());
                    revenue.setAmount(nu2);
                    revenue.setCreateTime(new Date());
                    revenueService.insert(revenue);
                    Double balance = revenueService.queryCompanyBalance();
                    //记录企业流水
                    CompanyFundFlow companyFundFlow = new CompanyFundFlow();
                    companyFundFlow.setType(3);
                    companyFundFlow.setObjectType(1);
                    companyFundFlow.setObjectId(null);
                    companyFundFlow.setBalance(new BigDecimal(balance));
                    companyFundFlow.setMoney(new BigDecimal(nu2));
                    companyFundFlow.setCreateTime(new Date());
                    companyFundFlowService.insert(companyFundFlow);

                }
                SystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<SystemConfig>().eq("type", 3)
                        .eq("companyType",2)
                        .eq("companyId",driver.getBranchOfficeId())
                        .last("LIMIT 1"));
                if(Objects.nonNull(systemConfig)){
                    JSONObject jsonObject = JSON.parseObject(systemConfig.getContent());
                    Double num2 = jsonObject.getDouble("num2");
                    Double num4 = jsonObject.getDouble("num4");
                    //分公司分佣
                    if(Objects.nonNull(num2) && num2 > 0 && num4 == 1){
                        Revenue revenue = new Revenue();
                        revenue.setType(2);
                        revenue.setUserType(5);
                        revenue.setUserId(driver.getBranchOfficeId());
//                        revenue.setOrderId(order.getId());
                        revenue.setAmount(num2);
                        revenue.setCreateTime(new Date());
                        revenueService.insert(revenue);
                        Double balance = revenueService.queryBranchOfficeBalance(driver.getAgentId());

                        //记录企业流水
                        CompanyFundFlow companyFundFlow = new CompanyFundFlow();
                        companyFundFlow.setType(3);
                        companyFundFlow.setObjectType(3);
                        companyFundFlow.setObjectId(driver.getBranchOfficeId());
                        companyFundFlow.setBalance(new BigDecimal(balance));
                        companyFundFlow.setMoney(new BigDecimal(num2));
                        companyFundFlow.setCreateTime(new Date());
                        companyFundFlowService.insert(companyFundFlow);

                        Driver driver1 = driverService.selectById(driver.getId());

                        if (driver1.getVipEndDate()==null||new Date().after(driver1.getVipEndDate())) {
                            AccountChangeDetail accountChangeDetail = new AccountChangeDetail();
                            accountChangeDetail.setCode(System.currentTimeMillis() + UUIDUtil.getNumberRandom(5));
                            accountChangeDetail.setUserType(2);
                            accountChangeDetail.setUserId(driver.getId());
                            accountChangeDetail.setType(1);
                            accountChangeDetail.setChangeType(9);
                            accountChangeDetail.setOldData(new BigDecimal(driver.getBalance()).add(new BigDecimal(driver.getBackgroundBalance())).setScale(2, RoundingMode.HALF_EVEN).doubleValue());
                            driver.setBalance(driver.getBalance() - num2);
                            accountChangeDetail.setNewData(new BigDecimal(driver.getBalance()).add(new BigDecimal(driver.getBackgroundBalance())).setScale(2, RoundingMode.HALF_EVEN).doubleValue());
                            accountChangeDetail.setExplain("分公司抽成");
                            accountChangeDetail.setCreateTime(new Date());
                            accountChangeDetailService.insert(accountChangeDetail);
                            driverService.updateById(driver);
                        }
                    }
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }


    /**
     * 每月16日凌晨执行的任务
     */
    @Scheduled(cron = "0 0 0 16 * *")
    public void taskMonth16(){
        try {
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}