龚焕茏
2024-08-27 fea89b769738f7db06281f244bc81135fc34ce76
ycl-server/src/main/java/com/ycl/task/PythonTask.java
@@ -8,6 +8,7 @@
import com.ycl.platform.domain.result.UY.*;
import com.ycl.platform.service.ITMonitorService;
import com.ycl.platform.service.IYwThresholdService;
import com.ycl.platform.service.UYErrorTypeCheckService;
import com.ycl.utils.DateUtils;
import constant.ApiConstants;
import lombok.extern.slf4j.Slf4j;
@@ -30,12 +31,14 @@
 * 拿去osd标注、标注时间数据
 */
@Slf4j
@Component("PythonTask")
@Component("pythonTask")
public class PythonTask {
    @Autowired
    private MongoTemplate mongoTemplate;
    @Autowired
    private PythonClient pythonClient;
    @Autowired
    private UYErrorTypeCheckService uyErrorTypeCheckService;
    public void pythonOsdTask(){
        log.info("开始执行pythonOsd数据同步");
@@ -58,6 +61,8 @@
                        DeleteResult result = mongoTemplate.remove(pyQuery, PyOsdResult.class);
                        //存放在mongo中
                        mongoTemplate.insertAll(records);
                        // 工单生成
                        uyErrorTypeCheckService.osdCheck(records);
                    }
                } else {
                    log.error("pythonOsd数据为空{}", jsonObject);