package com.landtool.lanbase.common.scheduletask;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.landtool.lanbase.common.utils.HttpUtils;
|
import com.landtool.lanbase.modules.res.entity.Res_ExtMapUrl;
|
import com.landtool.lanbase.modules.res.entity.Res_MainInfo;
|
import com.landtool.lanbase.modules.res.entity.Res_ProblemFeedback;
|
import com.landtool.lanbase.modules.res.service.impl.ResMainInfoServiceImpl;
|
import com.landtool.lanbase.modules.res.service.impl.ResProblemFeedbackServiceImpl;
|
import org.apache.commons.lang.StringUtils;
|
import org.apache.ibatis.transaction.Transaction;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import com.landtool.lanbase.modules.res.controller.ResMainInfoController;
|
import com.landtool.lanbase.modules.res.service.impl.ResExtMapUrlServiceImpl;
|
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.Date;
|
import java.util.List;
|
|
@Component
|
@Configuration
|
public class ScheduelTask {
|
|
public Logger log=LoggerFactory.getLogger(ScheduelTask.class);
|
|
@Autowired
|
ResMainInfoServiceImpl resMainInfoService;
|
@Autowired
|
ResExtMapUrlServiceImpl resExtMapUrlService;
|
@Autowired
|
private ResProblemFeedbackServiceImpl resProblemFeedbackService;
|
/*
|
* 定时检验正常服务 异常服务更新
|
* add by zsx
|
* 每天凌晨6点
|
* 查询所有资源原始地址 http请求地址
|
* 1.请求正常 如果资源之前状态为异常则更新正常
|
* 2.请求异常 若存在异常记录 则更新记录时间 否则插入一条新的记录 (对应资源状态为正常则更新为异常)
|
// */
|
@Scheduled(cron = "0 0 6 * * ?")
|
public void checkServiceUrl() {
|
//获取所有的服务资源
|
List<Res_ExtMapUrl> list = resExtMapUrlService.checkAllUrls();
|
log.info("服务监控开始");
|
for (Res_ExtMapUrl res_extMapUrl : list) {
|
int status=0; //插入记录数据 serverStatus 0 正常 1异常
|
boolean flag=false;
|
Integer resourceid = res_extMapUrl.getResourceid();
|
Integer serverResource = res_extMapUrl.getServerResource();
|
try {
|
String serverurl = res_extMapUrl.getServerurl();
|
if(StringUtils.isNotBlank(serverurl)){
|
String s = HttpUtils.get(serverurl);
|
//正常 如果存在之前异常数据则更新状态为正常
|
if(1== serverResource){
|
updateServerStatus(resourceid,status);
|
}
|
}
|
} catch (Exception e) {
|
status=1;
|
//异常抛出认为是服务不能正常使用 之后异常不重复记录(更新校验时间),
|
List<Res_ProblemFeedback> problemFeedbacks = resProblemFeedbackService.selectByResourceid(resourceid);
|
if(!CollectionUtil.isNotEmpty(problemFeedbacks)){
|
flag=true;
|
}
|
//首次记录异常记录
|
InsertProblem(resourceid,status,flag);
|
//如果存在之前正常数据则更新状态为异常
|
if(0== serverResource){
|
updateServerStatus(resourceid,status);
|
}
|
}
|
}
|
log.info("服务监控结束");
|
|
}
|
|
//更新异常记录状态
|
private void updateServerStatus(Integer resourceid, Integer status) {
|
Res_MainInfo mainInfo = new Res_MainInfo();
|
mainInfo.setResourceid(resourceid);
|
mainInfo.setResourcestatus(status); //状态更新回来
|
resMainInfoService.updateByPrimaryKeySelective(mainInfo);
|
}
|
//插入问题消息
|
private void InsertProblem(Integer resourceid, Integer status,Boolean flag) {
|
Res_ProblemFeedback model = new Res_ProblemFeedback();
|
java.sql.Timestamp time = new java.sql.Timestamp(new Date().getTime());
|
model.setResourceid(resourceid);
|
model.setAddtime(time);
|
if (flag){
|
model.setCreateuserid(0); //管理员操作
|
model.setFeedbacktype("系统");
|
model.setServerstatus(status);
|
model.setFeedbackstatus("服务问题");
|
model.setRemark("资源打不开");
|
resProblemFeedbackService.insertSelective(model);
|
}else {
|
resProblemFeedbackService.updateByResourceId(model);
|
}
|
}
|
|
public static void main(String[] args) {
|
try {
|
HttpUtils.get("http://71.3.251.104:8066/arcgis/rest/services/6257/MapServer");
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
