From 78f44737c296af3e970de6f0f8ef2477697ee829 Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期一, 12 一月 2026 15:43:31 +0800
Subject: [PATCH] lsh#
---
rsf-server/src/main/java/com/vincent/rsf/server/api/controller/pda/MobileController.java | 59 ++++++++++++++++++++++++++++++++++++++++++++---------------
1 files changed, 44 insertions(+), 15 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/pda/MobileController.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/pda/MobileController.java
index c18bf62..cfb6f1f 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/pda/MobileController.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/pda/MobileController.java
@@ -1,17 +1,27 @@
package com.vincent.rsf.server.api.controller.pda;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.vincent.rsf.framework.common.Cools;
import com.vincent.rsf.framework.common.R;
import com.vincent.rsf.framework.exception.CoolException;
-import com.vincent.rsf.server.api.controller.params.*;
+import com.vincent.rsf.server.api.controller.erp.params.CheckObjParams;
+import com.vincent.rsf.server.api.controller.erp.params.ManualShelvingParams;
+import com.vincent.rsf.server.api.controller.erp.params.OpStockParams;
+import com.vincent.rsf.server.api.controller.erp.params.OtherReceiptParams;
+import com.vincent.rsf.server.api.service.AgvService;
import com.vincent.rsf.server.api.service.MobileService;
import com.vincent.rsf.server.manager.controller.params.WaitPakinParam;
import com.vincent.rsf.server.manager.entity.QlyIsptItem;
+import com.vincent.rsf.server.manager.entity.WaitPakin;
+import com.vincent.rsf.server.manager.service.TaskService;
+import com.vincent.rsf.server.manager.service.WaitPakinService;
import com.vincent.rsf.server.system.controller.BaseController;
import com.vincent.rsf.server.system.controller.param.LoginParam;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.tika.utils.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
@@ -34,6 +44,12 @@
@Autowired
private MobileService mobileService;
+ @Autowired
+ private TaskService taskService;
+ @Autowired
+ private WaitPakinService waitPakinService;
+ @Autowired
+ private AgvService agvService;
/**
* PDA鐢ㄦ埛鐧诲綍
* @param param
@@ -101,7 +117,7 @@
@ApiOperation("鑾峰彇鏀惰揣鍖�")
@GetMapping("/areas/receipt")
public R getReceiptAreas() {
- return mobileService.getReceiptAreas();
+ return mobileService.getReceiptAreas(getLoginUser());
}
@@ -123,12 +139,12 @@
@PreAuthorize("hasAuthority('manager:asnOrderItem:list')")
@ApiOperation("鑾峰彇璁㈠崟鐗╂枡鏄庣粏")
- @GetMapping("/asnOrderItem/trackCode/{code}")
- public R getItemByTrackCode(@PathVariable String code) {
- if (StringUtils.isBlank(code)) {
- return R.error("缂栫爜涓嶈兘涓虹┖锛侊紒");
+ @PostMapping("/asnOrderItem/trackCode")
+ public R getItemByTrackCode(@RequestBody Map<String, Object> params) {
+ if (Objects.isNull(params)) {
+ throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
}
- return mobileService.getDeltByCode(code);
+ return mobileService.getDeltByCode(params);
}
@PreAuthorize("hasAuthority('manager:asnOrderItem:list')")
@@ -138,7 +154,11 @@
if (Objects.isNull(params)) {
return R.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
}
- return mobileService.getItemByContainer(params);
+ if (!Objects.isNull(params.get("type")) && params.get("type").equals("unbind")) {
+ return mobileService.getUnItemByContainer(params);
+ } else {
+ return mobileService.getItemByContainer(params);
+ }
}
@PreAuthorize("hasAuthority('manager:waitPakin:update')")
@@ -155,7 +175,12 @@
if (Objects.isNull(waitPakin.getItems()) || waitPakin.getItems().isEmpty()) {
return R.error("璺熻釜鐮佷笉鑳戒负绌猴紒锛�");
}
- return R.ok(mobileService.mergeItems(waitPakin, userId));
+ try{
+ mobileService.mergeItemsWcs(waitPakin, userId);
+ } catch (Exception e){
+ return R.error(e.getMessage());
+ }
+ return R.ok();
}
@PreAuthorize("hasAuthority('manager:waitPakin:update')")
@@ -169,7 +194,7 @@
return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒锛�");
}
if (Objects.isNull(param.getItems()) || param.getItems().isEmpty()) {
- return R.error("璺熻釜鐮佷笉鑳戒负绌猴紒锛�");
+ return R.error("瑙ｇ粦鏄庣粏涓嶈兘涓虹┖锛侊紒");
}
return R.ok(mobileService.unBind(param));
}
@@ -196,7 +221,7 @@
@ApiOperation("蹇�熻川妫�淇℃伅")
@PreAuthorize("hasAuthority('manager:qlyInspect:list')")
- @PostMapping("/inspect/query")
+// @PostMapping("/inspect/query")
public R checkObjs(@RequestBody CheckObjParams params) {
if (Objects.isNull(params)) {
return R.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
@@ -212,7 +237,7 @@
if (Objects.isNull(params) || params.isEmpty()) {
return R.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
}
- return mobileService.checkUpdate(params);
+ return mobileService.checkUpdate(params, getLoginUserId());
}
@ApiOperation("鑾峰彇涓婃灦淇℃伅")
@@ -228,11 +253,15 @@
@ApiOperation("浜哄伐涓婃灦")
@PreAuthorize("hasAuthority('manager:qlyInspect:update')")
@PostMapping("/stock/operate")
- public R publicToStock(@RequestBody PublicToStockParams params) {
- if (Objects.isNull(params)) {
+ public R publicToStock(@RequestBody ManualShelvingParams params) {
+ if (Cools.isEmpty(params.getItemList()) || Cools.isEmpty(params.getLocCode()) || Cools.isEmpty(params.getBarcode())) {
return R.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
}
- return mobileService.publicToStock(params, getLoginUserId());
+ WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, params.getBarcode()));
+
+
+ return taskService.generateFlatWarehouseTasks(waitPakin, params.getLocCode(), getLoginUserId());
+// return mobileService.publicToStock(params, getLoginUserId());
}
@ApiOperation("鑾峰彇浠诲姟淇℃伅")
--
Gitblit v1.9.1