package com.zy.acs.gateway.process;
|
|
import com.zy.acs.common.constant.RedisConstant;
|
import com.zy.acs.gateway.Executors;
|
import com.zy.acs.gateway.cache.ChannelCache;
|
import com.zy.acs.gateway.constant.AgvConstant;
|
import com.zy.acs.gateway.constant.ProtocolType;
|
import com.zy.acs.gateway.domain.AgvPackage;
|
import com.zy.acs.gateway.job.DispatcherPublisher;
|
import com.zy.acs.gateway.utils.ProtocolUtils;
|
import com.zy.acs.common.utils.RedisSupport;
|
import com.zy.acs.rpc.gateway.control.AgvCmdFeignApi;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Timer;
|
import java.util.TimerTask;
|
|
/**
|
* Created by vincent on 2023/3/17
|
*/
|
@Component
|
public class ActivateLauncher {
|
|
private final RedisSupport redis = RedisSupport.defaultRedisSupport;
|
|
@Autowired
|
private AgvCmdFeignApi agvCmdFeignApi;
|
@Autowired
|
private Executors executors;
|
@Autowired
|
private DispatcherPublisher publisher;
|
|
{
|
|
Timer timer = new Timer();
|
|
timer.schedule( new TimerTask() {
|
|
@Override
|
public void run() {
|
|
|
String[] uniqueNoList =
|
redis.getKeys("*" + RedisConstant.AGV_ONLINE_FLAG + "*");
|
|
for (String uniqueno : uniqueNoList) {
|
|
|
uniqueno = uniqueno.substring(uniqueno.lastIndexOf(".") + 1);
|
|
AgvPackage agvPackage
|
= ProtocolUtils.installDownProtocol(uniqueno, ProtocolType.HEARTBEAT_COMMAND);
|
|
|
if (null != publisher) {
|
|
|
publisher.publish(agvPackage);
|
}
|
|
|
}
|
|
}
|
|
}, 0, 5000);
|
|
}
|
|
@PostConstruct
|
public void launch() {
|
|
// List<String> allAgv = agvFeignApi.findAllAgv();
|
List<String> allAgv = new ArrayList<String>() {{
|
add("1");
|
}};
|
|
executors.getInstance().execute(
|
() -> {
|
|
try {
|
|
|
Thread.sleep(5000);
|
} catch (Exception ignore) {}
|
|
for (String uniqueNo : allAgv) {
|
|
AgvPackage agvPackage = null;
|
|
if (ChannelCache.hasChannel(uniqueNo)) {
|
|
agvPackage = ProtocolUtils.installDownProtocol(uniqueNo, ProtocolType.ACTIVATION_COMMAND);
|
|
|
|
}
|
|
|
if (null != agvPackage) {
|
|
publisher.publish(agvPackage);
|
}
|
|
}
|
|
|
});
|
|
|
|
}
|
|
|
}
|
