refactor(amos-boot): 更新开发环境配置并优化代码

amos-boot-data/amos-boot-data-openapi/src/main/resources/application-vb.properties

@@ -8,15 +8,15 @@ spring.datasource.dynamic.primary=openapi
 #spring.datasource.username=admin
 #spring.datasource.password=Yeejoin@2023
 #spring.datasource.driver-class-name=cn.com.vastbase.Driver
-#ds tzs
+#ds cyl
 spring.datasource.dynamic.datasource.openapi.url=jdbc:vastbase://172.16.10.243:5432/tzs_amos_tzs_biz_init?currentSchema=amos_openapi_cyl&allowMultiQueries=true
 spring.datasource.dynamic.datasource.openapi.username=admin
 spring.datasource.dynamic.datasource.openapi.password=Yeejoin@2023
 spring.datasource.dynamic.datasource.openapi.driver-class-name=cn.com.vastbase.Driver
-#ds cyl
-spring.datasource.dynamic.datasource.tzs.url=jdbc:vastbase://172.16.10.243:5432/tzs_amos_tzs_biz_init?currentSchema=amos_tzs_biz&allowMultiQueries=true
+#ds tzs
+spring.datasource.dynamic.datasource.tzs.url=jdbc:vastbase://172.16.10.254:5432/tzs_amos_tzs_biz_init?currentSchema=amos_tzs_biz&allowMultiQueries=true
 spring.datasource.dynamic.datasource.tzs.username=admin
-spring.datasource.dynamic.datasource.tzs.password=Yeejoin@2023
+spring.datasource.dynamic.datasource.tzs.password=Yeejoin@2024
 spring.datasource.dynamic.datasource.tzs.driver-class-name=cn.com.vastbase.Driver
 
 
@@ -41,16 +41,18 @@ spring.redis.lettuce.pool.max-idle=10
 spring.redis.lettuce.pool.min-idle=0
 spring.redis.expire.time=300
 
+localhost=${spring.cloud.client.ip-address}
+
 #注册中心地址
 eureka.client.service-url.defaultZone =http://admin:a1234560@172.16.10.243:10001/eureka/
 eureka.instance.prefer-ip-address=true
 management.endpoint.health.show-details=always
 management.endpoints.web.exposure.include=*
-eureka.instance.health-check-url=http://172.16.3.7:${server.port}${server.servlet.context-path}/actuator/health
+eureka.instance.health-check-url=http://${localhost}:${server.port}${server.servlet.context-path}/actuator/health
 eureka.instance.metadata-map.management.context-path=${server.servlet.context-path}/actuator
-eureka.instance.status-page-url=http://172.16.3.7:${server.port}${server.servlet.context-path}/actuator/info
-eureka.instance.metadata-map.management.api-docs=http://172.16.3.7:${server.port}${server.servlet.context-path}/doc.html
-eureka.instance.ip-address = 172.16.3.7
+eureka.instance.status-page-url=http://${localhost}:${server.port}${server.servlet.context-path}/actuator/info
+eureka.instance.metadata-map.management.api-docs=http://${localhost}:${server.port}${server.servlet.context-path}/doc.html
+eureka.instance.ip-address = ${localhost}
 
 ##emqx
 emqx.clean-session=true

amos-boot-system-tzs/amos-boot-module-96333/amos-boot-module-96333-biz/src/main/java/com/yeejoin/amos/boot/module/elevator/flc/biz/service/impl/RegUnitInfoServiceImpl.java

@@ -14,17 +14,12 @@ import com.yeejoin.amos.boot.biz.common.workflow.feign.WorkflowFeignService;
 import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.elevator.api.common.BizCommonConstant;
-import com.yeejoin.amos.boot.module.elevator.api.common.CommonException;
 import com.yeejoin.amos.boot.module.elevator.api.dto.BaseUnitLicenceDto;
 import com.yeejoin.amos.boot.module.elevator.api.entity.BaseUnitLicence;
 import com.yeejoin.amos.boot.module.elevator.api.entity.TzBaseEnterpriseInfo;
 import com.yeejoin.amos.boot.module.elevator.api.enums.CompanyLevelEnum;
 import com.yeejoin.amos.boot.module.elevator.api.mapper.TzBaseEnterpriseInfoMapper;
-import com.yeejoin.amos.boot.module.elevator.biz.service.impl.BaseUnitLicenceServiceImpl;
-import com.yeejoin.amos.boot.module.elevator.biz.service.impl.EquipmentCategoryServiceImpl;
-import com.yeejoin.amos.boot.module.elevator.biz.service.impl.StartPlatformTokenService;
-import com.yeejoin.amos.boot.module.elevator.biz.service.impl.TzBaseEnterpriseInfoServiceImpl;
-import com.yeejoin.amos.boot.module.elevator.biz.service.impl.TzsAuthServiceImpl;
+import com.yeejoin.amos.boot.module.elevator.biz.service.impl.*;
 import com.yeejoin.amos.boot.module.elevator.biz.utils.RedisUtil;
 import com.yeejoin.amos.boot.module.elevator.flc.api.dto.RegUnitIcDto;
 import com.yeejoin.amos.boot.module.elevator.flc.api.dto.RegUnitInfoDto;
