Merge remote-tracking branch 'origin/master'

security-protection-service/src/main/java/com/ai/bss/security/protection/controller/AttendanceReportController.java

import com.ai.bss.security.protection.model.AttendanceReport;
import com.ai.bss.security.protection.service.interfaces.AttendanceReportService;
import com.ai.bss.security.protection.utils.EbcConstant;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
		// 每页条数
		int pageSize = attendanceReport.getPageSize() < 1 ? EbcConstant.DEFAULT_PAGE_SIZE : attendanceReport.getPageSize();
		if (StringUtils.isEmpty(attendanceReport.getWorkDay())) {
			return CommonResponse.fail("503", "查询时间不能为空");
		}
		
		Map<String, Object> params = new HashMap<>();
		params.put("workDay",attendanceReport.getWorkDay());
		params.put("orgId",attendanceReport.getOrgId());
		// 每页条数
		int pageSize = attendanceReport.getPageSize() < 1 ? EbcConstant.DEFAULT_PAGE_SIZE : attendanceReport.getPageSize();
		if (StringUtils.isEmpty(attendanceReport.getMonth())) {
			return CommonResponse.fail("503", "查询时间不能为空");
		}
		
		if (StringUtils.isEmpty(attendanceReport.getOrgId())) {
			return CommonResponse.fail("504", "查询部门不能为空");
		}
		
		Map<String, Object> params = new HashMap<>();
		params.put("month",attendanceReport.getMonth());
		params.put("orgId",attendanceReport.getOrgId());

security-protection-service/src/main/java/com/ai/bss/security/protection/service/impl/AttendanceReportServiceImpl.java

