From c47395fe29493062a3f0bc2cf1d02a2946b20b88 Mon Sep 17 00:00:00 2001
From: zyh <zyh@123>
Date: 星期日, 04 一月 2026 08:41:35 +0800
Subject: [PATCH] 修改了判断空库位，查询语句的bug,和摄像头的连接
---
src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java | 104 +++++++++++++++++-----------------------------------
1 files changed, 34 insertions(+), 70 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
index 9e42536..1bfc8b4 100644
--- a/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MesServiceImpl.java
@@ -239,7 +239,6 @@
newMemo.put("itemdata", list);
-
// 鐢熸垚璁㈠崟
OrderPakin orderPakin = new OrderPakin();
orderPakin.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
@@ -260,8 +259,8 @@
// 鐢熸垚鏄庣粏
Mat mat = matService.selectByMatnr(mesMatInfo.getItemNo());
- if(Cools.isEmpty(mat)){
- log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�="+mesMatInfo.getItemNo());
+ if (Cools.isEmpty(mat)) {
+ log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�=" + mesMatInfo.getItemNo());
continue;
}
OrderDetlPakin orderDetlPakin = new OrderDetlPakin();
@@ -967,6 +966,7 @@
orderPakout.setUpdateTime(now);
orderPakout.setMemo(JSONObject.toJSONString(mesCallOutApply));
orderPakout.setPakinPakoutStatus(2);
+ orderPakout.setCstmrName(mesCallOutApply.getStationId());//agv鐩爣绔欑偣
if (!orderPakoutService.insert(orderPakout)) {
log.error("MES淇濆瓨鍑哄簱璁㈠崟锛堝彨鏂欙級涓绘。澶辫触");
throw new CoolException("淇濆瓨鍑哄簱璁㈠崟锛堝彨鏂欙級涓绘。澶辫触");
@@ -1003,9 +1003,9 @@
}
//鏈夊灏戠涓嶅悓鐨勯厤鐩樺彿 鍙湁閰嶇洏鍑哄簱鍗曢渶瑕佺煡閬�
- if (mesCallOutApply.getTransType().equals("閰嶇洏鍑哄簱鍗�")){
+ if (mesCallOutApply.getTransType().equals("閰嶇洏鍑哄簱鍗�")) {
orderPakout.setPayType(set.size());
- String shipCode =mesCallOutApply.getItemdata().get(0).getTrayid().split("-")[2];
+ String shipCode = mesCallOutApply.getItemdata().get(0).getTrayid().split("-")[2];
orderPakout.setShipCode(shipCode);//鍖哄煙 鏄惁鏄壒娈婃墭鐩�
orderPakoutService.updateById(orderPakout);
}
@@ -1039,11 +1039,11 @@
orderPakin.setPakinPakoutStatus(1);
orderPakinService.insert(orderPakin);
if (mesCallOutApply.getItemdata() != null && !mesCallOutApply.getItemdata().isEmpty()) {
- for (MesCallOutApply.MesOutApplyItem mesOutApplyItem : mesCallOutApply.getItemdata()){
+ for (MesCallOutApply.MesOutApplyItem mesOutApplyItem : mesCallOutApply.getItemdata()) {
// 鐢熸垚鏄庣粏
Mat mat = matService.selectByMatnr(mesOutApplyItem.getItemno());
- if(Cools.isEmpty(mat)){
- log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�="+mesOutApplyItem.getItemno());
+ if (Cools.isEmpty(mat)) {
+ log.error("璇ョ墿鏂欑紪鍙风珛搴撴病鏈�=" + mesOutApplyItem.getItemno());
continue;
}
OrderDetlPakin orderDetlPakin = new OrderDetlPakin();
@@ -1104,73 +1104,37 @@
return result;
}
- // 涓嬪彂缁橰CS
- RcsTaskSubmit rcsTaskSubmit = new RcsTaskSubmit();
- rcsTaskSubmit.setRobotTaskCode(transTask.getTaskno());
- rcsTaskSubmit.setInitPriority(10); //榛樿10
- List<RcsTaskTargetRoute> targetRouteList = new ArrayList<>();
- RcsTaskTargetRoute startRoute = new RcsTaskTargetRoute();
- startRoute.setSeq(0);
- startRoute.setCode(transTask.getCurStationId());
- startRoute.setOperation("COLLECT");
- targetRouteList.add(startRoute);
- RcsTaskTargetRoute endRoute = new RcsTaskTargetRoute();
- endRoute.setSeq(1);
- endRoute.setCode(transTask.getNextStationId());
- endRoute.setOperation("DELIVERY");
- targetRouteList.add(endRoute);
- rcsTaskSubmit.setTargetRoute(targetRouteList);
+ int workNo = commonService.getWorkNo(WorkNoType.OTHER.type);
+ Date now = new Date();
+ Task task = new Task();
+ task.setWrkNo(workNo);
+ task.setTaskType("ZX-AGV");
+ task.setWrkSts(301L);//301.AGV浠诲姟鍒涘缓
+ task.setIoType(3);//3.绔欏埌绔�
+ task.setIoPri(10.00);
+ task.setWrkDate(now);
+ task.setBarcode(transTask.getBarcode());
+ task.setSourceStaNo(transTask.getCurStationId());
+ task.setStaNo(transTask.getNextStationId());
+ task.setBarcode(transTask.getTuoPanId());
+ task.setModiUser(defaultUserId);
+ task.setModiTime(now);
+ task.setAppeUser(defaultUserId);
+ task.setAppeTime(now);
+ task.setTaskNo(transTask.getTaskno());
+ task.setMemo(JSONObject.toJSONString(transTask));
+ task.setPltType(transTask.getAgvFactory());//鍗庢檽AGV
+ task.setPacked(transTask.getRackNumber());//鏂欐灦鍙�
+ task.setCtnType(1);
- // 杞彂缁欐捣搴锋垨鍗庢檽RCS
- int success = rcsService.submitTask(rcsTaskSubmit, transTask.getAgvFactory());
- if (success == 1) {
- int workNo = commonService.getWorkNo(WorkNoType.OTHER.type);
- Date now = new Date();
- Task task = new Task();
- task.setWrkNo(workNo);
- task.setTaskType("ZX-AGV");
- task.setWrkSts(302L);//302.AGV浠诲姟鎵ц涓�
- task.setIoType(3);//3.绔欏埌绔�
- task.setIoPri(10.00);
- task.setWrkDate(now);
- task.setBarcode(transTask.getBarcode());
- task.setSourceStaNo(transTask.getCurStationId());
- task.setStaNo(transTask.getNextStationId());
- task.setBarcode(transTask.getTuoPanId());
- task.setModiUser(defaultUserId);
- task.setModiTime(now);
- task.setAppeUser(defaultUserId);
- task.setAppeTime(now);
- task.setTaskNo(transTask.getTaskno());
- task.setMemo(JSONObject.toJSONString(transTask));
- task.setPltType(transTask.getAgvFactory());//鍗庢檽AGV
- task.setPacked(transTask.getRackNumber());//鏂欐灦鍙�
+ if (taskService.insert(task)) {
+ result.put("Success", "1");
+ result.put("Message", "浠诲姟鎺ユ敹鎴愬姛");
- taskService.insert(task);
-// Mat mat = matService.selectByMatnr(transTask.getItemno());
-// TaskDetl taskDetl = new TaskDetl();
-// taskDetl.setWrkNo(task.getWrkNo());
-// taskDetl.setIoTime(task.getIoTime());
-// taskDetl.setMatnr(transTask.getItemno());
-// taskDetl.setAnfme(0.0);
-// taskDetl.setStandby1(String.valueOf(transTask.getQty()));
-// taskDetl.setMaktx(mat.getMaktx());
-// taskDetl.setSpecs(mat.getSpecs());
-// taskDetl.setOrderNo(transTask.getOrderNo());
-// taskDetl.setZpallet(transTask.getTuoPanId());
-// taskDetl.setMemo(JSONObject.toJSONString(transTask.getItemBarcode()));
-// taskDetl.setModiUser(defaultUserId);
-// taskDetl.setModiTime(now);
-// taskDetl.setAppeUser(defaultUserId);
-// taskDetl.setAppeTime(now);
-// taskDetlService.insert(taskDetl);
- result.put("Success", "1");
- result.put("Message", "浠诲姟鎺ユ敹鎴愬姛");
- } else {
+ }else {
result.put("Success", "2");
result.put("Message", "浠诲姟涓嬪彂缁橰CS澶辫触");
}
-
return result;
}
--
Gitblit v1.9.1