|
@ -3,6 +3,7 @@ package com.ai.bss.security.protection.service.task;
|
3
|
3
|
import java.util.List;
|
4
|
4
|
import java.util.Map;
|
5
|
5
|
|
|
6
|
import org.apache.commons.lang.StringUtils;
|
6
|
7
|
import org.apache.kafka.clients.consumer.ConsumerRecord;
|
7
|
8
|
import org.junit.Assert;
|
8
|
9
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@ -88,14 +89,13 @@ public class AiResultRecordKafkaTask {
|
88
|
89
|
AiIdenLog aiIdenLog = JSON.parseObject(message, new TypeReference<AiIdenLog>() {
|
89
|
90
|
});
|
90
|
91
|
aiIdenLog.setResourceToolId(resourceToolId);
|
91
|
|
aiIdenLog.setResourceToolName(String.valueOf(resourceToolMap.get("resourceToolName")));
|
92
|
|
aiIdenLog.setMonitorSceneId(String.valueOf(sceneTerminalRelMap.get("monitorSceneId")));
|
93
|
|
aiIdenLog.setMonitorSceneName(String.valueOf(sceneTerminalRelMap.get("monitorSceneName")));
|
94
|
|
//aiIdenLog.setEffectType(String.valueOf(sceneTerminalRelMap.get("effectType"))); //OTH
|
95
|
|
aiIdenLog.setEffectType("OTH"); //OTH
|
96
|
|
aiIdenLog.setTerminalPosition(String.valueOf(sceneTerminalRelMap.get("place")));
|
97
|
|
aiIdenLog.setOrganizationId(String.valueOf(sceneTerminalRelMap.get("orgId")));
|
98
|
|
aiIdenLog.setAiTaskId(Long.valueOf(String.valueOf(aiTaskMap.get("aiTaskId"))));
|
|
92
|
aiIdenLog.setResourceToolName(StringUtils.defaultIfBlank(String.valueOf(resourceToolMap.get("resourceToolName")),""));
|
|
93
|
aiIdenLog.setMonitorSceneId(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("monitorSceneId")),""));
|
|
94
|
aiIdenLog.setMonitorSceneName(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("monitorSceneName")),""));
|
|
95
|
aiIdenLog.setEffectType(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("effectType")),EbcConstant.TERMINAL_EFFECT_TYPE_OTH));
|
|
96
|
aiIdenLog.setTerminalPosition(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("place")),""));
|
|
97
|
aiIdenLog.setOrganizationId(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("orgId")),""));
|
|
98
|
aiIdenLog.setAiTaskId(aiTaskMap.get("aiTaskId")==null?0L:Long.valueOf(String.valueOf(aiTaskMap.get("aiTaskId"))));
|
99
|
99
|
|
100
|
100
|
//TODO 人员信息暂时默认
|
101
|
101
|
aiIdenLog.setRelateEmployeeRoleId("201613310867");
|