zoujiajian 1 gadu atpakaļ
vecāks
revīzija
7e0267e87c

+ 7 - 4
netflix-service/src/main/java/com/cyksj/service/claude/impl/ClaudeCodeServiceImpl.java

@@ -159,7 +159,7 @@ public class ClaudeCodeServiceImpl implements ClaudeCodeService {
 			if (expiresDays != null) {
 				parmas.put("expires_days", expiresDays);
 			}
-			String responseBody = executeClaudeCodePostApi(apiKeyUrl, parmas.toString());
+			String responseBody = executeClaudeCodePostApi(apiKeyUrl, Jsons.toJson(parmas));
 			ClaudeCodeResp claudeCodeResp = Jsons.parseObject(responseBody, ClaudeCodeResp.class);
 			if (!Constant.SUCCESS.equals(claudeCodeResp.getMessage())) {
 				throw BusinessRuntimeException.getInstance("创建失败");
@@ -283,6 +283,9 @@ public class ClaudeCodeServiceImpl implements ClaudeCodeService {
 			try {
 				ClaudeCodeResp codeUserPackage = createOrUpdateClaudeCodeUserPackage(claudeCodeUser.getUserId(), claudeCodeUser.getPlanName(), claudeCodeUser.getCodePoints(), claudeCodeUser.getCodeCreditRecovery(), claudeCodeUser.getExpiryTime());
 				if (!Constant.SUCCESS.equals(codeUserPackage.getMessage())) {
+					claudeCodeUser.setIsRetry(Boolean.TRUE);
+					claudeCodeUserMapper.updateById(claudeCodeUser);
+				} else {
 					claudeCodeUser.setIsRetry(Boolean.FALSE);
 					claudeCodeUserMapper.updateById(claudeCodeUser);
 				}
@@ -306,12 +309,12 @@ public class ClaudeCodeServiceImpl implements ClaudeCodeService {
 		parmas.put("plan_name", planName.replaceAll(";", ""));
 		parmas.put("credit_limit", codePoints);
 		parmas.put("credit_recovery", codeCreditRecovery);
-		parmas.put("expire_time", expiryTime);
+		parmas.put("expire_time", DateUtil.format(expiryTime,"yyyy-MM-dd HH:mm:ss"));
 		String planUrl = String.format(CLAUDE_CODE_API_PREFIX + "api/users/%s/plan", userId);
-		String responseBody = executeClaudeCodePostApi(planUrl, parmas.toString());
+		String responseBody = executeClaudeCodePostApi(planUrl, Jsons.toJson(parmas));
 		ClaudeCodeResp claudeCodeResp = Jsons.parseObject(responseBody, ClaudeCodeResp.class);
 		if (!Constant.SUCCESS.equals(claudeCodeResp.getMessage())) {
-			log.info("用户claude code用户:{}套餐:{}创建或更新失败,info:{}", userId, planName, Jsons.toJson(claudeCodeResp.getData()));
+			log.info("用户claude code用户:{}套餐:{}创建或更新失败,info:{}", userId, planName, claudeCodeResp.getMessage());
 		}
 		return claudeCodeResp;
 	}