package com.ld.igds.io.fzzy.command;
|
|
import com.ld.igds.io.fzzy.dto.IoMessage;
|
import com.ld.igds.io.request.QuantityRequest;
|
import com.ld.igds.util.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.concurrent.Callable;
|
|
/**
|
* @Desc: 数量检测进度查询，默认执行三次查询和三次抓拍
|
* @author: Andy
|
* @update-time: 2022/12/23
|
*/
|
@Slf4j
|
public class QueryProgressTask implements Callable<String> {
|
|
private RedisUtil redisUtil;
|
|
private String redisKey;
|
|
private BhznRemoteQuantityImpl remoteQuantityService;
|
|
public QueryProgressTask() {
|
super();
|
}
|
|
public QueryProgressTask(RedisUtil redisUtil, BhznRemoteQuantityImpl remoteQuantityService, String redisKey) {
|
super();
|
this.redisUtil = redisUtil;
|
this.remoteQuantityService = remoteQuantityService;
|
this.redisKey = redisKey;
|
}
|
|
@Override
|
public String call() throws Exception {
|
|
int index = 1;
|
while (index <= 10) {
|
index++;
|
try {
|
Thread.sleep(1000 * 35);
|
QuantityRequest request = (QuantityRequest) redisUtil.get(redisKey);
|
if (null == request) {
|
index = 11;
|
log.debug("子命令执行进度查询结束：检测完成" );
|
return "SUCCESS";
|
}
|
|
IoMessage message = CommandBuilder.getInstance().build2003Message(request);
|
log.debug("平台---->>数量检测：子命令执行进度查询：" + message.toString());
|
remoteQuantityService.sendMsg(request.getIp(), request.getPort(), message);
|
|
Thread.sleep(1000 * 3);
|
|
|
// message = CommandBuilder.getInstance().build2006Message(request);
|
// log.debug("平台---->>数量检测：子命令执行抓拍：" + message.toString());
|
// remoteQuantityService.sendMsg(request.getIp(), request.getPort(), message);
|
|
} catch (Exception e) {
|
log.error("平台---->>数量检测：子命令执行出现异常：" + e.getMessage());
|
log.error(e.getMessage(), e);
|
}
|
}
|
|
return "SUCCESS";
|
}
|
|
}
|
