分润表同步

kxs-transfer/pom.xml

@@ -93,6 +93,12 @@
             <groupId>com.baomidou</groupId>
             <artifactId>dynamic-datasource-spring-boot3-starter</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.kxs</groupId>
+            <artifactId>kxs-user-biz</artifactId>
+            <version>1.1.0</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

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

@@ -75,6 +75,9 @@ public class DtsController {
     private final KxsLeaderByOrderService kxsLeaderByOrderService;
     private final KxsUserReRealService kxsUserReRealService;
     private final KxsUserPresetBeforeService kxsUserPresetBeforeService;
+    private final KxsUserProfitService kxsUserProfitService;
+    private final KxsUserProfitZlbService kxsUserProfitZlbService;
+    private final KxsUserProfitLkbService kxsUserProfitLkbService;
 
     private final KxsMachineService kxsMachineService;
 
@@ -246,6 +249,16 @@ public class DtsController {
             if ("UserSetUnAuthRecord".equals(dmlData.getTableName())) {
                 kxsUserReRealService.changeData(dmlData);
             }
+            //创客分润表
+            if ("ProfitRecord".equals(dmlData.getTableName())) {
+                kxsUserProfitService.changeData(dmlData);
+            }
+            if ("HelpProfitReward".equals(dmlData.getTableName())) {
+                kxsUserProfitZlbService.changeData(dmlData);
+            }
+            if ("MpProfitRecord".equals(dmlData.getTableName())) {
+                kxsUserProfitLkbService.changeData(dmlData);
+            }
 
 
             //商品表同步

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/user/KxsUserProfitLkbMapper.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.KxsUserProfitLkb;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户分润表来客吧(KxsUserProfitLkb)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Mapper
+public interface KxsUserProfitLkbMapper extends BaseMapper<KxsUserProfitLkb> {
+
+}
+

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/user/KxsUserProfitMapper.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.KxsUserProfit;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户分润表pos(KxsUserProfit)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Mapper
+public interface KxsUserProfitMapper extends BaseMapper<KxsUserProfit> {
+
+}
+

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/user/KxsUserProfitZlbMapper.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.KxsUserProfitZlb;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户分润表助力宝(KxsUserProfitZlb)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Mapper
+public interface KxsUserProfitZlbMapper extends BaseMapper<KxsUserProfitZlb> {
+
+}
+

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

@@ -257,6 +257,12 @@ public class KxsLeaderAccountLogService extends ServiceImpl<KxsLeaderAccountLogM
                         break;
                 }
             }
+            //由于此表没有关联changeType字段，故只有通过remark查询
+            KxsChangeTypeKind kxsChangeTypeKind = kxsChangeTypeKindMapper.selectById(leaderAccountLog.getVariationType());
+            if (kxsChangeTypeKind != null) {
+                leaderAccountLog1.setVariationCause(kxsChangeTypeKind.getName());
+                leaderAccountLog.setVariationCause(kxsChangeTypeKind.getName());
+            }
             if (operation.equals(OperationType.INSERT)) {
                 // 插入数据
                 baseMapper.insert(leaderAccountLog1);
@@ -348,7 +354,11 @@ public class KxsLeaderAccountLogService extends ServiceImpl<KxsLeaderAccountLogM
                         break;
                 }
             }
