From 00b8aee10ff8a0fe54187d51ec6b8c5de14250b6 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期三, 02 四月 2025 15:01:39 +0800
Subject: [PATCH] *
---
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 73 +++++++++++++++++++++++++++++++-----
1 files changed, 62 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 45ef6a5..777dbde 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -7,17 +7,14 @@
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.asrs.domain.enums.TaskStatusType;
-import com.zy.asrs.entity.StaDesc;
-import com.zy.asrs.entity.TaskWrk;
-import com.zy.asrs.entity.ToWmsDTO;
+import com.zy.asrs.domain.enums.WorkNoType;
+import com.zy.asrs.entity.*;
import com.zy.asrs.entity.param.TaskOverParam;
import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
import com.zy.asrs.entity.param.TaskCreateParam;
-import com.zy.asrs.service.ApiLogService;
-import com.zy.asrs.service.OpenService;
-import com.zy.asrs.service.StaDescService;
-import com.zy.asrs.service.TaskWrkService;
+import com.zy.asrs.service.*;
import com.zy.asrs.utils.Utils;
+import com.zy.common.service.CommonService;
import com.zy.common.utils.HttpHandler;
import com.zy.core.DevpThread;
import com.zy.core.cache.MessageQueue;
@@ -46,6 +43,12 @@
@Autowired
private StaDescService staDescService;
+ @Autowired
+ private CommonService commonService;
+ @Autowired
+ private LocMastService locMastService;
+ @Autowired
+ private BasDevpService basDevpService;
@@ -70,13 +73,27 @@
Date now = new Date();
taskWrk = new TaskWrk();
+ LocMast locMast=locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no",param.getStartPoint()));
+ int workNo1 = commonService.getWorkNo(WorkNoType.PAKOUT.type);//鑾峰彇鍏ュ簱宸ヤ綔鍙�
taskWrk.setTaskNo(param.getTaskNo());//浠诲姟鍙�
+ taskWrk.setWrkNo(workNo1);
taskWrk.setStatus(TaskStatusType.RECEIVE.id);//浠诲姟鐘舵�侊細鎺ユ敹
taskWrk.setCreateTime(now);
+ taskWrk.setModiTime(now);
+ taskWrk.setAssignTime(new Date());
+ taskWrk.setModiUser(6666L);
+ try{
+ if (param.getIoType()>1){
+ if (Utils.locNoRowBoolean(locMast.getRow1())){
+ param.setTaskPriority(11);
+ }
+ }
+ }catch (Exception e){
+ }
taskWrk.setIoType(param.getIoType());//浠诲姟绫诲瀷
taskWrk.setIoPri(param.getTaskPriority());//浼樺厛绾�
taskWrk.setBarcode(param.getBarcode());//鏉＄爜
- taskWrk.setCrnNo(param.getCrn());
+ taskWrk.setCrnNo(locMast.getCrnNo());
if(param.getIoType() == 1){
taskWrk.setWrkSts(1);
if (!Cools.isEmpty(param.getTargetPoint())) {
@@ -87,15 +104,15 @@
} else if (param.getIoType() == 2) {
taskWrk.setWrkSts(11);
if (!Cools.isEmpty(param.getStartPoint())) {
- taskWrk.setStartPoint(Utils.getWcsLocNo(param.getStartPoint()));//璧风偣
- taskWrk.setOriginStartPoint(param.getStartPoint());
+ taskWrk.setStartPoint(param.getStartPoint());//璧风偣
+ taskWrk.setTargetPoint(param.getTargetPoint());
}
taskWrk.setTargetPoint(param.getTargetPoint());
}else if (param.getIoType() == 3){
taskWrk.setWrkSts(11);
if (!Cools.isEmpty(param.getStartPoint())) {
taskWrk.setStartPoint(param.getStartPoint());//璧风偣
- taskWrk.setOriginStartPoint(param.getStartPoint());
+ taskWrk.setTargetPoint(param.getTargetPoint());
}
}
@@ -248,6 +265,40 @@
}
+// @Override
+// public R getAgvPickAndPlaceV1(TaskOverParam param) {
+// BasDevp basDevp = basDevpService.selectById(param.getStaNo());
+// if (Cools.isEmpty(basDevp)){
+// return R.error("绔欑偣鍙锋湁璇�"+param.getStaNo());
+// }
+// if (param.getType()==0 && basDevp.getAgvStartPick()==1){
+// return R.ok();
+// }else if (param.getType()==1 && basDevp.getAgvStartPlace()==1){
+// return R.ok();
+// }else {
+// return R.error("涓嶅厑璁�");
+// }
+// }
+
+// @Override
+// public R getAgvPickAndPlaceV2(TaskOverParam param) {
+// BasDevp basDevp = basDevpService.selectById(param.getStaNo());
+// if (Cools.isEmpty(basDevp)){
+// return R.error("绔欑偣鍙锋湁璇�"+param.getStaNo());
+// }
+// if (param.getType()==0){
+// basDevp.setAgvTargetPick(1);
+// basDevpService.updateById(basDevp);
+// return R.ok();
+// }else if (param.getType()==1){
+// basDevp.setAgvTargetPlace(1);
+// basDevpService.updateById(basDevp);
+// return R.ok();
+// }else {
+// return R.error("璇锋眰绫诲瀷寮傚父"+param.getType());
+// }
+// }
+
public List<Integer> getInEnableRoadway(){
int[] roadway = null;
List<Integer> list = new ArrayList<>();
--
Gitblit v1.9.1