From 673761800f34c4c4dd70071fbaadecfcd593b85b Mon Sep 17 00:00:00 2001
From: Yimi <Yimi>
Date: Sat, 8 Mar 2025 18:41:36 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=90=8C=E6=AD=A5=E5=95=86?=
 =?UTF-8?q?=E5=93=81=E3=80=81=E4=BC=9A=E5=91=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/SyncThirdDataServiceImpl.java        | 56 +++++++++++--------
 1 file changed, 33 insertions(+), 23 deletions(-)

diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
index 532d4da0..a07efc42 100644
--- a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
+++ b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
@@ -536,6 +536,7 @@ public class SyncThirdDataServiceImpl implements SyncThirdDataService {
             return CommonResult.failed();
         }
 
+        //1-品牌，2-分类，3-商品，4-会员
         switch (syncType) {
             case 1:
                 return syncProductBrand(jdbcTemplate);
@@ -553,7 +554,7 @@ public class SyncThirdDataServiceImpl implements SyncThirdDataService {
     private JdbcTemplate getJDBCTemplate(SyncConfig syncConfig) {
 
         switch (syncConfig.getSys_version()) {
-            case "hbposev9" :
+            case "hbposev9":
                 DriverManagerDataSource dataSource = new DriverManagerDataSource();
                 dataSource.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
                 String url = String.format("jdbc:sqlserver://%s:%s;databaseName=%s",
@@ -567,13 +568,41 @@ public class SyncThirdDataServiceImpl implements SyncThirdDataService {
         return null;
     }
 
+
+    /**
+     * 同步商品
+     *
+     * @return
+     */
+    public CommonResult syncProduct(JdbcTemplate template) {
+        //商品编码 item_no、商品名称 item_name、零售价 sale_price、会员价 vip_price
+        String sql = "SELECT item_no, item_name, sale_price, vip_price FROM t_bd_item_info";
+
+        List<String> oList = template.queryForList(sql, String.class);
+        //todo 第三方 商品同步接口
+        return null;
+    }
+
+
+    /**
+     * 同步会员
+     *
+     * @return
+     */
+    public CommonResult syncVip(JdbcTemplate template) {
+        //会员卡号card_no、card_id、会员姓名vip_name、手机号vip_tel | mobile、性别 vip_sex、生日 birthday
+        String sql = "SELECT card_no, card_id, vip_name, vip_tel, vip_sex, birthday FROM t_rm_vip_info";
+        List<String> oList = template.queryForList(sql, String.class);
+        //todo 第三方 会员同步接口
+        return null;
+    }
+
     /**
      * 同步商品品牌
      *
      * @return
      */
-    public CommonResult syncProductBrand(JdbcTemplate syncAppO) {
-
+    public CommonResult syncProductBrand(JdbcTemplate template) {
         return null;
     }
 
@@ -582,27 +611,8 @@ public class SyncThirdDataServiceImpl implements SyncThirdDataService {
      *
      * @return
      */
-    public CommonResult syncProductClazz(JdbcTemplate syncAppO) {
+    public CommonResult syncProductClazz(JdbcTemplate template) {
         return null;
     }
 
-    /**
-     * 同步商品
-     *
-     * @return
-     */
-    public CommonResult syncProduct(JdbcTemplate syncAppO) {
-        return null;
-    }
-
-    /**
-     * 同步会员
-     *
-     * @return
-     */
-    public CommonResult syncVip(JdbcTemplate syncAppO) {
-        return null;
-    }
-
-
 }