同步用户密码信息

kxs-transfer/src/main/java/com/kxs/transfer/api/controller/DtsController.java

@@ -62,6 +62,14 @@ public class DtsController {
             record.commit(String.valueOf(record.getSourceTimestamp()));
             return;
         }
+        //用户表
+        if("Users".equals(dmlData.getTableName())){
+            kxsUserService.changeUser(dmlData);
+        }
+        //密码操作
+        if("UserMoveInfo".equals(dmlData.getTableName())){
+            kxsUserService.changeUserPwd(dmlData);
+        }
 
         //存储历史数据
         KxsDtsLog kxsDtsLog = new KxsDtsLog();
@@ -72,10 +80,6 @@ public class DtsController {
         kxsDtsLogService.save(kxsDtsLog);
         log.info("消费dts的数据表信息:{}", dmlData.getValidFieldDataMap());
 
-        if("Users".equals(dmlData.getTableName())){
-            kxsUserService.changeUser(dmlData);
-        }
-
         record.commit(String.valueOf(record.getSourceTimestamp()));
     }
 

kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/KxsUserService.java

@@ -20,5 +20,7 @@ import com.kxs.user.api.vo.kxsapp.user.UserInfoVO;
 public interface KxsUserService extends IService<KxsUser> {
 
     void changeUser(DMLData dmlData);
+
+    void changeUserPwd(DMLData dmlData);
 }
 

kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsUserServiceImpl.java

@@ -22,6 +22,7 @@ import com.kxs.transfer.api.mapper.user.KxsUserBankMapper;
 import com.kxs.transfer.api.mapper.user.KxsUserMapper;
 import com.kxs.transfer.api.mapper.user.KxsUserRealMapper;
 import com.kxs.transfer.api.model.table.DMLData;
+import com.kxs.transfer.api.model.table.FieldData;
 import com.kxs.transfer.api.service.user.KxsUserService;
 import com.kxs.user.api.model.KxsUser;
 import com.kxs.user.api.model.KxsUserAmount;
@@ -246,16 +247,40 @@ public class KxsUserServiceImpl extends ServiceImpl<KxsUserMapper, KxsUser> impl
 
     }
 
+    @Override
+    public void changeUserPwd(DMLData dmlData) {
 
+        Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
 
+        FieldData userId = fieldDataMap.get("UserId");
+        FieldData loginPwd = fieldDataMap.get("LoginPwd");
+        FieldData payPwd = fieldDataMap.get("PayPwd");
 
+        KxsUser user = baseMapper.selectById(userId.getValue().toString());
+        if(user != null){
+            //修改的字段
+            List<String> changeFieldList = dmlData.getChangeFieldList();
+            //加盐
+            String salt;
+            if(StrUtil.isNotBlank(user.getSalt())){
+                salt = user.getSalt();
+            }else{
+                salt = UUID.randomUUID().toString();
+            }
+            user.setSalt(salt);
+            if(changeFieldList.contains("LoginPwd")){
+                //登陆密码
+                user.setPassword(ENCODER.encode(loginPwd.getValue().toString() + salt));
+            }
+            if(changeFieldList.contains("PayPwd")){
+                //支付密码
+                user.setPayPwd(ENCODER.encode(payPwd.getValue().toString() + salt));
+            }
+            baseMapper.updateById(user);
+        }
 
 
-
-
-
-
-
+    }
 
 
 }

kxs-transfer/src/main/resources/import.txt

@@ -5,11 +5,19 @@ UserLevel as user_level, AuthFlag as real_status, MerchantType as is_merchant_ma
 FROM Users
 
 //用户实名信息表
-select Id as user_id, RealName as real_name, CertId as id_card, HandCertImage as id_card_hand, CertReverseImage as id_card_rear,
+select Id as id, Id as user_id, RealName as real_name, CertId as id_card, HandCertImage as id_card_hand, CertReverseImage as id_card_rear,
  CertFrontImage as id_card_front, AuthDate as create_time
 FROM Users where CertId is not null and CertId<>'' and RealName<>''
 
 //用户银行卡表
 select Id as user_id, SettleBankName as bank_name, Mobile as bank_phone, SettleBankCardNo as bank_code, BankCardPositiveImage as bank_pic,
  SeoTitle as bank_open, SettleBankCardName as bank_card_name, AuthDate as create_time
-FROM Users where SettleBankCardNo is not null and SettleBankName<>''
+FROM Users where SettleBankCardNo is not null and SettleBankName<>''
+
+//用户收货地址表
+select Id as id,
+SUBSTRING_INDEX(Areas, ',', 1) AS province,
+SUBSTRING_INDEX(SUBSTRING_INDEX(Areas, ',', -2), ',', 1) AS city,
+SUBSTRING_INDEX(Areas, ',', -1) AS area,
+address, Mobile as phone, RealName as consignee, IsDefault as is_default
+ FROM UserAddress