yujian
2019-01-26 6ad2e2280ca7add6f896d5542e29b0206d5b35b6
删除已失效队员关系
3个文件已修改
22 ■■■■■ 已修改文件
fanli/src/main/java/com/yeshi/fanli/dao/mybatis/ThreeSaleMapper.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/mapping/ThreeSaleMapper.xml 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/dao/mybatis/ThreeSaleMapper.java
@@ -26,6 +26,15 @@
    int updateByPrimaryKey(ThreeSale record);
    int effectThreeSale(Long workerUid);
    /**
     * 删除失效
     * @param bossId
     * @param workerId
     * @return
     */
    int deleteExpireRecord(@Param("bossId")Long bossId, @Param("workerId")Long workerId);
    /**
     * 查询一度队员集合
fanli/src/main/java/com/yeshi/fanli/mapping/ThreeSaleMapper.xml
@@ -146,7 +146,12 @@
        where t.state=0 and t.worker_id=#{0} AND (t.expire = 0 OR t.expire IS
        NULL)
    </update>
    <delete id="deleteExpireRecord" parameterType="java.lang.Long">
        DELETE FROM yeshi_ec_threesale
        WHERE expire = 1 AND boss_id = #{bossId} AND worker_id = #{workerId}
    </delete>
    <!-- 查询一度队员集合 -->
    <select id="queryMyFirstTeamList" resultMap="BaseResultMap">
        SELECT * FROM `yeshi_ec_threesale` yet
fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java
@@ -113,6 +113,9 @@
            threeSale.setWorker(inviteeUser);
            threeSaleMapper.insertSelective(threeSale);
            
            // 删除已失效关系
            threeSaleMapper.deleteExpireRecord(inviter.getId(), inviteeUser.getId());
            //创建通知
            userInviteMsgNotificationService.inviteScan(inviter.getId(), threeSale);
            
@@ -624,6 +627,9 @@
            threeSale.setCreateTime(java.lang.System.currentTimeMillis());
            threeSale.setUpdateTime(java.lang.System.currentTimeMillis());
            threeSaleMapper.insertSelective(threeSale);
            // 删除已失效关系
            threeSaleMapper.deleteExpireRecord(inviter.getId(), invitee.getId());
        }
    }