package com.ld.igds.io.fzzy.command;
|
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.io.fzzy.ServerUtils;
|
import com.ld.igds.io.fzzy.dto.IoMessage;
|
import com.ld.igds.io.fzzy.server.BhznQuantityServerEngine;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.constant.ProtocolEnum;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.request.QuantityRequest;
|
import com.ld.igds.io.response.BaseResponse;
|
import com.ld.igds.quantity.io.RemoteQuantityService;
|
import com.ld.igds.util.RedisUtil;
|
import com.ld.io.api.InvokeResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.FutureTask;
|
|
@Slf4j
|
@Component(BhznRemoteQuantityImpl.BEAN_ID)
|
public class BhznRemoteQuantityImpl implements RemoteQuantityService {
|
|
public static final String BEAN_ID = "fzzy.remoteQuantityService";
|
@Autowired
|
private BhznQuantityServerEngine bhznQuantityServerEngine;
|
@Autowired
|
private NotifyWebInvoker notifyWebInvoker;
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Override
|
public String getProtocol() {
|
return ProtocolEnum.TCP_FZZY_QUANTITY_V35.getCode();
|
}
|
|
@Override
|
public BaseResponse checkStart(QuantityRequest request) {
|
try {
|
|
String key = ServerUtils.buildRequestKey(request.getCompanyId(), request.getSn());
|
|
IoMessage message = CommandBuilder.getInstance().build2001Message(request);
|
InvokeResult result = sendMsg(request.getIp(), request.getPort(), message);
|
|
// 如果有执行异常，直接通知到前端
|
if (InvokeResult.SUCCESS != result) {
|
log.info("平台------>>>>数量检测：开始检测-失败{}", result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getSerName() + " 开始检测，命令执行失败");
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"开始检测执行失败：" + result.getMessage());
|
}
|
|
//最长保存一个小时
|
redisUtil.set(key, request, 60 * 60);
|
|
//启动子任务定时查询进度
|
FutureTask<String> futureTask = new FutureTask<>(new QueryProgressTask(redisUtil, this, key));
|
ExecutorService executorService = Executors.newCachedThreadPool();
|
executorService.submit(futureTask);
|
executorService.shutdown();
|
|
} catch (Exception e) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"执行失败：" + e.getMessage());
|
}
|
|
return new BaseResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
|
@Override
|
public BaseResponse remoteConf(QuantityRequest request) {
|
|
//检测之前先下发配置
|
IoMessage message = CommandBuilder.getInstance().build1001Message(request);
|
|
InvokeResult result = sendMsg(request.getIp(), request.getPort(), message);
|
|
if (InvokeResult.SUCCESS != result) {
|
log.info("平台------>>>>数量检测：下发配置失败-失败{}", result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getSerName() + " 下发检测配置，命令执行失败");
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"下发配置执行失败：" + result.getMessage());
|
}
|
|
return new BaseResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
@Override
|
public BaseResponse checkStop(QuantityRequest request) {
|
//检测之前先下发配置
|
IoMessage message = CommandBuilder.getInstance().build2002Message(request);
|
InvokeResult result = sendMsg(request.getIp(), request.getPort(), message);
|
if (InvokeResult.SUCCESS != result) {
|
log.info("平台------>>>>数量检测：停止检测-失败{}", result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getSerName() + " 停止检测失败，命令执行失败");
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"停止检测执行失败：" + result.getMessage());
|
}
|
String key = ServerUtils.buildRequestKey(request.getCompanyId(),request.getSn());
|
//删除缓存
|
redisUtil.del(key);
|
|
return new BaseResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
@Override
|
public BaseResponse snapImg(QuantityRequest request) {
|
return new BaseResponse(OrderRespEnum.NO_PROTOCOL);
|
}
|
|
@Override
|
public BaseResponse closeWarn(QuantityRequest request) {
|
return new BaseResponse(OrderRespEnum.NO_FUNCTION);
|
}
|
|
@Override
|
public BaseResponse ptz(QuantityRequest Request) {
|
return new BaseResponse(OrderRespEnum.NO_FUNCTION);
|
}
|
|
public InvokeResult sendMsg(String ip, Integer port, IoMessage message) {
|
|
String msg = CommandBuilder.getInstance().build(message);
|
|
log.debug("平台------>>>>数量检测：报文信息-{}", msg);
|
|
InvokeResult result = bhznQuantityServerEngine.push(ip, port, msg.getBytes());
|
return result;
|
}
|
|
}
|
