fix 加量包

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

@@ -1184,14 +1184,15 @@ public class ClaudeCodeServiceImpl implements ClaudeCodeService {
 
 	@Override
 	public void adjClaudeCodeUserPoints(Long userId, Integer points, String type, String description) throws Exception {
-		String apiKeyUrl = String.format(Constant.CLAUDE_CODE_API_PREFIX + "api/claude/users/%s/limit", userId);
+		String apiKeyUrl = String.format(Constant.CLAUDE_CODE_API_PREFIX + "api/users/%/balance/adjust", userId);
 		Map<String, Object> parmas = new HashMap<>();
+		parmas.put("platform", "claude");
 		parmas.put("amount", points);
 		parmas.put("type", type);
 		parmas.put("description", description);
 		ClaudeCodeResp claudeCodeResp = executeClaudeCodePostApi(apiKeyUrl, Jsons.toJson(parmas));
 		if (!Constant.SUCCESS.equals(claudeCodeResp.getMessage())) {
-			throw BusinessRuntimeException.getInstance("调整用户：{}额度:{}失败", userId, points);
+			throw BusinessRuntimeException.getInstance("调整cc用户：{}额度:{}失败", userId, points);
 		}
 	}
 

netflix-service/src/main/java/com/cyksj/service/codex/CodexService.java

@@ -84,4 +84,6 @@ public interface CodexService {
      * 续费升级
      */
     void handleClaudeCodeUserPackageSku(GroupsRelation relation, GoodsDonSku sku, Long id);
+
+	void adjCodexUserPoints(Long userId, Integer points, String type, String description) throws Exception;
 }

netflix-service/src/main/java/com/cyksj/service/codex/impl/CodexServiceImpl.java

@@ -1188,6 +1188,20 @@ public class CodexServiceImpl implements CodexService {
 		createOrUpdateCodexUserInfo(orderId, relation.getId(), relation.getUserId(), sku, 2);
 	}
 
+	@Override
+	public void adjCodexUserPoints(Long userId, Integer points, String type, String description) throws Exception {
+		String apiKeyUrl = String.format(Constant.CLAUDE_CODE_API_PREFIX + "api/users/%/balance/adjust", userId);
+		Map<String, Object> parmas = new HashMap<>();
+		parmas.put("platform", "codex");
+		parmas.put("amount", points);
+		parmas.put("type", type);
+		parmas.put("description", description);
+		ClaudeCodeResp claudeCodeResp = executeCodexPostApi(apiKeyUrl, Jsons.toJson(parmas));
+		if (!Constant.SUCCESS.equals(claudeCodeResp.getMessage())) {
+			throw BusinessRuntimeException.getInstance("调整codex用户：{}额度:{}失败", userId, points);
+		}
+	}
+
 	/**
 	 * 校验是否是codex用户
 	 * @param userId

netflix-service/src/main/java/com/cyksj/service/mange/impl/CmsOrderDonServiceImpl.java

@@ -54,6 +54,7 @@ import com.cyksj.model.request.OrderRefundReq;
 import com.cyksj.redis.RedisService;
 import com.cyksj.service.chatgpt.GptUserRechargeRecordService;
 import com.cyksj.service.claude.ClaudeCodeService;
+import com.cyksj.service.codex.CodexService;
 import com.cyksj.service.coin.UserGalaxyCoinService;
 import com.cyksj.service.coupon.CouponFontService;
 import com.cyksj.service.distribute.equipment.EquipmentDistributeService;
@@ -242,6 +243,8 @@ public class CmsOrderDonServiceImpl extends ServiceImpl<OrderDonMapper,OrderDon>
 
     private final CodexUserMapper codexUserMapper;
 
+    private final CodexService codexService;
+
     private static final GlobalThreadPoolTaskExecutor TASK_POOL = GlobalThreadPoolTaskExecutor.getInstance();
 
     @Override
@@ -613,8 +616,13 @@ public class CmsOrderDonServiceImpl extends ServiceImpl<OrderDonMapper,OrderDon>
                         .eq(CodexUser::getId, codexUser.getId()));
                 if (update == 0) {
                     log.info("codex user 套餐包增值失败 id:{},orderId:{}", codexUser.getId(), orderDon.getId());
+                } else {
+                    try {
+                        codexService.adjCodexUserPoints(codexUser.getUserId(), -upgradePackage.getNum(), "adjustment", "加量包退款");
+                    } catch (Exception e) {
+
+                    }
                 }
-                //TODO
             }
         }
     }

netflix-service/src/main/java/com/cyksj/service/order/impl/OrderDonServiceImpl.java

@@ -4581,7 +4581,7 @@ public class OrderDonServiceImpl extends ServiceImpl<OrderDonMapper, OrderDon> i
 					log.info("cc user 套餐包增值失败 id:{},orderId:{}", claudeCodeUser.getId(), orderDon.getId());
 				}else {
 					try {
-						claudeCodeService.adjClaudeCodeUserPoints(claudeCodeUser.getUserId(), upgradePackage.getNum(), "adjustment", "加量包");
+						claudeCodeService.adjClaudeCodeUserPoints(claudeCodeUser.getUserId(), upgradePackage.getNum(), "adjustment", "购买加量包");
 					} catch (Exception e) {
 
 					}
@@ -4598,6 +4598,12 @@ public class OrderDonServiceImpl extends ServiceImpl<OrderDonMapper, OrderDon> i
 						.eq(CodexUser::getId, codexUser.getId()));
 				if (update == 0) {
 					log.info("codex user 套餐包增值失败 id:{},orderId:{}", codexUser.getId(), orderDon.getId());
+				} else {
+					try {
+						codexService.adjCodexUserPoints(codexUser.getUserId(), upgradePackage.getNum(), "adjustment", "购买加量包");
+					} catch (Exception e) {
+
+					}
 				}
 			}
 		}