import com.ai.bss.worker.service.api.AttendanceStatusQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.ArrayList;
import java.util.*;
/**
 * @Auther: 王超
        CommonResponse<PageBean<Map<String,Object>>>  attendanceReport = null;
        try {
            attendanceReport = attendanceStatusQuery.queryMonthlyAttendanceReport((new CommonRequest<>(params,pageNumber,pageSize)));
            
            if (!attendanceReport.isSuccess()) {
            	return attendanceReport;
			}
            
            if (attendanceReport.getData()==null||CollectionUtils.isEmpty(attendanceReport.getData().getData())) {
				return CommonResponse.ok(new PageBean<Map<String,Object>>(new ArrayList<Map<String,Object>>(), pageSize, pageNumber, 1, 1));
			}
            
            List<Map<String, Object>> dailyAttendanceList = attendanceReport.getData().getData();
            if(dailyAttendanceList != null && dailyAttendanceList.size() != 0){
                Map<String, Object> dailyAttendanceMap = dailyAttendanceList.get(0);
        CommonResponse<List<Map<String, Object>>> attendanceReportResponse =  null;
        try {
            attendanceReportResponse = attendanceStatusQuery.queryAttendanceDetailReport(new CommonRequest<>(params,1,10));
            
            if (!attendanceReportResponse.isSuccess()) {
            	return attendanceReportResponse;
			}
            
            if (CollectionUtils.isEmpty(attendanceReportResponse.getData())) {
				return CommonResponse.ok(null);
			}
            
            List<Map<String, Object>> attendanceReportList = attendanceReportResponse.getData();
            attendanceReportList.forEach((dailyAttendance)->{
                    }
                });
                String[] attendanceStatusArray = new String[2];
                //存放考勤状态
                ArrayList<Object> attendanceStatusList = new ArrayList<>();
                //判断是否是外勤
                if (dailyAttendance.get("goToWorkExceptionStatus")!=null&& "FIE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("上午外勤");
                }
                if (dailyAttendance.get("goOffWorkExceptionStatus")!=null&&"FIE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("下午外勤");
                }
                //判断是否是加班
                if (dailyAttendance.get("goToWorkExceptionStatus")!=null&& "OVE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("上午加班");
                }
                if (dailyAttendance.get("goOffWorkExceptionStatus")!=null&&"OVE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("下午加班");
                }
                //如果都正常有外勤显示外勤，没外勤显示正常，不属于异常考勤
                if("正常".equals(dailyAttendance.get("goToWorkStatus"))&&"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    if(!(null!=attendanceStatusList&&attendanceStatusList.size()>0)){
                        attendanceStatusList.add("正常");
                    }
                    dailyAttendance.put("isAbnormal",false);
                }
                //如果上午正常，下午非正常 则显示下午的
                if("正常".equals(dailyAttendance.get("goToWorkStatus"))&&!"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    if("迟到".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add("迟到"+dailyAttendance.get("goOffWorkTime") +"分");
                    }
                    if("早退".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add("早退"+dailyAttendance.get("goOffWorkTime") +"分");
                    }
                    if("旷工".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add("旷工"+dailyAttendance.get("goToWorkTime") +"天");
                    }
                    if("倒休".equals(dailyAttendance.get("goOffWorkStatus"))||"事假".equals(dailyAttendance.get("goOffWorkStatus"))||"年假".equals(dailyAttendance.get("goOffWorkStatus"))||"放假".equals(dailyAttendance.get("goOffWorkStatus"))||"病假".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add(dailyAttendance.get("goOffWorkStatus"));
                        dailyAttendance.put("isAbnormal",false);
                    }else{
                        dailyAttendance.put("isAbnormal",true);
                    }
                }
                //如果上午非正常，下午正常 则显示上午的
                if(!"正常".equals(dailyAttendance.get("goToWorkStatus"))&&"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    if("迟到".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("迟到"+dailyAttendance.get("goToWorkTime") +"分");
                    }
                    if("早退".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("早退"+dailyAttendance.get("goToWorkTime") +"分");
                    }
                    if("旷工".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("旷工"+dailyAttendance.get("goToWorkTime") +"天");
                    }
                    if("倒休".equals(dailyAttendance.get("goToWorkStatus"))||"事假".equals(dailyAttendance.get("goToWorkStatus"))||"年假".equals(dailyAttendance.get("goToWorkStatus"))||"放假".equals(dailyAttendance.get("goToWorkStatus"))||"病假".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add(dailyAttendance.get("goToWorkStatus"));
                        dailyAttendance.put("isAbnormal",false);
                    }else{
                        dailyAttendance.put("isAbnormal",true);
                    }
                }
                //如果上午非正常，下午非正常
                if(!"正常".equals(dailyAttendance.get("goToWorkStatus"))&&!"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    //如果上下午状态相等且是放假 倒休 事假 年假 病假 放假 显示一种状态 非异常考勤
                    if(dailyAttendance.get("goToWorkStatus").equals(dailyAttendance.get("goOffWorkStatus"))&&("倒休".equals(dailyAttendance.get("goToWorkStatus"))||"事假".equals(dailyAttendance.get("goToWorkStatus"))||"年假".equals(dailyAttendance.get("goToWorkStatus"))||"放假".equals(dailyAttendance.get("goToWorkStatus"))||"病假".equals(dailyAttendance.get("goToWorkStatus")))){
                        attendanceStatusList.add(dailyAttendance.get("goToWorkStatus"));
                        dailyAttendance.put("isAbnormal",false);
                    }
                    //如果上下午状态相等且是旷工 显示一种状态 异常考勤
                    else if(dailyAttendance.get("goToWorkStatus").equals(dailyAttendance.get("goOffWorkStatus"))&&"旷工".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("旷工1天");
                        dailyAttendance.put("isAbnormal",true);
                    }else{
                        //显示俩种状态
                        String[] attendanceStatusArray = new String[2];
                        attendanceStatusArray[0]= (String) dailyAttendance.get("goToWorkStatus");
                        attendanceStatusArray[1]= (String) dailyAttendance.get("goOffWorkStatus");
                        dailyAttendance.put("isAbnormal",false);
                        if("迟到".equals(dailyAttendance.get("goToWorkStatus"))){
                            attendanceStatusArray[0]="迟到"+dailyAttendance.get("goToWorkTime") +"分";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("早退".equals(dailyAttendance.get("goOffWorkStatus"))){
                            attendanceStatusArray[1]="早退"+dailyAttendance.get("goOffWorkTime") +"分";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("旷工".equals(dailyAttendance.get("goToWorkStatus"))){
                            attendanceStatusArray[0]="旷工"+dailyAttendance.get("goToWorkTime") +"天";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("旷工".equals(dailyAttendance.get("goOffWorkStatus"))){
                            attendanceStatusArray[0]="旷工"+dailyAttendance.get("goOffWorkTime") +"天";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("未打卡".equals(dailyAttendance.get("goToWorkStatus"))||"未打卡".equals(dailyAttendance.get("goOffWorkStatus"))){
                            dailyAttendance.put("isAbnormal",true);
                        }
                        attendanceStatusList.add(attendanceStatusArray[0]);
                        attendanceStatusList.add(attendanceStatusArray[1]);
                    }
                    dailyAttendance.put("descr",attendanceStatusList);
                }
              /*  String[] attendanceStatusArray = new String[2];
                dailyAttendance.put("date",dailyAttendance.get("workDay"));
                dailyAttendance.put("isAbnormal",true);
                if("正常".equals(dailyAttendance.get("goToWorkStatus"))&&"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusArray[0]= (String) dailyAttendance.get("goToWorkStatus");
                    }
                    dailyAttendance.put("descr",attendanceStatusArray);
                }
                }*/
            });
            List<Map<String, Object>> dataList = attendanceReportResponse.getData();
          /*  List<Map<String, Object>> dataList = attendanceReportResponse.getData();
            dataList.forEach((data)->{
                String[] attendanceStatus = (String[]) data.get("descr");
                if(null!=attendanceStatus&&attendanceStatus.length>0){
                        data.put("descr",attendanceStatusArray);
                    }
                }
            });
            });*/
            HashMap<String, Object> attendanceReportMap = new HashMap<>();
            attendanceReportMap.put("userId",params.get("id"));
        CommonResponse<PageBean<Map<String,Object>>>  attendanceReport = null;
        try {
            attendanceReport = attendanceStatusQuery.queryDailyAttendanceReport((new CommonRequest<>(params,pageNumber,pageSize)));
            
            if (!attendanceReport.isSuccess()) {
            	return attendanceReport;
			}
            
            if (attendanceReport.getData()==null||CollectionUtils.isEmpty(attendanceReport.getData().getData())) {
				return CommonResponse.ok(new PageBean<Map<String,Object>>(new ArrayList<Map<String,Object>>(), pageSize, pageNumber, 1, 1));
			}
            
            List<Map<String, Object>> dailyAttendanceList = attendanceReport.getData().getData();
            dailyAttendanceList.forEach((dailyAttendance)->{
                mainjobpositionList.forEach((mainjobposition)->{
                        dailyAttendance.put("goOffWorkStatus", clockingStatus.getValue());
                    }
                });
                //存放考勤状态
                ArrayList<Object> attendanceStatusList = new ArrayList<>();
                //判断是否是外勤
                if (dailyAttendance.get("goToWorkExceptionStatus")!=null&& "FIE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("上午外勤");
                }
                if (dailyAttendance.get("goOffWorkExceptionStatus")!=null&&"FIE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("下午外勤");
                }
                //判断是否是加班
                if (dailyAttendance.get("goToWorkExceptionStatus")!=null&& "OVE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("上午加班");
                }
                if (dailyAttendance.get("goOffWorkExceptionStatus")!=null&&"OVE".equals(dailyAttendance.get("goToWorkExceptionStatus") )) {
                    attendanceStatusList.add("下午加班");
                }
                String[] attendanceStatusArray = new String[2];
                //如果都正常有外勤显示外勤，没外勤显示正常，不属于异常考勤
                if("正常".equals(dailyAttendance.get("goToWorkStatus"))&&"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    if(!(null!=attendanceStatusList&&attendanceStatusList.size()>0)){
                        attendanceStatusList.add("正常");
                    }
                    dailyAttendance.put("isAbnormal",false);
                }
                //如果上午正常，下午非正常 则显示下午的
                if("正常".equals(dailyAttendance.get("goToWorkStatus"))&&!"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    if("迟到".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add("迟到"+dailyAttendance.get("goOffWorkTime") +"分");
                    }
                    if("早退".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add("早退"+dailyAttendance.get("goOffWorkTime") +"分");
                    }
                    if("旷工".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add("旷工"+dailyAttendance.get("goToWorkTime") +"天");
                    }
                    if("倒休".equals(dailyAttendance.get("goOffWorkStatus"))||"事假".equals(dailyAttendance.get("goOffWorkStatus"))||"年假".equals(dailyAttendance.get("goOffWorkStatus"))||"放假".equals(dailyAttendance.get("goOffWorkStatus"))||"病假".equals(dailyAttendance.get("goOffWorkStatus"))){
                        attendanceStatusList.add(dailyAttendance.get("goOffWorkStatus"));
                        dailyAttendance.put("isAbnormal",false);
                    }else{
                        dailyAttendance.put("isAbnormal",true);
                    }
                }
                //如果上午非正常，下午正常 则显示上午的
                if(!"正常".equals(dailyAttendance.get("goToWorkStatus"))&&"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    if("迟到".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("迟到"+dailyAttendance.get("goToWorkTime") +"分");
                    }
                    if("早退".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("早退"+dailyAttendance.get("goToWorkTime") +"分");
                    }
                    if("旷工".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("旷工"+dailyAttendance.get("goToWorkTime") +"天");
                    }
                    if("倒休".equals(dailyAttendance.get("goToWorkStatus"))||"事假".equals(dailyAttendance.get("goToWorkStatus"))||"年假".equals(dailyAttendance.get("goToWorkStatus"))||"放假".equals(dailyAttendance.get("goToWorkStatus"))||"病假".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add(dailyAttendance.get("goToWorkStatus"));
                        dailyAttendance.put("isAbnormal",false);
                    }else{
                        dailyAttendance.put("isAbnormal",true);
                    }
                }
                //如果上午非正常，下午非正常
                if(!"正常".equals(dailyAttendance.get("goToWorkStatus"))&&!"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    //如果上下午状态相等且是放假 倒休 事假 年假 病假 放假 显示一种状态 非异常考勤
                    if(dailyAttendance.get("goToWorkStatus").equals(dailyAttendance.get("goOffWorkStatus"))&&("倒休".equals(dailyAttendance.get("goToWorkStatus"))||"事假".equals(dailyAttendance.get("goToWorkStatus"))||"年假".equals(dailyAttendance.get("goToWorkStatus"))||"放假".equals(dailyAttendance.get("goToWorkStatus"))||"病假".equals(dailyAttendance.get("goToWorkStatus")))){
                        attendanceStatusList.add(dailyAttendance.get("goToWorkStatus"));
                        dailyAttendance.put("isAbnormal",false);
                    }
                    //如果上下午状态相等且是旷工 显示一种状态 异常考勤
                    else if(dailyAttendance.get("goToWorkStatus").equals(dailyAttendance.get("goOffWorkStatus"))&&"旷工".equals(dailyAttendance.get("goToWorkStatus"))){
                        attendanceStatusList.add("旷工1天");
                        dailyAttendance.put("isAbnormal",true);
                    }else{
                        //显示俩种状态
                        String[] attendanceStatusArray = new String[2];
                        attendanceStatusArray[0]= (String) dailyAttendance.get("goToWorkStatus");
                        attendanceStatusArray[1]= (String) dailyAttendance.get("goOffWorkStatus");
                        dailyAttendance.put("isAbnormal",false);
                        if("迟到".equals(dailyAttendance.get("goToWorkStatus"))){
                            attendanceStatusArray[0]="迟到"+dailyAttendance.get("goToWorkTime") +"分";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("早退".equals(dailyAttendance.get("goOffWorkStatus"))){
                            attendanceStatusArray[1]="早退"+dailyAttendance.get("goOffWorkTime") +"分";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("旷工".equals(dailyAttendance.get("goToWorkStatus"))){
                            attendanceStatusArray[0]="旷工"+dailyAttendance.get("goToWorkTime") +"天";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("旷工".equals(dailyAttendance.get("goOffWorkStatus"))){
                            attendanceStatusArray[0]="旷工"+dailyAttendance.get("goOffWorkTime") +"天";
                            dailyAttendance.put("isAbnormal",true);
                        }
                        if("未打卡".equals(dailyAttendance.get("goToWorkStatus"))||"未打卡".equals(dailyAttendance.get("goOffWorkStatus"))){
                            dailyAttendance.put("isAbnormal",true);
                        }
                        attendanceStatusList.add(attendanceStatusArray[0]);
                        attendanceStatusList.add(attendanceStatusArray[1]);
                    }
                    dailyAttendance.put("descr",attendanceStatusList);
                }
               /* String[] attendanceStatusArray = new String[2];
                if("正常".equals(dailyAttendance.get("goToWorkStatus"))&&"正常".equals(dailyAttendance.get("goOffWorkStatus"))){
                    //上下班都正常
                        attendanceStatusArray[0]= (String) dailyAttendance.get("goToWorkStatus");
                    }
                    dailyAttendance.put("descr",attendanceStatusArray);
                }
                }*/
            });
        } catch (ParseException e) {
            e.printStackTrace();
        }
        List<Map<String, Object>> dataList = attendanceReport.getData().getData();
       /* List<Map<String, Object>> dataList = attendanceReport.getData().getData();
        dataList.forEach((data)->{
            String[] attendanceStatus = (String[]) data.get("attendanceStatus");
            if(null!=attendanceStatus&&attendanceStatus.length>0){
                    data.put("attendanceStatus",attendanceStatusArray);
                }
            }
        });
        });*/
        return attendanceReport;
    }
}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/task/AiResultRecordKafkaTask.java

