海康下发修改

This commit is contained in:
GUO 2024-06-13 00:04:20 +08:00
parent fc3187fa72
commit 74f9fce37e

View File

@ -1,5 +1,7 @@
package com.zhgd.xmgl.async;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.zhgd.jeecg.common.util.SpringContextUtils;
import com.zhgd.xmgl.call.HousingDataCall;
import com.zhgd.xmgl.call.WkServiceuCall;
import com.zhgd.xmgl.modules.basicdata.entity.Notice;
@ -10,6 +12,9 @@ import com.zhgd.xmgl.modules.project.service.IProjectUfaceConfigService;
import com.zhgd.xmgl.modules.worker.entity.*;
import com.zhgd.xmgl.modules.worker.mapper.WorkerInfoMapper;
import com.zhgd.xmgl.modules.worker.service.impl.WorkerInfoServiceImpl;
import com.zhgd.xmgl.modules.xz.entity.XzHikvisionSync;
import com.zhgd.xmgl.modules.xz.mapper.XzHikvisionSyncMapper;
import com.zhgd.xmgl.util.NumberUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.MapUtils;
import org.springframework.beans.factory.annotation.Autowired;
@ -83,8 +88,17 @@ public class AsyncWorker {
List<WorkerInfo> list = workerInfoMapper.selectProjectWorkerInfoList(map);
if (list.size() > 0) {
for (WorkerInfo info : list) {
//海康门禁isc
if (NumberUtils.lt(info.getSafeScore(), 80D)) {
log.info("安全评分红码不下发权限,名称:{}", info.getWorkerName());
continue;
}
try {
info.setNoticeUserId(userId);
SpringContextUtils.getBean(XzHikvisionSyncMapper.class).delete(new LambdaQueryWrapper<XzHikvisionSync>()
.eq(XzHikvisionSync::getBigType, 1)
.eq(XzHikvisionSync::getWhoId, info.getId())
);
projectUfaceConfigService.sendBatchWorkerInfo(info, projectUfaceConfig, devList);
workerInfoService.resetHkStatus(info);
} catch (Exception e) {