AI接口提交

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

@@ -0,0 +1,102 @@
package com.ai.bss.security.protection.controller;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.security.protection.model.AiQuery;
import com.ai.bss.security.protection.model.AttendanceReport;
import com.ai.bss.security.protection.service.interfaces.AiAlarmManageService;
import com.ai.bss.security.protection.utils.EbcConstant;
import com.ai.bss.work.safety.model.AiTask;
import com.ai.bss.work.task.model.common.WorkTask;
import com.github.pagehelper.PageInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
/**
 * AI报警管理
 */
@Controller
@RequestMapping("/aiAlarmManage")
public class AiAlarmManageController {
	Logger logger = LoggerFactory.getLogger(AiAlarmManageController.class);
	@Autowired
	AiAlarmManageService aiAlarmManageService;
	 /**
	 * 分页查询AI报警（监控报警任务综合查询 ）
	 * @param aiQuery 查询条件，具体如下：
	 *                            workOrgRoleId: 组织ID
	 *                            alarmTypeCode: 报警类型
	 *                            targetEmployeeRoleId: 被报警人
	 *                            workEmployeeRoleId: 处理人
	 *                            beginTime: 报警开始时间
	 *                            endTime: 报警结束时间
	 *                            statusList: 处理状态列表
	 * @return 结果集，具体如下：
	 *                            状态、状态时间、处理详情、报警类型、报警描述、设备名称、设备编号、设备位置、报警时间、处理人、处理时间、图片url、视频url
	 */
	@ResponseBody
	@RequestMapping("/queryPageAiAlarm")
	public CommonResponse<PageBean<Map<String,Object>>> queryPageAiAlarm(@ModelAttribute AiQuery aiQuery)   {
		// 当前页数
		int pageNumber = aiQuery.getPageNumber() < 1 ? 1 : aiQuery.getPageNumber();
		// 每页条数
		int pageSize = aiQuery.getPageSize() < 1 ? EbcConstant.DEFAULT_PAGE_SIZE : aiQuery.getPageSize();
		Map<String, Object> params = new HashMap<>();
		params.put("workOrgRoleId",aiQuery.getWorkOrgRoleId());
		params.put("alarmTypeCode",aiQuery.getAlarmTypeCode());
		params.put("targetEmployeeRoleId",aiQuery.getTargetEmployeeRoleId());
		params.put("workEmployeeRoleId",aiQuery.getWorkEmployeeRoleId());
		params.put("beginTime",aiQuery.getBeginTime());
		params.put("endTime",aiQuery.getEndTime());
		params.put("statusList",aiQuery.getStatusList());
		CommonResponse<PageBean<Map<String,Object>>> commonResponse = aiAlarmManageService.queryPageAiAlarm(params, pageNumber, pageSize);
		return commonResponse;
	}
	/**
	 * 报警记录处理（包含 确认、误判、关闭 三个操作类型）（设置任务状态、状态时间、处理详情）
	 * 状态参考以下常量定义（定义在WorkTask类中）：
	 * public final static String INIT_STATUS = "INI"; // 初始化（未确认）
	 * public final static String RUNNING_STATUS = "RUN"; // 处理中
	 * public final static String END_STATUS = "END"; // 结束（已处理）
	 * public final static String FALSE_ALARM_STATUS = "FAL"; // 误报
	 *
	 * @param aiQuery 要修改的任务（workTaskId 任务ID，status 状态，statusTime 状态时间，processMemo处理详情必选）
	 * @return 修改过的任务对象响应
	 */
	@ResponseBody
	@RequestMapping("/changeTaskStatus")
	public  CommonResponse<WorkTask> changeTaskStatus(@RequestBody AiQuery aiQuery) {
		WorkTask workTask =new WorkTask();
		workTask.setStatusTime(new Date());
		workTask.setStatus(aiQuery.getStatus());
		workTask.setWorkTaskId(aiQuery.getWorkTaskId());
		workTask.setProcessMemo( aiQuery.getProcessMemo());
		CommonRequest<WorkTask> workTaskRequest=new CommonRequest(workTask);
		CommonResponse<WorkTask> commonResponse = aiAlarmManageService.changeTaskStatus(workTaskRequest);
		return commonResponse;
	}
}

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

