正在下单 增加 指定用户可买逻辑

liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/dto/manage/GoblinStoreZhengzaiItemParam.java

@@ -27,6 +27,8 @@ public class GoblinStoreZhengzaiItemParam {
     private Integer buyFactor;
     @ApiModelProperty(required = false, value = "购买限制人员名单[购买限制为2-指定用户时必填]", example = "")
     private String buyRoster;
+    @ApiModelProperty(required = false, value = "操作指定可买用户类型 [1-添加|2-删除]", example = "")
+    private String type;
 }
 
 

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

@@ -184,6 +184,9 @@ public class GoblinZhengzaiServiceImpl implements IGoblinZhengzaiService {
             marketSkuList.add(skuVo.getSkuId());
             skuList.add(skuVo.getSkuId());
             priceList.add(item.getPriceMarketing());
+            if(bean.getBuyFactor()==2){
+                queueUtils.sendMsgByRedisXls(bean.getBuyRoster(),item.getType(),item.getSkuId());
+            }
         }
         if (errorNameList.size() == params.getGoblinStoreZhengzaiItemParams().size()) {
             return ResponseDto.failure("148001", JsonUtils.toJson(errorNameList));
@@ -268,6 +271,9 @@ public class GoblinZhengzaiServiceImpl implements IGoblinZhengzaiService {
                     bean.getStockMarketing(), bean.getBuyFactor(), bean.getBuyRoster(), bean.getBuyLimit(), bean.getUpdatedAt(), params.getSelfMarketId(), params.getStoreId()});
             marketSkuList.add(skuVo.getSkuId());
             priceList.add(bean.getPriceMarketing());
+            if(bean.getBuyFactor()==2){
+                queueUtils.sendMsgByRedisXls(bean.getBuyRoster(),item.getType(),item.getSkuId());
+            }
         }
         if (errorNameList.size() == params.getGoblinStoreZhengzaiItemParams().size()) {
             return ResponseDto.failure("148001", JsonUtils.toJson(errorNameList));