From 4d9da13450195525806495e9b81126e539911749 Mon Sep 17 00:00:00 2001
From: qiuyt <zane0312@foxmail.com>
Date: Tue, 8 Apr 2025 14:14:54 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E9=80=80=E5=BA=93=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../glxp/mipsdl/client/ctqyy/CtqyyClient.java |  9 ++---
 .../com/glxp/mipsdl/service/yb/YbClient.java  | 35 +++++++++++++++----
 2 files changed, 33 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/glxp/mipsdl/client/ctqyy/CtqyyClient.java b/src/main/java/com/glxp/mipsdl/client/ctqyy/CtqyyClient.java
index 5867391..57409b0 100644
--- a/src/main/java/com/glxp/mipsdl/client/ctqyy/CtqyyClient.java
+++ b/src/main/java/com/glxp/mipsdl/client/ctqyy/CtqyyClient.java
@@ -1496,10 +1496,10 @@ public class CtqyyClient extends CommonHttpClient {
 
             udiwmsBasicSkPrescribeRequest.setDatabaseProductName(getDataSourceType());
             if (udiwmsBasicSkPrescribeRequest.getBusType().equals("YPCFTF003")) {
-                udiwmsBasicSkPrescribeRequest.setIN_HOSP("1");
+                udiwmsBasicSkPrescribeRequest.setIN_HOSP("2");
 
             } else {
-                udiwmsBasicSkPrescribeRequest.setIN_HOSP("2");
+                udiwmsBasicSkPrescribeRequest.setIN_HOSP("1");
 
             }
             //拉取处方退货时，改成拉取v_ypzs_pres_info_return
@@ -2080,10 +2080,11 @@ public class CtqyyClient extends CommonHttpClient {
 
                 //区分住院、门诊处方
                 if (IntUtil.value(presInfoEntity.getIO_TYPE()) == 1) {
-                    ioCollectOrder.setBusType("YPCFTF003");
+                    ioCollectOrder.setBusType("YPCFTF002");
+
 //                    ioCollectOrder.setBillNo(presInfoEntity.getSTOOUT_NO());
                 } else {
-                    ioCollectOrder.setBusType("YPCFTF002");
+                    ioCollectOrder.setBusType("YPCFTF003");
 
                 }
                 ioCollectOrder.setBillNo(presInfoEntity.getAPPLY_NO());
diff --git a/src/main/java/com/glxp/mipsdl/service/yb/YbClient.java b/src/main/java/com/glxp/mipsdl/service/yb/YbClient.java
index 89b81e5..7511f9d 100644
--- a/src/main/java/com/glxp/mipsdl/service/yb/YbClient.java
+++ b/src/main/java/com/glxp/mipsdl/service/yb/YbClient.java
@@ -28,6 +28,7 @@ import javax.annotation.Resource;
 import java.net.ConnectException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
+import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 
@@ -108,13 +109,33 @@ public class YbClient {
             respStr = e.getMessage();
             return ResultVOUtils.error(500,"【" + apiNo + "】上传医保失败"+e.getMessage());
         }finally {
-            YbUploadingLog ybUploadingLog = new YbUploadingLog();
-            ybUploadingLog.setYbParam(reqStr);
-            ybUploadingLog.setYbReturn(respStr);
-            ybUploadingLog.setBillNo(billNo);
-            ybUploadingLog.setApiNo(apiNo);
-            ybUploadingLog.setUpdateTime(new Date());
-            ybUploadingLogMapper.insert(ybUploadingLog);
+
+            // 构建查询条件，按更新时间降序排序
+            QueryWrapper<YbUploadingLog> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("billNo", billNo)
+                    .orderByDesc("updateTime");
+            // 查询最新的一条记录
+            List<YbUploadingLog> logList = ybUploadingLogMapper.selectList(queryWrapper);
+            YbUploadingLog latestLog = logList.isEmpty() ? null : logList.get(0);
+
+            if (latestLog != null) {
+                // 存在记录，更新
+                latestLog.setYbParam(reqStr);
+                latestLog.setYbReturn(respStr);
+                latestLog.setApiNo(apiNo);
+                latestLog.setUpdateTime(new Date());
+                ybUploadingLogMapper.updateById(latestLog);
+            } else {
+                // 不存在记录，新增
+                YbUploadingLog newLog = new YbUploadingLog();
+                newLog.setYbParam(reqStr);
+                newLog.setYbReturn(respStr);
+                newLog.setBillNo(billNo);
+                newLog.setApiNo(apiNo);
+                newLog.setUpdateTime(new Date());
+                ybUploadingLogMapper.insert(newLog);
+            }
+
         }
     }