修改redis db

src/main/java/com/lanren/huhu/partner/constants/Constants.java

@@ -15,10 +15,15 @@ import java.util.Map;
 public class Constants {
     public static final String AGENT_REWARD_QUEUE_KEY = "agent_reward_redis_city_key";
     public static final int AGENT_REWARD_TYPE_YEAR_VIP = 710;
+    public static final String AGENT_REWARD_TYPE_YEAR_VIP_REMARK = "城市代理商所得的购买年-VIP";
     public static final int AGENT_REWARD_TYPE_HALF_YEAR_VIP = 720;
+    public static final String AGENT_REWARD_TYPE_HALF_YEAR_VIP_REMARK = "城市代理商所得的购买半年-VIP";
     public static final int AGENT_REWARD_TYPE_SVIP = 730;
+    public static final String AGENT_REWARD_TYPE_SVIP_REMARK = "城市代理商所得的购买超级VIP收益";
     public static final int AGENT_REWARD_TYPE_ORDER_AND_REDPACK = 740;
+    public static final String AGENT_REWARD_TYPE_ORDER_AND_REDPACK_REMARK = "城市代理商的CPS 收益（所有商品购物相关收益）和购买红包订单收益";
     public static Map<Integer, Map<Integer, BigDecimal>> AGENT_RATE_MAP = new HashMap<Integer, Map<Integer, BigDecimal>>();
+    public static Map<Integer, String> AGENT_REWARD_REMARK = new HashMap<Integer, String>();
     public static final int AGENT_LEVEL_1 = 1;
     public static final int AGENT_LEVEL_2 = 2;
     public static final int AGENT_LEVEL_3 = 3;
@@ -47,5 +52,10 @@ public class Constants {
         AGENT_RATE_MAP.get(AGENT_REWARD_TYPE_ORDER_AND_REDPACK).put(0, new BigDecimal("0.03"));
         AGENT_RATE_MAP.get(AGENT_REWARD_TYPE_ORDER_AND_REDPACK).put(1, new BigDecimal("0.02"));
         AGENT_RATE_MAP.get(AGENT_REWARD_TYPE_ORDER_AND_REDPACK).put(2, new BigDecimal("0.01"));
+
+        AGENT_REWARD_REMARK.put(AGENT_REWARD_TYPE_YEAR_VIP, AGENT_REWARD_TYPE_YEAR_VIP_REMARK);
+        AGENT_REWARD_REMARK.put(AGENT_REWARD_TYPE_HALF_YEAR_VIP, AGENT_REWARD_TYPE_HALF_YEAR_VIP_REMARK);
+        AGENT_REWARD_REMARK.put(AGENT_REWARD_TYPE_SVIP, AGENT_REWARD_TYPE_SVIP_REMARK);
+        AGENT_REWARD_REMARK.put(AGENT_REWARD_TYPE_ORDER_AND_REDPACK, AGENT_REWARD_TYPE_ORDER_AND_REDPACK_REMARK);
     }
 }

src/main/java/com/lanren/huhu/partner/dao/PartnerActivationRelationRecordMapper.java

+package com.lanren.huhu.partner.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.lanren.huhu.partner.domain.PartnerActivationRelationRecord;
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface PartnerActivationRelationRecordMapper extends BaseMapper<PartnerActivationRelationRecord> {
+    int updateBatch(List<PartnerActivationRelationRecord> list);
+
+    int batchInsert(@Param("list") List<PartnerActivationRelationRecord> list);
+
+    int insertOrUpdate(PartnerActivationRelationRecord record);
+
+    int insertOrUpdateSelective(PartnerActivationRelationRecord record);
+}
\ No newline at end of file

src/main/java/com/lanren/huhu/partner/dao/PartnerPurchaseRewardRecordMapper.java

+package com.lanren.huhu.partner.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.lanren.huhu.partner.domain.PartnerPurchaseRewardRecord;
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface PartnerPurchaseRewardRecordMapper extends BaseMapper<PartnerPurchaseRewardRecord> {
+    int updateBatch(List<PartnerPurchaseRewardRecord> list);
+
+    int batchInsert(@Param("list") List<PartnerPurchaseRewardRecord> list);
+
+    int insertOrUpdate(PartnerPurchaseRewardRecord record);
+
+    int insertOrUpdateSelective(PartnerPurchaseRewardRecord record);
+}
\ No newline at end of file

src/main/java/com/lanren/huhu/partner/dao/PartnerRevokeRecordsMapper.java

+package com.lanren.huhu.partner.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.lanren.huhu.partner.domain.PartnerRevokeRecords;
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface PartnerRevokeRecordsMapper extends BaseMapper<PartnerRevokeRecords> {
+    int updateBatch(List<PartnerRevokeRecords> list);
+
+    int batchInsert(@Param("list") List<PartnerRevokeRecords> list);
+
+    int insertOrUpdate(PartnerRevokeRecords record);
+
+    int insertOrUpdateSelective(PartnerRevokeRecords record);
+}
\ No newline at end of file

src/main/java/com/lanren/huhu/partner/domain/PartnerActivationRelationRecord.java

