木垒Ai推送是否管理员bug修复

This commit is contained in:
guoshengxiong 2024-11-07 15:18:43 +08:00
parent 5726c721ac
commit bfeb513f7a
2 changed files with 8 additions and 3 deletions

View File

@ -325,8 +325,8 @@ public class Project implements Serializable {
private Integer enableWorkerSafeWatch;
@ApiModelProperty(value = "安全履职报警推送时间")
private String workerSafeWatchTime;
@ApiModelProperty(value = "是否需要项目管理员做AI抓拍初筛")
private Integer aiAlarmNeedManageApprove;
/**
* runde平台token
*/

View File

@ -17,7 +17,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zhgd.jeecg.common.api.vo.Result;
import com.zhgd.jeecg.common.execption.OpenAlertException;
import com.zhgd.xmgl.async.AsyncAiAnalyse;
import com.zhgd.xmgl.base.entity.vo.SectorOneVo;
@ -137,6 +136,9 @@ public class AiAnalyseHardWareAlarmRecordServiceImpl extends ServiceImpl<AiAnaly
@Lazy
@Autowired
private UserEnterpriseServiceImpl userEnterpriseService;
@Lazy
@Autowired
private IAiAnalyseHardWareAlarmRecordService aiAnalyseHardWareAlarmRecordService;
@Override
public IPage<AiAnalyseHardWareAlarmRecord> queryAiAnalyseHardWareAlarmPageList(Map<String, Object> map) {
@ -267,6 +269,9 @@ public class AiAnalyseHardWareAlarmRecordServiceImpl extends ServiceImpl<AiAnaly
aiAnalyseHardWareAlarmRecordMapper.insert(aiAnalyseHardWareAlarmRecord);
//将数据通过MQTT转发到前台
asyncAiAnalyse.sendAiAnalyse(aiAnalyseHardWareAlarmRecord, Cts.PROJECT_LEVEL);
if (Objects.equals(projectInfoBySn.getAiAlarmNeedManageApprove(), 0)) {
aiAnalyseHardWareAlarmRecordService.violationPush(aiAnalyseHardWareAlarmRecord.getId());
}
}
@Override