first commit
This commit is contained in:
@@ -0,0 +1,41 @@
|
||||
package com.kimgo.wepush.service;
|
||||
|
||||
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.kimgo.wepush.config.UserConfig;
|
||||
import com.kimgo.wepush.mapper.ApiSettingMapper;
|
||||
import com.kimgo.wepush.model.ApiSetting;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
public class ApiSettingService {
|
||||
private final Logger logger = LoggerFactory.getLogger(ApiSettingService.class);
|
||||
private ApiSetting apiSetting;
|
||||
@Autowired
|
||||
private ApiSettingMapper apiSettingMapper;
|
||||
@Autowired
|
||||
private UserConfig userConfig;
|
||||
public ApiSetting getApiSetting() {
|
||||
if (apiSetting == null) {
|
||||
queryApiSetting();
|
||||
}
|
||||
return apiSetting;
|
||||
}
|
||||
private void queryApiSetting(){
|
||||
String phoneNumberToSearch = userConfig.getPhoneNumber();
|
||||
QueryWrapper<ApiSetting> wrapper = new QueryWrapper<>();
|
||||
wrapper.eq("phone_number", phoneNumberToSearch);
|
||||
logger.info("wrapper: {}",wrapper);
|
||||
ApiSetting result = apiSettingMapper.selectOne(wrapper);
|
||||
logger.info("result: {}",result);
|
||||
if (result == null){
|
||||
apiSetting = null;
|
||||
logger.error("updateAccessToken error");
|
||||
}
|
||||
apiSetting = result;
|
||||
logger.info("get apiSetting from mysql,accessToken: {}",apiSetting);
|
||||
}
|
||||
}
|
||||
125
src/main/java/com/kimgo/wepush/service/CallService.java
Normal file
125
src/main/java/com/kimgo/wepush/service/CallService.java
Normal file
@@ -0,0 +1,125 @@
|
||||
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 UserConfig userConfig;
|
||||
@Autowired
|
||||
private ApiSettingService apiSettingService;
|
||||
@Autowired
|
||||
private URLConfig urlConfig;
|
||||
@Autowired
|
||||
private QyWeChatAppInfoMapper qyWeChatAppInfoMapper;
|
||||
@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().getEnable_duplicate_check());
|
||||
textCardMessage.setDuplicate_check_interval(apiSettingService.getApiSetting().getDuplicate_check_interval());
|
||||
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){
|
||||
OkHttpClient client = new OkHttpClient();
|
||||
String url = urlConfig.getSendTextCardMessageUrl() + accessToken;
|
||||
|
||||
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;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,40 @@
|
||||
package com.kimgo.wepush.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.kimgo.wepush.config.UserConfig;
|
||||
import com.kimgo.wepush.mapper.QyWeChatAppInfoMapper;
|
||||
import com.kimgo.wepush.mapper.QyWeChatURLMapper;
|
||||
import com.kimgo.wepush.model.QyWeChatAppInfo;
|
||||
import com.kimgo.wepush.model.QyWeChatURL;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
public class QyWeChatURLService {
|
||||
private final Logger logger = LoggerFactory.getLogger(QyWeChatURLService.class);
|
||||
@Autowired
|
||||
private QyWeChatURLMapper qyWeChatURLMapper;
|
||||
@Autowired
|
||||
private UserConfig userConfig;
|
||||
private String urlName;
|
||||
private String sendTextCardMessageUrl;
|
||||
private String qyWechatGetTokenUrl;
|
||||
|
||||
public String getSendTextCardMessageUrl() {
|
||||
if (sendTextCardMessageUrl == null){
|
||||
queryLRL();
|
||||
}
|
||||
return sendTextCardMessageUrl;
|
||||
}
|
||||
private void queryLRL(){
|
||||
String phoneNumberToSearch = userConfig.getPhoneNumber();
|
||||
QueryWrapper<QyWeChatURL> wrapper = new QueryWrapper<>();
|
||||
wrapper.eq("phone_number", phoneNumberToSearch);
|
||||
QyWeChatURL result = qyWeChatURLMapper.selectOne(wrapper);
|
||||
if (result == null){
|
||||
logger.error("queryLRL error");
|
||||
}
|
||||
sendTextCardMessageUrl = result.getSendTextCardMessageUrl();
|
||||
qyWechatGetTokenUrl = result.getQyWechatGetTokenUrl();
|
||||
};
|
||||
}
|
||||
107
src/main/java/com/kimgo/wepush/service/SMSService.java
Normal file
107
src/main/java/com/kimgo/wepush/service/SMSService.java
Normal file
@@ -0,0 +1,107 @@
|
||||
package com.kimgo.wepush.service;
|
||||
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.kimgo.wepush.common.QyWeChatSendMessageApiResponse;
|
||||
import com.kimgo.wepush.config.URLConfig;
|
||||
import com.kimgo.wepush.model.SMSInfo;
|
||||
import com.kimgo.wepush.model.TextCardMessage;
|
||||
import com.kimgo.wepush.response.ServerResponseEntity;
|
||||
import okhttp3.*;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
import com.kimgo.wepush.config.UserConfig;
|
||||
import java.io.IOException;
|
||||
|
||||
@Service
|
||||
public class SMSService {
|
||||
private final Logger logger = LoggerFactory.getLogger(SMSService.class);
|
||||
@Autowired
|
||||
private UserConfig userConfig;
|
||||
@Autowired
|
||||
private ApiSettingService apiSettingService;
|
||||
@Autowired
|
||||
private TokenService tokenService;
|
||||
@Autowired
|
||||
private URLConfig urlConfig;
|
||||
|
||||
public ServerResponseEntity getSMSInfo(String accessToken, SMSInfo smsInfo){
|
||||
String correctAccessToken = tokenService.getApiAccessToken();
|
||||
logger.info("accessToken: {} correctAccessToken: {}",accessToken,correctAccessToken);
|
||||
if (!correctAccessToken.equals(accessToken)){
|
||||
return ServerResponseEntity.fail("Invalid accessToken");
|
||||
}
|
||||
String qyAccessToken = tokenService.getAccessToken();
|
||||
QyWeChatSendMessageApiResponse qyWeChatSendMessageApiResponse = requestWithOkhttp(qyAccessToken,smsInfo);
|
||||
if (qyWeChatSendMessageApiResponse != null){
|
||||
return ServerResponseEntity.success(qyWeChatSendMessageApiResponse.getMsgid());
|
||||
}
|
||||
return ServerResponseEntity.fail("request qyWeChat error,please check server error log.");
|
||||
}
|
||||
|
||||
public QyWeChatSendMessageApiResponse requestWithOkhttp(String accessToken,SMSInfo smsInfo){
|
||||
OkHttpClient client = new OkHttpClient();
|
||||
String url = urlConfig.getSendTextCardMessageUrl() + accessToken;
|
||||
|
||||
TextCardMessage textCardMessage = setTextCardMessage(smsInfo);
|
||||
// 使用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("Response: {}", 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, smsInfo);
|
||||
} else {
|
||||
// 处理其他错误情况
|
||||
logger.error("Error: {}", apiResponse.getErrmsg());
|
||||
return apiResponse;
|
||||
}
|
||||
} catch (IOException e) {
|
||||
logger.error("OkHttp request error", e);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
public TextCardMessage setTextCardMessage(SMSInfo smsInfo) {
|
||||
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().getEnable_duplicate_check());
|
||||
textCardMessage.setDuplicate_check_interval(apiSettingService.getApiSetting().getDuplicate_check_interval());
|
||||
|
||||
TextCardMessage.TextCard textCard = new TextCardMessage.TextCard();
|
||||
textCard.setTitle("新短信通知");
|
||||
textCard.setDescription("<div class='gray'>您有一条新短信</div><div class='highlight'>短信号码: " + smsInfo.getSmsNumber() + "</div><div class='highlight'>接受短信时间: " + smsInfo.getSmsAcceptanceTime() + "</div>" + smsInfo.getSmsContent());
|
||||
textCard.setUrl("https://kimgo.cn");
|
||||
// 将TextCard对象设置到TextCardMessage中
|
||||
textCardMessage.setTextcard(textCard);
|
||||
|
||||
logger.info("TextCardMessage: {}", textCardMessage.toString());
|
||||
|
||||
return textCardMessage;
|
||||
}
|
||||
}
|
||||
95
src/main/java/com/kimgo/wepush/service/TokenService.java
Normal file
95
src/main/java/com/kimgo/wepush/service/TokenService.java
Normal file
@@ -0,0 +1,95 @@
|
||||
package com.kimgo.wepush.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
||||
import com.kimgo.wepush.config.UserConfig;
|
||||
import com.kimgo.wepush.mapper.ApiSettingMapper;
|
||||
import com.kimgo.wepush.mapper.QyWeChatAppInfoMapper;
|
||||
import com.kimgo.wepush.model.QyWeChatAppInfo;
|
||||
import com.kimgo.wepush.request.WeChatAPI;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@Service
|
||||
public class TokenService {
|
||||
private final Logger logger = LoggerFactory.getLogger(TokenService.class);
|
||||
@Autowired
|
||||
private UserConfig userConfig;
|
||||
@Autowired
|
||||
private QyWeChatAppInfoMapper qyWeChatAppInfoMapper;
|
||||
@Autowired
|
||||
private ApiSettingMapper apiSettingMapper;
|
||||
private String accessToken;
|
||||
private String apiAccessToken;
|
||||
|
||||
public String getAccessToken() {
|
||||
if (accessToken == null) {
|
||||
updateAccessToken();
|
||||
}
|
||||
return accessToken;
|
||||
}
|
||||
|
||||
public String getApiAccessToken(){
|
||||
if (apiAccessToken == null){
|
||||
updateApiAccessToken();
|
||||
}
|
||||
return apiAccessToken;
|
||||
}
|
||||
|
||||
|
||||
public void updateAccessToken() {
|
||||
String phoneNumberToSearch = userConfig.getPhoneNumber();
|
||||
QueryWrapper<QyWeChatAppInfo> wrapper = new QueryWrapper<>();
|
||||
wrapper.eq("phone_number", phoneNumberToSearch);
|
||||
QyWeChatAppInfo result = qyWeChatAppInfoMapper.selectOne(wrapper);
|
||||
if (result == null){
|
||||
accessToken = null;
|
||||
logger.error("updateAccessToken error");
|
||||
}
|
||||
accessToken = result.getAccessToken();
|
||||
logger.info("get accessToken from mysql,accessToken: {}",accessToken);
|
||||
}
|
||||
public void setAccessToken(){
|
||||
String phoneNumberToSearch = userConfig.getPhoneNumber();
|
||||
QueryWrapper<QyWeChatAppInfo> wrapper = new QueryWrapper<>();
|
||||
wrapper.eq("phone_number", phoneNumberToSearch);
|
||||
QyWeChatAppInfo result = qyWeChatAppInfoMapper.selectOne(wrapper);
|
||||
if (result != null){
|
||||
WeChatAPI weChatAPI = new WeChatAPI();
|
||||
String accessToken1 = weChatAPI.getAccessToken(result.getCorpId(), result.getCorpSecret());
|
||||
if (accessToken1 == null){
|
||||
logger.error("accessToken1 == null");
|
||||
}
|
||||
accessToken = accessToken1;
|
||||
updateAccessTokenToMysql(accessToken,phoneNumberToSearch);
|
||||
}
|
||||
}
|
||||
|
||||
public void updateAccessTokenToMysql(String accessToken,String phoneNumber){
|
||||
UpdateWrapper<QyWeChatAppInfo> updateWrapper = new UpdateWrapper<>();
|
||||
updateWrapper.eq("phone_number", phoneNumber); // 根据 phoneNumber 更新
|
||||
updateWrapper.set("access_token", accessToken); // 设置新的 accessToken
|
||||
|
||||
int result = qyWeChatAppInfoMapper.update(null, updateWrapper);
|
||||
if (result > 0) {
|
||||
logger.info("Update successful");
|
||||
} else {
|
||||
logger.warn("Update failed: No rows affected");
|
||||
}
|
||||
}
|
||||
|
||||
public void updateApiAccessToken(){
|
||||
String phoneNumberToSearch = userConfig.getPhoneNumber();
|
||||
QueryWrapper<ApiSetting> wrapper = new QueryWrapper<>();
|
||||
wrapper.eq("phone_number", phoneNumberToSearch);
|
||||
ApiSetting result = apiSettingMapper.selectOne(wrapper);
|
||||
if (result == null){
|
||||
apiAccessToken = null;
|
||||
logger.error("updateApiAccessToken error");
|
||||
}
|
||||
apiAccessToken = result.getAccessToken();
|
||||
logger.info("get ApiAccessToken from mysql,accessToken: {}",apiAccessToken);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user