From 2b718717437184573b8575d62996d4be5c67a628 Mon Sep 17 00:00:00 2001
From: xd <844539747@qq.com>
Date: Thu, 7 Mar 2024 13:03:14 +0800
Subject: [PATCH] '111'

---
 pom.xml                                       |  2 +-
 .../clMaterial/CYlMaterialController.java     | 20 +++++++++++
 .../src/main/resources/application-druid.yml  | 13 ++++++-
 .../ruoyi/common/enums/DataSourceType.java    |  7 +++-
 .../ruoyi/framework/config/DruidConfig.java   | 10 ++++++
 .../clMaterial/mapper/CYlMaterialMapper.java  | 18 ++++++++++
 .../service/ICYlMaterialService.java          | 18 ++++++++++
 .../service/impl/CYlMaterialServiceImpl.java  | 31 +++++++++++++++++
 .../mapper/clMaterial/CYlMaterialMapper.xml   | 34 +++++++++++++++++++
 ruoyi-ui/src/api/clMaterial/clMaterial.js     |  8 +++++
 .../src/views/clMaterial/clMaterial/index.vue | 22 +++++++++++-
 .../src/views/material/material/index.vue     |  4 +--
 12 files changed, 181 insertions(+), 6 deletions(-)

diff --git a/pom.xml b/pom.xml
index 9646f35..d81cf9e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -18,7 +18,7 @@
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <java.version>1.8</java.version>
         <maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>
-        <druid.version>1.2.20</druid.version>
+        <druid.version>1.2.21</druid.version>
         <bitwalker.version>1.21</bitwalker.version>
         <swagger.version>3.0.0</swagger.version>
         <kaptcha.version>2.3.3</kaptcha.version>
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/clMaterial/CYlMaterialController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/clMaterial/CYlMaterialController.java
index 2b9a735..716489d 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/clMaterial/CYlMaterialController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/clMaterial/CYlMaterialController.java
@@ -109,4 +109,24 @@ public class CYlMaterialController extends BaseController
     {
         return toAjax(cYlMaterialService.deleteCYlMaterialByMaterialIds(materialIds));
     }
+
+    /**
+     * 同步更细报价实时价格
+     */
+    @PreAuthorize("@ss.hasPermi('clMaterial:clMaterial:synchronizeQuotationData')")
+    @Log(title = "同步更细报价实时价格", businessType = BusinessType.UPDATE)
+    @DataSource(DataSourceType.JNERP)
+    @PostMapping("/synchronizeUpdate")
+    public AjaxResult synchronizeUpdate()
+    {
+        //拉取9.2 jn_erp  报价实时价格数据,保存至 c_yl_material_bjdata 表
+        List<CYlMaterial> list = cYlMaterialService.getBjData();
+        cYlMaterialService.deleteYlMaterialBjBatch();
+        cYlMaterialService.insertYlMaterialBjBatch(list);
+
+        //数据执行sql 更新 c_yl_material_bjdata 表中单价字段
+
+
+        return success();
+    }
 }
diff --git a/ruoyi-admin/src/main/resources/application-druid.yml b/ruoyi-admin/src/main/resources/application-druid.yml
index b962313..85f3d94 100644
--- a/ruoyi-admin/src/main/resources/application-druid.yml
+++ b/ruoyi-admin/src/main/resources/application-druid.yml
@@ -22,9 +22,20 @@ spring:
                 # 从数据源开关/默认关闭
                 enabled: true
                 driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
-                url: jdbc:sqlserver://192.168.9.99:1433;DatabaseName=jn_quot
+                # 测试数据库
+                url: jdbc:sqlserver://192.168.9.66:1433;DatabaseName=jn_quot
+                # 正式数据库
+                # url: jdbc:sqlserver://192.168.9.99:1433;DatabaseName=jn_quot
                 username: sa
                 password: Itcenter110-
+            # 江南erp数据库数据源
+            jnerp:
+                # 从数据源开关/默认关闭
+                enabled: true
+                driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
+                url: jdbc:sqlserver://192.168.9.2:1433;DatabaseName=jn_erp
+                username: sa
+                password: it12345
             # 初始连接数
             initialSize: 10
             # 最小连接池数量
diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/enums/DataSourceType.java b/ruoyi-common/src/main/java/com/ruoyi/common/enums/DataSourceType.java
index 16bc447..c4c19ce 100644
--- a/ruoyi-common/src/main/java/com/ruoyi/common/enums/DataSourceType.java
+++ b/ruoyi-common/src/main/java/com/ruoyi/common/enums/DataSourceType.java
@@ -20,6 +20,11 @@ public enum DataSourceType
     /**
      * 江南全要素报价数据库
      */
-    QUOT
+    QUOT,
+
+    /**
+     * 江南ERP数据库
+     */
+    JNERP
 
 }
diff --git a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/DruidConfig.java b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/DruidConfig.java
index cf7ff2c..1fdc2f8 100644
--- a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/DruidConfig.java
+++ b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/DruidConfig.java
@@ -58,6 +58,15 @@ public class DruidConfig
         return druidProperties.dataSource(dataSource);
     }
 
+    @Bean
+    @ConfigurationProperties("spring.datasource.druid.jnerp")
+    @ConditionalOnProperty(prefix = "spring.datasource.druid.jnerp", name = "enabled", havingValue = "true")
+    public DataSource jnerpDataSource(DruidProperties druidProperties)
+    {
+        DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
+        return druidProperties.dataSource(dataSource);
+    }
+
     @Bean(name = "dynamicDataSource")
     @Primary
     public DynamicDataSource dataSource(DataSource masterDataSource)
@@ -66,6 +75,7 @@ public class DruidConfig
         targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);
         setDataSource(targetDataSources, DataSourceType.REDBOOK.name(), "redbookDataSource");
         setDataSource(targetDataSources, DataSourceType.QUOT.name(), "quotDataSource");
+        setDataSource(targetDataSources, DataSourceType.JNERP.name(), "jnerpDataSource");
         return new DynamicDataSource(masterDataSource, targetDataSources);
     }
 
diff --git a/ruoyi-system/src/main/java/com/ruoyi/clMaterial/mapper/CYlMaterialMapper.java b/ruoyi-system/src/main/java/com/ruoyi/clMaterial/mapper/CYlMaterialMapper.java
index 7131cd5..f22a332 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/clMaterial/mapper/CYlMaterialMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/clMaterial/mapper/CYlMaterialMapper.java
@@ -65,4 +65,22 @@ public interface CYlMaterialMapper
      * @return 结果
      */
     CYlMaterial checkMaterialNoUnique(String materialNo);
+
+    /**
+     * 拉取报价实时价格数据
+     * @return
+     */
+    List<CYlMaterial> getBjData();
+
+    /**
+     * 删除c_yl_material_bjdata 表数据
+     */
+    void deleteYlMaterialBjBatch();
+
+    /**
+     * 报价实时价格数据保存至 c_yl_material_bjdata 表
+     * @param list
+     */
+    void insertYlMaterialBjBatch(List<CYlMaterial> list);
+
 }
diff --git a/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/ICYlMaterialService.java b/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/ICYlMaterialService.java
index 38c66ff..fbded89 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/ICYlMaterialService.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/ICYlMaterialService.java
@@ -65,4 +65,22 @@ public interface ICYlMaterialService
      * @return
      */
     boolean checkMaterialNoUnique(CYlMaterial cYlMaterial);
+
+    /**
+     * 拉取报价实时价格数据
+     * @return
+     */
+    List<CYlMaterial> getBjData();
+
+    /**
+     * 删除c_yl_material_bjdata 表数据
+     */
+    void deleteYlMaterialBjBatch();
+
+    /**
+     * 报价实时价格数据保存至 c_yl_material_bjdata 表
+     * @param list
+     */
+    void insertYlMaterialBjBatch(List<CYlMaterial> list);
+
 }
