package com.hxzk.util;

import com.hxzk.deo.TbWarning;
import com.hxzk.pojo.TbSmsLog;
import com.hxzk.pojo.TbSmsReminder;
import com.hxzk.pojo.WarnTongji;
import com.hxzk.service.SmsLogService;
import com.hxzk.service.TbSmsReminderService;
import com.hxzk.service.WarnTongJiService;
import com.hxzk.service.WarningService;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.profile.HttpProfile;
import com.tencentcloudapi.sms.v20210111.SmsClient;
import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
import org.springframework.stereotype.Component;

import java.lang.ref.PhantomReference;
import java.sql.SQLOutput;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Random;

@Component
public class MyThreadTask implements Runnable {
    private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
    private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
    private WarningService warningService;
    private TbSmsReminderService smsReminderService;

    private SmsLogService smsLogService;
    private WarnTongJiService warnTongJiService;

    private Integer thr = 5000;
    private Integer csSMS = 0;
    private Integer csOnline = 0;
    private Integer CSOnlineSMS=0;//引擎上线告知
    public MyThreadTask(WarningService warningService,TbSmsReminderService smsReminderService,SmsLogService smsLogService,WarnTongJiService warnTongJiService) {
        this.warningService = warningService;
        this.smsReminderService = smsReminderService;
        this.smsLogService = smsLogService;
        this.warnTongJiService = warnTongJiService;

    }
    @Override
    public void run() {
        try {
            while (true) {
                //获取当前定义的短信提示类型
                List<TbSmsReminder> smsReminders = smsReminderService.findAllSMSReminder();
                List<Integer> ids = new ArrayList<>();
                //循环短信提示(根据类型)查找需要发送短信的告警
                for (int i = 0 ; i< smsReminders.size();i++){
                    String type = smsReminders.get(i).getSmstype();
                    if (type.equals("引擎异常")){
                        //根据现在系统时间查询Warning_TongJi时间
                        List<WarnTongji> warnTongjis = warnTongJiService.findWarnTongJi();
                        long time = GetTimeChaMiao(gettime(),warnTongjis.get(0).getAddtime());  //此方法计算时间差
                        if (time <= -90L){
                            csOnline = 1; //cs离线
                            CSOnlineSMS = 0;
                            if (csSMS == 0 && csOnline ==1){
                                smsRemin(smsReminders.get(i).getPhone(),smsReminders.get(i).getMsg());
                                TbSmsLog tbSmsLog = new TbSmsLog();
                                tbSmsLog.setAddtime(gettime());
                                tbSmsLog.setType(type);
                                tbSmsLog.setPhone(smsReminders.get(i).getPhone());
                                tbSmsLog.setMsg(smsReminders.get(i).getMsg());
                                tbSmsLog.setName(smsReminders.get(i).getName());
                                tbSmsLog.setBumen(smsReminders.get(i).getBumen());
                                smsLogService.addSMSLog(tbSmsLog);
                                csSMS = 1;
                                //发送之后修改短信状态为已发送
                                System.out.println("引擎报告异常成功");
                            }
                            thr = 60000;

                        }else{
                            if (CSOnlineSMS == 0){
                                //发送短信
                                smsRemin(smsReminders.get(i).getPhone(),"通知：引擎已经上线");
                                TbSmsLog tbSmsLog = new TbSmsLog();
                                tbSmsLog.setAddtime(gettime());
                                tbSmsLog.setType(type);
                                tbSmsLog.setPhone(smsReminders.get(i).getPhone());
                                tbSmsLog.setMsg("通知：引擎已经上线");
                                tbSmsLog.setName(smsReminders.get(i).getName());
                                tbSmsLog.setBumen(smsReminders.get(i).getBumen());
                                smsLogService.addSMSLog(tbSmsLog);
                                CSOnlineSMS = 1;
                            }
                            csOnline = 0;//cs在线
                            csSMS = 0;
                            thr = 5000;
                        }
                    }else{
                        List<TbWarning> a = warningService.findNowAll(type);
                        for (int j = 0 ; j <a.size();j++){
                            if (type.equals("SOS")){
                                String[] weizhi = a.get(j).getBaoliu1().split(";");
                                if(a.get(j).getPdepartment().equals(smsReminders.get(i).getBumen())){
                                    String sms = smsReminders.get(i).getMsg()+"，我的位置，经度："+weizhi[0]+",纬度："+weizhi[1]+"我的电话是："+a.get(j).getPphone()+"，我的名称是："+a.get(j).getPname()+"，我的设备编号："+a.get(j).getPtagid();
                                    String phone = smsReminders.get(i).getPhone();
                                    smsRemin(phone,sms);
                                    //发送成功，则添加日志
                                    TbSmsLog tbSmsLog = new TbSmsLog();
                                    tbSmsLog.setAddtime(gettime());
                                    tbSmsLog.setType(type);
                                    tbSmsLog.setPhone(phone);
                                    tbSmsLog.setMsg(sms);
                                    tbSmsLog.setName(smsReminders.get(i).getName());
                                    tbSmsLog.setBumen(smsReminders.get(i).getBumen());
                                    smsLogService.addSMSLog(tbSmsLog);
                                    //同时修改标识，只发一次短信
                                    ids.add(a.get(j).getId());
                                }
                            }else{
                                if(a.get(j).getPdepartment().equals(smsReminders.get(i).getBumen())){
                                    String sms = smsReminders.get(i).getMsg()+"，我的电话是："+a.get(j).getPphone()+"，我的名称："+a.get(j).getPname()+"，我的设备编号："+a.get(j).getPtagid();
                                    String phone = smsReminders.get(i).getPhone();
                                    smsRemin(phone,sms);
                                    //发送成功，则添加日志
                                    TbSmsLog tbSmsLog = new TbSmsLog();
                                    tbSmsLog.setAddtime(gettime());
                                    tbSmsLog.setType(type);
                                    tbSmsLog.setPhone(phone);
                                    tbSmsLog.setMsg(sms);
                                    tbSmsLog.setName(smsReminders.get(i).getName());
                                    tbSmsLog.setBumen(smsReminders.get(i).getBumen());
                                    smsLogService.addSMSLog(tbSmsLog);
                                    //同时修改标识，只发一次短信
                                    ids.add(a.get(j).getId());
                                }
                            }
                        }
                    }
                }
                for (int i = 0;i< ids.size();i++){
                    warningService.updateIDWarning(ids.get(i));
                }

                Thread.sleep(thr); // 线程休眠5秒
            }
        } catch (InterruptedException e) {
            // 处理线程中断异常
            e.printStackTrace();
        }
    }

