From 0ffc2d904802cfb299b10989167b07abc72c57f0 Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期四, 19 六月 2025 16:03:42 +0800
Subject: [PATCH] #改造
---
src/main/java/com/zy/asrs/controller/OpenController.java | 187 +++++++++++++++++++++++++---------------------
1 files changed, 101 insertions(+), 86 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index c542982..032c79e 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -6,11 +6,13 @@
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
+import com.core.common.SpringUtils;
import com.core.exception.CoolException;
import com.zy.asrs.entity.*;
import com.zy.asrs.entity.param.*;
import com.zy.asrs.service.*;
import com.zy.asrs.service.impl.BasCrnErrorServiceImpl;
+import com.zy.asrs.service.impl.TaskWrkLogServiceImpl;
import com.zy.asrs.utils.Utils;
import com.zy.common.web.BaseController;
import com.zy.core.CrnThread;
@@ -70,6 +72,8 @@
public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{
add("ea1f0459efc02a79f046f982767939ae");
}};
+ @Autowired
+ private TaskWrkLogServiceImpl taskWrkLogService;
//agv浠诲姟瀹屾垚
@PostMapping("/toAgvTaskOver")
@@ -342,18 +346,43 @@
auth(appkey, params, request);
// List<WMSAndAGVInterfaceParam> params1 =new ArrayList<>();
for (CarryParam param:params){
- param.updateIoTyoe(param.getIoType());//涓埅涓嬪彂 1锛氬嚭搴擄紝2锛氱Щ搴� 3锛氬叆搴� ====杞崲涓�====> 1锛氬叆搴擄紝2锛氬嚭搴擄紝3锛氱Щ搴�
- param.updateLocNo();
if (Cools.isEmpty(param)){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "鍙傛暟涓虹┖,params:"+JSON.toJSONString(params));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("鍙傛暟涓虹┖锛�");
} else if (Cools.isEmpty(param.getTaskNo())){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "浠诲姟鍙蜂负绌�,taskNo:"+JSON.toJSONString(param));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("浠诲姟鍙蜂负绌猴紒");
} else if (Cools.isEmpty(param.getIoType())){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "浠诲姟绫诲瀷涓虹┖,ioType:"+JSON.toJSONString(param));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("浠诲姟绫诲瀷涓虹┖锛�");
}
if (Cools.isEmpty(param.getStartPoint()) || Cools.isEmpty(param.getTargetPoint())){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "鍒濆鐩爣鎴栬�呯洰鏍囦綅涓虹┖,Point:"+JSON.toJSONString(param));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("鍒濆鐩爣鎴栬�呯洰鏍囦綅涓虹┖");
}
+
+ param.updateIoTyoe(param.getIoType());//涓埅涓嬪彂 1锛氬嚭搴擄紝2锛氱Щ搴� 3锛氬叆搴� ====杞崲涓�====> 1锛氬叆搴擄紝2锛氬嚭搴擄紝3锛氱Щ搴�
+ param.updateLocNo();
// if (Cools.isEmpty(param.getContainerCode())){
// return R.error("瀹瑰櫒缂栫爜(鎵樼洏鐮�)涓虹┖锛�");
// }
@@ -375,6 +404,12 @@
}
LocMast locMast = locMastService.selectByLocNo(locNo);
if(Cools.isEmpty(locMast)){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "鍒濆搴撲綅鏃犳硶鎵惧埌,locNo:"+JSON.toJSONString(locNo));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("鍒濆搴撲綅鏃犳硶鎵惧埌");
}
@@ -387,6 +422,12 @@
.eq("crn_no",locMast.getCrnNo())
.eq("stn_no",param.getStartPoint()));
if(Cools.isEmpty(staDesc)){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "鍏ュ簱璺姴涓嶅瓨鍦�,param:"+JSON.toJSONString(param));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("鍏ュ簱璺姴涓嶅瓨鍦�");
}
r = openService.taskCreate(new TaskCreateParam(param,staDesc.getCrnNo(),staDesc.getCrnStn()));
@@ -398,15 +439,33 @@
.eq("crn_no",locMast.getCrnNo())
.eq("stn_no",param.getTargetPoint()));
if(Cools.isEmpty(staDesc)){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "鍑哄簱璺姴涓嶅瓨鍦�,param:"+JSON.toJSONString(param));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("鍑哄簱璺姴涓嶅瓨鍦�");
}
r = openService.taskCreate(new TaskCreateParam(param,staDesc.getCrnNo(),staDesc.getStnNo()));
}else if (param.getIoType() == 3){
LocMast locMast2 = locMastService.selectByLocNo(param.getTargetPoint());
if(Cools.isEmpty(locMast2)){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "鐩爣搴撲綅鏃犳硶鎵惧埌,locNo:"+JSON.toJSONString(param.getTargetPoint()));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("鐩爣搴撲綅鏃犳硶鎵惧埌");
}
if (!locMast2.getCrnNo().equals(locMast.getCrnNo())){
+ try{
+ DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
+ deviceErrorService.addDeviceError("wms", 1, "璧峰搴撲綅涓庣洰鏍囧簱浣嶄笉鍐嶅悓涓�宸烽亾,param:"+JSON.toJSONString(param));
+ } catch (Exception e2){
+// log.error("e2:"+e2.getMessage());
+ }
return R.error("璧峰搴撲綅涓庣洰鏍囧簱浣嶄笉鍐嶅悓涓�宸烽亾");
}
//绉诲簱浠诲姟鍒涘缓
@@ -520,92 +579,17 @@
basCrnpWmsParam.sync(basCrnp);
basCrnpWmsParam.setCrnNoH(crnProtocol.getLaneNo());
+ basCrnpWmsParam.setCrnSts(crnProtocol.getStatus().intValue());
try{
- BasCrnError basCrnError = basCrnErrorService.selectById(basCrnp.getCrnErr());
+ BasCrnError basCrnError = basCrnErrorService.selectById(crnProtocol.getAlarm());
basCrnpWmsParam.setCrnErrM(basCrnError.getErrName());
} catch (Exception e){
basCrnpWmsParam.setCrnErrM("鏈煡寮傚父");
}
- basCrnpWmsParamList.add(basCrnpWmsParam);
-
-// list.add(basCrnpWmsParam);
- }
- wcsStatusResponseModel.setPilingCarList(basCrnpWmsParamList);
- for (RgvSlave rgvSlave : slaveProperties.getRgv()) {
- RgvProtocol rgvStatus = RgvStatusCache.getRgvStatus(rgvSlave.getId());
- if (Cools.isEmpty(rgvStatus)){
- continue;
- }
- BasRgvWmsParam basRgvWmsParam = new BasRgvWmsParam();
- basRgvWmsParam.setWrkNo(rgvStatus.getTaskNo());
- basRgvWmsParam.setCrnSts(rgvStatus.getStatus().intValue());
- basRgvWmsParam.setStatusType(rgvStatus.getStatusType().desc);
- basRgvWmsParam.setSteNo(rgvSlave.getId());
- basRgvWmsParam.setSteErr(rgvStatus.getAlarm().longValue());
- try{
- BasRgvErr basRgvErr = basRgvErrService.selectById((long)rgvStatus.getAlarm$());
-
- basRgvWmsParam.setSteErrM(basRgvErr.getErrName());
- } catch (Exception e){
- basRgvWmsParam.setSteErrM("鏈煡寮傚父");
- }
-// list.add(basRgvWmsParam);
- wcsStatusResponseModel.getRgvList().add(basRgvWmsParam);
-
- }
-// List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
-// for (BasCrnp basCrnp:basCrnps){
-// list.add(basCrnp);
-// }
- return R.ok(wcsStatusResponseModel);
- }
-
-
-
- //璁惧鐘舵�佹煡璇㈡帴鍙�
- @PostMapping("/errorRgv1")
- @Transactional
- public R errorRgv(@RequestHeader String appkey,
- HttpServletRequest request) {
- auth(appkey, "璁惧鐘舵�佹煡璇㈡帴鍙�", request);
- List<BasDevp> basDevps = basDevpService.selectList(new EntityWrapper<>());
- List<Object> list = new ArrayList<>();
- WcsStatusResponseModel wcsStatusResponseModel = new WcsStatusResponseModel();
- for (BasDevp basDevp:basDevps){
- BasDevpWmsParam basDevpWmsParam = new BasDevpWmsParam();
- basDevpWmsParam.setDevNo(basDevp.getDevNo());
- basDevpWmsParam.setWrkNo(basDevp.getWrkNo().longValue());
- basDevpWmsParam.setAutoing(basDevp.getAutoing());
- basDevpWmsParam.setLoading(basDevp.getLoading());
- basDevpWmsParam.setInEnable(basDevp.getInEnable());
- basDevpWmsParam.setOutEnable(basDevp.getOutEnable());
- basDevpWmsParam.setDevErr(basDevp.getStaErr().longValue());
- basDevpWmsParam.setDevErrM(basDevpWmsParam.getDevErr$());
-// list.add(basDevpWmsParam);
- wcsStatusResponseModel.getChainList().add(basDevpWmsParam);
- }
- List<BasCrnpWmsParam> basCrnpWmsParamList = new ArrayList<>();
- for (CrnSlave crn : slaveProperties.getCrn()) {
- // 鑾峰彇鍫嗗灈鏈轰俊鎭�
- CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
- CrnProtocol crnProtocol = crnThread.getCrnProtocol();
- if (crnProtocol == null) { continue; }
- BasCrnp basCrnp = basCrnpService.selectById(crn.getId());
- if (basCrnp == null) {
- log.error("{}鍙峰爢鍨涙満灏氭湭鍦ㄦ暟鎹簱杩涜缁存姢锛�", crn.getId());
- continue;
- }
- BasCrnpWmsParam basCrnpWmsParam = new BasCrnpWmsParam();
- basCrnpWmsParam.sync(basCrnp);
-
- basCrnpWmsParam.setCrnNoH(crnProtocol.getLaneNo());
-
- try{
- BasCrnError basCrnError = basCrnErrorService.selectById(basCrnp.getCrnErr());
- basCrnpWmsParam.setCrnErrM(basCrnError.getErrName());
- } catch (Exception e){
- basCrnpWmsParam.setCrnErrM("鏈煡寮傚父");
+ if (crnProtocol.getMode()!=3){
+ basCrnpWmsParam.setCrnErr(999L);
+ basCrnpWmsParam.setCrnErrM("闈炶嚜鍔紒锛侊紒");
}
basCrnpWmsParamList.add(basCrnpWmsParam);
@@ -624,12 +608,16 @@
basRgvWmsParam.setSteNo(rgvSlave.getId());
basRgvWmsParam.setSteErr(rgvStatus.getAlarm().longValue());
basRgvWmsParam.setSteErrM(rgvStatus.getAlarmM());
- try{
+// try{
// BasRgvErr basRgvErr = basRgvErrService.selectById((long)rgvStatus.getAlarm$());
-
+//
// basRgvWmsParam.setSteErrM(basRgvErr.getErrName());
- } catch (Exception e){
- basRgvWmsParam.setSteErrM("鏈煡寮傚父");
+// } catch (Exception e){
+// basRgvWmsParam.setSteErrM("鏈煡寮傚父");
+// }
+ if (rgvStatus.getMode()!=1){
+ basRgvWmsParam.setSteErr(999L);
+ basRgvWmsParam.setSteErrM("闈炶嚜鍔紒锛侊紒");
}
// list.add(basRgvWmsParam);
wcsStatusResponseModel.getRgvList().add(basRgvWmsParam);
@@ -642,5 +630,32 @@
return R.ok(wcsStatusResponseModel);
}
+ //璁惧鐘舵�佹煡璇㈡帴鍙�
+ @PostMapping("/taskWrkLogs")
+ @Transactional
+ public R taskWrkLogs(@RequestHeader String appkey,
+ HttpServletRequest request) {
+ List<TaskWrkLog> taskWrkLogs = taskWrkLogService.selectList(new EntityWrapper<>());
+ return R.ok(taskWrkLogs);
+ }
+
+ //璁惧鐘舵�佹煡璇㈡帴鍙�
+ @PostMapping("/error")
+ @Transactional
+ public R errorRgv(@RequestHeader String appkey,
+ HttpServletRequest request) {
+ List<TaskWrkLog> taskWrkLogs = taskWrkLogService.selectList(new EntityWrapper<>());
+ return R.ok(taskWrkLogs);
+ }
+
+ //璁惧鐘舵�佹煡璇㈡帴鍙�
+ @PostMapping("/wrkNo/wmsTaskNo")
+ @Transactional
+ public R wrkNoWmsTaskNo(@RequestHeader String appkey,
+ HttpServletRequest request) {
+ List<TaskWrkLog> taskWrkLogs = taskWrkLogService.selectList(new EntityWrapper<>());
+ return R.ok(taskWrkLogs);
+ }
+
}
--
Gitblit v1.9.1