|
@@ -193,8 +193,8 @@ public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {
|
|
|
if (rechargeRemainNum == null || rechargeRemainNum <= 0) {
|
|
if (rechargeRemainNum == null || rechargeRemainNum <= 0) {
|
|
|
throw BusinessRuntimeException.getInstance("剩余可代充次数为0");
|
|
throw BusinessRuntimeException.getInstance("剩余可代充次数为0");
|
|
|
}
|
|
}
|
|
|
- if (relation.getRechargeStatus() == GroupsRelation.RechargeStatus.auto_recharge) {
|
|
|
|
|
- throw BusinessRuntimeException.getInstance("自动充值中");
|
|
|
|
|
|
|
+ if (relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharging) {
|
|
|
|
|
+ throw BusinessRuntimeException.getInstance("正在充值中");
|
|
|
}
|
|
}
|
|
|
int updateRemainNum = relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
|
|
int updateRemainNum = relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
|
|
|
.set(GroupsRelation::getRechargeRemainNum, rechargeRemainNum - 1)
|
|
.set(GroupsRelation::getRechargeRemainNum, rechargeRemainNum - 1)
|
|
@@ -249,7 +249,7 @@ public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {
|
|
|
}
|
|
}
|
|
|
relation.setAccount(rechargeAccount);
|
|
relation.setAccount(rechargeAccount);
|
|
|
relation.setGptToken(accessToken);
|
|
relation.setGptToken(accessToken);
|
|
|
- relation.setRechargeStatus(GroupsRelation.RechargeStatus.auto_recharge);
|
|
|
|
|
|
|
+ relation.setRechargeStatus(GroupsRelation.RechargeStatus.recharging);
|
|
|
relation.setCardKey(gptCardKey);
|
|
relation.setCardKey(gptCardKey);
|
|
|
String taskId = result.getTaskId();
|
|
String taskId = result.getTaskId();
|
|
|
relation.setGptTaskId(taskId);
|
|
relation.setGptTaskId(taskId);
|
|
@@ -262,7 +262,7 @@ public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {
|
|
|
*/
|
|
*/
|
|
|
public void setRechargeRelationStatusAutoError(GroupsRelation relation) {
|
|
public void setRechargeRelationStatusAutoError(GroupsRelation relation) {
|
|
|
TASK_EXECUTOR.execute(()->{
|
|
TASK_EXECUTOR.execute(()->{
|
|
|
- relation.setRechargeStatus(GroupsRelation.RechargeStatus.auto_error);
|
|
|
|
|
|
|
+ relation.setRechargeStatus(GroupsRelation.RechargeStatus.recharge_error);
|
|
|
relationMapper.updateById(relation);
|
|
relationMapper.updateById(relation);
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
@@ -275,10 +275,10 @@ public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {
|
|
|
GroupsRelation relation = relationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
|
|
GroupsRelation relation = relationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
|
|
|
.eq(GroupsRelation::getGptTaskId, taskId)
|
|
.eq(GroupsRelation::getGptTaskId, taskId)
|
|
|
.last("limit 1"));
|
|
.last("limit 1"));
|
|
|
- if (relation != null && relation.getRechargeStatus() == GroupsRelation.RechargeStatus.auto_recharge) {
|
|
|
|
|
|
|
+ if (relation != null && relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharging) {
|
|
|
Integer rechargeRemainNum = relation.getRechargeRemainNum();
|
|
Integer rechargeRemainNum = relation.getRechargeRemainNum();
|
|
|
- GroupsRelation.RechargeStatus rechargeStatus = "completed".equals(status) ? GroupsRelation.RechargeStatus.complete : GroupsRelation.RechargeStatus.auto_error;
|
|
|
|
|
- if (rechargeStatus == GroupsRelation.RechargeStatus.auto_error) {
|
|
|
|
|
|
|
+ GroupsRelation.RechargeStatus rechargeStatus = "completed".equals(status) ? GroupsRelation.RechargeStatus.complete : GroupsRelation.RechargeStatus.recharge_error;
|
|
|
|
|
+ if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
|
|
|
String cardKey = relation.getCardKey();
|
|
String cardKey = relation.getCardKey();
|
|
|
GptRechargeCardKey gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class)
|
|
GptRechargeCardKey gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class)
|
|
|
.eq(GptRechargeCardKey::getCardKey, cardKey)
|
|
.eq(GptRechargeCardKey::getCardKey, cardKey)
|
|
@@ -293,10 +293,10 @@ public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
|
|
relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
|
|
|
- .set(rechargeStatus == GroupsRelation.RechargeStatus.auto_error, GroupsRelation::getRechargeRemainNum, rechargeRemainNum + 1)
|
|
|
|
|
|
|
+ .set(rechargeStatus == GroupsRelation.RechargeStatus.recharge_error, GroupsRelation::getRechargeRemainNum, rechargeRemainNum + 1)
|
|
|
.set(GroupsRelation::getRechargeStatus, rechargeStatus)
|
|
.set(GroupsRelation::getRechargeStatus, rechargeStatus)
|
|
|
.eq(GroupsRelation::getId, relation.getId())
|
|
.eq(GroupsRelation::getId, relation.getId())
|
|
|
- .eq(GroupsRelation::getRechargeStatus, GroupsRelation.RechargeStatus.auto_recharge));
|
|
|
|
|
|
|
+ .eq(GroupsRelation::getRechargeStatus, GroupsRelation.RechargeStatus.recharging));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|