浏览代码

agv回调参数取从redis里面取,不从一级缓存取,一二级缓存未同步更新

yejian 2 年之前
父节点
当前提交
c137b01176

+ 5 - 3
imcs-admin-boot/imcs-business-biz/src/main/java/com/github/zuihou/business/externalApi/service/impl/AgvHikOrderInfoServiceImpl.java

@@ -14,6 +14,7 @@ import com.github.zuihou.business.externalApi.entity.AgvHikOrderDetailInfo;
 import com.github.zuihou.business.externalApi.entity.AgvHikOrderInfo;
 import com.github.zuihou.business.externalApi.service.AgvHikOrderDetailInfoService;
 import com.github.zuihou.business.externalApi.service.AgvHikOrderInfoService;
+import com.github.zuihou.business.util.MsgUtil;
 import com.github.zuihou.common.constant.BizConstant;
 import com.github.zuihou.common.constant.CacheKey;
 import com.github.zuihou.common.constant.ParameterKey;
@@ -57,6 +58,8 @@ public class AgvHikOrderInfoServiceImpl extends SuperCacheServiceImpl<AgvHikOrde
     private RestTemplate restTemplate;
     @Autowired
     private AgvHikOrderDetailInfoService agvHikOrderDetailInfoService;
+    @Autowired
+    private MsgUtil msgUtil;
 
     @Override
     protected String getRegion() {
@@ -142,9 +145,8 @@ public class AgvHikOrderInfoServiceImpl extends SuperCacheServiceImpl<AgvHikOrde
         jsonObject.put("taskCode",taskCode);
         HttpEntity<String> addAgvTaskRequest = new HttpEntity<String>(jsonObject.toJSONString(), headers);
 
-        String agvCallbackUrl = parameterService.getValue(ParameterKey.AGVCALLBACKURL, null);
-
-
+        String agvCallbackUrl = (null == msgUtil.redis_get(ParameterKey.PARAMETERS)? "": ((Map<String,String>)msgUtil.redis_get(ParameterKey.PARAMETERS)).get(ParameterKey.AGVCALLBACKURL).toString());
+//        String agvCallbackUrl = parameterService.getValue(ParameterKey.AGVCALLBACKURL, null);
         agvHikOrderDetailInfoService.asyncCallbackTask(jsonObject.toJSONString(),agvCallbackUrl);
 //        ResponseEntity<String> addAgvTaskEntity = restTemplate.postForEntity(addAgvTaskUrl, addAgvTaskRequest, String.class);