-
+            //由于此表没有关联changeType字段，故只有通过remark查询
+            KxsChangeTypeKind kxsChangeTypeKind = kxsChangeTypeKindMapper.selectById(leaderAccountLog.getVariationType());
+            if (kxsChangeTypeKind != null) {
+                leaderAccountLog.setVariationCause(kxsChangeTypeKind.getName());
+            }
             if (operation.equals(OperationType.INSERT)) {
                 // 插入数据
                 baseMapper.insert(leaderAccountLog);

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

@@ -0,0 +1,93 @@
+package com.kxs.transfer.api.service.user;
+
+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.KxsUserProfitLkbMapper;
+import com.kxs.transfer.api.model.table.DMLData;
+import com.kxs.user.api.model.KxsUserProfit;
+import com.kxs.user.api.model.KxsUserProfitLkb;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户分润表来客吧(KxsUserProfitLkb)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Service("kxsUserProfitLkbService")
+public class KxsUserProfitLkbService extends ServiceImpl<KxsUserProfitLkbMapper, KxsUserProfitLkb> {
+
+    public void changeData(DMLData dmlData) {
+
+        //修改的字段值
+        Map<String, Object> validFieldDataMap = dmlData.getValidFieldDataMap();
+        //修改的字段
+        List<String> changeFieldList = dmlData.getChangeFieldList();
+        //操作的主键
+        int id = Integer.parseInt(dmlData.getId());
+
+        KxsUserProfitLkb userProfit = new KxsUserProfitLkb();
+        userProfit.setId(id);
+        //操作类型
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            // 更新数据
+            baseMapper.deleteById(id);
+            return;
+        }
+        for (String field : changeFieldList) {
+
+            switch (field) {
+                case "UserId":
+                    userProfit.setUserId(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "Version":
+                    userProfit.setStatus(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "SeoTitle":
+                    userProfit.setProfitMonth(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "SeoDescription":
+                    String tradeType = validFieldDataMap.get(field).toString();
+                    if("存量".equals(tradeType)){
+                        userProfit.setTradeType(1);
+                    }else{
+                        userProfit.setTradeType(0);
+                    }
+                    break;
+                case "BrandId":
+                    userProfit.setTradeType(Integer.parseInt(validFieldDataMap.get(field).toString()) - 1);
+                    break;
+                case "ProfitAmount":
+                    userProfit.setProfitAmt(new BigDecimal(validFieldDataMap.get(field).toString()));
+                    break;
+                case "DirectFlag":
+                    int isTeam = Integer.parseInt(validFieldDataMap.get(field).toString());
+                    if(isTeam == 0){
+                        userProfit.setIsTeam(1);
+                    }else{
+                        userProfit.setIsTeam(0);
+                    }
+                    break;
+                case "CreateDate":
+                    userProfit.setCreateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+                case "UpdateDate":
+                    userProfit.setUpdateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+            }
+        }
+
+        if(operation.equals(OperationType.INSERT)){
+
+            baseMapper.insert(userProfit);
+        }
+    }
+}
+

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

@@ -0,0 +1,92 @@
+package com.kxs.transfer.api.service.user;
+
+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.KxsUserProfitMapper;
+import com.kxs.transfer.api.model.table.DMLData;
+import com.kxs.user.api.model.KxsUserProfit;
+import com.kxs.user.api.model.KxsUserReReal;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户分润表pos(KxsUserProfit)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Service("kxsUserProfitService")
+public class KxsUserProfitService extends ServiceImpl<KxsUserProfitMapper, KxsUserProfit> {
+
+    public void changeData(DMLData dmlData) {
+        //修改的字段值
+        Map<String, Object> validFieldDataMap = dmlData.getValidFieldDataMap();
+        //修改的字段
+        List<String> changeFieldList = dmlData.getChangeFieldList();
+        //操作的主键
+        int id = Integer.parseInt(dmlData.getId());
+
+        KxsUserProfit userProfit = new KxsUserProfit();
+        userProfit.setId(id);
+        //操作类型
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            // 更新数据
+            baseMapper.deleteById(id);
+            return;
+        }
+        for (String field : changeFieldList) {
+
+            switch (field) {
+                case "UserId":
+                    userProfit.setUserId(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "Version":
+                    userProfit.setStatus(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "SeoTitle":
+                    userProfit.setProfitMonth(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "SeoDescription":
+                    String tradeType = validFieldDataMap.get(field).toString();
+                    if("存量".equals(tradeType)){
+                        userProfit.setTradeType(1);
+                    }else{
+                        userProfit.setTradeType(0);
+                    }
+                    break;
+                case "BrandId":
+                    userProfit.setBrandId(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "ProfitAmount":
+                    userProfit.setProfitAmt(new BigDecimal(validFieldDataMap.get(field).toString()));
+                    break;
+                case "DirectFlag":
+                    int isTeam = Integer.parseInt(validFieldDataMap.get(field).toString());
+                    if(isTeam == 0){
+                        userProfit.setIsTeam(1);
+                    }else{
+                        userProfit.setIsTeam(0);
+                    }
+                    break;
+                case "CreateDate":
+                    userProfit.setCreateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+                case "UpdateDate":
+                    userProfit.setUpdateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+            }
+        }
+
+        if(operation.equals(OperationType.INSERT)){
+
+            baseMapper.insert(userProfit);
+        }
+    }
+}
+

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

@@ -0,0 +1,86 @@
+package com.kxs.transfer.api.service.user;
+
+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.KxsUserProfitZlbMapper;
+import com.kxs.transfer.api.model.table.DMLData;
+import com.kxs.user.api.model.KxsUserProfit;
+import com.kxs.user.api.model.KxsUserProfitZlb;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户分润表助力宝(KxsUserProfitZlb)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:45:00
+ */
+@Service("kxsUserProfitZlbService")
+public class KxsUserProfitZlbService extends ServiceImpl<KxsUserProfitZlbMapper, KxsUserProfitZlb> {
+
+    public void changeData(DMLData dmlData) {
+        //修改的字段值
+        Map<String, Object> validFieldDataMap = dmlData.getValidFieldDataMap();
+        //修改的字段
+        List<String> changeFieldList = dmlData.getChangeFieldList();
+        //操作的主键
+        int id = Integer.parseInt(dmlData.getId());
+
+        KxsUserProfitZlb userProfit = new KxsUserProfitZlb();
+        userProfit.setId(id);
+        //操作类型
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            // 更新数据
+            baseMapper.deleteById(id);
+            return;
+        }
+        for (String field : changeFieldList) {
+
+            switch (field) {
+                case "UserId":
+                    userProfit.setUserId(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "Version":
+                    userProfit.setStatus(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "TradeMonth":
+                    userProfit.setProfitMonth(Integer.valueOf(validFieldDataMap.get(field).toString()));
+                    break;
+                case "CreditTradeAmt":
+                    userProfit.setTradeAmt(new BigDecimal(validFieldDataMap.get(field).toString()));
+                    break;
+                case "CreditRewardAmount":
+                    userProfit.setProfitAmt(new BigDecimal(validFieldDataMap.get(field).toString()));
+                    break;
+                case "RewardType":
+                    int isTeam = Integer.parseInt(validFieldDataMap.get(field).toString());
+                    if(isTeam == 1){
+                        userProfit.setIsTeam(0);
+                    }else if(isTeam == 112){
+                        userProfit.setIsTeam(1);
+                    }else{
+                        return;
+                    }
+                    break;
+                case "CreateDate":
+                    userProfit.setCreateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+                case "UpdateDate":
+                    userProfit.setUpdateTime(LocalDateTimeUtil.parse(validFieldDataMap.get(field).toString(), DatePattern.NORM_DATETIME_PATTERN));
+                    break;
+            }
+        }
+
+        if(operation.equals(OperationType.INSERT)){
+
+            baseMapper.insert(userProfit);
+        }
+    }
+}
+

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

@@ -0,0 +1,136 @@
+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;
+
+/**
+ * 用户分润表pos(KxsUserProfit)表实体类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class KxsUserProfit extends Model<KxsUserProfit> 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;
+
+
+    /**
+     * 用户ID
+     */
+    @Schema(description = "用户ID")
+    private Integer userId;
+
+
+    /**
+     * 分润金额
+     */
+    @Schema(description = "分润金额")
+    private BigDecimal profitAmt;
+
+
+    /**
+     * 状态 0待入账 1已入账
+     */
+    @Schema(description = "状态 0待入账 1已入账")
+    private Integer status;
+
+
+    /**
+     * 分润月
+     */
+    @Schema(description = "分润月")
+    private Integer profitMonth;
+
+
+    /**
+     * 备注
+     */
+    @Schema(description = "备注")
+    private String remark;
+
+
+    /**
+     * 品牌ID
+     */
+    @Schema(description = "品牌ID")
+    private Integer brandId;
+
+
+    /**
+     * 品牌名称
+     */
+    @Schema(description = "品牌名称")
+    private String brandName;
+
+
+    /**
+     * 交易类型 0新增 1存量
+     */
+    @Schema(description = "交易类型 0新增 1存量")
+    private Integer tradeType;
+
+
+    /**
+     * 分润来源 0 直营 1团队
+     */
+    @Schema(description = "分润来源 0 直营 1团队")
+    private Integer isTeam;
+
+
+
+
+}
+

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

@@ -0,0 +1,122 @@
+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;
+
+/**
+ * 用户分润表来客吧(KxsUserProfitLkb)表实体类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class KxsUserProfitLkb extends Model<KxsUserProfitLkb> 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;
+
+
+    /**
+     * 用户ID
+     */
+    @Schema(description = "用户ID")
+    private Integer userId;
+
+
+    /**
+     * 分润金额
+     */
+    @Schema(description = "分润金额")
+    private BigDecimal profitAmt;
+
+
+    /**
+     * 状态 0待入账 1已入账
+     */
+    @Schema(description = "状态 0待入账 1已入账")
+    private Integer status;
+
+
+    /**
+     * 分润月
+     */
+    @Schema(description = "分润月")
+    private Integer profitMonth;
+
+
+    /**
+     * 备注
+     */
+    @Schema(description = "备注")
+    private String remark;
+
+
+    /**
+     * 交易类型 0直联    1银联
+     */
+    @Schema(description = "交易类型 0直联    1银联")
+    private Integer tradeType;
+
+
+    /**
+     * 分润来源 0 直营 1团队
+     */
+    @Schema(description = "分润来源 0 直营 1团队")
+    private Integer isTeam;
+
+
+
+
+}
+

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

@@ -0,0 +1,122 @@
+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;
+
+/**
+ * 用户分润表助力宝(KxsUserProfitZlb)表实体类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class KxsUserProfitZlb extends Model<KxsUserProfitZlb> 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;
+
+
+    /**
+     * 用户ID
+     */
+    @Schema(description = "用户ID")
+    private Integer userId;
+
+
+    /**
+     * 分润金额
+     */
+    @Schema(description = "分润金额")
+    private BigDecimal profitAmt;
+
+
+    /**
+     * 状态 0待入账 1已入账
+     */
+    @Schema(description = "状态 0待入账 1已入账")
+    private Integer status;
+
+
+    /**
+     * 分润月
+     */
+    @Schema(description = "分润月")
+    private Integer profitMonth;
+
+
+    /**
+     * 备注
+     */
+    @Schema(description = "备注")
+    private String remark;
+
+
+    /**
+     * 分润来源 0 直营 1团队
+     */
+    @Schema(description = "分润来源 0 直营 1团队")
+    private Integer isTeam;
+
+
+    /**
+     * 交易额
+     */
+    @Schema(description = "交易额")
+    private BigDecimal tradeAmt;
+
+
+
+
+}
+

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

@@ -0,0 +1,17 @@
+package com.kxs.user.biz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsUserProfitLkb;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户分润表来客吧(KxsUserProfitLkb)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Mapper
+public interface KxsUserProfitLkbMapper extends BaseMapper<KxsUserProfitLkb> {
+
+}
+

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

@@ -0,0 +1,17 @@
+package com.kxs.user.biz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsUserProfit;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户分润表pos(KxsUserProfit)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Mapper
+public interface KxsUserProfitMapper extends BaseMapper<KxsUserProfit> {
+
+}
+

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

@@ -0,0 +1,17 @@
+package com.kxs.user.biz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsUserProfitZlb;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 用户分润表助力宝(KxsUserProfitZlb)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Mapper
+public interface KxsUserProfitZlbMapper extends BaseMapper<KxsUserProfitZlb> {
+
+}
+

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

@@ -0,0 +1,15 @@
+package com.kxs.user.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.kxs.user.api.model.KxsUserProfitLkb;
+
+/**
+ * 用户分润表来客吧(KxsUserProfitLkb)表服务接口
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+public interface KxsUserProfitLkbService extends IService<KxsUserProfitLkb> {
+
+}
+

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

@@ -0,0 +1,15 @@
+package com.kxs.user.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.kxs.user.api.model.KxsUserProfit;
+
+/**
+ * 用户分润表pos(KxsUserProfit)表服务接口
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+public interface KxsUserProfitService extends IService<KxsUserProfit> {
+
+}
+

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

@@ -0,0 +1,15 @@
+package com.kxs.user.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.kxs.user.api.model.KxsUserProfitZlb;
+
+/**
+ * 用户分润表助力宝(KxsUserProfitZlb)表服务接口
+ *
+ * @author 系统
+ * @since 2024-07-22 11:45:00
+ */
+public interface KxsUserProfitZlbService extends IService<KxsUserProfitZlb> {
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsUserProfitLkbServiceImpl.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.KxsUserProfitLkbMapper;
+import com.kxs.user.api.model.KxsUserProfitLkb;
+import com.kxs.user.biz.service.KxsUserProfitLkbService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 用户分润表来客吧(KxsUserProfitLkb)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Service("kxsUserProfitLkbService")
+public class KxsUserProfitLkbServiceImpl extends ServiceImpl<KxsUserProfitLkbMapper, KxsUserProfitLkb> implements KxsUserProfitLkbService {
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsUserProfitServiceImpl.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.KxsUserProfitMapper;
+import com.kxs.user.api.model.KxsUserProfit;
+import com.kxs.user.biz.service.KxsUserProfitService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 用户分润表pos(KxsUserProfit)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:44:59
+ */
+@Service("kxsUserProfitService")
+public class KxsUserProfitServiceImpl extends ServiceImpl<KxsUserProfitMapper, KxsUserProfit> implements KxsUserProfitService {
+
+}
+

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/service/impl/KxsUserProfitZlbServiceImpl.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.KxsUserProfitZlbMapper;
+import com.kxs.user.api.model.KxsUserProfitZlb;
+import com.kxs.user.biz.service.KxsUserProfitZlbService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 用户分润表助力宝(KxsUserProfitZlb)表服务实现类
+ *
+ * @author 系统
+ * @since 2024-07-22 11:45:00
+ */
+@Service("kxsUserProfitZlbService")
+public class KxsUserProfitZlbServiceImpl extends ServiceImpl<KxsUserProfitZlbMapper, KxsUserProfitZlb> implements KxsUserProfitZlbService {
+
+}
+

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

@@ -0,0 +1,21 @@
+<?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.KxsUserProfitLkbMapper">
+
+    <resultMap type="com.kxs.user.api.model.KxsUserProfitLkb" id="KxsUserProfitLkbMap">
+        <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="profit_amt" property="profitAmt" />
+        <result column="status" property="status" />
+        <result column="profit_month" property="profitMonth" />
+        <result column="remark" property="remark" />
+        <result column="trade_type" property="tradeType" />
+        <result column="is_team" property="isTeam" />
+
+    </resultMap>
+
+</mapper>

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

@@ -0,0 +1,23 @@
+<?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.KxsUserProfitMapper">
+
+    <resultMap type="com.kxs.user.api.model.KxsUserProfit" id="KxsUserProfitMap">
+        <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="profit_amt" property="profitAmt" />
+        <result column="status" property="status" />
+        <result column="profit_month" property="profitMonth" />
+        <result column="remark" property="remark" />
+        <result column="brand_id" property="brandId" />
+        <result column="brand_name" property="brandName" />
+        <result column="trade_type" property="tradeType" />
+        <result column="is_team" property="isTeam" />
+
+    </resultMap>
+
+</mapper>

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

@@ -0,0 +1,21 @@
+<?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.KxsUserProfitZlbMapper">
+
+    <resultMap type="com.kxs.user.api.model.KxsUserProfitZlb" id="KxsUserProfitZlbMap">
+        <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="profit_amt" property="profitAmt" />
+        <result column="status" property="status" />
+        <result column="profit_month" property="profitMonth" />
+        <result column="remark" property="remark" />
+        <result column="is_team" property="isTeam" />
+        <result column="trade_amt" property="tradeAmt" />
+
+    </resultMap>
+
+</mapper>