package com.zy.core.operation.handler;
|
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.Job;
|
import com.zy.asrs.enums.WorkNoTypeType;
|
import com.zy.asrs.service.CtuMainService;
|
import com.zy.asrs.service.JobService;
|
import com.zy.asrs.service.WrkLastnoService;
|
import com.zy.core.cache.MessageQueue;
|
import com.zy.core.cache.SlaveConnection;
|
import com.zy.core.enums.ConveyorStateType;
|
import com.zy.core.enums.SlaveType;
|
import com.zy.core.enums.TaskType;
|
import com.zy.core.model.DevpSlave;
|
import com.zy.core.model.Task;
|
import com.zy.core.model.protocol.StaProtocol;
|
import com.zy.core.operation.OperationHandler;
|
import com.zy.core.properties.CtuOperationConfig;
|
import com.zy.core.properties.SlaveProperties;
|
import com.zy.core.thread.SiemensDevpThread;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
|
@Slf4j
|
@Component
|
public class OutOperationHandler implements OperationHandler {
|
|
@Autowired
|
private SlaveProperties slaveProperties;
|
|
|
@Autowired
|
private WrkLastnoService wrkLastnoService;
|
|
@Autowired
|
private CtuMainService ctuMainService;
|
|
@Autowired
|
private JobService jobService;
|
|
|
@Override
|
public ConveyorStateType getType() {
|
return ConveyorStateType.OUTBOUND;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public synchronized void execute(CtuOperationConfig config) {
|
try {
|
// 根据输送线plc遍历
|
for (DevpSlave devp : slaveProperties.getDevp()) {
|
// 遍历出库口
|
for (DevpSlave.Sta releaseSta : devp.getReleaseSta()) {
|
// 获取入库站信息
|
SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
|
StaProtocol staProtocol = devpThread.getStation().get(releaseSta.getStaNo());
|
if (staProtocol == null) {
|
continue;
|
} else {
|
staProtocol = staProtocol.clone();
|
}
|
// 判断是否满足条件
|
if (!staProtocol.isLoading()) {
|
if (staProtocol.getWorkNo() > 0) {
|
log.error("输送线上有任务号无货，需要人工处理：{}", staProtocol.getSiteId());
|
}
|
continue;
|
}
|
|
if (staProtocol.isAutoing() && staProtocol.getWorkNo() == 0) {
|
if (staProtocol.isInEnable()) {
|
log.error("没有可入信号：{}", staProtocol.getSiteId());
|
continue;
|
}
|
String seqNum = ctuMainService.checkStationStatus(releaseSta.getStaNo());
|
if (seqNum != null) {
|
Job jobBySeqNum = jobService.getJobByTaskNo(seqNum);
|
if (jobBySeqNum == null) {
|
int workNo = wrkLastnoService.nextWorkNo(WorkNoTypeType.WORK_NO_TYPE.type);
|
// 下发移动 且 下发plc命令
|
staProtocol.setWorkNo(workNo);
|
staProtocol.setStaNo(releaseSta.getTargetSta());
|
Job job = new Job();
|
job.setTaskNo(seqNum);
|
job.setJobNo(workNo);
|
job.setJobSts(ConveyorStateType.OUTBOUND.getStatus());
|
if (!jobService.insert(job)) {
|
throw new CoolException("插入输送线任务失败," + jobBySeqNum + " - " + workNo);
|
}
|
boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(TaskType.WRITE, staProtocol));
|
if (result) {
|
log.info("输送线下发：{},{}", staProtocol.getWorkNo(), releaseSta.getTargetSta());
|
} else {
|
log.error("发布命令至输送线队列失败！！！ [plc编号：{}]", devp.getId());
|
}
|
}
|
} else {
|
log.info("站点信息不符合入库条件！！！" + " 调用RCS检验未通过,站点：{}", staProtocol.getSiteId());
|
}
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
}
|
}
|
}
|
