修改 正在下单逻辑

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/manage/GoblinZhengzaiServiceImpl.java

@@ -182,7 +182,7 @@ public class GoblinZhengzaiServiceImpl implements IGoblinZhengzaiService {
             skuVo.setBuyRoster(bean.getBuyRoster());
             skuVo.setBuyFactor(bean.getBuyFactor().toString());
             skuVo.setMarketId(GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue().concat(params.getSelfMarketId()));
-            mongoUtils.setGoodsSkuInfoVo(skuVo);
+            mongoUtils.upsertGoodsSkuInfoVo(skuVo);
             //redis
             redisUtils.setGoodsSkuInfoVo(skuVo);
             //mysql
@@ -208,7 +208,7 @@ public class GoblinZhengzaiServiceImpl implements IGoblinZhengzaiService {
         spuVo.setSpecMode("2");
         spuVo.setPriceLe(priceList.get(priceList.size() - 1));
         spuVo.setMarketId(GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue().concat(params.getSelfMarketId()));
-        mongoUtils.setGoodsInfoVo(spuVo);
+        mongoUtils.upsertGoodsInfoVo(spuVo);
         //redis
         redisUtils.setGoodsInfoVo(spuVo);
         relationVo.setSkuList(skuList);

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

@@ -306,6 +306,12 @@ public class GoblinMongoUtils {
         return mongoTemplate.insert(vo, GoblinGoodsInfoVo.class.getSimpleName());
     }
 
+    public void upsertGoodsInfoVo(GoblinGoodsInfoVo vo) {
+        Document document = (Document) mongoConverter.convertToMongoType(vo);
+        Update update = Update.fromDocument(document);
+        mongoTemplate.upsert(Query.query(Criteria.where("storeId").is(vo.getStoreId()).and("spuId").is(vo.getSpuId())), update, GoblinGoodsInfoVo.class.getSimpleName());
+    }
+
     public boolean delGoodsInfoVo(String spuId) {
         return mongoTemplate.getCollection(GoblinGoodsInfoVo.class.getSimpleName()).updateOne(
                 Query.query(Criteria.where("spuId").is(spuId).and("delFlg").is("0")).getQueryObject(),
@@ -505,6 +511,12 @@ public class GoblinMongoUtils {
         return mongoTemplate.insert(vo, GoblinGoodsSkuInfoVo.class.getSimpleName());
     }
 
+    public void upsertGoodsSkuInfoVo(GoblinGoodsSkuInfoVo vo) {
+        Document document = (Document) mongoConverter.convertToMongoType(vo);
+        Update update = Update.fromDocument(document);
+        mongoTemplate.upsert(Query.query(Criteria.where("storeId").is(vo.getStoreId()).and("skuId").is(vo.getSkuId())), update, GoblinGoodsInfoVo.class.getSimpleName());
+    }
+
     // SKU信息
     public List<GoblinGoodsSkuInfoVo> setGoodsSkuInfoVos(List<GoblinGoodsSkuInfoVo> vos) {
         return (List<GoblinGoodsSkuInfoVo>) mongoTemplate.insert(vos, GoblinGoodsSkuInfoVo.class.getSimpleName());
@@ -971,7 +983,8 @@ public class GoblinMongoUtils {
             criteria = criteria.and("backOrderSkuVos.spuName").regex(".*?\\" + spuName);
         }
         Query query = Query.query(criteria);
-        query.skip(skipCount).limit(size).with(Sort.by(Sort.Order.desc("createdAt")));;
+        query.skip(skipCount).limit(size).with(Sort.by(Sort.Order.desc("createdAt")));
+        ;
         query.fields().include("backCode").include("orderCode").include("backOrderId").include("type").include("status").include("realBackPrice").include("createdAt")
                 .include("backOrderSkuVos.spuName").include("backOrderSkuVos.skuName").include("backOrderSkuVos.spuPic").include("backOrderSkuVos.skuPic")
                 .include("backOrderSkuVos.skuSpecs").include("backOrderSkuVos.skuId").include("backOrderSkuVos.spuId").include("backOrderSkuVos.orderSkuId")