add

src/main/java/com/tanpu/fund/service/impl/ProductPrivateServiceImpl.java

@@ -261,6 +261,7 @@ public class ProductPrivateServiceImpl implements ProductPrivateService, Constan
             List<FundCount> list = mappings.stream()
                     .filter(mapping -> fundCountMap.containsKey(mapping.getFundId()))
                     .map(m -> fundCountMap.get(m.getFundId()))
+                    .distinct()
                     .sorted(Comparator.comparing(FundCount::getRetIncep).reversed())
                     .collect(Collectors.toList());
 

src/main/java/com/tanpu/fund/service/impl/ProductServiceImpl.java

@@ -693,7 +693,9 @@ public class ProductServiceImpl implements ProductService, Constant {
 
             List<FundCount> list = mappings.stream()
                     .filter(mapping -> fundCountMap.containsKey(mapping.getFundId()))
-                    .map(m -> fundCountMap.get(m.getFundId())).collect(Collectors.toList());
+                    .map(m -> fundCountMap.get(m.getFundId()))
+                    .distinct()
+                    .collect(Collectors.toList());
 
             if (CollectionUtils.isNotEmpty(list)) {
                 FundCount fundCount = list.get(0);

src/main/resources/application-prod.properties

+server.port=8199
+server.undertow.direct-buffers=true
+server.undertow.io-threads=9
+server.undertow.worker-threads=9
+
+spring.application.name=service-fund
+
+#\u76D1\u63A7
+management.endpoints.web.base-path = /myhealth
+management.endpoint.health.enabled=true
+management.endpoint.health.show-details=always
+
+spring.datasource.url=jdbc:mysql://tamper.mysql.polardb.rds.aliyuncs.com:3306/tamp_fund?autoReconnect=true&characterEncoding=utf-8&serverTimezone=GMT%2B8&useSSL=false
+spring.datasource.username=tamp
+spring.datasource.password= @imeng123
+spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
+
+company.oss.prefix = https://tamp-pro.oss-cn-shanghai.aliyuncs.com/
+
+#mybatis
+mybatis.mapper-locations=classpath:mybatis/generator/*.xml,classpath:mybatis/customize/*.xml
+
+#redis\u96C6\u7FA4\u914D\u7F6E
+spring.redis.host=118.190.63.109
+spring.redis.port=56379
+spring.redis.password=qimeng123
+#spring.redis.cluster.nodes[0]=55ai.cn:6379
+#spring.redis.cluster.max-redirects=3
+spring.redis.lettuce.pool.max-active=100
+spring.redis.lettuce.pool.max-idle=20
+spring.redis.lettuce.pool.max-wait=1000ms
+spring.redis.lettuce.pool.min-idle=10
+spring.redis.lettuce.pool.time-between-eviction-runs=300s
+spring.redis.lettuce.shutdown-timeout=5s
+
+elastic.job.zk.serverLists=47.103.68.216:2181
+elastic.job.zk.namespace=${spring.application.name}
+
+server.servlet.context-path=/fund
+
+springfox.documentation.swagger.v2.path=/api-docs
+
+# \u914D\u7F6E\u6838\u5FC3\u7EBF\u7A0B\u6570
+executor.core_pool_size=5
+# \u914D\u7F6E\u6700\u5927\u7EBF\u7A0B\u6570
+executor.max_pool_size=5
+# \u914D\u7F6E\u961F\u5217\u5927\u5C0F
+executor.queue_capacity=99
+# \u914D\u7F6E\u7EBF\u7A0B\u6C60\u4E2D\u7684\u7EBF\u7A0B\u7684\u540D\u79F0\u524D\u7F00
+executor.thread_name_prefix=async-service-fund
+# \u914D\u7F6E\u6838\u5FC3\u7EBF\u7A0B\u6570
+task.core_pool_size=1
+# \u914D\u7F6E\u6700\u5927\u7EBF\u7A0B\u6570
+task.max_pool_size=1
+# \u914D\u7F6E\u961F\u5217\u5927\u5C0F
+task.queue_capacity=10
+# \u914D\u7F6E\u7EBF\u7A0B\u6C60\u4E2D\u7684\u7EBF\u7A0B\u7684\u540D\u79F0\u524D\u7F00
+task.thread_name_prefix=async-task-fund
+
+file.preview.path = https://tamp-sit.oss-cn-shanghai.aliyuncs.com/docConvertOutput/
+
+#######################################
+####### kafka\u914D\u7F6E ####
+#######################################
+#spring.kafka.bootstrap-servers=118.190.63.109:9092
+#spring.kafka.producer.retries=1
+#spring.kafka.consumer.group-id=service-product
+#spring.kafka.consumer.auto-offset-reset=earliest
+#spring.kafka.consumer.enable-auto-commit=false
+#spring.kafka.listener.ack-mode=manual
+#spring.kafka.listener.type=batch
+##spring.kafka.consumer.auto-commit-interval=1000
+#spring.kafka.consumer.fetch-max-wait=500
+#spring.kafka.consumer.max-poll-records=100
+#spring.kafka.listener.missing-topics-fatal=false
+#spring.kafka.listener.concurrency=1
+
+
+### \u901A\u7528\u914D\u7F6E
+spring.cloud.consul.discovery.enabled=false
+spring.cloud.consul.enabled=false
+apollo.bootstrap.enabled=false
+
+logging.level.com.tanpu=debug
+
+
+## \u963F\u91CCOSS
+aliyun.aliyunoss.endpoint=http://oss-cn-shanghai.aliyuncs.com
+aliyun.accessKeyId = LTAIAKEzVydP0Q9P
+aliyun.accessKeySecret = 59V9ke9txaIFzWxHFKTb1eoOOpmKpJ
+tanpu.oss.ali.bucket-name=fatoolimg
+aliyun.aliyunoss.bucketName=${tanpu.oss.ali.bucket-name}
+tanpu.oss.ali.region-id = cn-shanghai
+tanpu.oss.ali.endpoint = https://oss-${tanpu.oss.ali.region-id}.aliyuncs.com
+tanpu.oss.ali.bucket-domain = https://${tanpu.oss.ali.bucket-name}.oss-${tanpu.oss.ali.region-id}.aliyuncs.com
+tanpu.oss.ali.oss-path = /upload
+
+tanpu.userno.startstep = 10000000
+
+shorterUrl.domain = http://shorturl:8086/shorter/get
+
+