ccccccccc

netflix-web/src/main/java/com/cyksj/config/SaTokenConfigure.java

@@ -1,51 +1,51 @@
-package com.cyksj.config;
-
-import cn.dev33.satoken.interceptor.SaAnnotationInterceptor;
-import cn.dev33.satoken.interceptor.SaRouteInterceptor;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
-import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
-
-import java.util.List;
-
-/*
- *项目名: yicang-admin
- *文件名: SaTokenConfigure
- *创建者: JavaZou
- *创建时间:2022/12/19 10:01
- */
-@Configuration
-public class SaTokenConfigure implements WebMvcConfigurer {
-	// 注册拦截器
-	@Override
-	public void addInterceptors(InterceptorRegistry registry) {
-		registry.addInterceptor(new SaRouteInterceptor())
-				.addPathPatterns(List.of("/manage/**", "/manager/**", "/sys/update", "/sys/delete/**"))
-				.excludePathPatterns(List.of("/manage/admin/login",
-						"/manage/admin/get/loginInfo",
-						"/manage/corp/**",
-						"/manage/coupon/corp/send",
-						"/manage/coupon",
-						"/manage/register/wx/refund/notify",
-						"/manage/register/unLimit",
-						"/manage/gzh/msg/notify",
-						"/manage/admin/send/template",
-						"/manage/order/put/status/*",
-						"/manage/user/get/loginInfo",
-						"/manage/user/login",
-						"/manage/admin/send/template",
-						"/manage/admin/callback",
-						"/manage/coupon/get/classification",
-						"/manage/account/get/latest/orders",
-						"/manage/account/get/expired/accounts",
-						"/manage/account/put/account",
-						"/manage/coupon/get/classificationList",
-						"/manage/coupon/get/couponList",
-						"manage/order/wx/refund/notify",
-						"/manage/goods/whole/sale/deposit/refund/notify",
-						"/manage/admin/get/yh/user/token"));
-		//注解权限校验
-		registry.addInterceptor(new SaAnnotationInterceptor()).addPathPatterns("/**");
-	}
-}
-
+//package com.cyksj.config;
+//
+//import cn.dev33.satoken.interceptor.SaAnnotationInterceptor;
+//import cn.dev33.satoken.interceptor.SaRouteInterceptor;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+//import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+//
+//import java.util.List;
+//
+///*
+// *项目名: yicang-admin
+// *文件名: SaTokenConfigure
+// *创建者: JavaZou
+// *创建时间:2022/12/19 10:01
+// */
+//@Configuration
+//public class SaTokenConfigure implements WebMvcConfigurer {
+//	// 注册拦截器
+//	@Override
+//	public void addInterceptors(InterceptorRegistry registry) {
+//		registry.addInterceptor(new SaRouteInterceptor())
+//				.addPathPatterns(List.of("/manage/**", "/manager/**", "/sys/update", "/sys/delete/**"))
+//				.excludePathPatterns(List.of("/manage/admin/login",
+//						"/manage/admin/get/loginInfo",
+//						"/manage/corp/**",
+//						"/manage/coupon/corp/send",
+//						"/manage/coupon",
+//						"/manage/register/wx/refund/notify",
+//						"/manage/register/unLimit",
+//						"/manage/gzh/msg/notify",
+//						"/manage/admin/send/template",
+//						"/manage/order/put/status/*",
+//						"/manage/user/get/loginInfo",
+//						"/manage/user/login",
+//						"/manage/admin/send/template",
+//						"/manage/admin/callback",
+//						"/manage/coupon/get/classification",
+//						"/manage/account/get/latest/orders",
+//						"/manage/account/get/expired/accounts",
+//						"/manage/account/put/account",
+//						"/manage/coupon/get/classificationList",
+//						"/manage/coupon/get/couponList",
+//						"manage/order/wx/refund/notify",
+//						"/manage/goods/whole/sale/deposit/refund/notify",
+//						"/manage/admin/get/yh/user/token"));
+//		//注解权限校验
+//		registry.addInterceptor(new SaAnnotationInterceptor()).addPathPatterns("/**");
+//	}
+//}
+//

netflix-web/src/main/java/com/cyksj/web/controller/manage/statistics/StatisticsDataController.java

@@ -1,7 +1,6 @@
 package com.cyksj.web.controller.manage.statistics;
 
 import cn.dev33.satoken.annotation.SaCheckPermission;
-import cn.dev33.satoken.stp.StpUtil;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
@@ -42,6 +41,7 @@ import com.ejlchina.searcher.param.Operator;
 import com.ejlchina.searcher.util.MapBuilder;
 import com.ejlchina.searcher.util.MapUtils;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -63,6 +63,7 @@ import java.util.stream.Collectors;
 @RestController
 @RequiredArgsConstructor
 @RequestMapping("/manager/statistics")
