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()); } }