package com.ld.igds.view.manager;
|
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.common.CoreSerService;
|
import com.ld.igds.common.dto.THDto;
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.io.RemoteCommonService;
|
import com.ld.igds.io.RemoteManager;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.request.CheckThRequest;
|
import com.ld.igds.io.response.BaseResponse;
|
import com.ld.igds.models.DepotConf;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.order.ExeOrderService;
|
import com.ld.igds.order.data.ExeRequest;
|
import com.ld.igds.th.CoreThService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 仓库温湿度管理
|
*
|
* @author: andy.jia
|
* @description:
|
* @version:
|
* @data:2020年2月17日
|
*/
|
@Slf4j
|
@Component
|
public class TempManager {
|
|
|
@Autowired
|
private CoreCommonService commonService;
|
@Autowired
|
private CoreThService thService;
|
@Autowired
|
private CoreSerService serService;
|
@Autowired
|
private RemoteManager remoteManager;
|
@Autowired
|
private ExeOrderService exeOrderService;
|
@Autowired
|
private NotifyWebInvoker notifyWebInvoker;
|
|
private RemoteCommonService remoteCommonService;
|
|
|
/**
|
* 系统定时检测
|
*/
|
public void scheduledCheck(String companyId) {
|
try {
|
//获取所有的仓库配置信息
|
List<DepotConf> list = commonService.getCacheDepotConf(companyId);
|
|
//查看温湿度的配置，同时从当前列表中获取到对应的分机信息
|
CheckThRequest request;
|
DeviceSer deviceSer;
|
//避免重复
|
Map<String, String> tempMap = new HashMap<>();
|
|
String key;
|
for (DepotConf conf : list) {
|
if (StringUtils.isEmpty(conf.getThSer())) continue;
|
|
key = conf.getThSer() + "_" + conf.getThConf();
|
|
if (null != tempMap.get(key)) {
|
continue;
|
}
|
tempMap.put(key, conf.getThSer());
|
|
deviceSer = serService.getCacheSer(companyId, conf.getThSer());
|
|
if (null == deviceSer) {
|
log.warn("根据仓库参数的温湿度分机配置未获取到相应的分机……");
|
continue;
|
}
|
|
if (deviceSer.getStatus().equals(Constant.YN_N)) {
|
log.warn("当前分机={}，不在线，不执行温湿度度检测。", deviceSer.getName());
|
notifyWebInvoker.notifyWeb(deviceSer.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, "分机=" + deviceSer.getName() + "不在线，不执行温湿度检测");
|
//每个设备间隔200毫秒
|
Thread.sleep(300);
|
continue;
|
}
|
|
request = new CheckThRequest();
|
request.setCompanyId(companyId);
|
request.setThConf(conf.getThConf());
|
request.setDepotId(conf.getDepotId());
|
request.setIp(deviceSer.getIp());
|
request.setPort(deviceSer.getPort());
|
request.setSerId(deviceSer.getId());
|
request.setDepotName(conf.getDepotName());
|
request.setSerName(deviceSer.getName());
|
|
request.setBizType(BizType.SYS.getCode());
|
|
// 避免重复发送命令和添加操作记录
|
ExeRequest exeRequest = new ExeRequest(request);
|
exeRequest.setAddLogTag(false);
|
exeRequest.setThConf(conf.getThConf());
|
|
exeOrderService.checkExecute(exeRequest);
|
|
//开始调用命令执行
|
remoteCommonService = remoteManager.getRemoteCommonService(deviceSer.getProtocol());
|
if (null == remoteCommonService) {
|
log.error("当前分机={}协议没有实现类", deviceSer.getName());
|
continue;
|
}
|
BaseResponse resp = remoteCommonService.checkTh(request);
|
if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(resp.getCode())) {
|
exeOrderService.addThCache(exeRequest);
|
} else {
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, "粮情分机=" + deviceSer.getName() + "发送温湿度命令信息失败：" + resp.getMsg());
|
}
|
|
//每个设备间隔200毫秒
|
Thread.sleep(200);
|
}
|
|
} catch (Exception e) {
|
log.error("执行出错:{}", e.getMessage());
|
}
|
}
|
|
public THDto getCacheTH(String companyId, String tempSer, String thConf) {
|
return thService.getCacheTH(companyId, tempSer, thConf);
|
}
|
|
/**
|
* 分机上线时对分机进行一次温湿度采集
|
* @param companyId 分机组织编码
|
* @param serId 分机id
|
*/
|
public void checkThBySer(String companyId, String serId) {
|
try {
|
//获取所有的仓库配置信息
|
List<DepotConf> list = commonService.getCacheDepotConf(companyId);
|
|
//查看温湿度的配置，同时从当前列表中获取到对应的分机信息
|
CheckThRequest request;
|
DeviceSer deviceSer;
|
//避免重复
|
Map<String, String> tempMap = new HashMap<>();
|
|
String key;
|
for (DepotConf conf : list) {
|
if (StringUtils.isEmpty(conf.getThSer())) {
|
continue;
|
}
|
if (!serId.equals(conf.getThSer())) {
|
continue;
|
}
|
|
key = conf.getThSer() + "_" + conf.getThConf();
|
if (null != tempMap.get(key)) {
|
continue;
|
}
|
tempMap.put(key, conf.getThSer());
|
|
deviceSer = serService.getCacheSer(companyId, conf.getThSer());
|
|
if (null == deviceSer) {
|
log.warn("根据仓库参数的温湿度分机配置未获取到相应的分机……");
|
continue;
|
}
|
|
if (deviceSer.getStatus().equals(Constant.YN_N)) {
|
log.warn("当前分机={}，不在线，不执行温湿度度检测。", deviceSer.getName());
|
notifyWebInvoker.notifyWeb(deviceSer.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, "分机=" + deviceSer.getName() + "不在线，不执行温湿度检测");
|
//每个设备间隔200毫秒
|
Thread.sleep(300);
|
continue;
|
}
|
request = new CheckThRequest();
|
request.setCompanyId(companyId);
|
request.setThConf(conf.getThConf());
|
request.setDepotId(conf.getDepotId());
|
request.setIp(deviceSer.getIp());
|
request.setPort(deviceSer.getPort());
|
request.setSerId(deviceSer.getId());
|
request.setDepotName(conf.getDepotName());
|
request.setSerName(deviceSer.getName());
|
|
request.setBizType(BizType.SYS.getCode());
|
|
// 避免重复发送命令和添加操作记录
|
ExeRequest exeRequest = new ExeRequest(request);
|
exeRequest.setAddLogTag(false);
|
exeRequest.setThConf(conf.getThConf());
|
|
exeOrderService.checkExecute(exeRequest);
|
|
//开始调用命令执行
|
remoteCommonService = remoteManager.getRemoteCommonService(deviceSer.getProtocol());
|
if (null == remoteCommonService) {
|
log.error("当前分机={}协议没有实现类", deviceSer.getName());
|
continue;
|
}
|
BaseResponse resp = remoteCommonService.checkTh(request);
|
if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(resp.getCode())) {
|
exeOrderService.addThCache(exeRequest);
|
} else {
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, "粮情分机=" + deviceSer.getName() + "发送温湿度命令信息失败：" + resp.getMsg());
|
}
|
|
//每个设备间隔200毫秒
|
Thread.sleep(200);
|
}
|
|
} catch (Exception e) {
|
log.error("执行出错:{}", e.getMessage());
|
}
|
}
|
}
|
