礼林首次代码

mjava-lilin/pom.xml

@@ -0,0 +1,96 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.malk</groupId>
+    <artifactId>lilin</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>mjava-lilin</name>
+    <description>mjava-lilin</description>
+    <properties>
+        <java.version>1.8</java.version>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+        <spring-boot.version>2.6.13</spring-boot.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.83</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>3.14.9</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.malk</groupId>
+            <artifactId>base</artifactId>
+            <version>1.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-dependencies</artifactId>
+                <version>${spring-boot.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.1</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                    <encoding>UTF-8</encoding>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>${spring-boot.version}</version>
+                <configuration>
+                    <mainClass>com.malk.lilin.MjavaLilinApplication</mainClass>
+                    <skip>true</skip>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>repackage</id>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

mjava-lilin/src/main/java/com/malk/lilin/Controller/LiLinController.java

@@ -0,0 +1,100 @@
+package com.malk.lilin.Controller;
+
+
+import com.alibaba.fastjson.JSON;
+import com.malk.lilin.Service.LiLinService;
+import com.malk.server.common.McR;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.IOException;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+@RestController
+@Slf4j
+@RequestMapping("/ll")
+public class LiLinController {
+    @Autowired
+    private LiLinService liLinService;
+    @GetMapping("/test")
+    public McR test() {
+       return McR.success();
+    }
+    @PostMapping("/lilinUpsert")
+    public McR lilinUpsert(@RequestBody Map<String,Object> map) {
+        if (Objects.nonNull(map.get("rqqj"))){
+            List<String> rqqj = (List<String>) map.get("rqqj");
+            String  bdbh = String.valueOf(map.get("ddbh"));
+            return liLinService.lilinUpsert(rqqj,bdbh);
+
+        }
+        return McR.errorParam("实例id不能为空！");
+    }
+    @PostMapping("/lilinhqbank")//获取银行联行号
+    public McR hqbank(@RequestBody Map<String,Object> map) throws IOException {
+        log.info("lilinhqbank:{}", JSON.toJSONString(map));
+        return liLinService.hqbank(map);
+    }
+    @PostMapping("/lilinZD")//付款制单
+    public McR lilinZD(@RequestBody Map<String,Object> map) throws IOException {
+        log.info("lilinZD:{}", JSON.toJSONString(map));
+            return liLinService.lilinZD(map);
+
+    }
+    @PostMapping("/lilinJG")//支付结果查询
+    public McR lilinJG(@RequestBody Map<String,Object> map) throws IOException {
+        log.info("lilinJG:{}", JSON.toJSONString(map));
+        return liLinService.lilinJG(map);
+
+    }
+    @PostMapping("/lilinLS")//查银行流水
+    public McR lilinLS(@RequestBody Map<String,Object> map) throws IOException {
+        log.info("lilinLS:{}", JSON.toJSONString(map));
+        return liLinService.lilinLS(map);
+
+    }
+    @PostMapping("/lilinLSCF")//流水拆分
+    public McR lilinLSCF(@RequestBody Map<String,Object> map) throws IOException {
+        log.info("lilinLSCF:{}", JSON.toJSONString(map));
+        return liLinService.lilinLSCF(map);
+
+    }
+//    @PostMapping("/lilinUpsert1")
+//    public McR lilinUpsert1(@RequestBody Map<String,Object> map) {
+//        if (Objects.nonNull(map.get("rqqj"))) {
+//            // 获取当前日期，替换为当天的起止时间
+//            LocalDate today = LocalDate.now();
+//            LocalDateTime startOfDay = today.atStartOfDay();
+//            LocalDateTime endOfDay = today.atTime(LocalTime.MAX);
+//
+//            // 格式化为字符串，格式：yyyy-MM-dd HH:mm:ss
+//            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+//
+//            List<String> rqqj = Arrays.asList(
+//                    startOfDay.format(formatter),
+//                    endOfDay.format(formatter)
+//            );
+//
+//            System.out.println("r===" + rqqj);
+//
+//            String bdbh = String.valueOf(map.get("bdbh"));
+//            return liLinService.lilinUpsert(rqqj, bdbh);
+//        }
+//        if (Objects.nonNull(map.get("rqqj"))){
+//            List<String> rqqj = (List<String>) map.get("rqqj");
+//            System.out.println("r==="+rqqj);
+////            String  bdbh = String.valueOf(map.get("ddbh"));
+////            return liLinService.lilinUpsert(rqqj,bdbh);
+//        }
+//        return McR.errorParam("实例id不能为空！");
+//    }
+}

mjava-lilin/src/main/java/com/malk/lilin/Controller/taskController.java

@@ -0,0 +1,80 @@
+package com.malk.lilin.Controller;
+
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.crypto.SecureUtil;
+import cn.hutool.http.HttpUtil;
+import com.malk.lilin.Service.LiLinService;
+import com.malk.server.common.McR;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.IOException;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+@RestController
+@Configuration
+@Slf4j
+//@EnableScheduling
+//@ConditionalOnProperty(name = {"enable.scheduling"})
+@RequestMapping("/ll")
+public class taskController {
+    @Autowired
+    private LiLinService lilinService;
+    public static void main(String[] args) throws IOException {
+
+        System.out.println(token().getData());
+//        OkHttpClient client = new OkHttpClient();
+
+//        Request request = new Request.Builder()
+//                .url("https://openapi.xencio.com/sandbox/cfa/api/bs/dailyBalance?securityCode=15d6b107643f2b2114a157bcd87f3feb&dateId=20230901&pageNow=1&pageSize=20")
+//                .get()
+//                .addHeader("x-xencio-client-id", "sandbox")
+//                .build();
+//        HttpUtil.downloadFile("ss", FileUtil.file())
+//        Response response = client.newCall(request).execute();
+//        System.out.println(response.body().string());
+        OkHttpClient client = new OkHttpClient();
+
+        Request request = new Request.Builder()
+                .url("https://openapi.xencio.com/sandbox/cfa/api/bank/searchBranch?securityCode="+token().getData()+"&queryType=full")
+                .get()
+                .addHeader("x-xencio-client-id", "4d9414e89bc24b0d89b678d9f20bc56a")
+                .addHeader("content-type", "application/x-www-form-urlencoded")
+                .build();
+        Response response = client.newCall(request).execute();
+    }
+    @GetMapping("/token")
+
+    public String  token1() {
+        return (String) token().getData();
+    }
+    @Scheduled(cron = "0 */5 * * * ?")
+    public void task() {
+        log.info("定时获取付款结果开始：{}", LocalDateTime.now());
+        try {
+            lilinService.lilinJG(null);
+        } catch (Exception e) {
+            // 记录错误信息
+            e.printStackTrace();
+        }
+
+
+    }
+    private static McR token() {
+        String today = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
+        String s = SecureUtil.md5("KHPuj0JMS6nS1ACzc#" + today);
+        return McR.success(s);
+    }
+
+}

mjava-lilin/src/main/java/com/malk/lilin/MjavaLilinApplication.java

@@ -0,0 +1,13 @@
+package com.malk.lilin;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication(scanBasePackages = {"com.malk"})
+public class MjavaLilinApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(MjavaLilinApplication.class, args);
+    }
+
+}

