调转调用顺序,优化

This commit is contained in:
kuang.yife 2024-02-23 11:55:50 +08:00
parent 31e8ac48bc
commit 5a2e981c41
4 changed files with 50 additions and 26 deletions

View File

@ -17,6 +17,7 @@ import com.ruoyi.system.domain.ClewPhone;
import com.ruoyi.system.domain.OppoCheck; import com.ruoyi.system.domain.OppoCheck;
import com.ruoyi.system.service.IClewPhoneService; import com.ruoyi.system.service.IClewPhoneService;
import com.ruoyi.system.service.ISysUserService; import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.web.core.config.GlobalLogHelper;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import okhttp3.MediaType; import okhttp3.MediaType;
import okhttp3.OkHttpClient; import okhttp3.OkHttpClient;
@ -187,6 +188,28 @@ public class ClewController extends BaseController
log.info("请求{}的属性{}", url, content); log.info("请求{}的属性{}", url, content);
String s = HttpUtils.sendPost(url, content, headerMap); String s = HttpUtils.sendPost(url, content, headerMap);
log.info("请求{}的响应{}", url, s); log.info("请求{}的响应{}", url, s);
}else if("xiaomi".equalsIgnoreCase(clew.getRemark())){
log.info("oaid : {}, imei:{}", clew.getOaid(), clew.getImei());
// String imei = clew.getImei();
String oaid = clew.getOaid();
// String ua = "Dalvik/2.1.0 (Linux; U; Android 11; M2012K11AC Build/RKQ1.200826.002)";
String clientIp = "58.49.150.163";
long convTime = System.currentTimeMillis();
String convType = "APP_PAY";
long appId = 1545362;
int customerId = 445972;
String singKey = "FkqMqeKVbCaeSGBI";
String encryptKey = "IIUWoEaMXlzctOqk";
GlobalLogHelper.UploadInfo uploadInfo = GlobalLogHelper.UploadInfo.builder()
// .imei(imei)
.oaid(oaid)
// .ua(ua)
.clientIp(clientIp)
.convTime(convTime).convType(convType)
.appId(appId).customerId(customerId).signKey(singKey).encryptKey(encryptKey).build().genInfo();
log.info("请求xiaomi的属性{}", uploadInfo.getFinalUrl());
String s = HttpUtils.sendGet(uploadInfo.getFinalUrl());
log.info("请求xiaomi的响应{}", s);
} }
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();

View File

