From 2aa3956f18d875084881d18e67464ea81eeea63d Mon Sep 17 00:00:00 2001
From: hecan <1718492867@qq.com>
Date: Mon, 6 Jan 2025 10:40:59 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0BIP=E6=89=93=E6=AC=BE?=
 =?UTF-8?q?=E9=87=91=E9=A2=9D=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../plugin/BackUpDatabaseInitializer.java     | 37 ++++++++++---------
 .../serviceData/entity/ServiceDataEntity.java | 17 +++++++++
 .../serviceData/entity/ServiceDataEntity.xml  |  3 ++
 .../service/impl/ServiceDataServiceImpl.java  |  3 +-
 pom.xml                                       |  4 +-
 5 files changed, 43 insertions(+), 21 deletions(-)

diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/BackUpDatabase/plugin/BackUpDatabaseInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/BackUpDatabase/plugin/BackUpDatabaseInitializer.java
index 7a98112a..bfeb35a6 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/BackUpDatabase/plugin/BackUpDatabaseInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/BackUpDatabase/plugin/BackUpDatabaseInitializer.java
@@ -5,13 +5,13 @@ import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.web.entity.BaseResult;
 import com.hzya.frame.web.entity.JsonResultEntity;
 
-import com.jcraft.jsch.Channel;
+/*import com.jcraft.jsch.Channel;
 import com.jcraft.jsch.ChannelSftp;
 import com.jcraft.jsch.JSch;
 import com.jcraft.jsch.Session;
 import com.jcraft.jsch.SftpATTRS;
 import com.jcraft.jsch.SftpException;
-import org.apache.commons.net.ftp.FTPClient;
+import org.apache.commons.net.ftp.FTPClient;*/
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
@@ -107,12 +107,12 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
     private String sftpFilePase;
 
 
