package com.ld.igds.protocol.zldz.task;
|
|
import com.ld.igds.protocol.zldz.command.BaseRemoteImpl;
|
import com.ld.igds.util.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.concurrent.Callable;
|
|
/**
|
* 粮情子任务，粮情子任务，忽略8815的回复和8817的回复，直接等结果包的到达，如果结果包没有到达，就重复发送粮情请求
|
*
|
* @author andy.jia
|
*/
|
@Slf4j
|
public class ReSendGrainTask extends BaseRemoteImpl implements Callable<String> {
|
|
private CommandTask commandData;
|
|
private RedisUtil redisUtil;
|
|
private String redisKey;
|
|
public RedisUtil getRedisUtil() {
|
return redisUtil;
|
}
|
|
public void setRedisUtil(RedisUtil redisUtil) {
|
this.redisUtil = redisUtil;
|
}
|
|
public String getRedisKey() {
|
return redisKey;
|
}
|
|
public void setRedisKey(String redisKey) {
|
this.redisKey = redisKey;
|
}
|
|
public void setCommandData(CommandTask commandData) {
|
this.commandData = commandData;
|
}
|
|
public CommandTask getCommandData() {
|
return commandData;
|
}
|
|
public ReSendGrainTask() {
|
super();
|
}
|
|
public ReSendGrainTask(CommandTask commandData, RedisUtil redisUtil, String redisKey) {
|
super();
|
this.commandData = commandData;
|
this.redisUtil = redisUtil;
|
this.redisKey = redisKey;
|
}
|
|
@Override
|
public String call() throws Exception {
|
|
String[] attCable = commandData.getCableRule().split("-");
|
int cableZ = Integer.valueOf(attCable[0]);
|
int cableY = Integer.valueOf(attCable[1]);
|
int cableX = Integer.valueOf(attCable[2]);
|
|
int point = cableX * cableY * cableZ;
|
long time = point * 100 + (point / 100) * 500;
|
|
//1,粮情第1次等待时间为采集点个数* 0.1 秒 + 20秒，如果没有正常返回则发送第二次命令。
|
Thread.sleep(time);
|
CommandTask redisData = (CommandTask) redisUtil.get(redisKey);
|
if (null == redisData) {
|
return "命令第1次等待，终端已经正常返回";
|
} else {
|
String msg = commandData.getSerName() + " 第1次补发命令=" + commandData.getCommand();
|
log.info(msg);
|
|
super.send(commandData.getIp(), commandData.getPort(), commandData.getByteCommand());
|
}
|
|
//2
|
Thread.sleep(time);
|
redisData = (CommandTask) redisUtil.get(redisKey);
|
if (null == redisData) {
|
return "命令第2次等等，终端已经正常返回";
|
} else {
|
String msg = commandData.getSerName() + " 第2次补发粮情命令，没有返回，系统断开当前连接。";
|
log.info(msg);
|
|
// ExeOrderService orderService = SpringUtil.getBean(ExeOrderService.class);
|
// orderService.progressError(commandData.getCompanyId(), BizType.GRAIN, commandData.getDepotId(), msg);
|
|
//2021年6月5日 07:30:22 取消超时踢出连接
|
// super.destory(commandData.getIp(), commandData.getPort());
|
}
|
return "子任务执行完成";
|
}
|
|
}
|
