From fefdead3f5c1504adbf96f08f8d75ac418a105db Mon Sep 17 00:00:00 2001 From: "ZHOUZ\\Noble'lift" <1014987728@qq.com> Date: Tue, 9 Jan 2024 08:38:37 +0800 Subject: [PATCH] =?UTF-8?q?rev:=E5=86=85=E5=8C=85=E9=97=B4=E9=80=BB?= =?UTF-8?q?=E8=BE=91=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../acs/service/impl/AcsToWmsServiceImpl.java | 85 +++++++++++++++++-- .../org/nl/wms/sch/tasks/PaperTubeTask.java | 6 +- .../java/org/nl/wms/sch/wql/QAUTO_QUERY.wql | 27 +++++- .../src/views/wms/pdm/ivt/package/index.vue | 16 +++- 4 files changed, 121 insertions(+), 13 deletions(-) diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java index 6c584841e..8a2d81bb2 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java @@ -1093,7 +1093,33 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { //查询当前输送线入口是否存在可用的载具 JSONObject in_jo = WQLObject.getWQLObject("sch_base_point").query("product_area = '" + product_area + "' AND point_type = '6'").uniqueResult(0); String vehicle_code = in_jo.getString("vehicle_code"); -// JSONObject vehicle_jo = WQLObject.getWQLObject("md_pb_vehiclearea").query("vehicle_code = '" + vehicle_code + "'").uniqueResult(0); + if (StrUtil.isNotEmpty(vehicle_code)) { + //判断是否存在010606 的任务存在 + JSONObject in_task = WQLObject.getWQLObject("sch_base_task").query("task_type = '010606' AND product_area = '" + product_area + "' AND is_delete = '0' AND task_status < '07'").uniqueResult(0); + if (ObjectUtil.isEmpty(in_task)) { + JSONObject vehicle_jo = WQLObject.getWQLObject("md_pb_vehiclearea").query("vehicle_code = '" + vehicle_code + "'").uniqueResult(0); + if (vehicle_jo.getString("point_location").equals(point_location)) { + //创建一个从套管工位到IN点的任务 + JSONObject tggw_jo = WQLObject.getWQLObject("st_ivt_shaftivt").query("product_area = '" + product_area + "' AND point_type = '4'").uniqueResult(0); + JSONObject jo = new JSONObject(); + jo.put("task_type", "010606"); + jo.put("truss_type", "1"); + jo.put("task_status", TaskStatusEnum.START_AND_POINT.getCode()); + jo.put("point_code1", tggw_jo.getString("point_code")); + jo.put("point_code2", in_jo.getString("point_code")); + JSONObject request_param = new JSONObject(); + request_param.put("container_name1", task_resq.getString("container_name1")); + request_param.put("container_name2", task_resq.getString("container_name2")); + jo.put("request_param", request_param); + jo.put("vehicle_code", task_resq.getString("container_name1")); + jo.put("product_area", product_area); + paperTrussTask.createTask(jo); + result.put("status", HttpStatus.OK.value()); + result.put("message", "反馈成功!"); + return result; + } + } + } //todo:如果缓存位有可用库位，创建一个桁架任务从穿拔轴位到缓存位，否则不动 JSONObject tz_jo = WQLObject.getWQLObject("st_ivt_shaftivt").query("product_area = '" + product_area + "' AND point_type = '2' AND have_qzz = '0' order by sort_seq").uniqueResult(0); if (ObjectUtil.isNotEmpty(tz_jo)) { @@ -1113,6 +1139,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { request_param.put("container_name2", task_resq.getString("container_name2")); jo.put("request_param", request_param.toString()); paperTrussTask.createTask(jo); + + result.put("status", HttpStatus.OK.value()); + result.put("message", "反馈成功!"); + return result; } else { noticeService.createNotice("套轴气胀轴缓存架空位不足", "套轴气胀轴缓存架空位不足" , NoticeTypeEnum.WARN.getCode()); @@ -1310,12 +1340,19 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { paperTrussTask.immediateNotifyAcs(null); } } else { - //未查询到需要搬运的气胀轴，创建空载具入库任务 - ShippingService shippingService = SpringContextHolder.getBean(ShippingService.class); - JSONObject ship_jo = new JSONObject(); - ship_jo.put("vehicle_code", vehicle_code); - ship_jo.put("point_code", in_jo.getString("point_code")); - shippingService.returnVehicle(ship_jo); + //判断在等待任务数量范围内是否存在符合的纸管，如果存在则等待，不存在则创建空载具入库任务 + boolean need_wait = this.judgeWait(product_area, vehicle_jo); + if (!need_wait) { + //未查询到需要搬运的气胀轴，创建空载具入库任务 + ShippingService shippingService = SpringContextHolder.getBean(ShippingService.class); + JSONObject ship_jo = new JSONObject(); + ship_jo.put("vehicle_code", vehicle_code); + ship_jo.put("point_code", in_jo.getString("point_code")); + shippingService.returnVehicle(ship_jo); + } else { + in_jo.put("vehicle_code", vehicle_code); + WQLObject.getWQLObject("sch_base_point").update(in_jo); + } } } } @@ -1325,6 +1362,40 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { return result; } + private boolean judgeWait(String product_area, JSONObject vehicle_jo) { + boolean need_wait = false; + JSONArray task_rows = WQL.getWO("QAUTO_QUERY").addParam("flag", "8").addParam("product_area", product_area).process().getResultJSONArray(0); + //取当前 + String point_location = vehicle_jo.getString("point_location"); + String task_num = ""; + if ("0".equals(point_location)) { + task_num = SpringContextHolder.getBean(SysParamServiceImpl.class).findByCode("up_task_num").getValue(); + } + if ("1".equals(point_location)) { + task_num = SpringContextHolder.getBean(SysParamServiceImpl.class).findByCode("down_task_num").getValue(); + } + int limit_num = Integer.parseInt(task_num); + //判断当前可用的空位是多少，MAX=5（4个缓存货架+1个套管工位） + JSONArray hchj_ja = WQLObject.getWQLObject("st_ivt_shaftivt").query("product_area = '" + product_area + "' AND point_type = '2' AND is_used = '1' AND have_qzz = '0'").getResultJSONArray(0); + JSONObject task_jo = WQLObject.getWQLObject("sch_base_task").query("task_type = '010607' AND product_area = '" + product_area + "' AND is_delete = '0' AND task_status < '07'").uniqueResult(0); + int min_num = 0; + if (ObjectUtil.isNotEmpty(task_jo)) { + min_num = Math.min(limit_num, hchj_ja.size()); + } else { + min_num = Math.min(limit_num, (hchj_ja.size() + 1)); + } + min_num = Math.min(task_rows.size(), min_num); + for (int i = 0; i < min_num; i++) { + JSONObject jo = task_rows.getJSONObject(i); + if (jo.getString("point_location").equals(point_location)) { + need_wait = true; + break; + } + } + + return need_wait; + } + @Override @Transactional(rollbackFor = Exception.class) public JSONObject shipDeviceUpdate(JSONObject whereJson) { diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/PaperTubeTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/PaperTubeTask.java index a81d3f0d0..b9ee676f9 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/PaperTubeTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/PaperTubeTask.java @@ -120,7 +120,9 @@ public class PaperTubeTask extends AbstractAcsTask { String have_qzz = cbz_jo.getString("have_qzz"); //判断当前RGV上是否存在未拔轴的成品卷 JSONObject rgv_jo = WQLObject.getWQLObject("st_ivt_shaftivt").query("point_type = '5' AND product_area = '" + product_area + "'").uniqueResult(0); - if ("0".equals(have_qzz) && "0".equals(rgv_jo.getString("have_qzz"))) { + //判断是否存在未完成的成品下卷任务 + JSONObject container_jo = WQLObject.getWQLObject("sch_base_task").query("task_type = '010605' AND product_area = '"+product_area+"' AND task_status < '07' AND is_delete = '0'").uniqueResult(0); + if ("0".equals(have_qzz) && "0".equals(rgv_jo.getString("have_qzz")) && ObjectUtil.isEmpty(container_jo)) { PaperTrussTask paperTrussTask = SpringContextHolder.getBean(PaperTrussTask.class); //todo:创建桁架任务搬运一个符合的气涨轴 JSONObject jo = new JSONObject(); @@ -149,7 +151,7 @@ public class PaperTubeTask extends AbstractAcsTask { String device_code = cbz_jo.getString("point_code"); //判断是否存在任务 JSONObject paper_jo = WQLObject.getWQLObject("sch_base_task").query("point_code1 = '" + device_code + "' AND task_status < '07' AND is_delete = '0'").uniqueResult(0); - if (ObjectUtil.isNotEmpty(paper_jo)) { + if (ObjectUtil.isEmpty(paper_jo)) { //给穿拔轴机下发套轴 WmsToAcsService wmsToAcsService = SpringContextHolder.getBean(WmsToAcsService.class); JSONArray action_rows = new JSONArray(); diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/wql/QAUTO_QUERY.wql b/lms/nladmin-system/src/main/java/org/nl/wms/sch/wql/QAUTO_QUERY.wql index c2983f577..aeafccc77 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/wql/QAUTO_QUERY.wql +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/wql/QAUTO_QUERY.wql @@ -58,7 +58,12 @@ AND IFNULL( call_time, '' ) <> '' AND is_delete = '0' AND cut.product_area = 输入.product_area - AND cut.point_location = 输入.point_location + OPTION 输入.point_location <> "" + cut.point_location = 输入.point_location + ENDOPTION + OPTION 输入.is_paper_ok <> "" + plan.is_paper_ok = 输入.is_paper_ok + ENDOPTION GROUP BY parent_container_name, split_group UNION @@ -240,4 +245,24 @@ ENDQUERY ENDIF + IF 输入.flag = "8" + QUERY + SELECT + ivt.point_location + FROM + sch_base_task task + LEFT JOIN pdm_bi_slittingproductionplan plan ON plan.container_name = task.vehicle_code AND plan.is_delete = '0' + LEFT JOIN st_ivt_cutpointivt ivt ON ivt.ext_code = plan.resource_name + WHERE + task.task_type = '010601' + AND + task.product_area = 输入.product_area + AND + task.is_delete = '0' + AND + task.task_status < '07' + ENDSELECT + ENDQUERY + ENDIF + diff --git a/lms/nladmin-ui/src/views/wms/pdm/ivt/package/index.vue b/lms/nladmin-ui/src/views/wms/pdm/ivt/package/index.vue index 855322a2f..a5f42d541 100644 --- a/lms/nladmin-ui/src/views/wms/pdm/ivt/package/index.vue +++ b/lms/nladmin-ui/src/views/wms/pdm/ivt/package/index.vue @@ -129,6 +129,12 @@ /> + + + + + + @@ -152,14 +158,16 @@ > - - - + + + + +