admin/wisdomisite-java
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

车辆调整

Browse Source
This commit is contained in:
pengjie 2024-05-26 11:41:19 +08:00
parent 5c1c4d0e72
commit 8ed205a4ea
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/zhgd/xmgl/task/ExamTask.java
View File

@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.zhgd.xmgl.async.AsyncHikvision;
import com.zhgd.xmgl.modules.car.entity.CarInfo; import com.zhgd.xmgl.modules.car.entity.CarInfo;
import com.zhgd.xmgl.modules.car.service.ICarInfoService; import com.zhgd.xmgl.modules.car.service.ICarInfoService;
import com.zhgd.xmgl.modules.exam.entity.*; import com.zhgd.xmgl.modules.exam.entity.*;
@ -68,12 +69,15 @@ public class ExamTask {
@Autowired @Autowired
private ICarInfoService carInfoService; private ICarInfoService carInfoService;
@Autowired
private AsyncHikvision asyncHikvision;
@Scheduled(cron = "0 0/1 * * * ?") @Scheduled(cron = "0 0/1 * * * ?")
public void xzMaterial() { public void xzMaterial() {
List<XzMaterial> list = xzMaterialService.list(); List<XzMaterial> list = xzMaterialService.list();
List<String> carNumber = new ArrayList<>(); List<String> carNumber = new ArrayList<>();
for (XzMaterial xzMaterial : list) { for (XzMaterial xzMaterial : list) {
if (xzMaterial.getEntryEndTime().compareTo(new Date()) < 0) { if (xzMaterial.getEntryEndTime() != null && xzMaterial.getEntryEndTime().compareTo(new Date()) < 0) {
if (StringUtils.isNotBlank(xzMaterial.getCarNumber())) { if (StringUtils.isNotBlank(xzMaterial.getCarNumber())) {
carNumber.add(xzMaterial.getCarNumber()); carNumber.add(xzMaterial.getCarNumber());
} }
@ -84,6 +88,10 @@ public class ExamTask {
carInfos = carInfos.stream().filter(c -> carNumber.contains(c.getCarNumber())).collect(Collectors.toList()); carInfos = carInfos.stream().filter(c -> carNumber.contains(c.getCarNumber())).collect(Collectors.toList());
if (carInfos.size() > 0) { if (carInfos.size() > 0) {
carInfoService.removeByIds(carInfos.stream().map(c -> c.getId()).collect(Collectors.toSet())); carInfoService.removeByIds(carInfos.stream().map(c -> c.getId()).collect(Collectors.toSet()));
for (CarInfo carInfo : carInfos) {
//同步海康
asyncHikvision.deleteCarInfoForHikvision(carInfo);
}
} }
} }
} }