package com.mes.job.opccallback;
|
|
import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
|
import com.mes.opctask.entity.EdgStorageDeviceTask;
|
import com.mes.opctask.service.EdgStorageDeviceTaskService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @Author : zhoush
|
* @Date: 2024/10/10 14:13
|
* @Description:
|
*/
|
@Service
|
@Slf4j
|
public class CacheGlassTestCallback implements SubscriptionCallback {
|
@Resource
|
EdgStorageDeviceTaskService edgStorageDeviceTaskService;
|
|
@Override
|
public void onSubscribe(String identifier, Object value) {
|
EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage("edg_storage_device_one_task");
|
try {
|
if (task == null) {
|
log.info("任务表基础数据录入失败，请检查数据是否录入成功");
|
return;
|
}
|
task.setTaskRunning(task.getTaskRunning() + 1);
|
log.info("当前第{}次执行", task.getTaskRunning());
|
// task.setTaskState(task.getTaskRunning());
|
edgStorageDeviceTaskService.updateTaskMessage("edg_storage_device_one_task", task);
|
} catch (Exception e) {
|
log.info("{}", e.getMessage());
|
}
|
}
|
}
|
