修正redis 最大连接数

device-manager/src/main/java/com/mortals/xhx/busiz/web/TestSendMsgController.java

@@ -64,6 +64,20 @@ public class TestSendMsgController {
         return JSON.toJSONString(rsp);
     }
 
+    @GetMapping("updateDevice")
+    public String updateDevice() {
+        log.info("刷新设备的产品编码");
+        ApiResp<DeviceResp> rsp = new ApiResp<>();
+        rsp.setCode(ApiRespCodeEnum.SUCCESS.getValue());
+        List<DeviceEntity> updateProductCodeList = deviceService.find(new DeviceQuery());
+
+        if (!ObjectUtils.isEmpty(updateProductCodeList)) {
+            log.info("更新设备产品列表，size:{}，str:{}", updateProductCodeList.size(), JSON.toJSONString(updateProductCodeList));
+            deviceService.update(updateProductCodeList,null);
+        }
+        return JSON.toJSONString(rsp);
+    }
+
 
     @GetMapping("reDeviceProductCode")
     public String reDeviceProductCode() {

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -365,7 +365,7 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
             Rest<String> officeRest = officeDeviceFeign.deviceCall(deviceReq);
             log.info("office  resp ==>{}", JSON.toJSONString(officeRest));
         } else {
-            Long lpush = cacheService.lpush(RedisKey.KEY_DEVICE_THIRDPARTY_QUEUE, deviceReq);
+            cacheService.lpush(RedisKey.KEY_DEVICE_THIRDPARTY_QUEUE, deviceReq);
 //            log.info("lpush:{}",lpush);
 //            String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://172.15.28.116:8090");
 //            ApiResp<String> resp = messageService.sendThirdParty(UrlBuilder.of(phpInUrl).addPath(thirdPartyPath).build(), deviceReq);