修改 sweet mongo 分片问题

修改 根据ar标签获取数据问题

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinMongoUtils.java

@@ -1504,13 +1504,35 @@ public class GoblinMongoUtils {
 
     //根据艺人标签和演出查询商品
     public List<GoblinGoodsInfoVo> getMusicTagPGoods(String musicTag, String performanceId) {
+        List<GoblinGoodsInfoVo> returnData = ObjectUtil.getGoblinGoodsInfoVos();
+
         Query query = Query.query(Criteria.where("artagVoList.tagName").is(musicTag)
                 .and("delFlg").is("0").and("shelvesStatus").is("3"));
-        return mongoTemplate.find(query,
+
+        List<GoblinGoodsInfoVo> baseData = mongoTemplate.find(query,
                 GoblinGoodsInfoVo.class,
                 GoblinGoodsInfoVo.class.getSimpleName()
         );
 
+        //查询活动id
+        Query queryShow = Query.query(Criteria.where("performanceId").is(performanceId));
+        List<GoblinSelfMarketingVo> showVoList = mongoTemplate.find(queryShow,
+                GoblinSelfMarketingVo.class,
+                GoblinSelfMarketingVo.class.getSimpleName()
+        );
+        if (showVoList.size() == 0) {
+            return baseData;
+        } else {
+            GoblinSelfMarketingVo showVo = showVoList.get(0);
+
+            //只保留 参加该活动或者没参加活动的数据
+            for (GoblinGoodsInfoVo vo : baseData) {
+                if (vo.getMarketId() == null || vo.getMarketId().equals(GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue().concat(showVo.getSelfMarketId())) || vo.getMarketId().equals("")) {
+                    returnData.add(vo);
+                }
+            }
+            return returnData;
+        }
     }
 
     //获取退款sku订单价格

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetPerformanceServiceImpl.java

@@ -186,7 +186,7 @@ public class SweetPerformanceServiceImpl extends ServiceImpl<SweetPerformanceMap
         }
         //修改 mongo数据
         BasicDBObject cv = new BasicDBObject("$set", mongoConverter.convertToMongoType(data));
-        mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
+        mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateMany(
                 Query.query(Criteria.where("arId").is("arId")).getQueryObject(),
                 cv
         );