fix 记录cc体验卡来源

netflix-dao/src/main/java/com/cyksj/mapper/ClaudeCodeUserTrialReceiveRecordMapper.java

@@ -0,0 +1,13 @@
+package com.cyksj.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.ClaudeCodeUserTrialReceiveRecord;
+
+/**
+ * 项目名: yhlxj11111111
+ * 文件名: ClaudeCodeUserTrialReceiveRecordMapper
+ * 创建者: JavaZou
+ * 创建时间:2025/8/25 12:04
+ */
+public interface ClaudeCodeUserTrialReceiveRecordMapper extends BaseMapper<ClaudeCodeUserTrialReceiveRecord> {
+}

netflix-dao/src/main/java/com/cyksj/model/entity/ClaudeCodeUserTrialReceiveRecord.java

@@ -0,0 +1,23 @@
+package com.cyksj.model.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 项目名: yhlxj11111111
+ * 文件名: ClaudeCodeUserTrialReceiveRecord
+ * 创建者: JavaZou
+ * 创建时间:2025/8/25 12:04
+ */
+@Getter
+@Setter
+public class ClaudeCodeUserTrialReceiveRecord extends BaseEntity{
+	private Long userId;
+
+	private Long relationId;
+
+	/**
+	 * 来源
+	 */
+	private String source;
+}

netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpServiceImpl.java

@@ -20,6 +20,7 @@ import com.cyksj.common.util.corp.WxCryptUtil;
 import com.cyksj.config.corp.WeChatCorpFactory;
 import com.cyksj.config.corp.YHLXWxCorpConfig;
 import com.cyksj.dto.CorpOauth2UserInfo;
+import com.cyksj.mapper.ClaudeCodeUserTrialReceiveRecordMapper;
 import com.cyksj.mapper.GroupsRelationMapper;
 import com.cyksj.mapper.OrderDonMapper;
 import com.cyksj.mapper.UserTicketClearedRecordMapper;
@@ -146,6 +147,9 @@ public class CorpServiceImpl implements CorpService {
 	@Autowired
 	private GroupRelationFrontService groupRelationFrontService;
 
+	@Autowired
+	private ClaudeCodeUserTrialReceiveRecordMapper claudeCodeUserTrialReceiveRecordMapper;
+
 	@PostConstruct
 	private void init() {
 		corpMessageRouter = new CorpMessageRouter(this)
@@ -541,6 +545,17 @@ public class CorpServiceImpl implements CorpService {
 
 		//发送claude code 体验卡
 		Long relationId = groupRelationFrontService.getTrialTicketByUserIdAndGoodsId(userId, Constant.DISTRIBUTE_CLAUDE_CODE_TRIAL_SKU_ID, 1);
+		recordReceiveClaudeCodeRecord(userId, relationId, "corpwx");
+	}
+
+	public void recordReceiveClaudeCodeRecord(Long userId, Long relationId, String source) {
+		if (relationId != null) {
+			ClaudeCodeUserTrialReceiveRecord record = new ClaudeCodeUserTrialReceiveRecord();
+			record.setUserId(userId);
+			record.setRelationId(relationId);
+			record.setSource(source);
+			claudeCodeUserTrialReceiveRecordMapper.insert(record);
+		}
 	}
 
 	public void insertUserIntentionTag(CorpUserPayIntention corpUserPayIntention, String tagId, String tagName) {