diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/AgvUtil.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/AgvUtil.java index de549c1..c659fdd 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/AgvUtil.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/AgvUtil.java @@ -6,6 +6,9 @@ import java.util.Calendar; import java.util.Date; import java.util.TimeZone; +/** + * @author 20220102CG\noblelift + */ public class AgvUtil { /** * 获得之后num个天的时间 diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/MagicAgvController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/MagicAgvController.java index 07d8324..63fd698 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/MagicAgvController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/MagicAgvController.java @@ -13,6 +13,9 @@ import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +/** + * @author 20220102CG\noblelift + */ @RestController @RequiredArgsConstructor @Api(tags = "AGV任务") @@ -23,14 +26,13 @@ public class MagicAgvController { /** * 设备请求离开 - * + * @PreAuthorize("@el.check('routePlan:list')") * @param device * @return */ @PostMapping("/agvack/{device}") @Log("AGV请求离开") @ApiOperation("AGV请求离开") - //@PreAuthorize("@el.check('routePlan:list')") public ResponseEntity requestAck(@PathVariable String device) { return new ResponseEntity<>(magicAgvService.requestAck(device), HttpStatus.OK); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/NDCAgvController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/NDCAgvController.java index 39e5192..a972608 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/NDCAgvController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/NDCAgvController.java @@ -1,4 +1,7 @@ package org.nl.acs.agv.rest; +/** + * @author 20220102CG\noblelift + */ public class NDCAgvController { } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/XianGongAgvController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/XianGongAgvController.java index fb4c1b7..3be96d2 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/XianGongAgvController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/XianGongAgvController.java @@ -1,4 +1,7 @@ package org.nl.acs.agv.rest; +/** + * @author 20220102CG\noblelift + */ public class XianGongAgvController { } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/ZheDaAgvController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/ZheDaAgvController.java index e9e2b8f..2a53630 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/ZheDaAgvController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/rest/ZheDaAgvController.java @@ -1,4 +1,7 @@ package org.nl.acs.agv.rest; +/** + * @author 20220102CG\noblelift + */ public class ZheDaAgvController { } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/AgvService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/AgvService.java index 74eb7a5..4ad0de5 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/AgvService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/AgvService.java @@ -7,7 +7,7 @@ import java.util.Map; /** * 所有agv公用接口 - * author + * @author 20220102CG\noblelift */ public interface AgvService { /** diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/MagicAgvService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/MagicAgvService.java index de0e045..1c7439f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/MagicAgvService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/MagicAgvService.java @@ -46,7 +46,7 @@ public interface MagicAgvService { /** - * + * 根据code下发agv任务 * @param code * @return * @throws Exception diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/NDCAgvService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/NDCAgvService.java index b7645bc..10f237f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/NDCAgvService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/NDCAgvService.java @@ -12,7 +12,7 @@ import java.util.Map; */ public interface NDCAgvService { /** - * + * 全部agv * @return */ Map findAllAgvFromCache(); @@ -34,7 +34,7 @@ public interface NDCAgvService { public void sendAgvInstToNDC(String agv_system_type, Instruction inst) throws Exception; /** - * + * 一号agv指令 * @param phase * @param index * @param result @@ -47,7 +47,7 @@ public interface NDCAgvService { public byte[] sendAgvOneModeInst(int phase, int index, int result, int startPoint, int nextPoint, int startHigh, int nextHigh); /** - * + * 下发二号agv指令 * @param phase * @param index * @param result @@ -56,7 +56,7 @@ public interface NDCAgvService { public byte[] sendAgvTwoModeInst(int phase, int index, int result); /** - * + * 下发一号agv指令 * @param phase * @param index * @param result diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/XianGongAgvService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/XianGongAgvService.java index 2ada05b..918a269 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/XianGongAgvService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/XianGongAgvService.java @@ -14,7 +14,7 @@ import java.util.Map; */ public interface XianGongAgvService { /** - * + * 查询所有AGV * @return */ Map findAllAgvFromCache(); @@ -53,7 +53,7 @@ public interface XianGongAgvService { public HttpResponse queryXZAgvDeviceStatus(); /** - * + * 查询AGV任务状态 * @param instCode * @return */ @@ -78,7 +78,7 @@ public interface XianGongAgvService { public HttpResponse sendOrderSequencesToXZ(Instruction inst) throws Exception; /** - * + * 添加 * @param inst * @return * @throws Exception @@ -95,7 +95,7 @@ public interface XianGongAgvService { /** - * + * 创建 * @param inst * @param type * @return diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/ZheDaAgvService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/ZheDaAgvService.java index 137a439..7e43c63 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/ZheDaAgvService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/ZheDaAgvService.java @@ -6,6 +6,7 @@ import org.nl.acs.instruction.domain.Instruction; /** * 浙大AGV服务 + * @author 20220102CG\noblelift */ public interface ZheDaAgvService { @@ -28,7 +29,7 @@ public interface ZheDaAgvService { public HttpResponse queryAgvInstStatus(String floor); /** - * + * AGV任务处理 * @param jobno * @param type * @param address diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/AgvServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/AgvServiceImpl.java index 1f375cc..8786b5b 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/AgvServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/AgvServiceImpl.java @@ -24,6 +24,9 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service @RequiredArgsConstructor diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/MagicAgvServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/MagicAgvServiceImpl.java index c770fc1..4aea8f4 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/MagicAgvServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/MagicAgvServiceImpl.java @@ -38,6 +38,9 @@ import java.util.Map; import static org.nl.acs.device_driver.conveyor.double_station_stacker.enums.CommandEnum.PICKUP_COMPLETE; +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service @RequiredArgsConstructor @@ -173,9 +176,8 @@ public class MagicAgvServiceImpl implements MagicAgvService { } - //指定agv车号 暂时不用 + //指定agv车号 暂时不用 设置任务最终时间 //orderjo.put("intendedVehicle", ""); - //设置任务最终时间 orderjo.put("deadline", AgvUtil.getNextDay(1)); orderjo.put("destinations", ja); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/NDCAgvServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/NDCAgvServiceImpl.java index 37c51cf..1f918fc 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/NDCAgvServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/NDCAgvServiceImpl.java @@ -25,6 +25,9 @@ import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service @RequiredArgsConstructor @@ -64,7 +67,7 @@ public class NDCAgvServiceImpl implements NDCAgvService { }; log.info("下发删除AGV指令--{}", Bytes2HexString(b)); -// NDCSocketConnectionAutoRun.write(b); + // NDCSocketConnectionAutoRun.write(b); System.out.println("下发删除agv指令数据:" + Bytes2HexString(b)); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/XianGongAgvServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/XianGongAgvServiceImpl.java index 7a04ce6..a1e1ab0 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/XianGongAgvServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/XianGongAgvServiceImpl.java @@ -30,6 +30,9 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service @RequiredArgsConstructor diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/ZheDaAgvServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/ZheDaAgvServiceImpl.java index 9d999d5..90135d2 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/ZheDaAgvServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/agv/server/impl/ZheDaAgvServiceImpl.java @@ -27,6 +27,9 @@ import org.nl.system.service.param.ISysParamService; import org.nl.config.SpringContextHolder; import org.springframework.stereotype.Service; +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service @RequiredArgsConstructor @@ -120,13 +123,12 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { } /** - * + * ZDAGV * @param type * @return */ @LokiLog(type = LokiLogType.AGV) @Override - //ZDAGV public HttpResponse queryAgvInstStatus(String type) { if (StrUtil.equals(paramService.findByCode(AcsConfig.FORKAGV).getValue(), CommonFinalParam.ONE)) { String agvurl = ""; @@ -154,7 +156,7 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { } /** - * 处理AGV指令 + * 处理AGV指令 ZDAGV * * @param jobno * @param type @@ -165,7 +167,6 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { */ @LokiLog(type = LokiLogType.AGV) @Override - //ZDAGV public synchronized String process(String jobno, String type, String address, String action, String processingVehicle) { log.info("查询到AGV请求参数,jobno:{},address:{}", jobno + ",address:" + address + ",type:" + type + ",action:" + action); //释放AGV资源,继续后续动作 @@ -197,9 +198,11 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { //豪凯自动线对接位 if (addressdevice.getDeviceDriver() instanceof HongXiangConveyorDeviceDriver) { hongXiangConveyorDeviceDriver = (HongXiangConveyorDeviceDriver) addressdevice.getDeviceDriver(); - if ((hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_ONE || hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_THREE) && hongXiangConveyorDeviceDriver.getMove() == 1) { - inst.setExecute_status(CommonFinalParam.ONE); - is_feedback = true; + if ((hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_ONE || hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_THREE)) { + if(hongXiangConveyorDeviceDriver.getMove() == 1){ + inst.setExecute_status(CommonFinalParam.ONE); + is_feedback = true; + } } } } @@ -291,9 +294,11 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { if (ENTRY_REQUIRED.equals(type)) { if (addressdevice.getDeviceDriver() instanceof HongXiangConveyorDeviceDriver) { hongXiangConveyorDeviceDriver = (HongXiangConveyorDeviceDriver) addressdevice.getDeviceDriver(); - if ((hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_TWO || hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_THREE) && hongXiangConveyorDeviceDriver.getMove() == 0) { - inst.setExecute_status("3"); - is_feedback = true; + if ((hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_TWO || hongXiangConveyorDeviceDriver.getAction() == CommonFinalParam.ACTION_THREE)) { + if(hongXiangConveyorDeviceDriver.getMove() == 0){ + inst.setExecute_status("3"); + is_feedback = true; + } } } } @@ -363,7 +368,7 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { /** - * 返回一个点位操作子任务 + * 返回一个点位操作子任务 ZDAGV * * @param locationName 点位 * @param operation 点位操作 @@ -373,7 +378,6 @@ public class ZheDaAgvServiceImpl implements ZheDaAgvService { * demo:destination("cz14", "JackUnload", "3", "") * @return */ - //ZDAGV @LokiLog(type = LokiLogType.AGV) public static JSONObject destination(String locationName, String operation, String propertiesType, String pro) { //新增业务订单 diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/labeling_template/service/LabelingTemplateService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/labeling_template/service/LabelingTemplateService.java index a0eb218..f1c36a2 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/labeling_template/service/LabelingTemplateService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/labeling_template/service/LabelingTemplateService.java @@ -44,7 +44,7 @@ public interface LabelingTemplateService extends CommonService LabelingTemplate getById(String id); /** - * + * 根据id查询 * @param id * @return */ @@ -59,21 +59,21 @@ public interface LabelingTemplateService extends CommonService int insert(LabelingTemplateDto resources); /** - * + * 根据id修改 * @param resources * @return */ int updateById(LabelingTemplateDto resources); /** - * + * 根据id删除 * @param id * @return */ int removeById(String id); /** - * + * 根据多个id删除 * @param ids * @return */ diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/BlockedRunable.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/BlockedRunable.java index 9eb511d..f21e6c9 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/BlockedRunable.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/BlockedRunable.java @@ -4,6 +4,9 @@ import java.util.Date; import java.util.HashMap; import java.util.Map; +/** + * @author LENOVO + */ public abstract class BlockedRunable implements Runnable { private String threadName; private Date startTime; @@ -16,10 +19,19 @@ public abstract class BlockedRunable implements Runnable { this.index = index; } + /** + * 获取code + * @return + */ public abstract String getCode(); + /** + * subRun + * @throws Exception + */ public abstract void subRun() throws Exception; + @Override public void run() { try { this.setStartTime(new Date()); @@ -60,6 +72,7 @@ public abstract class BlockedRunable implements Runnable { this.index = index; } + @Override public int hashCode() { int prime = 1; int result = 1; @@ -67,6 +80,7 @@ public abstract class BlockedRunable implements Runnable { return result; } + @Override public boolean equals(Object obj) { if (this == obj) { return true; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppService.java index b507a05..c912d0f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppService.java @@ -8,6 +8,9 @@ import org.nl.acs.device_driver.LinewayDeviceDriver; import java.util.List; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ public interface DeviceAppService { /** * 查找所有设备 @@ -32,6 +35,11 @@ public interface DeviceAppService { */ Device findDeviceByAddress(String address); + /** + * 设备总数 + * + * @return + */ int deviceSize(); /** @@ -41,6 +49,10 @@ public interface DeviceAppService { */ Map>> findAllFormatProtocolFromDriver(); + /** + * key:opcServer编码,List 每个opcServe下面挂了多少Plc + * @return + */ Map>> findAllFormatProtocolFromDriverByPlc(); @@ -61,6 +73,12 @@ public interface DeviceAppService { */ Map findDeviceOptions(DeviceType deviceType); + /** + * 根据设备类型查找设备 + * + * @param deviceType + * @return + */ List findDeviceByType(DeviceType deviceType); /** @@ -71,8 +89,16 @@ public interface DeviceAppService { */ List findDevice(DeviceType deviceType); + /** + * 重新加载设备驱动 + */ void reload(); + /** + * 找线网设备 + * + * @return + */ List findLaneway(); /** @@ -83,8 +109,18 @@ public interface DeviceAppService { */ String findDeviceTypeByCode(String deviceCode); + /** + * 移除设备 + * + * @param deviceCode + */ void removeDevice(String deviceCode); + /** + * 添加设备 + * + * @param deviceCode + */ void addDevice(String deviceCode); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppServiceImpl.java index d4b0124..1077a59 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceAppServiceImpl.java @@ -17,11 +17,20 @@ import org.springframework.stereotype.Service; import java.util.*; +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service public class DeviceAppServiceImpl implements DeviceAppService, ApplicationAutoInitial { - private List devices = new ArrayList(); // 所有设备链表 - private List code_indexs = new ArrayList(); // 设备对应的下表 + /** + * 所有设备链表 + */ + private List devices = new ArrayList(); + /** + * 设备对应的下表 + */ + private List code_indexs = new ArrayList(); @Autowired private DeviceManageService deviceManageService; @Autowired @@ -48,6 +57,7 @@ public class DeviceAppServiceImpl implements DeviceAppService, ApplicationAutoIn return device; } + @Override public Device findDeviceByAddress(String address) { Iterator var2 = this.findAllDevice().iterator(); @@ -304,6 +314,7 @@ public class DeviceAppServiceImpl implements DeviceAppService, ApplicationAutoIn return null; } + @Override public List findLaneway() { return this.findDeviceDriver(LinewayDeviceDriver.class); } @@ -314,6 +325,7 @@ public class DeviceAppServiceImpl implements DeviceAppService, ApplicationAutoIn this.reload(); } + @Override public synchronized void reload() { List deviceManageDtos = deviceManageService.queryAllWithExtra(); this.devices = new ArrayList(); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceDriverDefinationAppServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceDriverDefinationAppServiceImpl.java index afaf08a..f3a3b0d 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceDriverDefinationAppServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceDriverDefinationAppServiceImpl.java @@ -15,6 +15,9 @@ import org.springframework.stereotype.Service; import java.util.*; +/** + * @author 20220102CG\noblelift + */ @Service @Slf4j public class DeviceDriverDefinationAppServiceImpl implements DeviceDriverDefinationAppService, InitializingBean, ApplicationContextAware { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExecuteAutoRun.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExecuteAutoRun.java index bfb4009..7acb57b 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExecuteAutoRun.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExecuteAutoRun.java @@ -10,6 +10,9 @@ import org.springframework.stereotype.Component; import java.util.*; import java.util.concurrent.*; +/** + * @author 20220102CG\noblelift + */ @Component @Slf4j public class DeviceExecuteAutoRun extends AbstractAutoRunnable { @@ -83,7 +86,6 @@ public class DeviceExecuteAutoRun extends AbstractAutoRunnable { } } -// Thread.sleep(10000L); log.info("设备执行线程开始..."); while (true) { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExtraManageDto.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExtraManageDto.java index 8589dd7..1a7d63d 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExtraManageDto.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExtraManageDto.java @@ -2,6 +2,9 @@ package org.nl.acs.opc; import lombok.Data; +/** + * @author 20220102CG\noblelift + */ @Data public class DeviceExtraManageDto { private String device_id; @@ -17,7 +20,6 @@ public class DeviceExtraManageDto { public Object parseName() { - //return DictionaryUtl.parseValue(this.getCollection_type(), this.getValue_type(), this.getName()); return extra_value; } } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageDto.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageDto.java index 335007f..30f34d3 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageDto.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageDto.java @@ -6,6 +6,9 @@ import lombok.Data; import java.util.*; +/** + * @author 20220102CG\noblelift + */ @Data public class DeviceManageDto { private static final long serialVersionUID = 1L; @@ -53,16 +56,24 @@ public class DeviceManageDto { private Boolean is_configed; private Boolean is_exist; private Boolean is_entrance; - /* 粉桶号 */ + /** + * 粉桶号 + */ private String barrels_code; - /* 配合批号 */ + /** + * 配合批号 + */ private String cooperate_code; - /* 粉种名称 */ + /** + * 粉种名称 + */ private String powder_name; - /* 粉桶状态 */ + /** + * 粉桶状态 + */ private String barrels_status; private List extra = new LinkedList(); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageService.java index a592f2a..856ac5e 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageService.java @@ -2,8 +2,20 @@ package org.nl.acs.opc; import java.util.List; +/** + * @author 20220102CG\noblelift + */ public interface DeviceManageService { + /** + * 查询所有设备 + * @return + */ List queryAllWithExtra(); + /** + * 根据设备编号查询设备 + * @param device_code + * @return + */ List queryAllWithExtra(String device_code); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageServiceImpl.java index b641ad3..774d098 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceManageServiceImpl.java @@ -21,7 +21,9 @@ import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.Iterator; import java.util.List; - +/** + * @author 20220102CG\noblelift + */ @Service public class DeviceManageServiceImpl implements DeviceManageService { @@ -42,24 +44,19 @@ public class DeviceManageServiceImpl implements DeviceManageService { @Override public List queryAllWithExtra() { -// JSONArray arr = WQLObject.getWQLObject("acs_device").query().getResultJSONArray(0); // 获取所有的设备 List deviceList = new LambdaQueryChainWrapper<>(deviceMapper).list(); JSONArray arr = JSONArray.parseArray(JSON.toJSONString(deviceList)); // 获取列表扩展 -// JSONArray extArr = WQLObject.getWQLObject("acs_device_extra").query().getResultJSONArray(0); List deviceExtraList = new LambdaQueryChainWrapper<>(deviceExtraMapper).list(); JSONArray extArr = JSONArray.parseArray(JSON.toJSONString(deviceExtraList)); // 设备+扩展DTO List extras = extArr.toJavaList(DeviceExtraManageDto.class); -// WQLObject runpointTab = WQLObject.getWQLObject("acs_device_runpoint"); -// WQLObject opcTab = WQLObject.getWQLObject("acs_opc"); //OPC_PLC表【acs_opc_plc】 -// WQLObject plcTab = WQLObject.getWQLObject("acs_opc_plc"); List devices = new ArrayList<>(); for (int i = 0; i < arr.size(); i++) { JSONObject json = arr.getJSONObject(i); @@ -68,7 +65,6 @@ public class DeviceManageServiceImpl implements DeviceManageService { String opc_plc_id = json.getString("opc_plc_id"); if (StrUtil.isNotEmpty(opc_plc_id) && StrUtil.isNotEmpty(opc_server_id)) { //OPC表【acs_opc】 -// String opc_code = opcTab.query("is_delete= '0' AND is_active= '1' AND opc_id = '" + opc_server_id + "'").uniqueResult(0).getString("opc_code"); String opc_code = new LambdaQueryChainWrapper<>(opcMapper).apply("is_delete= '0' AND is_active= '1' AND opc_id = '" + opc_server_id + "'") .one().getOpc_code(); /*Opc opc = opcMapper.selectOne(Wrappers.lambdaQuery(Opc.class).eq(Opc::getIs_delete, "0").eq(Opc::getIs_active, CommonFinalParam.ONE).eq(Opc::getOpc_id, opc_server_id)); @@ -77,12 +73,10 @@ public class DeviceManageServiceImpl implements DeviceManageService { opc_code = opc.getOpc_code(); }*/ device.setOpc_server_code(opc_code); -// if(ObjectUtil.isEmpty(plcTab.query("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").uniqueResult(0))) if (ObjectUtil.isEmpty(new LambdaQueryChainWrapper<>(opcPlcMapper).apply("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").one())) { System.out.println(device.getDevice_code()); continue; } -// String plc_code = plcTab.query("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").uniqueResult(0).getString("plc_code"); String plc_code = new LambdaQueryChainWrapper<>(opcPlcMapper).apply("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").one().getPlc_code(); device.setOpc_plc_code(plc_code); } @@ -99,10 +93,6 @@ public class DeviceManageServiceImpl implements DeviceManageService { if (extra.getDevice_id().equals(device.getDevice_id())) { device.getExtra().add(extra); if (StrUtil.equals(extra.getExtra_code(), "station_manager") && StrUtil.equals(extra.getExtra_value().toString(), "true")) { -// String has_goods = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("hasgoods"); -// String material_type = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("material_type"); -// String batch = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("batch"); -// String islock = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("islock"); String has_goods = new LambdaQueryChainWrapper<>(deviceRunpointMapper).apply("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").one().getHasgoods(); String material_type = new LambdaQueryChainWrapper<>(deviceRunpointMapper).apply("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").one().getMaterial_type(); String batch = new LambdaQueryChainWrapper<>(deviceRunpointMapper).apply("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").one().getBatch(); @@ -121,21 +111,15 @@ public class DeviceManageServiceImpl implements DeviceManageService { @Override public List queryAllWithExtra(String device_code) { -// JSONArray arr = WQLObject.getWQLObject("acs_device").query("device_code = '" + device_code + " '").getResultJSONArray(0); List deviceList = new LambdaQueryChainWrapper<>(deviceMapper).eq(Device::getDevice_code, device_code).list(); JSONArray arr = JSONArray.parseArray(JSON.toJSONString(deviceList)); -// JSONArray extArr = WQLObject.getWQLObject("acs_device_extra").query("device_code = '" + device_code + " '").getResultJSONArray(0); List deviceExtraList = new LambdaQueryChainWrapper<>(deviceExtraMapper).eq(DeviceExtra::getDevice_code, device_code).list(); JSONArray extArr = JSONArray.parseArray(JSON.toJSONString(deviceExtraList)); List extras = extArr.toJavaList(DeviceExtraManageDto.class); -// WQLObject runpointTab = WQLObject.getWQLObject("acs_device_runpoint"); -// WQLObject opcTab = WQLObject.getWQLObject("acs_opc"); - //OPC_PLC表【acs_opc_plc】 -// WQLObject plcTab = WQLObject.getWQLObject("acs_opc_plc"); List devices = new ArrayList<>(); for (int i = 0; i < arr.size(); i++) { JSONObject json = arr.getJSONObject(i); @@ -143,8 +127,6 @@ public class DeviceManageServiceImpl implements DeviceManageService { String opc_server_id = json.getString("opc_server_id"); String opc_plc_id = json.getString("opc_plc_id"); if (StrUtil.isNotEmpty(opc_plc_id) && StrUtil.isNotEmpty(opc_server_id)) { - //OPC表【acs_opc】 -// JSONObject rb = opcTab.query("is_delete= '0' AND is_active= '1' AND opc_id = '" + opc_server_id + "'").uniqueResult(0); Opc opc = new LambdaQueryChainWrapper<>(opcMapper).apply("is_delete= '0' AND is_active= '1' AND opc_id = '" + opc_server_id + "'").one(); if (ObjectUtil.isEmpty(opc)) { System.out.println(device.getDevice_code()); @@ -152,12 +134,10 @@ public class DeviceManageServiceImpl implements DeviceManageService { } String opc_code = opc.getOpc_code(); device.setOpc_server_code(opc_code); -// if(ObjectUtil.isEmpty(plcTab.query("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").uniqueResult(0))) if (ObjectUtil.isEmpty(new LambdaQueryChainWrapper<>(opcPlcMapper).apply("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").one())) { System.out.println(device.getDevice_code()); continue; } -// String plc_code = plcTab.query("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").uniqueResult(0).getString("plc_code"); String plc_code = new LambdaQueryChainWrapper<>(opcPlcMapper).apply("is_delete= '0' AND is_active= '1' AND plc_id = '" + opc_plc_id + "'").one().getPlc_code(); device.setOpc_plc_code(plc_code); } @@ -174,10 +154,6 @@ public class DeviceManageServiceImpl implements DeviceManageService { if (extra.getDevice_id().equals(device.getDevice_id())) { device.getExtra().add(extra); if (StrUtil.equals(extra.getExtra_code(), "station_manager") && StrUtil.equals(extra.getExtra_value().toString(), "true")) { -// String has_goods = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("hasgoods"); -// String material_type = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("material_type"); -// String batch = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("batch"); -// String islock = runpointTab.query("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").uniqueResult(0).getString("islock"); String has_goods = new LambdaQueryChainWrapper<>(deviceRunpointMapper).apply("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").one().getHasgoods(); String material_type = new LambdaQueryChainWrapper<>(deviceRunpointMapper).apply("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").one().getMaterial_type(); String batch = new LambdaQueryChainWrapper<>(deviceRunpointMapper).apply("is_delete= '0' AND is_active= '1' AND device_id = '" + extra.getDevice_id() + "'").one().getBatch(); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java index 748fe5e..1f7ffc9 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java @@ -17,7 +17,9 @@ import org.springframework.stereotype.Service; import java.util.*; - +/** + * @author 20220102CG\noblelift + */ @Slf4j @Service public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerConnectionStateListener { @@ -359,6 +361,7 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC } + @Override public void connectionStateChanged(boolean connected) { if (!connected) { this.server = null; @@ -381,6 +384,7 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC } + @Override public void changed(Item item, ItemState itemState) { String itemId = item.getId(); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java index a202060..65f5d3f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceOpcSynchronizeAutoRun.java @@ -16,6 +16,7 @@ import java.util.concurrent.Executors; /** * OPC设备同步启动 + * @author 20220102CG\noblelift */ @Component public class DeviceOpcSynchronizeAutoRun extends AbstractAutoRunnable { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/JsonUtl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/JsonUtl.java index 6b1fc80..ccdb0da 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/JsonUtl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/JsonUtl.java @@ -12,6 +12,9 @@ import java.io.IOException; import java.util.List; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ public class JsonUtl { private static ObjectMapper objectMapper = null; private static ObjectMapper objectMapperLog = null; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/ObjectUtl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/ObjectUtl.java index b43fc4c..fa4dbd1 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/ObjectUtl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/ObjectUtl.java @@ -4,6 +4,9 @@ package org.nl.acs.opc; import java.util.Arrays; import java.util.Objects; +/** + * @author 20220102CG\noblelift + */ public class ObjectUtl { private ObjectUtl() { } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcConfig.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcConfig.java index 8507168..44eccaa 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcConfig.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcConfig.java @@ -1,5 +1,8 @@ package org.nl.acs.opc; +/** + * @author 20220102CG\noblelift + */ public class OpcConfig { public static Boolean auto_start_opc = Boolean.valueOf(true); public static String udw_opc_value_key = "opc_value"; @@ -11,6 +14,8 @@ public class OpcConfig { public static String resource_code = "opc_sync"; public static String resource_name = "opc同步"; - //OPC 数据同步是否采用回调机制实现。之前是线程定期全部读,效率低。 + /** + * OPC 数据同步是否采用回调机制实现。之前是线程定期全部读,效率低。 + */ public static Boolean opc_item_read_using_callback = false; } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcItemDto.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcItemDto.java index 677d00f..63c6efd 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcItemDto.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcItemDto.java @@ -3,6 +3,9 @@ package org.nl.acs.opc; import java.util.ArrayList; import java.util.List; +/** + * @author 20220102CG\noblelift + */ public class OpcItemDto { private String device_code; private String device_name; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerManageService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerManageService.java index b3ec34b..0426284 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerManageService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerManageService.java @@ -4,6 +4,14 @@ import org.nl.acs.opc.service.dto.OpcServerManageDto; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ public interface OpcServerManageService { + /** + * 查询所有opc服务器 + * + * @return + */ Map queryAllServerMap(); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerService.java index 6341f02..54ab3df 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerService.java @@ -11,15 +11,42 @@ import org.openscada.opc.lib.da.Group; */ public interface OpcServerService { + /** + * 重新加载 + */ void reload(); + /** + * 获取服务器 + * @param var1 + * @return + */ Group getServer(String var1); + /** + * 获取服务器 + * @param var1 + * @return + */ Group getServerByNewConn(String var1); + /** + * 写入整数 + * @param var1 + * @param var2 + */ void writeInteger(String var1, ItemValue... var2); + /** + * 写入整数 + * @param var1 + * @param var2 + */ void writeIntegerByNewConn(String var1, ItemValue... var2); + /** + * 清除服务器 + * @param var1 + */ void clearServer(String var1); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java index 9098f0a..8dcd2e5 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java @@ -46,6 +46,7 @@ public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoIn * * @throws Exception */ + @Override public void autoInitial() throws Exception { this.reload(); // 加载opc服务 if (OpcConfig.auto_start_opc) { @@ -68,11 +69,13 @@ public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoIn } } + @Override public synchronized void reload() { this.opcServerManageDtos = this.opcServerManageService.queryAllServerMap(); this.opcServerManageDtos = Collections.synchronizedMap(this.opcServerManageDtos); } + @Override public synchronized Group getServer(String code) { synchronized (this.buildLock(code)) { Group group = null; @@ -188,6 +191,7 @@ public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoIn } } + @Override public synchronized void clearServer(String code) { try { Server server = (Server) this.servers.get(code); @@ -204,6 +208,7 @@ public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoIn this.groups.remove(code); } + @Override public void writeInteger(String code, ItemValue... values) { try { Group group = this.getServer(code); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerUtl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerUtl.java index 8bce071..49dcca4 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerUtl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcServerUtl.java @@ -3,6 +3,9 @@ package org.nl.acs.opc; import cn.hutool.core.util.StrUtil; import org.openscada.opc.lib.da.Server; +/** + * @author 20220102CG\noblelift + */ public class OpcServerUtl { public static synchronized Server getServerWithOutException(String host, String clsid, String user, String password, diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcStartTag.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcStartTag.java index 0b1679a..c782740 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcStartTag.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcStartTag.java @@ -1,5 +1,8 @@ package org.nl.acs.opc; +/** + * @author 20220102CG\noblelift + */ public class OpcStartTag { public static boolean is_run = false; } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcUtl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcUtl.java index 7853031..f24cec9 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcUtl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/OpcUtl.java @@ -17,6 +17,9 @@ import java.util.List; import java.util.Map; import java.util.concurrent.Executors; +/** + * @author 20220102CG\noblelift + */ @Slf4j public class OpcUtl { private static int timeout = 1 * 60 * 1000; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/QualityTypeValue.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/QualityTypeValue.java index d3dbb0f..62df4c5 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/QualityTypeValue.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/QualityTypeValue.java @@ -1,5 +1,8 @@ package org.nl.acs.opc; +/** + * @author 20220102CG\noblelift + */ public class QualityTypeValue { public static short OPC_QUALITY_GOOD = 192; public static short OPC_QUALITY_LOCAL_OVERRIDE = 216; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/WcsConfig.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/WcsConfig.java index 7f7f745..bf2a718 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/WcsConfig.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/WcsConfig.java @@ -1,16 +1,25 @@ package org.nl.acs.opc; +/** + * @author 20220102CG\noblelift + */ public class WcsConfig { public static Integer opc_group_sync_max_item = 700; - //设备是否需要校验在线 + /** + * 设备是否需要校验在线 + */ public static Boolean fake_online; - //物料默认类型描述 + /** + * 物料默认类型描述 + */ public static String task_container_type_default_desc; - //重复的指令下发超时 ms + /** + * 重复的指令下发超时 ms + */ public static Integer opc_write_repeat_check = 1000; } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/opcServerManageServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/opcServerManageServiceImpl.java index 5767b49..a4ad211 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/opcServerManageServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/opcServerManageServiceImpl.java @@ -16,6 +16,9 @@ import java.util.Iterator; import java.util.List; import java.util.Map; +/** + * @author 20220102CG\noblelift + */ @Service public class opcServerManageServiceImpl implements OpcServerManageService { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/OpcService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/OpcService.java index 3d66bf5..87e2a0c 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/OpcService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/OpcService.java @@ -41,19 +41,48 @@ public interface OpcService extends CommonService { */ List queryAll(OpcQueryParam query); + /** + * 根据ID查询 + * + * @param id ID + * @return Opc + */ Opc getById(String id); + /** + * 根据ID查询 + * + * @param id ID + * @return OpcDto + */ OpcDto findById(String id); /** * 插入一条新数据。 + * @param resources + * @return */ int insert(OpcDto resources); + /** + * 编辑一条数据 + * @param resources + * @return + */ int updateById(OpcDto resources); + /** + * 删除数据 + * @param id + * @return + */ int removeById(String id); + /** + * 根据多个id删除 + * @param ids + * @return + */ int removeByIds(Set ids); /** @@ -136,11 +165,30 @@ public interface OpcService extends CommonService { */ OpcDto queryServerPlc(String opc_id); + /** + * 查询 + * + * @param whereJson 条件 + * @return Map + */ HashMap getmeteal(Map whereJson); + /** + * 创建PLC + * + * @param map map + */ void createPLC(Map map); + /** + * 删除plc + * @param map + */ void delPLC(Map map); + /** + * 编辑plc + * @param json + */ void editPLC(JSONObject json); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/dto/OpcServerManageDto.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/dto/OpcServerManageDto.java index 9222a05..f9ea7ae 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/dto/OpcServerManageDto.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/dto/OpcServerManageDto.java @@ -1,5 +1,8 @@ package org.nl.acs.opc.service.dto; +/** + * @author 20220102CG\noblelift + */ public class OpcServerManageDto { private static final long serialVersionUID = 1L; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/impl/OpcServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/impl/OpcServiceImpl.java index 98af6f2..9d07398 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/impl/OpcServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/service/impl/OpcServiceImpl.java @@ -48,10 +48,11 @@ import java.util.*; @Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) public class OpcServiceImpl extends CommonServiceImpl implements OpcService { - // private final RedisUtils redisUtils; private final OpcMapper opcMapper; private final OpcPlcMapper opcPlcMapper; + private static final String BLURRY = "blurry"; + @Override public PageInfo queryAll(OpcQueryParam query, Pageable pageable) { IPage queryPage = PageUtil.toMybatisPage(pageable); @@ -130,7 +131,7 @@ public class OpcServiceImpl extends CommonServiceImpl implements IPage queryPage = PageUtil.toMybatisPage(page); LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(Opc::getIs_delete, "0").eq(Opc::getIs_active, CommonFinalParam.ONE); - if (whereJson.get("blurry") != null) { + if (whereJson.get(BLURRY) != null) { wrapper.like(Opc::getOpc_code, whereJson.get("blurry")).or().like(Opc::getOpc_name, whereJson.get("blurry")).or().like(Opc::getOpc_host, whereJson.get("blurry")); } IPage opcPage = opcMapper.selectPage(queryPage, wrapper); @@ -179,7 +180,7 @@ public class OpcServiceImpl extends CommonServiceImpl implements @Override public List queryAll(Map whereJson) { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); - if (whereJson.get("blurry") != null) { + if (whereJson.get(BLURRY) != null) { wrapper.like(Opc::getOpc_code, whereJson.get("blurry")).or().like(Opc::getOpc_name, whereJson.get("blurry")).or().like(Opc::getOpc_host, whereJson.get("blurry")); } return ConvertUtil.convertList(opcMapper.selectList(wrapper), OpcDto.class);