package com.gk.firework.Scheduls.WarningTask;


import com.gk.firework.Domain.StockInfo;
import com.gk.firework.Domain.WarnContentInfo;
import com.gk.firework.Domain.WarningInfo;
import com.gk.firework.Service.SaleOrderService;
import com.gk.firework.Service.StockService;
import com.gk.firework.Service.WarnContentService;
import com.gk.firework.Service.WarningService;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;

import java.io.UnsupportedEncodingException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

@Configuration
@EnableScheduling
@ConditionalOnProperty(prefix = "scheduling",name = "enabled",havingValue = "true")
public class StockWarnTask {
    private Logger logger = LogManager.getLogger(StockWarnTask.class);
    private static final String warnType = "库存超量";

    @Autowired
    WarningService warningService;
    @Autowired
    SaleOrderService saleOrderService;
    @Autowired
    WarnContentService warnContentService;
    @Autowired
    StockService stockService;

//    @Scheduled(cron = "0/20 * * * * ?") //每隔5秒执行一次
    @Scheduled(cron = "0 0 2 * * ?") //每天凌晨两点执行一次
    private void purchaseWarn() throws Exception{
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        try {
            List<WarningInfo> warningInfos = warningService.selectByType(warnType);
            if (warningInfos.size() > 0){
                for (WarningInfo warningInfo : warningInfos){
                    insertWarnContent(warningInfo);
                }
            }
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void insertWarnContent(WarningInfo warningInfo) {
        Integer min = warningInfo.getMinimum();
        Integer max = warningInfo.getMaximum();
        List<Integer> slices = new ArrayList<>();
        for (int i = 1; i < 21; i++){
            slices.add(i);
        }
        //超过预警值
        List<StockInfo> earlyWarnList = stockService.selectEarlyWarn(min,max,warningInfo.getEnterprisetype(),slices);
        if (earlyWarnList.size() > 0){
            List<WarnContentInfo> warnContentInfos = new ArrayList<>();
            for (StockInfo stockInfo : earlyWarnList) {
                String warncontent = "超出库存限制,当前库存总数为"+stockInfo.getNum();
                WarnContentInfo warnContentExist = warnContentService.selectByEnterpriseWarn(warnType,"预警",Long.parseLong(stockInfo.getOwner()),warncontent);
                if (warnContentExist == null) {
                    WarnContentInfo warnContentInfo = new WarnContentInfo();
                    warnContentInfo.setWarntype(warnType);
                    warnContentInfo.setWarnlevel("预警");
                    warnContentInfo.setEnterpriseid(Long.parseLong(stockInfo.getOwner()));
                    warnContentInfo.setWarncontent(warncontent);
                    warnContentInfo.setIsmend((byte) 0);
                    warnContentInfo.setIsneed((byte) 0);
                    warnContentInfo.setIssend((byte) 0);
                    warnContentInfo.setModifiedby("系统生成");
                    warnContentInfo.setModifieddate(new Date());
                    warnContentInfo.setCreateddate(new Date());

                    if (warnContentInfos.size() > 0){
                        boolean isfound = false;
                        for (WarnContentInfo warnContent : warnContentInfos){
                            if (warnContent.getEnterpriseid().equals(warnContentInfo.getEnterpriseid())
                                    && warnContent.getWarncontent().equals(warnContentInfo.getWarncontent())){
                                isfound = true;
                                break;
                            }
                        }
                        if (!isfound){
                            warnContentInfos.add(warnContentInfo);
                        }
                    }else {
                        warnContentInfos.add(warnContentInfo);
                    }
                }
            }
            warnContentService.saveBatch(warnContentInfos);
        }
        //超过报警值
        List<StockInfo> alarmList = stockService.selectAlarm(max,warningInfo.getEnterprisetype(),slices);
        if (alarmList.size() > 0){
            List<WarnContentInfo> warnContentInfos = new ArrayList<>();
            Byte issms = warningInfo.getIssms();
            for (StockInfo stockInfo : alarmList) {
                String warncontent = "超出库存限制,当前库存总数为"+stockInfo.getNum();
                WarnContentInfo warnContentExist = warnContentService.selectByEnterpriseWarn(warnType,"报警",Long.parseLong(stockInfo.getOwner()),warncontent);
                if (warnContentExist == null) {
                    WarnContentInfo warnContentInfo = new WarnContentInfo();
                    warnContentInfo.setWarntype(warnType);
                    warnContentInfo.setWarnlevel("报警");
                    warnContentInfo.setEnterpriseid(Long.parseLong(stockInfo.getOwner()));
                    warnContentInfo.setWarncontent(warncontent);
                    warnContentInfo.setIsmend((byte) 0);
                    warnContentInfo.setIsneed(issms);
                    warnContentInfo.setIssend((byte) 0);
                    warnContentInfo.setModifiedby("系统生成");
                    warnContentInfo.setModifieddate(new Date());
                    warnContentInfo.setCreateddate(new Date());

                    if (warnContentInfos.size() > 0){
                        boolean isfound = false;
                        for (WarnContentInfo warnContent : warnContentInfos){
                            if (warnContent.getEnterpriseid().equals(warnContentInfo.getEnterpriseid())
                                    && warnContent.getWarncontent().equals(warnContentInfo.getWarncontent())){
                                isfound = true;
                                break;
                            }
                        }
                        if (!isfound){
                            warnContentInfos.add(warnContentInfo);
                        }
                    }else {
                        warnContentInfos.add(warnContentInfo);
                    }
                }
            }
            warnContentService.saveBatch(warnContentInfos);
        }
    }



}