@@ -0,0 +1,125 @@
package com.ai.bss.security.protection.controller;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.security.protection.model.AiQuery;
import com.ai.bss.security.protection.service.interfaces.SysConfigAiTaskService;
import com.ai.bss.security.protection.utils.EbcConstant;
import com.ai.bss.work.safety.model.AiTask;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * 系统配置-AI任务
 */
@Controller
@RequestMapping("/sysConfigAiTask")
public class SysConfigAiTaskController {
	Logger logger = LoggerFactory.getLogger(SysConfigAiTaskController.class);
	@Autowired
	SysConfigAiTaskService sysConfigAiTaskService;
	/**
	 * 分页查询AI任务
	 * @param  aiQuery
	 *                              workOrgId：组织标识
	 *                              name：名称（精确查询）
	 *                              nameAsLike：名称（模糊查询）
	 *                              aiIdenModel：匹配模型
	 *                              statusList：任务状态列表
	 *      @return 结果集，具体如下：
	 *      任务ID--aiTaskId，任务名称--aiTaskName，任务编号--aiTaskCode，匹配模型--aiIdenModel，
	 *      执行设备（executeDeviceString），创建时间--createDate，最后修改时间--doneDate，状态--aiTaskStatus
	 */
	@ResponseBody
	@RequestMapping("/queryPageAiTask")
	public  CommonResponse<PageBean<Map<String, Object>>> queryPageAiTask(@ModelAttribute AiQuery aiQuery) throws Exception {
		// 当前页数
		int pageNumber = aiQuery.getPageNumber() < 1 ? 1 : aiQuery.getPageNumber();
		// 每页条数
		int pageSize = aiQuery.getPageSize() < 1 ? EbcConstant.DEFAULT_PAGE_SIZE : aiQuery.getPageSize();
		Map<String, Object> params = new HashMap<>();
		params.put("workOrgId",aiQuery.getWorkOrgId());
		params.put("name",aiQuery.getName());
		params.put("nameAsLike",aiQuery.getNameAsLike());
		params.put("aiIdenModel",aiQuery.getAiIdenModel());
		params.put("statusList",aiQuery.getStatusList());
		CommonResponse<PageBean<Map<String, Object>>> commonResponse = sysConfigAiTaskService.queryPageAiTask(params, pageNumber, pageSize);
		return commonResponse;
	}
	/**
	 * 查询AI任务
	 * @param  aiTask
	 *            aiTaskId 按id查询
	 */
	@ResponseBody
	@RequestMapping("/queryAiTask")
	public  CommonResponse<AiTask> queryAiTaskById(@ModelAttribute AiTask aiTask) throws Exception {
		CommonResponse<AiTask> commonResponse = sysConfigAiTaskService.queryAiTaskById(aiTask);
		return commonResponse;
	}
	/**
	 * 创建AI任务
	 * @param  aiTask
	 *
	 */
	@ResponseBody
	@RequestMapping("/createAiTask")
	public  CommonResponse<AiTask> createAiTask(@RequestBody AiTask aiTask) throws Exception {
		CommonResponse<AiTask> commonResponse = sysConfigAiTaskService.createAiTask(aiTask);
		return commonResponse;
	}
	/**
	 * 修改AI任务
	 * @param  aiTask
	 *
	 */
	@ResponseBody
	@RequestMapping("/modifyAiTask")
	public  CommonResponse<AiTask> modifyAiTask(@RequestBody AiTask aiTask) throws Exception {
		CommonResponse<AiTask> commonResponse = sysConfigAiTaskService.modifyAiTask(aiTask);
		return commonResponse;
	}
	/**
	 * 删除AI任务
	 * @param  aiTaskIdList
	 *
	 */
	@ResponseBody
	@RequestMapping("/deleteAiTask")
	public  CommonResponse<AiTask> deleteAiTask(@RequestBody List<Long> aiTaskIdList)  {
		CommonResponse<AiTask> commonResponse = sysConfigAiTaskService.deleteAiTask(aiTaskIdList);
		return commonResponse;
	}
}

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

