| | |
| | | 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; |
| | |
| | | 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(); |
| | |
| | | smsLogService.addSMSLog(tbSmsLog); |
| | | csSMS = 1; |
| | | //发送之后修改短信状态为已发送 |
| | | System.out.println("发送成功"); |
| | | 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; |