领券更新缓存

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

@@ -199,7 +199,7 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
                 // mysql 抽奖记录
                 LinkedList<String> sqls = CollectionUtil.linkedListString();
                 LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-                sqls.add(SqlMapping.get("integral_activity_draw.insert"));
+                sqls.add(SqlMapping.get("sweet_integral_activity_draw.insert"));
                 sqlsDataA.add(new Object[]{
                         drawId, integralActivityId, integralActivity.getActivityNum(),
                         integralActivityPrizeVo.getPrizeId(), integralActivityPrizeVo.getPrizeTitle(), integralActivityPrizeVo.getPrizeType(),
@@ -299,7 +299,7 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
         // mysql
         LinkedList<String> sqls = CollectionUtil.linkedListString();
         LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-        sqls.add(SqlMapping.get("integral_activity_draw.update"));
+        sqls.add(SqlMapping.get("sweet_integral_activity_draw.update"));
         sqlsDataA.add(new Object[]{
                 receivingAddressesId, receivingName, receivingPhone, receivingAddress, receivingProvince, receivingCity, receivingCounty, nowTime, drawId
         });
@@ -328,14 +328,28 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
             LocalDateTime nowTime = LocalDateTime.now();
             LinkedList<String> sqls = CollectionUtil.linkedListString();
             LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-            sqls.add(SqlMapping.get("sweet_get_coupon.insert"));
+            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
+            sqls.add(SqlMapping.get("sweet_integral_activity_draw.get_coupon"));
+            sqls.add(SqlMapping.get("sweet_integral_activity_draw.updateStatus"));
             sqlsDataA.add(new Object[]{
                     IDGenerator.nextTimeId2(), couponId,
                     1, mobile, nowTime, "INTEGRAL_DRAW", nowTime
             });
+            sqlsDataB.add(new Object[]{
+                    2, nowTime, drawId
+            });
             queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
-                    SqlMapping.gets(sqls, sqlsDataA));
-            // TODO: 2021/12/7 更改发放状态redis info list mongo 数据库写入券id 
+                    SqlMapping.gets(sqls, sqlsDataA, sqlsDataB));
+            // 更新缓存
+            redisDataUtils.delIntegralActivityDrawList(drawVo.getIntegralActivityId(), uid);
+
+            redisDataUtils.updateIntegralActivityDrawInfo(drawId);
+
+            mongoTemplate.getCollection(IntegralActivityDrawVo.class.getSimpleName()).updateOne(
+                    Query.query(Criteria.where("drawId").is(drawId)).getQueryObject(),
+                    new Document("$set", new Document("receivingStatus", 2)
+                            .append("updatedAt", DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now())))
+            );
         }
         return ResponseDto.success();
     }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/RedisDataUtils.java

@@ -649,6 +649,14 @@ public class RedisDataUtils {
                 .concat(drawId);
         redisUtil.set(redisKeyDraw, drawVo);
     }
+    public void updateIntegralActivityDrawInfo(String drawId) {
+        String redisKeyDraw = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_INFO
+                .concat(drawId);
+        IntegralActivityDrawVo info = (IntegralActivityDrawVo) redisUtil.get(redisKeyDraw);
+        info.setReceivingStatus(2);
+        info.setUpdatedAt(LocalDateTime.now());
+        redisUtil.set(redisKeyDraw, info);
+    }
 
     public boolean setIntegralDrawLock(String userId) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_LOCK

liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties

@@ -16,13 +16,6 @@ kylin_order_ticket_status.synPay=UPDATE kylin_order_ticket_status SET `status` =
 kylin_order_ticket_relation.synPay=UPDATE kylin_order_ticket_relations SET updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ?)
 kylin_order_ticket_entities.synPay=UPDATE kylin_order_ticket_entities SET is_payment = ?,updated_at = ?,sys_damai = 1 WHERE order_id = ? and (updated_at <= ? or created_at = ?)
 