@@ -1,47 +0,0 @@
package com.ai.bss.security.protection.controller;
import com.ai.bss.security.protection.service.interfaces.AreaInRecordService;
import com.github.pagehelper.PageInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.Date;
import java.util.Map;
/**
 * 进出记录
 */
@Controller
@RequestMapping("/areaInOutRecordManage")
public class areaInOutRecordController {
	Logger logger = LoggerFactory.getLogger(areaInOutRecordController.class);
	@Autowired
	AreaInRecordService areaInRecordService;
	/**
	 * 分页查询考勤统计分析
	 */
	
	@ResponseBody
	@RequestMapping("/queryPageAttendanceCount")
	public PageInfo queryPageAttendanceCount(Map params) throws Exception {
		// 当前页数
		int pageNum = (int)params.get("pageNum") < 1 ? 1 : (int)params.get("pageNum");
		// 每页条数
		int pageSize = (int)params.get("pageSize") < 1 ? 1: (int)params.get("pageSize");
		if(params.get("currentDate")==null|| params.get("currentDate").equals("")){
			params.put("currentDate",new Date());
		}
		PageInfo pageInfo = areaInRecordService.queryPageAttendanceCount(params, pageNum, pageSize);
		return pageInfo;
	}
}

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

@@ -1,46 +0,0 @@
package com.ai.bss.security.protection.controller;
import com.ai.bss.security.protection.service.interfaces.AreaInRecordService;
import com.github.pagehelper.PageInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.Date;
import java.util.Map;
/**
 * 异常考勤
 */
@Controller
@RequestMapping("/attendanceConfiguration")
public class attendanceConfigurationController {
	Logger logger = LoggerFactory.getLogger(attendanceConfigurationController.class);
	@Autowired
	AreaInRecordService areaInRecordService;
	/**
	 * 分页查询考勤统计分析
	 */
	@ResponseBody
	@RequestMapping("/queryPageAttendanceCount")
	public PageInfo queryPageAttendanceCount(Map params) throws Exception {
		// 当前页数
		int pageNum = (int)params.get("pageNum") < 1 ? 1 : (int)params.get("pageNum");
		// 每页条数
		int pageSize = (int)params.get("pageSize") < 1 ? 1: (int)params.get("pageSize");
		if(params.get("currentDate")==null|| params.get("currentDate").equals("")){
			params.put("currentDate",new Date());
		}
		PageInfo pageInfo = areaInRecordService.queryPageAttendanceCount(params, pageNum, pageSize);
		return pageInfo;
	}
}

security-protection-service/src/main/java/com/ai/bss/security/protection/model/AiQuery.java

@@ -0,0 +1,51 @@
package com.ai.bss.security.protection.model;
import lombok.Data;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
/**
 * @Auther: 王超
 * @Date: 2020/12/8 17:37
 * @Description:
 */
@NoArgsConstructor
@Getter
@Setter
public class AiQuery {
    private int pageNumber; // 当前页数
    private int pageSize; // 每页条数
    private String workOrgId; // 组织标识
    private String name; // 名称（精确查询）
    private String nameAsLike; // 名称（模糊查询）
    private String aiIdenModel; // 匹配模型
    private String statusList; // 任务状态列表  处理状态列表
    private long aiTaskId; // 任务场景id
    private String alarmTypeCode; // 报警类型
    private String targetEmployeeRoleId; // 被报警人
    private String workEmployeeRoleId; // 处理人
    private String beginTime; // 报警开始时间
    private String endTime; // 报警结束时间
    private String workOrgRoleId; // 组织ID
    private String status; // 状态
    private String workTaskId; // 任务ID
    private String processMemo; // 处理详情必选
}

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

@@ -0,0 +1,38 @@
package com.ai.bss.security.protection.service.impl;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.security.protection.service.interfaces.AiAlarmManageService;
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 org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/8 16:42
 * @Description:
 */
