| | |
| | | int dataToLianyunquGovernment = Integer.parseInt(redisUtils.get("dataToLianyunquGovernment").toString()); |
| | | int dataToChangShu = Integer.parseInt(redisUtils.get("dataToChangShu").toString()); |
| | | int dataToLongTeng = Integer.parseInt(redisUtils.get("dataToLongTeng").toString()); |
| | | int dataToJinTanNewMaterials = Integer.parseInt(redisUtils.get("dataToJinTanNewMaterials").toString()); |
| | | int dataToQianDeng = Integer.parseInt(redisUtils.get("dataToQianDeng").toString()); |
| | | int dataToChangShuHuanSi = Integer.parseInt(redisUtils.get("dataToChangShuHuanSi").toString()); |
| | | int nowTime = LengthOfTimeUtils.getSecondTimestampTwo(new Date()); |
| | | List<String> programList = new ArrayList<>(); |
| | | if (nowTime - dataToLianyunquGovernment > 10){ |
| | | if (nowTime - dataToLianyunquGovernment > 1200){ |
| | | programList.add("dataToLianyunquGovernment"); |
| | | } |
| | | if (nowTime - dataToChangShu > 7){ |
| | | if (nowTime - dataToChangShu > 7200){ |
| | | programList.add("dataToChangShu"); |
| | | } |
| | | if (nowTime - dataToLongTeng > 6){ |
| | | if (nowTime - dataToLongTeng > 600){ |
| | | programList.add("dataToLongTeng"); |
| | | } |
| | | if (nowTime - dataToJinTanNewMaterials > 300){ |
| | | programList.add("dataToJinTanNewMaterials"); |
| | | } |
| | | if (nowTime - dataToQianDeng > 300){ |
| | | programList.add("dataToQianDeng"); |
| | | } |
| | | if (nowTime - dataToChangShuHuanSi > 300){ |
| | | programList.add("dataToChangShuHuanSi"); |
| | | } |
| | | if (!programList.isEmpty()){ |
| | | AlarmUtils_2.sendMail("357328213@qq.com","程序掉线警报!",programList.toString()+"程序可能离线了!"); |
| | | ReturnT returnT = new ReturnT(200, "执行成功!"); |
| | | AlarmUtils_2.sendMail("357328213@qq.com,1vv_zkk6ji3kln@dingtalk.com","程序掉线警报!",programList.toString()+"程序可能离线了!"); |
| | | ReturnT returnT = new ReturnT(200, "执行成功!有邮件发送!"); |
| | | return returnT; |
| | | } |
| | | ReturnT returnT = new ReturnT(200, "执行成功!"); |
| | | ReturnT returnT = new ReturnT(200, "执行成功!无邮件发送"); |
| | | return returnT; |
| | | }catch (Exception e){ |
| | | ReturnT returnT = new ReturnT(500, "执行失败!"); |
| | | return returnT; |
| | | XxlJobLogger.log("OffLineAlarmException:" + e.getMessage()); |
| | | logger.error(e.getMessage()); |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | ReturnT returnT = new ReturnT(500, "执行失败!"); |
| | | return returnT; |
| | | } |
| | | |
| | | } |