From 51f58c3bdf9ad55133e46054dff0d05236334297 Mon Sep 17 00:00:00 2001 From: liyongde <1419499670@qq.com> Date: Thu, 6 Nov 2025 11:03:32 +0800 Subject: [PATCH] =?UTF-8?q?opt:=20=E7=9C=8B=E6=9D=BF=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E4=B8=8D=E5=9C=A8=E6=9F=A5=E8=AF=A2=E7=94=B5=E6=B0=94=E6=8A=A5?= =?UTF-8?q?=E9=94=99=E4=BF=A1=E5=8F=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../slitter/controller/SlitterController.java | 42 ++++++------------- 1 file changed, 12 insertions(+), 30 deletions(-) diff --git a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/controller/SlitterController.java b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/controller/SlitterController.java index fcbbc034e..f0bf48db7 100644 --- a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/controller/SlitterController.java +++ b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/controller/SlitterController.java @@ -4,7 +4,6 @@ import cn.dev33.satoken.annotation.SaIgnore; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import lombok.extern.slf4j.Slf4j; -import org.nl.b_lms.sch.tasks.slitter.constant.SlitterEnum; import org.nl.b_lms.sch.tasks.slitter.service.SlitterService; import org.nl.b_lms.sch.tasks.slitter.util.SlitterTaskUtil; import org.nl.modules.common.utils.RedisUtils; @@ -43,61 +42,44 @@ public class SlitterController { @PostMapping("/calPaperNum") @Log("扣除纸管库存") @SaIgnore - public ResponseEntity calPaperNum(@RequestBody JSONObject entity){ + public ResponseEntity calPaperNum(@RequestBody JSONObject entity) { return new ResponseEntity<>(slitterService.acsToReduceTube(entity), HttpStatus.CREATED); } + @PostMapping("/tzInfo") @Log("套轴BCP透明链路") @SaIgnore - public ResponseEntity tzInfo(@RequestBody JSONObject entity){ + public ResponseEntity tzInfo(@RequestBody JSONObject entity) { return new ResponseEntity<>(redisUtils.get("INFO" + entity.getString("device_code")), HttpStatus.CREATED); } + @PostMapping("/v2/tzInfo") @Log("套轴BCP透明链路2") @SaIgnore - public ResponseEntity tzInfo2(@RequestBody JSONObject entity){ + public ResponseEntity tzInfo2(@RequestBody JSONObject entity) { List list = SlitterTaskUtil.objectToList(redisUtils.get("ERROR" + entity.getString("device_code"))); - try { - // 获取字典数据 - List bcbjError = dictService.getDictByName("CBJ_ERROR"); - // 判断气胀轴是否有轴 - JSONArray device_rows = new JSONArray(); - JSONObject device_obj = new JSONObject(); - device_rows.add(device_obj); - device_obj.put("device_code", entity.getString("device_code")); - // todo: 暂时都是B1 - device_obj.put("product_area", "B1"); - JSONObject pointStatus = wmsToAcsService.getPointStatus(device_rows); - JSONObject data = pointStatus.getJSONArray("data").getJSONObject(0); - Dict error = bcbjError.stream() - .filter(p -> p.getValue().equals(data.getString("error"))) - .findFirst() - .orElse(null); - list.add(">>>实时获取电气上报异常信息:" + (error != null - ? error.getLabel() - : (data.getString("error") + "对应异常信息未定义"))); - } catch (Exception e) { - list.add(">>>获取电气上报异常信息失败(此记录不影响流程)..."); - } return new ResponseEntity<>(list, HttpStatus.CREATED); } + @PostMapping("/v2/tzTaskINfo") @Log("套轴BCP透明链路2") @SaIgnore - public ResponseEntity tzTaskINfo(@RequestBody JSONObject entity){ + public ResponseEntity tzTaskINfo(@RequestBody JSONObject entity) { return new ResponseEntity<>(slitterService.tzTaskINfo(entity), HttpStatus.OK); } + @PostMapping("/recover") @Log("恢复计划") @SaIgnore - public ResponseEntity recover(@RequestBody JSONObject entity){ + public ResponseEntity recover(@RequestBody JSONObject entity) { slitterService.recover(entity); - return new ResponseEntity<>( HttpStatus.OK); + return new ResponseEntity<>(HttpStatus.OK); } + @PostMapping("/callShaft") @Log("呼叫空轴") @SaIgnore - public ResponseEntity callShaft(@RequestBody JSONObject entity){ + public ResponseEntity callShaft(@RequestBody JSONObject entity) { return new ResponseEntity<>(slitterService.callShaft(entity), HttpStatus.OK); } }