From df4441322e9801c102299451da41d7c40b4502e9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 24 六月 2021 18:53:13 +0800
Subject: [PATCH] zookeeper地址修改，Maven采用私服

---
 service-lucky/src/main/java/com/ks/lucky/service/impl/LuckyActivityJoinManager.java |   74 +++++++++++++++++++++++++++++++++++-
 1 files changed, 71 insertions(+), 3 deletions(-)

diff --git a/service-lucky/src/main/java/com/ks/lucky/service/impl/LuckyActivityJoinManager.java b/service-lucky/src/main/java/com/ks/lucky/service/impl/LuckyActivityJoinManager.java
index 71e8d96..f9beef3 100644
--- a/service-lucky/src/main/java/com/ks/lucky/service/impl/LuckyActivityJoinManager.java
+++ b/service-lucky/src/main/java/com/ks/lucky/service/impl/LuckyActivityJoinManager.java
@@ -1,13 +1,17 @@
 package com.ks.lucky.service.impl;
 
 import com.ks.lucky.exception.LuckyActivityAwardException;
+import com.ks.lucky.mapper.LuckyActivityAwardResultMapper;
 import com.ks.lucky.mapper.LuckyActivityAwardsMapper;
 import com.ks.lucky.mapper.LuckyActivityJoinRecordMapper;
 import com.ks.lucky.pojo.DO.LuckyActivityAwardMaterial;
+import com.ks.lucky.pojo.DO.LuckyActivityAwardResult;
 import com.ks.lucky.pojo.DO.LuckyActivityAwards;
 import com.ks.lucky.pojo.DO.LuckyActivityJoinRecord;
 import com.ks.lucky.query.ActivityAwardQuery;
+import com.ks.lucky.query.ActivityAwardResultQuery;
 import com.ks.lucky.query.ActivityJoinRecordQuery;
+import com.ks.lucky.remote.service.LuckyActivityAwardService;
 import org.springframework.stereotype.Component;
 import org.springframework.validation.annotation.Validated;
 import org.yeshi.utils.StringUtil;
@@ -27,14 +31,17 @@
     @Resource
     private LuckyActivityJoinRecordMapper luckyActivityJoinRecordMapper;
 
+    @Resource
+    private LuckyActivityAwardResultMapper luckyActivityAwardResultMapper;
+
 
     public LuckyActivityJoinRecord getRecord(Long activityId, Long appId, String uid) {
         ActivityJoinRecordQuery query = new ActivityJoinRecordQuery();
         query.appId = appId;
         query.uid = uid;
         query.activityId = activityId;
-        query.start=0;
-        query.count=1;
+        query.start = 0;
+        query.count = 1;
         List<LuckyActivityJoinRecord> list = luckyActivityJoinRecordMapper.list(query);
         if (list != null && list.size() > 0)
             return list.get(0);
@@ -43,12 +50,17 @@
 
     /**
      * 鑾峰彇鍙備笌鏁版嵁
+     *
      * @param activityId
+     * @param userType   鐢ㄦ埛绫诲瀷
      * @return
      */
-    public Map<String, Integer> getJoinData(Long activityId) {
+    public Map<String, Integer> getJoinData(Long activityId, Integer userType) {
         Map<String, Integer> map = new HashMap<>();
         ActivityJoinRecordQuery query = new ActivityJoinRecordQuery();
+        if (userType != null) {
+            query.userType = userType;
+        }
         query.activityId = activityId;
         long count = luckyActivityJoinRecordMapper.count(query);
         int pageSize = 200;
@@ -68,5 +80,61 @@
     }
 
 
+    /**
+     * 璁剧疆鎵�鏈夌殑鍙備笌鑰呮湭涓
+     *
+     * @param activityId
+     */
+    public void setActivityAllJoinerUnDraw(Long activityId) {
+        ActivityJoinRecordQuery query = new ActivityJoinRecordQuery();
+        query.activityId = activityId;
+        LuckyActivityJoinRecord record = new LuckyActivityJoinRecord();
+        record.setUpdateTime(new Date());
+        record.setDrawState(LuckyActivityJoinRecord.DRAW_STATE_NOT_DRAWN);
+        luckyActivityJoinRecordMapper.updateSelectiveWithQuery(record, query);
+    }
+
+
+    /**
+     * 璁剧疆宸茬粡涓鐨勫弬涓庤褰曚负涓
+     *
+     * @param activityId
+     */
+    public void setActivityDrawnJoinerState(Long activityId) {
+        //鏌ヨ涓璁板綍
+        ActivityAwardResultQuery query = new ActivityAwardResultQuery();
+        query.activityId = activityId;
+        long count = luckyActivityAwardResultMapper.count(query);
+        //鍒嗛〉鏌ヨ
+        int pageSize = 200;
+        int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+
+        for (int page = 0; page < totalPage; page++) {
+            query.start = page * pageSize;
+            query.count = pageSize;
+            //鏌ヨ鍑轰腑濂栬褰�
+            List<LuckyActivityAwardResult> list = luckyActivityAwardResultMapper.list(query);
+            for (LuckyActivityAwardResult result : list) {
+                ActivityJoinRecordQuery recordQuery = new ActivityJoinRecordQuery();
+                recordQuery.activityId = activityId;
+                recordQuery.appId = result.getAppId();
+                recordQuery.uid = result.getUid();
+                recordQuery.count = 1;
+                //鏌ヨ涓璁板綍瀵瑰簲鐨勫弬涓庤褰�
+                List<LuckyActivityJoinRecord> recordList = luckyActivityJoinRecordMapper.list(recordQuery);
+                if (recordList != null && recordList.size() > 0) {
+                    LuckyActivityJoinRecord record = new LuckyActivityJoinRecord();
+                    record.setId(recordList.get(0).getId());
+                    record.setDrawState(LuckyActivityJoinRecord.DRAW_STATE_DRAWN);
+                    record.setUpdateTime(new Date());
+                    //淇敼鍙備笌璁板綍鐨勭姸鎬佺殑宸蹭腑濂�
+                    luckyActivityJoinRecordMapper.updateByPrimaryKeySelective(record);
+                }
+            }
+        }
+
+
+    }
+
 
 }

--
Gitblit v1.8.0