更新缓存。。。

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/admin/IKylinRecommendActiveService.java

@@ -19,6 +19,8 @@ public interface IKylinRecommendActiveService extends IService<KylinRecommendAct
     boolean updateKylinRecommendActive(KylinRecommendActive kylinRecommendActive);
     List<KylinRecommendActive>  pageKylinAcitve(int pageSize, int pageNumber);
     KylinRecommendActive getKylinRecommendActiveById(int mid);
+    KylinRecommendActive getByRecommendId(String id);
     int validateTime(KylinRecommendActive kylinRecommendActive);
     void updateRedis(KylinRecommendActive kylinRecommendActive);
+
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRecommendActiveRelationServiceImpl.java

@@ -2,6 +2,7 @@ package com.liquidnet.client.admin.zhengzai.kylin.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.kylin.entity.KylinRecommendActive;
 import com.liquidnet.service.kylin.entity.KylinRecommendActiveRelation;
 import com.liquidnet.service.kylin.mapper.KylinRecommendActiveRelationMapper;
 import com.liquidnet.service.kylin.service.admin.IKylinRecommendActiveRelationService;
@@ -20,6 +21,8 @@ import java.time.LocalDateTime;
  */
 @Service
 public class KylinRecommendActiveRelationServiceImpl extends ServiceImpl<KylinRecommendActiveRelationMapper, KylinRecommendActiveRelation> implements IKylinRecommendActiveRelationService {
+    @Autowired
+    private KylinRecommendActiveServiceImpl kylinRecommendActiveService;
     @Autowired
     private KylinRecommendActiveRelationMapper kylinRecommendActiveRelationMapper;
     @Override
@@ -29,6 +32,9 @@ public class KylinRecommendActiveRelationServiceImpl extends ServiceImpl<KylinRe
         kylinRecommendActiveRelation.setCreatedAt(LocalDateTime.now());
         kylinRecommendActiveRelation.setRecommendRelationId(IDGenerator.nextSnowId());
         kylinRecommendActiveRelationMapper.insert(kylinRecommendActiveRelation);
+        //更新 redis
+        KylinRecommendActive byRecommendId = kylinRecommendActiveService.getByRecommendId(kylinRecommendActiveRelation.getRecommendActiveId());
+        kylinRecommendActiveService.updateRedis(byRecommendId);
         return true;
     }
 
@@ -36,6 +42,9 @@ public class KylinRecommendActiveRelationServiceImpl extends ServiceImpl<KylinRe
     public boolean deleteKylinRecommendActiveRelation(KylinRecommendActiveRelation kylinRecommendActiveRelation) {
         kylinRecommendActiveRelation.setDelTag(1);
         kylinRecommendActiveRelationMapper.updateById(kylinRecommendActiveRelation);
+        //更新 redis
+        KylinRecommendActive byRecommendId = kylinRecommendActiveService.getByRecommendId(kylinRecommendActiveRelation.getRecommendActiveId());
+        kylinRecommendActiveService.updateRedis(byRecommendId);
         return true;
     }
 

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRecommendActiveServiceImpl.java

@@ -87,6 +87,13 @@ public class KylinRecommendActiveServiceImpl extends ServiceImpl<KylinRecommendA
         return kylinRecommendActive;
     }
 
+    @Override
+    public KylinRecommendActive getByRecommendId(String id) {
+        LambdaQueryWrapper<KylinRecommendActive> queryWrapper = Wrappers.lambdaQuery(KylinRecommendActive.class);
+        queryWrapper.eq(KylinRecommendActive::getRecommendId,id);
+        return  kylinRecommendActiveMapper.selectOne(queryWrapper);
+    }
+
     @Override
     public int validateTime(KylinRecommendActive kylinRecommendActive) {
         return   kylinRecommendActiveMapper.validateTime(kylinRecommendActive);