package com.jsh.erp.service.sms.impl;

import com.jsh.erp.service.redis.RedisUtil;
import com.jsh.erp.service.sms.SmsService;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.util.Random;

@Service
@Slf4j
public class SmsServiceImpl implements SmsService {
    private final RedisUtil redisUtil;

    private final String accessKey;
    private final String secretKey;
    private final String region;
    private final String signName;
    private final String templateId;

    public SmsServiceImpl(RedisUtil redisUtil, @Value("${volc.sms.access-key}") String accessKey, @Value("${volc.sms.secret-key}") String secretKey, @Value("${volc.sms.region}") String region, @Value("${volc.sms.sign-name}") String signName, @Value("${volc.sms.template-id}") String templateId) {
        this.redisUtil = redisUtil;
        this.accessKey = accessKey;
        this.secretKey = secretKey;
        this.region = region;
        this.signName = signName;
        this.templateId = templateId;
    }

    @Override
    public boolean sendCode(String phone) {
        //测试生成固定的凑得
        String code = "888888";
        redisUtil.setCode(phone, code);
        return true;
//        // 生成6位随机验证码
//        String code = String.format("%06d", new Random().nextInt(999999));
//
//        // 存储到Redis
//        redisUtil.setCode(phone, code);
//
//        // 构造火山云请求
//        try {
//            // 使用火山云短信API（示例为简化版，需根据官方文档调整）
//            String url = "https://sms.volcengineapi.com/v2/send";
//            String jsonBody = String.format("{\"phone\":\"%s\",\"sign_name\":\"%s\",\"template_id\":\"%s\",\"template_param\":\"{\\\"code\\\":\\\"%s\\\"}\"}", phone, signName, templateId, code);
//
//            // 生成签名（需按火山云签名算法实现）
//            String signature = generateVolcSignature(accessKey, secretKey);
//
//            // 发送HTTP请求
//            CloseableHttpClient client = HttpClients.createDefault();
//            HttpPost httpPost = new HttpPost(url);
//            httpPost.setHeader("Content-Type", "application/json");
//            httpPost.setHeader("Authorization", "HMAC-SHA256 Credential=" + accessKey + ",Signature=" + signature);
//            httpPost.setEntity(new StringEntity(jsonBody));
//
//            CloseableHttpResponse response = client.execute(httpPost);
//            return response.getStatusLine().getStatusCode() == 200;
//        } catch (Exception e) {
//            log.error("短信发送失败: {}", e.getMessage());
//            return false;
//        }
    }

    @Override
    public boolean verifyCode(String phone, String code) {
        String storedCode = redisUtil.getCode(phone);
        return code != null && code.equals(storedCode);
    }

    // 火山云签名生成方法（需根据官方文档实现）
    private String generateVolcSignature(String accessKey, String secretKey) {
        // 实际需按火山云签名算法生成（示例简化）
        return "generated_signature";
    }
}