diff --git a/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/impl/CYlMaterialServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/impl/CYlMaterialServiceImpl.java
index 430cfab..3042a1c 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/impl/CYlMaterialServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/clMaterial/service/impl/CYlMaterialServiceImpl.java
@@ -2,8 +2,10 @@ package com.ruoyi.clMaterial.service.impl;
 
 import java.util.List;
 
+import com.ruoyi.common.annotation.DataSource;
 import com.ruoyi.common.constant.UserConstants;
 import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.enums.DataSourceType;
 import com.ruoyi.common.utils.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -110,4 +112,33 @@ public class CYlMaterialServiceImpl implements ICYlMaterialService
         }
         return UserConstants.UNIQUE;
     }
+
+    /**
+     * 拉取报价实时价格数据
+     * @return
+     */
+    @Override
+    public List<CYlMaterial> getBjData() {
+
+        List<CYlMaterial> list = cYlMaterialMapper.getBjData();
+        System.out.println(list);
+        return null;
+    }
+
+    /**
+     * 删除c_yl_material_bjdata 表数据
+     */
+    @Override
+    public void deleteYlMaterialBjBatch() {
+        cYlMaterialMapper.deleteYlMaterialBjBatch();
+    }
+
+    /**
+     * 报价实时价格数据保存至 c_yl_material_bjdata 表
+     * @param list
+     */
+    @Override
+    public void insertYlMaterialBjBatch(List<CYlMaterial> list) {
+        cYlMaterialMapper.insertYlMaterialBjBatch(list);
+    }
 }
diff --git a/ruoyi-system/src/main/resources/mapper/clMaterial/CYlMaterialMapper.xml b/ruoyi-system/src/main/resources/mapper/clMaterial/CYlMaterialMapper.xml
index c806a71..0b38a42 100644
--- a/ruoyi-system/src/main/resources/mapper/clMaterial/CYlMaterialMapper.xml
+++ b/ruoyi-system/src/main/resources/mapper/clMaterial/CYlMaterialMapper.xml
@@ -72,4 +72,38 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         select top(1) material_id, material_no from c_yl_material where material_no = #{materialNo}
     </select>
 
+    <select id="getBjData" resultType="CYlMaterial">
+        SELECT A.m_id_0 materialNo,A.m_name_0 materialName,
+        case when isnull(CONVERT(decimal(10,2), C.XLXSCLHQ_HSJG),0)=0 then A.m_price_0 else CONVERT(decimal(10,2), C.XLXSCLHQ_HSJG) end materialPrice
+        from aq_base_material  A left join c_user B on A.create_user_uid_0=B.uid_0
+        left join (
+        select REPLACE(REPLACE(REPLACE(XLXSBJCL_BJCLID,char(10),''),CHAR(13),''),CHAR(32),'')
+        as XLXSCLHQ_BJCLID,XLXSBJCL_BJCLMC,
+        isnull(XLXSCLHQ_HSJG,0.0)as XLXSCLHQ_HSJG,
+        isnull(XLXSCLHQ_WHR,' ')as XLXSCLHQ_WHR,XLXSCLHQ_WHSJ
+        from [BJ].[GTDB8].[JSERP8].XLXSBJCL
+        left join [BJ].[GTDB8].[JSERP8].XLXSCLHQ on XLXSCLHQ_JGBID=(select xlxsjgb_JGBID
+        from [BJ].[GTDB8].[JSERP8].xlxsjgb
+        where xlxsjgb_tjys='3 '
+        and XLXSJGB_YXQS <![CDATA[<=]]> rtrim(convert(char,getdate(),20))
+        and (XLXSJGB_YXQZ is null or XLXSJGB_YXQZ>=rtrim(convert(char,getdate(),20))))
+        and XLXSCLHQ_BJCLID=XLXSBJCL_BJCLID
+        where 1=1
+        ) C on C.XLXSCLHQ_BJCLID = A.bjm_id_0 order by A.m_id_0
+    </select>
+
+    <delete id="deleteYlMaterialBjBatch">
+        delete from c_yl_material_bjdata
+    </delete>
+
+    <insert id="insertYlMaterialBjBatch">
+        INSERT INTO c_yl_material_bjdata (material_no, material_name, material_price)
+        VALUES
+        <foreach collection="list" index="" item="t" separator=",">
+            (#{t.materialNo,jdbcType=VARCHAR},
+            #{t.materialName,jdbcType=VARCHAR},
+            #{t.materialPrice,jdbcType=DECIMAL})
+        </foreach>
+    </insert>
+
 </mapper>
diff --git a/ruoyi-ui/src/api/clMaterial/clMaterial.js b/ruoyi-ui/src/api/clMaterial/clMaterial.js
index e463f66..7137e6d 100644
--- a/ruoyi-ui/src/api/clMaterial/clMaterial.js
+++ b/ruoyi-ui/src/api/clMaterial/clMaterial.js
@@ -42,3 +42,11 @@ export function delClMaterial(materialId) {
     method: 'delete'
   })
 }
