ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/CameraParam.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/CameraParam.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.param.YY; package com.ycl.platform.domain.param.UY; import lombok.Data; import lombok.experimental.Accessors; ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/OnlineParam.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/OnlineParam.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.param.YY; package com.ycl.platform.domain.param.UY; import lombok.Data; import lombok.experimental.Accessors; ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/RecordMetaDSumParam.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/param/YY/RecordMetaDSumParam.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.param.YY; package com.ycl.platform.domain.param.UY; import lombok.Data; import lombok.experimental.Accessors; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/CameraResult.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/CameraResult.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.result.YY; package com.ycl.platform.domain.result.UY; import lombok.Data; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OnlineResult.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.result.YY; package com.ycl.platform.domain.result.UY; import lombok.Data; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/OsdMonitorResult.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.result.YY; package com.ycl.platform.domain.result.UY; import lombok.Data; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/result/YY/RecordMetaDSumResult.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.result.YY; package com.ycl.platform.domain.result.UY; import lombok.Data; ycl-server/src/main/java/com/ycl/task/HKTask.java
@@ -58,6 +58,7 @@ mongoTemplate.insert(list); //同步的数据进行工单阈值处理 ywThresholdService.carCheck(list); } else { log.error("同步车辆设备全检指标监测结果失败", jsonObject); } @@ -80,10 +81,10 @@ if (CollectionUtils.isEmpty(list)) { throw new RuntimeException("人脸设备全检指标监测结果数据为空"); } //TODO:同步的数据可能需要工单阈值等处理 //存放在mongo中 mongoTemplate.insert(list); //TODO:同步的数据可能需要工单阈值等处理 } else { log.error("同步人脸设备全检指标监测结果失败", jsonObject); } ycl-server/src/main/java/com/ycl/task/UYTask.java
New file @@ -0,0 +1,59 @@ package com.ycl.task; import com.alibaba.fastjson2.JSONObject; import com.ycl.platform.domain.param.HK.FaceDeviceInspectionParam; import com.ycl.platform.domain.param.HK.VehicleDeviceInspectionParam; import com.ycl.platform.domain.result.HK.FaceDeviceInspectionResult; import com.ycl.platform.domain.result.HK.VehicleDeviceInspectionResult; import com.ycl.platform.service.IYwThresholdService; import com.ycl.web.HKClient; import com.ycl.web.UYClient; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; @Slf4j @Component("UYTask") public class UYTask { @Autowired private MongoTemplate mongoTemplate; @Autowired private UYClient uyClient; @Autowired private IYwThresholdService ywThresholdService; private final static Integer pageNo = 1; private final static Integer pageSize = 5000; //成功状态码 private final static String successCode = "0"; //车辆设备全检指标监测结果 public void VehicleDeviceInspectionTask() { log.info("开始执行车辆设备全检指标监测结果数据同步"); log.info("结束车辆设备全检指标监测结果数据同步"); } public void FaceDeviceInspectionTask() { log.info("开始执行人脸设备全检指标监测结果数据同步"); log.info("结束人脸设备全检指标监测结果数据同步"); } private String getToday() { Date date = new Date(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String today = sdf.format(date); return today; } } ycl-server/src/main/java/com/ycl/web/UYClient.java
@@ -1,11 +1,10 @@ package com.ycl.web; import com.alibaba.fastjson2.JSONObject; import com.ycl.config.HKFeignConfig; import com.ycl.config.YYFeignConfig; import com.ycl.platform.domain.param.YY.CameraParam; import com.ycl.platform.domain.param.YY.OnlineParam; import com.ycl.platform.domain.param.YY.RecordMetaDSumParam; import com.ycl.platform.domain.param.UY.CameraParam; import com.ycl.platform.domain.param.UY.OnlineParam; import com.ycl.platform.domain.param.UY.RecordMetaDSumParam; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.GetMapping; ycl-server/src/main/resources/mapper/zgyw/YwThresholdMapper.xml
@@ -18,7 +18,7 @@ </resultMap> <sql id="selectYwThresholdVo"> select id, monitor_type, count_type , key, name, value, value_auto, create_time, update_time, description, deleted from t_yw_threshold select id, monitor_type, count_type, `key` , name, value, value_auto, create_time, update_time, description, deleted from t_yw_threshold </sql> <select id="selectYwThresholdList" parameterType="YwThreshold" resultMap="YwThresholdResult">