@ -102,6 +102,22 @@ public class NoticeController {
SendSmsResponse sendSmsResponse = client.sendSmsWithOptions(sendSmsRequest, runtime); SendSmsResponse sendSmsResponse = client.sendSmsWithOptions(sendSmsRequest, runtime);
log.info("发送给{}短信响应为{}", request.getPhone(), sendSmsResponse); log.info("发送给{}短信响应为{}", request.getPhone(), sendSmsResponse);
CacheUtils.put(request.getPhone(), code); CacheUtils.put(request.getPhone(), code);
// 请求次数入库
try {
ClewPhone param = new ClewPhone();
param.setPhone(request.getPhone());
List<ClewPhone> clewPhones = clewPhoneService.selectClewPhoneList(param);
if(CollectionUtils.isEmpty(clewPhones)){
ClewPhone model = new ClewPhone();
model.setPhone(request.getPhone());
model.setCreateTime(new Date());
model.setRemark(request.getFrom());
clewPhoneService.insertClewPhone(model);
}
}catch (Exception e){
e.printStackTrace();
log.error("手机号入库失败!,原因:{}", e.getMessage());
}
// 调用oppo的统计接口 // 调用oppo的统计接口
try { try {
if("oppo".equalsIgnoreCase(request.getFrom())){ if("oppo".equalsIgnoreCase(request.getFrom())){
@ -136,20 +152,21 @@ public class NoticeController {
String s = HttpUtils.sendPost(url, content, headerMap); String s = HttpUtils.sendPost(url, content, headerMap);
log.info("请求{}的响应{}", url, s); log.info("请求{}的响应{}", url, s);
}else if("xiaomi".equalsIgnoreCase(request.getFrom())){ }else if("xiaomi".equalsIgnoreCase(request.getFrom())){
log.info("oaid : {}, imei:{}", request.getOaid(), request.getImei());
String imei = request.getImei(); String imei = request.getImei();
String oaid = request.getOaid(); String oaid = request.getOaid();
String ua = "Dalvik/2.1.0 (Linux; U; Android 11; M2012K11AC Build/RKQ1.200826.002)"; // String ua = "Dalvik/2.1.0 (Linux; U; Android 11; M2012K11AC Build/RKQ1.200826.002)";
String clientIp = "127.0.0.1"; String clientIp = "58.49.150.163";
long convTime = System.currentTimeMillis(); long convTime = System.currentTimeMillis();
String convType = "APP_PAY_NEW"; String convType = "APP_REGISTER";
long appId = 1545362; long appId = 1545362;
int customerId = 1545362; int customerId = 445972;
String singKey = "IIUWoEaMXlzctOqk"; String singKey = "rEQNdyVQxHlayYzw";
String encryptKey = "FkqMqeKVbCaeSGBI"; String encryptKey = "RPeKBIdybnbMAVlK";
GlobalLogHelper.UploadInfo uploadInfo = GlobalLogHelper.UploadInfo.builder() GlobalLogHelper.UploadInfo uploadInfo = GlobalLogHelper.UploadInfo.builder()
.imei(imei) // .imei(imei)
.oaid(oaid) .oaid(oaid)
.ua(ua) // .ua(ua)
.clientIp(clientIp) .clientIp(clientIp)
.convTime(convTime).convType(convType) .convTime(convTime).convType(convType)
.appId(appId).customerId(customerId).signKey(singKey).encryptKey(encryptKey).build().genInfo(); .appId(appId).customerId(customerId).signKey(singKey).encryptKey(encryptKey).build().genInfo();
@ -163,22 +180,6 @@ public class NoticeController {
e.printStackTrace(); e.printStackTrace();
log.error("回调oppo报错:{}", e.getMessage()); log.error("回调oppo报错:{}", e.getMessage());
} }
// 请求次数入库
try {
ClewPhone param = new ClewPhone();
param.setPhone(request.getPhone());
List<ClewPhone> clewPhones = clewPhoneService.selectClewPhoneList(param);
if(CollectionUtils.isEmpty(clewPhones)){
ClewPhone model = new ClewPhone();
model.setPhone(request.getPhone());
model.setCreateTime(new Date());
model.setRemark(request.getFrom());
clewPhoneService.insertClewPhone(model);
}
}catch (Exception e){
e.printStackTrace();
log.error("手机号入库失败!,原因:{}", e.getMessage());
}
}catch (Exception e){ }catch (Exception e){
log.error("给 {} 发送短信失败 {}", request.getPhone(), ExceptionUtil.getExceptionMessage(e)); log.error("给 {} 发送短信失败 {}", request.getPhone(), ExceptionUtil.getExceptionMessage(e));

View File

@ -46,7 +46,7 @@ public class GlobalLogHelper {
private String signature; private String signature;
private final static String HOST = "http://trail.e.mi.com"; private final static String HOST = "http://trail.e.mi.com";
private final static String PATH = "/global/test"; private final static String PATH = "/global/log";
@SneakyThrows @SneakyThrows
public UploadInfo genInfo() { public UploadInfo genInfo() {

View File

@ -16,7 +16,7 @@ ruoyi:
# 开发环境配置 # 开发环境配置
server: server:
# 服务器的HTTP端口默认为80 # 服务器的HTTP端口默认为80
port: 8001 port: 19002
servlet: servlet:
# 应用的访问路径 # 应用的访问路径
context-path: / context-path: /