创客重新实名开放表数据同步

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

@@ -28,6 +28,7 @@ import com.kxs.transfer.api.service.sys.KxsMorningService;
 import com.kxs.transfer.api.service.sys.KxsSchoolStudyService;
 import com.kxs.transfer.api.service.sys.KxsSysMsgService;
 import com.kxs.transfer.api.service.user.*;
+import com.kxs.transfer.api.service.user.impl.KxsUserReRealService;
 import com.kxs.user.api.model.KxsLeaderAmountLog;
 import com.kxs.user.api.model.KxsPartner;
 import com.kxs.user.api.model.KxsUserByStage;
@@ -72,6 +73,7 @@ public class DtsController {
     private final KxsBankChangeLogService kxsBankChangeLogService;
     private final KxsUserByStageService kxsUserByStageService;
     private final KxsLeaderAmountLogService kxsLeaderAmountLogService;
+    private final KxsUserReRealService kxsUserReRealService;
 
     private final KxsMachineService kxsMachineService;
 
@@ -216,6 +218,9 @@ public class DtsController {
             if ("ToChargeBackRecordSub".equals(dmlData.getTableName())) {
                 kxsUserByStageService.changeInfoData(dmlData);
             }
+            if ("UserSetUnAuthRecord".equals(dmlData.getTableName())) {
+                kxsUserReRealService.changeData(dmlData);
+            }
 
 
             //商品表同步

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/user/KxsUserReRealMapper.java

@@ -0,0 +1,17 @@
+package com.kxs.transfer.api.mapper.user;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsUserReReal;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 创客重新实名开放表(KxsUserReReal)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-06-05 14:02:55
+ */
+@Mapper
+public interface KxsUserReRealMapper extends BaseMapper<KxsUserReReal> {
+
+}
+

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

@@ -0,0 +1,86 @@
+package com.kxs.transfer.api.service.user.impl;
+
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.LocalDateTimeUtil;
+import com.aliyun.dts.subscribe.clients.record.OperationType;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.kxs.transfer.api.mapper.user.KxsUserReRealMapper;
+import com.kxs.transfer.api.model.table.DMLData;
+import com.kxs.user.api.model.KxsUserReReal;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 创客重新实名开放表(KxsUserReReal)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-06-05 14:02:55
+ */
+@Service("kxsUserReRealService")
+public class KxsUserReRealService extends ServiceImpl<KxsUserReRealMapper, KxsUserReReal> {
+
+    public void changeData(DMLData dmlData) {
+
+        //修改的字段值
+        Map<String, Object> validFieldDataMap = dmlData.getValidFieldDataMap();
+        //修改的字段
+        List<String> changeFieldList = dmlData.getChangeFieldList();
+        //操作的主键
+        int id = Integer.parseInt(dmlData.getId());
+
+        KxsUserReReal userReReal = new KxsUserReReal();
+        userReReal.setId(id);
+        //操作类型
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            // 更新数据
+            baseMapper.deleteById(id);
+            return;
+        }
+        for (String field : changeFieldList) {
+
+            switch (field) {
+                case "UserId":
+                    userReReal.setUserId(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "Remark":
+                    userReReal.setRemark(validFieldDataMap.get(field).toString());
+                    break;
+                case "RealName":
+                    userReReal.setUsername(validFieldDataMap.get(field).toString());
+                    break;
+                case "MakerCode":
+                    userReReal.setUserCode(validFieldDataMap.get(field).toString());
+                    break;
+                case "Operator":
+                    userReReal.setCreateBy(validFieldDataMap.get(field).toString());
+                    break;
+                case "CreateDate":
+                    userReReal.setCreateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+                case "UpdateDate":
+                    userReReal.setUpdateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+            }
+        }
+
+        if(operation.equals(OperationType.UPDATE)){
+
+            // 更新数据
+            baseMapper.updateById(userReReal);
+        }
+        if(operation.equals(OperationType.INSERT)){
+
+            KxsUserReReal kxsUserReReal = baseMapper.selectById(id);
+            if (kxsUserReReal != null){
+                baseMapper.updateById(userReReal);
+            }else{
+                // 插入数据
+                baseMapper.insert(userReReal);
+            }
+        }
+    }
+}
+

kxs-user/kxs-user-api/src/main/java/com/kxs/user/api/model/KxsUserLevelLog.java

@@ -102,6 +102,12 @@ public class KxsUserLevelLog extends Model<KxsUserLevelLog> implements Serializa
     private Integer createById;
 
 
+    /**
+     * 备注
+     */
+    private String remark;
+
+
 
 
 }

kxs-user/kxs-user-api/src/main/java/com/kxs/user/api/model/KxsUserReReal.java

@@ -0,0 +1,108 @@
+package com.kxs.user.api.model;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 创客重新实名开放表(KxsUserReReal)表实体类
+ *
+ * @author 系统
+ * @since 2024-06-05 14:02:55
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class KxsUserReReal extends Model<KxsUserReReal> implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    
+    
+    /**
+     * 主键ID
+     */
+    @Schema(description = "主键ID")
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+
+    /**
+     * 新增时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    @Schema(description = "新增时间")
+    private LocalDateTime createTime;
+
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.UPDATE)
+    @Schema(description = "更新时间")
+    private LocalDateTime updateTime;
+
+
+    /**
+     * 删除标记，0未删除，1已删除
+     */
+    @Schema(description = "删除标记，0未删除，1已删除")
+    private String delFlag;
+
+
+    /**
+     * 版本
+     */
+    @Schema(description = "版本")
+    private Integer version;
+
+
+    /**
+     * 备注
+     */
+    @Schema(description = "备注")
+    private String remark;
+
+
+    /**
+     * 操作人
+     */
+    @Schema(description = "操作人")
+    private String createBy;
+
+
+    /**
+     * 创客ID
+     */
+    @Schema(description = "创客ID")
+    private Integer userId;
+
+
+    /**
+     * 创客姓名
+     */
+    @Schema(description = "创客姓名")
+    private String username;
+
+
+    /**
+     * 创客编号
+     */
+    @Schema(description = "创客编号")
+    private String userCode;
+
+
+
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/mapper/KxsUserReRealMapper.java

@@ -0,0 +1,17 @@
+package com.kxs.user.biz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsUserReReal;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 创客重新实名开放表(KxsUserReReal)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-06-05 14:02:55
+ */
+@Mapper
+public interface KxsUserReRealMapper extends BaseMapper<KxsUserReReal> {
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/KxsUserReRealService.java

@@ -0,0 +1,15 @@
+package com.kxs.user.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.kxs.user.api.model.KxsUserReReal;
+
+/**
+ * 创客重新实名开放表(KxsUserReReal)表服务接口
+ *
+ * @author 系统
+ * @since 2024-06-05 14:02:55
+ */
+public interface KxsUserReRealService extends IService<KxsUserReReal> {
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsUserReRealServiceImpl.java

@@ -0,0 +1,19 @@
+package com.kxs.user.biz.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.kxs.user.biz.mapper.KxsUserReRealMapper;
+import com.kxs.user.api.model.KxsUserReReal;
+import com.kxs.user.biz.service.KxsUserReRealService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 创客重新实名开放表(KxsUserReReal)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-06-05 14:02:55
+ */
+@Service("kxsUserReRealService")
+public class KxsUserReRealServiceImpl extends ServiceImpl<KxsUserReRealMapper, KxsUserReReal> implements KxsUserReRealService {
+
+}
+

kxs-user/kxs-user-biz/src/main/resources/mapper/KxsUserLevelLogMapper.xml

@@ -13,6 +13,7 @@
         <result column="end_time" property="endTime" />
         <result column="preset_level" property="presetLevel" />
         <result column="create_by_id" property="createById" />
+        <result column="remark" property="remark" />
 
     </resultMap>
 

kxs-user/kxs-user-biz/src/main/resources/mapper/KxsUserReRealMapper.xml

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.kxs.user.biz.mapper.KxsUserReRealMapper">
+
+    <resultMap type="com.kxs.user.api.model.KxsUserReReal" id="KxsUserReRealMap">
+        <result column="id" property="id" />
+        <result column="create_time" property="createTime" />
+        <result column="update_time" property="updateTime" />
+        <result column="del_flag" property="delFlag" />
+        <result column="version" property="version" />
+        <result column="remark" property="remark" />
+        <result column="create_by" property="createBy" />
+        <result column="user_id" property="userId" />
+        <result column="username" property="username" />
+        <result column="user_code" property="userCode" />
+
+    </resultMap>
+
+</mapper>