mjava-lilin/src/main/java/com/malk/lilin/Service/LiLinService.java

@@ -0,0 +1,24 @@
+package com.malk.lilin.Service;
+
+
+import com.malk.server.common.McR;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+
+public interface LiLinService {
+
+    McR lilinUpsert(List<String> rqqj,String bdbh);
+
+
+    McR hqbank(Map<String, Object> map) throws IOException;
+
+    McR lilinZD(Map<String, Object> map) throws IOException;
+
+    McR lilinJG(Map<String, Object> map) throws IOException;
+
+    McR lilinLS(Map<String, Object> map) throws IOException;
+
+    McR lilinLSCF(Map<String, Object> map) throws IOException;
+}

mjava-lilin/src/main/resources/application-dev.yml

@@ -0,0 +1,34 @@
+#测试学习
+server:
+  port: 9091
+  servlet:
+    context-path: /lilin
+
+enable:
+  scheduling: false
+logging:
+#  config: classpath:logback-spring.xml
+#  path: /home/server/lianxiang/log/
+  level:
+    com.malk.*: debug
+
+# dingtalk
+dingtalk:
+  agentId: 3745118146
+  appKey: dingrlxbv5y8hrsmmrnm
+  appSecret: tnAtNJUfYmYWURK302FkLXYLRW3PnCat6wj65lOG06db86m24kRqpWnVPHFCgUCU
+  corpId:
+  aesKey:
+  token:
+#  operator: 1656315499790273 #孙海生
+#  unionId: iPPoZ001WAYlZxyoU04g2bgiEiE #孙海生
+#  spaceId: 26395140381 #钉盘-团队文件-宜搭文件库
+#  partnersDentryId: 176651024213 #钉盘-团队文件-宜搭文件库-合作伙伴文件
+#  unrestrictedDonationDentryId: 176648777099 #钉盘-团队文件-宜搭文件库-资助人费用登记文件
+
+aliwork:
+  appType: APP_V25MK3XKODKB02UVTGSH
+  systemToken: IQC66GC1L5TW5HKF6SX645RC4AXG2CFGQOMCMOQ4
+
+
+

mjava-lilin/src/main/resources/application.yml

@@ -0,0 +1,15 @@
+spring:
+  profiles:
+    active: dev
+  servlet:
+    multipart:
+      max-file-size: 100MB
+      max-request-size: 100MB
+  http:
+    enabled: false
+
+  #  configuration:
+  #    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  global-config:
+    db-config:
+      id-type: auto

mjava-lilin/src/test/java/com/malk/lilin/MjavaLilinApplicationTests.java

@@ -0,0 +1,13 @@
+package com.malk.lilin;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class MjavaLilinApplicationTests {
+
+    @Test
+    void contextLoads() {
+    }
+
+}