package com.fzzy.protocol;
|
|
import com.fzzy.api.data.GatewayDeviceProtocol;
|
import com.fzzy.gateway.GatewayUtils;
|
import com.fzzy.gateway.data.BaseReqData;
|
import com.fzzy.gateway.entity.GatewayDevice;
|
import com.fzzy.protocol.zldz.service.ZldzGatewayGrainService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.Collection;
|
import java.util.Date;
|
|
|
/**
|
* 协议相关的定时器，全局定时器，包含所有的协议，逻辑处理是否执行
|
*/
|
@Slf4j
|
@Component(ProtocolScheduled.BEAN_ID)
|
public class ProtocolScheduled {
|
|
public static final String BEAN_ID = "protocol.Scheduled";
|
|
|
@Resource
|
private ZldzGatewayGrainService zldzGatewayGrainService;
|
|
|
/**
|
* 从6-19点每小时执行一次
|
* cron = "0 0 6-19 * * ? *"
|
*/
|
@Scheduled(cron = "0 0 6-19 * * ? ")
|
public void scheduled() {
|
|
Date cur = new Date();
|
|
log.info("--------------系统执行定时数据同步操作--------------");
|
|
//正来电子协议-定时任务
|
this.scheduledZldz(cur);
|
|
|
}
|
|
/**
|
* 正来电子定时任务
|
*
|
* @param cur
|
*/
|
private void scheduledZldz(Date cur) {
|
|
//获取设备列表
|
Collection<GatewayDevice> list = GatewayUtils.allCacheDevice();
|
|
try {
|
BaseReqData reqData;
|
for (GatewayDevice device : list) {
|
|
if (null == device.getSyncProtocol()) continue;
|
|
if (!GatewayDeviceProtocol.GRAIN_FZZY_ZLDZ_WEB.getCode().equals(device.getSyncProtocol())) {
|
continue;
|
}
|
|
reqData = new BaseReqData();
|
reqData.setDeviceId(device.getDeviceId());
|
reqData.setProductId(device.getProductId());
|
reqData.setDeviceName(device.getDeviceName());
|
reqData.setDevice(device);
|
|
zldzGatewayGrainService.syncGrainTh(reqData);
|
|
Thread.sleep(500);
|
}
|
|
} catch (Exception e) {
|
|
}
|
}
|
|
|
}
|
