diff --git a/code/cpicxim-huixiabao/pom.xml b/code/cpicxim-huixiabao/pom.xml
index 96d1b00..36758dd 100644
--- a/code/cpicxim-huixiabao/pom.xml
+++ b/code/cpicxim-huixiabao/pom.xml
@@ -129,6 +129,12 @@
${jackson.version}
+
+ com.mysql
+ mysql-connector-j
+ 9.2.0
+
+
diff --git a/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/db/HuixiabaoDbUtils.java b/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/db/HuixiabaoDbUtils.java
index 4021fcb..134ecee 100644
--- a/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/db/HuixiabaoDbUtils.java
+++ b/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/db/HuixiabaoDbUtils.java
@@ -1,11 +1,12 @@
/**
- * @Author: Kane
- * @Date: 2025-03-17 14:52:06
-* @LastEditors: Kane
-* @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/db/HuixiabaoDbUtils.java
+ * @Author: Kane Wang
+ * @Date: 2025-03-17 19:03:17
+ * @LastEditors: Kane
+ * @LastModified: 2025-03-20 10:49:49
+ * @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/db/HuixiabaoDbUtils.java
* @Description:
*
- * Copyright (c) ${2023} by Kane, All Rights Reserved.
+ * Copyright (c) 2025 by Kane All rights reserved
*/
package com.cpic.xim.huixiabao.db;
@@ -26,14 +27,15 @@ public class HuixiabaoDbUtils
private static Logger logger = LoggerFactory.getLogger( HuixiabaoDbUtils.class );
public static void saveHmbXyxInfoToMysql( Vector xyxInfo )
- throws ClassNotFoundException
+ throws ClassNotFoundException,
+ SQLException
{
Connection connection = null;
PreparedStatement statementDelete = null;
PreparedStatement statementInsert = null;
String sqlDelete = """
- delete from HmbXyxInfo where xyxNo = ?"
+ delete from HmbXyxInfo where xyxNo = ?
""";
String sqlInsert = """
insert into HmbXyxInfo( psnName, certno, serviceId, status, xyxNo )
@@ -47,32 +49,24 @@ public class HuixiabaoDbUtils
connection = DriverManager.getConnection( AppConfig.getUrltest(),
AppConfig.getUsername(),
AppConfig.getPassword() );
- statementDelete = connection.prepareStatement( sqlDelete );
- statementInsert = connection.prepareStatement( sqlInsert );
+ statementDelete = connection.prepareStatement( sqlDelete.trim() );
+ statementInsert = connection.prepareStatement( sqlInsert.trim() );
- for ( HmbXyxInfoItem item: xyxInfo )
+ for ( HmbXyxInfoItem item : xyxInfo )
{
logger.info( "写入记录{<>}", item.getXyxNo() );
- statementDelete.setString(1, item.getXyxNo() );
- statementInsert.setString(1, item.getPsnName() );
- statementInsert.setString(2, item.getCertno() );
- statementInsert.setString(3, item.getServiceId() );
- statementInsert.setString(4, item.getStatus() );
- statementInsert.setString(5, item.getXyxNo() );
-
+ statementDelete.setString( 1, item.getXyxNo() );
+ statementInsert.setString( 1, item.getPsnName() );
+ statementInsert.setString( 2, item.getCertno() );
+ statementInsert.setString( 3, item.getServiceId() );
+ statementInsert.setString( 4, item.getStatus() );
+ statementInsert.setString( 5, item.getXyxNo() );
+
statementDelete.execute();
statementInsert.execute();
}
}
- catch ( ClassNotFoundException error )
- {
- logger.error("加载mysql驱动失败：{<>}", error.getMessage() );
- }
- catch ( SQLException error )
- {
- logger.error("执行sql失败：{<>}", error.getMessage() );
- }
finally
{
if ( statementDelete != null )
diff --git a/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java b/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java
index cdd0c0a..f9eddce 100644
--- a/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java
+++ b/code/cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java
@@ -1,9 +1,9 @@
/**
* @Author: Kane Wang
* @Date: 2025-03-15 18:40:54
- * @LastEditors: Kane Wang
+ * @LastEditors: Kane
* @LastModified: 2025-03-16 08:59:16
- * @FilePath: src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java
+ * @FilePath: /cpicxim-huixiabao/src/main/java/com/cpic/xim/huixiabao/web/controllers/MediCover/MediCoverController.java
* @Description:
*
* Copyright (c) 2025 by Kane All rights reserved
@@ -19,11 +19,16 @@ import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.web.bind.annotation.PostMapping;
+
+import java.sql.SQLException;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.cpic.xim.utils.secrecy.*;
import com.cpic.xim.huixiabao.web.data.nhs.xyx.HmbXyxInfo;
+import com.cpic.xim.huixiabao.web.data.nhs.xyx.HmbXyxInfoItem;
+import com.cpic.xim.huixiabao.db.HuixiabaoDbUtils;
@Controller
@@ -58,27 +63,56 @@ public class MediCoverController
try
{
xyxInfo = jsonMapper.readValue( decryptData, HmbXyxInfo.class );
+
+ HuixiabaoDbUtils.saveHmbXyxInfoToMysql( xyxInfo.getHmbList() );
+ }
+ catch ( ClassNotFoundException error )
+ {
+ logger.error( "加载mysql驱动失败：{}", error.getMessage() );
+
+ // 解析json错误。通知调用者
+ response = new MediCoverResponse( "500",
+ "加载mysql驱动失败：" + error.getMessage(),
+ "",
+ "",
+ "",
+ false );
+ }
+ catch ( SQLException error )
+ {
+ // 执行sql错误。通知调用者
+ logger.error( "执行sql失败：{}", error.getMessage() );
+
+ response = new MediCoverResponse( "500",
+ "执行sql失败：" + error.getMessage(),
+ "",
+ "",
+ "",
+ false );
}
catch ( Exception error )
{
// 解析json错误。通知调用者
response = new MediCoverResponse( "500",
- "解析JSON失败：" + error.getMessage(),
+ "解析JSON失败：{}" + error.getMessage(),
"",
"",
"",
false );
- return response;
}
- // 处理成功
- response = new MediCoverResponse( "20000",
- "处理成功",
- "",
- "",
- "",
- true );
+
+ if ( response == null )
+ {
+ // 处理成功
+ response = new MediCoverResponse( "20000",
+ "处理成功",
+ "",
+ "",
+ "",
+ true );
+ }
return response;
}