wePush/src/main/java/com/kimgo/wepush/service/CallService.java

package com.kimgo.wepush.service;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.kimgo.wepush.common.PhoneNumberValidation;
import com.kimgo.wepush.common.QyWeChatSendMessageApiResponse;
import com.kimgo.wepush.config.URLConfig;
import com.kimgo.wepush.config.UserConfig;
import com.kimgo.wepush.mapper.QyWeChatAppInfoMapper;
import com.kimgo.wepush.model.CallInfo;
import com.kimgo.wepush.model.TextCardMessage;
import com.kimgo.wepush.response.SendMessageResonse;
import com.kimgo.wepush.response.ServerResponseEntity;
import okhttp3.OkHttpClient;
import okhttp3.RequestBody;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import okhttp3.*;

import java.io.IOException;

@Service
public class CallService {
    private final Logger logger = LoggerFactory.getLogger(CallService.class);

    private ServerResponseEntity serverResponseEntity;
    @Autowired
    private QyWeChatURLService qyWeChatURLService;
    @Autowired
    private ApiSettingService apiSettingService;
    @Autowired
    TokenService tokenService;
    public ServerResponseEntity getPhoneNumber(String accessToken, CallInfo callInfo){
        String correctAccessToken = tokenService.getApiAccessToken();
        logger.info("accessToken: {} correctAccessToken: {}",accessToken,correctAccessToken);
        if (!correctAccessToken.equals(accessToken)){
            return ServerResponseEntity.fail("Invalid accessToken");
        }
        PhoneNumberValidation phoneNumberValidation = new PhoneNumberValidation();
        String phoneNumber = callInfo.getPhoneNumber();
        String callTime = callInfo.getCallTime();
        if (!phoneNumberValidation.isValidPhoneNumber(callInfo.getPhoneNumber())){
            return ServerResponseEntity.fail("Invalid phoneNumber");
        }
        String qyAccessToken = tokenService.getAccessToken();
        QyWeChatSendMessageApiResponse qyWeChatSendMessageApiResponse = requestWithOkhttp(qyAccessToken,phoneNumber,callTime);
        int code = qyWeChatSendMessageApiResponse.getErrcode();
        if (code == 0){
            SendMessageResonse sendMessageResonse = new SendMessageResonse();
            sendMessageResonse.setMsgid(qyWeChatSendMessageApiResponse.getMsgid());
            return ServerResponseEntity.success(sendMessageResonse);
        } else {
            return ServerResponseEntity.fail("request qyWeChat error,please check server error log.");
        }
    }

    public TextCardMessage setTextCardMessage(String phoneNumber, String callTime) {
        TextCardMessage textCardMessage = new TextCardMessage();
        textCardMessage.setTouser(apiSettingService.getApiSetting().getTouser());
        textCardMessage.setMsgtype(apiSettingService.getApiSetting().getMsgtype());
        textCardMessage.setAgentid(apiSettingService.getApiSetting().getAgentid());
        textCardMessage.setEnable_duplicate_check(apiSettingService.getApiSetting().getEnableDuplicateCheck());
        textCardMessage.setDuplicate_check_interval(apiSettingService.getApiSetting().getDuplicateCheckInterval());
        TextCardMessage.TextCard textCard = new TextCardMessage.TextCard();
        textCard.setTitle("新来电通知");
        textCard.setDescription("<div class='gray'>您有一通新来电</div><div class='highlight'>来电号码: " + phoneNumber + "</div><div class='highlight'>来电时间: " + callTime + "</div>如果您认识这个号码，请及时回电。如果不认识，请注意可能是垃圾电话或诈骗电话。");
        textCard.setUrl("https://kimgo.cn");
        // 将TextCard对象设置到TextCardMessage中
        textCardMessage.setTextcard(textCard);

        logger.info("TextCardMessage: {}", textCardMessage.toString());

        return textCardMessage;
    }

    public QyWeChatSendMessageApiResponse requestWithOkhttp(String accessToken,String phoneNumber,String callTime){
        String url = qyWeChatURLService.getSendTextCardMessageUrl() + "?access_token=" + accessToken;
        OkHttpClient client = new OkHttpClient();

        TextCardMessage textCardMessage = setTextCardMessage(phoneNumber,callTime);
        // 使用Jackson进行序列化
        ObjectMapper objectMapper = new ObjectMapper();
        String jsonBody = null;
        try {
            jsonBody = objectMapper.writeValueAsString(textCardMessage);
            logger.info("jsonBody: {}",jsonBody);
        } catch (JsonProcessingException e) {
            logger.error("JSON processing error", e);
            return null;
        }
        // 构建请求体
        RequestBody body = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), jsonBody);
        Request request = new Request.Builder().url(url).post(body).build();
        try (Response response = client.newCall(request).execute()) {
            String responseBody = response.body().string();
            logger.info("request sendMessage api ResponseBody: {}", responseBody);

            ObjectMapper objectMapper1 = new ObjectMapper();
            QyWeChatSendMessageApiResponse apiResponse = objectMapper1.readValue(responseBody, QyWeChatSendMessageApiResponse.class);

            if (apiResponse.getErrcode() == 0) {
                return apiResponse;
            } else if (apiResponse.getErrcode() == 42001 || apiResponse.getErrcode() == 40014) {
                logger.info("Access token expired. Refreshing token...");
                tokenService.setAccessToken();  // 一个方法来刷新accessToken
                String newAccessToken = tokenService.getAccessToken();
                return requestWithOkhttp(newAccessToken, phoneNumber, callTime);
            } else {
                // 处理其他错误情况
                logger.error("Error: {}", apiResponse.getErrmsg());
                return apiResponse;
            }
        } catch (IOException e) {
            logger.error("OkHttp request error", e);
            return null;
        }
    }
}