+package com.lanren.huhu.partner.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import lombok.Data;
+
+@Data
+@TableName(value = "partner_activation_relation_record")
+public class PartnerActivationRelationRecord implements Serializable {
+    /**
+     * 主键
+     */
+     @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 激活奖励规则表主键
+     */
+    @TableField(value = "rid")
+    private Integer rid;
+
+    /**
+     * 激活得订单号
+     */
+    @TableField(value = "active_order_id")
+    private String activeOrderId;
+
+    /**
+     * 激活得订单号类型
+     */
+    @TableField(value = "active_order_type")
+    private String activeOrderType;
+
+    /**
+     * 直接邀请人ID
+     */
+    @TableField(value = "invite_user_id")
+    private Integer inviteUserId;
+
+    /**
+     * 直接奖励类型 默认0、10现金 20 红包
+     */
+    @TableField(value = "invite_reward_type")
+    private Integer inviteRewardType;
+
+    /**
+     * 直接奖励金额
+     */
+    @TableField(value = "invite_amout")
+    private BigDecimal inviteAmout;
+
+    /**
+     * 间接邀请人ID
+     */
+    @TableField(value = "indirect_invite_uid")
+    private Integer indirectInviteUid;
+
+    /**
+     * 间接奖励类型 默认0、10现金 20 红包
+     */
+    @TableField(value = "indirect_reward_type")
+    private Integer indirectRewardType;
+
+    /**
+     * 间接奖励金额
+     */
+    @TableField(value = "indirect_amout")
+    private BigDecimal indirectAmout;
+
+    /**
+     * 10待奖励  20已结算（高伟 由10改为20） 120 已结算（关晨 由10->120） 30 已返回
+     */
+    @TableField(value = "reward_state")
+    private Integer rewardState;
+
+    /**
+     * 激活时间
+     */
+    @TableField(value = "active_time")
+    private Integer activeTime;
+
+    /**
+     * 结算时间
+     */
+    @TableField(value = "settle_time")
+    private Integer settleTime;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_at")
+    private Integer createdAt;
+
+    /**
+     * 修改时间
+     */
+    @TableField(value = "updated_at")
+    private Integer updatedAt;
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String COL_RID = "rid";
+
+    public static final String COL_ACTIVE_ORDER_ID = "active_order_id";
+
+    public static final String COL_ACTIVE_ORDER_TYPE = "active_order_type";
+
+    public static final String COL_INVITE_USER_ID = "invite_user_id";
+
+    public static final String COL_INVITE_REWARD_TYPE = "invite_reward_type";
+
+    public static final String COL_INVITE_AMOUT = "invite_amout";
+
+    public static final String COL_INDIRECT_INVITE_UID = "indirect_invite_uid";
+
+    public static final String COL_INDIRECT_REWARD_TYPE = "indirect_reward_type";
+
+    public static final String COL_INDIRECT_AMOUT = "indirect_amout";
+
+    public static final String COL_REWARD_STATE = "reward_state";
+
+    public static final String COL_ACTIVE_TIME = "active_time";
+
+    public static final String COL_SETTLE_TIME = "settle_time";
+
+    public static final String COL_CREATED_AT = "created_at";
+
+    public static final String COL_UPDATED_AT = "updated_at";
+}
\ No newline at end of file

src/main/java/com/lanren/huhu/partner/domain/PartnerPurchaseRewardRecord.java

+package com.lanren.huhu.partner.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import lombok.Data;
+
+@Data
+@TableName(value = "partner_purchase_reward_record")
+public class PartnerPurchaseRewardRecord implements Serializable {
+    /**
+     * 主键
+     */
+     @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 贡献人ID
+     */
+    @TableField(value = "user_id")
+    private Integer userId;
+
+    /**
+     * 贡献人级别快照 默认0 普通10 高级20 超级30
+     */
+    @TableField(value = "user_level")
+    private Integer userLevel;
+
+    /**
+     * 激活的订单号
+     */
+    @TableField(value = "active_order_id")
+    private String activeOrderId;
+
+    /**
+     * 激活得订单号类型
+     */
+    @TableField(value = "active_order_type")
+    private String activeOrderType;
+
+    /**
+     * 激活得订单号金额
+     */
+    @TableField(value = "active_order_cash")
+    private BigDecimal activeOrderCash;
+
+    /**
+     * 购物返现比例
+     */
+    @TableField(value = "active_return_cash_proportion")
+    private BigDecimal activeReturnCashProportion;
+
+    /**
+     * 直接邀请人ID
+     */
+    @TableField(value = "invite_user_id")
+    private Integer inviteUserId;
+
+    /**
+     * 直接奖励类型 默认0、10现金 20 红包
+     */
+    @TableField(value = "invite_reward_type")
+    private Integer inviteRewardType;
+
+    /**
+     * 直接级别快照 默认0 普通10 高级20 超级30
+     */
+    @TableField(value = "invite_partner_level")
+    private Integer invitePartnerLevel;
+
+    /**
+     * 直接奖励金额
+     */
+    @TableField(value = "invite_amout")
+    private BigDecimal inviteAmout;
+
+    /**
+     * 奖励类型  0 默认 10 直接 20 间接
+     */
+    @TableField(value = "reward_type")
+    private Integer rewardType;
+
+    /**
+     * 100待奖励 ;120已结算
+     */
+    @TableField(value = "reward_state")
+    private Integer rewardState;
+
+    /**
+     * 激活时间
+     */
+    @TableField(value = "active_time")
+    private Integer activeTime;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_at")
+    private Integer createdAt;
+
+    /**
+     * 修改时间
+     */
+    @TableField(value = "updated_at")
+    private Integer updatedAt;
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String COL_USER_ID = "user_id";
+
+    public static final String COL_USER_LEVEL = "user_level";
+
+    public static final String COL_ACTIVE_ORDER_ID = "active_order_id";
+
+    public static final String COL_ACTIVE_ORDER_TYPE = "active_order_type";
+
+    public static final String COL_ACTIVE_ORDER_CASH = "active_order_cash";
+
+    public static final String COL_ACTIVE_RETURN_CASH_PROPORTION = "active_return_cash_proportion";
+
+    public static final String COL_INVITE_USER_ID = "invite_user_id";
+
+    public static final String COL_INVITE_REWARD_TYPE = "invite_reward_type";
+
+    public static final String COL_INVITE_PARTNER_LEVEL = "invite_partner_level";
+
+    public static final String COL_INVITE_AMOUT = "invite_amout";
+
+    public static final String COL_REWARD_TYPE = "reward_type";
+
+    public static final String COL_REWARD_STATE = "reward_state";
+
+    public static final String COL_ACTIVE_TIME = "active_time";
+
+    public static final String COL_CREATED_AT = "created_at";
+
+    public static final String COL_UPDATED_AT = "updated_at";
+}
\ No newline at end of file

src/main/java/com/lanren/huhu/partner/domain/PartnerRevokeRecords.java