@@ -489,7 +484,7 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
 				.flatMap(node -> Stream.concat(
 						node.get(conditionName).equals(condition) ? Stream.of(node) : Stream.empty(),
 						node.get(childName) != null ? findNodesByCondition((List<LinkedHashMap>) node.get(childName),
-								conditionName, condition, condition).stream() :
+								conditionName, condition, childName).stream() :
 								Stream.empty()
 				))
 				.collect(Collectors.toList());

amos-boot-system-tzs/amos-boot-module-app/amos-boot-module-app-biz/src/main/java/com/yeejoin/amos/boot/module/app/flc/biz/service/impl/RegUnitInfoServiceImpl.java

@@ -488,7 +488,7 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
 				.flatMap(node -> Stream.concat(
 						node.get(conditionName).equals(condition) ? Stream.of(node) : Stream.empty(),
 						node.get(childName) != null ? findNodesByCondition((List<LinkedHashMap>) node.get(childName),
-								conditionName, condition, condition).stream() :
+								conditionName, condition, childName).stream() :
 								Stream.empty()
 				))
 				.collect(Collectors.toList());

amos-boot-system-tzs/amos-boot-module-cylinder/amos-boot-module-cylinder-biz/src/main/java/com/yeejoin/amos/boot/module/cylinder/flc/biz/service/impl/RegUnitInfoServiceImpl.java

@@ -489,7 +489,7 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
 				.flatMap(node -> Stream.concat(
 						node.get(conditionName).equals(condition) ? Stream.of(node) : Stream.empty(),
 						node.get(childName) != null ? findNodesByCondition((List<LinkedHashMap>) node.get(childName),
-								conditionName, condition, condition).stream() :
+								conditionName, condition, childName).stream() :
 								Stream.empty()
 				))
 				.collect(Collectors.toList());

amos-boot-system-tzs/amos-boot-module-jczs/amos-boot-module-jczs-biz/src/main/java/com/yeejoin/amos/boot/module/jczs/flc/biz/service/impl/RegUnitInfoServiceImpl.java

@@ -14,17 +14,12 @@ import com.yeejoin.amos.boot.biz.common.workflow.feign.WorkflowFeignService;
 import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.jczs.api.common.BizCommonConstant;
-import com.yeejoin.amos.boot.module.jczs.api.common.CommonException;
 import com.yeejoin.amos.boot.module.jczs.api.dto.BaseUnitLicenceDto;
 import com.yeejoin.amos.boot.module.jczs.api.entity.BaseUnitLicence;
 import com.yeejoin.amos.boot.module.jczs.api.entity.TzBaseEnterpriseInfo;
 import com.yeejoin.amos.boot.module.jczs.api.enums.CompanyLevelEnum;
 import com.yeejoin.amos.boot.module.jczs.api.mapper.TzBaseEnterpriseInfoMapper;
-import com.yeejoin.amos.boot.module.jczs.biz.service.impl.BaseUnitLicenceServiceImpl;
-import com.yeejoin.amos.boot.module.jczs.biz.service.impl.EquipmentCategoryServiceImpl;
-import com.yeejoin.amos.boot.module.jczs.biz.service.impl.StartPlatformTokenService;
-import com.yeejoin.amos.boot.module.jczs.biz.service.impl.TzBaseEnterpriseInfoServiceImpl;
-import com.yeejoin.amos.boot.module.jczs.biz.service.impl.TzsAuthServiceImpl;
+import com.yeejoin.amos.boot.module.jczs.biz.service.impl.*;
 import com.yeejoin.amos.boot.module.jczs.biz.utils.RedisUtil;
 import com.yeejoin.amos.boot.module.jczs.flc.api.dto.RegUnitIcDto;
 import com.yeejoin.amos.boot.module.jczs.flc.api.dto.RegUnitInfoDto;
@@ -489,7 +484,7 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
 				.flatMap(node -> Stream.concat(
 						node.get(conditionName).equals(condition) ? Stream.of(node) : Stream.empty(),
 						node.get(childName) != null ? findNodesByCondition((List<LinkedHashMap>) node.get(childName),
-								conditionName, condition, condition).stream() :
+								conditionName, condition, childName).stream() :
 								Stream.empty()
 				))
 				.collect(Collectors.toList());

amos-boot-system-tzs/amos-boot-module-jczs/amos-boot-module-jczs-biz/src/main/resources/application-dev.properties

+localhost=${spring.cloud.client.ip-address}
 #DB properties:
-spring.datasource.url=jdbc:vastbase://36.46.137.116:5432/tzs_amos_tzs_biz_init?currentSchema=amos_tzs_biz&allowMultiQueries=true
+spring.datasource.url=jdbc:vastbase://172.16.10.243:5432/tzs_amos_tzs_biz_init?currentSchema=amos_tzs_biz&allowMultiQueries=true
 spring.datasource.username=admin
 spring.datasource.password=Yeejoin@2023
