记得上下班打卡 | git大法好,push需谨慎

Commit 8145fa96 authored by jiangxiulong's avatar jiangxiulong

记录领取的id

parent 02de99f9
...@@ -341,17 +341,19 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg ...@@ -341,17 +341,19 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
sqlsB.add(SqlMapping.get("sweet_integral_activity_draw.updateStatus")); sqlsB.add(SqlMapping.get("sweet_integral_activity_draw.updateStatus"));
sqlsDataB.add(new Object[]{ sqlsDataB.add(new Object[]{
2, nowTime, drawId 2, couponId, nowTime, drawId
}); });
queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey(), queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey(),
SqlMapping.gets(sqlsB, sqlsDataB)); SqlMapping.gets(sqlsB, sqlsDataB));
// 更新缓存 // 更新缓存
redisDataUtils.updateIntegralActivityDrawInfo(drawId); redisDataUtils.updateIntegralActivityDrawInfo(drawId, couponId);
mongoTemplate.getCollection(IntegralActivityDrawVo.class.getSimpleName()).updateOne( mongoTemplate.getCollection(IntegralActivityDrawVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("drawId").is(drawId)).getQueryObject(), Query.query(Criteria.where("drawId").is(drawId)).getQueryObject(),
new Document("$set", new Document("receivingStatus", 2) new Document("$set", new Document("receivingStatus", 2)
.append("updatedAt", LocalDateTime.now())) .append("relationId", couponId)
.append("updatedAt", LocalDateTime.now())
)
); );
redisDataUtils.delIntegralActivityDrawList(drawVo.getIntegralActivityId(), uid); redisDataUtils.delIntegralActivityDrawList(drawVo.getIntegralActivityId(), uid);
......
...@@ -655,11 +655,12 @@ public class RedisDataUtils { ...@@ -655,11 +655,12 @@ public class RedisDataUtils {
.concat(drawId); .concat(drawId);
redisUtil.set(redisKeyDraw, drawVo); redisUtil.set(redisKeyDraw, drawVo);
} }
public void updateIntegralActivityDrawInfo(String drawId) { public void updateIntegralActivityDrawInfo(String drawId, String couponId) {
String redisKeyDraw = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_INFO String redisKeyDraw = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_INFO
.concat(drawId); .concat(drawId);
IntegralActivityDrawVo info = (IntegralActivityDrawVo) redisUtil.get(redisKeyDraw); IntegralActivityDrawVo info = (IntegralActivityDrawVo) redisUtil.get(redisKeyDraw);
info.setReceivingStatus(2); info.setReceivingStatus(2);
info.setRelationId(couponId);
info.setUpdatedAt(LocalDateTime.now()); info.setUpdatedAt(LocalDateTime.now());
redisUtil.set(redisKeyDraw, info); redisUtil.set(redisKeyDraw, info);
} }
......
...@@ -40,7 +40,7 @@ sweet_antigenic_question.insert=INSERT INTO sweet_antigenic_question (question_i ...@@ -40,7 +40,7 @@ sweet_antigenic_question.insert=INSERT INTO sweet_antigenic_question (question_i
# ------------------------积分抽奖---------------------------- # ------------------------积分抽奖----------------------------
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.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.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.updateStatus=UPDATE sweet_integral_activity_draw SET receiving_status = ?, relation_id = ?, 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_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, ?, ?, ?, ?)
# --------------------------小程序登录记录用户解密后信息-------------------------- # --------------------------小程序登录记录用户解密后信息--------------------------
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment