package com.mes.job;
|
import com.mes.bigstorage.entity.BigStorageCageDetails;
|
import com.mes.bigstorage.service.BigStorageCageDetailsService;
|
import com.mes.bigstorage.service.BigStorageCageService;
|
import com.mes.bigstoragetask.entity.BigStorageCageFeedTask;
|
import com.mes.bigstoragetask.entity.BigStorageCageOutTask;
|
import com.mes.bigstoragetask.service.BigStorageCageFeedTaskService;
|
import com.mes.bigstoragetask.service.BigStorageCageOutTaskService;
|
import com.mes.common.S7object;
|
import com.mes.device.PlcParameterObject;
|
import com.mes.edgstoragetask.service.TaskCacheService;
|
import com.mes.glassinfo.entity.GlassInfo;
|
import com.mes.glassinfo.service.GlassInfoService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@Component
|
@Slf4j
|
public class PlcStorageCageTask {
|
|
@Resource
|
private BigStorageCageService bigStorageCageService;
|
@Resource
|
private BigStorageCageDetailsService bigStorageCageDetailsService;
|
@Resource
|
private GlassInfoService glassInfoService;
|
@Resource
|
private BigStorageCageFeedTaskService bigStorageCageFeedTaskService;
|
@Resource
|
private BigStorageCageOutTaskService bigStorageCageOutTaskService;
|
@Resource
|
private TaskCacheService taskCacheService;
|
|
PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
|
|
public static boolean bigStorageCageFullAlarm = false;
|
/**
|
* fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成）
|
* fixedDelay : 上一个调用结束后再次调用的延时
|
*/
|
@Scheduled(fixedDelay = 5000)
|
public void plcStorageCageTask() throws InterruptedException {
|
try {
|
|
String plcFeedGlassid = "";
|
String plcFeedReqLine = "0";
|
if ("1".equals(plcParameterObject.getPlcParameter("D01Request").getValue())) {
|
plcFeedReqLine = "1";
|
plcFeedGlassid=plcParameterObject.getPlcParameter("D01ID1").getValue();
|
}
|
if ("1".equals(plcParameterObject.getPlcParameter("D04Request").getValue())) {
|
plcFeedReqLine = "2";
|
plcFeedGlassid=plcParameterObject.getPlcParameter("D04ID1").getValue();
|
}
|
|
if (!("0".equals(plcFeedReqLine))) {
|
log.info("1、Plc进片请求时");
|
BigStorageCageDetails bigStorageCageDetails = new BigStorageCageDetails();
|
GlassInfo glassInfo = glassInfoService.getById(plcFeedGlassid);
|
log.info("2、根据玻璃id获取玻璃信息" + glassInfo);
|
if(bigStorageCageDetailsService.selectGetBoard(glassInfo,plcFeedReqLine)){
|
BigStorageCageDetails slotInfo = bigStorageCageService.feedGlass(glassInfo, bigStorageCageDetails);
|
if (slotInfo != null) {
|
int taskType = taskCacheService.judgeTasktype();
|
log.info("3、查询任务表判断当前任务类型为上车等到还是上车启动" + taskType);
|
bigStorageCageFeedTaskService.addFeedTask(slotInfo, Integer.parseInt(plcFeedReqLine), taskType);
|
log.info("4、添加任务到任务表");
|
bigStorageCageFullAlarm = false;
|
} else {
|
bigStorageCageFullAlarm = true;
|
}
|
}else{
|
log.info("当前玻璃宽度不够上车" + glassInfo);
|
if(!("1".equals(plcFeedReqLine))){
|
S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("D02Go").getAddress(), 1);
|
}else{
|
S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("D05Go").getAddress(), 1);
|
}
|
}
|
} else {
|
List<BigStorageCageFeedTask> bigStorageCageFeedTaskList = bigStorageCageFeedTaskService.querybigStorageCageFeedTask(1);
|
log.info("5、查询任务表是否有已经完成的进片任务" + bigStorageCageFeedTaskList.size());
|
for (BigStorageCageFeedTask bigStorageCageFeedTask : bigStorageCageFeedTaskList
|
) {
|
BigStorageCageDetails bigStorageCageDetails = new BigStorageCageDetails();
|
bigStorageCageDetails.setId(bigStorageCageFeedTask.getId());
|
bigStorageCageDetails.setState(1);
|
bigStorageCageDetailsService.updateById(bigStorageCageDetails);
|
log.info("6、修改理片笼详情玻璃状态");
|
bigStorageCageFeedTaskService.removeById(bigStorageCageFeedTask);
|
log.info("7、删除已经完成的进片任务");
|
}
|
}
|
|
//查询出片表是否有任务未完成的任务
|
List<BigStorageCageOutTask> bigStorageCageOutTask=bigStorageCageOutTaskService.querybigStorageCageOutTask(0);
|
if(bigStorageCageOutTask.size()==0){
|
bigStorageCageService.outGlass();
|
log.info("8、没有未完成任务时调用出片接口");
|
}
|
bigStorageCageOutTaskService.updateOutTask();
|
log.info("9、根据任务表状态修改钢化小片表任务状态");
|
|
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
