Browse Source

fix 清除user

zoujiajian 1 year ago
parent
commit
959d6f5fe4

+ 1 - 1
netflix-dao/src/main/java/com/cyksj/mapper/GroupsRelationMapper.java

@@ -84,5 +84,5 @@ public interface GroupsRelationMapper extends BaseMapper<GroupsRelation> {
 
 	List<UserTicketView> selectUserTickets(@Param("userIds") List<Long> userIds, @Param("goodsId") Long goodsId, @Param("skuId") Long skuId);
 
-	Integer selectCountByGoodsId(@Param("userIdList") List<Long> userIdList, @Param("goodsId") Long goodsId, @Param("now") DateTime now);
+	Integer selectCountByGoodsId(@Param("userIds") List<Long> userIdList, @Param("goodsId") Long goodsId, @Param("now") DateTime now);
 }

+ 7 - 4
netflix-service/src/main/java/com/cyksj/service/relation/impl/GroupRelationClearServiceImpl.java

@@ -1,10 +1,9 @@
 package com.cyksj.service.relation.impl;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.cyksj.common.constant.Constant;
-import com.cyksj.mapper.GoodsDonSkuMapper;
-import com.cyksj.mapper.GroupsMapper;
-import com.cyksj.mapper.GroupsRelationMapper;
-import com.cyksj.mapper.UserTicketClearedRecordMapper;
+import com.cyksj.mapper.*;
+import com.cyksj.model.entity.ClaudeCodeUser;
 import com.cyksj.model.entity.GoodsDonSku;
 import com.cyksj.model.entity.GroupsRelation;
 import com.cyksj.model.entity.UserTicketClearedRecord;
@@ -44,6 +43,8 @@ public class GroupRelationClearServiceImpl implements GroupRelationClearService
 
 	private final ClaudeCodeService claudeCodeService;
 
+	private final ClaudeCodeUserMapper claudeCodeUserMapper;
+
 	@Override
 	public void clearTicket(GroupsRelation relation, UserTicketClearedRecord.Source source) {
 		Long relationId = relation.getId();
@@ -137,6 +138,8 @@ public class GroupRelationClearServiceImpl implements GroupRelationClearService
 				if (groupsRelation.getGoodsId() != null && groupsRelation.getGoodsId() == Constant.CLAUDE_CODE_GOODS_ID) {
 					//用户失效 车票用户id
 					claudeCodeService.invalidateUserCache(groupsRelation.getUserId());
+					//清除claude code user
+					claudeCodeUserMapper.delete(Wrappers.lambdaQuery(ClaudeCodeUser.class).eq(ClaudeCodeUser::getRelationId, relationId));
 				}
 			}
 		}