zoujiajian 2 yıl önce
ebeveyn
işleme
b0d45cb0a9

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

@@ -843,7 +843,7 @@ public class RedisService {
         APPLY_MONEY_DAY_LIMIT_KEY("apply_money_day_limit_key:%s:%s:%s", "每日提现次数限制", 60 * 60 * 24L),
         NETFLIX_SET_LIMIT_TIME("netflix_set_limit_time", "奈飞设置限制", 30l),
         LUMA_USER("luma_user:", "luma_user", 60 * 60 * 2L),
-        LUMA_USER_MUM_LIMIT("luma_user_mum_limit:", "luma_user 生成视频次数", 60 * 60 * 48L),
+        LUMA_NUM_LIMIT("luma_num_limit:", "luma次数", 60 * 60 * 48L),
         ;
 
         private String name;

+ 1 - 1
netflix-service/src/main/java/com/cyksj/service/luma/impl/LumaServiceImpl.java

@@ -125,7 +125,7 @@ public class LumaServiceImpl implements LumaService {
 			lumaUserMapper.insert(lumaUser);
 		} catch (DuplicateKeyException e) {
 		}
-		redisService.set(RedisService.key.LUMA_USER_MUM_LIMIT.getName() + lumaUser.getId(), lumaUser.getNum(), RedisService.key.LUMA_USER_MUM_LIMIT.getTimeout());
+		redisService.set(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), lumaUser.getNum(), RedisService.key.LUMA_NUM_LIMIT.getTimeout());
 		return lumaUser;
 	}
 

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

@@ -522,9 +522,9 @@ public class CmsOrderDonServiceImpl extends ServiceImpl<OrderDonMapper,OrderDon>
                 if (update == 0) {
                     log.info("lumaUser 套餐包增值失败 id:{},orderId:{}", lumaUser.getId(), orderDon.getId());
                 }
-                Long decr = redisService.decr(RedisService.key.LUMA_USER_MUM_LIMIT.getName() + lumaUser.getId(), upgradePackage.getNum().longValue());
+                Long decr = redisService.decr(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), upgradePackage.getNum().longValue());
                 if (decr < 0) {
-                    redisService.set(RedisService.key.LUMA_USER_MUM_LIMIT.getName() + lumaUser.getId(), 0L);
+                    redisService.set(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), 0L);
                 }
             }
         }

+ 14 - 0
netflix-service/src/main/java/com/cyksj/service/mange/impl/MirrorUserCleatServiceImpl.java

@@ -2,6 +2,7 @@ package com.cyksj.service.mange.impl;
 
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.cyksj.common.constant.Constant;
 import com.cyksj.mapper.*;
 import com.cyksj.model.entity.*;
 import com.cyksj.redis.RedisService;
@@ -43,6 +44,8 @@ public class MirrorUserCleatServiceImpl implements MirrorUserCleatService {
 
 	private final GroupsMapper groupsMapper;
 
+	private final LumaUserMapper lumaUserMapper;
+
 	@Override
 	public void delMirrorUser(Long goodsId, Long relationId) {
 		//gpt镜像
@@ -64,6 +67,17 @@ public class MirrorUserCleatServiceImpl implements MirrorUserCleatService {
 				redisService.del(RedisService.key.MIDJOURNEY_USER.getName() + user.getUserToken());
 			}
 		}
+
+		//luma
+		if (goodsId != null && goodsId == Constant.LUMA_GOODS_ID) {
+			LumaUser user = lumaUserMapper.selectOne(Wrappers.lambdaQuery(LumaUser.class)
+					.eq(LumaUser::getRelationId, relationId).last("limit 1"));
+			if (user != null) {
+				lumaUserMapper.delete(Wrappers.lambdaQuery(LumaUser.class)
+						.eq(LumaUser::getRelationId, relationId));
+				redisService.del(RedisService.key.LUMA_NUM_LIMIT.getName() + user.getId());
+			}
+		}
 	}
 
 	@Override

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

@@ -3605,11 +3605,11 @@ public class OrderDonServiceImpl extends ServiceImpl<OrderDonMapper, OrderDon> i
 				if (update == 0) {
 					log.info("lumaUser 套餐包增值失败 id:{},orderId:{}", lumaUser.getId(), orderDon.getId());
 				}
-				Object num = redisService.get(RedisService.key.LUMA_USER_MUM_LIMIT.getName() + lumaUser.getId());
+				Object num = redisService.get(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId());
 				if (num == null) {
-					redisService.set(RedisService.key.LUMA_USER_MUM_LIMIT.getName() + lumaUser.getId(), lumaUser.getNum() + upgradePackage.getNum().longValue(), RedisService.key.LUMA_USER_MUM_LIMIT.getTimeout());
+					redisService.set(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), lumaUser.getNum() + upgradePackage.getNum().longValue(), RedisService.key.LUMA_NUM_LIMIT.getTimeout());
 				} else {
-					redisService.incr(RedisService.key.LUMA_USER_MUM_LIMIT.getName() + lumaUser.getId(), upgradePackage.getNum().longValue());
+					redisService.incr(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), upgradePackage.getNum().longValue());
 				}
 			}
 		}