修改少写的mongodb的东西

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/goblin/service/impl/GoblinFrontSelectGoodsServiceImpl.java

 package com.liquidnet.client.admin.zhengzai.goblin.service.impl;
 
+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;
 import com.liquidnet.client.admin.zhengzai.goblin.service.IGoblinFrontSelectGoodsService;
 import com.liquidnet.common.cache.redis.util.RedisGoblinUtil;
 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.GoblinFrontSelectGoods;
 import com.liquidnet.service.goblin.mapper.GoblinFrontSelectGoodsMapper;
+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;
@@ -32,6 +38,8 @@ public class GoblinFrontSelectGoodsServiceImpl extends ServiceImpl<GoblinFrontSe
     private GoblinFrontSelectGoodsMapper goblinFrontSelectGoodsMapper;
     @Autowired
     private RedisGoblinUtil redisGoblinUtil;
+    @Autowired
+    private MongoTemplate mongoTemplate;
 
     public boolean create(GoblinFrontSelectGoods goblinFrontSelectGoods){
         List list= this.getList();
@@ -74,6 +82,18 @@ public class GoblinFrontSelectGoodsServiceImpl extends ServiceImpl<GoblinFrontSe
         LambdaQueryWrapper<GoblinFrontSelectGoods> queryWrapper = Wrappers.lambdaQuery(GoblinFrontSelectGoods.class);
         queryWrapper.eq(GoblinFrontSelectGoods::getDelTag,0);
         List<GoblinFrontSelectGoods> list=goblinFrontSelectGoodsMapper.selectList(queryWrapper);
+        //放入mongodb
+        GoblinFrontSelectGoods goblinFrontSelectGoods= list.get(0);
+        GoblinFrontSelectGoods  goblinFrontSelectGoods1= mongoTemplate.findOne(Query.query(Criteria.where("selectGoodsId").is(goblinFrontSelectGoods.getSelectGoodsId())), GoblinFrontSelectGoods.class, GoblinFrontSelectGoods.class.getSimpleName());
+        if(null==goblinFrontSelectGoods1){
+            mongoTemplate.save(goblinFrontSelectGoods1,GoblinFrontSelectGoods.class.getSimpleName());
+        }else{
+            BasicDBObject orderObject = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(goblinFrontSelectGoods)));
+            mongoTemplate.getCollection(GoblinFrontSelectGoods.class.getSimpleName()).updateOne(
+                    Query.query(Criteria.where("selectGoodsId").is(goblinFrontSelectGoods.getSelectGoodsId())).getQueryObject(),
+                    orderObject
+            );
+        }
         redisGoblinUtil.set(GoblinRedisConst.SELECT_GOODS,list);
         return  true;
     }