-eureka.client.service-url.defaultZone=http://172.16.10.210:10001/eureka/
+eureka.client.service-url.defaultZone=http://172.16.10.243:10001/eureka/
 eureka.instance.prefer-ip-address=true
 management.endpoint.health.show-details=always
 management.endpoints.web.exposure.include=*
-eureka.instance.health-check-url=http://172.16.3.34:${server.port}${server.servlet.context-path}/actuator/health
+eureka.instance.health-check-url=http://${localhost}:${server.port}${server.servlet.context-path}/actuator/health
 eureka.instance.metadata-map.management.context-path=${server.servlet.context-path}/actuator
-eureka.instance.status-page-url=http://172.16.3.34:${server.port}${server.servlet.context-path}/actuator/info
-eureka.instance.metadata-map.management.api-docs=http://172.16.3.34:${server.port}${server.servlet.context-path}/doc.html
-eureka.instance.ip-address=172.16.3.34
+eureka.instance.status-page-url=http://${localhost}:${server.port}${server.servlet.context-path}/actuator/info
+eureka.instance.metadata-map.management.api-docs=http://${localhost}:${server.port}${server.servlet.context-path}/doc.html
+eureka.instance.ip-address=${localhost}
 ## ES properties:
 elasticsearch.username=elastic
 elasticsearch.password=a123456
-spring.elasticsearch.rest.uris=http://172.16.10.210:9200
+spring.elasticsearch.rest.uris=http://172.16.10.243:9200
 ## unit(h)
 alertcall.es.synchrony.time=48
 #redis properties:
 spring.redis.database=1
-spring.redis.host=172.16.10.210
-spring.redis.port=16379
+spring.redis.host=172.16.10.243
+spring.redis.port=6379
 spring.redis.password=yeejoin@2020
 spring.redis.lettuce.pool.max-active=200
 spring.redis.lettuce.pool.max-wait=-1
@@ -30,7 +31,7 @@ spring.redis.lettuce.pool.min-idle=0
 ## emqx properties:
 emqx.clean-session=true
 emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
-emqx.broker=tcp://36.46.151.113:1883
+emqx.broker=tcp://172.16.10.243:1883
 emqx.client-user-name=super
 emqx.client-password=123456
 emqx.keepAliveInterval=1000
@@ -69,20 +70,20 @@ tzs.wechat.tempId.supervise=P5XGbszS2Pc6kynvGjzPpZ--ikAwDZo6O7WdJ2EUxtE
 tzs.wechat.test.userId=3413513
 ##new properties
 org.filter.group.seq=1564150103147573249
-fileserver.domain=http://172.16.10.210:19000/
+fileserver.domain=http://172.16.10.243:19000/
 log.level=INFO
 duty.seats.role.ids=1585956200472674305,1585956257590706177
 ## ???? properties:
 rule.definition.load=false
 ##rule.definition.model-package=com.yeejoin.amos.boot.module.jcs.api.dto
 rule.definition.default-agency=tzs
-rule.definition.local-ip=172.16.10.210
+rule.definition.local-ip=172.16.10.243
 #\u6C14\u74F6\u5145\u88C5\u4FE1\u606F\u5B9A\u65F6\u540C\u6B65\u81F3es
 tzs.cylinder.fill.cron=0 0 12 * * ?
 #\u6C14\u74F6\u57FA\u672C\u4FE1\u606F\u5B9A\u65F6\u540C\u6B65\u81F3es
 tzs.cylinder.info.cron=0 0 1 * * ?
 # ??????????
-minio.url.path=http://172.16.10.210:9000/
+minio.url.path=http://172.16.10.243:9000/
 ## ɼǰ׺
 regulatory_code_prefix=https://nav.sspai.top/tzs?code=
 outSystem.user.password=a1234560

amos-boot-system-tzs/amos-boot-module-tcm/amos-boot-module-tcm-biz/src/main/java/com/yeejoin/amos/boot/module/tcm/flc/biz/service/impl/RegUnitInfoServiceImpl.java

@@ -593,7 +593,7 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
                 .flatMap(node -> Stream.concat(
                         node.get(conditionName).equals(condition) ? Stream.of(node) : Stream.empty(),
                         node.get(childName) != null ? findNodesByCondition((List<LinkedHashMap>) node.get(childName),
-                                conditionName, condition, condition).stream() :
+                                conditionName, condition, childName).stream() :
                                 Stream.empty()
                 ))
                 .collect(Collectors.toList());

amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-biz/src/main/java/com/yeejoin/amos/boot/module/ymt/flc/biz/service/impl/RegUnitInfoServiceImpl.java

@@ -489,7 +489,7 @@ public class RegUnitInfoServiceImpl extends BaseService<RegUnitInfoDto, RegUnitI
 				.flatMap(node -> Stream.concat(
 						node.get(conditionName).equals(condition) ? Stream.of(node) : Stream.empty(),
 						node.get(childName) != null ? findNodesByCondition((List<LinkedHashMap>) node.get(childName),
-								conditionName, condition, condition).stream() :
+								conditionName, condition, childName).stream() :
 								Stream.empty()
 				))
 				.collect(Collectors.toList());