fix 发送奈飞恢复短信通知

netflix-common/src/main/java/com/cyksj/common/constant/Constant.java

@@ -118,6 +118,8 @@ public interface Constant {
 
 	String CHANGE_GROUPS_TRIPS_ACCOUNT = "您好，您购买的%s，车票账号：%s密码已更换【杭州崇宇信息】";
 
+	String NETFLIX_ERROR_CHANGE_TICKET_MSG = "您申请恢复的奈飞账号已更换，请登录官网https://nf.video/ 查看【杭州崇宇信息】";
+
 	String ONE_EMPTY = " ";
 
 	String AMERICA_APPID_SECRET = "1990-01-01 朋友 aaa111 工作 aab112 父母 aac113";

netflix-service/src/main/java/com/cyksj/service/relation/impl/CmsGroupsRelationServiceImpl.java

@@ -10,6 +10,7 @@ import com.cyksj.model.entity.*;
 import com.cyksj.redis.RedisService;
 import com.cyksj.service.relation.CmsGroupsRelationService;
 import com.cyksj.service.relation.GroupRelationClearService;
+import com.cyksj.service.sms.SmsService;
 import com.cyksj.service.user.UserBindRelationService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -44,6 +45,8 @@ public class CmsGroupsRelationServiceImpl implements CmsGroupsRelationService {
 
 	private final OrderDonMapper orderDonMapper;
 
+	private final SmsService smsService;
+
 	private static final GlobalThreadPoolTaskExecutor TASK_EXECUTOR = GlobalThreadPoolTaskExecutor.getInstance();
 
 	@Override
@@ -88,6 +91,12 @@ public class CmsGroupsRelationServiceImpl implements CmsGroupsRelationService {
 						recoverRecordMapper.update(null, Wrappers.lambdaUpdate(NetflixUserAccountSubmitRecoverRecord.class)
 								.set(NetflixUserAccountSubmitRecoverRecord::getReplaceRelationId, newRelation.getId())
 								.eq(NetflixUserAccountSubmitRecoverRecord::getId, recoverRecordId));
+						try {
+							//发送奈飞恢复短信通知
+							smsService.sendSmsToRelationUser(recoverRecord.getUserId(), Constant.NETFLIX_ERROR_CHANGE_TICKET_MSG);
+						} catch (Exception e) {
+
+						}
 					}
 				}
 			}

netflix-service/src/main/java/com/cyksj/service/sms/impl/SmsServiceImpl.java

@@ -1,6 +1,7 @@
 package com.cyksj.service.sms.impl;
 
 import cn.hutool.core.util.StrUtil;
+import com.cyksj.common.EnvCommonService;
 import com.cyksj.common.constant.Constant;
 import com.cyksj.common.util.SmsUtil;
 import com.cyksj.mapper.GroupsRelationMapper;
@@ -22,8 +23,13 @@ import org.springframework.stereotype.Service;
 public class SmsServiceImpl implements SmsService {
 	private final GroupsRelationMapper groupsRelationMapper;
 
+	private final EnvCommonService envCommonService;
+
 	@Override
 	public void sendSmsToRelationUser(Long userId, String template, String... objs) throws Exception {
+		if (!envCommonService.isPrdEnv()) {
+			return;
+		}
 		PhoneCode areaPhone = groupsRelationMapper.getAreaPhoneByUserId(userId);
 		if (areaPhone != null && StrUtil.isNotBlank(areaPhone.getPhone())) {
 			String phone = areaPhone.getPhone();