diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/basedriver/plc_to_agv/PlcToAgvDeviceDriver.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/basedriver/plc_to_agv/PlcToAgvDeviceDriver.java index a95da68..4635d7e 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/basedriver/plc_to_agv/PlcToAgvDeviceDriver.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/basedriver/plc_to_agv/PlcToAgvDeviceDriver.java @@ -121,7 +121,6 @@ public class PlcToAgvDeviceDriver extends AbstractOpcDeviceDriver implements Dev } - /** * 多个信号一起下发电气 * @@ -148,25 +147,26 @@ public class PlcToAgvDeviceDriver extends AbstractOpcDeviceDriver implements Dev } public void writing(String param, String value) { + if (!"heartbeat".equals(param)) { + String to_param = this.getDevice().getOpc_server_code() + "." + this.getDevice().getOpc_plc_code() + "." + this.getDevice().getDevice_code() + + "." + param; - String to_param = this.getDevice().getOpc_server_code() + "." + this.getDevice().getOpc_plc_code() + "." + this.getDevice().getDevice_code() - + "." + param; - - Map itemMap = new HashMap(); + Map itemMap = new HashMap(); - itemMap.put(to_param, Integer.parseInt(value)); - try { - Thread.sleep(1000); - this.checkcontrol(itemMap); - } catch (Exception e) { - e.printStackTrace(); + itemMap.put(to_param, Integer.parseInt(value)); + try { + Thread.sleep(1000); + this.checkcontrol(itemMap); + } catch (Exception e) { + e.printStackTrace(); + } + LuceneLogDto logDto = LuceneLogDto.builder() + .device_code(device_code) + .content("下发多个电气信号" + itemMap) + .build(); + logDto.setLog_level(4); + luceneExecuteLogService.deviceExecuteLog(logDto); } - LuceneLogDto logDto = LuceneLogDto.builder() - .device_code(device_code) - .content("下发多个电气信号" + itemMap) - .build(); - logDto.setLog_level(4); - luceneExecuteLogService.deviceExecuteLog(logDto); } public void writing(List list) { @@ -231,7 +231,7 @@ public class PlcToAgvDeviceDriver extends AbstractOpcDeviceDriver implements Dev jo.put("signals_are_allowed", AGVSetInLowerAllowed == 1 ? "下层允许上料请求" : AGVSetOutLowerAllowed == 1 ? "下层允许下料请求" : AGVSetInUpperAllowed == 1 ? "上层允许上料请求" : AGVSetOutUpperAllowed == 1 ? "上层允许下料请求" : "未允许"); jo.put("agv_enable", AGVEnable == 1 ? "启用" : "禁用"); - jo.put("request_a_signal",AGVSetInReqUpper == 1 ? "上层上料请求" : AGVSetInReqLower == 1 ? "下层上料请求" + jo.put("request_a_signal", AGVSetInReqUpper == 1 ? "上层上料请求" : AGVSetInReqLower == 1 ? "下层上料请求" : AGVSetOutReqUpper == 1 ? "上层下料请求" : AGVSetOutReqLower == 1 ? "下层下料请求" : "未请求"); jo.put("agv_inop", AGVInOP == 1 ? "AGV动作中" : "AGV空闲"); return jo; 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 6efd70b..50e09ca 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 @@ -207,10 +207,12 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC } if(!ObjectUtil.isEmpty(value) || "".equals(value)){ accessor_value.setValue(itemId, value); - LuceneLogDto luceneLogDto = new LuceneLogDto(itemDto.getOpc_server_code(), itemDto.getOpc_plc_code(),4, itemDto.getDevice_code(), itemDto.getItem_code().substring(itemDto.getItem_code().lastIndexOf(".") + 1), - String.valueOf(his), String.valueOf(value)); - luceneLogDto.setLogType(LogTypeEnum.DEVICE_LOG.getDesc()); - log.info("{}", JSON.toJSONString(luceneLogDto)); + if(!"heartbeat".equals(itemDto.getItem_code().substring(itemDto.getItem_code().lastIndexOf(".") + 1))){ + LuceneLogDto luceneLogDto = new LuceneLogDto(itemDto.getOpc_server_code(), itemDto.getOpc_plc_code(),4, itemDto.getDevice_code(), itemDto.getItem_code().substring(itemDto.getItem_code().lastIndexOf(".") + 1), + String.valueOf(his), String.valueOf(value)); + luceneLogDto.setLogType(LogTypeEnum.DEVICE_LOG.getDesc()); + log.info("{}", JSON.toJSONString(luceneLogDto)); + } } if(ObjectUtil.isEmpty(value) && !"".equals(value)){ accessor_value.removeValue(itemId); diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java index 7e1ee17..80f8d3b 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java @@ -400,9 +400,9 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { json.put("task_code", schBaseTask.getTask_code()); AcsResponse acsResponse = connectorService.feedAgvTaskStatus(json); } - List list = iSchBaseVehiclematerialgroupService.selectOrdersByVehicleCode(schBaseTask.getVehicle_code()); + /*List list = iSchBaseVehiclematerialgroupService.selectOrdersByVehicleCode(schBaseTask.getVehicle_code()); //同步fab工序流程 - FabServiceImpl.syncFab(list); + FabServiceImpl.syncFab(list);*/ } else if ("2".equals(is_connector)) { JSONObject json = new JSONObject(); json.put("vehicle_code", schBaseTask.getVehicle_code()); diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/controller/FabController.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/controller/FabController.java index 932764a..0742fe5 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/controller/FabController.java +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/controller/FabController.java @@ -91,16 +91,29 @@ public class FabController { /** * 根据工序查询订单 * - * @param regionCode + * @param deviceCode * @return */ - @Log("根据工序查询工单") + @Log("根据设备工序查询工单") @GetMapping("/regionOrder") - public ResponseEntity> regionOrder(String deviceCode) { + public ResponseEntity> selectOrderByPointCode(String deviceCode) { List structList = iSchBasePointService.getStructList(deviceCode, null); return new ResponseEntity(TableDataInfo.build(structList), HttpStatus.OK); } + /** + * 根据工序查询订单 + * + * @param + * @return + */ + @Log("根据工序查询工单") + @GetMapping("/selectOrderByRegion") + public ResponseEntity> regionOrder(String regionCode) { + List structList = iSchBasePointService.selectOrder(regionCode); + return new ResponseEntity(TableDataInfo.build(structList), HttpStatus.OK); + } + /** * 根据工单查询匹配库存 * @@ -279,16 +292,24 @@ public class FabController { @Log("查询订单号") @PostMapping("/orders") public ResponseEntity selectOrders(@RequestBody SendVehicleVo sendVehicleVo) { - if (StrUtil.isEmpty(sendVehicleVo.getDevice_code()) && StrUtil.isEmpty(sendVehicleVo.getVehicle_code())) { + List deviceCodes = sendVehicleVo.getDeviceCodes(); + if (CollUtil.isEmpty(deviceCodes) && StrUtil.isEmpty(sendVehicleVo.getVehicle_code())) { throw new BadRequestException("请输入设备号或载具号!"); } List list = null; if (StrUtil.isNotEmpty(sendVehicleVo.getVehicle_code())) { - list = iSchBaseVehiclematerialgroupService.selectOrdersByVehicleCode(sendVehicleVo.getVehicle_code()); - } else if (StrUtil.isNotEmpty(sendVehicleVo.getDevice_code())) { - SchBasePoint schBasePoint = iSchBasePointService.selectByPointCode(sendVehicleVo.getDevice_code()); - if (ObjectUtil.isEmpty(schBasePoint)) throw new BadRequestException("设备不存在!"); - list = iSchBaseVehiclematerialgroupService.selectOrdersByVehicleCode(schBasePoint.getVehicle_code()); + deviceCodes = new ArrayList<>(); + deviceCodes.add(sendVehicleVo.getVehicle_code()); + list = iSchBaseVehiclematerialgroupService.selectOrdersByVehicleCode(deviceCodes); + } else if (CollUtil.isNotEmpty(deviceCodes)) { + List vehicleCodes = new ArrayList<>(); + deviceCodes.stream().forEach(deviceCode -> { + SchBasePoint schBasePoint = iSchBasePointService.selectByPointCode(deviceCode); + if (ObjectUtil.isEmpty(schBasePoint)) throw new BadRequestException("设备不存在!"); + vehicleCodes.add(schBasePoint.getVehicle_code()); + } + ); + list = iSchBaseVehiclematerialgroupService.selectOrdersByVehicleCode(vehicleCodes); } HashSet keys = new HashSet<>(); list.stream().forEach(item -> { diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/service/dto/SendVehicleVo.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/service/dto/SendVehicleVo.java index e2581d3..52a3f8e 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/service/dto/SendVehicleVo.java +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/fab/service/dto/SendVehicleVo.java @@ -36,4 +36,6 @@ public class SendVehicleVo { */ List sendVehicleVoList; + List deviceCodes; + } diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/sorting/service/impl/SortingServiceImpl.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/sorting/service/impl/SortingServiceImpl.java index f4c70d3..905220b 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/sorting/service/impl/SortingServiceImpl.java +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/sorting/service/impl/SortingServiceImpl.java @@ -172,11 +172,14 @@ public class SortingServiceImpl implements SortingService { .set("is_lock", true) .set("remark", task_code) .eq("point_code", pointCode + "_01")); + jsonObject.put("pallet_detail",jsonArray1); + taskParam = new JSONObject(MapOf.of("task_code", task_code, "job_name", jobname, "device_code", pointCode, "requestNo" + , "sorting_" + IdUtil.getStringId(), "ext_data", jsonObject, "vehicle_code", vehicle_code, "ext_data", jsonObject)); + taskParam.put("config_code", "SortingSMTTask"); taskParam.put("task_seq", "1"); taskParam.put("vehicle_code", jsonObject.getString("vehicle_code2")); taskParam.put("device_code", pointCode + "_02"); taskParam.put("task_code", task_code + "B"); - taskParam.put("ext_data", jsonObject.put("pallet_detail",jsonArray1)); connectorTask.apply(taskParam); iSchBasePointService.update(new UpdateWrapper() .set("is_lock", true) diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java index 19c0be4..4f421bd 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/ISchBaseVehiclematerialgroupService.java @@ -72,7 +72,7 @@ public interface ISchBaseVehiclematerialgroupService extends IService selectOrdersByVehicleCode(String vehicle_code); + List selectOrdersByVehicleCode(List vehicle_code); /** * 根据载具号查找物料信息 diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java index e36a5c5..0e66d97 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.java @@ -21,7 +21,7 @@ public interface SchBaseVehiclematerialgroupMapper extends BaseMapper selectOrders(String vehicle_code); + List selectOrders(@Param("list") List vehicleCodes); List selectMaterialByVehicleCode(String vehicle_code); } diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml index c08f9a4..4216693 100644 --- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml +++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/group/service/dao/mapper/SchBaseVehiclematerialgroupMapper.xml @@ -50,10 +50,13 @@ AND vg.group_bind_material_status = '2' - SELECT sbv.order_code FROM sch_base_vehiclematerialgroup sbv - WHERE sbv.vehicle_code = #{vehicle_code} + WHERE sbv.vehicle_code IN + + #{code} +