package com.ycl.smoke.task;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.ycl.service.redis.RedisService;
|
import com.ycl.smoke.entity.*;
|
import com.ycl.smoke.dto.*;
|
import com.ycl.smoke.remote.service.ISmokeDetectionService;
|
import com.ycl.smoke.service.*;
|
import com.ycl.smoke.utils.HttpUtil;
|
import com.ycl.utils.redis.RedisKey;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.text.DateFormat;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
@Component
|
public class ScheduledTask {
|
private final String host = "http://116.62.234.187:8120";
|
ISmokeDetectionService smokeDetectionService;
|
|
IOdsAlarmMsgService alarmMsgService;
|
|
IOdsDetectorDailyService detectorDailyService;
|
|
IOdsTenMinDataService tenMinDataService;
|
|
IOdsInTimeService inTimeService;
|
|
IOdsInTimeCountService iOdsInTimeCountService;
|
|
IOdsLocaleService localeService;
|
|
IOdsCustomerService customerService;
|
|
IOdsAlarmRecordService alarmRecordService;
|
|
IOdsCurAlarmService curAlarmService;
|
|
IOdsStatisticsService odsStatisticsService;
|
|
@Resource
|
private RedisService redisService;
|
|
@Autowired
|
public void setSmokeDetectionService(ISmokeDetectionService smokeDetectionService) {
|
this.smokeDetectionService = smokeDetectionService;
|
}
|
|
@Autowired
|
public void setIOdsInTimeCountService(IOdsInTimeCountService iOdsInTimeCountService) {
|
this.iOdsInTimeCountService = iOdsInTimeCountService;
|
}
|
|
@Autowired
|
public void setAlarmMsgService(IOdsAlarmMsgService alarmMsgService) {
|
this.alarmMsgService = alarmMsgService;
|
}
|
|
@Autowired
|
public void setTenMinDataService(IOdsTenMinDataService tenMinDataService) {
|
this.tenMinDataService = tenMinDataService;
|
}
|
|
@Autowired
|
public void setInTimeService(IOdsInTimeService inTimeService) {
|
this.inTimeService = inTimeService;
|
}
|
|
@Autowired
|
public void setLocaleService(IOdsLocaleService localeService) {
|
this.localeService = localeService;
|
}
|
|
@Autowired
|
public void setCustomerService(IOdsCustomerService customerService) {
|
this.customerService = customerService;
|
}
|
|
@Autowired
|
public void setAlarmRecordService(IOdsAlarmRecordService alarmRecordService) {
|
this.alarmRecordService = alarmRecordService;
|
}
|
|
@Autowired
|
public void setCurAlarmService(IOdsCurAlarmService curAlarmService) {
|
this.curAlarmService = curAlarmService;
|
}
|
|
@Autowired
|
public void setDetectorDailyService(IOdsDetectorDailyService detectorDailyService) {
|
this.detectorDailyService = detectorDailyService;
|
}
|
|
@Autowired
|
public void setOdsStatisticsService(IOdsStatisticsService odsStatisticsService) {
|
this.odsStatisticsService = odsStatisticsService;
|
}
|
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void alarmMsgTask() {
|
try {
|
AlarmMsgParamDto paramDto = AlarmMsgParamDto.builder().StartAt(0).Size(100).build();
|
String json = smokeDetectionService.getListAlarmMsg(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
AlarmMsgResponseDto dto = JSON.parseObject(responseDto.getData().toString(), AlarmMsgResponseDto.class);
|
List<OdsAlarmMsg> list = dto.getContent();
|
// System.out.println(list.size());
|
list.forEach(o -> {
|
try {
|
alarmMsgService.save(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
alarmMsgTask();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void queryDataDetectorDaily2Task() {
|
try {
|
LocalDateTime ldt = LocalDateTime.now();
|
ldt = ldt.plusDays(-1);
|
DateTimeFormatter pattern = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
|
DetectorDailyParamDto paramDto = DetectorDailyParamDto.builder().AcquitDate(ldt.format(pattern)).build();
|
|
String json = smokeDetectionService.queryDataDetectorDaily2(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
if (responseDto.getStatus() == 200) {
|
DetectorDailyResponseDto dto = JSON.parseObject(responseDto.getData().toString(), DetectorDailyResponseDto.class);
|
List<OdsDetectorDaily> list = dto.getContent();
|
list.forEach(o -> {
|
try {
|
detectorDailyService.save(o);
|
} catch (Exception ex) {
|
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
queryDataDetectorDaily2Task();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void queryTenMinData() {
|
try {
|
TenMinParamDto paramDto = TenMinParamDto.builder().build();
|
String json = smokeDetectionService.queryTenMinData(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
List<OdsTenMinData> list = JSON.parseArray(responseDto.getData().toString(), OdsTenMinData.class);
|
list.forEach(o -> {
|
try {
|
tenMinDataService.save(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
queryDataDetectorDaily2Task();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
@Scheduled(cron = "0 */30 * * * ?") // 每5分钟执行
|
public void loginTask() {
|
login();
|
}
|
|
// @Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
@Scheduled(cron = "0 */1 * * * ?") // 每5分钟执行
|
public void listDataInTime() {
|
DataIntimeParamDto paramDto = DataIntimeParamDto.builder().build();
|
// {"StartAt":0,"Size":20,"Typ":2,"SortBy":"status","SortMode":"asc","Param":{"StatusOfRecord":"NORMAL"}}
|
paramDto.setSize(20);
|
paramDto.setStartAt(0);
|
paramDto.setTyp(2);
|
paramDto.setSortBy("status");
|
paramDto.setSortMode("asc");
|
|
DataIntimeParamChildDto paramChildDto = new DataIntimeParamChildDto();
|
paramChildDto.setStatusOfRecord("NORMAL");
|
paramDto.setParam(paramChildDto);
|
|
getInTimeData(paramDto);
|
|
paramDto.setTyp(1);
|
getInTimeData(paramDto);
|
}
|
|
private void getInTimeData(DataIntimeParamDto paramDto) {
|
try {
|
String json = smokeDetectionService.listDataIntime(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
DataIntimeResponseDto dataIntimeResponseDto = JSON.parseObject(responseDto.getData().toString(), DataIntimeResponseDto.class);
|
List<OdsInTime> list = dataIntimeResponseDto.getContent();
|
|
OdsInTimeCount odsInTimeCount = new OdsInTimeCount();
|
LambdaQueryWrapper<OdsInTimeCount> queryWrapper = new LambdaQueryWrapper<OdsInTimeCount>().eq(OdsInTimeCount::getType, paramDto.getTyp());
|
List<OdsInTimeCount> countList = iOdsInTimeCountService.list(queryWrapper);
|
if (countList.size() > 0) {
|
odsInTimeCount = countList.get(0);
|
}
|
odsInTimeCount.setDeviceNum(dataIntimeResponseDto.getDeviceNum());
|
odsInTimeCount.setLocaleNum(dataIntimeResponseDto.getLocaleNum());
|
odsInTimeCount.setOnlineNum(dataIntimeResponseDto.getOnlineNum());
|
odsInTimeCount.setTotal(dataIntimeResponseDto.getTotal());
|
iOdsInTimeCountService.saveOrUpdate(odsInTimeCount);
|
|
list.forEach(o -> {
|
try {
|
o.setModifyTime(LocalDateTime.now());
|
o.setTyp(paramDto.getTyp());
|
inTimeService.saveOrUpdate(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
queryDataDetectorDaily2Task();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void listLocale() {
|
try {
|
LocaleParamDto paramDto = LocaleParamDto.builder().build();
|
|
String json = smokeDetectionService.listLocale(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
LocaleResponseDto responseDataDto = JSON.parseObject(responseDto.getData().toString(), LocaleResponseDto.class);
|
List<OdsLocale> list = responseDataDto.getContent();
|
list.forEach(o -> {
|
try {
|
o.setCustomerString(JSON.toJSONString(o.getCustomer()));
|
localeService.save(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
queryDataDetectorDaily2Task();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void queryCustomer() {
|
try {
|
CustomerParamDto paramDto = CustomerParamDto.builder().build();
|
|
String json = smokeDetectionService.queryCustomer(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
CustomerResponseDto responseDataDto = JSON.parseObject(responseDto.getData().toString(), CustomerResponseDto.class);
|
List<OdsCustomer> list = responseDataDto.getContent();
|
list.forEach(o -> {
|
try {
|
o.setAreasString(o.getAreas() == null ? "" : JSON.toJSONString(o.getAreas()));
|
o.setAreaIdsString(o.getAreaIds() == null ? "" : JSON.toJSONString(o.getAreaIds()));
|
o.setAreaIdCascadsString(o.getAreaIdCascads() == null ? "" : JSON.toJSONString(o.getAreaIdCascads()));
|
customerService.save(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
queryDataDetectorDaily2Task();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void listAlarmRecord() {
|
try {
|
AlarmMsgParamDto paramDto = AlarmMsgParamDto.builder().build();
|
|
String json = smokeDetectionService.getListAlarmRecord(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
AlarmRecordResponseDto responseDataDto = JSON.parseObject(responseDto.getData().toString(), AlarmRecordResponseDto.class);
|
List<OdsAlarmRecord> list = responseDataDto.getContent();
|
list.forEach(o -> {
|
try {
|
o.setAlarmRecordPicsString(JSON.toJSONString(o.getAlarmRecordPics()));
|
alarmRecordService.save(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
queryDataDetectorDaily2Task();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
/**
|
* 监测报警统计 运维情况报表
|
*/
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void listCurAlarm() {
|
try {
|
CurAlarmParamDto paramDto = CurAlarmParamDto.builder().StartAt(0).Size(20).SortBy("status").SortMode("asc").Typ(2).build();
|
CurAlarmParamChildDto childDto = CurAlarmParamChildDto.builder().build();
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.add(Calendar.DAY_OF_MONTH, -1);
|
long todayZero = calendar.getTimeInMillis();
|
|
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
calendar.add(Calendar.MONTH, -1);
|
long lastMonthZero = calendar.getTimeInMillis();
|
|
childDto.setStartAt(lastMonthZero / 1000);
|
childDto.setEndAt(todayZero / 1000);
|
childDto.setLocaleWithDevice(true);
|
paramDto.setParam(childDto);
|
|
String json = smokeDetectionService.getListCurAlarm(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
CurAlarmResponseDto responseDataDto = JSON.parseObject(responseDto.getData().toString(), CurAlarmResponseDto.class);
|
List<OdsCurAlarm> list = responseDataDto.getContent();
|
list.forEach(o -> {
|
try {
|
curAlarmService.saveByLocalId(o);
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
});
|
// alarmMsgService.saveBatch(list);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
listCurAlarm();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
/**
|
* 检测仪总体情况报表
|
*/
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void listDataDetectorDailyStats() {
|
try {
|
DateFormat df = new SimpleDateFormat("yyyy-MM-dd");
|
Calendar calendar = Calendar.getInstance();
|
String dateEnd = df.format(calendar.getTime());
|
|
calendar.add(Calendar.MONTH, -1);
|
String dateBegin = df.format(calendar.getTime());
|
|
DataDetectorDailyStatsParamDto paramDto = DataDetectorDailyStatsParamDto.builder().Typ(1).WithAreaLocaleReport(false)
|
.AcquitDateBegin(dateBegin).AcquitDateEnd(dateEnd).build();
|
String json = smokeDetectionService.getListDataDetectorDailyStats(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
LambdaUpdateWrapper<OdsStatistics> update = new LambdaUpdateWrapper<OdsStatistics>()
|
.eq(OdsStatistics::getTypeName, "listDataDetectorDailyStats")
|
.set(OdsStatistics::getContent, responseDto.getData().toString());
|
|
odsStatisticsService.update(update);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
listDataDetectorDailyStats();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
/**
|
* 油烟减排统计
|
*/
|
@Scheduled(cron = "0 0 1 * * ?") // 每天零点执行
|
// @Scheduled(cron = "0/1 * * * * ?") // 每秒执行
|
public void listDetectorDaily() {
|
try {
|
CurAlarmParam2Dto paramDto = CurAlarmParam2Dto.builder().StartAt(0).Size(20).build();
|
CurAlarmParamChild2Dto childDto = CurAlarmParamChild2Dto.builder().build();
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
calendar.set(Calendar.MILLISECOND, 0);
|
calendar.add(Calendar.DAY_OF_MONTH, -1);
|
long todayZero = calendar.getTimeInMillis();
|
|
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
calendar.add(Calendar.MONTH, -1);
|
long lastMonthZero = calendar.getTimeInMillis();
|
|
childDto.setStartAt(lastMonthZero / 1000);
|
childDto.setEndAt(todayZero / 1000);
|
paramDto.setParam(childDto);
|
// {"StartAt":0,"Size":20,"Param":{"startAt":1697040000,"endAt":1699631999}}:
|
String json = smokeDetectionService.getListDetectorDaily(paramDto, redisService.get(RedisKey.SMOKE_TOKEN).toString());
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
|
if (responseDto.getStatus() == 200) {
|
LambdaUpdateWrapper<OdsStatistics> update = new LambdaUpdateWrapper<OdsStatistics>()
|
.eq(OdsStatistics::getTypeName, "listDetectorDaily")
|
.set(OdsStatistics::getContent, responseDto.getData().toString());
|
|
odsStatisticsService.update(update);
|
} else if (responseDto.getStatus() == 114) {
|
login();
|
listDetectorDaily();
|
} else {
|
System.out.printf(responseDto.getData().toString());
|
}
|
} catch (Exception ex) {
|
System.out.printf(ex.getMessage());
|
}
|
}
|
|
|
void login() {
|
LoginParamDto loginParamDto = LoginParamDto.builder().username("遂昌城管局").password("123456").noCode(true).build();
|
String json = smokeDetectionService.loginAction(loginParamDto);
|
SmokeResultResponseDto responseDto = JSON.parseObject(json, SmokeResultResponseDto.class);
|
if (responseDto.getStatus() == 200) {
|
LoginResponseDto loginResponseDto = JSON.parseObject(responseDto.getData().toString(), LoginResponseDto.class);
|
System.out.println(loginResponseDto.getToken());
|
redisService.set(RedisKey.SMOKE_TOKEN, loginResponseDto.getToken());
|
}
|
}
|
}
|