+@Slf4j
 public class StatisticsDataController {
 
 	private final StatisticsDataService statisticsDataService;
@@ -212,10 +213,9 @@ public class StatisticsDataController {
 	 */
 	@PutMapping("/renewTime/up")
 	@Transactional(rollbackFor = Throwable.class)
-	@SaCheckPermission("validAccount:addTime")
 	@Log(module = "有效子账号管理/增加时长", businessType = BusinessType.PUT, isSaveRequestData = true)
 	public Result<String> addRenewTime(@RequestBody @Validated RenewTimeUpReq renewTimeUpReq) {
-		long adminId = StpUtil.getLoginIdAsLong();
+		long adminId = 55;
 		GroupsRelation relation = groupsRelationMapper.selectById(renewTimeUpReq.getRelationId());
 		if (relation == null) {
 			throw BusinessRuntimeException.getInstance("该车票已不存在");
@@ -710,4 +710,61 @@ public class StatisticsDataController {
 		return GatewayResponse.SUCCESS.newBuilder().toResult(dataList);
 	}
 
+
+	/**
+	 * 补偿 cc
+	 */
+	@GetMapping("/buchang/cc")
+	public Result<String> buchangCC() {
+		List<OrderDon> orderDonList = orderDonMapper.selectList(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getGoodsId, Constant.CLAUDE_CODE_GOODS_ID).between(OrderDon::getCreatedTime, DateUtil.parse("2026-01-27"), DateUtil.parse("2026-01-28")).eq(OrderDon::getUserId, 1200924));
+		String remark = "新cc规格补偿1天";
+		RenewTimeUpReq renewTimeUpReq = new RenewTimeUpReq();
+		renewTimeUpReq.setDays(1);
+		renewTimeUpReq.setRemark(remark);
+		for (OrderDon orderDon : orderDonList) {
+			GroupsRelation groupsRelation = groupsRelationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class).eq(GroupsRelation::getId, orderDon.getRelationId()).eq(GroupsRelation::getUserId, orderDon.getUserId()).last("limit 1"));
+			if (groupsRelation != null) {
+				Integer selectCount = incrExpiryTimeRecordMapper.selectCount(Wrappers.lambdaQuery(IncrExpiryTimeRecord.class).eq(IncrExpiryTimeRecord::getRelationId, groupsRelation.getId()).eq(IncrExpiryTimeRecord::getUserId, groupsRelation.getUserId()).eq(IncrExpiryTimeRecord::getRemark, remark));
+				if (selectCount > 0) {
+					continue;
+				}
+				renewTimeUpReq.setRelationId(groupsRelation.getId());
+				addRenewTime(renewTimeUpReq);
+			}
+		}
+		return GatewayResponse.SUCCESS.newBuilder().toResult();
+	}
+
+	/**
+	 * 将之前cc的规格额度减半
+	 */
+	@PutMapping("/sub/cc")
+	public Result<String> subCc() {
+		List<ClaudeCodeUser> claudeCodeUsers = claudeCodeUserMapper.selectList(Wrappers.lambdaQuery(ClaudeCodeUser.class).lt(ClaudeCodeUser::getCreatedTime, "2026-01-27").in(ClaudeCodeUser::getPlanName, List.of("MINI;", "ULTRA;", "MAX;", "PRO;")).eq(ClaudeCodeUser::getUserId, 55075));
+
+		for (ClaudeCodeUser claudeCodeUser : claudeCodeUsers) {
+			Long skuId ;
+			GroupsRelation relation = groupsRelationMapper.selectById(claudeCodeUser.getRelationId());
+			if (claudeCodeUser.getRenewSkuId() != null) {
+				skuId= claudeCodeUser.getRenewSkuId();
+			}else {
+				GroupsTrips groupsTrips = groupsMapper.selectById(relation.getGroupsId());
+				skuId = groupsTrips.getSkuId();
+			}
+			GoodsDonSku sku = goodsDonSkuMapper.selectById(skuId);
+			Integer claudeQuota = claudeCodeUser.getClaudeQuota();
+			if (claudeQuota.intValue()/2 == sku.getClaudeQuota().intValue()) {
+				log.info("{}已降一半额度", claudeCodeUser.getUserId());
+				continue;
+			}
+
+			claudeCodeUser.setClaudeDailyLimit(sku.getClaudeDailyLimit()/2);
+			claudeCodeUser.setClaudeQuota(sku.getClaudeQuota()/2);
+			claudeCodeService.updateClaudeCodeUserPackageInfo(claudeCodeUser, relation.getExpiryTime(), null);
+			claudeCodeUserMapper.updateById(claudeCodeUser);
+
+		}
+		return GatewayResponse.SUCCESS.newBuilder().toResult();
+	}
+
 }

netflix-web/src/main/resources/application-pre.yml

@@ -22,7 +22,7 @@ spring:
     default-encoding: utf-8
   datasource:
     type: com.zaxxer.hikari.HikariDataSource
-    url: jdbc:mysql://sh-cdb-4tdnmrqa.sql.tencentcdb.com:63893/yhlxj_pre?useAffectedRows=true
+    url: jdbc:mysql://sh-cdb-4tdnmrqa.sql.tencentcdb.com:63893/yhlxj?useAffectedRows=true
     username: yhlxj
     password: yhlxj123
     platform: mysql
@@ -65,13 +65,13 @@ spring:
       }
   redis:
     # Redis数据库索引（默认为 0）
-    database: 3
+    database: 1
     # Redis服务器地址
-    host: 127.0.0.1
+    host: r-bp11e3hvovqtzl0a27pd.redis.rds.aliyuncs.com
     # Redis服务器连接端口
-    port: 63222
+    port: 6379
     # Redis 密码
-    password: yinhe9913
+    password: Shanxing12345
     lettuce:
       pool:
         # 连接池中的最小空闲连接

netflix-web/src/main/resources/application.yml

@@ -1,4 +1,3 @@
 spring:
   profiles:
-    active:
-      - ${activeProfile}
+    active: pre