| | |
| | | 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; |
| | |
| | | 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; |
| | | |
| | | /** |
| | |
| | | public class RemoteGrainServiceImpl implements RemoteGrainService { |
| | | |
| | | public static final String BEAN_ID = "beiboGrain.remoteGrainService"; |
| | | |
| | | @Autowired |
| | | private RedisUtil redisUtil; |
| | | |
| | | @Override |
| | | public String getProtocol() { |
| | |
| | | |
| | | // 封装返回信息 |
| | | 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 { |