|
|
@@ -133,8 +133,18 @@ public class AfDianRechargeServiceImpl implements AfDianRechargeService {
|
|
|
JSONObject requestBody = new JSONObject();
|
|
|
requestBody.put("cdk", cardKey);
|
|
|
requestBody.put("user", accessToken);
|
|
|
+ HttpRequest post = HttpRequest.post(url);
|
|
|
+ //模拟浏览器请求
|
|
|
+ post.header("accept", "*/*");
|
|
|
+ post.header("accept-language", "zh-CN,zh;q=0.9,sq;q=0.8,zh-TW;q=0.7");
|
|
|
+ post.header("Content-Type", "text/plain;charset=UTF-8");
|
|
|
+ post.header("Origin", "https://receipt.nitro.xin");
|
|
|
+ post.header("Referer", "https://receipt.nitro.xin/");
|
|
|
+ post.header("User-Agent", "Mozilla/5.0");
|
|
|
+ post.header("x-device-id", "web");
|
|
|
|
|
|
- HttpResponse response = HttpRequest.post(url)
|
|
|
+
|
|
|
+ HttpResponse response = post
|
|
|
.setConnectionTimeout(60000)
|
|
|
.body(requestBody.toString())
|
|
|
.execute();
|
|
|
@@ -270,11 +280,15 @@ public class AfDianRechargeServiceImpl implements AfDianRechargeService {
|
|
|
Integer rechargeRemainNum = relation.getRechargeRemainNum();
|
|
|
String cardKey = relation.getCardKey();
|
|
|
GptRechargeCardKey gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class).eq(GptRechargeCardKey::getCardKey, cardKey).last("limit 1"));
|
|
|
- if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
|
|
|
- if (gptRechargeCardKey != null) {
|
|
|
- gptRechargeCardKeyMapper.update(null, Wrappers.lambdaUpdate(GptRechargeCardKey.class).set(GptRechargeCardKey::getStatus, Boolean.FALSE).set(GptRechargeCardKey::getOrderId, null).set(GptRechargeCardKey::getOrderNo, null).eq(GptRechargeCardKey::getId, gptRechargeCardKey.getId()).eq(GptRechargeCardKey::getStatus, Boolean.TRUE));
|
|
|
- }
|
|
|
- }
|
|
|
+ if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
|
|
|
+ if (gptRechargeCardKey != null) {
|
|
|
+ if ("stock not found.".equals(result)) {
|
|
|
+ gptRechargeCardKeyMapper.update(null, Wrappers.lambdaUpdate(GptRechargeCardKey.class).set(GptRechargeCardKey::getOrderNo, "卡密异常").eq(GptRechargeCardKey::getId, gptRechargeCardKey.getId()).eq(GptRechargeCardKey::getStatus, Boolean.TRUE));
|
|
|
+ } else {
|
|
|
+ gptRechargeCardKeyMapper.update(null, Wrappers.lambdaUpdate(GptRechargeCardKey.class).set(GptRechargeCardKey::getStatus, Boolean.FALSE).set(GptRechargeCardKey::getOrderId, null).set(GptRechargeCardKey::getOrderNo, null).eq(GptRechargeCardKey::getId, gptRechargeCardKey.getId()).eq(GptRechargeCardKey::getStatus, Boolean.TRUE));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
|
|
|
if (!redisService.setNx(RedisService.key.GPT_RECHARGE_RECOVER_KEY.getName() + taskId, taskId, RedisService.key.GPT_RECHARGE_RECOVER_KEY.getTimeout())) {
|
|
|
return;
|