package com.ld.igds.n2.manager;
|
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.common.CoreSerService;
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.io.RemoteControlService;
|
import com.ld.igds.io.RemoteManager;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.request.DeviceAutoControlRequest;
|
import com.ld.igds.io.response.DeviceControlResponse;
|
import com.ld.igds.models.DepotConf;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.models.N2IntelTask;
|
import com.ld.igds.n2.N2ModelTag;
|
import com.ld.igds.n2.N2Util;
|
import com.ld.igds.n2.dto.N2AutoData;
|
import com.ld.igds.n2.dto.N2Param;
|
import com.ld.igds.n2.dto.N2TaskParam;
|
import com.ld.igds.n2.service.HN2Service;
|
import com.ld.igds.util.ContextUtil;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
import java.util.List;
|
|
|
/**
|
* @Desc: 智能气调业务逻辑管理页面，主要包括气密性检测流程，智能气调流程控制管理
|
* @author: Andy
|
* @update-time: 2022/12/27
|
*/
|
@Slf4j
|
@Component
|
public class N2IntelManager {
|
|
@Autowired
|
private CoreCommonService coreCommonService;
|
@Autowired
|
private RemoteManager remoteManager;
|
@Autowired
|
private CoreSerService coreSerService;
|
@Autowired
|
private HN2Service hn2Service;
|
|
|
// /**
|
// * 智能气调操作入口，实现逻辑
|
// * 1，首先验证是否满足执行的标准，设备状态是否满足，当前是否有正在执行的智能任务，比如智能通风或者其他智能任务。
|
// * 2.将新增的任务添加到任务队列中，有系统自动调用参数判断执行
|
// *
|
// * @param autoData
|
// * @param param
|
// * @param modeClose 是否执行关闭操作，针对流程来讲关闭操作的动作是停止运行，不去回复已经打开的设备状态
|
// * @return
|
// */
|
// public DeviceControlResponse exeIntel(N2AutoData autoData, N2Param param, String modeClose) {
|
// String result;
|
// if (N2Util.EXE_MODE_02.equals(autoData.getExeMode())) {
|
// result = exeIntelBySer(autoData, param, modeClose);
|
// } else {
|
// result = exeIntelBySys(autoData, param, modeClose);
|
// }
|
//
|
// if (null == result) {
|
// return new DeviceControlResponse(
|
// OrderRespEnum.ORDER_SUCCESS.getCode(), "命令发送成功，待终端执行！");
|
// }
|
//
|
// return new DeviceControlResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
// result);
|
// }
|
//
|
// /**
|
// * 当前系统执行 智能化任务
|
// *
|
// * @param autoData
|
// * @param param
|
// * @param modeClose
|
// * @return
|
// */
|
// private String exeIntelBySys(N2AutoData autoData, N2Param param, String modeClose) {
|
//
|
// //如果执行关闭任务
|
// if (Constant.YN_Y.equals(modeClose)) {
|
// return exeStopIntel(autoData, param);
|
// }
|
//
|
// //正常开启任务，系统执行需要多验证设备状态是否满足开启任务条件
|
// boolean checkTag = n2TaskCheck(param.getCompanyId(), param.getDepotId());
|
// if (checkTag) {
|
// return "当前仓库有气调任务执行中，请先关闭当前子任务！";
|
// }
|
// checkTag = airTaskCheck(param.getCompanyId(), param.getDepotId());
|
// if (checkTag) {
|
// return "当前仓库有通风任务执行中，请先关闭当前子任务！";
|
// }
|
//
|
// checkTag = airDeviceStatus(param.getCompanyId(), param.getDepotId());
|
// if (checkTag) {
|
// return "当前仓库设备通风状态有开启，不能执行当前操作！";
|
// }
|
//
|
//
|
// //创建任务，任务创建可能有多个，主任务 + 子任务
|
// addN2TaskByAuto(autoData);
|
//
|
// return null;
|
// }
|
//
|
//
|
// /**
|
// * 智能控制柜执行智能化任务
|
// *
|
// * @param autoData
|
// * @param param
|
// * @param modeClose
|
// * @return
|
// */
|
// private String exeIntelBySer(N2AutoData autoData, N2Param param, String modeClose) {
|
//
|
// //如果执行关闭任务，先要发送通知给智能控制柜，然后关闭当前任务
|
// if (Constant.YN_Y.equals(modeClose)) {
|
// String msg = exeAutoActionBySer(autoData, param, modeClose);
|
// if (null == msg) {
|
// msg = exeStopIntel(autoData, param);
|
// }
|
// return msg;
|
// }
|
//
|
// //正常开启任务，控制柜执行不验证通风状态
|
// boolean checkTag = n2TaskCheck(param.getCompanyId(), param.getDepotId());
|
// if (checkTag) {
|
// return "当前仓库有气调任务执行中，请先关闭当前子任务！";
|
// }
|
// checkTag = airTaskCheck(param.getCompanyId(), param.getDepotId());
|
// if (checkTag) {
|
// return "当前仓库有通风任务执行中，请先关闭当前子任务！";
|
// }
|
//
|
// //新增智能任务
|
// addN2TaskByAuto(autoData);
|
//
|
// return exeAutoActionBySer(autoData, param, modeClose);
|
// }
|
//
|
//
|
// public String exeAutoActionBySer(N2AutoData autoData, N2Param param, String modeClose) {
|
//
|
// DepotConf depotConf = coreCommonService.getCacheDepotConf(param.getCompanyId(), param.getDepotId());
|
//
|
// //获取粮情分机的主控信息
|
// DeviceSer ser = coreSerService.getCacheSer(param.getCompanyId(), depotConf.getGrainSer());
|
//
|
// if (null == ser || Constant.YN_N.equals(ser.getStatus())) {
|
// return "当前仓库控制分机不存在或者已经掉线，系统无法执行，请联系管理员！";
|
// }
|
//
|
// DeviceAutoControlRequest request = new DeviceAutoControlRequest();
|
// request.setDepotId(param.getDepotId());
|
// request.setCompanyId(param.getCompanyId());
|
// request.setBizType(BizType.AREATION.getCode());
|
// request.setModeTag(autoData.getModeTag());
|
// request.setSerId(ser.getId());
|
// request.setSerName(ser.getName());
|
// request.setModeClose(modeClose);
|
// request.setIp(ser.getIp());
|
// request.setPort(ser.getPort());
|
// request.setDepotName(depotConf.getDepotName());
|
//
|
// RemoteControlService remoteControlService = remoteManager.getRemoteControlService(ser.getProtocol());
|
//
|
// if (null == remoteControlService) {
|
// return "当前仓库控制分机协议没有实现，系统无法执行，请联系管理员！";
|
// }
|
//
|
// DeviceControlResponse response = remoteControlService.n2AutoControl(request);
|
//
|
// if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(response.getCode())) {
|
// return null;
|
// }
|
//
|
// return "后台发送命令执行失败，原因：" + response.getMsg();
|
// }
|
//
|
// /**
|
// * 执行关闭智能任务
|
// *
|
// * @param autoData
|
// * @param param
|
// * @return 执行异常信息，正常返回 null
|
// */
|
// private String exeStopIntel(N2AutoData autoData, N2Param param) {
|
//
|
// // TODO 执行智能任务关闭操作
|
//
|
//
|
// return null;
|
// }
|
//
|
//
|
// /**
|
// * 核对气调任务，有返回true 没有返回false
|
// *
|
// * @param companyId
|
// * @param depotId
|
// * @return
|
// */
|
// public boolean n2TaskCheck(String companyId, String depotId) {
|
// // TODO 暂时不做处理
|
// N2TaskParam param = new N2TaskParam();
|
// param.setCompanyId(companyId);
|
// param.setDepotId(depotId);
|
// param.setNotStatus(N2Util.TASK_STATUS_03);
|
//
|
// List<N2IntelTask> list = null;//
|
//
|
// if (null == list || list.isEmpty()) return false;
|
//
|
// return true;
|
// }
|
//
|
//
|
// /**
|
// * 核对通风任务，有返回true 没有返回false
|
// *
|
// * @param companyId
|
// * @param depotId
|
// * @return
|
// */
|
// public boolean airTaskCheck(String companyId, String depotId) {
|
// // TODO 验证是否有通风任务正在执行，暂时不核对
|
//
|
// log.warn("------------验证是否有通风任务正在执行，暂时不核对");
|
//
|
// return false;
|
// }
|
//
|
// /**
|
// * 核对通风设备状态，有开启返回 true,没有返回false
|
// *
|
// * @param companyId
|
// * @param depotId
|
// * @return
|
// */
|
// private boolean airDeviceStatus(String companyId, String depotId) {
|
// // TODO 验证设备通风状态，暂时不核对
|
//
|
// return false;
|
// }
|
//
|
// /**
|
// * 新增智能任务，主任务，主任务创建需要自动创建至少一个子任务
|
// *
|
// * @param autoData
|
// */
|
// private void addN2TaskByAuto(N2AutoData autoData) {
|
// N2IntelTask task = new N2IntelTask();
|
// String parentId = ContextUtil.getUUID();
|
// task.setId(parentId);
|
// task.setCompanyId(autoData.getCompanyId());
|
// task.setDepotId(autoData.getDepotId());
|
// task.setDeptId(autoData.getDeptId());
|
// task.setAutoName(autoData.getName());
|
// task.setExeNum(1);
|
// task.setStatus(N2Util.TASK_STATUS_01);
|
// task.setStart(new Date());
|
// task.setExeMode(autoData.getExeMode());
|
// task.setModeTag(autoData.getModeTag());
|
//
|
// //主任务
|
// hn2Service.saveIntelTask(task);
|
//
|
// //气密性检测-子任务
|
// if (N2ModelTag.MODEL_30.getCode().equals(autoData.getModeTag())) {
|
// // -添加气压检测任务
|
// task.setParentId(parentId);
|
// task.setId(ContextUtil.getUUID());
|
// task.setModeTag(N2ModelTag.MODEL_42.getCode());
|
// task.setAutoName(N2ModelTag.MODEL_42.getMsg());
|
// hn2Service.saveIntelTask(task);
|
//
|
// //-添加第一个动作抽负压
|
// task.setParentId(parentId);
|
// task.setId(ContextUtil.getUUID());
|
// task.setModeTag(N2ModelTag.MODEL_01.getCode());
|
// task.setAutoName(N2ModelTag.MODEL_01.getMsg());
|
// hn2Service.saveIntelTask(task);
|
// }
|
//
|
//
|
// //智能气调-子任务
|
// if (N2ModelTag.MODEL_31.getCode().equals(autoData.getModeTag())) {
|
//
|
// // -添加气压检测任务
|
// task.setParentId(parentId);
|
// task.setId(ContextUtil.getUUID());
|
// task.setModeTag(N2ModelTag.MODEL_42.getCode());
|
// task.setAutoName(N2ModelTag.MODEL_42.getMsg());
|
// hn2Service.saveIntelTask(task);
|
//
|
// // -添加一个气体检测任务
|
// task.setParentId(parentId);
|
// task.setId(ContextUtil.getUUID());
|
// task.setModeTag(N2ModelTag.MODEL_41.getCode());
|
// task.setAutoName(N2ModelTag.MODEL_41.getMsg());
|
// hn2Service.saveIntelTask(task);
|
//
|
// //-添加第一个动作充氮
|
// task.setParentId(parentId);
|
// task.setId(ContextUtil.getUUID());
|
// task.setModeTag(N2ModelTag.MODEL_03.getCode());
|
// task.setAutoName(N2ModelTag.MODEL_03.getMsg());
|
//
|
// hn2Service.saveIntelTask(task);
|
// }
|
//
|
// }
|
|
|
}
|