+package com.lanren.huhu.partner.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import lombok.Data;
+
+@Data
+@TableName(value = "partner_revoke_records")
+public class PartnerRevokeRecords implements Serializable {
+    /**
+     * 主键id
+     */
+     @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 订单id
+     */
+    @TableField(value = "order_id")
+    private String orderId;
+
+    /**
+     * 用户id(被邀请者的用户id)
+     */
+    @TableField(value = "user_id")
+    private Long userId;
+
+    /**
+     * 回收的关联id
+     */
+    @TableField(value = "ref_id")
+    private String refId;
+
+    /**
+     * 回收类型:100 邀请奖励的回收,120分享赚奖励的回收
+     */
+    @TableField(value = "revoke_type")
+    private Integer revokeType;
+
+    /**
+     * 100 未处理 200处理成功
+     */
+    @TableField(value = "state")
+    private Integer state;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "created_at")
+    private Long createdAt;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "updated_at")
+    private Long updatedAt;
+
+    /**
+     * 订单类型
+     */
+    @TableField(value = "order_type")
+    private String orderType;
+
+    /**
+     * 订单号
+     */
+    @TableField(value = "order_sn")
+    private String orderSn;
+
+    /**
+     * 子订单号
+     */
+    @TableField(value = "sub_order_sn")
+    private String subOrderSn;
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String COL_ORDER_ID = "order_id";
+
+    public static final String COL_USER_ID = "user_id";
+
+    public static final String COL_REF_ID = "ref_id";
+
+    public static final String COL_REVOKE_TYPE = "revoke_type";
+
+    public static final String COL_STATE = "state";
+
+    public static final String COL_CREATED_AT = "created_at";
+
+    public static final String COL_UPDATED_AT = "updated_at";
+
+    public static final String COL_ORDER_TYPE = "order_type";
+
+    public static final String COL_ORDER_SN = "order_sn";
+
+    public static final String COL_SUB_ORDER_SN = "sub_order_sn";
+}
\ No newline at end of file

src/main/java/com/lanren/huhu/partner/schedule/AgentRewardQueueTask.java

@@ -162,7 +162,12 @@ public class AgentRewardQueueTask {
                     logger.info("插入代理商分成奖励,奖励比例: {}, 代理商: {}", commissionRate, rewardList.get(i));
                 } else {
                     logger.error("插入失败, 写回到队列");
-//                    ops.leftPush(AGENT_REWARD_QUEUE_KEY, JSON.toJSONString(message));
+                    ops.leftPush(AGENT_REWARD_QUEUE_KEY, JSON.toJSONString(message));
+                    try {
+                        Thread.sleep(5 * 1000L);
+                    } catch (InterruptedException e) {
+                        logger.error(e.getMessage(), e);
+                    }
                 }
             }
         }
