ats配置调整

zhywpt-service-ats/build.gradle

     implementation "org.apache.skywalking:apm-toolkit-trace:8.8.0"
     implementation "org.apache.skywalking:apm-toolkit-opentracing:8.8.0"
     implementation "org.apache.skywalking:apm-toolkit-logback-1.x:8.8.0"
+//    //MYSQL
+//    runtimeOnly 'mysql:mysql-connector-java'
+    //ORACLE+库编码问题
+    runtimeOnly 'com.oracle.database.jdbc:ojdbc8:19.10.0.0'
+    runtimeOnly 'cn.easyproject:orai18n:12.1.0.2.0'
     //二维码
     implementation "com.google.zxing:core:3.5.1"
     // 支付宝SDK
     // 微信SDK
     implementation 'com.github.binarywang:weixin-java-pay:4.7.4.B'
     implementation 'com.github.wechatpay-apiv3:wechatpay-java:0.2.12'
-//    //MYSQL
-//    runtimeOnly 'mysql:mysql-connector-java'
-    //ORACLE+库编码问题
-    runtimeOnly 'com.oracle.database.jdbc:ojdbc8:19.10.0.0'
-    runtimeOnly 'cn.easyproject:orai18n:12.1.0.2.0'
 }
 
 bootJar {

zhywpt-service-ats/src/main/java/cn/com/taiji/ats/config/AppConfig.java

 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.transaction.annotation.EnableTransactionManagement;
 import org.springframework.validation.beanvalidation.LocalValidatorFactoryBean;
 
 import cn.com.taiji.common.pub.AppEnv;
 import cn.com.taiji.common.repo.jpa.MyJpaRespositoryFactoryBean;
 
+import java.util.concurrent.ThreadPoolExecutor;
+
 @Configuration
 @EntityScan(value = {"cn.com.taiji." + AppConfig.APP_NAME + ".entity", "cn.com.taiji.core.entity"})
 @EnableJpaRepositories(
     public CommonBatchJdbcDao commonJdbcDao() {
         return new CommonBatchJdbcDao(dataSource);
     }
+
+    @Bean(name = "myExecutor")
+    public ThreadPoolTaskExecutor threadPoolExecutor() {
+        ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
+        threadPoolTaskExecutor.setCorePoolSize(256);
+        threadPoolTaskExecutor.setMaxPoolSize(512);
+        threadPoolTaskExecutor.setKeepAliveSeconds(60);
+        threadPoolTaskExecutor.setQueueCapacity(100);
+        threadPoolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+        return threadPoolTaskExecutor;
+    }
 }

zhywpt-service-ats/src/main/resources/bootstrap.yml

   messages:
     basename: ValidationMessages_zh
   jpa:
-    database-platform: org.hibernate.dialect.MySQL8Dialect
+    database-platform: org.hibernate.dialect.OracleDialect
     open-in-view: false
   cloud:
     nacos:
         connectTimeout: 10000
         readTimeout: 600000
 server:
-  port: 8086
+  port: 8087
   servlet:
     context-path: /ats/
 
   comm:
     #    自定义服务地址map，key为服务名、value为服务地址。如果配置了服务地址，接口调用时请求到该地址，如果没配置，默认请求到gateway
     serviceAddr:
-      sample: http://127.0.0.1:8086
+      ats: http://127.0.0.1:8087

zhywpt-service-ats/src/test/java/cn/com/taiji/ats/manager/cs/TestHandler.java

+package cn.com.taiji.ats.manager.cs;
+
+import cn.com.taiji.ats.Application;
+import cn.com.taiji.ats.manager.AbstractCommManager;
+import cn.com.taiji.ats.manager.weixin.CreatePayOrderV2Manager;
+import cn.com.taiji.common.manager.net.http.ServiceHandleException;
+import cn.com.taiji.core.model.comm.protocol.ats.AtsCreatPayOrderV2Request;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * @Auther: humh
+ * @Description:
+ * @Date: 2025/5/12 10:58
+ * @email: huminghao@mail.taiji.com.cn
+ * @version: 1.0
+ */
+@SpringBootTest(classes = Application.class)
+public class TestHandler extends AbstractCommManager {
+
+    @Autowired
+    private CreatePayOrderV2Manager createPayOrderV2Manager;
+
+    @Test
+    public void test() {
+        AtsCreatPayOrderV2Request request = new AtsCreatPayOrderV2Request();
+        try {
+            createPayOrderV2Manager.serviceHandle(request);
+        } catch (ServiceHandleException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public static void main(String[] args) {
+        LocalDateTime parse = LocalDateTime.parse("2024-04-02 16:55:41", DateTimeFormatter.ofPattern("yyyy-MM-dd['T'][ ]HH:mm:ss"));
+        System.out.println(parse);
+    }
+
+}