package com.ycl.smoke.task;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.ycl.smoke.dto.EventAddParamDto;
|
import com.ycl.smoke.dto.EventAddResponseDto;
|
import com.ycl.smoke.dto.ResultResponseDto;
|
import com.ycl.smoke.entity.BaseCase;
|
import com.ycl.smoke.entity.VideoAlarmReport;
|
import com.ycl.smoke.entity.Violations;
|
import com.ycl.smoke.mapper.BaseCaseMapper;
|
import com.ycl.smoke.mapper.VideoAlarmReportMapper;
|
import com.ycl.smoke.mapper.ViolationsMapper;
|
import com.ycl.smoke.service.CityPlatformService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@Component
|
public class CityUploadTask {
|
|
@Resource
|
BaseCaseMapper baseCaseMapper;
|
|
@Resource
|
ViolationsMapper violationsMapper;
|
|
|
@Resource
|
VideoAlarmReportMapper videoAlarmReportMapper;
|
|
@Autowired
|
CityPlatformService cityPlatformService;
|
|
|
@Scheduled(cron = "0 */5 * * * ?") // 每5分钟执行
|
public void upload() {
|
QueryWrapper<BaseCase> wrapperWc = new QueryWrapper<>();
|
wrapperWc.lambda().eq(BaseCase::getState, 10);
|
List<BaseCase> baseCases = baseCaseMapper.selectList(wrapperWc);
|
|
baseCases.forEach(o -> {
|
|
Violations violations = violationsMapper.selectById(o.getId());
|
String medias = "";
|
String eventDesc = "";
|
if (violations != null) {
|
eventDesc = violations.getDescription();
|
VideoAlarmReport videoAlarmReport = videoAlarmReportMapper.selectById(violations.getVideoAlarmReportId());
|
if (videoAlarmReport != null) {
|
StringBuilder stringBuilder = new StringBuilder().append("[{'mediaURL':'").append(videoAlarmReport.getPicData()).append(videoAlarmReport.getPicData()).append("'}]");
|
medias = stringBuilder.toString();
|
}
|
}
|
EventAddParamDto dto = EventAddParamDto.builder().y84(o.getLatitude() != null ? o.getLatitude().toString() : "")
|
.x84(o.getLongitude() != null ? o.getLongitude().toString() : "")
|
.source(11).address(o.getSite()).eventDesc(eventDesc).eventSign(o.getCode())
|
.medias(medias).build();
|
String msg = cityPlatformService.addEvent(dto);
|
ResultResponseDto result = JSONObject.parseObject(msg, ResultResponseDto.class);
|
System.out.println("--" + result.toString());
|
if (result.getCode() == 0) {
|
try {
|
|
// EventAddResponseDto responseDto = JSONObject.parseObject(result.getResult(), EventAddResponseDto.class);
|
// o.setTaskCode(responseDto.getTaskcode());
|
o.setTaskCode(result.getResult());
|
o.setState(2);
|
baseCaseMapper.updateById(o);
|
// System.out.println("--更新成功");
|
|
} catch (Exception ex) {
|
|
System.out.println("--" + ex.getMessage());
|
}
|
}
|
|
});
|
}
|
}
|