-    private ChannelSftp sftp = null;
-    private Session sshSession = null;
+    /*private ChannelSftp sftp = null;
+    private Session sshSession = null;*/
 
     @Override
     public JsonResultEntity executeBusiness(JSONObject requestJson) {
-        try {
+       /* try {
             if(filePase == null || "".equals(filePase)
                 || databaseName == null || "".equals(databaseName)
                 || fileName == null || "".equals(fileName)
@@ -185,14 +185,14 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
             return false;
         }
     }
-    /**
+    *//**
      * @Author lvleigang
      * @Description  创建目录及文件
      * @Date 8:59 上午 2024/10/22
      * @param filePath
      * @param fileName
      * @return java.io.File
-     **/
+     **//*
     public File creatFile(String filePath, String fileName) {
         File folder = new File(filePath);
         //文件夹路径不存在
@@ -252,9 +252,9 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
         }
     }
 
-    /**
+    *//**
      * 关闭连接
-     */
+     *//*
     public void disconnect() {
         if (this.sftp != null) {
             if (this.sftp.isConnected()) {
@@ -274,7 +274,7 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
         }
     }
 
-    /**
+    *//**
      * 上传单个文件
      *
      * @param remotePath:远程保存目录
@@ -282,7 +282,7 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
      * @param localPath:本地上传目录(以路径符号结束)
      * @param localFileName:上传的文件名
      * @return
-     */
+     *//*
     public boolean uploadFile(String remotePath, String remoteFileName, String localPath, String localFileName) {
         FileInputStream in = null;
         try {
@@ -304,12 +304,12 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
         return false;
     }
 
-    /**
+    *//**
      * 创建目录
      *
      * @param createpath
      * @return
-     */
+     *//*
     public boolean createDir(String createpath) {
         try {
             if (isDirExist(createpath)) {
@@ -340,12 +340,12 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
         return false;
     }
 
-    /**
+    *//**
      * 判断目录是否存在
      *
      * @param directory
      * @return
-     */
+     *//*
     public boolean isDirExist(String directory) {
         boolean isDirExistFlag = false;
         try {
@@ -362,11 +362,11 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
 
 
 
-    /**
+    *//**
      * 如果目录不存在就创建目录
      *
      * @param path
-     */
+     *//*
     public void mkdirs(String path) {
         File f = new File(path);
 
@@ -376,7 +376,8 @@ public class BackUpDatabaseInitializer extends PluginBaseEntity {
 
         if (!f.exists()) {
             f.mkdirs();
-        }
+        }*/
+        return null;
     }
 
 
diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.java b/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.java
index eeb4c0cf..9f72712a 100644
--- a/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.java
+++ b/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.java
@@ -18,7 +18,24 @@ public class ServiceDataEntity extends BaseEntity {
 
     private String summary_id;//summary_id
 
+    private String bipAmountField;//BIP打款金额字段
+    private String bipAmount;//BIP打款金额
 
+    public String getBipAmountField() {
+        return bipAmountField;
+    }
+
+    public void setBipAmountField(String bipAmountField) {
+        this.bipAmountField = bipAmountField;
+    }
+
+    public String getBipAmount() {
+        return bipAmount;
+    }
+
+    public void setBipAmount(String bipAmount) {
+        this.bipAmount = bipAmount;
+    }
 
     public String getSummary_id() {
         return summary_id;
diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.xml b/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.xml
index b763bc6e..8f5fa7e4 100644
--- a/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.xml
+++ b/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/entity/ServiceDataEntity.xml
@@ -25,6 +25,8 @@
         ,summary_id
         ,bip_payment_number_field as bipPaymentNumberField
         ,bip_payment_number as bipPaymentNumber
+        ,bip_amount_field as bipAmountField
+        ,bip_amount as bipAmount
     </sql>
 
     <select id="entity_list_base" resultMap="get-ServiceDataEntity-result" parameterType = "com.hzya.frame.sysnew.comparison.serviceData.entity.ServiceDataEntity">
@@ -89,6 +91,7 @@
         update ${tabName} set
         <trim suffix="" suffixOverrides=",">
             <if test="payDate != null and payDate != ''"> ${payDateFiled} = #{payDate},</if>
+            <if test="bipAmount != null and bipAmount != ''"> ${bipAmountField} = #{bipAmount},</if>
             <if test="payResult != null and payResult != ''"> ${payResultFiled} = #{payResult}</if>
         </trim>
         where id=#{id}
diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/service/impl/ServiceDataServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/service/impl/ServiceDataServiceImpl.java
index ac63ae39..096ecf33 100644
--- a/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/service/impl/ServiceDataServiceImpl.java
+++ b/base-service/src/main/java/com/hzya/frame/sysnew/comparison/serviceData/service/impl/ServiceDataServiceImpl.java
@@ -162,6 +162,7 @@ public class ServiceDataServiceImpl extends BaseService<ComparisonEntity,String>
                         if (jsonObject.getString("billCode").equals(serviceDataEntity.getBillCode())) {
                             serviceDataEntity.setPayResult(jsonObject.getString("payResult"));
                             serviceDataEntity.setPayDate(jsonObject.getString("payDate"));
+                            serviceDataEntity.setBipAmount(jsonObject.getString("bipAmount"));
                             serviceDataEntity.setDataSourceCode(jsonObject.getString("dataSourceCode"));
                             logger.info("====开始根据单据号:{},表名称:{},表单id:{}更新支付状态和时间======", serviceDataEntity.getBillCode(), serviceDataEntity.getTabName(), serviceDataEntity.getId());
                             integer = serviceDataDao.updatePayResult(serviceDataEntity);
@@ -292,7 +293,7 @@ public class ServiceDataServiceImpl extends BaseService<ComparisonEntity,String>
         try {
             StringBuffer stringBuffer = new StringBuffer();
             stringBuffer.append("select oa_id as data_id,tab_name,title,pay_company,bill_name,pay_result_field,pay_date_field,receipt_filed,\n" +
-                    "push_status_field,summary_id,bip_payment_number_field,\n" +
+                    "push_status_field,summary_id,bip_payment_number_field,bip_amount_field,\n" +
                     "vdef1,pk_acceptorg,creator,pk_group,pk_org,applydate,pk_trantypecode,pk_busitype,vdef2,pk_currtype,\n" +
                     "pk_supplier,pk_bankacc_r,pk_bankacc_p,pk_decidedept,vdef10,vdef12,vdef3,vdef4,vdef5,vdef6,applysum,\n" +
                     "vdef7,vdef8,vdef9 from v_cmp_apply where 1=1 and vdef1 is not null  and push_status is null and applysum >0");
diff --git a/pom.xml b/pom.xml
index a4da4f32..d962aadc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -14,9 +14,9 @@
 <!--        <module>fw-nc</module>-->
 <!--        <module>fw-ncc</module>-->
 <!--        <module>fw-ningbobank</module>-->
-<!--        <module>fw-oa</module>-->
+        <module>fw-oa</module>
 <!--        <module>fw-u8</module>-->
-<!--        <module>fw-u8c</module>-->
+        <module>fw-u8c</module>
 <!--        <module>fw-u9c</module>-->
     </modules>
     <groupId>com.hzya.frame</groupId>