@Service
public class AiAlarmManageServiceImpl implements AiAlarmManageService {
    @Autowired
    WorkTaskCommand workTaskCommand;
    @Autowired
    AiTaskQuery aiTaskQuery;
    @Override
    public CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(Map<String, Object> params, int pageNumber, int pageSize) {
        CommonResponse<PageBean<Map<String, Object>>> queryResult = aiTaskQuery.queryMonitorAlarmTask(
                new CommonRequest<>(params, pageNumber, pageSize));
        return queryResult;
    }
    @Override
    public CommonResponse<WorkTask> changeTaskStatus(CommonRequest<WorkTask> workTaskRequest) {
        CommonResponse changeResultResponse = workTaskCommand.changeTaskStatus(workTaskRequest);
        return changeResultResponse;
    }
}

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

@@ -0,0 +1,71 @@
package com.ai.bss.security.protection.service.impl;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.security.protection.model.AiQuery;
import com.ai.bss.security.protection.service.interfaces.SysConfigAiTaskService;
import com.ai.bss.work.safety.model.AiTask;
import com.ai.bss.work.safety.service.api.AiTaskCommand;
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 org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
 * @Auther: 王超
 * @Date: 2020/12/8 16:47
 * @Description:
 */
@Service
public class SysConfigAiTaskServiceImpl implements SysConfigAiTaskService {
    @Autowired
    AiTaskQuery aiTaskQuery;
    @Autowired
    AiTaskCommand aiTaskCommand;
    @Autowired
    WorkTaskCommand workTaskCommand;
    @Override
    public CommonResponse<PageBean<Map<String, Object>>> queryPageAiTask(Map<String, Object> params, int pageNumber, int pageSize) {
        CommonResponse<PageBean<Map<String, Object>>> queryResult = aiTaskQuery.queryAiTask(new CommonRequest<>(params, pageNumber, pageSize));
        return queryResult;
    }
    @Override
    public CommonResponse<AiTask> queryAiTaskById(AiTask aiTask) {
        CommonResponse<AiTask> aiTaskCommonResponse = aiTaskQuery.loadAiTask(new CommonRequest<>(aiTask.getAiTaskId()));
        return aiTaskCommonResponse;
    }
    @Override
    public CommonResponse<AiTask> createAiTask(AiTask aiTask) {
        CommonRequest<AiTask> aiTaskRequest=new CommonRequest<>(aiTask);
        CommonResponse<AiTask> runningResult = aiTaskCommand.createAiTask(aiTaskRequest);
        return runningResult;
    }
    @Override
    public CommonResponse<AiTask> deleteAiTask(List<Long> aiTaskLong) {
        CommonRequest<List<Long>> aiTaskRequest=new CommonRequest<>(aiTaskLong);
        CommonResponse<AiTask> runningResult = aiTaskCommand.deleteAiTask(aiTaskRequest);
        return runningResult;
    }
    @Override
    public CommonResponse<AiTask> modifyAiTask(AiTask aiTask) {
        CommonRequest<AiTask> aiTaskRequest=new CommonRequest<>(aiTask);
        CommonResponse<AiTask> runningResult = aiTaskCommand.modifyAiTask(aiTaskRequest);
        return runningResult;
    }
}

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

@@ -0,0 +1,14 @@
package com.ai.bss.security.protection.service.interfaces;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.work.task.model.common.WorkTask;
import java.util.Map;
public interface AiAlarmManageService {
    CommonResponse<PageBean<Map<String, Object>>> queryPageAiAlarm(Map<String, Object> params, int pageNumber, int pageSize);
    CommonResponse<WorkTask> changeTaskStatus(CommonRequest<WorkTask> workTaskRequest);
}

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

@@ -0,0 +1,24 @@
package com.ai.bss.security.protection.service.interfaces;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.security.protection.model.AiQuery;
import com.ai.bss.work.safety.model.AiTask;
import com.ai.bss.work.task.model.common.WorkTask;
import java.util.List;
import java.util.Map;
public interface SysConfigAiTaskService {
    CommonResponse<PageBean<Map<String, Object>>> queryPageAiTask(Map<String, Object> params, int pageNumber, int pageSize);
    CommonResponse<AiTask> queryAiTaskById(AiTask aiTask);
    CommonResponse<AiTask> createAiTask(AiTask aiTask);
    CommonResponse<AiTask> deleteAiTask(List<Long> aiTaskLong);
    CommonResponse<AiTask> modifyAiTask(AiTask aiTask);
}