新增存量预设职级数据同步和表

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.KxsUserPresetBeforeService;
 import com.kxs.transfer.api.service.user.impl.KxsUserReRealService;
 import com.kxs.user.api.model.KxsLeaderAmountLog;
 import com.kxs.user.api.model.KxsPartner;
@@ -74,6 +75,7 @@ public class DtsController {
     private final KxsUserByStageService kxsUserByStageService;
     private final KxsLeaderAmountLogService kxsLeaderAmountLogService;
     private final KxsUserReRealService kxsUserReRealService;
+    private final KxsUserPresetBeforeService kxsUserPresetBeforeService;
 
     private final KxsMachineService kxsMachineService;
 
@@ -159,6 +161,10 @@ public class DtsController {
             if ("UserRankWhite".equals(dmlData.getTableName())) {
                 kxsUserPresetLogService.changeUser(dmlData);
             }
+            //用户存量预设
+            if ("UserRankWhiteBefore".equals(dmlData.getTableName())) {
+                kxsUserPresetBeforeService.changeData(dmlData);
+            }
             //密码操作
             if ("UserMoveInfo".equals(dmlData.getTableName())) {
                 kxsUserService.changeUserPwd(dmlData);

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/user/KxsUserPresetBeforeMapper.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.KxsUserPresetBefore;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户存量预设职级表(KxsUserPresetBefore)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-06-07 16:24:47
+ */
+@Mapper
+public interface KxsUserPresetBeforeMapper extends BaseMapper<KxsUserPresetBefore> {
+
+}
+

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

@@ -0,0 +1,80 @@
+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.KxsUserPresetBeforeMapper;
+import com.kxs.transfer.api.model.table.DMLData;
+import com.kxs.transfer.api.model.table.FieldData;
+import com.kxs.user.api.model.KxsUserPresetBefore;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户存量预设职级表(KxsUserPresetBefore)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-06-07 16:24:47
+ */
+@Service("kxsUserPresetBeforeService")
+public class KxsUserPresetBeforeService extends ServiceImpl<KxsUserPresetBeforeMapper, KxsUserPresetBefore>  {
+
+    public void changeData(DMLData dmlData) {
+        //修改的字段值
+        Map<String, Object> validFieldDataMap = dmlData.getValidFieldDataMap();
+        //全部字段值
+        Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
+        //修改的字段
+        List<String> changeFieldList = dmlData.getChangeFieldList();
+        //操作的主键
+        int id = Integer.parseInt(dmlData.getId());
+
+        KxsUserPresetBefore presetLog = new KxsUserPresetBefore();
+        presetLog.setId(id);
+        //操作类型
+        OperationType operation = dmlData.getOperation();
+        if (operation.equals(OperationType.DELETE)) {
+            // 更新数据
+            baseMapper.deleteById(id);
+            return;
+        }
+
+        for (String field : changeFieldList) {
+
+            switch (field) {
+                case "UserId":
+                    presetLog.setUserId(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "Rank":
+                    presetLog.setPresetLevel(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "CreateDate":
+                    presetLog.setStartTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    presetLog.setCreateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+                case "UpdateDate":
+                    presetLog.setEndTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+            }
+        }
+
+        if (operation.equals(OperationType.UPDATE)) {
+            // 更新数据
+            baseMapper.updateById(presetLog);
+        }
+        if (operation.equals(OperationType.INSERT)) {
+
+            KxsUserPresetBefore userPresetLog = baseMapper.selectById(presetLog.getId());
+            if (userPresetLog != null) {
+                baseMapper.updateById(presetLog);
+            } else {
+                // 插入数据
+                baseMapper.insert(presetLog);
+            }
+        }
+    }
+}
+

kxs-user/kxs-user-api/src/main/java/com/kxs/user/api/model/KxsUserPresetBefore.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;
+
+/**
+ * 用户存量预设职级表(KxsUserPresetBefore)表实体类
+ *
+ * @author 系统
+ * @since 2024-06-07 16:24:47
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class KxsUserPresetBefore extends Model<KxsUserPresetBefore> 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 Integer delFlag;
+
+
+    /**
+     * 版本
+     */
+    @Schema(description = "版本")
+    private Integer version;
+
+
+    /**
+     * 用户ID
+     */
+    @Schema(description = "用户ID")
+    private Integer userId;
+
+
+    /**
+     * 开始时间
+     */
+    @Schema(description = "开始时间")
+    private LocalDateTime startTime;
+
+
+    /**
+     * 结束时间
+     */
+    @Schema(description = "结束时间")
+    private LocalDateTime endTime;
+
+
+    /**
+     * 预设等级
+     */
+    @Schema(description = "预设等级")
+    private Integer presetLevel;
+
+
+    /**
+     * 设置人
+     */
+    @Schema(description = "设置人")
+    private Integer createById;
+
+
+
+
+}
+

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

@@ -0,0 +1,17 @@
+package com.kxs.user.biz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsUserPresetBefore;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户存量预设职级表(KxsUserPresetBefore)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-06-07 16:24:47
+ */
+@Mapper
+public interface KxsUserPresetBeforeMapper extends BaseMapper<KxsUserPresetBefore> {
+
+}
+

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

@@ -0,0 +1,15 @@
+package com.kxs.user.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.kxs.user.api.model.KxsUserPresetBefore;
+
+/**
+ * 用户存量预设职级表(KxsUserPresetBefore)表服务接口
+ *
+ * @author 系统
+ * @since 2024-06-07 16:24:47
+ */
+public interface KxsUserPresetBeforeService extends IService<KxsUserPresetBefore> {
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsUserPresetBeforeServiceImpl.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.KxsUserPresetBeforeMapper;
+import com.kxs.user.api.model.KxsUserPresetBefore;
+import com.kxs.user.biz.service.KxsUserPresetBeforeService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 用户存量预设职级表(KxsUserPresetBefore)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-06-07 16:24:47
+ */
+@Service("kxsUserPresetBeforeService")
+public class KxsUserPresetBeforeServiceImpl extends ServiceImpl<KxsUserPresetBeforeMapper, KxsUserPresetBefore> implements KxsUserPresetBeforeService {
+
+}
+

kxs-user/kxs-user-biz/src/main/resources/mapper/KxsUserPresetBeforeMapper.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.KxsUserPresetBeforeMapper">
+
+    <resultMap type="com.kxs.user.api.model.KxsUserPresetBefore" id="KxsUserPresetBeforeMap">
+        <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="user_id" property="userId" />
+        <result column="start_time" property="startTime" />
+        <result column="end_time" property="endTime" />
+        <result column="preset_level" property="presetLevel" />
+        <result column="create_by_id" property="createById" />
+
+    </resultMap>
+
+</mapper>