@@ -170,7 +175,6 @@ public class AgentRewardQueueTask {
 
     private boolean doInsert(BigDecimal commissionRate, ParentAgent agent, AgentRewardMessage message) {
         try {
-            int partnerLevel = partnerAccountService.getOneByUserId(agent.getUserId()).getPartnerLevel();
             int sourceUserLevel = partnerAccountService.getOneByUserId(message.getSourceUserId()).getPartnerLevel();
             AgentReward agentReward = new AgentReward();
             agentReward.setRewardType(message.getRewardType());
@@ -178,20 +182,30 @@ public class AgentRewardQueueTask {
             agentReward.setSourceUserId(message.getSourceUserId());
             agentReward.setReferenceId(Long.parseLong(message.getReferenceId()));
             agentReward.setAgentId(agent.getAgentId());
-            agentReward.setCommissionAcount(message.getAgentReward().multiply(commissionRate));
-            agentReward.setCommissionRate(commissionRate);
             agentReward.setSettleState(message.getSettleState());
             agentReward.setOrderType(message.getOrderType());
             agentReward.setOrderSn(message.getOrderSn());
             agentReward.setSubOrderSn(message.getSubOrderSn());
-            agentReward.setMoney(message.getOrderCommission());
             agentReward.setAgentLevel(agent.getLevel());
             agentReward.setUserId(agent.getUserId());
-            agentReward.setRewardRemark("测试");
-            agentReward.setAmount(message.getAgentReward().multiply(commissionRate));
+            agentReward.setRewardRemark(AGENT_REWARD_REMARK.get(message.getRewardType()));
             agentReward.setSourceOrder(message.getReferenceId());
             agentReward.setSourceUserLevel(sourceUserLevel);
             agentReward.setCreatedAt(System.currentTimeMillis() / 1000L);
+            agentReward.setCommissionRate(commissionRate);
+            /**
+             * agent_reward里:
+             * money 面额(message里, 需要上供的代理商自己获得的奖励)
+             * commission_account 面额
+             * amount 奖励金额
+             * commission 奖励金额
+             * cash_code 支付金额
+             */
+            agentReward.setMoney(message.getAgentReward());
+            agentReward.setCommissionAcount(message.getAgentReward());
+            agentReward.setAmount(message.getAgentReward().multiply(commissionRate));
+            agentReward.setCommission(message.getAgentReward().multiply(commissionRate));
+            agentReward.setCashCode("0");
             return agentRewardService.save(agentReward);
         } catch (Exception e) {
             logger.error(e.getMessage(), e);

src/main/java/com/lanren/huhu/partner/service/PartnerActivationRelationRecordService.java

+package com.lanren.huhu.partner.service;
+
+import java.util.List;
+import com.lanren.huhu.partner.domain.PartnerActivationRelationRecord;
+import com.baomidou.mybatisplus.extension.service.IService;
+    /**  
+    * @title: ${NAME}
+    * @projectName partner
+    * @author chen
+    * @package ${PACKAGE_NAME}
+    * @date 2019-07-02 16:26
+    */
+public interface PartnerActivationRelationRecordService extends IService<PartnerActivationRelationRecord>{
+
+
+    int updateBatch(List<PartnerActivationRelationRecord> list);
+
+    int batchInsert(List<PartnerActivationRelationRecord> list);
+
+    int insertOrUpdate(PartnerActivationRelationRecord record);
+
+    int insertOrUpdateSelective(PartnerActivationRelationRecord record);
+
+}

src/main/java/com/lanren/huhu/partner/service/PartnerPurchaseRewardRecordService.java

+package com.lanren.huhu.partner.service;
+
+import com.lanren.huhu.partner.domain.PartnerPurchaseRewardRecord;
+import java.util.List;
+import com.baomidou.mybatisplus.extension.service.IService;
+    /**  
+    * @title: ${NAME}
+    * @projectName partner
+    * @author chen
+    * @package ${PACKAGE_NAME}
+    * @date 2019-07-02 16:28
+    */
+public interface PartnerPurchaseRewardRecordService extends IService<PartnerPurchaseRewardRecord>{
+
+
+    int updateBatch(List<PartnerPurchaseRewardRecord> list);
+
+    int batchInsert(List<PartnerPurchaseRewardRecord> list);
+
+    int insertOrUpdate(PartnerPurchaseRewardRecord record);
+
+    int insertOrUpdateSelective(PartnerPurchaseRewardRecord record);
+
+}

src/main/java/com/lanren/huhu/partner/service/PartnerRevokeRecordsService.java

+package com.lanren.huhu.partner.service;
+
+import java.util.List;
+import com.lanren.huhu.partner.domain.PartnerRevokeRecords;
+import com.baomidou.mybatisplus.extension.service.IService;
+    /**  
+    * @title: ${NAME}
+    * @projectName partner
+    * @author chen
+    * @package ${PACKAGE_NAME}
+    * @date 2019-07-02 16:26
+    */
+public interface PartnerRevokeRecordsService extends IService<PartnerRevokeRecords>{
+
+
+    int updateBatch(List<PartnerRevokeRecords> list);
+
+    int batchInsert(List<PartnerRevokeRecords> list);
+
+    int insertOrUpdate(PartnerRevokeRecords record);
+
+    int insertOrUpdateSelective(PartnerRevokeRecords record);
+
+}

src/main/java/com/lanren/huhu/partner/service/impl/PartnerActivationRelationRecordServiceImpl.java

+package com.lanren.huhu.partner.service.impl;
+
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.List;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import java.util.List;
+import com.lanren.huhu.partner.dao.PartnerActivationRelationRecordMapper;
+import com.lanren.huhu.partner.domain.PartnerActivationRelationRecord;
+import com.lanren.huhu.partner.service.PartnerActivationRelationRecordService;
+/**  
+    * @title: ${NAME}
+    * @projectName partner
+    * @author chen
+    * @package ${PACKAGE_NAME}
+    * @date 2019-07-02 16:26
+    */
+@Service
+public class PartnerActivationRelationRecordServiceImpl extends ServiceImpl<PartnerActivationRelationRecordMapper, PartnerActivationRelationRecord> implements PartnerActivationRelationRecordService{
+
+    @Override
+    public int updateBatch(List<PartnerActivationRelationRecord> list) {
+        return baseMapper.updateBatch(list);
+    }
+    @Override
+    public int batchInsert(List<PartnerActivationRelationRecord> list) {
+        return baseMapper.batchInsert(list);
+    }
+    @Override
+    public int insertOrUpdate(PartnerActivationRelationRecord record) {
+        return baseMapper.insertOrUpdate(record);
+    }
+    @Override
+    public int insertOrUpdateSelective(PartnerActivationRelationRecord record) {
+        return baseMapper.insertOrUpdateSelective(record);
+    }
+}

src/main/java/com/lanren/huhu/partner/service/impl/PartnerPurchaseRewardRecordServiceImpl.java

+package com.lanren.huhu.partner.service.impl;
+
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.List;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.lanren.huhu.partner.domain.PartnerPurchaseRewardRecord;
+import java.util.List;
+import com.lanren.huhu.partner.dao.PartnerPurchaseRewardRecordMapper;
+import com.lanren.huhu.partner.service.PartnerPurchaseRewardRecordService;
+/**  
+    * @title: ${NAME}
+    * @projectName partner
+    * @author chen
+    * @package ${PACKAGE_NAME}
+    * @date 2019-07-02 16:28
+    */
+@Service
+public class PartnerPurchaseRewardRecordServiceImpl extends ServiceImpl<PartnerPurchaseRewardRecordMapper, PartnerPurchaseRewardRecord> implements PartnerPurchaseRewardRecordService{
+
+    @Override
+    public int updateBatch(List<PartnerPurchaseRewardRecord> list) {
+        return baseMapper.updateBatch(list);
+    }
+    @Override
+    public int batchInsert(List<PartnerPurchaseRewardRecord> list) {
+        return baseMapper.batchInsert(list);
+    }
+    @Override
+    public int insertOrUpdate(PartnerPurchaseRewardRecord record) {
+        return baseMapper.insertOrUpdate(record);
+    }
+    @Override
+    public int insertOrUpdateSelective(PartnerPurchaseRewardRecord record) {
+        return baseMapper.insertOrUpdateSelective(record);
+    }
+}

src/main/java/com/lanren/huhu/partner/service/impl/PartnerRevokeRecordsServiceImpl.java

+package com.lanren.huhu.partner.service.impl;
+
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.List;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import java.util.List;
+import com.lanren.huhu.partner.dao.PartnerRevokeRecordsMapper;
+import com.lanren.huhu.partner.domain.PartnerRevokeRecords;
+import com.lanren.huhu.partner.service.PartnerRevokeRecordsService;
+/**  
+    * @title: ${NAME}
+    * @projectName partner
+    * @author chen
+    * @package ${PACKAGE_NAME}
+    * @date 2019-07-02 16:26
+    */
+@Service
+public class PartnerRevokeRecordsServiceImpl extends ServiceImpl<PartnerRevokeRecordsMapper, PartnerRevokeRecords> implements PartnerRevokeRecordsService{
+
+    @Override
+    public int updateBatch(List<PartnerRevokeRecords> list) {
+        return baseMapper.updateBatch(list);
+    }
+    @Override
+    public int batchInsert(List<PartnerRevokeRecords> list) {
+        return baseMapper.batchInsert(list);
+    }
+    @Override
+    public int insertOrUpdate(PartnerRevokeRecords record) {
+        return baseMapper.insertOrUpdate(record);
+    }
+    @Override
+    public int insertOrUpdateSelective(PartnerRevokeRecords record) {
+        return baseMapper.insertOrUpdateSelective(record);
+    }
+}

src/main/resources/application.yml

@@ -53,7 +53,7 @@ spring:
   ## Redis 配置
   ## Redis数据库索引（默认为0）
   redis:
-    database: 12
+    database: 13
     ## Redis测试服务器地址
     host: @redis.host@
     ## Redis测试服务器连接端口

src/main/resources/mapper/PartnerActivationRelationRecordMapper.xml

+<?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.lanren.huhu.partner.dao.PartnerActivationRelationRecordMapper">
+  <resultMap id="BaseResultMap" type="com.lanren.huhu.partner.domain.PartnerActivationRelationRecord">
+    <!--@mbg.generated-->
+    <id column="id" property="id" />
+    <result column="rid" property="rid" />
+    <result column="active_order_id" property="activeOrderId" />
+    <result column="active_order_type" property="activeOrderType" />
+    <result column="invite_user_id" property="inviteUserId" />
+    <result column="invite_reward_type" property="inviteRewardType" />
+    <result column="invite_amout" property="inviteAmout" />
+    <result column="indirect_invite_uid" property="indirectInviteUid" />
+    <result column="indirect_reward_type" property="indirectRewardType" />
+    <result column="indirect_amout" property="indirectAmout" />
+    <result column="reward_state" property="rewardState" />
+    <result column="active_time" property="activeTime" />
+    <result column="settle_time" property="settleTime" />
+    <result column="created_at" property="createdAt" />
+    <result column="updated_at" property="updatedAt" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, rid, active_order_id, active_order_type, invite_user_id, invite_reward_type, 
+    invite_amout, indirect_invite_uid, indirect_reward_type, indirect_amout, reward_state, 
+    active_time, settle_time, created_at, updated_at
+  </sql>
+  <update id="updateBatch" parameterType="java.util.List">
+    <!--@mbg.generated-->
+    update partner_activation_relation_record
+    <trim prefix="set" suffixOverrides=",">
+      <trim prefix="rid = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.rid}
+        </foreach>
+      </trim>
+      <trim prefix="active_order_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeOrderId}
+        </foreach>
+      </trim>
+      <trim prefix="active_order_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeOrderType}
+        </foreach>
+      </trim>
+      <trim prefix="invite_user_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.inviteUserId}
+        </foreach>
+      </trim>
+      <trim prefix="invite_reward_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.inviteRewardType}
+        </foreach>
+      </trim>
+      <trim prefix="invite_amout = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.inviteAmout}
+        </foreach>
+      </trim>
+      <trim prefix="indirect_invite_uid = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.indirectInviteUid}
+        </foreach>
+      </trim>
+      <trim prefix="indirect_reward_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.indirectRewardType}
+        </foreach>
+      </trim>
+      <trim prefix="indirect_amout = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.indirectAmout}
+        </foreach>
+      </trim>
+      <trim prefix="reward_state = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.rewardState}
+        </foreach>
+      </trim>
+      <trim prefix="active_time = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeTime}
+        </foreach>
+      </trim>
+      <trim prefix="settle_time = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.settleTime}
+        </foreach>
+      </trim>
+      <trim prefix="created_at = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.createdAt}
+        </foreach>
+      </trim>
+      <trim prefix="updated_at = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.updatedAt}
+        </foreach>
+      </trim>
+    </trim>
+    where id in
+    <foreach close=")" collection="list" item="item" open="(" separator=", ">
+      #{item.id}
+    </foreach>
+  </update>
+  <insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_activation_relation_record
+    (rid, active_order_id, active_order_type, invite_user_id, invite_reward_type, invite_amout, 
+      indirect_invite_uid, indirect_reward_type, indirect_amout, reward_state, active_time, 
+      settle_time, created_at, updated_at)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.rid}, #{item.activeOrderId}, #{item.activeOrderType}, #{item.inviteUserId}, 
+        #{item.inviteRewardType}, #{item.inviteAmout}, #{item.indirectInviteUid}, #{item.indirectRewardType}, 
+        #{item.indirectAmout}, #{item.rewardState}, #{item.activeTime}, #{item.settleTime}, 
+        #{item.createdAt}, #{item.updatedAt})
+    </foreach>
+  </insert>
+  <insert id="insertOrUpdate" keyColumn="id" keyProperty="id" parameterType="com.lanren.huhu.partner.domain.PartnerActivationRelationRecord" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_activation_relation_record
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      rid,
+      active_order_id,
+      active_order_type,
+      invite_user_id,
+      invite_reward_type,
+      invite_amout,
+      indirect_invite_uid,
+      indirect_reward_type,
+      indirect_amout,
+      reward_state,
+      active_time,
+      settle_time,
+      created_at,
+      updated_at,
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id},
+      </if>
+      #{rid},
+      #{activeOrderId},
+      #{activeOrderType},
+      #{inviteUserId},
+      #{inviteRewardType},
+      #{inviteAmout},
+      #{indirectInviteUid},
+      #{indirectRewardType},
+      #{indirectAmout},
+      #{rewardState},
+      #{activeTime},
+      #{settleTime},
+      #{createdAt},
+      #{updatedAt},
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id},
+      </if>
+      rid = #{rid},
+      active_order_id = #{activeOrderId},
+      active_order_type = #{activeOrderType},
+      invite_user_id = #{inviteUserId},
+      invite_reward_type = #{inviteRewardType},
+      invite_amout = #{inviteAmout},
+      indirect_invite_uid = #{indirectInviteUid},
+      indirect_reward_type = #{indirectRewardType},
+      indirect_amout = #{indirectAmout},
+      reward_state = #{rewardState},
+      active_time = #{activeTime},
+      settle_time = #{settleTime},
+      created_at = #{createdAt},
+      updated_at = #{updatedAt},
+    </trim>
+  </insert>
+  <insert id="insertOrUpdateSelective" keyColumn="id" keyProperty="id" parameterType="com.lanren.huhu.partner.domain.PartnerActivationRelationRecord" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_activation_relation_record
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="rid != null">
+        rid,
+      </if>
+      <if test="activeOrderId != null">
+        active_order_id,
+      </if>
+      <if test="activeOrderType != null">
+        active_order_type,
+      </if>
+      <if test="inviteUserId != null">
+        invite_user_id,
+      </if>
+      <if test="inviteRewardType != null">
+        invite_reward_type,
+      </if>
+      <if test="inviteAmout != null">
+        invite_amout,
+      </if>
+      <if test="indirectInviteUid != null">
+        indirect_invite_uid,
+      </if>
+      <if test="indirectRewardType != null">
+        indirect_reward_type,
+      </if>
+      <if test="indirectAmout != null">
+        indirect_amout,
+      </if>
+      <if test="rewardState != null">
+        reward_state,
+      </if>
+      <if test="activeTime != null">
+        active_time,
+      </if>
+      <if test="settleTime != null">
+        settle_time,
+      </if>
+      <if test="createdAt != null">
+        created_at,
+      </if>
+      <if test="updatedAt != null">
+        updated_at,
+      </if>
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id},
+      </if>
+      <if test="rid != null">
+        #{rid},
+      </if>
+      <if test="activeOrderId != null">
+        #{activeOrderId},
+      </if>
+      <if test="activeOrderType != null">
+        #{activeOrderType},
+      </if>
+      <if test="inviteUserId != null">
+        #{inviteUserId},
+      </if>
+      <if test="inviteRewardType != null">
+        #{inviteRewardType},
+      </if>
+      <if test="inviteAmout != null">
+        #{inviteAmout},
+      </if>
+      <if test="indirectInviteUid != null">
+        #{indirectInviteUid},
+      </if>
+      <if test="indirectRewardType != null">
+        #{indirectRewardType},
+      </if>
+      <if test="indirectAmout != null">
+        #{indirectAmout},
+      </if>
+      <if test="rewardState != null">
+        #{rewardState},
+      </if>
+      <if test="activeTime != null">
+        #{activeTime},
+      </if>
+      <if test="settleTime != null">
+        #{settleTime},
+      </if>
+      <if test="createdAt != null">
+        #{createdAt},
+      </if>
+      <if test="updatedAt != null">
+        #{updatedAt},
+      </if>
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id},
+      </if>
+      <if test="rid != null">
+        rid = #{rid},
+      </if>
+      <if test="activeOrderId != null">
+        active_order_id = #{activeOrderId},
+      </if>
+      <if test="activeOrderType != null">
+        active_order_type = #{activeOrderType},
+      </if>
+      <if test="inviteUserId != null">
+        invite_user_id = #{inviteUserId},
+      </if>
+      <if test="inviteRewardType != null">
+        invite_reward_type = #{inviteRewardType},
+      </if>
+      <if test="inviteAmout != null">
+        invite_amout = #{inviteAmout},
+      </if>
+      <if test="indirectInviteUid != null">
+        indirect_invite_uid = #{indirectInviteUid},
+      </if>
+      <if test="indirectRewardType != null">
+        indirect_reward_type = #{indirectRewardType},
+      </if>
+      <if test="indirectAmout != null">
+        indirect_amout = #{indirectAmout},
+      </if>
+      <if test="rewardState != null">
+        reward_state = #{rewardState},
+      </if>
+      <if test="activeTime != null">
+        active_time = #{activeTime},
+      </if>
+      <if test="settleTime != null">
+        settle_time = #{settleTime},
+      </if>
+      <if test="createdAt != null">
+        created_at = #{createdAt},
+      </if>
+      <if test="updatedAt != null">
+        updated_at = #{updatedAt},
+      </if>
+    </trim>
+  </insert>
+</mapper>
\ No newline at end of file

