package com.gk.firework.Scheduls.Task;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.gk.firework.Config.WebSocket.WebSocketServer;
import com.gk.firework.Domain.Enterprise;
import com.gk.firework.Domain.EnterpriseLicense;
import com.gk.firework.Domain.EnterprisePerson;
import com.gk.firework.Domain.Enum.EnterpriseSafetySupervision;
import com.gk.firework.Domain.Enum.MsgContentType;
import com.gk.firework.Domain.Enum.MsgType;
import com.gk.firework.Domain.Enum.PersonnelCategory;
import com.gk.firework.Domain.UserInfo;
import com.gk.firework.Domain.Utils.Message;
import com.gk.firework.Domain.Utils.SpringBeanUtil;
import com.gk.firework.Domain.Utils.StringUtils;
import com.gk.firework.Service.EnterpriseLicenseService;
import com.gk.firework.Service.EnterprisePersonService;
import com.gk.firework.Service.EnterpriseService;
import lombok.SneakyThrows;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

import javax.websocket.Session;
import java.util.ArrayList;
import java.util.Date;

@Component("task")
@Scope("prototype")
public class CheckEnterpriseTask implements Runnable{

    final static Logger logger= LoggerFactory.getLogger(CheckEnterpriseTask.class);

    private UserInfo userInfo;


    public CheckEnterpriseTask(UserInfo userInfo) {
        this.userInfo = userInfo;
    }

    @SneakyThrows
    @Override
    public void run() {
        String companynumber = userInfo.getCompanynumber();
        Long companyid = userInfo.getCompanyid();
        //普通企业
        if (StringUtils.isNotBlank(companynumber)) {
            logger.info("正在执行：检查企业信息是否完善");
            Enterprise enterprise = SpringBeanUtil.getBean(EnterpriseService.class).selectEnterpriseByNumber(companynumber);
            Message message = new Message(MsgType.NOTIFICATION,MsgContentType.INFO_UNDONE,Boolean.FALSE);
            ArrayList<String> msgs = new ArrayList<>();
            if (!checkEnterprise(enterprise)) msgs.add("企业相关信息还未完善");
            if (!checkEnterpriseLicense(companyid)) msgs.add("许可证信息还未完善");
            if (!checkSafetyPerson(companyid)) msgs.add("安全人员信息还未完善");
            //长期店、短期店不用特种人员
            if (!checkSpecialPerson(companyid)
                    && (enterprise.getSafetysupervision().equals(EnterpriseSafetySupervision.PRODUCE)
                    || enterprise.getSafetysupervision().equals(EnterpriseSafetySupervision.WHOLESALER))
            ) msgs.add("特种人员信息还未完善");
            if (msgs.size() > 0){
                message.setMessage(msgs.toString());
                WebSocketServer.sendMessage(userInfo.getId(), JSONObject.toJSONString(message));
            }

            //检查许可证过期
            logger.info("正在执行：检查企业许可证是否过期");
            if (enterprise.getValidendtime().before(new Date())) {
                Message message2 = new Message(MsgType.NOTIFICATION,MsgContentType.LICENSE_EXPIRED,Boolean.FALSE);
                message2.setMessage("您的许可证已到期，请重新录入许可证期限并上传许可证");
                WebSocketServer.sendMessage(userInfo.getId(), JSONObject.toJSONString(message2));
            }
        }
        //监管部门
        if (StringUtils.isBlank(companynumber)) {
            //查找管辖的所有企业的信息未完善的
            logger.info("正在执行：检查企业信息未完善个数");
            int undoneEnterprise = SpringBeanUtil.getBean(EnterpriseService.class).countAllUndoneEnterprise(userInfo);
            if (undoneEnterprise > 0) {
                Message message = new Message(MsgType.NOTIFICATION, MsgContentType.INFO_UNDONE, Boolean.TRUE);
                message.setMessage(String.format("共有%d个企业未完善企业相关信息",undoneEnterprise));
                WebSocketServer.sendMessage(userInfo.getId(), JSONObject.toJSONString(message));
            }

            logger.info("正在执行：检查所有许可证过期企业");
            int expiredEnterprise = SpringBeanUtil.getBean(EnterpriseService.class).countAllEnterpriseExpired(userInfo);
            if (expiredEnterprise > 0) {
                Message message = new Message(MsgType.NOTIFICATION, MsgContentType.LICENSE_EXPIRED, Boolean.TRUE);
                message.setMessage(String.format("共有%d个企业许可证已过期",expiredEnterprise));
                WebSocketServer.sendMessage(userInfo.getId(), JSONObject.toJSONString(message));
            }

        }
        logger.info("结束执行");

    }

    //检查企业信息完整
    private boolean checkEnterprise(Enterprise enterprise) {
        boolean flag = true;
        //小提示
        if (StringUtils.isBlank(enterprise.getOfficeaddress())) {
            flag = false;
        }
        return flag;
    }

    //检查许可证 有无
    private boolean checkEnterpriseLicense(Long enterpriseid) {
        LambdaQueryWrapper<EnterpriseLicense> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(EnterpriseLicense::getEnterpriseid, enterpriseid)
                .eq(EnterpriseLicense::getValidflag, true);
        int count = SpringBeanUtil.getBean(EnterpriseLicenseService.class).count(queryWrapper);
        return count != 0;
    }


    //检查安全人员
    private boolean checkSafetyPerson(Long enterpriseid) {
        LambdaQueryWrapper<EnterprisePerson> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(EnterprisePerson::getEnterpriseid, enterpriseid)
                .eq(EnterprisePerson::getValidflag, true)
                .eq(EnterprisePerson::getType, PersonnelCategory.SECURITY);
        int count = SpringBeanUtil.getBean(EnterprisePersonService.class).count(queryWrapper);
        return count != 0;
    }

    //检查特种人员
    private boolean checkSpecialPerson(Long enterpriseid) {
        LambdaQueryWrapper<EnterprisePerson> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(EnterprisePerson::getEnterpriseid, enterpriseid)
                .eq(EnterprisePerson::getValidflag, true)
                .eq(EnterprisePerson::getType, PersonnelCategory.SPECIAL);
        int count = SpringBeanUtil.getBean(EnterprisePersonService.class).count(queryWrapper);
        return count != 0;
    }





}