package com.zy.asrs.controller;
|
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.zy.asrs.controller.requestParam.StaParam;
|
import com.zy.asrs.controller.requestParam.StationRequestParam;
|
import com.zy.asrs.controller.responseParam.StationResponseParam;
|
import com.zy.asrs.entity.Job;
|
import com.zy.asrs.service.JobService;
|
import com.zy.common.web.BaseController;
|
import com.zy.core.DevpThread;
|
import com.zy.core.cache.SlaveConnection;
|
import com.zy.core.enums.SlaveType;
|
import com.zy.core.model.protocol.StaProtocol;
|
import com.zy.core.properties.SlaveProperties;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 对ctu系统的接口
|
*/
|
@Slf4j
|
@RestController
|
public class WmsController extends BaseController {
|
|
|
@Autowired
|
private JobService jobService;
|
|
/**
|
* 站点查询
|
*/
|
@ResponseBody
|
@PostMapping("/station/getTaskNo")
|
public R query(@RequestBody StaParam param) {
|
log.info("根据站点查询taskNo：{}", param);
|
String staNo = param.getStaNo();
|
DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, param.getDevpId());
|
List<StationResponseParam> list = new ArrayList<>();
|
Map<Integer, StaProtocol> station = devpThread.getStation();
|
StaProtocol staProtocol = station.get(Integer.parseInt(staNo));
|
Integer workNo = staProtocol.getWorkNo();
|
if (workNo != null) {
|
Job jobByJobNo = jobService.getJobByJobNo(workNo);
|
if (jobByJobNo != null) {
|
return R.ok(jobByJobNo.getJobNo());
|
}
|
}
|
return R.ok(list);
|
}
|
|
|
}
|
