zoujiajian il y a 11 mois
Parent
commit
2dc4c7be01

+ 12 - 3
netflix-service/src/main/java/com/cyksj/service/distribute/impl/DistributeServiceImpl.java

@@ -27,6 +27,7 @@ import com.cyksj.redis.RedisService;
 import com.cyksj.service.claude.ClaudeCodeService;
 import com.cyksj.service.distribute.DistributeService;
 import com.cyksj.service.market.task.TaskService;
+import com.cyksj.service.relation.GroupRelationFrontService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.dao.DuplicateKeyException;
@@ -91,6 +92,8 @@ public class DistributeServiceImpl implements DistributeService {
 
 	private final UserMapper userMapper;
 
+	private final GroupRelationFrontService groupRelationFrontService;
+
 	@Override
 	@Transactional(rollbackFor = Throwable.class)
 	public void insertDistribute(UserDistributeReq userDistributeReq) {
@@ -339,9 +342,15 @@ public class DistributeServiceImpl implements DistributeService {
 		}
 		try {
 			userDistributeSharedMapper.insert(userDistributeShared);
-			//若是cc普通推广 发送claude code积分卡
-			claudeCodeService.sendCreditCard(null, userDistributeShared.getSharedId(), 1000, Constant.CLAUDE_CODE_CARD_NUMBER + System.currentTimeMillis(), "新用户注册");
-
+			if (Constant.CC_DISTRIBUTE_MARK.equals(userDistributeShared.getRemark())) {
+				//若是cc普通推广 发送claude code积分卡
+				claudeCodeService.sendCreditCard(null, userDistributeShared.getSharedId(), 1000, Constant.CLAUDE_CODE_CARD_NUMBER + System.currentTimeMillis(), "新用户注册");
+				//存在Claude code车票不发送体验卡
+				if (!claudeCodeService.checkClaudeCodeUser(userId)) {
+					//发送claude code 体验卡
+					groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(user.getId(), Constant.DISTRIBUTE_CLAUDE_CODE_TRIAL_SKU_ID, 1);
+				}
+			}
 			TaskType taskType = taskTypeMapper.selectOne(Wrappers.lambdaQuery(TaskType.class)
 					.eq(TaskType::getName, TaskTypeEnum.share.getDesc()).last("limit 1"));
 			taskService.completeTask(taskType, sharedId);