|
|
@@ -74,74 +74,4 @@ public class MeterWorkImageTempServiceImpl extends BaseServiceImpl<MeterWorkImag
|
|
|
}
|
|
|
return rm;
|
|
|
}
|
|
|
-
|
|
|
- //定时刷新接口 每30秒执行一次
|
|
|
-// @Scheduled(cron = "0/30 * * * * ? ")
|
|
|
- @Transactional
|
|
|
- public void imageAutoUpload(){
|
|
|
- ComBaseInfo baseInfo = comBaseInfoMapper.selectByPrimaryKey("001043006");
|
|
|
- if(baseInfo != null && baseInfo.getBaseName() != null && StringUtils.isNotEmpty(baseInfo.getBaseName())) {
|
|
|
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
- Date imageTime = new Date();
|
|
|
- Calendar beforeD = Calendar.getInstance();
|
|
|
- Calendar afterD = Calendar.getInstance();
|
|
|
- beforeD.setTime(imageTime);
|
|
|
- afterD.setTime(imageTime);
|
|
|
- beforeD.add(Calendar.MINUTE, -Integer.parseInt(baseInfo.getBaseName()));
|
|
|
- afterD.add(Calendar.MINUTE, 0);
|
|
|
- String startTime = sdf.format(beforeD.getTime());
|
|
|
- String endTime = sdf.format(afterD.getTime());
|
|
|
- HashMap<String, Object> imageMap = new HashMap();
|
|
|
- imageMap.put("startTime", startTime);
|
|
|
- imageMap.put("endTime", endTime);
|
|
|
- imageMap.put("valueFlag", "0");
|
|
|
- //查询图片中间表 当前时间-baseInfo.getBaseName()至当前时间的图片信息
|
|
|
- List<MeterWorkImageTemp> imageTemps = meterWorkImageTempMapper.imageQuery(imageMap);
|
|
|
-
|
|
|
- if(imageTemps.size() >= 1) {
|
|
|
- for(MeterWorkImageTemp imageTemp: imageTemps) {
|
|
|
- Date createTime = imageTemp.getImageTime();
|
|
|
- Calendar beforeDTemp = Calendar.getInstance();
|
|
|
- Calendar afterDTemp = Calendar.getInstance();
|
|
|
- beforeDTemp.setTime(createTime);
|
|
|
- afterDTemp.setTime(createTime);
|
|
|
- beforeDTemp.add(Calendar.MINUTE, -6);
|
|
|
- afterDTemp.add(Calendar.MINUTE, 0);
|
|
|
- String startTimeTemp = sdf.format(beforeDTemp.getTime());
|
|
|
- String endTimeTemp = sdf.format(afterDTemp.getTime());
|
|
|
- HashMap<String, Object> receivedMap = new HashMap();
|
|
|
- receivedMap.put("startTime", startTimeTemp);
|
|
|
- receivedMap.put("endTime", endTimeTemp);
|
|
|
- receivedMap.put("railwayNo", imageTemp.getRailwayNo());
|
|
|
- receivedMap.put("baseSpotNo", imageTemp.getBaseSpotNo());
|
|
|
-
|
|
|
- List<MeterWorkRailwayReceived> receiveds = meterWorkRailwayReceivedMapper.getReceived(receivedMap);
|
|
|
- if(receiveds.size() == 1) {
|
|
|
- MeterWorkImage image = meterWorkImageMapper.selectByPrimaryKey(receiveds.get(0).getActualFirstNo());
|
|
|
- if(image != null) {
|
|
|
- if(imageTemp.getImageUrl1().indexOf("P1") != -1) {
|
|
|
- image.setImageFile3(imageTemp.getImageUrl1());
|
|
|
- }else if(imageTemp.getImageUrl1().indexOf("P2") != -1) {
|
|
|
- image.setImageFile4(imageTemp.getImageUrl1());
|
|
|
- }
|
|
|
- meterWorkImageMapper.updateByPrimaryKeySelective(image);
|
|
|
- imageTemp.setValueFlag("1");
|
|
|
- meterWorkImageTempMapper.updateByPrimaryKeySelective(imageTemp);
|
|
|
- }else {
|
|
|
- MeterWorkImage imageModel = new MeterWorkImage();
|
|
|
- imageModel.setActualFirstNo(receiveds.get(0).getActualFirstNo());
|
|
|
- if(imageTemp.getImageUrl1().indexOf("P1") != -1) {
|
|
|
- imageModel.setImageFile3(imageTemp.getImageUrl1());
|
|
|
- }else if(imageTemp.getImageUrl1().indexOf("P2") != -1) {
|
|
|
- imageModel.setImageFile4(imageTemp.getImageUrl1());
|
|
|
- }
|
|
|
- meterWorkImageMapper.insertSelective(imageModel);
|
|
|
- imageTemp.setValueFlag("1");
|
|
|
- meterWorkImageTempMapper.updateByPrimaryKeySelective(imageTemp);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
}
|