selectUserDetailByUserId

qnfhq-api/src/main/java/com/qnfhq/modules/business/controller/TMingOrderController.java

@@ -3,9 +3,9 @@ package com.qnfhq.modules.business.controller;
 
 import cn.dev33.satoken.stp.StpUtil;
 import com.qnfhq.common.ApiBaseController;
-import com.qnfhq.common.redis.RedisCache;
 import com.qnfhq.common.utils.Result;
 import com.qnfhq.common.utils.StringUtils;
+import com.qnfhq.common.utils.cache.RedisCache;
 import com.qnfhq.modules.business.entity.TMingOrder;
 import com.qnfhq.modules.business.service.ITMingOrderService;
 import com.qnfhq.modules.user.service.SettingService;

qnfhq-api/src/main/java/com/qnfhq/modules/business/dao/TMingProductUserMapper.java

@@ -2,6 +2,8 @@ package com.qnfhq.modules.business.dao;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.qnfhq.modules.business.entity.MingProductUser;
+import org.apache.ibatis.annotations.Mapper;
 
+@Mapper
 public interface TMingProductUserMapper extends BaseMapper<MingProductUser> {
 }

qnfhq-common/src/main/java/com/qnfhq/common/redis/RedisCache.java

@@ -1,387 +0,0 @@
-package com.qnfhq.common.redis;
-
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.dao.DataAccessException;
-import org.springframework.data.redis.connection.RedisConnection;
-import org.springframework.data.redis.core.*;
-import org.springframework.stereotype.Component;
-
-import java.util.*;
-import java.util.concurrent.TimeUnit;
-
-
-/**
- * spring redis 工具类
- *
- * @author ruoyi
- **/
-@SuppressWarnings(value = {"unchecked", "rawtypes"})
-@Component
-public class RedisCache {
-    @Autowired
-    public RedisTemplate redisTemplate;
-
-    /**
-     * 获取原子自增
-     *
-     * @param key     缓存的键值
-     * @param value   缓存的值
-     * @param timeout 过期时间
-     */
-    public <T> void increment(final String key, final T value, final Integer timeout) {
-        // 3. 存入 Redis，设置初始值 + 过期时间
-        redisTemplate.opsForValue().set(key, String.valueOf(value), timeout);
-    }
-    /**
-     * 获取原子自增
-     * @param key     缓存的键值
-     * @param value   缓存的值
-     */
-    public <T> Long increment(final String key, final Long value) {
-        // 3. 存入 Redis，设置初始值 + 过期时间
-        return redisTemplate.opsForValue().increment(key, value);
-    }
-
-    /**
-     * 缓存基本的对象，Integer、String、实体类等
-     *
-     * @param key   缓存的键值
-     * @param value 缓存的值
-     */
-    public <T> void setCacheObject(final String key, final T value) {
-        redisTemplate.opsForValue().set(key, value);
-    }
-
-    /**
-     * 缓存基本的对象，Integer、String、实体类等
-     *
-     * @param key      缓存的键值
-     * @param value    缓存的值
-     * @param timeout  时间
-     * @param timeUnit 时间颗粒度
-     */
-    public <T> void setCacheObject(final String key, final T value, final Integer timeout, final TimeUnit timeUnit) {
-        redisTemplate.opsForValue().set(key, value, timeout, timeUnit);
-    }
-
-    /**
-     * 设置有效时间
-     *
-     * @param key     Redis键
-     * @param timeout 超时时间
-     * @return true=设置成功；false=设置失败
-     */
-    public boolean expire(final String key, final long timeout) {
-        return expire(key, timeout, TimeUnit.SECONDS);
-    }
-
-    /**
-     * 设置有效时间
-     *
-     * @param key     Redis键
-     * @param timeout 超时时间
-     * @param unit    时间单位
-     * @return true=设置成功；false=设置失败
-     */
-    public boolean expire(final String key, final long timeout, final TimeUnit unit) {
-        return redisTemplate.expire(key, timeout, unit);
-    }
-
-    /**
-     * 获取有效时间
-     *
-     * @param key Redis键
-     * @return 有效时间
-     */
-    public long getExpire(final String key) {
-        return redisTemplate.getExpire(key);
-    }
-
-    /**
-     * 判断 key是否存在
-     *
-     * @param key 键
-     * @return true 存在 false不存在
-     */
-    public Boolean hasKey(String key) {
-        return redisTemplate.hasKey(key);
-    }
-
-    /**
-     * 获得缓存的基本对象。
-     *
-     * @param key 缓存键值
-     * @return 缓存键值对应的数据
-     */
-    public <T> T getCacheObject(final String key) {
-        ValueOperations<String, T> operation = redisTemplate.opsForValue();
-        return operation.get(key);
-    }
-
-    /**
-     * 删除单个对象
-     *
-     * @param key
-     */
-    public boolean deleteObject(final String key) {
-        return redisTemplate.delete(key);
-    }
- /*   public boolean deleteStreamObject(final String key)
-    {
-       *//* return redisTemplate.opsForStream().destroyGroup()*//*
-    }*/
-
-    /**
-     * 删除集合对象
-     *
-     * @param collection 多个对象
-     * @return
-     */
-    public boolean deleteObject(final Collection collection) {
-        return redisTemplate.delete(collection) > 0;
-    }
-
-    /**
-     * 缓存List数据
-     *
-     * @param key      缓存的键值
-     * @param dataList 待缓存的List数据
-     * @return 缓存的对象
-     */
-    public <T> long setCacheList(final String key, final List<T> dataList) {
-        Long count = redisTemplate.opsForList().rightPushAll(key, dataList);
-        return count == null ? 0 : count;
-    }
-
-    /**
-     * 获得缓存的list对象
-     *
-     * @param key 缓存的键值
-     * @return 缓存键值对应的数据
-     */
-    public <T> List<T> getCacheList(final String key) {
-        return redisTemplate.opsForList().range(key, 0, -1);
-    }
-
-    /**
-     * 缓存Set
-     *
-     * @param key     缓存键值
-     * @param dataSet 缓存的数据
-     * @return 缓存数据的对象
-     */
-    public <T> BoundSetOperations<String, T> setCacheSet(final String key, final Set<T> dataSet) {
-        BoundSetOperations<String, T> setOperation = redisTemplate.boundSetOps(key);
-        Iterator<T> it = dataSet.iterator();
-        while (it.hasNext()) {
-            setOperation.add(it.next());
-        }
-        return setOperation;
-    }
-
-    /**
-     * 获得缓存的set
-     *
-     * @param key
-     * @return
-     */
-    public <T> Set<T> getCacheSet(final String key) {
-        return redisTemplate.opsForSet().members(key);
-    }
-
-    /**
-     * 缓存Map
-     *
-     * @param key
-     * @param dataMap
-     */
-    public <T> void setCacheMap(final String key, final Map<String, T> dataMap) {
-        if (dataMap != null) {
-            redisTemplate.opsForHash().putAll(key, dataMap);
-        }
-    }
-
-    /**
-     * 获得缓存的Map
-     *
-     * @param key
-     * @return
-     */
-    public <T> Map<String, T> getCacheMap(final String key) {
-        return redisTemplate.opsForHash().entries(key);
-    }
-
-    /**
-     * 往Hash中存入数据
-     *
-     * @param key   Redis键
-     * @param hKey  Hash键
-     * @param value 值
-     */
-    public <T> void setCacheMapValue(final String key, final String hKey, final T value) {
-        redisTemplate.opsForHash().put(key, hKey, value);
-    }
-
-    /**
-     * 获取Hash中的数据
-     *
-     * @param key  Redis键
-     * @param hKey Hash键
-     * @return Hash中的对象
-     */
-    public <T> T getCacheMapValue(final String key, final String hKey) {
-        HashOperations<String, String, T> opsForHash = redisTemplate.opsForHash();
-        return opsForHash.get(key, hKey);
-    }
-
-    /**
-     * 获取多个Hash中的数据
-     *
-     * @param key   Redis键
-     * @param hKeys Hash键集合
-     * @return Hash对象集合
-     */
-    public <T> List<T> getMultiCacheMapValue(final String key, final Collection<Object> hKeys) {
-        return redisTemplate.opsForHash().multiGet(key, hKeys);
-    }
-
-    /**
-     * 删除Hash中的某条数据
-     *
-     * @param key  Redis键
-     * @param hKey Hash键
-     * @return 是否成功
-     */
-    public boolean deleteCacheMapValue(final String key, final String hKey) {
-        return redisTemplate.opsForHash().delete(key, hKey) > 0;
-    }
-
-    /**
-     * 获得缓存的基本对象列表
-     *
-     * @param pattern 字符串前缀
-     * @return 对象列表
-     */
-    public Collection<String> keys(final String pattern) {
-        return redisTemplate.keys(pattern);
-    }
-
-    public List<Long> getAllActiveUserId() {
-            List<Long> userIds = new ArrayList<>();
-            Collection<String> keys = keys("active:UserId:*");
-            for (String key : keys) {
-                String substring = key.substring(14);
-                userIds.add(Long.parseLong(substring));
-            }
-            setCacheObject("active:all:", userIds, 60, TimeUnit.SECONDS);
-            return userIds;
-    }
-
-
-    public <K, V> boolean tryLock(K key, V value, long timeout) {
-        return Boolean.TRUE.equals(redisTemplate.opsForValue().setIfAbsent(key, value, timeout, TimeUnit.MILLISECONDS));
-    }
-
-    public boolean deleteAllObject() {
-        boolean execute = (boolean) redisTemplate.execute(new RedisCallback<Object>() {
-            public String doInRedis(RedisConnection connection) throws DataAccessException {
-                connection.flushDb();
-                return "ok";
-            }
-        });
-        return execute;
-    }
-
-    /**
-     * 原子递减
-     * @param key
-     * @param value
-     * @return
-     * @author yelz
-     */
-    public <T> Long decrement(final String key, final Long value) {
-        return redisTemplate.opsForValue().decrement(key, value);
-    }
-
-    /**
-     * 查询范围
-     * @param zsetKey
-     * @param type
-     * @param start
-     * @param end
-     * @return
-     * @author yelz
-     */
-    public ArrayList<String> getRange(String zsetKey,Integer type,long start,long end) {
-        ZSetOperations<String,String> ops = redisTemplate.opsForZSet();
-        Set<String> values = null;
-        if(2 == type.intValue()) {
-            values = ops.range(zsetKey, start, end);
-        } else {
-            values = ops.reverseRange(zsetKey, start, end);
-        }
-        return values.isEmpty() ? null : new ArrayList<String>(values);
-    }
-
-    /**
-     * 按分数范围查询
-     * @param zsetKey
-     * @param min
-     * @param max
-     * @return
-     * @author yelz
-     */
-    public ArrayList<String> getRangeByScore(String zsetKey,double min,double max) {
-        ZSetOperations<String,String> ops = redisTemplate.opsForZSet();
-        Set<String> values = null;
-        values = ops.rangeByScore(zsetKey, min, max);
-        return values.isEmpty() ? null : new ArrayList<String>(values);
-    }
-
-    /**
-     * 添加
-     * @param zsetKey
-     * @param value
-     * @param score
-     * @param direction
-     * @param maxLength
-     * @return
-     * @author yelz
-     */
-    public boolean addZSet(String zsetKey,String value,double score,int direction, long maxLength) {
-        ZSetOperations<String,String> ops = redisTemplate.opsForZSet();
-        ops.add(zsetKey, value, score);
-        long size = ops.zCard(zsetKey);
-        if(size > maxLength) {
-            if(direction == 1) {
-                ops.removeRange(zsetKey,0,size-maxLength-1);
-            } else {
-                ops.removeRange(zsetKey,maxLength,size);
-            }
-
-        }
-        return true;
-    }
-
-    /**
-     * 移除
-     * @param zsetKey
-     * @param id
-     * @return
-     */
-    public Long removeZset(String zsetKey, String id) {
-        ZSetOperations<String,String> ops = redisTemplate.opsForZSet();
-        return ops.remove(zsetKey, id);
-    }
-
-    /**
-     * 返回元素个数
-     * @return
-     */
-    public Long countZset(String zsetKey) {
-        ZSetOperations<String,String> ops = redisTemplate.opsForZSet();
-        return ops.size(zsetKey);
-    }
-}
-