修改上线。

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/goblin/GoblinFrontBannerController.java

@@ -5,6 +5,8 @@ import com.alibaba.fastjson.JSON;
 import com.liquidnet.client.admin.common.core.controller.BaseController;
 import com.liquidnet.client.admin.common.core.domain.AjaxResult;
 import com.liquidnet.client.admin.zhengzai.goblin.service.imp.GoblinFrontBannerServiceImpl;
+import com.liquidnet.client.admin.zhengzai.goblin.service.imp.GoblinFrontHotWordServiceImpl;
+import com.liquidnet.client.admin.zhengzai.goblin.service.imp.GoblinFrontNavigationServiceImpl;
 import com.liquidnet.service.goblin.entity.GoblinFrontBanner;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -26,6 +28,10 @@ import org.springframework.web.bind.annotation.*;
 public class GoblinFrontBannerController extends BaseController {
     @Autowired
     GoblinFrontBannerServiceImpl goblinFrontBannerService;
+    @Autowired
+    GoblinFrontHotWordServiceImpl goblinFrontHotWordService;
+    @Autowired
+    GoblinFrontNavigationServiceImpl goblinFrontNavigationService;
     /**
      * @author zhangfuxin
      * @Description:添加banner
@@ -84,5 +90,23 @@ public class GoblinFrontBannerController extends BaseController {
         return AjaxResult.success(goblinFrontBannerService.bannerPage(pageSize,pageNumber,null));
     }
 
+    @PostMapping("online")
+    @ApiOperation(value = "上线")
+    @ResponseBody
+    public AjaxResult online( ) {
+        logger.info("上线操作");
+        boolean bannerResult=goblinFrontBannerService.online();
+        logger.info("bannerResult,{}",bannerResult);
+        boolean hotWordResult=goblinFrontHotWordService.online();
+        logger.info("hotWordResult,{}",hotWordResult);
+        boolean navigationResult=goblinFrontNavigationService.online();
+        logger.info("navigationResult,{}",navigationResult);
+        if (bannerResult&&hotWordResult&&navigationResult ) {
+            return success("操作成功");
+        } else {
+            return error("操作失败");
+        }
+    }
+
 
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/goblin/GoblinFrontHotWordController.java

@@ -6,6 +6,7 @@ import com.liquidnet.client.admin.common.core.controller.BaseController;
 import com.liquidnet.client.admin.common.core.domain.AjaxResult;
 import com.liquidnet.client.admin.zhengzai.goblin.service.imp.GoblinFrontHotWordServiceImpl;
 import com.liquidnet.service.goblin.entity.GoblinFrontHotWord;
+import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -19,6 +20,7 @@ import org.springframework.web.bind.annotation.*;
  * @author liquidnet
  * @since 2021-12-28
  */
+@Api(tags = "热点管理")
 @RestController
 @RequestMapping("/hotWord")
 public class GoblinFrontHotWordController extends BaseController {

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/service/imp/GoblinFrontBannerServiceImpl.java

 package com.liquidnet.client.admin.zhengzai.goblin.service.imp;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -8,11 +9,15 @@ import com.github.pagehelper.PageInfo;
 import com.liquidnet.client.admin.zhengzai.goblin.service.IGoblinFrontBannerService;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.entity.GoblinFrontBanner;
 import com.liquidnet.service.goblin.mapper.GoblinFrontBannerMapper;
+import com.mongodb.BasicDBObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -112,6 +117,30 @@ public class GoblinFrontBannerServiceImpl extends ServiceImpl<GoblinFrontBannerM
         }
         return pageInfoTmp;
     }
+    public boolean online(){
+        //banner
+        LambdaQueryWrapper<GoblinFrontBanner> queryWrapper = Wrappers.lambdaQuery(GoblinFrontBanner.class);
+        queryWrapper.ne(GoblinFrontBanner::getDelTag,1);
+        queryWrapper.orderByDesc(GoblinFrontBanner::getIndexs);
+        List<GoblinFrontBanner> list=goblinFrontBannerMapper.selectList(queryWrapper);
+        //mongodb
+        for(GoblinFrontBanner goblinFrontBanner: list){
+            GoblinFrontBanner goblinFrontBanner1=mongoTemplate.findOne(Query.query(Criteria.where("bannerId").is(goblinFrontBanner.getBannerId())), GoblinFrontBanner.class, GoblinFrontBanner.class.getSimpleName());
+            if(null==goblinFrontBanner1){
+                mongoTemplate.save(goblinFrontBanner,GoblinFrontBanner.class.getSimpleName());
+            }else{
+                BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(goblinFrontBanner)));
+                mongoTemplate.getCollection(GoblinFrontBanner.class.getSimpleName()).updateOne(
+                        Query.query(Criteria.where("bannerId").is(goblinFrontBanner.getBannerId())).getQueryObject(),
+                        orderObject
+                );
+            }
+        }
+        //redis
+        redisDataSourceUtil.getRedisGoblinUtil().set(GoblinRedisConst.FRONT_BANNER,list);
+        return true;
+    }
+
 
 
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/service/imp/GoblinFrontHotWordServiceImpl.java

 package com.liquidnet.client.admin.zhengzai.goblin.service.imp;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -8,11 +9,15 @@ import com.github.pagehelper.PageInfo;
 import com.liquidnet.client.admin.zhengzai.goblin.service.IGoblinFrontHotWordService;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.entity.GoblinFrontHotWord;
 import com.liquidnet.service.goblin.mapper.GoblinFrontHotWordMapper;
