From 1a78ba1b06078ad7604ee5cb95aa9d42d7e66561 Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期六, 19 十月 2024 15:20:39 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/controller/RgvController.java | 103 ++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 85 insertions(+), 18 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/RgvController.java b/src/main/java/com/zy/asrs/controller/RgvController.java index c33b833..7376efc 100644 --- a/src/main/java/com/zy/asrs/controller/RgvController.java +++ b/src/main/java/com/zy/asrs/controller/RgvController.java @@ -2,40 +2,42 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.annotations.ManagerAuth; -import com.core.common.Arith; import com.core.common.R; import com.core.exception.CoolException; import com.zy.asrs.domain.enums.RgvStatusType; +import com.zy.asrs.domain.param.EnergyGatheringRingParam; import com.zy.asrs.domain.param.RgvOperatorParam; +import com.zy.asrs.domain.param.RingThroughParam; import com.zy.asrs.domain.vo.*; import com.zy.asrs.entity.*; import com.zy.asrs.mapper.BasRgvErrMapper; +import com.zy.asrs.service.BasDevpPositionService; import com.zy.asrs.service.BasRgvService; -import com.zy.asrs.service.LocMastService; import com.zy.asrs.service.WrkMastService; import com.zy.asrs.service.impl.MainServiceImpl; -import com.zy.asrs.utils.VersionUtils; -import com.zy.core.Slave; +import com.zy.asrs.utils.NumUtils; +import com.zy.asrs.utils.Utils; import com.zy.core.cache.MessageQueue; import com.zy.core.cache.OutputQueue; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.RgvModeType; import com.zy.core.enums.RgvTaskModeType; import com.zy.core.enums.SlaveType; +import com.zy.core.model.DevpSlave; import com.zy.core.model.RgvSlave; import com.zy.core.model.Task; import com.zy.core.model.command.RgvCommand; import com.zy.core.model.protocol.RgvProtocol; import com.zy.core.properties.SlaveProperties; import com.zy.core.thread.RgvThread; -import com.zy.core.thread.ScaleThread; +import com.zy.core.thread.SiemensDevpThread; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import javax.rmi.CORBA.Util; import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -61,7 +63,7 @@ @Autowired private MainServiceImpl mainService; @Autowired - private LocMastService locMastService; + private BasDevpPositionService basDevpPositionService; @PostMapping("/table/rgv/state") @ManagerAuth(memo = "RGV淇℃伅琛�") @@ -324,24 +326,89 @@ return false; } - @PostMapping("/console/rgv/site/data") - @ManagerAuth(memo = "灏忚溅瀹炴椂浣嶇疆") - public R scaleLatestData(){ - List<Map> result = new ArrayList<>(); + @PostMapping("/ring/through/rgv/position/data") +// @ManagerAuth(memo = "鐜┛浣嶇疆淇℃伅") + public R ringThroughRgv(){ + List<RingThroughParam> result = new ArrayList<>(); for (RgvSlave rgv : slaveProperties.getRgv()) { - // 鑾峰彇RGV淇℃伅 +// for (int i = 1;i<2;i++) { +// // 鑾峰彇RGV淇℃伅 RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Rgv, rgv.getId()); if (rgvThread == null) { - throw new CoolException("RGV涓嶅湪绾�"); + continue; } RgvProtocol rgvProtocol = rgvThread.getRgvProtocol(); if (rgvProtocol == null) { - throw new CoolException("RGV涓嶅湪绾�"); + continue; } - Map<String, Object> rgvMap = new HashMap<>(); - rgvMap.put("title", rgvProtocol.getRgvPosI()); - rgvMap.put("id", rgvProtocol.getRgvNo()); - result.add(rgvMap); + RingThroughParam ringThroughParam = new RingThroughParam(); + + ringThroughParam.setIndex(rgv.getId()); +// ringThroughParam.setIndex(i); +// double[] doubles = Utils.RingThroughXY2(1737000.0, NumUtils.GetRandomIntInRange(183)); + double[] doubles = Utils.RingThroughXYRgv(1737000.0, 1737000.0-rgvProtocol.RgvPos.doubleValue()); +// double[] doubles = Utils.RingThroughXY2(183.0, 100*i ); + + ringThroughParam.setValueX(doubles[0]-2.94); + ringThroughParam.setValueY(doubles[1]-2.94); + ringThroughParam.setModeColor(rgvProtocol.modeType.color); + ringThroughParam.setStatusColor(rgvProtocol.statusType.color); + result.add(ringThroughParam); + } + return R.ok().add(result); + } + + @PostMapping("/ring/through/dev/position/data") +// @ManagerAuth(memo = "绔欑偣淇℃伅") + public R ringThroughDev(){ + List<RingThroughParam> result = new ArrayList<>(); + List<BasDevpPosition> basDevpPositions = basDevpPositionService.selectList(new EntityWrapper<>()); + for (BasDevpPosition basDevpPosition : basDevpPositions){ + RingThroughParam ringThroughParam = new RingThroughParam(); + ringThroughParam.setIndex(basDevpPosition.getDevNo()); + double[] doubles = Utils.RingThroughXYSta(1737000.0, 1737000.0-basDevpPosition.getPlcPosition()); + ringThroughParam.setValueX(doubles[0]>50? doubles[0]+6:doubles[0]-1); + ringThroughParam.setValueY(doubles[1]>50? doubles[1]+6:doubles[1]-1); + result.add(ringThroughParam); + } + return R.ok().add(result); + } + + @PostMapping("/ring/through/track/position/data") +// @ManagerAuth(memo = "杞ㄩ亾PLC鐘舵�佷俊鎭�") + public R wnergyGatheringRingParamTrack(){ + List<EnergyGatheringRingParam> result = new ArrayList<>(); + try{ + for (DevpSlave devp : slaveProperties.getDevp()) { + if (devp.getId()!=1){ + break; + } + SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); + if (devpThread.isResult()){ + if (true){ + EnergyGatheringRingParam energyGatheringRingParam = new EnergyGatheringRingParam(); + energyGatheringRingParam.setTrackColor("rgba(0, 230, 118, 0.5)"); + energyGatheringRingParam.setRadiationColor("rgba(0, 230, 118, 0.5)"); + result.add(energyGatheringRingParam); + } else { + EnergyGatheringRingParam energyGatheringRingParam = new EnergyGatheringRingParam(); + energyGatheringRingParam.setTrackColor("rgba(0, 230, 118, 0.5)"); + energyGatheringRingParam.setRadiationColor("rgba(0, 230, 118, 0.5)"); + result.add(energyGatheringRingParam); + } + } + } + if (result.isEmpty()){ + EnergyGatheringRingParam energyGatheringRingParam = new EnergyGatheringRingParam(); + energyGatheringRingParam.setTrackColor("rgba(0, 0, 0, 81)"); + energyGatheringRingParam.setRadiationColor("rgba(0, 0, 0, 81)"); + result.add(energyGatheringRingParam); + } + } catch (Exception e){ + EnergyGatheringRingParam energyGatheringRingParam = new EnergyGatheringRingParam(); + energyGatheringRingParam.setTrackColor("rgba(0, 0, 0, 81)"); + energyGatheringRingParam.setRadiationColor("rgba(0, 0, 0, 81)"); + result.add(energyGatheringRingParam); } return R.ok().add(result); } -- Gitblit v1.9.1