src/main/resources/mapper/PartnerPurchaseRewardRecordMapper.xml

+<?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.lanren.huhu.partner.dao.PartnerPurchaseRewardRecordMapper">
+  <resultMap id="BaseResultMap" type="com.lanren.huhu.partner.domain.PartnerPurchaseRewardRecord">
+    <!--@mbg.generated-->
+    <id column="id" property="id" />
+    <result column="user_id" property="userId" />
+    <result column="user_level" property="userLevel" />
+    <result column="active_order_id" property="activeOrderId" />
+    <result column="active_order_type" property="activeOrderType" />
+    <result column="active_order_cash" property="activeOrderCash" />
+    <result column="active_return_cash_proportion" property="activeReturnCashProportion" />
+    <result column="invite_user_id" property="inviteUserId" />
+    <result column="invite_reward_type" property="inviteRewardType" />
+    <result column="invite_partner_level" property="invitePartnerLevel" />
+    <result column="invite_amout" property="inviteAmout" />
+    <result column="reward_type" property="rewardType" />
+    <result column="reward_state" property="rewardState" />
+    <result column="active_time" property="activeTime" />
+    <result column="created_at" property="createdAt" />
+    <result column="updated_at" property="updatedAt" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, user_id, user_level, active_order_id, active_order_type, active_order_cash, active_return_cash_proportion, 
+    invite_user_id, invite_reward_type, invite_partner_level, invite_amout, reward_type, 
+    reward_state, active_time, created_at, updated_at
+  </sql>
+  <update id="updateBatch" parameterType="java.util.List">
+    <!--@mbg.generated-->
+    update partner_purchase_reward_record
+    <trim prefix="set" suffixOverrides=",">
+      <trim prefix="user_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.userId}
+        </foreach>
+      </trim>
+      <trim prefix="user_level = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.userLevel}
+        </foreach>
+      </trim>
+      <trim prefix="active_order_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeOrderId}
+        </foreach>
+      </trim>
+      <trim prefix="active_order_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeOrderType}
+        </foreach>
+      </trim>
+      <trim prefix="active_order_cash = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeOrderCash}
+        </foreach>
+      </trim>
+      <trim prefix="active_return_cash_proportion = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeReturnCashProportion}
+        </foreach>
+      </trim>
+      <trim prefix="invite_user_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.inviteUserId}
+        </foreach>
+      </trim>
+      <trim prefix="invite_reward_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.inviteRewardType}
+        </foreach>
+      </trim>
+      <trim prefix="invite_partner_level = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.invitePartnerLevel}
+        </foreach>
+      </trim>
+      <trim prefix="invite_amout = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.inviteAmout}
+        </foreach>
+      </trim>
+      <trim prefix="reward_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.rewardType}
+        </foreach>
+      </trim>
+      <trim prefix="reward_state = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.rewardState}
+        </foreach>
+      </trim>
+      <trim prefix="active_time = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.activeTime}
+        </foreach>
+      </trim>
+      <trim prefix="created_at = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.createdAt}
+        </foreach>
+      </trim>
+      <trim prefix="updated_at = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.updatedAt}
+        </foreach>
+      </trim>
+    </trim>
+    where id in
+    <foreach close=")" collection="list" item="item" open="(" separator=", ">
+      #{item.id}
+    </foreach>
+  </update>
+  <insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_purchase_reward_record
+    (user_id, user_level, active_order_id, active_order_type, active_order_cash, active_return_cash_proportion, 
+      invite_user_id, invite_reward_type, invite_partner_level, invite_amout, reward_type, 
+      reward_state, active_time, created_at, updated_at)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.userId}, #{item.userLevel}, #{item.activeOrderId}, #{item.activeOrderType}, 
+        #{item.activeOrderCash}, #{item.activeReturnCashProportion}, #{item.inviteUserId}, 
+        #{item.inviteRewardType}, #{item.invitePartnerLevel}, #{item.inviteAmout}, #{item.rewardType}, 
+        #{item.rewardState}, #{item.activeTime}, #{item.createdAt}, #{item.updatedAt})
+    </foreach>
+  </insert>
+  <insert id="insertOrUpdate" keyColumn="id" keyProperty="id" parameterType="com.lanren.huhu.partner.domain.PartnerPurchaseRewardRecord" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_purchase_reward_record
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      user_id,
+      user_level,
+      active_order_id,
+      active_order_type,
+      active_order_cash,
+      active_return_cash_proportion,
+      invite_user_id,
+      invite_reward_type,
+      invite_partner_level,
+      invite_amout,
+      reward_type,
+      reward_state,
+      active_time,
+      created_at,
+      updated_at,
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id},
+      </if>
+      #{userId},
+      #{userLevel},
+      #{activeOrderId},
+      #{activeOrderType},
+      #{activeOrderCash},
+      #{activeReturnCashProportion},
+      #{inviteUserId},
+      #{inviteRewardType},
+      #{invitePartnerLevel},
+      #{inviteAmout},
+      #{rewardType},
+      #{rewardState},
+      #{activeTime},
+      #{createdAt},
+      #{updatedAt},
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id},
+      </if>
+      user_id = #{userId},
+      user_level = #{userLevel},
+      active_order_id = #{activeOrderId},
+      active_order_type = #{activeOrderType},
+      active_order_cash = #{activeOrderCash},
+      active_return_cash_proportion = #{activeReturnCashProportion},
+      invite_user_id = #{inviteUserId},
+      invite_reward_type = #{inviteRewardType},
+      invite_partner_level = #{invitePartnerLevel},
+      invite_amout = #{inviteAmout},
+      reward_type = #{rewardType},
+      reward_state = #{rewardState},
+      active_time = #{activeTime},
+      created_at = #{createdAt},
+      updated_at = #{updatedAt},
+    </trim>
+  </insert>
+  <insert id="insertOrUpdateSelective" keyColumn="id" keyProperty="id" parameterType="com.lanren.huhu.partner.domain.PartnerPurchaseRewardRecord" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_purchase_reward_record
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="userId != null">
+        user_id,
+      </if>
+      <if test="userLevel != null">
+        user_level,
+      </if>
+      <if test="activeOrderId != null">
+        active_order_id,
+      </if>
+      <if test="activeOrderType != null">
+        active_order_type,
+      </if>
+      <if test="activeOrderCash != null">
+        active_order_cash,
+      </if>
+      <if test="activeReturnCashProportion != null">
+        active_return_cash_proportion,
+      </if>
+      <if test="inviteUserId != null">
+        invite_user_id,
+      </if>
+      <if test="inviteRewardType != null">
+        invite_reward_type,
+      </if>
+      <if test="invitePartnerLevel != null">
+        invite_partner_level,
+      </if>
+      <if test="inviteAmout != null">
+        invite_amout,
+      </if>
+      <if test="rewardType != null">
+        reward_type,
+      </if>
+      <if test="rewardState != null">
+        reward_state,
+      </if>
+      <if test="activeTime != null">
+        active_time,
+      </if>
+      <if test="createdAt != null">
+        created_at,
+      </if>
+      <if test="updatedAt != null">
+        updated_at,
+      </if>
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id},
+      </if>
+      <if test="userId != null">
+        #{userId},
+      </if>
+      <if test="userLevel != null">
+        #{userLevel},
+      </if>
+      <if test="activeOrderId != null">
+        #{activeOrderId},
+      </if>
+      <if test="activeOrderType != null">
+        #{activeOrderType},
+      </if>
+      <if test="activeOrderCash != null">
+        #{activeOrderCash},
+      </if>
+      <if test="activeReturnCashProportion != null">
+        #{activeReturnCashProportion},
+      </if>
+      <if test="inviteUserId != null">
+        #{inviteUserId},
+      </if>
+      <if test="inviteRewardType != null">
+        #{inviteRewardType},
+      </if>
+      <if test="invitePartnerLevel != null">
+        #{invitePartnerLevel},
+      </if>
+      <if test="inviteAmout != null">
+        #{inviteAmout},
+      </if>
+      <if test="rewardType != null">
+        #{rewardType},
+      </if>
+      <if test="rewardState != null">
+        #{rewardState},
+      </if>
+      <if test="activeTime != null">
+        #{activeTime},
+      </if>
+      <if test="createdAt != null">
+        #{createdAt},
+      </if>
+      <if test="updatedAt != null">
+        #{updatedAt},
+      </if>
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id},
+      </if>
+      <if test="userId != null">
+        user_id = #{userId},
+      </if>
+      <if test="userLevel != null">
+        user_level = #{userLevel},
+      </if>
+      <if test="activeOrderId != null">
+        active_order_id = #{activeOrderId},
+      </if>
+      <if test="activeOrderType != null">
+        active_order_type = #{activeOrderType},
+      </if>
+      <if test="activeOrderCash != null">
+        active_order_cash = #{activeOrderCash},
+      </if>
+      <if test="activeReturnCashProportion != null">
+        active_return_cash_proportion = #{activeReturnCashProportion},
+      </if>
+      <if test="inviteUserId != null">
+        invite_user_id = #{inviteUserId},
+      </if>
+      <if test="inviteRewardType != null">
+        invite_reward_type = #{inviteRewardType},
+      </if>
+      <if test="invitePartnerLevel != null">
+        invite_partner_level = #{invitePartnerLevel},
+      </if>
+      <if test="inviteAmout != null">
+        invite_amout = #{inviteAmout},
+      </if>
+      <if test="rewardType != null">
+        reward_type = #{rewardType},
+      </if>
+      <if test="rewardState != null">
+        reward_state = #{rewardState},
+      </if>
+      <if test="activeTime != null">
+        active_time = #{activeTime},
+      </if>
+      <if test="createdAt != null">
+        created_at = #{createdAt},
+      </if>
+      <if test="updatedAt != null">
+        updated_at = #{updatedAt},
+      </if>
+    </trim>
+  </insert>
+</mapper>
\ No newline at end of file

