yujian
2019-12-19 626d711cb15896055c13fe344eb7fcc824589715
fanli/src/main/java/com/yeshi/fanli/aspect/ActiveUserAspect.java
@@ -19,15 +19,16 @@
import org.yeshi.utils.NumberUtil;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.service.inter.integral.IntegralGetService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoModifyRecordService;
import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
import com.yeshi.fanli.util.annotation.UserActive;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.params.SetParams;
/**
 * 活跃用户处理
@@ -86,8 +87,7 @@
                     String key = "useractive-" + uidStr;
                     Jedis jedis = jedisPool.getResource();
                     try {
                        if (jedis.setnx(key, "1") > 0) {
                           jedis.expire(key, 60 * 5);// 5分钟内不处理
                        if (!StringUtil.isNullOrEmpty(jedis.set(key, "1", new SetParams().nx().ex(300)))) {
                           try {
                              // TODO 用户活跃处理
                              Long uid = Long.parseLong(uidStr);
@@ -99,7 +99,7 @@
                           }
                        }
                     } finally {
                        jedisPool.returnResource(jedis);
                        jedis.close();
                     }
                  }
               });