exit

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

@@ -67,7 +67,7 @@ public class GoblinGoodsAnticipateController {
 
     @ApiOperation("创建预约关联sku")
     @PostMapping("/addAnticipateValues")
-    public ResponseDto<Object> addAnticipateValues(List<GoblinGoodsAnticipateValueParam> list) {
+    public ResponseDto<Object> addAnticipateValues(@RequestBody List<GoblinGoodsAnticipateValueParam> list) {
         return goblinGoodsAnticipateService.addAnticipateValues(list);
     }
 
@@ -90,7 +90,7 @@ public class GoblinGoodsAnticipateController {
 
     @ApiOperation("根据spuId查询出所有的sku")
     @PostMapping("")
-    public ResponseDto<Object> getSkus(@RequestParam(name = "apuId") String SpuId) {
-        return goblinGoodsAnticipateService.getSkus(SpuId);
+    public ResponseDto<Object> getSkus(@RequestParam(name = "apuId") String spuId) {
+        return goblinGoodsAnticipateService.getSkus(spuId);
     }
 }

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

@@ -209,6 +209,9 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
     @Override
     public ResponseDto<Object> addAnticipateValues(List<GoblinGoodsAnticipateValueParam> list) {
         if (list != null && list.size() > 0) {
+            for (GoblinGoodsAnticipateValueParam vo : list){
+                if (goblinRedisUtils.getAnticipate(vo.getAntId(),vo.getSkuId())) return ResponseDto.failure("该预约已选择该sku");
+            }
             list.forEach(item -> {
                 GoblinGoodsAnticipateValueVo goodsAnticipateValueVo = new GoblinGoodsAnticipateValueVo();
                 BeanUtils.copyProperties(item, goodsAnticipateValueVo);
@@ -217,7 +220,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                 goodsAnticipateValueVo.setDelTag(0);
                 //redis消息
                 //redis标识存入该sku处于预约列表
-                goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getSkuId());
+                goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getAntId(),goodsAnticipateValueVo.getSkuId());
 
                 //保存mysql中间表
                 LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
@@ -249,7 +252,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                 BeanUtils.copyProperties(item, goodsAnticipateValueVo);
                 //redis消息
                 //redis标识存入该sku处于预约列表
-                goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getSkuId());
+                goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getAntId(),goodsAnticipateValueVo.getSkuId());
 
                 //保存mysql中间表
                 LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();

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

@@ -47,8 +47,15 @@ public class GoblinRedisUtils {
     /**
      * 该skuId已开启预约
      */
-    public void setAnticipate(String skuId){
-        redisUtil.set(GoblinRedisConst.ANTICIPATE_SKUID.concat(skuId),1);
+    public void setAnticipate(String antId, String skuId){
+        redisUtil.set(GoblinRedisConst.ANTICIPATE_SKUID.concat(antId).concat(skuId),1);
+    }
+
+    /**
+     * 获取关联
+     */
+    public boolean getAnticipate(String antId, String skuId){
+       return redisUtil.get(GoblinRedisConst.ANTICIPATE_SKUID.concat(antId).concat(skuId)) != null;
     }
 
     public GoblinGoodAnticipateUserVo getUserAboutAut(String skuId, String uid) {

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/resources/sqlmap.properties

@@ -140,7 +140,7 @@ goblin_goods_anticipate_update_actual_reduce_people=UPDATE goblin_goods_anticipa
 goblin_goods_anticipate_delete=UPDATE goblin_goods_anticipate SET `del_tag` = 1 WHERE ant_id = ? 
 goblin_goods_anticipate_value=INSERT INTO goblin_goods_anticipate_value (ant_id,sku_name,sku_id,spu_id,about_start_date,about_end_date,created_date,del_tag) VALUES(?,?,?,?,?,?,?,?) 
 goblin_goods_anticipate_value_update=UPDATE goblin_goods_anticipate_value SET `about_start_date` = ?,`about_end_date`= ?,update_date = NOW() WHERE ant_id = ? AND sku_id = ? AND spu_id = ?
-goblin_goods_anticipate_value_delete=UPDATE goblin_goods_anticipate_value SET `del_tag` = 1 WHERE ant_id = ? 
+goblin_goods_anticipate_value_delete=UPDATE goblin_goods_anticipate_value SET `del_tag` = 1,update_date = NOW() WHERE ant_id = ? 
 goblin_goods_anticipate_update=UPDATE goblin_goods_anticipate SET `name` = ?,`rule`= ? WHERE ant_id = ? 
 goblin_goods_anticipate_update_proper=UPDATE goblin_goods_anticipate SET about_people = ? WHERE ant_id = ? 
 goblin_goods_anticipate_user=INSERT INTO goblin_goods_anticipate_user(uid,sku_id,phone,state) VALUES(?,?,?,?)