import org.apache.commons.lang.StringUtils;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.junit.Assert;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
	@Autowired
	private ResourceToolManageService resourceToolManageService;
	
	@Autowired
	private MonitorSceneQuery monitorSceneQuery;
	
	@Autowired
	private AiAlarmManageService aiAlarmManageService;
	
	@KafkaListener(containerFactory = "kafkaBatchListener6", topics = "${kafka.topic.aitask:topic_ai_task}", groupId = "ai_group")
	public void AiResultRecordListener(ConsumerRecord<String, String> records, Acknowledgment ack) throws Throwable {
			log.info("已接AI任务执行结果消息，消息为：" + message);
			JSONObject messageJson = JSONObject.parseObject(message);
			String resourceToolCod=messageJson.getString("resourceToolCode");
			String aiIdenModel=messageJson.getString("aiIdenModel");
			String idenResultType=messageJson.getString("idenResultType");
			
			//查询相关数据
			String resourceToolCod = messageJson.getString("resourceToolCode");
			String aiIdenModel = messageJson.getString("aiIdenModel");
			String idenResultType = messageJson.getString("idenResultType");
			// 查询相关数据
			Map<String, Object> resourceToolMap = resourceToolManageService.queryResourceToolByCode(resourceToolCod);
			if (resourceToolMap == null) {
				log.error("AI任务执行结果的设备CODE不存在:  resourceToolCode=" + messageJson.getString("resourceToolCode"));
				throw new NullPointerException("resourceToolCode not exist");
			}
			
			String resourceToolId=String.valueOf(resourceToolMap.get("resourceToolId"));
			
			CommonResponse<List<Map<String, Object>>> sceneTerminalRelResponse =monitorSceneQuery.selectSceneTerminalRel(new CommonRequest<Long>(Long.valueOf(resourceToolId)));
			if (sceneTerminalRelResponse == null||CollectionUtils.isEmpty(sceneTerminalRelResponse.getData())) {
			String resourceToolId = String.valueOf(resourceToolMap.get("resourceToolId"));
			CommonResponse<List<Map<String, Object>>> sceneTerminalRelResponse = monitorSceneQuery
					.selectSceneTerminalRel(new CommonRequest<Long>(Long.valueOf(resourceToolId)));
			if (sceneTerminalRelResponse == null || CollectionUtils.isEmpty(sceneTerminalRelResponse.getData())) {
				log.error("AI任务执行结果的关联场景不存在:  resourceToolId=" + resourceToolId);
				throw new NullPointerException("sceneTerminalRel not exist");
			}
			Map<String,Object> sceneTerminalRelMap=sceneTerminalRelResponse.getData().get(0);
			
			CommonResponse<List<Map<String, Object>>> aiTaskResponse = aiAlarmManageService.queryAiTaskByDevice(resourceToolId, aiIdenModel);
			if (aiTaskResponse == null||CollectionUtils.isEmpty(aiTaskResponse.getData())) {
				log.error("AI任务执行结果的任务不存在:  resourceToolId=" + resourceToolId+", aiIdenModel="+aiIdenModel);
			Map<String, Object> sceneTerminalRelMap = sceneTerminalRelResponse.getData().get(0);
			CommonResponse<List<Map<String, Object>>> aiTaskResponse = aiAlarmManageService
					.queryAiTaskByDevice(resourceToolId, aiIdenModel);
			if (aiTaskResponse == null || CollectionUtils.isEmpty(aiTaskResponse.getData())) {
				log.error("AI任务执行结果的任务不存在:  resourceToolId=" + resourceToolId + ", aiIdenModel=" + aiIdenModel);
				throw new NullPointerException("aiTask not exist");
			}
			Map<String, Object> aiTaskMap=aiTaskResponse.getData().get(0);
			
			//封装数据
			Map<String, Object> aiTaskMap = aiTaskResponse.getData().get(0);
			// 封装数据
			AiIdenLog aiIdenLog = JSON.parseObject(message, new TypeReference<AiIdenLog>() {
			});
			aiIdenLog.setResourceToolId(resourceToolId);
			aiIdenLog.setResourceToolName(StringUtils.defaultIfBlank(String.valueOf(resourceToolMap.get("resourceToolName")),""));
			aiIdenLog.setMonitorSceneId(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("monitorSceneId")),""));
			aiIdenLog.setMonitorSceneName(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("monitorSceneName")),""));
			//aiIdenLog.setEffectType(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("effectType")),EbcConstant.TERMINAL_EFFECT_TYPE_OTH));
			aiIdenLog.setTerminalPosition(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("place")),""));
			aiIdenLog.setOrganizationId(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("orgId")),""));
			aiIdenLog.setAiTaskId(aiTaskMap.get("aiTaskId")==null?0L:Long.valueOf(String.valueOf(aiTaskMap.get("aiTaskId"))));
			
			//TODO 人员信息暂时默认
			aiIdenLog.setResourceToolName(
					StringUtils.defaultIfBlank(String.valueOf(resourceToolMap.get("resourceToolName")), ""));
			aiIdenLog.setMonitorSceneId(
					StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("monitorSceneId")), ""));
			aiIdenLog.setMonitorSceneName(
					StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("monitorSceneName")), ""));
			// aiIdenLog.setEffectType(StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("effectType")),EbcConstant.TERMINAL_EFFECT_TYPE_OTH));
			aiIdenLog.setTerminalPosition(
					StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("place")), ""));
			aiIdenLog.setOrganizationId(
					StringUtils.defaultIfBlank(String.valueOf(sceneTerminalRelMap.get("orgId")), ""));
			aiIdenLog.setAiTaskId(
					aiTaskMap.get("aiTaskId") == null ? 0L : Long.valueOf(String.valueOf(aiTaskMap.get("aiTaskId"))));
			// TODO 人员信息暂时默认
			aiIdenLog.setRelateEmployeeRoleId("201613310867");
			aiIdenLog.setRelateEmployeeRoleName("王浩");
			//执行操作
			CommonRequest<AiIdenLog> aiIdenLogRequest=new CommonRequest<AiIdenLog>(aiIdenLog);
			
			// 执行操作
			CommonRequest<AiIdenLog> aiIdenLogRequest = new CommonRequest<AiIdenLog>(aiIdenLog);
			CommonResponse<AiIdenLog> runningResult = aiTaskCommand.createAiIdenLog(aiIdenLogRequest);
			log.debug("aiTaskResult runningResult: \n{}", JsonUtils.toJSONStringByDateFormat(runningResult, true));
			Assert.assertTrue(runningResult.isSuccess());
			
			log.debug("AI任务执行结果: \n{}", JsonUtils.toJSONStringByDateFormat(runningResult, true));
			if (!runningResult.isSuccess()) {
				log.error("AI任务执行结果异常: " + runningResult.getFail().getMessage());
				return;
			}
			if (!EbcConstant.AI_IDENTIFY_RESULT_NORMAL.equals(idenResultType)) {
				CommonResponse runningResult1 = aiTaskCommand.aiIdenLogTriggerEvent(aiIdenLogRequest);
				
				log.debug("AI任务非正常情况的执行结果: \n{}", JsonUtils.toJSONStringByDateFormat(runningResult1, true));
				Assert.assertTrue(runningResult1.isSuccess());
				if (!runningResult.isSuccess()) {
					log.error("AI任务非正常情况的执行结果异常: " + runningResult.getFail().getMessage());
					return;
				}
			}
		} catch (Exception e) {
			log.error("kafka消费异常" + e.getMessage(), e);
			log.error("AI任务执行结果消费异常" + e.getMessage(), e);
		} finally {
			ack.acknowledge();// 手动提交偏移量
		}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/task/AiVideoKafkaTask.java

