划卡优化

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisUtil.java

@@ -32,5 +32,14 @@ public final class RedisUtil extends AbstractRedisUtil{
         return this.redisConfig;
     }
 
-
+    public static void main(String[] args) {
+        String[] keys = {
+                "chime:per:openNum:Allow510093798172016641784538"
+        };
+        for (String key : keys) {
+            long value = key.hashCode();
+            int idx = ((int) (value ^ (value >>> 32)) % 250);
+            System.out.printf("\n[%s] - idx:%s", key, idx);
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/utils/DoTaskUtils.java

@@ -12,6 +12,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import org.springframework.util.MultiValueMap;
 
+import java.time.LocalDateTime;
 import java.util.Calendar;
 
 @Slf4j
@@ -24,32 +25,28 @@ public class DoTaskUtils {
 
     /**
      * 划卡调任务
+     *
      * @param currentUserId
      */
     public void userAddNum(String currentUserId) {
-        Calendar cal = Calendar.getInstance();
-        cal.add(Calendar.DAY_OF_YEAR,1);
-        cal.set(Calendar.HOUR_OF_DAY,0);
-        cal.set(Calendar.SECOND,0);
-        cal.set(Calendar.MINUTE,0);
-        cal.set(Calendar.MILLISECOND,0);
-        Long timeout=(cal.getTimeInMillis()-System.currentTimeMillis())/1000;
-        Integer i;
+        long timeout = ((24 * 60 * 60) - LocalDateTime.now().getSecond());
+        Object obj = redisUtil.get(ChimeConstant.REDIS_USER_OPEN_NUM + currentUserId);
+        int slidCount ;
         //判断当天是否有划卡
-        if (!redisUtil.hasKey(ChimeConstant.REDIS_USER_OPEN_NUM+currentUserId)){
-            i=1;
-            redisUtil.set(ChimeConstant.REDIS_USER_OPEN_NUM+currentUserId, i, timeout);
-        }else {
-            i = (Integer) redisUtil.get(ChimeConstant.REDIS_USER_OPEN_NUM+currentUserId)+1;
+        if (obj==null) {
+            slidCount = 1;
+        } else {
+            slidCount = (int)obj;
+            slidCount = slidCount + 1;
         }
+        redisUtil.set(ChimeConstant.REDIS_USER_OPEN_NUM + currentUserId, slidCount, timeout);
 
-        redisUtil.set(ChimeConstant.REDIS_USER_OPEN_NUM+currentUserId, i, timeout);
         //获取用户是否调用过任务接口
         boolean hasKey = redisUtil.hasKey(ChimeConstant.REDIS_USER_TO_DOTASK + currentUserId);
-        if(!hasKey){
+        if (!hasKey) {
 
             //满足10次调用接口，每天最多调用一次
-            if(i >= 10){
+            if (slidCount >= 10) {
                 MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
                 params.add("uid", currentUserId);
                 params.add("taskId", 3 + "");
@@ -60,9 +57,9 @@ public class DoTaskUtils {
                 //接口调用失败，重试
                 if (!success) {
                     this.userAddNum(currentUserId);
-                }else {
+                } else {
                     //调用接口成功,记录
-                    redisUtil.set(ChimeConstant.REDIS_USER_TO_DOTASK +currentUserId,1,timeout);
+                    redisUtil.set(ChimeConstant.REDIS_USER_TO_DOTASK + currentUserId, 1, timeout);
                 }
             }
         }