修正循环依赖

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceMsgComsumerStartedService.java

@@ -220,7 +220,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
                             }
                             //获取exchange,
                             PlatformEntity platformEntity = platformService.getCache(deviceEntity.getPlatformId().toString());
-                            String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://172.15.28.116:8090");
+                            String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://127.0.0.1:11078/zwfw_api");
                             if (!Constant.MESSAGETYPE_HEARTBEAT.equalsIgnoreCase(messageType)
                                     && !ObjectUtils.isEmpty(platformEntity)
                                     && platformEntity.getSendSwitch() == YesNoEnum.YES.getValue()) {

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceSendThirdPartyService.java

@@ -44,7 +44,7 @@ public class DeviceSendThirdPartyService implements IApplicationStartedService {
                     try {
                     DeviceReq deviceReq = cacheService.blpop(KEY_DEVICE_THIRDPARTY_QUEUE,10, DeviceReq.class);
                     if (!ObjectUtils.isEmpty(deviceReq)) {
-                        String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://172.15.28.116:8090");
+                        String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://127.0.0.1:11078/zwfw_api");
                         ApiResp<String> resp = messageService.sendThirdParty(UrlBuilder.of(phpInUrl).addPath(thirdPartyPath).build(), deviceReq);
                         log.info("sendThirty resp ==>{}", JSON.toJSONString(resp));
                     }

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

@@ -123,7 +123,10 @@ public class DeviceModuleDistributeServiceImpl extends AbstractCRUDCacheServiceI
         } catch (Exception e) {
             log.error("异常", e);
         }
+
         ZipUtil.unzip(targetFilePath, disPath, Charset.forName(fileEncode));
+
+       // ZipReader.of(disPath,fileEncode).setMaxSizeDiff(1024 * 1024 * 1024)
         //更新
         distributeEntity.setDistributeFilePath(disPath);
         distributeEntity.setDistribute(YesNoEnum.YES.getValue());