Compare commits
35 Commits
main
...
feature-NH
| Author | SHA1 | Date | |
|---|---|---|---|
| 636974c99c | |||
| d25f43db18 | |||
| 5bf6b6f679 | |||
| 47b91d277a | |||
| b2237d3270 | |||
| 9f805266d6 | |||
| c11d80a7bf | |||
| 22b6ed81bd | |||
| a42d742a5e | |||
| 2fe8043791 | |||
| 5d117f7b51 | |||
| bec378be36 | |||
| 66d55f9e87 | |||
| d12a7b14e4 | |||
| c33b7e8e35 | |||
| c3c14048d7 | |||
| aaef2bd862 | |||
| ae25e50f3d | |||
| 45fb965496 | |||
| f77272ff29 | |||
| a4ccfaf9b8 | |||
| 1b1545968c | |||
| f64cac1c21 | |||
| 95047193eb | |||
| a823e3f963 | |||
| a3dc3480ba | |||
| 22d92ccf97 | |||
| 095f5c2c05 | |||
| 3f34ed1c8d | |||
| 2e0fbb5008 | |||
| e53521356d | |||
| 85cbca1fa3 | |||
| 6f61d5c07c | |||
| 807ed211f7 | |||
| 61c6198a9b |
8
code/cpicxim-XMNHSA-repeater/.idea/.gitignore
generated
vendored
Normal file
8
code/cpicxim-XMNHSA-repeater/.idea/.gitignore
generated
vendored
Normal file
@ -0,0 +1,8 @@
|
||||
# 默认忽略的文件
|
||||
/shelf/
|
||||
/workspace.xml
|
||||
# 基于编辑器的 HTTP 客户端请求
|
||||
/httpRequests/
|
||||
# Datasource local storage ignored files
|
||||
/dataSources/
|
||||
/dataSources.local.xml
|
||||
5
code/cpicxim-XMNHSA-repeater/.idea/codeStyles/codeStyleConfig.xml
generated
Normal file
5
code/cpicxim-XMNHSA-repeater/.idea/codeStyles/codeStyleConfig.xml
generated
Normal file
@ -0,0 +1,5 @@
|
||||
<component name="ProjectCodeStyleConfiguration">
|
||||
<state>
|
||||
<option name="PREFERRED_PROJECT_CODE_STYLE" value="Default" />
|
||||
</state>
|
||||
</component>
|
||||
18
code/cpicxim-XMNHSA-repeater/.idea/compiler.xml
generated
Normal file
18
code/cpicxim-XMNHSA-repeater/.idea/compiler.xml
generated
Normal file
@ -0,0 +1,18 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="CompilerConfiguration">
|
||||
<annotationProcessing>
|
||||
<profile name="Maven default annotation processors profile" enabled="true">
|
||||
<sourceOutputDir name="target/generated-sources/annotations" />
|
||||
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
|
||||
<outputRelativeToContentRoot value="true" />
|
||||
<module name="cpicxim-XMNHSA-repeater" />
|
||||
</profile>
|
||||
</annotationProcessing>
|
||||
</component>
|
||||
<component name="JavacSettings">
|
||||
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
|
||||
<module name="cpicxim-XMNHSA-repeater" options="-extdirs D:\develop\cpicxim\cpicxim-huixiabao\code\cpicxim-XMNHSA-repeater\lib" />
|
||||
</option>
|
||||
</component>
|
||||
</project>
|
||||
7
code/cpicxim-XMNHSA-repeater/.idea/encodings.xml
generated
Normal file
7
code/cpicxim-XMNHSA-repeater/.idea/encodings.xml
generated
Normal file
@ -0,0 +1,7 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="Encoding">
|
||||
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
|
||||
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
|
||||
</component>
|
||||
</project>
|
||||
20
code/cpicxim-XMNHSA-repeater/.idea/jarRepositories.xml
generated
Normal file
20
code/cpicxim-XMNHSA-repeater/.idea/jarRepositories.xml
generated
Normal file
@ -0,0 +1,20 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="RemoteRepositoriesConfiguration">
|
||||
<remote-repository>
|
||||
<option name="id" value="central" />
|
||||
<option name="name" value="Maven Central repository" />
|
||||
<option name="url" value="https://repo1.maven.org/maven2" />
|
||||
</remote-repository>
|
||||
<remote-repository>
|
||||
<option name="id" value="jboss.community" />
|
||||
<option name="name" value="JBoss Community repository" />
|
||||
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
|
||||
</remote-repository>
|
||||
<remote-repository>
|
||||
<option name="id" value="central" />
|
||||
<option name="name" value="Central Repository" />
|
||||
<option name="url" value="https://maven.aliyun.com/repository/public" />
|
||||
</remote-repository>
|
||||
</component>
|
||||
</project>
|
||||
12
code/cpicxim-XMNHSA-repeater/.idea/misc.xml
generated
Normal file
12
code/cpicxim-XMNHSA-repeater/.idea/misc.xml
generated
Normal file
@ -0,0 +1,12 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="ExternalStorageConfigurationManager" enabled="true" />
|
||||
<component name="MavenProjectsManager">
|
||||
<option name="originalFiles">
|
||||
<list>
|
||||
<option value="$PROJECT_DIR$/pom.xml" />
|
||||
</list>
|
||||
</option>
|
||||
</component>
|
||||
<component name="ProjectRootManager" version="2" project-jdk-name="22 (2)" project-jdk-type="JavaSDK" />
|
||||
</project>
|
||||
6
code/cpicxim-XMNHSA-repeater/.idea/vcs.xml
generated
Normal file
6
code/cpicxim-XMNHSA-repeater/.idea/vcs.xml
generated
Normal file
@ -0,0 +1,6 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project version="4">
|
||||
<component name="VcsDirectoryMappings">
|
||||
<mapping directory="$PROJECT_DIR$/../.." vcs="Git" />
|
||||
</component>
|
||||
</project>
|
||||
0
code/cpicxim-XMNHSA-repeater/.mvn/jvm.config
Normal file
0
code/cpicxim-XMNHSA-repeater/.mvn/jvm.config
Normal file
0
code/cpicxim-XMNHSA-repeater/.mvn/maven.config
Normal file
0
code/cpicxim-XMNHSA-repeater/.mvn/maven.config
Normal file
3
code/cpicxim-XMNHSA-repeater/.vscode/settings.json
vendored
Normal file
3
code/cpicxim-XMNHSA-repeater/.vscode/settings.json
vendored
Normal file
@ -0,0 +1,3 @@
|
||||
{
|
||||
"java.configuration.updateBuildConfiguration": "automatic"
|
||||
}
|
||||
BIN
code/cpicxim-XMNHSA-repeater/bak/zephyr-api-sdk-cx.jar
Normal file
BIN
code/cpicxim-XMNHSA-repeater/bak/zephyr-api-sdk-cx.jar
Normal file
Binary file not shown.
BIN
code/cpicxim-XMNHSA-repeater/bak/zephyr-api-sdk-nhs.jar
Normal file
BIN
code/cpicxim-XMNHSA-repeater/bak/zephyr-api-sdk-nhs.jar
Normal file
Binary file not shown.
BIN
code/cpicxim-XMNHSA-repeater/lib/zephyr-api-sdk-nhs.jar
Normal file
BIN
code/cpicxim-XMNHSA-repeater/lib/zephyr-api-sdk-nhs.jar
Normal file
Binary file not shown.
179
code/cpicxim-XMNHSA-repeater/pom.xml
Normal file
179
code/cpicxim-XMNHSA-repeater/pom.xml
Normal file
@ -0,0 +1,179 @@
|
||||
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>com.cpic.xim</groupId>
|
||||
<artifactId>cpicxim-XMNHSA-repeater</artifactId>
|
||||
<version>v20250314</version>
|
||||
|
||||
<name>cpicxim-XMNHSA-repeater</name>
|
||||
<!-- FIXME change it to the project's website -->
|
||||
<url>http://www.example.com</url>
|
||||
|
||||
<properties>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<maven.compile.source>1.8</maven.compile.source>
|
||||
<maven.compile.target>1.8</maven.compile.target>
|
||||
<!-- <maven.compiler.release>1.8</maven.compiler.release> -->
|
||||
</properties>
|
||||
|
||||
<dependencyManagement>
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.junit</groupId>
|
||||
<artifactId>junit-bom</artifactId>
|
||||
<version>5.11.0</version>
|
||||
<type>pom</type>
|
||||
<scope>import</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
</dependencyManagement>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.junit.jupiter</groupId>
|
||||
<artifactId>junit-jupiter-api</artifactId>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<!-- Optionally: parameterized tests support -->
|
||||
<dependency>
|
||||
<groupId>org.junit.jupiter</groupId>
|
||||
<artifactId>junit-jupiter-params</artifactId>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<!--jackson-->
|
||||
<!-- <dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-databind</artifactId>
|
||||
<version>2.14.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-core</artifactId>
|
||||
<version>2.13.4</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-annotations</artifactId>
|
||||
<version>2.13.4</version>
|
||||
</dependency> -->
|
||||
|
||||
<!-- log-4j -->
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-core</artifactId>
|
||||
<version>2.20.0</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-slf4j2-impl</artifactId>
|
||||
<version>2.20.0</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-api</artifactId>
|
||||
<version>2.20.0</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId> cn.hsa.zephyr</groupId>
|
||||
<artifactId>zephyr-api-sdk</artifactId>
|
||||
<version>2.0.1</version>
|
||||
<scope>system</scope>
|
||||
<systemPath>${project.basedir}/lib/zephyr-api-sdk-nhs.jar</systemPath>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>com.mysql</groupId>
|
||||
<artifactId>mysql-connector-j</artifactId>
|
||||
<version>9.2.0</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.bouncycastle</groupId>
|
||||
<artifactId>bcprov-jdk18on</artifactId>
|
||||
<version>1.80</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>commons-logging</groupId>
|
||||
<artifactId>commons-logging</artifactId>
|
||||
<version>1.3.5</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.alibaba</groupId>
|
||||
<artifactId>fastjson</artifactId>
|
||||
<!-- <version>1.2.83</version> -->
|
||||
<version>2.0.56</version>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
<defaultGoal>compile</defaultGoal>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<artifactId>maven-surefire-plugin</artifactId>
|
||||
<version>3.5.2</version>
|
||||
<configuration>
|
||||
<skip>true</skip>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<artifactId>maven-compiler-plugin</artifactId>
|
||||
<version>3.14.0</version>
|
||||
<configuration>
|
||||
<source>1.8</source>
|
||||
<target>1.8</target>
|
||||
<encoding>UTF-8</encoding>
|
||||
<compilerArguments>
|
||||
<extdirs>${project.basedir}/lib</extdirs>
|
||||
</compilerArguments>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-assembly-plugin</artifactId>
|
||||
<version>3.7.1</version>
|
||||
<configuration>
|
||||
<descriptorRefs>
|
||||
<descriptorRef>jar-with-dependencies</descriptorRef>
|
||||
</descriptorRefs>
|
||||
<archive>
|
||||
<manifest>
|
||||
<mainClass>com.cpic.xim.huixiabao.AppMain</mainClass>
|
||||
</manifest>
|
||||
</archive>
|
||||
</configuration>
|
||||
<executions>
|
||||
<execution>
|
||||
<id>make-assembly</id>
|
||||
<phase>package</phase>
|
||||
<goals>
|
||||
<goal>single</goal>
|
||||
</goals>
|
||||
</execution>
|
||||
</executions>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-maven-plugin</artifactId>
|
||||
<version>2.6.0</version>
|
||||
<configuration>
|
||||
<mainClass>com.cpic.xim.huixiabao.AppMain</mainClass>
|
||||
<includeSystemScope>true</includeSystemScope>
|
||||
</configuration>
|
||||
<executions>
|
||||
<execution>
|
||||
<id>repackage</id>
|
||||
<goals>
|
||||
<goal>repackage</goal>
|
||||
</goals>
|
||||
</execution>
|
||||
</executions>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</project>
|
||||
@ -0,0 +1,61 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
*
|
||||
* @Date: 2025-03-11 09:27:40
|
||||
*
|
||||
* @LastEditors: Kane
|
||||
*
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/main/java/com/cpic/xim/huixiabao/AppMain.java
|
||||
*
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao;
|
||||
|
||||
import java.util.Vector;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import com.cpic.xim.huixiabao.data.config.HuixiabaoConfig;
|
||||
import com.cpic.xim.huixiabao.data.pojo.HmbXyxInfo;
|
||||
import com.cpic.xim.huixiabao.nhs.CpicximToXMNHS;
|
||||
|
||||
public class AppMain
|
||||
{
|
||||
private static Logger logger = LoggerFactory.getLogger( AppMain.class );
|
||||
|
||||
public static void main( String[] args )
|
||||
{
|
||||
doPostXyxInfo();
|
||||
|
||||
System.out.println( "Hello World!" );
|
||||
}
|
||||
|
||||
private static void doPostXyxInfo()
|
||||
{
|
||||
while ( true )
|
||||
{
|
||||
Vector<HmbXyxInfo> xyxInfo = CpicximToXMNHS.getNeverTransHmbList();
|
||||
|
||||
// 发送
|
||||
if ( xyxInfo.isEmpty() == false )
|
||||
{
|
||||
logger.info( "查询到" + String.valueOf( xyxInfo.size() ) + "条数据，开始发送！" );
|
||||
|
||||
CpicximToXMNHS.postHmbXyxInfo( xyxInfo );
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
logger.info( "等待" + String.valueOf( HuixiabaoConfig.getSleepSeconds() ) + "秒。" );
|
||||
Thread.sleep( HuixiabaoConfig.getSleepSeconds() * 1000 );
|
||||
}
|
||||
catch ( InterruptedException error )
|
||||
{
|
||||
logger.error( "sleep时出错：" + error.getMessage() );
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,68 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
*
|
||||
* @Date: 2025-03-11 09:30:38
|
||||
*
|
||||
* @LastEditors: Kane
|
||||
*
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/main/java/com/cpic/xim/huixiabao/data/config/HuixiabaoConfig.java
|
||||
*
|
||||
* @Description: 存放惠厦保相关的配置文件，以后要改成json文件存放。
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
|
||||
package com.cpic.xim.huixiabao.data.config;
|
||||
|
||||
public class HuixiabaoConfig
|
||||
{
|
||||
public static String getAppid()
|
||||
{
|
||||
return appid;
|
||||
}
|
||||
|
||||
public static String getAppSecret()
|
||||
{
|
||||
return appSecret;
|
||||
}
|
||||
|
||||
public static String getSignKey()
|
||||
{
|
||||
return signKey;
|
||||
}
|
||||
|
||||
public static String getEncKey()
|
||||
{
|
||||
return encKey;
|
||||
}
|
||||
|
||||
public static int getMAX_COUNT_PER_REQUEST()
|
||||
{
|
||||
return MAX_COUNT_PER_REQUEST;
|
||||
}
|
||||
|
||||
public static String getUrl()
|
||||
{
|
||||
return url;
|
||||
}
|
||||
|
||||
public static String getFunId()
|
||||
{
|
||||
return funId;
|
||||
}
|
||||
|
||||
public static int getSleepSeconds()
|
||||
{
|
||||
return SLEEP_SECONDS;
|
||||
}
|
||||
|
||||
private static final int MAX_COUNT_PER_REQUEST = 500;
|
||||
private static final int SLEEP_SECONDS = 10;
|
||||
|
||||
private static final String url = "http://172.18.1.150:9040/h3c/new/api/gafe/rest";
|
||||
private static final String appid = "hxb-tb";
|
||||
private static final String appSecret = "60F468FB46170DD4CF6CBECE215DBFC0";
|
||||
private static final String funId = "XY00.00.00.03";
|
||||
private static final String signKey = "1A2F447BD0F930798D8031B137EC6E25";
|
||||
private static final String encKey = "08307695B1668EB9FD6210250FED874F";
|
||||
}
|
||||
@ -0,0 +1,100 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
*
|
||||
* @Date: 2025-03-06 14:33:27
|
||||
*
|
||||
* @LastEditors: Kane
|
||||
*
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/main/java/com/cpic/xim/huixiabao/data/pojo/HmbXyxInfo.java
|
||||
*
|
||||
* @Description: 小药箱接口参数描述
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao.data.pojo;
|
||||
|
||||
// import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
// import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
// import com.fasterxml.jackson.annotation.JsonPropertyOrder;
|
||||
|
||||
// @JsonInclude( JsonInclude.Include.NON_EMPTY )
|
||||
// @JsonPropertyOrder( alphabetic = true )
|
||||
public class HmbXyxInfo
|
||||
{
|
||||
|
||||
public HmbXyxInfo( String psnName,
|
||||
String certNo,
|
||||
String serviceId,
|
||||
String status,
|
||||
String xyxNo )
|
||||
{
|
||||
this.psnName = psnName;
|
||||
this.certNo = certNo;
|
||||
this.serviceId = serviceId;
|
||||
this.status = status;
|
||||
this.xyxNo = xyxNo;
|
||||
}
|
||||
|
||||
public String getPsnName()
|
||||
{
|
||||
return psnName;
|
||||
}
|
||||
|
||||
public void setPsnName( String psnName )
|
||||
{
|
||||
this.psnName = psnName;
|
||||
}
|
||||
|
||||
public String getCertNo()
|
||||
{
|
||||
return certNo;
|
||||
}
|
||||
|
||||
public void setCertNo( String certNo )
|
||||
{
|
||||
this.certNo = certNo;
|
||||
}
|
||||
|
||||
public String getServiceId()
|
||||
{
|
||||
return serviceId;
|
||||
}
|
||||
|
||||
public void setServiceId( String serviceId )
|
||||
{
|
||||
this.serviceId = serviceId;
|
||||
}
|
||||
|
||||
public String getStatus()
|
||||
{
|
||||
return status;
|
||||
}
|
||||
|
||||
public void setStatus( String status )
|
||||
{
|
||||
this.status = status;
|
||||
}
|
||||
|
||||
public String getXyxNo()
|
||||
{
|
||||
return xyxNo;
|
||||
}
|
||||
|
||||
public void setXyxNo( String xyxNo )
|
||||
{
|
||||
this.xyxNo = xyxNo;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString()
|
||||
{
|
||||
return "HmbXyxInfo [psnName=" + psnName + ", certNo=" + certNo + ", serviceId=" + serviceId + ", status=" + status + ", xyxNo=" + xyxNo + "]";
|
||||
}
|
||||
|
||||
private String psnName;
|
||||
private String certNo;
|
||||
private String serviceId;
|
||||
private String status;
|
||||
private String xyxNo;
|
||||
|
||||
}
|
||||
@ -0,0 +1,51 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-06 14:27:05
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/main/java/com/cpic/xim/huixiabao/data/pojo/HmbXyxInfoRequest.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao.data.pojo;
|
||||
|
||||
import java.util.Vector;
|
||||
|
||||
public class HmbXyxInfoRequest
|
||||
{
|
||||
public HmbXyxInfoRequest()
|
||||
{
|
||||
this.topic = "hmbXyxInfo";
|
||||
this.hmbList = new Vector<>();
|
||||
}
|
||||
|
||||
public HmbXyxInfoRequest( String topic, Vector<HmbXyxInfo> hmbList )
|
||||
{
|
||||
this.topic = topic;
|
||||
this.topic = "hmbXyxInfo";
|
||||
this.hmbList = hmbList;
|
||||
}
|
||||
|
||||
public String getTopic()
|
||||
{
|
||||
return topic;
|
||||
}
|
||||
|
||||
public void setTopic( String topic )
|
||||
{
|
||||
this.topic = topic;
|
||||
}
|
||||
|
||||
public Vector<HmbXyxInfo> getHmbList()
|
||||
{
|
||||
return hmbList;
|
||||
}
|
||||
|
||||
public void setHmbList( Vector<HmbXyxInfo> hmbList )
|
||||
{
|
||||
this.hmbList = hmbList;
|
||||
}
|
||||
|
||||
private String topic; // 业务类型
|
||||
private Vector<HmbXyxInfo> hmbList;
|
||||
}
|
||||
@ -0,0 +1,108 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
*
|
||||
* @Date: 2025-03-06 14:17:24
|
||||
*
|
||||
* @LastEditors: Kane
|
||||
*
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/main/java/com/cpic/xim/huixiabao/data/pojo/NHACommenRequestBody.java
|
||||
*
|
||||
* @Description: 易联众请求共通报文结构
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao.data.pojo;
|
||||
|
||||
public class NHACommenRequestBody
|
||||
{
|
||||
|
||||
public String getChs_fjs_appid()
|
||||
{
|
||||
return chs_fjs_appid;
|
||||
}
|
||||
|
||||
public void setChs_fjs_appid( String chs_fjs_appid )
|
||||
{
|
||||
this.chs_fjs_appid = chs_fjs_appid;
|
||||
}
|
||||
|
||||
public String getChs_fjs_appsecret()
|
||||
{
|
||||
return chs_fjs_appsecret;
|
||||
}
|
||||
|
||||
public void setChs_fjs_appsecret( String chs_fjs_appsecret )
|
||||
{
|
||||
this.chs_fjs_appsecret = chs_fjs_appsecret;
|
||||
}
|
||||
|
||||
public String getChs_fjs_token()
|
||||
{
|
||||
return chs_fjs_token;
|
||||
}
|
||||
|
||||
public void setChs_fjs_token( String chs_fjs_token )
|
||||
{
|
||||
this.chs_fjs_token = chs_fjs_token;
|
||||
}
|
||||
|
||||
public String getChs_fjs_funid()
|
||||
{
|
||||
return chs_fjs_funid;
|
||||
}
|
||||
|
||||
public void setChs_fjs_funid( String chs_fjs_funid )
|
||||
{
|
||||
this.chs_fjs_funid = chs_fjs_funid;
|
||||
}
|
||||
|
||||
public String getChs_fjs_encdata()
|
||||
{
|
||||
return chs_fjs_encdata;
|
||||
}
|
||||
|
||||
public void setChs_fjs_encdata( String chs_fjs_encdata )
|
||||
{
|
||||
this.chs_fjs_encdata = chs_fjs_encdata;
|
||||
}
|
||||
|
||||
public String getChs_fjs_sign()
|
||||
{
|
||||
return chs_fjs_sign;
|
||||
}
|
||||
|
||||
public void setChs_fjs_sign( String chs_fjs_sign )
|
||||
{
|
||||
this.chs_fjs_sign = chs_fjs_sign;
|
||||
}
|
||||
|
||||
public int getChs_fjs_timestamp()
|
||||
{
|
||||
return chs_fjs_timestamp;
|
||||
}
|
||||
|
||||
public void setChs_fjs_timestamp( int chs_fjs_timestamp )
|
||||
{
|
||||
this.chs_fjs_timestamp = chs_fjs_timestamp;
|
||||
}
|
||||
|
||||
public String getData()
|
||||
{
|
||||
return data;
|
||||
}
|
||||
|
||||
public void setData( String data )
|
||||
{
|
||||
this.data = data;
|
||||
}
|
||||
|
||||
private String chs_fjs_appid; // 渠道id
|
||||
private String chs_fjs_appsecret; // 渠道私钥
|
||||
private String chs_fjs_token; // 请求时携带的动态令牌
|
||||
private String chs_fjs_funid; // 服务编号
|
||||
private String chs_fjs_encdata; // 加密后的数据
|
||||
private String chs_fjs_sign; // 签名数据串
|
||||
private String data; // 未加密的数据
|
||||
private int chs_fjs_timestamp; // 时间戳
|
||||
|
||||
}
|
||||
@ -0,0 +1,338 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
*
|
||||
* @Date: 2025-03-12 09:01:59
|
||||
*
|
||||
* @LastEditors: Kane
|
||||
*
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/main/java/com/cpic/xim/huixiabao/nhs/CpicximToXMNHS.java
|
||||
*
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
|
||||
package com.cpic.xim.huixiabao.nhs;
|
||||
|
||||
import java.sql.Connection;
|
||||
import java.sql.DriverManager;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.Statement;
|
||||
import java.sql.SQLException;
|
||||
import java.util.Vector;
|
||||
import com.cpic.xim.huixiabao.data.pojo.*;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import cn.hsa.zephyr.apisdk.DefaultZephyrClient;
|
||||
import cn.hsa.zephyr.apisdk.internal.exception.ZephyrApiException;
|
||||
import cn.hsa.zephyr.apisdk.internal.util.encrypt.EncryptionModeEnum;
|
||||
import cn.hsa.zephyr.apisdk.internal.util.encrypt.SignTypeEnum;
|
||||
import cn.hsa.zephyr.apisdk.request.DefaultZephyrRequest;
|
||||
import cn.hsa.zephyr.apisdk.response.DefaultZephyrResponse;
|
||||
import com.cpic.xim.huixiabao.data.config.HuixiabaoConfig;
|
||||
|
||||
@SuppressWarnings(
|
||||
"unused"
|
||||
)
|
||||
public class CpicximToXMNHS
|
||||
{
|
||||
private static Logger logger = LoggerFactory.getLogger( CpicximToXMNHS.class );
|
||||
|
||||
private static String driverName = "com.mysql.cj.jdbc.Driver";
|
||||
private static String url = "jdbc:mysql://10.39.0.85:3306/huixiabao?useUnicode=true&characterEncoding=utf8&useSSL=true";
|
||||
private static String userName = "huixiabao";
|
||||
private static String password = "Kane@1981";
|
||||
|
||||
/**
|
||||
* 从HmbXyxInfo_Update中获取未发送过的小药箱数据。
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static Vector<HmbXyxInfo> getNeverTransHmbList()
|
||||
{
|
||||
|
||||
Vector<HmbXyxInfo> items = new Vector<HmbXyxInfo>();
|
||||
HmbXyxInfo item = null;
|
||||
|
||||
Connection connection = null;
|
||||
Statement statement = null;
|
||||
ResultSet result = null;
|
||||
|
||||
try
|
||||
{
|
||||
Class.forName( "com.mysql.cj.jdbc.Driver" );
|
||||
|
||||
String url = CpicximToXMNHS.url;
|
||||
String userName = CpicximToXMNHS.userName;
|
||||
String password = CpicximToXMNHS.password;
|
||||
// String sql = """
|
||||
// select info.psnName, info.certNo, info.serviceId, info.status, info.xyxNo
|
||||
// from HmbXyxInfo info,
|
||||
// HmbXyxInfo_Update u
|
||||
// where info.xyxNo = u.xyxNo """;
|
||||
|
||||
String sql = "select info.psnName, info.certNo, info.serviceId, info.status, info.xyxNo \n" +
|
||||
" from HmbXyxInfo info, \n" +
|
||||
" HmbXyxInfo_Update u \n" +
|
||||
" where info.xyxNo = u.xyxNo";
|
||||
|
||||
connection = DriverManager.getConnection( url, userName, password );
|
||||
statement = connection.createStatement();
|
||||
result = statement.executeQuery( sql.trim() );
|
||||
|
||||
while ( result.next() )
|
||||
{
|
||||
item = new HmbXyxInfo( result.getString( "psnName" ),
|
||||
result.getString( "certno" ),
|
||||
result.getString( "serviceId" ),
|
||||
result.getString( "status" ),
|
||||
result.getString( "xyxNo" ) );
|
||||
|
||||
items.add( item );
|
||||
}
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
error.printStackTrace();
|
||||
}
|
||||
catch ( ClassNotFoundException error )
|
||||
{
|
||||
logger.error( "加载sql驱动错误：" + error.getMessage() );
|
||||
}
|
||||
finally
|
||||
{
|
||||
if ( result != null )
|
||||
{
|
||||
try
|
||||
{
|
||||
result.close();
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
if ( statement != null )
|
||||
{
|
||||
try
|
||||
{
|
||||
statement.close();
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
if ( connection != null )
|
||||
{
|
||||
try
|
||||
{
|
||||
connection.close();
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return items;
|
||||
}
|
||||
|
||||
/**
|
||||
* 将 postedItems 中的小药箱数据，冲HmbXyxInfo_update中清除。
|
||||
*
|
||||
* @param postedItems 已发送的小药箱数据
|
||||
*/
|
||||
public static void removePostedHmbXyxInfo( Vector<HmbXyxInfo> postedItems )
|
||||
{
|
||||
Vector<HmbXyxInfo> items = new Vector<HmbXyxInfo>();
|
||||
HmbXyxInfo item = null;
|
||||
|
||||
Connection connection = null;
|
||||
PreparedStatement statement = null;
|
||||
ResultSet result = null;
|
||||
|
||||
try
|
||||
{
|
||||
Class.forName( "com.mysql.cj.jdbc.Driver" );
|
||||
|
||||
String url = CpicximToXMNHS.url;
|
||||
String userName = CpicximToXMNHS.userName;
|
||||
String password = CpicximToXMNHS.password;
|
||||
String sql = "delete from HmbXyxInfo_Update where xyxNo = ?";
|
||||
|
||||
connection = DriverManager.getConnection( url, userName, password );
|
||||
statement = connection.prepareStatement( sql.trim() );
|
||||
|
||||
for ( HmbXyxInfo info : postedItems )
|
||||
{
|
||||
statement.setString( 1, info.getXyxNo() );
|
||||
statement.execute();
|
||||
}
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
try
|
||||
{
|
||||
connection.rollback();
|
||||
}
|
||||
catch ( SQLException e )
|
||||
{
|
||||
|
||||
}
|
||||
|
||||
logger.error( "清理已发送数据失败：" + error.getMessage() );
|
||||
}
|
||||
catch ( ClassNotFoundException error )
|
||||
{
|
||||
|
||||
}
|
||||
finally
|
||||
{
|
||||
if ( result != null )
|
||||
{
|
||||
try
|
||||
{
|
||||
result.close();
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
if ( statement != null )
|
||||
{
|
||||
try
|
||||
{
|
||||
statement.close();
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
logger.error( "加载sql驱动错误：" + error.getMessage() );
|
||||
}
|
||||
}
|
||||
|
||||
if ( connection != null )
|
||||
{
|
||||
try
|
||||
{
|
||||
connection.close();
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public static void postHmbXyxInfo( Vector<HmbXyxInfo> items )
|
||||
{
|
||||
String url = HuixiabaoConfig.getUrl();
|
||||
String appId = HuixiabaoConfig.getAppid();
|
||||
String appSecret = HuixiabaoConfig.getAppSecret();
|
||||
String funId = HuixiabaoConfig.getFunId();
|
||||
String encKey = HuixiabaoConfig.getEncKey();
|
||||
String signKey = HuixiabaoConfig.getSignKey();
|
||||
|
||||
SignTypeEnum signType = SignTypeEnum.SM3;
|
||||
EncryptionModeEnum encType = EncryptionModeEnum.SM4;
|
||||
|
||||
// 发送用工具对象
|
||||
DefaultZephyrClient client = new DefaultZephyrClient( url,
|
||||
funId,
|
||||
appId,
|
||||
appSecret,
|
||||
signType,
|
||||
signKey,
|
||||
encType,
|
||||
encKey );
|
||||
DefaultZephyrRequest req = new DefaultZephyrRequest();
|
||||
DefaultZephyrResponse resp = null;
|
||||
|
||||
// 数据
|
||||
JSONObject data = new JSONObject();
|
||||
JSONObject requestObject = new JSONObject();
|
||||
JSONObject xyxInfo = null;
|
||||
JSONArray xyxInfoList = new JSONArray();
|
||||
Vector<HmbXyxInfo> postedInfo = new Vector<HmbXyxInfo>(); // 存放已经送出的数据
|
||||
|
||||
requestObject.put( "topic", "hmbXyxInfo" );
|
||||
|
||||
int request_count = 0; // 计数，每个请求不能超过500条
|
||||
int total_count = 0;
|
||||
|
||||
for ( HmbXyxInfo info : items )
|
||||
{
|
||||
xyxInfo = new JSONObject();
|
||||
|
||||
xyxInfo.put( "psnName", info.getPsnName() );
|
||||
xyxInfo.put( "cerno", info.getCertNo() );
|
||||
xyxInfo.put( "serviceId", info.getServiceId() );
|
||||
xyxInfo.put( "status", info.getStatus() );
|
||||
xyxInfo.put( "xyxNo", info.getXyxNo() );
|
||||
|
||||
xyxInfoList.add( xyxInfo );
|
||||
postedInfo.add( info );
|
||||
|
||||
request_count++;
|
||||
total_count++;
|
||||
|
||||
logger.info( "准备数据：" + xyxInfo.toJSONString() );
|
||||
|
||||
if ( request_count >= HuixiabaoConfig.getMAX_COUNT_PER_REQUEST() - 1 || total_count == items.size() )
|
||||
{
|
||||
// 达到上限，或者记录已经全部处理，将当前生成的数据送出
|
||||
requestObject.remove( "hmbList" );
|
||||
requestObject.put( "hmbList", xyxInfoList );
|
||||
|
||||
try
|
||||
{
|
||||
data.remove("data");
|
||||
data.put("data", requestObject);
|
||||
logger.info( "发送请求内容:" + requestObject.toJSONString() );
|
||||
logger.info( "请求地址：" + HuixiabaoConfig.getUrl() );
|
||||
|
||||
req.setData( requestObject );
|
||||
resp = client.execute( req );
|
||||
|
||||
if ( resp != null )
|
||||
{
|
||||
logger.info( "发送成功，返回消息Body：" + resp.getBody() );
|
||||
logger.info( "发送成功，返回消息data：" + resp.getData() );
|
||||
logger.info( "发送成功，返回消息message：" + resp.getMessage() );
|
||||
|
||||
// 将已发送的数据从HmbXyxInfo_update表中清理掉
|
||||
removePostedHmbXyxInfo( postedInfo );
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.info( "已发送请求，但获取的DefaultZephyrResponse为null！" );
|
||||
}
|
||||
}
|
||||
catch ( ZephyrApiException error )
|
||||
{
|
||||
// 发送不成功，记录日志
|
||||
// 不从HmbXyxInfo_update中清理当前这批数据，待以后重新发送
|
||||
logger.error( "发送异常：" + error.getMessage() );
|
||||
}
|
||||
finally
|
||||
{
|
||||
// 清理清单，重置计数
|
||||
// 如果发送失败，在HmbXyxInfo_update表中保留发送失败的记录，待下次发送
|
||||
xyxInfoList.clear();
|
||||
postedInfo.clear();
|
||||
|
||||
request_count = 0;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
40
code/cpicxim-XMNHSA-repeater/src/main/resources/log4j2.xml
Normal file
40
code/cpicxim-XMNHSA-repeater/src/main/resources/log4j2.xml
Normal file
@ -0,0 +1,40 @@
|
||||
<Configuration status="WARN" monitorInterval="300">
|
||||
<Appenders>
|
||||
<Console name="Console" target="SYSTEM_OUT">
|
||||
<PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} ### %msg%n" />
|
||||
<ThresholdFilter level="trace" onMatch="ACCEPT" onMismatch="DENY" />
|
||||
</Console>
|
||||
<RollingFile name="rolling_file_win"
|
||||
filePattern="./logs/huixiabao/$${date:yyyy-MM}/huixiabao-%d{MM-dd-yyyy}-%i.log.gz">
|
||||
<PatternLayout>
|
||||
<Pattern>[%t][%level][%d{HH:mm:ss.SSS}][%logger.%M{36}#%L] %msg%n</Pattern>
|
||||
</PatternLayout>
|
||||
<Policies>
|
||||
<TimeBasedTriggeringPolicy interval="1" />
|
||||
<SizeBasedTriggeringPolicy size="20MB" />
|
||||
<DefaultRolloverStrategy max="20" />
|
||||
</Policies>
|
||||
</RollingFile>
|
||||
<RollingFile name="rolling_file_linux"
|
||||
filePattern="/logs/huixiabao/$${date:yyyy-MM}/app-%d{MM-dd-yyyy}-%i.log.gz">
|
||||
<PatternLayout>
|
||||
<Pattern>[%t][%level][%d{HH:mm:ss.SSS}][%logger.%M{36}#%L] %msg%n</Pattern>
|
||||
</PatternLayout>
|
||||
<Policies>
|
||||
<TimeBasedTriggeringPolicy interval="1" />
|
||||
<SizeBasedTriggeringPolicy size="20MB" />
|
||||
<DefaultRolloverStrategy max="20" />
|
||||
</Policies>
|
||||
</RollingFile>
|
||||
</Appenders>
|
||||
<Loggers>
|
||||
<!-- <Logger name="mylog" level="info">
|
||||
<AppenderRef ref="rolling_file" />
|
||||
</Logger> -->
|
||||
<Root level="debug">
|
||||
<AppenderRef ref="rolling_file_linux" />
|
||||
<AppenderRef ref="rolling_file_win" />
|
||||
<AppenderRef ref="Console" />
|
||||
</Root>
|
||||
</Loggers>
|
||||
</Configuration>
|
||||
@ -0,0 +1,140 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
*
|
||||
* @Date: 2025-03-11 09:27:40
|
||||
*
|
||||
* @LastEditors: Kane
|
||||
*
|
||||
* @FilePath: /cpicxim-XMNHSA-repeater/src/test/java/com/cpic/xim/huixiabao/AppTest.java
|
||||
*
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import java.util.Vector;
|
||||
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.cpic.xim.huixiabao.data.pojo.HmbXyxInfo;
|
||||
import com.cpic.xim.huixiabao.nhs.CpicximToXMNHS;
|
||||
|
||||
import cn.hsa.zephyr.apisdk.DefaultZephyrClient;
|
||||
import cn.hsa.zephyr.apisdk.internal.exception.ZephyrApiException;
|
||||
import cn.hsa.zephyr.apisdk.internal.util.encrypt.EncryptionModeEnum;
|
||||
import cn.hsa.zephyr.apisdk.internal.util.encrypt.SignTypeEnum;
|
||||
import cn.hsa.zephyr.apisdk.request.DefaultZephyrRequest;
|
||||
import cn.hsa.zephyr.apisdk.response.DefaultZephyrResponse;
|
||||
|
||||
|
||||
/**
|
||||
* Unit test for simple App.
|
||||
*/
|
||||
public class AppTest
|
||||
{
|
||||
private Logger logger = LoggerFactory.getLogger( AppTest.class );
|
||||
|
||||
/**
|
||||
* Rigorous Test :-)
|
||||
*/
|
||||
@Test
|
||||
public void shouldAnswerWithTrue()
|
||||
{
|
||||
assertTrue( true );
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testLog()
|
||||
{
|
||||
for (
|
||||
int i = 0;
|
||||
i < 10000;
|
||||
i++
|
||||
)
|
||||
{
|
||||
// System.out.print("test!");
|
||||
logger.error( "test!!!!" );
|
||||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
public void nhsTest()
|
||||
{
|
||||
String url = "172.18.1.150:9040";
|
||||
String appId = "待定";
|
||||
String appSecret = "待定";
|
||||
String funId = "xxx";
|
||||
String encKey = "A5B6E00DA599G56C41ABFE23A74E6E60";
|
||||
String signKey = "待定";
|
||||
|
||||
SignTypeEnum signType = SignTypeEnum.SM3;
|
||||
EncryptionModeEnum encType = EncryptionModeEnum.SM4;
|
||||
|
||||
try
|
||||
{
|
||||
DefaultZephyrClient client = new DefaultZephyrClient( url,
|
||||
funId,
|
||||
appId,
|
||||
appSecret,
|
||||
signType,
|
||||
signKey,
|
||||
encType,
|
||||
encKey );
|
||||
|
||||
DefaultZephyrRequest req = new DefaultZephyrRequest();
|
||||
JSONObject jsonObject1 = new JSONObject();
|
||||
DefaultZephyrResponse resp = null;
|
||||
|
||||
jsonObject1.put( "code", "XXXXXXXXXXXXXXXXXX" );
|
||||
jsonObject1.put( "scene_code", "XXX" );
|
||||
|
||||
req.setData( jsonObject1 );
|
||||
resp = client.execute( req );
|
||||
|
||||
System.out.println( resp.getData() );
|
||||
}
|
||||
catch ( ZephyrApiException e )
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
public void jsonTest()
|
||||
{
|
||||
JSONObject requestObject = new JSONObject();
|
||||
JSONObject item = new JSONObject();
|
||||
JSONArray hmbList = new JSONArray();
|
||||
|
||||
requestObject.put( "topic", "hmbXyxInfo" );
|
||||
requestObject.put( "hmbList", hmbList );
|
||||
|
||||
item.put( "psnName", "王炜" );
|
||||
item.put( "cerno", "350402198106130016" );
|
||||
item.put( "serviceId", "100007" );
|
||||
item.put( "status", "1" );
|
||||
item.put( "xyxNo", "1234567" );
|
||||
|
||||
hmbList.add( item );
|
||||
|
||||
String json = requestObject.toJSONString();
|
||||
|
||||
System.out.println( json );
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testMysql()
|
||||
{
|
||||
Vector<HmbXyxInfo> items = CpicximToXMNHS.getNeverTransHmbList();
|
||||
|
||||
System.out.println( items.toString() );
|
||||
|
||||
assert( items.size() > 0 );
|
||||
}
|
||||
}
|
||||
0
code/cpicxim-huixiabao/.mvn/jvm.config
Normal file
0
code/cpicxim-huixiabao/.mvn/jvm.config
Normal file
0
code/cpicxim-huixiabao/.mvn/maven.config
Normal file
0
code/cpicxim-huixiabao/.mvn/maven.config
Normal file
87
code/cpicxim-huixiabao/.vscode/fileheader.template.js
vendored
Normal file
87
code/cpicxim-huixiabao/.vscode/fileheader.template.js
vendored
Normal file
@ -0,0 +1,87 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-16 00:35:09
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-huixiabao/.vscode/fileheader.template.js
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
/**
|
||||
* This file is generated by VSCode extension: Fileheader Pro
|
||||
*/
|
||||
|
||||
/**
|
||||
* These comments can help you write your own template with type hint
|
||||
* @typedef {Object} FileheaderVariable Fileheader variables
|
||||
* @property {string} birthtime file birth time. will get it from VCS or fallback to filesystem when it is not available
|
||||
* @property {string} mtime file modification time. will get it from VCS or fallback to filesystem when it is not available
|
||||
* @property {string} authorName if the file is tracked by VCS, it will get the author name from VCS. else it will get it from current user name
|
||||
* @property {string} authorEmail if the file is tracked by VCS, it will get the author email from VCS. else it will get it from current user email
|
||||
* @property {string} userName else it will get it from current user name
|
||||
* @property {string} userEmail user email is from VSCode config, and fallback to VCS config
|
||||
* @property {string} companyName
|
||||
* @property {string} projectName name of current project
|
||||
* @property {string} filePath the file path, relative to project root with POSIX path separator
|
||||
* @property {string} dirPath the directory path, relative to project root with POSIX path separator
|
||||
* @property {string} fileName filename with extension
|
||||
*/
|
||||
|
||||
/**
|
||||
* @typedef {string | number | null | undefined | Template | boolean} TemplateInterpolation NOTE: boolean or falsy value will render empty string
|
||||
*
|
||||
* @typedef {{ strings: TemplateStringsArray; interpolations: TemplateInterpolation[]; }} Template
|
||||
* @typedef {(strings: TemplateStringsArray, ...values: any[]) => string} ITemplateFunction
|
||||
*
|
||||
*/
|
||||
|
||||
/**
|
||||
* Please confirm your provider extends from globalThis.FileheaderLanguageProvider
|
||||
*/
|
||||
class CustomLanguageProvider extends globalThis.FileheaderLanguageProvider {
|
||||
/**
|
||||
* @type {string[]}
|
||||
*/
|
||||
languages = [
|
||||
"java",
|
||||
"javascript",
|
||||
"typescript",
|
||||
"javascriptreact",
|
||||
"typescriptreact",
|
||||
];
|
||||
|
||||
/**
|
||||
* @type {string=} the language block comment start string.
|
||||
* this is for future feature: support detect old custom template when custom template changes
|
||||
*/
|
||||
blockCommentStart = "/**";
|
||||
|
||||
/**
|
||||
* @type {string=}
|
||||
*/
|
||||
blockCommentEnd = "*/";
|
||||
|
||||
/**
|
||||
* get your template when document language matched
|
||||
* @param {ITemplateFunction} tpl template function, it is a tagged function, support nested interpolation
|
||||
* @param {FileheaderVariable} variables template variables
|
||||
* @returns {Template}
|
||||
*/
|
||||
getTemplate(tpl, variables) {
|
||||
// prettier-ignore
|
||||
return tpl
|
||||
`/**
|
||||
* @Author: ${variables.authorName} <${variables.authorEmail}>
|
||||
* @Date: ${variables.birthtime}
|
||||
* @LastEditors: ${variables.userName}
|
||||
* @LastModified: ${variables.mtime}
|
||||
* @FilePath: ${variables.filePath}
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2025} by Kane All rights reserved
|
||||
*/`;
|
||||
}
|
||||
}
|
||||
|
||||
// export your provider classes
|
||||
module.exports = [CustomLanguageProvider];
|
||||
4
code/cpicxim-huixiabao/.vscode/settings.json
vendored
Normal file
4
code/cpicxim-huixiabao/.vscode/settings.json
vendored
Normal file
@ -0,0 +1,4 @@
|
||||
{
|
||||
"java.configuration.updateBuildConfiguration": "automatic",
|
||||
"java.compile.nullAnalysis.mode": "automatic"
|
||||
}
|
||||
148
code/cpicxim-huixiabao/pom.xml
Normal file
148
code/cpicxim-huixiabao/pom.xml
Normal file
@ -0,0 +1,148 @@
|
||||
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>com.cpic.xim</groupId>
|
||||
<artifactId>cpicxim-huixiabao</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<packaging>war</packaging>
|
||||
<name>cpicxim-huixiabao-backend</name>
|
||||
<url>http://www.cpic.com.cn</url>
|
||||
|
||||
<properties>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<maven.compiler.source>18</maven.compiler.source>
|
||||
<maven.compiler.target>18</maven.compiler.target>
|
||||
<spring.version>6.2.4</spring.version>
|
||||
<log4j.version>2.24.3</log4j.version>
|
||||
<jackson.version>2.18.3</jackson.version>
|
||||
</properties>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>junit</groupId>
|
||||
<artifactId>junit</artifactId>
|
||||
<version>4.13.1</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<!-- springmvc -->
|
||||
<dependency>
|
||||
<groupId>org.springframework</groupId>
|
||||
<artifactId>spring-context</artifactId>
|
||||
<version>${spring.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework</groupId>
|
||||
<artifactId>spring-test</artifactId>
|
||||
<version>${spring.version}</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework</groupId>
|
||||
<artifactId>spring-web</artifactId>
|
||||
<version>${spring.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework</groupId>
|
||||
<artifactId>spring-webmvc</artifactId>
|
||||
<version>${spring.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>javax.servlet</groupId>
|
||||
<artifactId>javax.servlet-api</artifactId>
|
||||
<version>4.0.1</version>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
|
||||
<!-- log4j -->
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-core</artifactId>
|
||||
<version>${log4j.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-slf4j2-impl</artifactId>
|
||||
<version>${log4j.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-api</artifactId>
|
||||
<version>${log4j.version}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.directory.studio</groupId>
|
||||
<artifactId>org.apache.commons.codec</artifactId>
|
||||
<version>1.8</version>
|
||||
</dependency>
|
||||
|
||||
<!-- jackson -->
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-databind</artifactId>
|
||||
<version>${jackson.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-core</artifactId>
|
||||
<version>${jackson.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-annotations</artifactId>
|
||||
<version>${jackson.version}</version>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
<finalName>cpicxim-huixiabao</finalName>
|
||||
<resources>
|
||||
<resource>
|
||||
<directory>src/main/resources</directory>
|
||||
<includes>
|
||||
<include>**/*.properties</include>
|
||||
<include>**/*.xml</include>
|
||||
</includes>
|
||||
<filtering>false</filtering>
|
||||
</resource>
|
||||
</resources>
|
||||
<pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to
|
||||
parent pom) -->
|
||||
<plugins>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-war-plugin</artifactId>
|
||||
<version>3.4.0</version>
|
||||
<configuration>
|
||||
<outputDirectory>${project.build.directory}/../../../输出/back/</outputDirectory>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-surefire-plugin</artifactId>
|
||||
<version>3.5.2</version>
|
||||
<configuration>
|
||||
<skipTests>true</skipTests>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-compiler-plugin</artifactId>
|
||||
<version>3.14.0</version>
|
||||
<configuration>
|
||||
<source>18</source>
|
||||
<target>18</target>
|
||||
<encoding>UTF-8</encoding>
|
||||
</configuration>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</pluginManagement>
|
||||
</build>
|
||||
</project>
|
||||
@ -0,0 +1,57 @@
|
||||
/**
|
||||
* @Author: Kane Wang <wangkane@qq.com>
|
||||
* @Date: 2025-03-15 18:40:54
|
||||
* @LastEditors: Kane Wang
|
||||
* @LastModified: 2025-03-16 08:59:16
|
||||
* @FilePath: src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) 2025 by Kane All rights reserved
|
||||
*/
|
||||
package com.cpic.xim.huixiabao.web.controllers.MediCover;
|
||||
|
||||
import org.springframework.stereotype.Controller;
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.ResponseBody;
|
||||
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import com.cpic.xim.utils.secrecy.*;;
|
||||
|
||||
@Controller
|
||||
@RequestMapping( "/huixiabao" )
|
||||
public class MediCoverController
|
||||
{
|
||||
private static Logger logger = LoggerFactory.getLogger( MediCoverController.class );
|
||||
private static String privateKey = "MIICeAIBADANBgkqhkiG9w0BAQEFAASCAmIwggJeAgEAAoGBAMBanAXTnHChd6W/vYq6eVmmr1R2p25tghivDEb8qrgxHMCY3lqYhJAw3jgQAH3HzSOFxZ3Mz/WcRaW3CzWfAZ0mm5dcVY0qEgyT/1BOsdhLwKa3BBuURRCEp5ZPapErm3Ugl/OBxjEURgtc9JnVBOECc9Kvk3FXvuN4tDWl18lxAgMBAAECgYBBAJ3HLkqomTg4sAIaloeZr0WC0pIkNCeJteX9OzdqBVbFEyPZE7+AhrMh2O6BkvqU7YjpmaQRSR0UMjY8iZ5eaJ8vkPJPFgoJI14dqj3Pby46GYqC8iPHTeFN35RL6Sgktt9i/loLoiRj6ifQ2AqnlE3e66Iaw1Zdnx1Lt9/T7QJBAP6PZatPD4UM9kQ0xO1QmJ+IsgLBhv3fhn2i8X4NSJGJ1yi9+JWnQ+CfBZ2u/V0op1Wz5kIDK7BA40o2Ntlf6acCQQDBcSNGlyE5sSSJS39pnbTqxNjKoakBQ5LFIrk4ld8Vuk0H7dcdfUittHoDnNMn9TKIIAvxo0s4fQe8WMPqH2cnAkEA4x49r6JSTntKHYCXUsTd5zim2h6gulF8RQvkOnrPjEpXVVppN9yMixRWhmFiXIOxCJ4BilQZ3p+GKuhD953DcQJBAKdGjpqcVb7t0AppnuRV2/yn/FA9O0g8hs6yGDk2YJMJZ1NT+JEnpZGQX3KASphjEC9mhu2Np55RgD7/A2uRfEECQQCdyFLVuPMSnCRAXvwb0EegaM0sS4/bT3/fix7RpKqv7tsUfXXsL1bbxxp9b/FBJe834s6wqq0U2wTlfVHXD1Oh";
|
||||
private static String publicyKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDAWpwF05xwoXelv72KunlZpq9UdqdubYIYrwxG/Kq4MRzAmN5amISQMN44EAB9x80jhcWdzM/1nEWltws1nwGdJpuXXFWNKhIMk/9QTrHYS8CmtwQblEUQhKeWT2qRK5t1IJfzgcYxFEYLXPSZ1QThAnPSr5NxV77jeLQ1pdfJcQIDAQAB";
|
||||
|
||||
/**
|
||||
* 接收医保局财政支持小药箱数据。
|
||||
*
|
||||
* @param request
|
||||
* @return
|
||||
*/
|
||||
@PostMapping( "/xyx" )
|
||||
@ResponseBody
|
||||
public static MediCoverResponse getHmbXyxInfo(
|
||||
@RequestBody MediCoverRequestBody request
|
||||
)
|
||||
{
|
||||
MediCoverResponse response = new MediCoverResponse();
|
||||
ObjectMapper jsonMapper = new ObjectMapper();
|
||||
|
||||
String decryptData = AESUtils.decryptData( request.getKey(), privateKey, request.getBizContent() );
|
||||
|
||||
logger.info( "【接收小药箱数据】请求参数<{}>", request.toString() );
|
||||
logger.info( "【接收小药箱数据】解密参数<{}>", decryptData );
|
||||
|
||||
// jsonMapper.readValue( decryptData, null );
|
||||
return response;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,103 @@
|
||||
/**
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-15 21:01:56
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverRequestBody.java
|
||||
* @Description:
|
||||
* @
|
||||
* @Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
|
||||
package com.cpic.xim.huixiabao.web.controllers.MediCover;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
|
||||
public class MediCoverRequestBody
|
||||
{
|
||||
|
||||
@JsonProperty( "transId" )
|
||||
private String transId;
|
||||
|
||||
@JsonProperty( "format" )
|
||||
private String format;
|
||||
|
||||
@JsonProperty( "bizContent" )
|
||||
private String bizContent;
|
||||
|
||||
@JsonProperty( "key" )
|
||||
private String key;
|
||||
|
||||
@JsonProperty( "timestamp" )
|
||||
private String timestamp;
|
||||
|
||||
public MediCoverRequestBody(
|
||||
String transId,
|
||||
String format,
|
||||
String bizContent,
|
||||
String key,
|
||||
String timestamp
|
||||
)
|
||||
{
|
||||
this.transId = transId;
|
||||
this.format = format;
|
||||
this.bizContent = bizContent;
|
||||
this.key = key;
|
||||
this.timestamp = timestamp;
|
||||
}
|
||||
|
||||
public String getTransId()
|
||||
{
|
||||
return transId;
|
||||
}
|
||||
|
||||
public void setTransId( String transId )
|
||||
{
|
||||
this.transId = transId;
|
||||
}
|
||||
|
||||
public String getFormat()
|
||||
{
|
||||
return format;
|
||||
}
|
||||
|
||||
public void setFormat( String format )
|
||||
{
|
||||
this.format = format;
|
||||
}
|
||||
|
||||
public String getBizContent()
|
||||
{
|
||||
return bizContent;
|
||||
}
|
||||
|
||||
public void setBizContent( String bizContent )
|
||||
{
|
||||
this.bizContent = bizContent;
|
||||
}
|
||||
|
||||
public String getKey()
|
||||
{
|
||||
return key;
|
||||
}
|
||||
|
||||
public void setKey( String key )
|
||||
{
|
||||
this.key = key;
|
||||
}
|
||||
|
||||
public String getTimestamp()
|
||||
{
|
||||
return timestamp;
|
||||
}
|
||||
|
||||
public void setTimestamp( String timestamp )
|
||||
{
|
||||
this.timestamp = timestamp;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString()
|
||||
{
|
||||
return "MediCoverRequestBody [transId=" + transId + ", format=" + format + ", bizContent=" + bizContent + ", key=" + key + ", timestamp=" + timestamp + "]";
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,55 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-15 17:21:50
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverResponse.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao.web.controllers.MediCover;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
|
||||
public class MediCoverResponse
|
||||
{
|
||||
MediCoverResponse()
|
||||
{
|
||||
code = "500";
|
||||
message = "未知失败原因";
|
||||
subMessage = "";
|
||||
result = new MediCoverResultInResponse( "", "" );
|
||||
success = false;
|
||||
}
|
||||
|
||||
public MediCoverResponse(
|
||||
String code,
|
||||
String message,
|
||||
String subMessage,
|
||||
String key,
|
||||
String content,
|
||||
Boolean success
|
||||
)
|
||||
{
|
||||
this.code = code;
|
||||
this.message = message;
|
||||
this.subMessage = subMessage;
|
||||
this.result = new MediCoverResultInResponse( key, content );
|
||||
this.success = success;
|
||||
}
|
||||
|
||||
@JsonProperty( "code" )
|
||||
private String code;
|
||||
|
||||
@JsonProperty( "message" )
|
||||
private String message;
|
||||
|
||||
@JsonProperty( "subMessage" )
|
||||
private String subMessage;
|
||||
|
||||
@JsonProperty( "result" )
|
||||
private MediCoverResultInResponse result;
|
||||
|
||||
@JsonProperty( "success" )
|
||||
private Boolean success;
|
||||
}
|
||||
@ -0,0 +1,59 @@
|
||||
/**
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-15 21:01:56
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverResultInResponse.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
/**
|
||||
* @Author: Kane Wang <wangkane@qq.com>
|
||||
* @Date: 2025-03-15 18:40:54
|
||||
* @LastEditors: Kane Wang
|
||||
* @LastModified: 2025-03-16 01:13:50
|
||||
* @FilePath: src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverResultInResponse.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) 2025 by Kane All rights reserved
|
||||
*/
|
||||
|
||||
package com.cpic.xim.huixiabao.web.controllers.MediCover;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
|
||||
public class MediCoverResultInResponse
|
||||
{
|
||||
|
||||
public MediCoverResultInResponse( String key, String content )
|
||||
{
|
||||
this.key = key;
|
||||
this.content = content;
|
||||
}
|
||||
|
||||
public String getKey()
|
||||
{
|
||||
return key;
|
||||
}
|
||||
|
||||
public void setKey( String key )
|
||||
{
|
||||
this.key = key;
|
||||
}
|
||||
|
||||
public String getContent()
|
||||
{
|
||||
return content;
|
||||
}
|
||||
|
||||
public void setContent( String content )
|
||||
{
|
||||
this.content = content;
|
||||
}
|
||||
|
||||
@JsonProperty( "key" )
|
||||
private String key;
|
||||
|
||||
@JsonProperty( "content" )
|
||||
private String content;
|
||||
}
|
||||
@ -0,0 +1,10 @@
|
||||
/**
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-16 00:12:27
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/data/nhs/HmbXyxInfo.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.huixiabao.web.data.nhs.xyx;
|
||||
@ -0,0 +1,83 @@
|
||||
/**
|
||||
* @Author: Kane
|
||||
* @Date: 2025-03-15 21:01:56
|
||||
* @LastEditors: Kane
|
||||
* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/data/nhs/xyx/HmbXyxInfoItem.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2023} by Kane, All Rights Reserved.
|
||||
*/
|
||||
|
||||
|
||||
package com.cpic.xim.huixiabao.web.data.nhs.xyx;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
|
||||
public class HmbXyxInfoItem
|
||||
{
|
||||
|
||||
public String getPsnName()
|
||||
{
|
||||
return psnName;
|
||||
}
|
||||
|
||||
public void setPsnName( String psnName )
|
||||
{
|
||||
this.psnName = psnName;
|
||||
}
|
||||
|
||||
public String getCertno()
|
||||
{
|
||||
return certno;
|
||||
}
|
||||
|
||||
public void setCertno( String certno )
|
||||
{
|
||||
this.certno = certno;
|
||||
}
|
||||
|
||||
public String getServiceId()
|
||||
{
|
||||
return serviceId;
|
||||
}
|
||||
|
||||
public void setServiceId( String serviceId )
|
||||
{
|
||||
this.serviceId = serviceId;
|
||||
}
|
||||
|
||||
public String getStatus()
|
||||
{
|
||||
return status;
|
||||
}
|
||||
|
||||
public void setStatus( String status )
|
||||
{
|
||||
this.status = status;
|
||||
}
|
||||
|
||||
public String getXyxNo()
|
||||
{
|
||||
return xyxNo;
|
||||
}
|
||||
|
||||
public void setXyxNo( String xyxNo )
|
||||
{
|
||||
this.xyxNo = xyxNo;
|
||||
}
|
||||
|
||||
@JsonProperty( "psnName" )
|
||||
private String psnName;
|
||||
|
||||
@JsonProperty( "certno" )
|
||||
private String certno;
|
||||
|
||||
@JsonProperty( "serviceId" )
|
||||
private String serviceId;
|
||||
|
||||
@JsonProperty( "status" )
|
||||
private String status;
|
||||
|
||||
@JsonProperty( "xyxNo" )
|
||||
private String xyxNo;
|
||||
}
|
||||
@ -0,0 +1,112 @@
|
||||
/**
|
||||
* @Author: Kane Wang <wangkane@qq.com>
|
||||
* @Date: 2025-03-15 12:50:53
|
||||
* @LastEditors: Kane Wang
|
||||
* @LastModified: 2025-03-16 08:44:52
|
||||
* @FilePath: src/main/java/com/cpic/xim/utils/secrecy/AESUtils.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) 2025 by Kane All rights reserved
|
||||
*/
|
||||
package com.cpic.xim.utils.secrecy;
|
||||
|
||||
import javax.crypto.Cipher;
|
||||
import javax.crypto.spec.IvParameterSpec;
|
||||
import javax.crypto.spec.SecretKeySpec;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import java.util.UUID;
|
||||
|
||||
/**
|
||||
* AESUtils
|
||||
*/
|
||||
public class AESUtils
|
||||
{
|
||||
|
||||
/**
|
||||
* 偏移量,必须是16位字符串
|
||||
*/
|
||||
private static final String IV_STRING = "16-Bytes--String";
|
||||
|
||||
/**
|
||||
* 产生随机密钥(这里产生密钥必须是16位)
|
||||
*/
|
||||
private static String generateKey()
|
||||
{
|
||||
String key = UUID.randomUUID().toString();
|
||||
key = key.replace( "-", "" ).substring( 0, 16 );// 替换掉-号
|
||||
|
||||
return key;
|
||||
}
|
||||
|
||||
/**
|
||||
* 加密
|
||||
*
|
||||
* @param publicKey 公钥
|
||||
* @param content 加密数据
|
||||
* @return
|
||||
*/
|
||||
public static Map<String, String> encryptData( String publicKey, String content )
|
||||
{
|
||||
byte[] encryptedBytes;
|
||||
try
|
||||
{
|
||||
byte[] byteContent = content.getBytes( "UTF-8" );
|
||||
// 注意，为了能与 iOS 统一
|
||||
// 这里的 key 不可以使用 KeyGenerator、SecureRandom、SecretKey 生成
|
||||
String key = generateKey();
|
||||
byte[] enCodeFormat = key.getBytes();
|
||||
SecretKeySpec secretKeySpec = new SecretKeySpec( enCodeFormat, "AES" );
|
||||
byte[] initParam = IV_STRING.getBytes();
|
||||
IvParameterSpec ivParameterSpec = new IvParameterSpec( initParam );
|
||||
// 指定加密的算法、工作模式和填充方式
|
||||
Cipher cipher = Cipher.getInstance( "AES/CBC/PKCS5Padding" );
|
||||
cipher.init( Cipher.ENCRYPT_MODE, secretKeySpec, ivParameterSpec );
|
||||
encryptedBytes = cipher.doFinal( byteContent );
|
||||
// 同样对加密后数据进行 base64 编码
|
||||
key = RSAUtils.encryptByPublicKey( key, publicKey );
|
||||
Map<String, String> result = new HashMap<>( 2 );
|
||||
result.put( "key", key );
|
||||
result.put( "content", Base64Utils.encode( encryptedBytes ) );
|
||||
return result;
|
||||
}
|
||||
catch ( Exception e )
|
||||
{
|
||||
throw new RuntimeException( "加密失败：" + e.getMessage(), e );
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 解密
|
||||
*
|
||||
* @param key
|
||||
* @param privateKey
|
||||
* @param content
|
||||
* @return
|
||||
*/
|
||||
public static String decryptData( String key, String privateKey, String content )
|
||||
{
|
||||
try
|
||||
{
|
||||
System.out.println( "KEY:" + key );
|
||||
System.out.println( "privateKey:" + privateKey );
|
||||
System.out.println( "content:" + content );
|
||||
// base64 解码
|
||||
byte[] encryptedBytes = Base64Utils.decode( content );
|
||||
key = RSAUtils.decryptByPrivateKey( privateKey, key );
|
||||
byte[] enCodeFormat = key.getBytes();
|
||||
SecretKeySpec secretKey = new SecretKeySpec( enCodeFormat, "AES" );
|
||||
byte[] initParam = IV_STRING.getBytes();
|
||||
IvParameterSpec ivParameterSpec = new IvParameterSpec( initParam );
|
||||
Cipher cipher = Cipher.getInstance( "AES/CBC/PKCS5Padding" );
|
||||
cipher.init( Cipher.DECRYPT_MODE, secretKey, ivParameterSpec );
|
||||
byte[] result = cipher.doFinal( encryptedBytes );
|
||||
return new String( result, "UTF-8" );
|
||||
}
|
||||
catch ( Exception e )
|
||||
{
|
||||
throw new RuntimeException( "解密失败：" + e.getMessage(), e );
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,165 @@
|
||||
/**
|
||||
* @Author: Kane Wang <wangkane@qq.com>
|
||||
* @Date: 2025-03-15 12:50:53
|
||||
* @LastEditors: Kane
|
||||
* @LastModified: 2025-03-16 08:40:07
|
||||
* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/utils/secrecy/Base64Utils.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) 2025 by Kane All rights reserved
|
||||
*/
|
||||
package com.cpic.xim.utils.secrecy;
|
||||
|
||||
import org.apache.commons.codec.binary.Base64;
|
||||
import java.io.*;
|
||||
|
||||
/**
|
||||
* Base64Utils
|
||||
*/
|
||||
public class Base64Utils
|
||||
{
|
||||
|
||||
/** */
|
||||
/**
|
||||
* 文件读取缓冲区大小
|
||||
*/
|
||||
private static final int CACHE_SIZE = 1024;
|
||||
|
||||
/** */
|
||||
/**
|
||||
* <p>
|
||||
* BASE64字符串解码为二进制数据
|
||||
* </p>
|
||||
*
|
||||
* @param base64
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public static byte[] decode( String base64 )
|
||||
throws Exception
|
||||
{
|
||||
return Base64.decodeBase64( base64.getBytes() );
|
||||
}
|
||||
|
||||
public static String decode( byte[] b )
|
||||
throws Exception
|
||||
{
|
||||
return new String( Base64.decodeBase64( b ) );
|
||||
}
|
||||
|
||||
/** */
|
||||
/**
|
||||
* <p>
|
||||
* 二进制数据编码为BASE64字符串
|
||||
* </p>
|
||||
*
|
||||
* @param bytes
|
||||
* @return
|
||||
*/
|
||||
public static String encode( byte[] bytes )
|
||||
{
|
||||
return new String( Base64.encodeBase64( bytes ) );
|
||||
}
|
||||
|
||||
/** */
|
||||
/**
|
||||
* <p>
|
||||
* 将文件编码为BASE64字符串
|
||||
* </p>
|
||||
* <p>
|
||||
* 大文件慎用，可能会导致内存溢出
|
||||
* </p>
|
||||
*
|
||||
* @param filePath 文件绝对路径
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public static String encodeFile( String filePath )
|
||||
throws Exception
|
||||
{
|
||||
byte[] bytes = fileToByte( filePath );
|
||||
return encode( bytes );
|
||||
}
|
||||
|
||||
/** */
|
||||
/**
|
||||
* <p>
|
||||
* BASE64字符串转回文件
|
||||
* </p>
|
||||
*
|
||||
* @param filePath 文件绝对路径
|
||||
* @param base64 编码字符串
|
||||
* @throws Exception
|
||||
*/
|
||||
public static void decodeToFile( String filePath, String base64 )
|
||||
throws Exception
|
||||
{
|
||||
byte[] bytes = decode( base64 );
|
||||
byteArrayToFile( bytes, filePath );
|
||||
}
|
||||
|
||||
/** */
|
||||
/**
|
||||
* <p>
|
||||
* 文件转换为二进制数组
|
||||
* </p>
|
||||
*
|
||||
* @param filePath 文件路径
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public static byte[] fileToByte( String filePath )
|
||||
throws Exception
|
||||
{
|
||||
byte[] data = new byte[0];
|
||||
File file = new File( filePath );
|
||||
if ( file.exists() )
|
||||
{
|
||||
FileInputStream in = new FileInputStream( file );
|
||||
ByteArrayOutputStream out = new ByteArrayOutputStream( 2048 );
|
||||
byte[] cache = new byte[CACHE_SIZE];
|
||||
int nRead = 0;
|
||||
while ( (nRead = in.read( cache )) != -1 )
|
||||
{
|
||||
out.write( cache, 0, nRead );
|
||||
out.flush();
|
||||
}
|
||||
out.close();
|
||||
in.close();
|
||||
data = out.toByteArray();
|
||||
}
|
||||
return data;
|
||||
}
|
||||
|
||||
/** */
|
||||
/**
|
||||
* <p>
|
||||
* 二进制数据写文件
|
||||
* </p>
|
||||
*
|
||||
* @param bytes 二进制数据
|
||||
* @param filePath 文件生成目录
|
||||
*/
|
||||
public static void byteArrayToFile( byte[] bytes, String filePath )
|
||||
throws Exception
|
||||
{
|
||||
InputStream in = new ByteArrayInputStream( bytes );
|
||||
File destFile = new File( filePath );
|
||||
if ( !destFile.getParentFile().exists() )
|
||||
{
|
||||
destFile.getParentFile().mkdirs();
|
||||
}
|
||||
destFile.createNewFile();
|
||||
OutputStream out = new FileOutputStream( destFile );
|
||||
byte[] cache = new byte[CACHE_SIZE];
|
||||
int nRead = 0;
|
||||
while ( (nRead = in.read( cache )) != -1 )
|
||||
{
|
||||
out.write( cache, 0, nRead );
|
||||
out.flush();
|
||||
}
|
||||
out.close();
|
||||
in.close();
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,202 @@
|
||||
/**
|
||||
* @Author: Kane Wang <wangkane@qq.com>
|
||||
* @Date: 2025-03-15 12:50:53
|
||||
* @LastEditors: Kane Wang
|
||||
* @LastModified: 2025-03-16 08:43:56
|
||||
* @FilePath: src/main/java/com/cpic/xim/utils/secrecy/RSAUtils.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) 2025 by Kane All rights reserved
|
||||
*/
|
||||
package com.cpic.xim.utils.secrecy;
|
||||
|
||||
import javax.crypto.Cipher;
|
||||
import java.io.ByteArrayOutputStream;
|
||||
import java.math.BigInteger;
|
||||
import java.security.*;
|
||||
import java.security.interfaces.RSAPrivateKey;
|
||||
import java.security.interfaces.RSAPublicKey;
|
||||
import java.security.spec.PKCS8EncodedKeySpec;
|
||||
import java.security.spec.RSAPrivateKeySpec;
|
||||
import java.security.spec.X509EncodedKeySpec;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* RSAUtils
|
||||
*/
|
||||
public class RSAUtils
|
||||
{
|
||||
|
||||
/**
|
||||
* RSA最大加密明文大小
|
||||
*/
|
||||
private static final int MAX_ENCRYPT_BLOCK = 117;
|
||||
|
||||
/**
|
||||
* RSA最大解密密文大小
|
||||
*/
|
||||
private static final int MAX_DECRYPT_BLOCK = 128;
|
||||
|
||||
/**
|
||||
* 加密算法RSA
|
||||
*/
|
||||
private static final String KEY_ALGORITHM = "RSA";
|
||||
|
||||
/**
|
||||
* 生成公钥和私钥
|
||||
*
|
||||
* @throws Exception
|
||||
*/
|
||||
public static Map<String, String> getKeys()
|
||||
throws Exception
|
||||
{
|
||||
KeyPairGenerator keyPairGen = KeyPairGenerator.getInstance( "RSA" );
|
||||
keyPairGen.initialize( 1024 );
|
||||
KeyPair keyPair = keyPairGen.generateKeyPair();
|
||||
RSAPublicKey publicKey = ( RSAPublicKey ) keyPair.getPublic();
|
||||
RSAPrivateKey privateKey = ( RSAPrivateKey ) keyPair.getPrivate();
|
||||
|
||||
String publicKeyStr = getPublicKeyStr( publicKey );
|
||||
String privateKeyStr = getPrivateKeyStr( privateKey );
|
||||
|
||||
Map<String, String> result = new HashMap<>( 2 );
|
||||
result.put( "publicKeyStr", publicKeyStr );
|
||||
result.put( "privateKeyStr", privateKeyStr );
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
public static void main( String[] args )
|
||||
throws Exception
|
||||
{
|
||||
Map<String, String> keys = getKeys();
|
||||
System.out.println( "publicKeyStr=" + keys.get( "publicKeyStr" ) );
|
||||
System.out.println( "privateKeyStr=" + keys.get( "privateKeyStr" ) );
|
||||
}
|
||||
|
||||
/**
|
||||
* 使用模和指数生成RSA私钥
|
||||
* 注意：【此代码用了默认补位方式，为RSA/None/PKCS1Padding，不同JDK默认的补位方式可能不同，如Android默认是RSA
|
||||
* /None/NoPadding】
|
||||
*
|
||||
* @param modulus 模
|
||||
* @param exponent 指数
|
||||
* @return
|
||||
*/
|
||||
public static RSAPrivateKey getPrivateKey( String modulus, String exponent )
|
||||
{
|
||||
try
|
||||
{
|
||||
BigInteger b1 = new BigInteger( modulus );
|
||||
BigInteger b2 = new BigInteger( exponent );
|
||||
KeyFactory keyFactory = KeyFactory.getInstance( "RSA" );
|
||||
RSAPrivateKeySpec keySpec = new RSAPrivateKeySpec( b1, b2 );
|
||||
return ( RSAPrivateKey ) keyFactory.generatePrivate( keySpec );
|
||||
}
|
||||
catch ( Exception e )
|
||||
{
|
||||
e.printStackTrace();
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 公钥加密
|
||||
*
|
||||
* @param data 加密数据
|
||||
* @param publicKey 加密key
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public static String encryptByPublicKey( String data, String publicKey )
|
||||
throws Exception
|
||||
{
|
||||
byte[] dataByte = data.getBytes();
|
||||
byte[] keyBytes = Base64Utils.decode( publicKey );
|
||||
X509EncodedKeySpec x509KeySpec = new X509EncodedKeySpec( keyBytes );
|
||||
KeyFactory keyFactory = KeyFactory.getInstance( KEY_ALGORITHM );
|
||||
Key publicK = keyFactory.generatePublic( x509KeySpec );
|
||||
// 对数据加密
|
||||
Cipher cipher = Cipher.getInstance( "RSA/ECB/PKCS1Padding" );
|
||||
cipher.init( Cipher.ENCRYPT_MODE, publicK );
|
||||
int inputLen = dataByte.length;
|
||||
ByteArrayOutputStream out = new ByteArrayOutputStream();
|
||||
int offSet = 0;
|
||||
byte[] cache;
|
||||
int i = 0;
|
||||
// 对数据分段加密
|
||||
while ( inputLen - offSet > 0 )
|
||||
{
|
||||
if ( inputLen - offSet > MAX_ENCRYPT_BLOCK )
|
||||
{
|
||||
cache = cipher.doFinal( dataByte, offSet, MAX_ENCRYPT_BLOCK );
|
||||
}
|
||||
else
|
||||
{
|
||||
cache = cipher.doFinal( dataByte, offSet, inputLen - offSet );
|
||||
}
|
||||
out.write( cache, 0, cache.length );
|
||||
i++;
|
||||
offSet = i * MAX_ENCRYPT_BLOCK;
|
||||
}
|
||||
byte[] encryptedData = out.toByteArray();
|
||||
out.close();
|
||||
return Base64Utils.encode( encryptedData );
|
||||
}
|
||||
|
||||
/**
|
||||
* 私钥解密
|
||||
*
|
||||
* @param privateKey 私钥
|
||||
* @param data 加密数据
|
||||
* @return
|
||||
* @throws Exception
|
||||
*/
|
||||
public static String decryptByPrivateKey( String privateKey, String data )
|
||||
throws Exception
|
||||
{
|
||||
byte[] encryptedData = Base64Utils.decode( data );
|
||||
byte[] keyBytes = Base64Utils.decode( privateKey );
|
||||
PKCS8EncodedKeySpec pkcs8KeySpec = new PKCS8EncodedKeySpec( keyBytes );
|
||||
KeyFactory keyFactory = KeyFactory.getInstance( KEY_ALGORITHM );
|
||||
Key privateK = keyFactory.generatePrivate( pkcs8KeySpec );
|
||||
// Cipher cipher = Cipher.getInstance(keyFactory.getAlgorithm());
|
||||
Cipher cipher = Cipher.getInstance( "RSA/ECB/PKCS1Padding" );
|
||||
|
||||
cipher.init( Cipher.DECRYPT_MODE, privateK );
|
||||
int inputLen = encryptedData.length;
|
||||
ByteArrayOutputStream out = new ByteArrayOutputStream();
|
||||
int offSet = 0;
|
||||
byte[] cache;
|
||||
int i = 0;
|
||||
// 对数据分段解密
|
||||
while ( inputLen - offSet > 0 )
|
||||
{
|
||||
if ( inputLen - offSet > MAX_DECRYPT_BLOCK )
|
||||
{
|
||||
cache = cipher.doFinal( encryptedData, offSet, MAX_DECRYPT_BLOCK );
|
||||
}
|
||||
else
|
||||
{
|
||||
cache = cipher.doFinal( encryptedData, offSet, inputLen - offSet );
|
||||
}
|
||||
out.write( cache, 0, cache.length );
|
||||
i++;
|
||||
offSet = i * MAX_DECRYPT_BLOCK;
|
||||
}
|
||||
byte[] decryptedData = out.toByteArray();
|
||||
out.close();
|
||||
return new String( decryptedData );
|
||||
}
|
||||
|
||||
public static String getPrivateKeyStr( PrivateKey privateKey )
|
||||
{
|
||||
return Base64Utils.encode( privateKey.getEncoded() );
|
||||
}
|
||||
|
||||
public static String getPublicKeyStr( PublicKey publicKey )
|
||||
{
|
||||
return Base64Utils.encode( publicKey.getEncoded() );
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,66 @@
|
||||
/**
|
||||
* @Author: Kane Wang <wangkane@qq.com>
|
||||
* @Date: 2025-03-15 18:40:54
|
||||
* @LastEditors: Kane Wang
|
||||
* @LastModified: 2025-03-16 08:56:20
|
||||
* @FilePath: src/main/java/com/cpic/xim/web/filters/cros/CrosFilter.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) 2025 by Kane All rights reserved
|
||||
*/
|
||||
package com.cpic.xim.web.filters.cros;
|
||||
|
||||
import java.io.IOException;
|
||||
import javax.servlet.Filter;
|
||||
import javax.servlet.FilterChain;
|
||||
import javax.servlet.ServletException;
|
||||
import javax.servlet.ServletRequest;
|
||||
import javax.servlet.ServletResponse;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.http.HttpMethod;
|
||||
|
||||
public class CrosFilter implements Filter
|
||||
{
|
||||
private static Logger logger = LoggerFactory.getLogger( CrosFilter.class );
|
||||
|
||||
/**
|
||||
* @param req
|
||||
*/
|
||||
@Override
|
||||
public void doFilter(
|
||||
ServletRequest req,
|
||||
ServletResponse resp,
|
||||
FilterChain chain
|
||||
)
|
||||
throws ServletException,
|
||||
IOException
|
||||
{
|
||||
HttpServletRequest request = ( HttpServletRequest ) req;
|
||||
HttpServletResponse response = ( HttpServletResponse ) resp;
|
||||
String method = request.getMethod();
|
||||
String originHeader = request.getHeader( "Origin" );
|
||||
|
||||
logger.info( "收到" + method + "请求，来自" + originHeader );
|
||||
|
||||
// 如果是Options请求
|
||||
if ( method.equals( HttpMethod.OPTIONS.toString() ) )
|
||||
{
|
||||
originHeader = "*";
|
||||
}
|
||||
|
||||
response.setHeader( "Access-Control-Allow-Origin", originHeader );
|
||||
response.setHeader( "Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE, PUT" );
|
||||
response.setHeader( "Access-Control-Max-Age", "0" );
|
||||
response.setHeader( "Access-Control-Allow-Headers",
|
||||
"Origin, No-Cache, X-Requested-With, If-Modified-Since, Pragma, Last-Modified, Cache-Control, Expires, Content-Type, X-E4M-With,userId,token" );
|
||||
response.setHeader( "Access-Control-Allow-Credentials", "true" );
|
||||
response.setHeader( "XDomainRequestAllowed", "1" );
|
||||
response.setHeader( "XDomainRequestAllowed", "1" );
|
||||
|
||||
chain.doFilter( request, response );
|
||||
}
|
||||
|
||||
}
|
||||
40
code/cpicxim-huixiabao/src/main/resources/log4j2.xml
Normal file
40
code/cpicxim-huixiabao/src/main/resources/log4j2.xml
Normal file
@ -0,0 +1,40 @@
|
||||
<Configuration status="WARN" monitorInterval="300">
|
||||
<Appenders>
|
||||
<Console name="Console" target="SYSTEM_OUT">
|
||||
<PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} ### %msg%n" />
|
||||
<ThresholdFilter level="trace" onMatch="ACCEPT" onMismatch="DENY" />
|
||||
</Console>
|
||||
<RollingFile name="rolling_file_win"
|
||||
filePattern="./logs/huixiabao/$${date:yyyy-MM}/huixiabao-%d{MM-dd-yyyy}-%i.log.gz">
|
||||
<PatternLayout>
|
||||
<Pattern>[%t][%level][%d{HH:mm:ss.SSS}][%logger.%M{36}#%L] %msg%n</Pattern>
|
||||
</PatternLayout>
|
||||
<Policies>
|
||||
<TimeBasedTriggeringPolicy interval="1" />
|
||||
<SizeBasedTriggeringPolicy size="20MB" />
|
||||
<DefaultRolloverStrategy max="20" />
|
||||
</Policies>
|
||||
</RollingFile>
|
||||
<RollingFile name="rolling_file_linux"
|
||||
filePattern="/logs/huixiabao/$${date:yyyy-MM}/app-%d{MM-dd-yyyy}-%i.log.gz">
|
||||
<PatternLayout>
|
||||
<Pattern>[%t][%level][%d{HH:mm:ss.SSS}][%logger.%M{36}#%L] %msg%n</Pattern>
|
||||
</PatternLayout>
|
||||
<Policies>
|
||||
<TimeBasedTriggeringPolicy interval="1" />
|
||||
<SizeBasedTriggeringPolicy size="20MB" />
|
||||
<DefaultRolloverStrategy max="20" />
|
||||
</Policies>
|
||||
</RollingFile>
|
||||
</Appenders>
|
||||
<Loggers>
|
||||
<!-- <Logger name="mylog" level="info">
|
||||
<AppenderRef ref="rolling_file" />
|
||||
</Logger> -->
|
||||
<Root level="debug">
|
||||
<AppenderRef ref="rolling_file_linux" />
|
||||
<AppenderRef ref="rolling_file_win" />
|
||||
<AppenderRef ref="Console" />
|
||||
</Root>
|
||||
</Loggers>
|
||||
</Configuration>
|
||||
@ -0,0 +1,37 @@
|
||||
<beans xmlns="http://www.springframework.org/schema/beans"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xmlns:context="http://www.springframework.org/schema/context"
|
||||
xmlns:jdbc="http://www.springframework.org/schema/jdbc"
|
||||
xmlns:jee="http://www.springframework.org/schema/jee"
|
||||
xmlns:tx="http://www.springframework.org/schema/tx"
|
||||
xmlns:aop="http://www.springframework.org/schema/aop"
|
||||
xmlns:mvc="http://www.springframework.org/schema/mvc"
|
||||
xmlns:util="http://www.springframework.org/schema/util"
|
||||
xmlns:jpa="http://www.springframework.org/schema/data/jpa"
|
||||
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
|
||||
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
|
||||
http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd
|
||||
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd
|
||||
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
|
||||
http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa-1.3.xsd
|
||||
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
|
||||
http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
|
||||
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsd">
|
||||
|
||||
<context:component-scan base-package="com.cpic.xim" />
|
||||
<mvc:annotation-driven />
|
||||
<mvc:default-servlet-handler />
|
||||
|
||||
<!-- <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
|
||||
<property
|
||||
name="prefix" value="/WEB-INF/jsp/" />
|
||||
<property name="suffix" value=".jsp" />
|
||||
</bean> -->
|
||||
|
||||
<bean id="multipartResolver"
|
||||
class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
|
||||
<property name="defaultEncoding" value="UTF-8" />
|
||||
<property name="maxUploadSize" value="-1" />
|
||||
</bean>
|
||||
|
||||
</beans>
|
||||
34
code/cpicxim-huixiabao/src/main/webapp/WEB-INF/web.xml
Normal file
34
code/cpicxim-huixiabao/src/main/webapp/WEB-INF/web.xml
Normal file
@ -0,0 +1,34 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<web-app
|
||||
version="4.0"
|
||||
xmlns="http://xmlns.jcp.org/xml/ns/javaee"
|
||||
xmlns:javaee="http://xmlns.jcp.org/xml/ns/javaee"
|
||||
xmlns:xml="http://www.w3.org/XML/1998/namespace"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd">
|
||||
<display-name>Archetype Created Web Application</display-name>
|
||||
|
||||
<servlet>
|
||||
<servlet-name>springmvc</servlet-name>
|
||||
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
|
||||
<init-param>
|
||||
<param-name>contextConfigLocation</param-name>
|
||||
<param-value>classpath:spring.xml</param-value>
|
||||
</init-param>
|
||||
<load-on-startup>1</load-on-startup>
|
||||
</servlet>
|
||||
<servlet-mapping>
|
||||
<servlet-name>springmvc</servlet-name>
|
||||
<url-pattern>/huixibao</url-pattern>
|
||||
</servlet-mapping>
|
||||
|
||||
<filter>
|
||||
<filter-name>CrosFilter</filter-name>
|
||||
<filter-class>com.cpic.xim.web.filters.cros.CrosFilter</filter-class>
|
||||
</filter>
|
||||
<filter-mapping>
|
||||
<filter-name>CrosFilter</filter-name>
|
||||
<url-pattern>*</url-pattern>
|
||||
</filter-mapping>
|
||||
|
||||
</web-app>
|
||||
5
code/cpicxim-huixiabao/src/main/webapp/index.jsp
Normal file
5
code/cpicxim-huixiabao/src/main/webapp/index.jsp
Normal file
@ -0,0 +1,5 @@
|
||||
<html>
|
||||
<body>
|
||||
<h2><%= "Hello World!" %></h2>
|
||||
</body>
|
||||
</html>
|
||||
117
code/nginx配置/nginx.conf
Normal file
117
code/nginx配置/nginx.conf
Normal file
@ -0,0 +1,117 @@
|
||||
|
||||
#user nobody;
|
||||
worker_processes 1;
|
||||
|
||||
#error_log logs/error.log;
|
||||
#error_log logs/error.log notice;
|
||||
#error_log logs/error.log info;
|
||||
|
||||
#pid logs/nginx.pid;
|
||||
|
||||
|
||||
events {
|
||||
worker_connections 1024;
|
||||
}
|
||||
|
||||
|
||||
http {
|
||||
include mime.types;
|
||||
default_type application/octet-stream;
|
||||
|
||||
#log_format main '$remote_addr - $remote_user [$time_local] "$request" '
|
||||
# '$status $body_bytes_sent "$http_referer" '
|
||||
# '"$http_user_agent" "$http_x_forwarded_for"';
|
||||
|
||||
#access_log logs/access.log main;
|
||||
|
||||
sendfile on;
|
||||
#tcp_nopush on;
|
||||
|
||||
#keepalive_timeout 0;
|
||||
keepalive_timeout 65;
|
||||
|
||||
#gzip on;
|
||||
|
||||
server {
|
||||
listen 80;
|
||||
server_name localhost;
|
||||
|
||||
#charset koi8-r;
|
||||
|
||||
#access_log logs/host.access.log main;
|
||||
|
||||
location / {
|
||||
root html;
|
||||
index index.html index.htm;
|
||||
}
|
||||
|
||||
#error_page 404 /404.html;
|
||||
|
||||
# redirect server error pages to the static page /50x.html
|
||||
#
|
||||
error_page 500 502 503 504 /50x.html;
|
||||
location = /50x.html {
|
||||
root html;
|
||||
}
|
||||
|
||||
# proxy the PHP scripts to Apache listening on 127.0.0.1:80
|
||||
#
|
||||
#location ~ \.php$ {
|
||||
# proxy_pass http://127.0.0.1;
|
||||
#}
|
||||
|
||||
# pass the PHP scripts to FastCGI server listening on 127.0.0.1:9000
|
||||
#
|
||||
#location ~ \.php$ {
|
||||
# root html;
|
||||
# fastcgi_pass 127.0.0.1:9000;
|
||||
# fastcgi_index index.php;
|
||||
# fastcgi_param SCRIPT_FILENAME /scripts$fastcgi_script_name;
|
||||
# include fastcgi_params;
|
||||
#}
|
||||
|
||||
# deny access to .htaccess files, if Apache's document root
|
||||
# concurs with nginx's one
|
||||
#
|
||||
#location ~ /\.ht {
|
||||
# deny all;
|
||||
#}
|
||||
}
|
||||
|
||||
|
||||
# another virtual host using mix of IP-, name-, and port-based configuration
|
||||
#
|
||||
#server {
|
||||
# listen 8000;
|
||||
# listen somename:8080;
|
||||
# server_name somename alias another.alias;
|
||||
|
||||
# location / {
|
||||
# root html;
|
||||
# index index.html index.htm;
|
||||
# }
|
||||
#}
|
||||
|
||||
|
||||
# HTTPS server
|
||||
#
|
||||
#server {
|
||||
# listen 443 ssl;
|
||||
# server_name localhost;
|
||||
|
||||
# ssl_certificate cert.pem;
|
||||
# ssl_certificate_key cert.key;
|
||||
|
||||
# ssl_session_cache shared:SSL:1m;
|
||||
# ssl_session_timeout 5m;
|
||||
|
||||
# ssl_ciphers HIGH:!aNULL:!MD5;
|
||||
# ssl_prefer_server_ciphers on;
|
||||
|
||||
# location / {
|
||||
# root html;
|
||||
# index index.html index.htm;
|
||||
# }
|
||||
#}
|
||||
|
||||
}
|
||||
34
code/sql/HmbXyxInfo.sql
Normal file
34
code/sql/HmbXyxInfo.sql
Normal file
@ -0,0 +1,34 @@
|
||||
/*
|
||||
Navicat Premium Data Transfer
|
||||
|
||||
Source Server : mysql - 10.39.0.85
|
||||
Source Server Type : MySQL
|
||||
Source Server Version : 90200
|
||||
Source Host : 10.39.0.85:3306
|
||||
Source Schema : huixiabao
|
||||
|
||||
Target Server Type : MySQL
|
||||
Target Server Version : 90200
|
||||
File Encoding : 65001
|
||||
|
||||
Date: 12/03/2025 09:14:18
|
||||
*/
|
||||
|
||||
SET NAMES utf8mb4;
|
||||
SET FOREIGN_KEY_CHECKS = 0;
|
||||
|
||||
-- ----------------------------
|
||||
-- Table structure for HmbXyxInfo
|
||||
-- ----------------------------
|
||||
DROP TABLE IF EXISTS `HmbXyxInfo`;
|
||||
CREATE TABLE `HmbXyxInfo` (
|
||||
`hmbListIndex` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT 'hmbList的索引，由timestamp和hmbList的hash值组成。',
|
||||
`psnName` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '姓名',
|
||||
`certno` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '证件号',
|
||||
`serviceId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '服务id',
|
||||
`status` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '订单状态',
|
||||
`xyxNo` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '主键id',
|
||||
PRIMARY KEY (`xyxNo`) USING BTREE
|
||||
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = 'HmbXyxInfo的子表。\r\n保存hmbList集合的元素。' ROW_FORMAT = Dynamic;
|
||||
|
||||
SET FOREIGN_KEY_CHECKS = 1;
|
||||
24
code/sql/触发器.txt
Normal file
24
code/sql/触发器.txt
Normal file
@ -0,0 +1,24 @@
|
||||
drop TRIGGER xyxinfo_insert;
|
||||
CREATE TRIGGER xyxinfo_insert after INSERT ON huixiabao.HmbXyxInfo FOR EACH ROW
|
||||
BEGIN
|
||||
delete from huixiabao.HmbXyxInfo_Update u where u.xyxNo = NEW.xyxNo;
|
||||
INSERT INTO huixiabao.HmbXyxInfo_Update ( xyxNo, update_time )
|
||||
VALUES
|
||||
(
|
||||
new.xyxNo,
|
||||
SYSDATE());
|
||||
|
||||
END;
|
||||
|
||||
|
||||
drop trigger xyxinfo_update;
|
||||
create trigger xyxinfo_update after update on huixiabao.HmbXyxInfo FOR EACH ROW
|
||||
BEGIN
|
||||
delete from huixiabao.HmbXyxInfo_Update u where u.xyxNo = NEW.xyxNo;
|
||||
INSERT INTO huixiabao.HmbXyxInfo_Update ( xyxNo, update_time )
|
||||
VALUES
|
||||
(
|
||||
new.xyxNo,
|
||||
SYSDATE());
|
||||
|
||||
END;
|
||||
16
code/sql/调试.sql
Normal file
16
code/sql/调试.sql
Normal file
@ -0,0 +1,16 @@
|
||||
/*
|
||||
delete from HmbXyxInfo;
|
||||
insert into HmbXyxInfo( psnName, certno, serviceid, status, xyxno)
|
||||
values( '王炜', '350402198106130016', '100007', '1', '100001');
|
||||
insert into HmbXyxInfo( psnName, certno, serviceid, status, xyxno)
|
||||
values( '王炜', '350402198106130016', '100007', '1', '100002');
|
||||
insert into HmbXyxInfo( psnName, certno, serviceid, status, xyxno)
|
||||
values( '王炜', '350402198106130016', '100007', '1', '100003');
|
||||
commit;
|
||||
/*
|
||||
|
||||
select * from HmbXyxInfo_Update;
|
||||
select a.*
|
||||
from HmbXyxInfo a,
|
||||
HmbXyxInfo_Update b
|
||||
where a.xyxNo = b.xyxNo;
|
||||
9
文档/request.json
Normal file
9
文档/request.json
Normal file
@ -0,0 +1,9 @@
|
||||
{
|
||||
"chs_fjs_appid": "",
|
||||
"chs_fjs_appsecret": "",
|
||||
"chs_fjs_token": "",
|
||||
"chs_fjs_funid": "",
|
||||
"chs_fjs_timestamp": "",
|
||||
"chs_fjs_encdata": "",
|
||||
"chs_fjs_sign": ""
|
||||
}
|
||||
33
文档/sm2_expl.json
Normal file
33
文档/sm2_expl.json
Normal file
@ -0,0 +1,33 @@
|
||||
{
|
||||
"appId": "43AF047BBA47FC8A1AE8EFB232BDBBCB",
|
||||
"data": {
|
||||
"appId": "43AF047BBA47FC8A1AE8EFB232BDBBCB",
|
||||
"appUserId": "o8z4C5avQXqC0aWFPf1Mzu6D7WCQ_bd",
|
||||
"idNo": "350181199011193519",
|
||||
"idType": "01",
|
||||
"phoneNumber": "13763873033",
|
||||
"userName": "测试"
|
||||
},
|
||||
"encType": "SM4",
|
||||
"signData": "URVQNdVNn5mz2EhKZhLTlXNwAWTSncFoSe8Ilx7jhn81eABJ46sdRRN1ZiAiQjPUTixG9bwqEhiJupHRGmyO5w==",
|
||||
"signType": "SM2",
|
||||
"timestamp": "20200207175759",
|
||||
"transType": "ec.gen.index",
|
||||
"version": "1.0.0"
|
||||
}
|
||||
|
||||
appId=43AF047BBA47FC8A1AE8EFB232BDBBCB&data=
|
||||
{
|
||||
"appId":"43AF047BBA47FC8A1AE8EFB232BDBBCB",
|
||||
"appUserId":"o8z4C5avQXqC0aWFPf1Mzu6D7WCQ_bd",
|
||||
"idNo":"350181199011193519",
|
||||
"idType":"01",
|
||||
"phoneNumber":"13763873033",
|
||||
"userName":"测试"
|
||||
}
|
||||
&encType=SM4
|
||||
&signType=SM2
|
||||
×tamp=20200207175759
|
||||
&transType=ec.gen.index
|
||||
&version=1.0.0
|
||||
&key=4117E877F5FA0A0188891283E4B617D5
|
||||
BIN
文档/地址.xlsx
Normal file
BIN
文档/地址.xlsx
Normal file
Binary file not shown.
23
文档/接口/医保局接口sdk与示例/java-sdk使用例子.txt
Normal file
23
文档/接口/医保局接口sdk与示例/java-sdk使用例子.txt
Normal file
@ -0,0 +1,23 @@
|
||||
public static void main(String[] args) {
|
||||
String url = "";
|
||||
String appId = "待定";
|
||||
String appSecret = "待定";
|
||||
String funId = "xxx";
|
||||
SignTypeEnum signType = SignTypeEnum.SM3;
|
||||
String signKey = "待定";
|
||||
EncryptionModeEnum encType = EncryptionModeEnum.SM4;
|
||||
String encKey = "A5B6E00DA599G56C41ABFE23A74E6E60";
|
||||
try {
|
||||
DefaultZephyrClient client = new DefaultZephyrClient(url, funId, appId, appSecret,
|
||||
signType, signKey, encType, encKey);
|
||||
DefaultZephyrRequest req = new DefaultZephyrRequest();
|
||||
JSONObject jsonObject1 = new JSONObject();
|
||||
jsonObject1.put("code", "XXXXXXXXXXXXXXXXXX");
|
||||
jsonObject1.put("scene_code", "XXX");
|
||||
req.setData(jsonObject1);
|
||||
DefaultZephyrResponse resp = client.execute(req);
|
||||
System.out.println(resp.getData());
|
||||
} catch (ZephyrApiException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
6
文档/接口/医保局接口sdk与示例/测试环境配置说明.txt
Normal file
6
文档/接口/医保局接口sdk与示例/测试环境配置说明.txt
Normal file
@ -0,0 +1,6 @@
|
||||
|
||||
appid:hxb-tb
|
||||
appSecret:60F468FB46170DD4CF6CBECE215DBFC0
|
||||
signKey:1A2F447BD0F930798D8031B137EC6E25
|
||||
encKey:08307695B1668EB9FD6210250FED874F
|
||||
|
||||
BIN
文档/接口/惠夏保理赔规范v1.4.pdf
Normal file
BIN
文档/接口/惠夏保理赔规范v1.4.pdf
Normal file
Binary file not shown.
BIN
文档/接口/惠夏保理赔规范v1.5.pdf
Normal file
BIN
文档/接口/惠夏保理赔规范v1.5.pdf
Normal file
Binary file not shown.
BIN
文档/接口/福建医疗保障平台商业补充医疗保险接入规范(全)v1.7-20240925.pdf
Normal file
BIN
文档/接口/福建医疗保障平台商业补充医疗保险接入规范(全)v1.7-20240925.pdf
Normal file
Binary file not shown.
Loading…
x
Reference in New Issue
Block a user