推送服务完善

admin

2021-06-16 4403f34670d2aef9da4abd1dd8e9363d3b7b2b27

 lib-common/src/main/java/com/ks/lib/common/util/RedisUtil.java

@@ -42,7 +42,7 @@
     */

    public long getExpire(String key) {
        return redisTemplate.getExpire(key, TimeUnit.SECONDS);
        return redisTemplate.getExpire(key);
    }

    /**
@@ -346,7 +346,7 @@
     * @return
     */

    public double hincr(String key, String item, double by) {
    public double hincr(String key, String item, long by) {

        return redisTemplate.opsForHash().increment(key, item, by);

@@ -361,7 +361,7 @@
     * @return
     */

    public double hdecr(String key, String item, double by) {
    public double hdecr(String key, String item, long by) {

        return redisTemplate.opsForHash().increment(key, item, -by);

@@ -409,12 +409,12 @@
     * @param values 值 可以是多个
     * @return 成功个数
     */
    public long sSet(String key, Object... values) {
    public boolean sSet(String key, Object... values) {
        try {
            return redisTemplate.opsForSet().add(key, values);
            return redisTemplate.opsForSet().add(key, values) != null;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
            return false;
        }
    }

@@ -426,15 +426,16 @@
     * @param values 值 可以是多个
     * @return 成功个数
     */
    public long sSetAndTime(String key, long time, Object... values) {
    public boolean sSetAndTime(String key, long time, Object... values) {
        try {
            Long count = redisTemplate.opsForSet().add(key, values);
            if (time > 0)
            long count = redisTemplate.opsForSet().add(key, values);
            if (time > 0) {
                expire(key, time);
            return count;
            }
            return count > 0;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
            return false;
        }
    }

@@ -461,13 +462,12 @@
     * @return 移除的个数
     */

    public long setRemove(String key, Object... values) {
    public boolean setRemove(String key, Object... values) {
        try {
            Long count = redisTemplate.opsForSet().remove(key, values);
            return count;
            return redisTemplate.opsForSet().remove(key, values) > 0;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
            return false;
        }
    }

@@ -564,45 +564,6 @@
        }
    }

    /**
     * 将list放入缓存
     *
     * @param key   键
     * @param value 值
     * @return
     */

    public boolean lSet(String key, List<Object> value) {
        try {
            redisTemplate.opsForList().rightPushAll(key, value);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    /**
     * 将list放入缓存
     *
     * @param key   键
     * @param value 值
     * @param time  时间(秒)
     * @return
     */

    public boolean lSet(String key, List<Object> value, long time) {
        try {
            redisTemplate.opsForList().rightPushAll(key, value);
            if (time > 0) {
                expire(key, time);
            }
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    /**
     * 根据索引修改list中的某条数据