发货

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/constant/SweetConstant.java

@@ -85,4 +85,5 @@ public class SweetConstant {
     public static final String REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_INFO = "sweet:integralActivity:activityId:";
     public static final String REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_PRIZE_NUM = "sweet:integralActivity:prizeNum:activityId:";
     public static final String REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_PRIZE_WINNERS_NUM = "sweet:integralActivity:prizeWinnersNum:activityId:";
+    public static final String REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_IN_USER = "sweet:integralActivity:DrawIn:activityId:";
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/sweet/SweetIntegralActivityDrawController.java

@@ -77,10 +77,10 @@ public class SweetIntegralActivityDrawController extends BaseController {
     @ApiImplicitParams({
             @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "drawId", value = "抽奖id")
     })
-    public AjaxResult isOnline(
+    public AjaxResult receivingStatus(
             @RequestParam("drawId") @NotEmpty(message = "drawId不能为空") String drawId
     ) {
-        Integer result = iSweetIntegralActivityDrawService.isOnline(drawId);
+        Integer result = iSweetIntegralActivityDrawService.receivingStatus(drawId);
         if (result > 0) {
             return success("操作成功");
         } else {

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/sweet/service/ISweetIntegralActivityDrawService.java

@@ -22,5 +22,5 @@ public interface ISweetIntegralActivityDrawService extends IService<SweetIntegra
 
     List<SweetActivityDrawListDao> selectExcelList(String integralActivityId);
 
-    Integer isOnline(String drawId);
+    Integer receivingStatus(String drawId);
 }

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

@@ -4,15 +4,24 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import com.liquidnet.client.admin.zhengzai.sweet.service.ISweetIntegralActivityDrawService;
+import com.liquidnet.client.admin.zhengzai.sweet.utils.SweetRedisAdminUtils;
+import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.service.sweet.dto.SweetActivityDrawListDao;
 import com.liquidnet.service.sweet.dto.param.admin.SweetIntegralActivityDrawListSearchParam;
+import com.liquidnet.service.sweet.dto.vo.IntegralActivityDrawVo;
 import com.liquidnet.service.sweet.entity.SweetIntegralActivityDraw;
 import com.liquidnet.service.sweet.mapper.SweetIntegralActivityDrawMapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.sweet.utils.SweetNewObjectUtil;
+import org.bson.Document;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.LinkedList;
 import java.util.List;
 
 /**
@@ -29,6 +38,12 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
     @Autowired
     private SweetIntegralActivityDrawMapper sweetIntegralActivityDrawMapper;
 
+    @Autowired
+    private SweetRedisAdminUtils sweetRedisAdminUtils;
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
     @Override
     public PageInfo<SweetIntegralActivityDraw> drawList(SweetIntegralActivityDrawListSearchParam listParam) {
         PageHelper.startPage(listParam.getPageNum(), listParam.getPageSize());
@@ -45,7 +60,7 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
     }
 
     @Override
-    public Integer isOnline(String drawId) {
+    public Integer receivingStatus(String drawId) {
         SweetIntegralActivityDraw sweetIntegralActivityDraw = SweetIntegralActivityDraw.getNew();
         sweetIntegralActivityDraw.setReceivingStatus(2);
         sweetIntegralActivityDraw.setUpdatedAt(LocalDateTime.now());
@@ -53,7 +68,32 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
                 sweetIntegralActivityDraw,
                 Wrappers.lambdaUpdate(SweetIntegralActivityDraw.class).eq(SweetIntegralActivityDraw::getDrawId, drawId)
         );
-        // TODO: 2021/10/20 更新缓存
+        SweetIntegralActivityDraw sweetIntegralActivityDrawNew = sweetIntegralActivityDrawMapper.selectOne(
+                Wrappers.lambdaUpdate(SweetIntegralActivityDraw.class).eq(SweetIntegralActivityDraw::getDrawId, drawId)
+        );
+
+        // 更新缓存
+        List<SweetIntegralActivityDraw> sweetIntegralActivityDraws = sweetIntegralActivityDrawMapper.selectList(
+                Wrappers.lambdaUpdate(SweetIntegralActivityDraw.class)
+                        .eq(SweetIntegralActivityDraw::getIntegralActivityId, sweetIntegralActivityDrawNew.getIntegralActivityId())
+                        .eq(SweetIntegralActivityDraw::getUserId, sweetIntegralActivityDrawNew.getUserId())
+                        .orderByDesc(SweetIntegralActivityDraw::getMid)
+                        .last(" limit 20 ")
+        );
+        LinkedList<IntegralActivityDrawVo> activityDrawArrayList = SweetNewObjectUtil.getSweetIntegralActivityDrawVoLinkedList();
+        for (SweetIntegralActivityDraw draw : sweetIntegralActivityDraws) {
+            IntegralActivityDrawVo integralActivityDrawVo = IntegralActivityDrawVo.getNew().copy(draw);
+            activityDrawArrayList.add(integralActivityDrawVo);
+        }
+        sweetRedisAdminUtils.setIntegralActivityDraw(activityDrawArrayList, sweetIntegralActivityDrawNew.getIntegralActivityId(), sweetIntegralActivityDrawNew.getUserId());
+
+        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 update;
     }
+
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/sweet/utils/SweetRedisAdminUtils.java

@@ -2,11 +2,13 @@ package com.liquidnet.client.admin.zhengzai.sweet.utils;
 
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.service.sweet.constant.SweetConstant;
+import com.liquidnet.service.sweet.dto.vo.IntegralActivityDrawVo;
 import com.liquidnet.service.sweet.dto.vo.IntegralActivityVo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.stereotype.Component;
 
+import java.util.LinkedList;
 import java.util.List;
 
 @Component
@@ -21,6 +23,7 @@ public class SweetRedisAdminUtils {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_LIST;
         boolean set = redisUtil.set(redisKey, voList);
     }
+
     public void setIntegralActivityInfo(IntegralActivityVo integralActivityVo) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_INFO.concat(integralActivityVo.getIntegralActivityId());
         boolean set = redisUtil.set(redisKey, integralActivityVo);
@@ -57,4 +60,13 @@ public class SweetRedisAdminUtils {
                 .concat(prizeId);
         redisUtil.decr(redisKey, num);
     }
+
+    public void setIntegralActivityDraw(LinkedList<IntegralActivityDrawVo> sweetIntegralActivityDraws, String integralActivityId, String userId) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_INTEGRAL_ACTIVITY_DRAW_IN_USER
+                .concat(integralActivityId)
+                .concat(":userId:")
+                .concat(userId);
+        redisUtil.set(redisKey, sweetIntegralActivityDraws);
+    }
+
 }