修改AI报警处理人字段

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

	*                            statusList: 处理状态列表
	* @return 结果集，具体如下：
	*                            状态、状态时间、处理详情、报警类型、报警描述、设备名称、设备编号、设备位置、报警时间、处理人、处理时间、图片url、视频url
	 * @throws Exception 
	*/
	@ResponseBody
	@RequestMapping("/queryPageAiAlarm")
	public CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(@ModelAttribute AiQuery aiQuery) {
	public CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(@ModelAttribute AiQuery aiQuery) throws Exception {
		// 当前页数
		int pageNumber = aiQuery.getPageNumber() < 1 ? 1 : aiQuery.getPageNumber();
		// 每页条数

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

import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.characteristic.spec.model.CharacteristicSpecValue;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.security.protection.model.EbcMonitorVideoLog;
import com.ai.bss.security.protection.service.interfaces.AiAlarmManageService;
import com.ai.bss.security.protection.service.interfaces.CharSpecService;
import com.ai.bss.security.protection.service.interfaces.MonitorVideoLogManageService;
import com.ai.bss.security.protection.utils.EbcConstant;
import com.ai.bss.user.dto.EmployeeDto;
import com.ai.bss.user.service.api.EmployeeService;
import com.ai.bss.work.safety.model.AiModel;
import com.ai.bss.work.safety.model.WorkTaskSafetyAlarm;
import com.ai.bss.work.safety.service.api.AiTaskQuery;
import com.ai.bss.work.service.api.WorkTaskCommand;
import com.ai.bss.work.task.model.common.WorkTask;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
/**
 */
@Service
public class AiAlarmManageServiceImpl implements AiAlarmManageService {
    @Autowired
    WorkTaskCommand workTaskCommand;
    
    @Autowired
    AiTaskQuery aiTaskQuery;
	@Autowired
	WorkTaskCommand workTaskCommand;
    @Autowired
    CharSpecService charSpecService;
	@Autowired
	AiTaskQuery aiTaskQuery;
    @Autowired
    EmployeeService employeeService;
	@Autowired
	CharSpecService charSpecService;
	@Autowired
	EmployeeService employeeService;
    @Autowired
	@Autowired
	private UploadFileService uploadFileService;
    
	@Autowired
	private MonitorVideoLogManageService monitorVideoLogManageService;
    @Override
    public CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(Map<String, Object> params, int pageNumber, int pageSize) {
        //在特征表获取职务值
        List<CharacteristicSpecValue> aiAlarmTypeList = charSpecService.getCharSpecList(EbcConstant.AI_ALARM_TYPE);
        CommonResponse<PageBean<Map<String, Object>>> queryResult = aiTaskQuery.queryMonitorAlarmTask(new CommonRequest<>(params, pageNumber, pageSize));
        List<Map<String, Object>> aiAlarmList = queryResult.getData().getData();
        aiAlarmList.forEach((aiAlarm)->{
            //根据处理人id查找姓名
            if(null!=aiAlarm.get("workEmployeeRoleId")){
                long relateEmployeeRoleId = Long.parseLong((String) aiAlarm.get("workEmployeeRoleId"));
                EmployeeDto employeeDto = new EmployeeDto();
                employeeDto.setId(relateEmployeeRoleId);
                CommonRequest<EmployeeDto> request = CommonRequest.<EmployeeDto>builder().data(employeeDto).build();
                CommonResponse<EmployeeDto> response = employeeService.queryEmployee(request);
                EmployeeDto employee = response.getData();
                if(employee!=null){
                    aiAlarm.put("workEmployeeRoleName", employee.getName());
                }else{
                    aiAlarm.put("workEmployeeRoleName", aiAlarm.get("workEmployeeRoleId"));
                }
            }
            //根据报警类型查找报警中文名字
	@Override
	public CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(Map<String, Object> params, int pageNumber,
			int pageSize) throws Exception {
		// 在特征表获取职务值
		List<CharacteristicSpecValue> aiAlarmTypeList = charSpecService.getCharSpecList(EbcConstant.AI_ALARM_TYPE);
		CommonResponse<PageBean<Map<String, Object>>> queryResult = aiTaskQuery
				.queryMonitorAlarmTask(new CommonRequest<>(params, pageNumber, pageSize));
		if (queryResult == null || queryResult.getData() == null
				|| CollectionUtils.isEmpty(queryResult.getData().getData())) {
			return queryResult;
		}
		List<Map<String, Object>> aiAlarmList = queryResult.getData().getData();
		for (Map<String, Object> aiAlarm : aiAlarmList) {
			aiAlarm.put("workEmployeeRoleName", "");
			aiAlarm.put("processTime", "");
			
			if (WorkTask.END_STATUS.equals(String.valueOf(aiAlarm.get("status")))) {
				// 根据处理人id查找姓名
				if (null != aiAlarm.get("processEmployeeRoleId")) {
					long processEmployeeRoleId = Long
							.parseLong((String) aiAlarm.get("processEmployeeRoleId").toString());
					EmployeeDto processEmployeeDto = new EmployeeDto();
					processEmployeeDto.setId(processEmployeeRoleId);
					CommonRequest<EmployeeDto> request = new CommonRequest<EmployeeDto>(processEmployeeDto);
					CommonResponse<EmployeeDto> response = employeeService.queryEmployee(request);
					processEmployeeDto = response.getData();
					if (processEmployeeDto != null) {
						aiAlarm.put("workEmployeeRoleName", processEmployeeDto.getName());
					}
					// 处理时间
					aiAlarm.put("processTime", DateUtil.formatObjectToDate(aiAlarm.get("processTime")));
				}
			}
			// 根据报警类型查找报警中文名字
			aiAlarm.put("alarmTypeName", aiAlarm.get("alarmTypeCode"));
            aiAlarmTypeList.forEach((aiAlarmType) -> {
                if (aiAlarmType.getCode().equals(aiAlarm.get("alarmTypeCode"))) {
                    aiAlarm.put("alarmTypeName", aiAlarmType.getValue());
                }
            });
        });
        return queryResult;
    }
    @Override
    public CommonResponse<WorkTask> changeTaskStatus(CommonRequest<WorkTask> workTaskRequest) {
    	CommonResponse<WorkTask> changeResultResponse = workTaskCommand.changeTaskStatus(workTaskRequest);
        return changeResultResponse;
    }
    
			aiAlarmTypeList.forEach((aiAlarmType) -> {
				if (aiAlarmType.getCode().equals(aiAlarm.get("alarmTypeCode"))) {
					aiAlarm.put("alarmTypeName", aiAlarmType.getValue());
				}
			});
		}
		return queryResult;
	}
	@Override
	public CommonResponse<WorkTask> changeTaskStatus(CommonRequest<WorkTask> workTaskRequest) {
		CommonResponse<WorkTask> changeResultResponse = workTaskCommand.changeTaskStatus(workTaskRequest);
		return changeResultResponse;
	}
	@Override
	public CommonResponse<List<Map<String, Object>>> queryAiTaskByDevice(String resourceToolId, String aiIdenModel) {
		Map<String, Object> conditionMap = new HashMap<String, Object>();
        conditionMap.put("resourceToolId", resourceToolId);
        conditionMap.put("aiIdenModel", aiIdenModel);
        CommonRequest<Map<String, Object>> request=new CommonRequest<Map<String, Object>>(conditionMap);
        return aiTaskQuery.selectAiTaskDevice(request);
		conditionMap.put("resourceToolId", resourceToolId);
		conditionMap.put("aiIdenModel", aiIdenModel);
		CommonRequest<Map<String, Object>> request = new CommonRequest<Map<String, Object>>(conditionMap);
		return aiTaskQuery.selectAiTaskDevice(request);
	}
	@Override
	public CommonResponse<Map<String, Object>> queryOneAiAlarmInfo(String workTaskId) throws Exception {
		CommonRequest<String> request = new CommonRequest<String>(workTaskId);
		CommonResponse<WorkTaskSafetyAlarm> response = aiTaskQuery.queryWorkTaskSafetyAlarmById(request);
		
		if (response==null||response.getData()==null) {
		if (response == null || response.getData() == null) {
			return CommonResponse.fail("504", "获取失败");
		}
		
		//报警详细信息
		Map<String, String> workTaskSafetyAlarmMap= JSON.parseObject(JSON.toJSONString(response.getData()), new TypeReference<Map<String, String>>() {
        });
		
		List<CharacteristicSpecValue> aiAlarmTypeList = charSpecService.getCharSpecList(EbcConstant.BUSINESS_SPEC_AI_ALARM_TYPE);
		// 报警详细信息
		Map<String, String> workTaskSafetyAlarmMap = JSON.parseObject(JSON.toJSONString(response.getData()),
				new TypeReference<Map<String, String>>() {
				});
		List<CharacteristicSpecValue> aiAlarmTypeList = charSpecService
				.getCharSpecList(EbcConstant.BUSINESS_SPEC_AI_ALARM_TYPE);
		for (CharacteristicSpecValue characteristicSpecValue : aiAlarmTypeList) {
			if (characteristicSpecValue.getCode().equals(workTaskSafetyAlarmMap.get("alarmTypeCode"))) {
				workTaskSafetyAlarmMap.put("alarmTypeCodeZh",characteristicSpecValue.getValue());
				workTaskSafetyAlarmMap.put("alarmTypeCodeZh", characteristicSpecValue.getValue());
				break;
			}
		}
		List<CharacteristicSpecValue> aiAlarmStatusList = charSpecService.getCharSpecList(EbcConstant.BUSINESS_SPEC_AI_TASK_STATUS);
		List<CharacteristicSpecValue> aiAlarmStatusList = charSpecService
				.getCharSpecList(EbcConstant.BUSINESS_SPEC_AI_TASK_STATUS);
		for (CharacteristicSpecValue characteristicSpecValue : aiAlarmStatusList) {
			if (characteristicSpecValue.getCode().equals(workTaskSafetyAlarmMap.get("status"))) {
				workTaskSafetyAlarmMap.put("statusZh",characteristicSpecValue.getValue());
				workTaskSafetyAlarmMap.put("statusZh", characteristicSpecValue.getValue());
				break;
			}
		}
		
		if(StringUtils.isNotEmpty(workTaskSafetyAlarmMap.get("workEmployeeRoleId"))){
            long relateEmployeeRoleId = Long.parseLong(workTaskSafetyAlarmMap.get("workEmployeeRoleId"));
            EmployeeDto employeeDto = new EmployeeDto();
            employeeDto.setId(relateEmployeeRoleId);
            CommonRequest<EmployeeDto> employeeDtoRequest = new CommonRequest<EmployeeDto>(employeeDto);
            CommonResponse<EmployeeDto> employeeDtoResponse = employeeService.queryEmployee(employeeDtoRequest);
            if (employeeDtoResponse==null||employeeDtoResponse.getData()==null) {
            	workTaskSafetyAlarmMap.put("workEmployeeRoleName","--");
			}else {
				workTaskSafetyAlarmMap.put("workEmployeeRoleName",employeeDtoResponse.getData().getName());
		workTaskSafetyAlarmMap.put("workEmployeeRoleName", "--");
		workTaskSafetyAlarmMap.put("disposeDate", "");
		if (WorkTask.END_STATUS.equals(workTaskSafetyAlarmMap.get("status"))
				|| WorkTask.FALSE_ALARM_STATUS.equals(workTaskSafetyAlarmMap.get("status"))) {
			workTaskSafetyAlarmMap.put("disposeDate", DateUtil.formatDate(response.getData().getDoneDate()));
			if (StringUtils.isNotEmpty(response.getData().getOpId())) {
				long relateEmployeeRoleId = Long.parseLong(response.getData().getOpId());
				EmployeeDto employeeDto = new EmployeeDto();
				employeeDto.setId(relateEmployeeRoleId);
				CommonRequest<EmployeeDto> employeeDtoRequest = new CommonRequest<EmployeeDto>(employeeDto);
				CommonResponse<EmployeeDto> employeeDtoResponse = employeeService.queryEmployee(employeeDtoRequest);
				if (employeeDtoResponse != null && employeeDtoResponse.getData() != null) {
					workTaskSafetyAlarmMap.put("workEmployeeRoleName", employeeDtoResponse.getData().getName());
				}
			}
        }
		
		if (WorkTask.END_STATUS.equals(workTaskSafetyAlarmMap.get("status"))||WorkTask.FALSE_ALARM_STATUS.equals(workTaskSafetyAlarmMap.get("status"))) {
			workTaskSafetyAlarmMap.put("disposeDate",DateUtil.formatDate(response.getData().getDoneDate()));
		}else {
			workTaskSafetyAlarmMap.put("disposeDate","");
		}
		
		workTaskSafetyAlarmMap.put("createDate",DateUtil.formatDate(response.getData().getCreateDate()));
		workTaskSafetyAlarmMap.put("aiIdenTime",DateUtil.formatDate(response.getData().getAiIdenTime()));
		
		//图片信息
		Map<String, String> pictureMap= uploadFileService.getFileUrlToMap(workTaskSafetyAlarmMap.get("idenPictureUrl"));
		
		//视频信息
		workTaskSafetyAlarmMap.put("createDate", DateUtil.formatDate(response.getData().getCreateDate()));
		workTaskSafetyAlarmMap.put("aiIdenTime", DateUtil.formatDate(response.getData().getAiIdenTime()));
		// 图片信息
		Map<String, String> pictureMap = uploadFileService
				.getFileUrlToMap(workTaskSafetyAlarmMap.get("idenPictureUrl"));
		// 视频信息
		/*List<EbcMonitorVideoLog> logsList=monitorVideoLogManageService.getMonitorVideoLogByPictureTime(pictureMap.get("fileDateTimeStr"), workTaskSafetyAlarmMap.get("resourceToolId")).getData();
		EbcMonitorVideoLog ebcMonitorVideoLog=null;
		if (!CollectionUtils.isEmpty(logsList)) {
			ebcMonitorVideoLog=logsList.get(0);
			ebcMonitorVideoLog.setVideoFileUrl(uploadFileService.getFileUrl(ebcMonitorVideoLog.getVideoUrl()));
		}*/
		String videoFileUrl =monitorVideoLogManageService.getMonitorVideoLogByPictureTime(pictureMap.get("fileDateTimeStr"), workTaskSafetyAlarmMap.get("resourceToolId")).getData();
		
		Map<String,Object> resultMap= new HashMap<String, Object>();
		String videoFileUrl = monitorVideoLogManageService.getMonitorVideoLogByPictureTime(
				pictureMap.get("fileDateTimeStr"), workTaskSafetyAlarmMap.get("resourceToolId")).getData();
		Map<String, Object> resultMap = new HashMap<String, Object>();
		resultMap.put("alarmInfo", workTaskSafetyAlarmMap);
		resultMap.put("pictureInfo", pictureMap);
		//resultMap.put("videoInfo", ebcMonitorVideoLog);
		// resultMap.put("videoInfo", ebcMonitorVideoLog);
		resultMap.put("videoInfo", videoFileUrl);
		return CommonResponse.ok(resultMap);
	}
	@Override
	public List<Map<String,Object>> queryAiAlarmCount(Map<String, Object> params) throws Exception {
		CommonRequest<Map<String, Object>> request=new CommonRequest<Map<String,Object>>(params);
        CommonResponse<List<Map<String,Object>>> response = aiTaskQuery.safetyAlarmStatusStatistics(request);
		
        List<Map<String,Object>> resultList=new ArrayList<Map<String,Object>>();
        long iniCount=0;
        long runCount=0;
        
        if (response!=null&&!CollectionUtils.isEmpty(response.getData())) {
	        for (Map<String, Object> map : response.getData()) {
	        	if (WorkTask.INIT_STATUS.equals(String.valueOf(map.get("status")))) {
	        		iniCount=(long)map.get("cn");
				}else if (WorkTask.RUNNING_STATUS.equals(String.valueOf(map.get("status")))){
					runCount=(long)map.get("cn");
	public List<Map<String, Object>> queryAiAlarmCount(Map<String, Object> params) throws Exception {
		CommonRequest<Map<String, Object>> request = new CommonRequest<Map<String, Object>>(params);
		CommonResponse<List<Map<String, Object>>> response = aiTaskQuery.safetyAlarmStatusStatistics(request);
		List<Map<String, Object>> resultList = new ArrayList<Map<String, Object>>();
		long iniCount = 0;
		long runCount = 0;
		if (response != null && !CollectionUtils.isEmpty(response.getData())) {
			for (Map<String, Object> map : response.getData()) {
				if (WorkTask.INIT_STATUS.equals(String.valueOf(map.get("status")))) {
					iniCount = (long) map.get("cn");
				} else if (WorkTask.RUNNING_STATUS.equals(String.valueOf(map.get("status")))) {
					runCount = (long) map.get("cn");
				}
			}
        }
        
        Map<String, Object> map=new HashMap<String, Object>();
        map.put("name", "ini");
        map.put("value", iniCount);
        resultList.add(map);
        
        map=new HashMap<String, Object>();
        map.put("name", "run");
        map.put("value", iniCount+runCount);
        resultList.add(map);
        
        return resultList;
		}
		Map<String, Object> map = new HashMap<String, Object>();
		map.put("name", "ini");
		map.put("value", iniCount);
		resultList.add(map);
		map = new HashMap<String, Object>();
		map.put("name", "run");
		map.put("value", iniCount + runCount);
		resultList.add(map);
		return resultList;
	}
}

security-protection-service/src/main/java/com/ai/bss/security/protection/service/interfaces/AiAlarmManageService.java

public interface AiAlarmManageService {
	CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(Map<String, Object> params, int pageNumber,
			int pageSize);
			int pageSize)throws Exception;
	CommonResponse<WorkTask> changeTaskStatus(CommonRequest<WorkTask> workTaskRequest);