src/main/resources/mapper/PartnerRevokeRecordsMapper.xml

+<?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.lanren.huhu.partner.dao.PartnerRevokeRecordsMapper">
+  <resultMap id="BaseResultMap" type="com.lanren.huhu.partner.domain.PartnerRevokeRecords">
+    <!--@mbg.generated-->
+    <id column="id" property="id" />
+    <result column="order_id" property="orderId" />
+    <result column="user_id" property="userId" />
+    <result column="ref_id" property="refId" />
+    <result column="revoke_type" property="revokeType" />
+    <result column="state" property="state" />
+    <result column="created_at" property="createdAt" />
+    <result column="updated_at" property="updatedAt" />
+    <result column="order_type" property="orderType" />
+    <result column="order_sn" property="orderSn" />
+    <result column="sub_order_sn" property="subOrderSn" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, order_id, user_id, ref_id, revoke_type, `state`, created_at, updated_at, order_type, 
+    order_sn, sub_order_sn
+  </sql>
+  <update id="updateBatch" parameterType="java.util.List">
+    <!--@mbg.generated-->
+    update partner_revoke_records
+    <trim prefix="set" suffixOverrides=",">
+      <trim prefix="order_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.orderId}
+        </foreach>
+      </trim>
+      <trim prefix="user_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.userId}
+        </foreach>
+      </trim>
+      <trim prefix="ref_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.refId}
+        </foreach>
+      </trim>
+      <trim prefix="revoke_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.revokeType}
+        </foreach>
+      </trim>
+      <trim prefix="`state` = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.state}
+        </foreach>
+      </trim>
+      <trim prefix="created_at = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.createdAt}
+        </foreach>
+      </trim>
+      <trim prefix="updated_at = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.updatedAt}
+        </foreach>
+      </trim>
+      <trim prefix="order_type = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.orderType}
+        </foreach>
+      </trim>
+      <trim prefix="order_sn = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.orderSn}
+        </foreach>
+      </trim>
+      <trim prefix="sub_order_sn = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.subOrderSn}
+        </foreach>
+      </trim>
+    </trim>
+    where id in
+    <foreach close=")" collection="list" item="item" open="(" separator=", ">
+      #{item.id}
+    </foreach>
+  </update>
+  <insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_revoke_records
+    (order_id, user_id, ref_id, revoke_type, `state`, created_at, updated_at, order_type, 
+      order_sn, sub_order_sn)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.orderId}, #{item.userId}, #{item.refId}, #{item.revokeType}, #{item.state}, 
+        #{item.createdAt}, #{item.updatedAt}, #{item.orderType}, #{item.orderSn}, #{item.subOrderSn}
+        )
+    </foreach>
+  </insert>
+  <insert id="insertOrUpdate" keyColumn="id" keyProperty="id" parameterType="com.lanren.huhu.partner.domain.PartnerRevokeRecords" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_revoke_records
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      order_id,
+      user_id,
+      ref_id,
+      revoke_type,
+      `state`,
+      created_at,
+      updated_at,
+      order_type,
+      order_sn,
+      sub_order_sn,
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id},
+      </if>
+      #{orderId},
+      #{userId},
+      #{refId},
+      #{revokeType},
+      #{state},
+      #{createdAt},
+      #{updatedAt},
+      #{orderType},
+      #{orderSn},
+      #{subOrderSn},
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id},
+      </if>
+      order_id = #{orderId},
+      user_id = #{userId},
+      ref_id = #{refId},
+      revoke_type = #{revokeType},
+      `state` = #{state},
+      created_at = #{createdAt},
+      updated_at = #{updatedAt},
+      order_type = #{orderType},
+      order_sn = #{orderSn},
+      sub_order_sn = #{subOrderSn},
+    </trim>
+  </insert>
+  <insert id="insertOrUpdateSelective" keyColumn="id" keyProperty="id" parameterType="com.lanren.huhu.partner.domain.PartnerRevokeRecords" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into partner_revoke_records
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="orderId != null">
+        order_id,
+      </if>
+      <if test="userId != null">
+        user_id,
+      </if>
+      <if test="refId != null">
+        ref_id,
+      </if>
+      <if test="revokeType != null">
+        revoke_type,
+      </if>
+      <if test="state != null">
+        `state`,
+      </if>
+      <if test="createdAt != null">
+        created_at,
+      </if>
+      <if test="updatedAt != null">
+        updated_at,
+      </if>
+      <if test="orderType != null">
+        order_type,
+      </if>
+      <if test="orderSn != null">
+        order_sn,
+      </if>
+      <if test="subOrderSn != null">
+        sub_order_sn,
+      </if>
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id},
+      </if>
+      <if test="orderId != null">
+        #{orderId},
+      </if>
+      <if test="userId != null">
+        #{userId},
+      </if>
+      <if test="refId != null">
+        #{refId},
+      </if>
+      <if test="revokeType != null">
+        #{revokeType},
+      </if>
+      <if test="state != null">
+        #{state},
+      </if>
+      <if test="createdAt != null">
+        #{createdAt},
+      </if>
+      <if test="updatedAt != null">
+        #{updatedAt},
+      </if>
+      <if test="orderType != null">
+        #{orderType},
+      </if>
+      <if test="orderSn != null">
+        #{orderSn},
+      </if>
+      <if test="subOrderSn != null">
+        #{subOrderSn},
+      </if>
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id},
+      </if>
+      <if test="orderId != null">
+        order_id = #{orderId},
+      </if>
+      <if test="userId != null">
+        user_id = #{userId},
+      </if>
+      <if test="refId != null">
+        ref_id = #{refId},
+      </if>
+      <if test="revokeType != null">
+        revoke_type = #{revokeType},
+      </if>
+      <if test="state != null">
+        `state` = #{state},
+      </if>
+      <if test="createdAt != null">
+        created_at = #{createdAt},
+      </if>
+      <if test="updatedAt != null">
+        updated_at = #{updatedAt},
+      </if>
+      <if test="orderType != null">
+        order_type = #{orderType},
+      </if>
+      <if test="orderSn != null">
+        order_sn = #{orderSn},
+      </if>
+      <if test="subOrderSn != null">
+        sub_order_sn = #{subOrderSn},
+      </if>
+    </trim>
+  </insert>
+</mapper>
\ No newline at end of file