Merge branch 'dev'

master
wangsiyuan 2023-12-22 14:10:38 +08:00
commit dbca2373bc
6 changed files with 43 additions and 33 deletions

View File

@ -7,17 +7,20 @@ import com.kimgo.wepush.mapper.ApiSettingMapper;
import com.kimgo.wepush.model.ApiSetting; import com.kimgo.wepush.model.ApiSetting;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@Service @Service
public class ApiSettingService { public class ApiSettingService {
private final Logger logger = LoggerFactory.getLogger(ApiSettingService.class); private final Logger logger = LoggerFactory.getLogger(ApiSettingService.class);
private ApiSetting apiSetting; private ApiSetting apiSetting;
@Autowired private final ApiSettingMapper apiSettingMapper;
private ApiSettingMapper apiSettingMapper; private final UserConfig userConfig;
@Autowired
private UserConfig userConfig; public ApiSettingService(ApiSettingMapper apiSettingMapper, UserConfig userConfig) {
this.apiSettingMapper = apiSettingMapper;
this.userConfig = userConfig;
}
public ApiSetting getApiSetting() { public ApiSetting getApiSetting() {
if (apiSetting == null) { if (apiSetting == null) {
queryApiSetting(); queryApiSetting();

View File

@ -11,7 +11,6 @@ import okhttp3.OkHttpClient;
import okhttp3.RequestBody; import okhttp3.RequestBody;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import okhttp3.*; import okhttp3.*;
@ -20,12 +19,17 @@ import java.io.IOException;
@Service @Service
public class CallService { public class CallService {
private final Logger logger = LoggerFactory.getLogger(CallService.class); private final Logger logger = LoggerFactory.getLogger(CallService.class);
@Autowired private final QyWeChatURLService qyWeChatURLService;
private QyWeChatURLService qyWeChatURLService; private final ApiSettingService apiSettingService;
@Autowired final
private ApiSettingService apiSettingService;
@Autowired
TokenService tokenService; TokenService tokenService;
public CallService(QyWeChatURLService qyWeChatURLService, ApiSettingService apiSettingService, TokenService tokenService) {
this.qyWeChatURLService = qyWeChatURLService;
this.apiSettingService = apiSettingService;
this.tokenService = tokenService;
}
public ServerResponseEntity getPhoneNumber(String accessToken, CallInfo callInfo){ public ServerResponseEntity getPhoneNumber(String accessToken, CallInfo callInfo){
String correctAccessToken = tokenService.getApiAccessToken(); String correctAccessToken = tokenService.getApiAccessToken();
logger.info("accessToken: {} correctAccessToken: {}",accessToken,correctAccessToken); logger.info("accessToken: {} correctAccessToken: {}",accessToken,correctAccessToken);

View File

@ -149,7 +149,6 @@ public class MonitorService {
} catch (Exception e) { } catch (Exception e) {
logger.error("Error updating status for SN: " + device.getSN(), e); logger.error("Error updating status for SN: " + device.getSN(), e);
throw new DatabaseUpdateException("update to mysql error.",e); throw new DatabaseUpdateException("update to mysql error.",e);
} }
} }
} }

View File

@ -2,24 +2,23 @@ package com.kimgo.wepush.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.kimgo.wepush.config.UserConfig; import com.kimgo.wepush.config.UserConfig;
import com.kimgo.wepush.mapper.QyWeChatAppInfoMapper;
import com.kimgo.wepush.mapper.QyWeChatURLMapper; import com.kimgo.wepush.mapper.QyWeChatURLMapper;
import com.kimgo.wepush.model.QyWeChatAppInfo;
import com.kimgo.wepush.model.QyWeChatURL; import com.kimgo.wepush.model.QyWeChatURL;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@Service @Service
public class QyWeChatURLService { public class QyWeChatURLService {
private final Logger logger = LoggerFactory.getLogger(QyWeChatURLService.class); private final Logger logger = LoggerFactory.getLogger(QyWeChatURLService.class);
@Autowired private final QyWeChatURLMapper qyWeChatURLMapper;
private QyWeChatURLMapper qyWeChatURLMapper; private final UserConfig userConfig;
@Autowired
private UserConfig userConfig;
private String sendTextCardMessageUrl; private String sendTextCardMessageUrl;
private String qyWechatGetTokenUrl;
public QyWeChatURLService(QyWeChatURLMapper qyWeChatURLMapper, UserConfig userConfig) {
this.qyWeChatURLMapper = qyWeChatURLMapper;
this.userConfig = userConfig;
}
public String getSendTextCardMessageUrl() { public String getSendTextCardMessageUrl() {
if (sendTextCardMessageUrl == null){ if (sendTextCardMessageUrl == null){

View File

@ -19,12 +19,15 @@ import java.io.IOException;
public class SMSService { public class SMSService {
private final Logger logger = LoggerFactory.getLogger(SMSService.class); private final Logger logger = LoggerFactory.getLogger(SMSService.class);
@Autowired private final ApiSettingService apiSettingService;
private ApiSettingService apiSettingService; private final TokenService tokenService;
@Autowired private final QyWeChatURLService qyWeChatURLService;
private TokenService tokenService;
@Autowired public SMSService(ApiSettingService apiSettingService, TokenService tokenService, QyWeChatURLService qyWeChatURLService) {
private QyWeChatURLService qyWeChatURLService; this.apiSettingService = apiSettingService;
this.tokenService = tokenService;
this.qyWeChatURLService = qyWeChatURLService;
}
public ServerResponseEntity getSMSInfo(String accessToken, SMSInfo smsInfo){ public ServerResponseEntity getSMSInfo(String accessToken, SMSInfo smsInfo){
String correctAccessToken = tokenService.getApiAccessToken(); String correctAccessToken = tokenService.getApiAccessToken();

View File

@ -10,21 +10,23 @@ import com.kimgo.wepush.model.QyWeChatAppInfo;
import com.kimgo.wepush.request.WeChatAPI; import com.kimgo.wepush.request.WeChatAPI;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@Service @Service
public class TokenService { public class TokenService {
private final Logger logger = LoggerFactory.getLogger(TokenService.class); private final Logger logger = LoggerFactory.getLogger(TokenService.class);
@Autowired private final UserConfig userConfig;
private UserConfig userConfig; private final QyWeChatAppInfoMapper qyWeChatAppInfoMapper;
@Autowired private final ApiSettingMapper apiSettingMapper;
private QyWeChatAppInfoMapper qyWeChatAppInfoMapper;
@Autowired
private ApiSettingMapper apiSettingMapper;
private String accessToken; private String accessToken;
private String apiAccessToken; private String apiAccessToken;
public TokenService(ApiSettingMapper apiSettingMapper, QyWeChatAppInfoMapper qyWeChatAppInfoMapper, UserConfig userConfig) {
this.apiSettingMapper = apiSettingMapper;
this.qyWeChatAppInfoMapper = qyWeChatAppInfoMapper;
this.userConfig = userConfig;
}
public String getAccessToken() { public String getAccessToken() {
if (accessToken == null) { if (accessToken == null) {
updateAccessToken(); updateAccessToken();