From 95aa8661cf7499638a9db6ee015be507599bac15 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期三, 05 七月 2023 01:26:07 +0800
Subject: [PATCH] 出入库业务逻辑判断
---
igds-inout/src/main/java/com/ld/igds/inout/manager/InoutEventControlManager.java | 57 +++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 55 insertions(+), 2 deletions(-)
diff --git a/igds-inout/src/main/java/com/ld/igds/inout/manager/InoutEventControlManager.java b/igds-inout/src/main/java/com/ld/igds/inout/manager/InoutEventControlManager.java
index c4c35af..8539d8b 100644
--- a/igds-inout/src/main/java/com/ld/igds/inout/manager/InoutEventControlManager.java
+++ b/igds-inout/src/main/java/com/ld/igds/inout/manager/InoutEventControlManager.java
@@ -10,6 +10,7 @@
import com.ld.igds.file.CoreFileService;
import com.ld.igds.inout.ApiInoutManager;
import com.ld.igds.inout.ApiInoutService;
+import com.ld.igds.inout.InoutApiConstant;
import com.ld.igds.inout.InoutConstant;
import com.ld.igds.inout.dto.*;
import com.ld.igds.inout.service.InoutService;
@@ -194,7 +195,7 @@
apiData.setMsg("绉伴噸宸插畬鎴�");
// apiInoutManager.getApiService(apiData.getProtocol()).noticeWeightDone(apiData);
- // apiInoutManager.getApiService(apiData.getProtocol()).noticeRadio(apiData);
+ // apiInoutManager.getApiService(apiData.getProtocol()).noticeRadio(apiData);
}
/**
@@ -420,15 +421,67 @@
*/
@Async
public void onInoutWeight(InoutData data, String curProgress, String nextProgress) {
+ //鑾峰彇鍦扮鎺у埗鍣�
+ InoutConf conf = this.getWeightGateway(data.getCompanyId(), data.getDeptId(), null);
+ if (null == conf) {
+ log.info("----------绉伴噸瀹屾垚浜嬩欢锛屾病鏈夎幏鍙栧埌绉伴噸鎺у埗鍣�--------------");
+ }
- //1銆侀�氱煡绉伴噸鏄剧ず灞�
+ //1銆侀�氱煡绉伴噸鏄剧ず灞忥紝璁惧缂栧彿6001
+ ApiInoutData apiData = new ApiInoutData(conf);
+ apiData.setTime(new Date());
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_6001);
+ ApiInoutService inoutApiService = apiInoutManager.getApiService(conf.getProtocol());
+ inoutApiService.noticeLed(apiData, data);
//2銆佽闊抽�氱煡
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_8001);
+ inoutApiService.noticeRadio(apiData, data);
//3銆佸紑闂告満
+ if (InoutConstant.TYPE_IN.equals(data.getType())) {
+ //缁撶畻閲嶉噺澶т簬0琛ㄧず浜屾绉伴噸
+ if (data.getNetWeight() > 0) {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_1002);
+ } else {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_1003);
+ }
+ apiData.setActionCode(InoutApiConstant.ACTION_CODE_1);
+
+ inoutApiService.gateControl(apiData);
+ } else {
+ //缁撶畻閲嶉噺澶т簬0琛ㄧず浜屾绉伴噸
+ if (data.getNetWeight() > 0) {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_1003);
+ } else {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_1002);
+ }
+ apiData.setActionCode(InoutApiConstant.ACTION_CODE_1);
+ inoutApiService.gateControl(apiData);
+ }
//4銆佸紑绾㈢豢鐏�
+ if (InoutConstant.TYPE_IN.equals(data.getType())) {
+ //缁撶畻閲嶉噺澶т簬0琛ㄧず浜屾绉伴噸
+ if (data.getNetWeight() > 0) {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_7001);
+ } else {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_7002);
+ }
+ apiData.setActionCode(InoutApiConstant.ACTION_CODE_1);
+ inoutApiService.lightControl(apiData);
+ } else {
+ //缁撶畻閲嶉噺澶т簬0琛ㄧず浜屾绉伴噸
+ if (data.getNetWeight() > 0) {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_7002);
+ } else {
+ apiData.setDeviceId(InoutApiConstant.DEVICE_CODE_7001);
+ }
+ apiData.setActionCode(InoutApiConstant.ACTION_CODE_1);
+ inoutApiService.lightControl(apiData);
+ }
+
}
--
Gitblit v1.9.3