    public String gettime(){
        Date now = new Date();
        // 创建日期格式化对象，设置格式为 "yyyy-MM-dd HH:mm"
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        // 格式化日期对象，输出字符串结果
        String formattedDate = sdf.format(now);
        return formattedDate;
    }
    public long GetTimeChaMiao(String time,String warTime){
        String startTimeStr = time;
        String endTimeStr = warTime;
        long differenceSeconds = 0;
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        try {
            Date startTime = format.parse(startTimeStr);
            Date endTime = format.parse(endTimeStr);

            long differenceMillis = endTime.getTime() - startTime.getTime();
            differenceSeconds = differenceMillis / 1000;

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

    public void smsRemin(String phone,String neirong){
        try {
            Credential cred = new Credential(this.SecretId, this.SecretKey);
            HttpProfile httpProfile = new HttpProfile();
            httpProfile.setEndpoint("sms.tencentcloudapi.com");
            ClientProfile clientProfile = new ClientProfile();
            clientProfile.setHttpProfile(httpProfile);
            SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
            SendSmsRequest req = new SendSmsRequest();
            String[] phoneNumberSet1 = new String[]{phone};
            req.setPhoneNumberSet(phoneNumberSet1);
            req.setSmsSdkAppId("1400838975");
            req.setSignName("北京华星北斗智控");
            req.setTemplateId("2082020");
            String[] templateParamSet1 = new String[]{String.valueOf(neirong)};
            req.setTemplateParamSet(templateParamSet1);
            SendSmsResponse resp = client.SendSms(req);
        } catch (TencentCloudSDKException var12) {
            System.out.println(var12.toString());
        }
    }
}