+import com.mongodb.BasicDBObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -114,6 +119,37 @@ public class GoblinFrontHotWordServiceImpl extends ServiceImpl<GoblinFrontHotWor
         }
         return pageInfoTmp;
     }
+    public boolean online(){
+        LambdaQueryWrapper<GoblinFrontHotWord> queryWrapper = Wrappers.lambdaQuery(GoblinFrontHotWord.class);
+        queryWrapper.ne(GoblinFrontHotWord::getDelTag,1);
+        queryWrapper.orderByDesc(GoblinFrontHotWord::getIndexs);
+        List<GoblinFrontHotWord> list=goblinFrontHotWordMapper.selectList(queryWrapper);
+        for(GoblinFrontHotWord goblinFrontHotWord: list){
+            //查看 mongodb 有没有
+            GoblinFrontHotWord goblinFrontHotWord1=mongoTemplate.findOne(Query.query(Criteria.where("hotWordId").is(goblinFrontHotWord.getHotWordId())), GoblinFrontHotWord.class, GoblinFrontHotWord.class.getSimpleName());
+            if(null==goblinFrontHotWord1){
+                mongoTemplate.save(goblinFrontHotWord,GoblinFrontHotWord.class.getSimpleName());
+            }else{
+                BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(goblinFrontHotWord)));
+                mongoTemplate.getCollection(GoblinFrontHotWord.class.getSimpleName()).updateOne(
+                        Query.query(Criteria.where("hotWordId").is(goblinFrontHotWord.getHotWordId())).getQueryObject(),
+                        orderObject
+                );
+            }
+
+        }
+        GoblinFrontHotWord goblinFrontHotWord=list.get(0);
+        if(null!=goblinFrontHotWord){
+            //redis
+            if(null!=goblinFrontHotWord.getChangeTime()&&goblinFrontHotWord.getChangeTime()>0){
+                redisDataSourceUtil.getRedisGoblinUtil().set(GoblinRedisConst.FRONT_HOTWORD,list.get(0),goblinFrontHotWord.getChangeTime());
+            }else{
+                redisDataSourceUtil.getRedisGoblinUtil().set(GoblinRedisConst.FRONT_HOTWORD,list.get(0));
+            }
+
+        }
+        return true;
+    }
 
 
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/service/imp/GoblinFrontNavigationServiceImpl.java

 package com.liquidnet.client.admin.zhengzai.goblin.service.imp;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -8,11 +9,15 @@ import com.github.pagehelper.PageInfo;
 import com.liquidnet.client.admin.zhengzai.goblin.service.IGoblinFrontNavigationService;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.entity.GoblinFrontNavigation;
 import com.liquidnet.service.goblin.mapper.GoblinFrontNavigationMapper;
+import com.mongodb.BasicDBObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -94,4 +99,27 @@ public class GoblinFrontNavigationServiceImpl extends ServiceImpl<GoblinFrontNav
         return pageInfoTmp;
     }
 
+    public boolean online(){
+        LambdaQueryWrapper<GoblinFrontNavigation> queryWrapper = Wrappers.lambdaQuery(GoblinFrontNavigation.class);
+        queryWrapper.ne(GoblinFrontNavigation::getDelTag,1);
+        queryWrapper.orderByDesc(GoblinFrontNavigation::getIndexs);
+        List<GoblinFrontNavigation> list=goblinFrontNavigationMapper.selectList(queryWrapper);
+        //mongodb
+        for(GoblinFrontNavigation goblinFrontNavigation: list){
+            GoblinFrontNavigation goblinFrontNavigation1=mongoTemplate.findOne(Query.query(Criteria.where("navigationId").is(goblinFrontNavigation.getNavigationId())), GoblinFrontNavigation.class, GoblinFrontNavigation.class.getSimpleName());
+            if(null==goblinFrontNavigation1){
+                mongoTemplate.save(goblinFrontNavigation,GoblinFrontNavigation.class.getSimpleName());
+            }else{
+                BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(goblinFrontNavigation)));
+                mongoTemplate.getCollection(GoblinFrontNavigation.class.getSimpleName()).updateOne(
+                        Query.query(Criteria.where("navigationId").is(goblinFrontNavigation.getNavigationId())).getQueryObject(),
+                        orderObject
+                );
+            }
+        }
+        //redis
+        redisDataSourceUtil.getRedisGoblinUtil().set(GoblinRedisConst.FRONT_NAVIGATION,list);
+        return true;
+    }
+
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/utils/GoblinRedisUtils.java

@@ -35,8 +35,8 @@ public class GoblinRedisUtils {
         redisDataSourceUtil.getRedisGoblinUtil().set(redisKey, data);
     }
 
-    public boolean delZhengzaiRelation(String selfMarketId,String storeId){
+    public void delZhengzaiRelation(String selfMarketId,String storeId){
         String redisKey = GoblinRedisConst.REDIS_GOBLIN_ZHENGZAI_RELATION.concat(selfMarketId).concat(":store_id:"+storeId);
-        redisDataSourceUtil.getRedisGoblinUtil().del(redisKey);
+         redisDataSourceUtil.getRedisGoblinUtil().del(redisKey);
     }
 }