package com.zy.asrs.controller; import com.core.annotations.ManagerAuth; import com.core.common.Cools; import com.core.common.R; import com.zy.asrs.domain.enums.CrnStatusType; import com.zy.asrs.domain.enums.SiteStatusType; import com.zy.asrs.domain.param.SystemSwitchParam; import com.zy.asrs.domain.vo.*; import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.WrkMast; import com.zy.asrs.service.BasDevpService; import com.zy.asrs.service.WrkMastService; import com.zy.common.CodeRes; import com.zy.core.Slave; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.CrnModeType; import com.zy.core.enums.SlaveType; import com.zy.core.model.CrnSlave; import com.zy.core.model.DevpSlave; import com.zy.core.model.protocol.CrnProtocol; import com.zy.core.model.protocol.StaProtocol; import com.zy.core.properties.SlaveProperties; import com.zy.core.properties.SystemProperties; import com.zy.core.thread.BarcodeThread; import com.zy.core.thread.CrnThread; import com.zy.core.thread.DevpThread; 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.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import java.util.*; /** * 主控图接口 * Created by vincent on 2020-06-01 */ @Slf4j @RestController @RequestMapping("/console") public class ConsoleController { @Autowired private SlaveProperties slaveProperties; @Autowired private WrkMastService wrkMastService; @Autowired private BasDevpService basDevpService; @PostMapping("/system/running/status") @ManagerAuth(memo = "系统运行状态") public R systemRunningStatus(){ return R.ok().add(Cools.add("status", SystemProperties.WCS_RUNNING_STATUS.get())); } @PostMapping("/system/switch") @ManagerAuth(memo = "系统运行开关操作") public R systemSwitch(SystemSwitchParam param) throws InterruptedException { if (Cools.isEmpty(param.getOperatorType())){ return R.error(); } if (param.getOperatorType() == 0) { if (Cools.isEmpty(param.getPassword())){ return R.error("请输入口令"); } if (!param.getPassword().equals(SystemProperties.WCS_PASSWORD)){ return R.error("口令错误"); } } Thread.sleep(2000L); SystemProperties.WCS_RUNNING_STATUS.set(param.getOperatorType()==1?Boolean.TRUE:Boolean.FALSE); return R.ok().add(Cools.add("status", SystemProperties.WCS_RUNNING_STATUS.get())); } /****************************************************************/ /************************** 实时数据 ******************************/ /****************************************************************/ @PostMapping("/latest/data/site") @ManagerAuth(memo = "站点实时数据") public R siteLatestData(){ List vos = new ArrayList<>(); Map stations = new HashMap<>(); for (DevpSlave devp : slaveProperties.getDevp()) { DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); if (null != devpThread) { stations.putAll(devpThread.getStation()); } } for (Map.Entry entry : stations.entrySet()) { SiteLatestDataVo vo = new SiteLatestDataVo(); StaProtocol staProtocol = entry.getValue(); vo.setSiteId(String.valueOf(entry.getKey())); // 站点编号 vo.setWorkNo(staProtocol.getWorkNo()); // 工作号 vo.setSiteStatus(SiteStatusType.process(staProtocol)); // 状态 vos.add(vo); } return R.ok().add(vos); } @PostMapping("/latest/data/crn") @ManagerAuth(memo = "堆垛机实时数据") public R crnLatestData(){ List vos = new ArrayList<>(); for (CrnSlave crn : slaveProperties.getCrn()) { // 获取堆垛机信息 CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId()); if (crnThread == null) { log.error("{}号堆垛机连接失败", crn.getId()); continue; } CrnProtocol crnProtocol = crnThread.getCrnProtocol(); if (crnProtocol == null) { log.error("{}号堆垛机连接失败", crn.getId()); continue; } CrnLatestDataVo vo = new CrnLatestDataVo(); vo.setCrnId(crn.getId()); // 堆垛机编号 vo.setOffset((double) new Random().nextInt(560)); // 堆垛机偏移量 /** * 堆垛机状态判断 */ if (crnProtocol.getTaskNo()>0) { WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); if (wrkMast != null) { vo.setCrnStatusType(CrnStatusType.process(wrkMast.getIoType())); } } else { vo.setCrnStatusType(crnProtocol.modeType.equals(CrnModeType.AUTO)? CrnStatusType.AUTO: CrnStatusType.UN_AUTO); } vos.add(vo); } return R.ok().add(vos); } @PostMapping("/latest/data/barcode") @ManagerAuth(memo = "条码扫描仪实时数据") public R barcodeLatestData(){ List list = new ArrayList<>(); for (Slave barcode : slaveProperties.getBarcode()) { BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcode.getId()); BarcodeDataVo vo = new BarcodeDataVo(); vo.setBarcodeId(barcode.getId()); vo.setCodeValue(barcodeThread.getBarcode()); list.add(vo); } return R.ok().add(list); } /****************************************************************/ /************************** 详情操作 ******************************/ /****************************************************************/ @PostMapping("/site/detail") @ManagerAuth(memo = "输送设备数据详情") public R siteDetail(@RequestParam Integer siteId){ if (Cools.isEmpty(siteId)){ return R.parse(CodeRes.EMPTY); } SiteDetailVo vo = new SiteDetailVo(); for (DevpSlave devp : slaveProperties.getDevp()) { DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); if (null != devpThread) { StaProtocol staProtocol = devpThread.getStation().get(siteId); if (staProtocol != null) { BasDevp basDevp = basDevpService.selectById(siteId); if (basDevp == null) { return R.error("数据库维护异常"); } vo.setSiteId(siteId); // 站点编号 vo.setWorkNo(staProtocol.getWorkNo()); // 工作号 if (staProtocol.getWorkNo() > 0) { WrkMast wrkMast = wrkMastService.selectById(staProtocol.getWorkNo()); if (wrkMast != null) { vo.setWrkSts(wrkMast.getWrkSts$()); // 工作状态 vo.setIoType(wrkMast.getIoType$()); // 入出库类型 vo.setSourceStaNo(wrkMast.getSourceStaNo$()); vo.setStaNo(wrkMast.getStaNo$()); vo.setSourceLocNo(wrkMast.getSourceLocNo$()); vo.setLocNo(wrkMast.getLocNo$()); } } vo.setAutoing(staProtocol.isAutoing()?"Y":"N"); // 自动 vo.setLoading(staProtocol.isLoading()?"Y":"N"); // 有物 vo.setCanining(basDevp.getCanining()); // 能入 vo.setCanouting(basDevp.getCanouting()); // 能出 return R.ok().add(vo); } } } return R.error(); } @PostMapping("/crn/detail") @ManagerAuth(memo = "堆垛机设备数据详情") public R crnDetail(@RequestParam Integer crnNo){ if (Cools.isEmpty(crnNo)){ return R.parse(CodeRes.EMPTY); } CrnDetailVo vo = new CrnDetailVo(); for (CrnSlave crnSlave : slaveProperties.getCrn()) { if (crnSlave.getId().equals(crnNo)) { CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crnSlave.getId()); CrnProtocol crnProtocol = crnThread.getCrnProtocol(); vo.setCrnNo(crnNo); vo.setWorkNo(crnProtocol.getTaskNo()); if (crnProtocol.getTaskNo() > 0) { WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); if (wrkMast != null) { vo.setSourceStaNo(wrkMast.getSourceStaNo$()); vo.setStaNo(wrkMast.getStaNo$()); vo.setWrkSts(wrkMast.getWrkSts$()); // 工作状态 vo.setIoType(wrkMast.getIoType$()); // 入出库类型 vo.setSourceLocNo(wrkMast.getSourceLocNo$()); vo.setLocNo(wrkMast.getLocNo$()); vo.setCrnStatus(crnProtocol.getStatusType().desc); vo.setError(""); // todo return R.ok().add(vo); } } } } return R.error(); } @Deprecated @PostMapping("/site/update") @ManagerAuth(memo = "输送设备数据修改") public R updateSite(){ return R.ok(); } @Deprecated @PostMapping("/crn/update") @ManagerAuth(memo = "堆垛机数据修改") public R updateCrn(){ return R.ok(); } }