fix mj试用车票记录mj用户id

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

@@ -19,4 +19,9 @@ public class UserReceiveTrialTicketRecord extends BaseEntity{
 	private Long skuId;
 
 	private Long relationId;
+
+	/**
+	 * mj会话 user_id
+	 */
+	private Long mjUserId;
 }

netflix-service/src/main/java/com/cyksj/service/ticket/impl/UserReceiveTrialTicketRecordServiceImpl.java

@@ -6,11 +6,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.cyksj.common.exception.BusinessRuntimeException;
 import com.cyksj.common.util.StringUtil;
 import com.cyksj.mapper.*;
-import com.cyksj.model.entity.GoodsDonSku;
-import com.cyksj.model.entity.GroupsRelation;
-import com.cyksj.model.entity.GroupsTrips;
-import com.cyksj.model.entity.UserReceiveTrialTicketRecord;
+import com.cyksj.model.entity.*;
 import com.cyksj.service.groups.GroupsFuncService;
+import com.cyksj.service.midjourney.MidjourneyAccountService;
 import com.cyksj.service.ticket.UserReceiveTrialTicketRecordService;
 import com.cyksj.service.user.UserBindRelationService;
 import com.github.rholder.retry.*;
@@ -47,6 +45,8 @@ public class UserReceiveTrialTicketRecordServiceImpl implements UserReceiveTrial
 
 	private final OrderDonMapper orderDonMapper;
 
+	private final MidjourneyAccountService midjourneyAccountService;
+
 	@Override
 	public void sendTicketAndRecord(Long userId, Long trialSkuId) {
 		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
@@ -78,6 +78,12 @@ public class UserReceiveTrialTicketRecordServiceImpl implements UserReceiveTrial
 
 			Long relationId = getTrialTicketByUserIdAndGoodsId(userId, trialSkuId);
 			userReceiveTrialTicketRecord.setRelationId(relationId);
+			try {
+				//mj user
+				MidjourneyUser midjourneyUser = midjourneyAccountService.getMidjourneyUserToken(userId, relationId);
+				userReceiveTrialTicketRecord.setMjUserId(midjourneyUser.getId());
+			} catch (Exception e) {
+			}
 			userReceiveTrialTicketRecordMapper.updateById(userReceiveTrialTicketRecord);
 
 		} catch (DuplicateKeyException e) {