import java.util.Map;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.junit.Assert;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
			Map<String, Object> resourceToolMap = resourceToolManageService
					.queryResourceToolByCode(messageJson.getString("resourceToolCode"));
			if (resourceToolMap==null) {
			if (resourceToolMap == null) {
				log.error("AI监控视频日志的设备CODE不存在: " + messageJson.getString("resourceToolCode"));
				throw new NullPointerException("resourceToolCode not exist");
			}
			
			MonitorVideoLog monitorVideoLog = JSON.parseObject(message, new TypeReference<MonitorVideoLog>() {
			});
			monitorVideoLog.setResourceToolId(String.valueOf(resourceToolMap.get("resourceToolId")));
			CommonResponse<MonitorVideoLog> runningResult = monitorVideoLogManageService
					.createMonitorVideoLog(monitorVideoLog);
			log.debug("kafka aivideo runningResult: \n{}", JsonUtils.toJSONStringByDateFormat(runningResult, true));
			Assert.assertTrue(runningResult.isSuccess());
			log.debug("AI监控视频日志执行结果: \n{}", JsonUtils.toJSONStringByDateFormat(runningResult, true));
			if (!runningResult.isSuccess()) {
				log.error("AI监控视频日志执行结果异常: " + runningResult.getFail().getMessage());
				return;
			}
		} catch (Exception e) {
			log.error("AI监控视频日志消息的kafka消费异常: " + e.getMessage(), e);

security-protection-service/src/main/resources/application.properties

kafka.bootstrap-servers=10.19.90.34:9090
kafka.topic.aitask=topic_ai_task
kafka.topic.aivideo=topic_ai_video
#kafka.topic.aitask=topicTaskTest
#kafka.topic.aivideo=topicVideoTest
kafka.producer.batch-size=16785
kafka.producer.retries=1
kafka.producer.buffer-memory=33554432