zoujiajian 1 năm trước cách đây
mục cha
commit
348eed519a

+ 1 - 0
netflix-service/src/main/java/com/cyksj/redis/RedisService.java

@@ -858,6 +858,7 @@ public class RedisService {
         CORP_WX_YL_KEY("corp_wx_yl_key:", "企业微信引流", 60 * 30),
         TG_MINI_USER_SAHRE_COUNT_KEY("mini_popualrize_user_sahre_count_key:", "推广小程序用户分享次数key", 60 * 60 * 24l),
         GPT_RECHARGE_KEY("gpt_recharge_key:", "gpt代充", 60),
+        GPT_RECHARGE_RECOVER_KEY("gpt_recharge_recover_key:", "gpt代充恢复key", 60 * 5l),
         ;
 
         private String name;

+ 5 - 0
netflix-service/src/main/java/com/cyksj/server/recharge/impl/GptProxyRechargeServiceImpl.java

@@ -314,6 +314,11 @@ public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {
 								.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;
+					}
+				}
 				relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
 						.set(rechargeStatus == GroupsRelation.RechargeStatus.recharge_error, GroupsRelation::getRechargeRemainNum, rechargeRemainNum + 1)
 						.set(GroupsRelation::getRechargeStatus, rechargeStatus)

+ 1 - 0
netflix-web/src/main/java/com/cyksj/web/controller/recharge/GptRechargeController.java

@@ -49,6 +49,7 @@ public class GptRechargeController {
      */
     @GetMapping("/task-status/{taskId}")
     public Result<TaskResult> getTaskStatus(@PathVariable String taskId) {
+        long userId = StpUserUtil.getLoginIdAsLong();
         return GatewayResponse.SUCCESS.newBuilder().toResult(gptProxyRechargeService.getTaskResult(taskId));
     }
 }