exit

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

@@ -41,25 +41,25 @@ public class GoblinGoodsAnticipateController {
 
     @ApiOperation("创建预约信息")
     @PostMapping("/add")
-    public ResponseDto<Object> add(@RequestBody GoblinGoodsAnticipateAddParam goodsAnticipateAddParam){
+    public ResponseDto<Object> add(@RequestBody GoblinGoodsAnticipateAddParam goodsAnticipateAddParam) {
         return goblinGoodsAnticipateService.add(goodsAnticipateAddParam);
     }
 
     @ApiOperation("修改预约人数")
     @PostMapping("/updatePeople")
-    public ResponseDto<Object> updatePeople(@RequestParam(name = "antId", required = true) String antId,@RequestParam(name = "people", required = true)  Long people){
-        return goblinGoodsAnticipateService.updatePeople(antId,people);
+    public ResponseDto<Object> updatePeople(@RequestParam(name = "antId", required = true) String antId, @RequestParam(name = "people", required = true) Long people) {
+        return goblinGoodsAnticipateService.updatePeople(antId, people);
     }
 
     @ApiOperation("修改预约")
     @PostMapping("/update")
-    public ResponseDto<Object> update(GoblinGoodsAnticipateUpdateParam goodsAnticipateUpdateParam){
+    public ResponseDto<Object> update(GoblinGoodsAnticipateUpdateParam goodsAnticipateUpdateParam) {
         return goblinGoodsAnticipateService.update(goodsAnticipateUpdateParam);
     }
 
     @ApiOperation("删除预约")
     @DeleteMapping("/delete")
-    public ResponseDto<Object> delete(@RequestParam(name = "antId")String antId){
+    public ResponseDto<Object> delete(@RequestParam(name = "antId") String antId) {
         return goblinGoodsAnticipateService.delete(antId);
     }
 
@@ -69,13 +69,13 @@ public class GoblinGoodsAnticipateController {
                                          @RequestParam(name = "skuId", required = true) String skuId,
                                          @RequestParam(name = "uid", required = true) String uid,
                                          @RequestParam(name = "phone", required = true) String phone,
-                                         @RequestParam(name = "state",required = true)Integer state){
-        return goblinGoodsAnticipateService.userAbout(antId,skuId,uid,phone,state);
+                                         @RequestParam(name = "state", required = true) Integer state) {
+        return goblinGoodsAnticipateService.userAbout(antId, skuId, uid, phone, state);
     }
 
     @ApiOperation("根据spuid查询出所有的sku")
     @PostMapping("")
-    public ResponseDto<Object> getSkus(@RequestParam(name = "apuId")String 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

@@ -166,14 +166,29 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
     public ResponseDto<Object> userAbout(String autId,String skuId, String uid, String phone, Integer state) {
         //查询该用户是否预
         GoblinGoodAnticipateUserVo userVo = goblinRedisUtils.getUserAboutAut(skuId,uid);
+        LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
         if (state.equals(GoblinGoodAnticipateUserVo.STATE_VALID) &&userVo==null) {
             //用户没有预约过
             //发送redis消息修改mysql记录用户预约
+            sqlValue.add(new Object[]{
+                    uid,
+                    skuId,
+                    phone,
+                    state
+            });
+            sendRedis("goblin_goods_anticipate_user",sqlValue);
             GoblinGoodAnticipateUserVo user = new GoblinGoodAnticipateUserVo(uid,skuId,phone,state);
             //mongodb记录
             goblinRedisUtils.setUserAboutSku(user);
             //预约人数+1或-1
         }else {
+            //mysql删除用户记录
+            sqlValue.add(new Object[]{
+                    uid,
+                    skuId
+            });
+            sendRedis("goblin_goods_anticipate_user_update",sqlValue);
+            //删除缓存  redis和mongodb
             goblinRedisUtils.delUserAboutSku(skuId,uid);
         }
         goblinRedisUtils.setAutId(autId,state);

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

@@ -136,6 +136,7 @@ goblin_user_digital_artwork.update_for_unboxing=UPDATE goblin_user_digital_artwo
 #----       \u9884\u7EA6
 goblin_goods_anticipate=INSERT INTO goblin_goods_anticipate(ant_id,`name`,`rule`,actual_people,about_start_date,about_end_date,created_date,del_tag) VALUES(?,?,?,0,?,?,NOW(),0) 
 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(?,?,?,?,?,?,NOW(),0) 
-
 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(?,?,?,?) 
+goblin_goods_anticipate_user_update=UPDATE goblin_goods_anticipate_user SET state = 0 WHERE uid = ? AND sku_id = ?