From b9e930a68548bbaa9b67b29541b74c013f3fb9eb Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期一, 25 九月 2023 21:49:19 +0800
Subject: [PATCH] 优化提交
---
igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/RemoteGrainServiceImpl.java | 15 ++++++++++++---
1 files changed, 12 insertions(+), 3 deletions(-)
diff --git a/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/RemoteGrainServiceImpl.java b/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/RemoteGrainServiceImpl.java
index 601dccb..ab545e1 100644
--- a/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/RemoteGrainServiceImpl.java
+++ b/igds-protocol-beibo/src/main/java/com/ld/igds/protocol/beibo/grain/RemoteGrainServiceImpl.java
@@ -1,5 +1,6 @@
package com.ld.igds.protocol.beibo.grain;
+import com.ld.igds.constant.RedisConst;
import com.ld.igds.io.RemoteGrainService;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.constant.ProtocolEnum;
@@ -8,8 +9,10 @@
import com.ld.igds.protocol.beibo.grain.builder.CommandBuild;
import com.ld.igds.protocol.beibo.grain.client.BeiboClientEngine;
import com.ld.igds.util.BytesUtil;
+import com.ld.igds.util.RedisUtil;
import com.ld.io.api.InvokeResult;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
@@ -23,6 +26,9 @@
public static final String BEAN_ID = "beiboGrain.remoteGrainService";
+ @Autowired
+ private RedisUtil redisUtil;
+
@Override
public String getProtocol() {
return ProtocolEnum.TCP_BEIBO_GRAIN_V1.getCode();
@@ -31,8 +37,8 @@
@Override
public GrainResponse checkGrain(CheckGrainRequest request) {
try {
- log.info("璐濆崥绮儏鍒嗘満寮�濮嬫娴嬶紝鍒嗘満{}鐨処P={},绔彛={}",request.getSerId(),request.getIp(),request.getPort());
- BeiboClientEngine beibo = new BeiboClientEngine(request.getIp(),request.getPort());
+ log.info("璐濆崥绮儏鍒嗘満寮�濮嬫娴嬶紝鍒嗘満{}鐨処P={},绔彛={}", request.getSerId(), request.getIp(), request.getPort());
+ BeiboClientEngine beibo = new BeiboClientEngine(request.getIp(), request.getPort());
beibo.start();
Thread.sleep(3000);
@@ -41,10 +47,13 @@
InvokeResult result = beibo.send(BytesUtil.hexStrToBytes(hexStr));
- log.info("result=" +result.getMessage());
+ log.info("result=" + result.getMessage());
// 灏佽杩斿洖淇℃伅
if (InvokeResult.SUCCESS == result) {
+
+ String key = RedisConst.buildKey(request.getCompanyId(), "GRAIN_BEIBO");
+ redisUtil.set(key, request.getDepotId());
return new GrainResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
"绮儏绮儏鍙戦�佹垚鍔燂紒");
} else {
--
Gitblit v1.9.3