+
+//同步更细报价实时价格
+export function synchronizeUpdate() {
+  return request({
+    url: '/clMaterial/clMaterial/synchronizeUpdate',
+    method: 'post'
+  })
+}
diff --git a/ruoyi-ui/src/views/clMaterial/clMaterial/index.vue b/ruoyi-ui/src/views/clMaterial/clMaterial/index.vue
index 7231caf..75f765e 100644
--- a/ruoyi-ui/src/views/clMaterial/clMaterial/index.vue
+++ b/ruoyi-ui/src/views/clMaterial/clMaterial/index.vue
@@ -76,6 +76,16 @@
           v-hasPermi="['clMaterial:clMaterial:export']"
         >导出</el-button>
       </el-col>
+      <el-col :span="1.5">
+        <el-button
+          type="primary"
+          plain
+          icon="el-icon-refresh-right"
+          size="mini"
+          @click="handleSynchronize"
+          v-hasPermi="['clMaterial:clMaterial:synchronizeQuotationData']"
+        >同步更新报价</el-button>
+      </el-col>
       <right-toolbar :showSearch.sync="showSearch" @queryTable="getList"></right-toolbar>
     </el-row>
 
@@ -150,7 +160,7 @@
 </template>
 
 <script>
-import { listClMaterial, getClMaterial, delClMaterial, addClMaterial, updateClMaterial } from "@/api/clMaterial/clMaterial";
+import { listClMaterial, getClMaterial, delClMaterial, addClMaterial, updateClMaterial, synchronizeUpdate } from "@/api/clMaterial/clMaterial";
 
 export default {
   name: "ClMaterial",
@@ -308,6 +318,16 @@ export default {
     /** 序号 */
     rowClMaterialIndex({ row, rowIndex }) {
       row.index = rowIndex + 1;
+    },
+
+    /*同步更新报价实时价格*/
+    handleSynchronize(){
+      this.$modal.confirm('是否确认同步更新？').then(function() {
+        return synchronizeUpdate();
+      }).then(() => {
+        this.getList();
+        this.$modal.msgSuccess("更新成功");
+      }).catch(() => {});
     }
   }
 };
diff --git a/ruoyi-ui/src/views/material/material/index.vue b/ruoyi-ui/src/views/material/material/index.vue
index 0746dab..31543f7 100644
--- a/ruoyi-ui/src/views/material/material/index.vue
+++ b/ruoyi-ui/src/views/material/material/index.vue
@@ -308,10 +308,10 @@ export default {
           { required: true, message: "类别不能为空", trigger: "blur" }
         ],
         costClQty: [
-          { pattern: /^(([1-9]{1}\d{0,9})|(0{1}))(\.\d{1,5})?$/, message: '格式有误',trigger: "blur"}
+          { pattern: /^(([1-9]{1}\d{0,9})|(0{1}))(\.\d{1,4})?$/, message: '格式有误',trigger: "blur"}
         ],
         costClQty2: [
-          { pattern: /^(([1-9]{1}\d{0,9})|(0{1}))(\.\d{1,5})?$/, message: '格式有误',trigger: "blur"}
+          { pattern: /^(([1-9]{1}\d{0,9})|(0{1}))(\.\d{1,4})?$/, message: '格式有误',trigger: "blur"}
         ],
       }
     };