yhlxj/netflix-service/src/main/java/com/cyksj/service/mail/impl/YhEmailServiceImpl.java

package com.cyksj.service.mail.impl;

import cn.hutool.core.lang.Validator;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpStatus;
import cn.hutool.http.HttpUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.cyksj.common.exception.BusinessRuntimeException;
import com.cyksj.common.util.StringUtil;
import com.cyksj.common.util.TicketCodeCommonUtil;
import com.cyksj.mapper.sys.SysEmailMapper;
import com.cyksj.model.entity.SysEmail;
import com.cyksj.service.mail.YhMailService;
import com.cyksj.service.relation.GroupsRelationNetflixService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;

/**
 * 项目名: yhlxj2
 * 文件名: YhEmailServiceImpl
 * 创建者: JavaZou
 * 创建时间:2024/8/19 15:40
 */
@Service
@RequiredArgsConstructor
@Slf4j
public class YhEmailServiceImpl implements YhMailService {
	private final GroupsRelationNetflixService groupsRelationNetflixService;

	private final SysEmailMapper sysEmailMapper;

	@Override
	public String getVerifyCode(String account, Long goodsId, Integer type, Integer linkType) throws Exception {
		//获取邮箱密码
		SysEmail sysEmail = sysEmailMapper.selectOne(Wrappers.lambdaQuery(SysEmail.class)
				.eq(SysEmail::getEmail, account)
				.last("limit 1"));
		if (sysEmail == null) {
			log.info("获取账号：{}验证码异常,未配置对应系统邮箱", account);
			throw BusinessRuntimeException.getInstance("获取账号验证码异常,请联系客服...");
		}
		String url = "http://yinhelx.com/api/controller.php";
		Map<String, Object> params = new HashMap<>();

		params.put("imap_key", "imap_56568niua@@");
		params.put("fun", "imap_read");
		params.put("imap_ip", "yinhelx.com");
		params.put("port", "143");
		params.put("username", account);
		params.put("password", sysEmail.getPassword());
		params.put("mbox_id", "0");
		params.put("delete", "0");

		HttpRequest post = HttpUtil.createPost(url);
		post.form(params);
		cn.hutool.http.HttpResponse execute = post.execute();
		if (execute.getStatus() != HttpStatus.HTTP_OK) {
			throw BusinessRuntimeException.getInstance("获取验证码异常,请联系客服...");
		}
		String code = getDifferentGoodsCode(goodsId, execute.body(), type, linkType);
		return code;
	}

	public String getDifferentGoodsCode(Long goodsId, String body, Integer type, Integer linkType) {
		String code = null;
		//奈飞
		if (goodsId == 1) {
			if (type != null && type == 1) {
				if (body.contains("輸入此代碼登入") || body.contains("输入此代码登录") || body.contains("Enter this code to sign in")) {
					code = StrUtil.subBetween(body, "輸入此代碼登入", "請在裝置上輸入上");
					if (StrUtil.isEmpty(code)) {
						code = StrUtil.subAfter(body, "输入此代码登录", true);
					}
					if (StrUtil.isEmpty(code)) {
						code = StrUtil.subAfter(body, "Enter this code to sign in", true);
					}
				}
				if (StrUtil.isEmpty(code)) {
					throw BusinessRuntimeException.getInstance("查询失败，请检查是否发送了登陆码..");
				}
			} else {
				String urlPref;
				//更新装置
				if (linkType == 1) {
					urlPref = "https://www.netflix.com/account/update-primary-location";
					code = StrUtil.subBetween(body, "[" + urlPref, "]");
				} else {
					//验证链接
					urlPref = "https://www.netflix.com/account/travel/verify";
					code = StrUtil.subBetween(body, "[" + urlPref, "]");
				}
				if (StrUtil.isEmpty(code)) {
					throw BusinessRuntimeException.getInstance("获取认证链接失败,请重新获取");
				}
				String url = urlPref + code;
				//非点击装置同步更新按钮 直接返回链接
				if (linkType == 2) return url;
				//失败返回验证链接
				if (!groupsRelationNetflixService.confirmUpdate(url)) {
					return url;
				}
				return StrUtil.EMPTY;
			}
		}
		//除奈飞
		if (StrUtil.isEmpty(code)) {
			code = TicketCodeCommonUtil.getTicketCodeStr(body, goodsId);
		}
		int length = 4;
		if (goodsId == 33l) {
			length = 6;
		}
		code = StringUtil.getVerifyCodePattern(code, length);
		if (!Validator.isNumber(code)) {
			log.error("获取账号验证码失败:{}", StrUtil.subSufByLength(code, 512));
			throw BusinessRuntimeException.getInstance("获取验证码失败,请重新获取..");
		}
		return code.trim();
	}

}