更新缓存

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinRedisConst.java

@@ -96,6 +96,8 @@ public class KylinRedisConst {
     public  static final String ACTIVE_TICKET_AR_TICKET = "kylin:active:ar:ticket:";//互动券
     public  static final String ACTIVE_TICKET_AR_USER = "kylin:active:ar:user:";//互动券 绑定的用户
 
+    public  static final String RECOMMEND_ACTIVE = "kylin:active:recommend:";// 推荐活动
+
     /**
      * 巡演券
      * eg:{kylin:c_rs:${couponId}, List<巡演ID>}

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

@@ -20,4 +20,5 @@ public interface IKylinRecommendActiveService extends IService<KylinRecommendAct
     List<KylinRecommendActive>  pageKylinAcitve(int pageSize, int pageNumber);
     KylinRecommendActive getKylinRecommendActiveById(int mid);
     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/KylinRecommendActiveServiceImpl.java

@@ -4,7 +4,9 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.entity.KylinRecommendActive;
 import com.liquidnet.service.kylin.entity.KylinRecommendActiveRelation;
 import com.liquidnet.service.kylin.mapper.KylinRecommendActiveMapper;
@@ -14,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -30,6 +33,8 @@ public class KylinRecommendActiveServiceImpl extends ServiceImpl<KylinRecommendA
     private KylinRecommendActiveMapper kylinRecommendActiveMapper;
     @Autowired
     private KylinRecommendActiveRelationMapper kylinRecommendActiveRelationMapper;
+    @Autowired
+    RedisDataSourceUtil redisDataSourceUtil;
 
     @Override
     public boolean addKylinRecommendActive(KylinRecommendActive kylinRecommendActive, List<KylinRecommendActiveRelation> kylinRecommendActiveRelations) {
@@ -47,12 +52,16 @@ public class KylinRecommendActiveServiceImpl extends ServiceImpl<KylinRecommendA
             r.setRecommendActiveId(kylinRecommendActive.getRecommendId());
             kylinRecommendActiveRelationMapper.insert(r);
         });
+        //更新redis数据
+        this.updateRedis(kylinRecommendActive);
         return true;
     }
 
     @Override
     public boolean updateKylinRecommendActive(KylinRecommendActive kylinRecommendActive) {
         kylinRecommendActiveMapper.updateById(kylinRecommendActive);
+        //更新redis数据
+        this.updateRedis(kylinRecommendActive);
         return true;
     }
 
@@ -82,4 +91,16 @@ public class KylinRecommendActiveServiceImpl extends ServiceImpl<KylinRecommendA
     public int validateTime(KylinRecommendActive kylinRecommendActive) {
         return   kylinRecommendActiveMapper.validateTime(kylinRecommendActive);
     }
+
+    @Override
+    public void updateRedis(KylinRecommendActive kylinRecommendActive) {
+        //查出这个类型， 这个演出  对应配置的数据
+        List<KylinRecommendActive> list= kylinRecommendActiveMapper.getBybindId(kylinRecommendActive.getActiveType(),kylinRecommendActive.getActiveBindId());
+        List<KylinRecommendActive> redisList=new ArrayList<>();
+        list.forEach(r->{
+            //查推荐商品
+            redisList.add( this.getKylinRecommendActiveById(r.getMid().intValue()));
+        });
+        redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.RECOMMEND_ACTIVE, redisList);
+    }
 }

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinRecommendActiveMapper.java

@@ -2,6 +2,9 @@ package com.liquidnet.service.kylin.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.liquidnet.service.kylin.entity.KylinRecommendActive;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * <p>
@@ -13,4 +16,5 @@ import com.liquidnet.service.kylin.entity.KylinRecommendActive;
  */
 public interface KylinRecommendActiveMapper extends BaseMapper<KylinRecommendActive> {
         int validateTime(KylinRecommendActive kylinRecommendActive);
+        List<KylinRecommendActive> getBybindId(@Param("type") int type,@Param("bindId")String bindId);
 }

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/kylinRecommendActiveMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.liquidnet.service.kylin.mapper.KylinRecommendActiveMapper">
+    <resultMap id="BaseResultMap" type="com.liquidnet.service.kylin.entity.KylinRecommendActive">
+        <id column="mid" jdbcType="BIGINT" property="mid" />
+        <result column="recommend_id" jdbcType="VARCHAR" property="recommendId" />
+        <result column="start_time" jdbcType="TIMESTAMP" property="startTime" />
+        <result column="end_time" jdbcType="TIMESTAMP" property="endTime" />
+        <result column="active_type" jdbcType="INTEGER" property="activeType" />
+        <result column="active_bind_id" jdbcType="VARCHAR" property="activeBindId" />
+        <result column="del_tag" jdbcType="INTEGER" property="delTag" />
+        <result column="created_at" jdbcType="TIMESTAMP" property="createdAt" />
+        <result column="updated_at" jdbcType="TIMESTAMP" property="updatedAt" />
+        <result column="status" jdbcType="INTEGER" property="status" />
+    </resultMap>
     <!-- getBannersRelationsId  -->
     <select id="validateTime" parameterType="com.liquidnet.service.kylin.entity.KylinRecommendActive" resultType="int">
     select count(1) from  kylin_recommend_active
@@ -8,4 +20,8 @@
     or #{endTime} BETWEEN start_time and end_time) and active_type=#{activeType} and active_bind_id=#{activeBindId}
     </select>
 
+    <select id="getBybindId"  resultMap="BaseResultMap">
+    select * from kylin_recommend_active where active_type=#{type} and active_bind_id=#{bindId} and del_tag=0 and `status`=0 ORDER BY start_time asc
+    </select>
+
 </mapper>