package com.zy.acs.conveyor.controller;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.zy.acs.common.utils.RedisSupport;
|
import com.zy.acs.conveyor.controller.vo.SiteTableVo;
|
import com.zy.acs.conveyor.core.constant.RedisConveyorConstant;
|
import com.zy.acs.conveyor.core.model.SafeSignal;
|
import com.zy.acs.conveyor.core.model.StaProtocol;
|
import com.zy.acs.conveyor.core.properties.DevpSlave;
|
import com.zy.acs.conveyor.core.properties.OutputQueue;
|
import com.zy.acs.conveyor.core.properties.SlaveProperties;
|
import com.zy.acs.conveyor.core.service.StationService;
|
import com.zy.acs.conveyor.entity.Devp;
|
import com.zy.acs.conveyor.service.DevpService;
|
import com.zy.acs.framework.annotations.ManagerAuth;
|
import com.zy.acs.framework.common.R;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.*;
|
|
/**
|
* 输送设备接口
|
* Created by vincent on 2020-06-01
|
*/
|
@RestController
|
@RequestMapping("/site")
|
public class SiteController {
|
|
@Autowired
|
private SlaveProperties slaveProperties;
|
|
|
@Autowired
|
private DevpService devpService;
|
|
@Autowired
|
private StationService stationService;
|
|
|
private final RedisSupport redis = RedisSupport.defaultRedisSupport;
|
|
|
@PostMapping("/table/site")
|
@ManagerAuth(memo = "站点信息表")
|
public R siteTable() {
|
List<SiteTableVo> list = new ArrayList<>();
|
// 内存数据
|
Map<Integer, StaProtocol> station = new HashMap<>();
|
for (DevpSlave devp : slaveProperties.getDevp()) {
|
Map<Integer, StaProtocol> stationMap = stationService.getStationMap(devp.getId());
|
station.putAll(stationMap);
|
}
|
// 持久数据
|
List<Devp> devps = devpService.selectList(new EntityWrapper<Devp>().orderBy("dev_no"));
|
for (Devp devp : devps) {
|
SiteTableVo vo = new SiteTableVo();
|
vo.setDevNo(devp.getDevNo()); // 站点编号
|
|
list.add(vo);
|
StaProtocol staProtocol = station.get(devp.getDevNo());
|
if (null == staProtocol) {
|
continue;
|
}
|
vo.setWorkNo(staProtocol.getWorkNo());
|
vo.setAutoing(staProtocol.isAutoing() ? "Y" : "N"); // 自动
|
vo.setLoading(staProtocol.isLoading() ? "Y" : "N"); // 有物
|
vo.setInEnable(staProtocol.isInEnable() ? "Y" : "N"); // 可入
|
vo.setOutEnable(staProtocol.isOutEnable() ? "Y" : "N"); // 可出
|
vo.setEmptyMk(staProtocol.isEmptyMk() != staProtocol.isFullPlt() ? (staProtocol.isEmptyMk() ? "空" : "满") : "-"); // 空板信号
|
vo.setStaNo(staProtocol.getStaNo()); // 目标站
|
vo.setWeight(staProtocol.getWeight() == null ? 0D : staProtocol.getWeight());
|
vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() ? (staProtocol.isLow() ? "低" : "高") : "-"); //高低库位
|
vo.setAllow((staProtocol.getAllowPut() ? "可放" : "不可放") + "/" + (staProtocol.getAllowTake() ? "可取" : "不可取"));
|
vo.setBarcode(staProtocol.getBarcode());
|
}
|
|
return R.ok().add(list);
|
}
|
|
|
@PostMapping("/output/site")
|
@ManagerAuth(memo = "站点设备报文日志输出")
|
public R siteOutput() {
|
StringBuilder str = new StringBuilder();
|
String s;
|
int i = 0;
|
while ((s = OutputQueue.DEVP.poll()) != null && i <= 10) {
|
str.append("\n").append(s);
|
i++;
|
}
|
return R.ok().add(str.toString());
|
}
|
|
/****************************************************************/
|
/************************** 详情操作 ******************************/
|
/****************************************************************/
|
|
@GetMapping("/detl/{siteId}")
|
public R siteDetl(@PathVariable("siteId") Integer siteId) {
|
SiteTableVo vo = new SiteTableVo();
|
for (DevpSlave devp : slaveProperties.getDevp()) {
|
Map<Integer, StaProtocol> station = stationService.getStationMap(devp.getId());
|
for (Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
|
if (siteId.equals(entry.getKey())) {
|
StaProtocol staProtocol = entry.getValue();
|
vo.setDevNo(entry.getKey()); // 站点编号
|
vo.setWorkNo(staProtocol.getWorkNo()); // 工作号
|
vo.setAutoing(staProtocol.isAutoing() ? "Y" : "N"); // 自动
|
vo.setLoading(staProtocol.isLoading() ? "Y" : "N"); // 有物
|
vo.setInEnable(staProtocol.isInEnable() ? "Y" : "N"); // 可入
|
vo.setOutEnable(staProtocol.isOutEnable() ? "Y" : "N"); // 可出
|
vo.setEmptyMk(staProtocol.isEmptyMk() != staProtocol.isFullPlt() ? (staProtocol.isEmptyMk() ? "空" : "满") : "-"); // 空板信号
|
vo.setStaNo(staProtocol.getStaNo()); // 目标站
|
vo.setWeight(staProtocol.getWeight() == null ? 0D : staProtocol.getWeight());
|
vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() ? (staProtocol.isLow() ? "低" : "高") : "-"); //高低库位
|
vo.setAllow((staProtocol.getAllowPut() ? "可放" : "不可放") + "/" + (staProtocol.getAllowTake() ? "可取" : "不可取"));
|
vo.setBarcode(staProtocol.getBarcode());
|
return R.ok().add(vo);
|
}
|
}
|
}
|
return R.error("plc已掉线");
|
}
|
|
@PostMapping("/detl/update")
|
@ManagerAuth(memo = "修改站点数据")
|
public R siteDetlUpdate(@RequestParam Integer siteId,
|
@RequestParam Integer workNo,
|
@RequestParam Integer staNo) {
|
for (DevpSlave devp : slaveProperties.getDevp()) {
|
Map<Integer, StaProtocol> station = stationService.getStationMap(devp.getId());
|
for (Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
|
if (siteId.equals(entry.getKey())) {
|
StaProtocol staProtocol = entry.getValue();
|
if (staProtocol == null) {
|
continue;
|
} else {
|
staProtocol = staProtocol.clone();
|
}
|
if (workNo != null) {
|
staProtocol.setWorkNo(workNo);
|
}
|
if (staNo != null) {
|
staProtocol.setStaNo(staNo);
|
}
|
staProtocol.setStartUpFlag(true);
|
redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol);
|
return R.ok();
|
|
}
|
}
|
}
|
return R.error("plc已掉线");
|
}
|
|
@PostMapping("/detl/safe")
|
@ManagerAuth(memo = "补充安全信号")
|
public R safe(@RequestParam Integer siteId) {
|
for (DevpSlave devp : slaveProperties.getDevp()) {
|
Map<Integer, StaProtocol> station = stationService.getStationMap(devp.getId());
|
for (Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
|
if (siteId.equals(entry.getKey())) {
|
StaProtocol staProtocol = entry.getValue();
|
if (staProtocol == null) {
|
continue;
|
} else {
|
staProtocol = staProtocol.clone();
|
}
|
boolean flag = true;
|
List<DevpSlave.Sta> putSta = devp.getPutSta();
|
List<DevpSlave.Sta> takeSta = devp.getTakeSta();
|
Optional<DevpSlave.Sta> first = takeSta.stream().filter(sta -> sta.getStaNo().equals(siteId)).findFirst();
|
int i = -1;
|
if (first.isPresent()) {
|
i = takeSta.indexOf(first.get());
|
if (i != -1) {
|
flag = false;
|
}
|
}
|
if (i == -1) {
|
first = putSta.stream().filter(sta -> sta.getStaNo().equals(siteId)).findFirst();
|
if (first.isPresent()) {
|
i = putSta.indexOf(first.get());
|
flag = true;
|
}
|
}
|
if (i == -1) {
|
return R.error("此站点无需安全信号");
|
}
|
staProtocol.setSafeSignal(new SafeSignal(i, true, flag));
|
redis.push(RedisConveyorConstant.CONVEYOR_SAFE_FLAG, staProtocol);
|
return R.ok();
|
|
}
|
}
|
}
|
return R.error("plc已掉线");
|
}
|
}
|
