| | |
|---|
| | | package com.ycl.task; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.ycl.platform.domain.entity.YwThreshold; |
|---|
| | | 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.mapper.YwThresholdMapper; |
|---|
| | | import com.ycl.web.HKClient; |
|---|
| | | import enumeration.BusinessType; |
|---|
| | | import enumeration.general.BusinessTypeEnum; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.data.mongodb.core.MongoTemplate; |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private MongoTemplate mongoTemplate; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private HKClient hkClient; |
|---|
| | | @Autowired |
|---|
| | | private YwThresholdMapper thresholdMapper; |
|---|
| | | |
|---|
| | | private final static Integer pageNo = 1; |
|---|
| | | private final static Integer pageSize = 5000; |
|---|
| | |
|---|
| | | throw new RuntimeException("车辆设备全检指标监测结果数据为空"); |
|---|
| | | } |
|---|
| | | //TODO:同步的数据可能需要工单阈值等处理 |
|---|
| | | |
|---|
| | | List<YwThreshold> ywThresholds = thresholdMapper.selectByType(BusinessTypeEnum.CAR.name()); |
|---|
| | | //存放在mongo中 |
|---|
| | | mongoTemplate.insert(list); |
|---|
| | | } else { |
|---|