-
-
-# ------------------------订单关闭----------------------------
-kylin_order_ticket.close=UPDATE kylin_order_tickets SET updated_at = ? WHERE order_tickets_id = ?
-kylin_order_ticket_status.close=UPDATE kylin_order_ticket_status SET `status` = ?,updated_at = ? WHERE order_id = ?
-kylin_order_ticket_relation.close=UPDATE kylin_order_ticket_relations SET updated_at = ? WHERE order_id = ?
-
 # ------------------------用户关系----------------------------
 sweet_user_relation.insert=INSERT INTO sweet_user_relation (user_id,type,target_id,manual_id,status,created_at) VALUES (?,?,?,?,1,?)
 sweet_user_relation.delete=DELETE FROM  sweet_user_relation WHERE user_id = ? and target_id = ? and manual_id = ? and type = ?
@@ -45,8 +38,10 @@ sweet_city_vote_stat.update=UPDATE sweet_city_vote_stat SET vote_num = IFNULL(vo
 # --------------------------防疫答题--------------------------
 sweet_antigenic_question.insert=INSERT INTO sweet_antigenic_question (question_id,type,openId,unionId,nickname,address,phone,urgent_phone,keyword1,keyword11,keyword2,keyword3,keyword4,keyword5,keyword6,keyword7) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
 # ------------------------积分抽奖----------------------------
-integral_activity_draw.insert=INSERT INTO sweet_integral_activity_draw (draw_id,integral_activity_id,activity_num,prize_id,prize_title,prize_type,prize_type_num,user_id,nickname,receiving_status) VALUES (?,?,?,?,?,?,?,?,?,?)
-integral_activity_draw.update=UPDATE sweet_integral_activity_draw SET receiving_addresses_id = ?, receiving_name = ?, receiving_phone = ?, receiving_address = ?, receiving_province = ?, receiving_city = ?, receiving_county = ?, updated_at = ? WHERE draw_id = ?
+sweet_integral_activity_draw.insert=INSERT INTO sweet_integral_activity_draw (draw_id,integral_activity_id,activity_num,prize_id,prize_title,prize_type,prize_type_num,user_id,nickname,receiving_status) VALUES (?,?,?,?,?,?,?,?,?,?)
+sweet_integral_activity_draw.update=UPDATE sweet_integral_activity_draw SET receiving_addresses_id = ?, receiving_name = ?, receiving_phone = ?, receiving_address = ?, receiving_province = ?, receiving_city = ?, receiving_county = ?, updated_at = ? WHERE draw_id = ?
+sweet_integral_activity_draw.updateStatus=UPDATE sweet_integral_activity_draw SET receiving_status = ?, updated_at = ? WHERE draw_id = ?
+sweet_integral_activity_draw.get_coupon=INSERT INTO candy_mgt_coupon (mcoupon_id, coupon_id, `state`, event_amt, event_type, event_limit, event_at, `operator`, created_at) VALUES (?, ?, 0, ?, 2, ?, ?, ?, ?)
 
 # --------------------------小程序登录记录用户解密后信息--------------------------
 sweet_applet_users.insert=INSERT INTO sweet_applet_users (applet_user_id,user_id,open_id,union_id,phone_number,pure_phone_number,country_code,type) VALUES (?,?,?,?,?,?,?,?)
@@ -56,7 +51,4 @@ sweet_wechat_users.delete=DELETE FROM sweet_wechat_users WHERE union_id = ? and
 
 #---------------------------音乐节活动海报--------------------------------
 sweet_strawberry_poster_user=INSERT INTO sweet_strawberry_poster(open_id,poster_id,union_id,nickname,city_name,city_code,custom_text,created_at,updated_at) VALUES (?,?,?,?,?,?,?,?,?)
-sweet_strawberry_poster_Musician=INSERT INTO sweet_strawberry_poster_lineup(lineup_id,poster_id,lineup_num,musician_name,created_at,updated_at) VALUES (?,?,?,?,?,?)
-
-#---------------------------积分活动领券--------------------------------
-sweet_get_coupon.insert=INSERT INTO candy_mgt_coupon (mcoupon_id, coupon_id, `state`, event_amt, event_type, event_limit, event_at, `operator`, created_at) VALUES (?, ?, 0, ?, 2, ?, ?, ?, ?)
\ No newline at end of file
+sweet_strawberry_poster_Musician=INSERT INTO sweet_strawberry_poster_lineup(lineup_id,poster_id,lineup_num,musician_name,created_at,updated_at) VALUES (?,?,?,?,?,?)
\ No newline at end of file