package com.zy.core.operation.handler;
|
|
import com.core.common.DateUtils;
|
import com.zy.asrs.controller.vo.OpenBusSubmitParam;
|
import com.zy.asrs.controller.vo.TaskDto;
|
import com.zy.asrs.entity.Job;
|
import com.zy.asrs.service.CtuMainService;
|
import com.zy.asrs.service.JobService;
|
import com.zy.asrs.service.WrkLastnoService;
|
import com.zy.core.enums.ConveyorStateType;
|
import com.zy.core.operation.OperationHandler;
|
import com.zy.core.properties.CtuOperationConfig;
|
import com.zy.core.properties.SlaveProperties;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 模拟WMS
|
*/
|
@Slf4j
|
@Component
|
public class FakeWmsOperationHandler implements OperationHandler {
|
|
@Autowired
|
private SlaveProperties slaveProperties;
|
|
|
@Autowired
|
private WrkLastnoService wrkLastnoService;
|
|
@Autowired
|
private CtuMainService ctuMainService;
|
|
@Autowired
|
private JobService jobService;
|
|
|
@Override
|
public ConveyorStateType getType() {
|
return ConveyorStateType.FAKEWMS;
|
}
|
|
@Override
|
public void execute(CtuOperationConfig config) {
|
List<Job> jobs = jobService.listJobByJobSts(5);
|
for (Job job : jobs) {
|
OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
|
openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
|
List<TaskDto> taskList = new ArrayList<>();
|
TaskDto taskDto = new TaskDto();
|
taskDto.setSeqNum("SSX-RK" + job.getJobNo());
|
taskDto.setOriSta("1007");
|
taskDto.setPriority(9527);
|
taskList.add(taskDto);
|
openBusSubmitParam.setTaskList(taskList);
|
boolean b = ctuMainService.sendTask(openBusSubmitParam);
|
if (b) {
|
job.setJobSts(6);
|
job.setRcsTime(new Date());
|
jobService.updateById(job);
|
log.info("任务发送给RCS成功," + job.getSeqNum() + " - " + job.getJobNo());
|
} else {
|
log.info("任务发送给RCS失败," + job.getSeqNum() + " - " + job.getJobNo());
|
}
|
}
|
}
|
}
|
