新增测风塔实体和redis工具类

ipfcst-common/ipfcst-common-core/src/main/java/com/jiayue/ipfcst/common/core/util/DateTimeUtil.java

@@ -248,4 +248,16 @@ public class DateTimeUtil {
         return day.equals(nowDay);
     }
 
+    /**
+     * 将时间戳秒变成0
+     * @param dateTime
+     * @return
+     */
+    public static Long timeTransZero(Long dateTime) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTimeInMillis(dateTime);
+        calendar.set(Calendar.SECOND, 0);
+        return calendar.getTimeInMillis();
+    }
+
 }

ipfcst-common/ipfcst-common-data/src/main/java/com/jiayue/ipfcst/common/data/entity/WindTowerInfo.java

@@ -0,0 +1,38 @@
+package com.jiayue.ipfcst.common.data.entity;
+
+import com.jiayue.ipfcst.common.data.abst.equipmentinfo.AbstractEquipmentInfo;
+import com.jiayue.ipfcst.common.data.constant.enums.EquipmentTypeEnum;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+
+/**
+ * 测风塔实体
+ *
+ * @author zzy
+ * @version 1.0
+ * @since 2019/7/22 11:18
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@Entity
+public class WindTowerInfo extends AbstractEquipmentInfo {
+
+    public WindTowerInfo() {
+        super.setEquipmentType(EquipmentTypeEnum.WINDTOWER);
+    }
+
+    /**
+     * 测风塔是否样板机
+     */
+    @Column
+    private Boolean sample;
+
+    /**
+     * 绑定数据采集通道
+     */
+    String bindTunnel;
+
+}

ipfcst-common/ipfcst-common-data/src/main/java/com/jiayue/ipfcst/common/data/repository/WindTowerInfoRepository.java

@@ -0,0 +1,22 @@
+package com.jiayue.ipfcst.common.data.repository;
+
+import com.jiayue.ipfcst.common.data.entity.WindTowerInfo;
+
+import java.util.List;
+
+/**
+ * 测风塔设备信息实体仓储
+ *
+ * @author yh
+ * @version 1.0
+ * @since 2019/8/6 13:10
+ */
+public interface WindTowerInfoRepository extends BaseRepository<WindTowerInfo, Integer> {
+    /**
+     * 根据ID排序查出所有 测风塔设备信息
+     * yh
+     */
+    List<WindTowerInfo> findAllByOrderByIdAsc();
+
+    WindTowerInfo findByName(String name);
+}

ipfcst-common/ipfcst-common-data/src/main/java/com/jiayue/ipfcst/common/data/repository/WindTowerStatusDataRepository.java

@@ -0,0 +1,27 @@
+package com.jiayue.ipfcst.common.data.repository;
+
+import com.jiayue.ipfcst.common.data.entity.WindTowerStatusData;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 测风塔数据实体仓储
+ *
+ * @author zzy
+ * @version 1.0
+ * @since 2019/8/6 13:08
+ */
+public interface WindTowerStatusDataRepository extends JpaRepository<WindTowerStatusData, Integer>, JpaSpecificationExecutor<WindTowerStatusData> {
+	/**
+	 * 根据设备号和时间段获取测风塔数据
+	 *
+	 * @param equipmentNo
+	 * @param startTime
+	 * @param endTime
+	 * @return
+	 */
+	List<WindTowerStatusData> findByEquipmentNoAndTimeBetween(String equipmentNo, Date startTime, Date endTime);
+}

ipfcst-console/README.md

@@ -54,8 +54,16 @@ wsInst30 30米风速瞬时值
 wdInst30 30米风向瞬时值
 wsInst50 50米风速瞬时值
 wdInst50 50米风向瞬时值
+wsInst60 60米风速瞬时值
+wdInst60 60米风向瞬时值
 wsInst70 70米风速瞬时值
 wdInst70 70米风向瞬时值
+wsInst80 80米风速瞬时值
+wdInst80 80米风向瞬时值
+wsInst90 90米风速瞬时值
+wdInst90 90米风向瞬时值
+wsInst100 100米风速瞬时值
+wdInst100 100米风向瞬时值
 wsInstHubHeight 轮毂高度风速瞬时值
 wdInstHubHeight 轮毂高度风向瞬时值
 

ipfcst-console/src/main/java/com/jiayue/ipfcst/console/util/RedisUtils.java

@@ -0,0 +1,1499 @@
+package com.jiayue.ipfcst.console.util;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.Pipeline;
+import redis.clients.jedis.Tuple;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * redis操作工具类
+ */
+@Component
+public class RedisUtils {
+  @Autowired
+  private JedisPool jedisPool;
+    /*
+    除了该工具类提供的方法外，还可以在外面调用getJedis()方法，获取到jedis实例后，调用它原生的api来操作
+     */
+
+    /**
+     * 获取jedis对象，并选择redis库。jedis默认是0号库，可传入1-16之间的数选择库存放数据
+     * 原则上使用一个redis库存放数据，通过特定的key的命令规则来区分不同的数据就行了。
+     *
+     * @param index redis库号。使用可变参数的目的就是该参数可传可不传。
+     * @return 返回jedis对象
+     */
+    public Jedis getJedis(int... index) {
+        Jedis jedis = jedisPool.getResource();
+        if (index != null && index.length > 0) {
+            if (index[0] > 0 && index[0] <= 16){
+                jedis.select(index[0]);
+            }
+        }
+        return jedis;
+    }
+
+    /*########################  key的操作  ################################*/
+
+    /**
+     * 根据pattern返回当前库中的key
+     *
+     * @param pattern
+     * @return
+     */
+    public  Set<String> keys(String pattern) {
+        Jedis jedis = null;
+        Set<String> keys = null;
+        try {
+            jedis = getJedis();
+            keys = jedis.keys(pattern);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return keys;
+    }
+
+    /**
+     * 删除一个或多个key
+     *
+     * @param key 一个或多个key
+     */
+    public  Long del(String... key) {
+        Jedis jedis = null;
+        Long delNum = 0L;
+        try {
+            jedis = getJedis();
+            delNum =jedis.del(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return delNum;
+    }
+
+    /**
+     * 批量删除
+     * @param keyList 要删除的key的集合
+     */
+    public  void mdel(List<String> keyList){
+        Jedis jedis = getJedis();
+        //获取pipeline
+        Pipeline pipeline = jedis.pipelined();
+        for (String key : keyList) {
+            pipeline.del(key);
+        }
+        //执行结果同步，这样才能保证结果的正确性。实际上不执行该方法也执行了上面的命令，但是结果确不一定完全正确。
+        //注意
+        pipeline.sync();
+        //关闭连接
+        jedis.close();
+    }
+
+    /**
+     * 判断某个key是否还存在
+     *
+     * @param key key
+     * @return
+     */
+    public  Boolean exists(String key) {
+        Jedis jedis = null;
+        Boolean flag = false;
+        try {
+            jedis = getJedis();
+            flag = jedis.exists(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return flag;
+    }
+
+    /**
+     * 设置某个key的过期时间，单位秒
+     *
+     * @param key key
+     * @param seconds 过期时间秒
+     */
+    public  void expire(String key, int seconds) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.expire(key, seconds);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 查看某个key还有几秒过期，-1表示永不过期 ，-2表示已过期
+     *
+     * @param key key
+     * @return
+     */
+    public  Long timeToLive(String key) {
+        Jedis jedis = null;
+        Long ttl;
+        try {
+            jedis = getJedis();
+            ttl = jedis.ttl(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return ttl;
+    }
+
+    /**
+     * 查看某个key对应的value的类型
+     *
+     * @param key
+     * @return
+     */
+    public  String type(String key) {
+        Jedis jedis = null;
+        String type = null;
+        try {
+            jedis = getJedis();
+            type = jedis.type(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return type;
+    }
+
+
+    /*########################  string(字符串)的操作  ####################*/
+
+    /**
+     * 获取某个key的value，类型要对，只能value是string的才能获取
+     *
+     * @param key
+     * @return
+     */
+    public  String get(String key) {
+        Jedis jedis = null;
+        String value = null;
+        try {
+            jedis = getJedis();
+            value = jedis.get(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return value;
+    }
+
+    /**
+     * 设置某个key的value
+     *
+     * @param key
+     * @param value
+     */
+    public  void set(String key, String value) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.set(key, value);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 字符串后追加内容
+     *
+     * @param key key
+     * @param appendContent 要追加的内容
+     */
+    public  void append(String key, String appendContent) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.append(key, appendContent);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 返回key的value的长度
+     *
+     * @param key
+     * @return
+     */
+    public  Long strlen(String key) {
+        Jedis jedis = null;
+        Long strLen = 0L;
+        try {
+            jedis = getJedis();
+            strLen = jedis.strlen(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return strLen;
+    }
+
+    /**
+     * value 加1 必
+     * 须是字符型数字
+     * @param key
+     * @return 增加后的值
+     */
+    public  Long incr(String key) {
+        Jedis jedis = null;
+        Long incrResult = 0L;
+        try {
+            jedis = getJedis();
+            incrResult = jedis.incr(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return incrResult;
+    }
+
+    /**
+     * value 减1   必须是字符型数字
+     *
+     * @param key
+     * @return
+     */
+    public  Long decr(String key) {
+        Jedis jedis = null;
+        Long decrResult = 0L;
+        try {
+            jedis = getJedis();
+            decrResult = jedis.decr(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return decrResult;
+    }
+
+    /**
+     * value 加increment
+     *
+     * @param key key
+     * @param increment 加几
+     * @return
+     */
+    public  Long incrby(String key, int increment) {
+        Jedis jedis = null;
+        Long incrByResult = 0L;
+        try {
+            jedis = getJedis();
+            incrByResult = jedis.incrBy(key, increment);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return incrByResult;
+    }
+
+    /**
+     * value 减increment
+     *
+     * @param key
+     * @param increment
+     * @return
+     */
+    public  Long decrby(String key, int increment) {
+        Jedis jedis = null;
+        Long decrByResult = 0L;
+        try {
+            jedis = getJedis();
+            decrByResult = jedis.decrBy(key, increment);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return decrByResult;
+    }
+
+    /**
+     * 给某个key设置过期时间和value，成功返回OK
+     *
+     * @param key key
+     * @param seconds 过期时间秒
+     * @param value 设置的值
+     * @return
+     */
+    public  String setex(String key, int seconds, String value) {
+        Jedis jedis = null;
+        String result = null;
+        try {
+            jedis = getJedis();
+            result = jedis.setex(key, seconds, value);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return result;
+    }
+
+
+    /*########################  list(列表)的操作  #######################*/
+    //lpush rpush lpop rpop lrange lindex llen lset
+
+    /**
+     * 从左边向列表中添加值
+     *
+     * @param key key
+     * @param str 要添加的值
+     */
+    public  void lpush(String key, String str) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.lpush(key, str);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 从右边向列表中添加值
+     *
+     * @param key key
+     * @param str 要添加的值
+     */
+    public  void rpush(String key, String str) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.rpush(key, str);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 从左边取出一个列表中的值
+     *
+     * @param key
+     * @return
+     */
+    public  String lpop(String key) {
+        Jedis jedis = null;
+        String lpop = null;
+        try {
+            jedis = getJedis();
+            lpop = jedis.lpop(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return lpop;
+    }
+
+    /**
+     * 从右边取出一个列表中的值
+     *
+     * @param key
+     * @return
+     */
+    public  String rpop(String key) {
+        Jedis jedis = null;
+        String rpop = null;
+        try {
+            jedis = getJedis();
+            rpop = jedis.rpop(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return rpop;
+    }
+
+    /**
+     * 取出列表中指定范围内的值，0 到 -1 表示全部
+     *
+     * @param key
+     * @param startIndex
+     * @param endIndex
+     * @return
+     */
+    public  List<String> lrange(String key, int startIndex, int endIndex) {
+        Jedis jedis = null;
+        List<String> result = null;
+        try {
+            jedis = getJedis();
+            result = jedis.lrange(key, startIndex, endIndex);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 返回某列表指定索引位置的值
+     *
+     * @param key 列表key
+     * @param index 索引位置
+     * @return
+     */
+    public  String lindex(String key, int index) {
+        Jedis jedis = null;
+        String lindex = null;
+        try {
+            jedis = getJedis();
+            lindex = jedis.lindex(key, index);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return lindex;
+    }
+
+    /**
+     * 返回某列表的长度
+     *
+     * @param key
+     * @return
+     */
+    public  Long llen(String key) {
+        Jedis jedis = null;
+        Long llen = 0L;
+        try {
+            jedis = getJedis();
+            llen = jedis.llen(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return llen;
+    }
+
+    /**
+     * 给某列表指定位置设置为指定的值
+     *
+     * @param key
+     * @param index
+     * @param str
+     */
+    public  void lset(String key, Long index, String str) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.lset(key, index, str);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 对列表进行剪裁，保留指定闭区间的元素(索引位置也会重排)
+     * @param key 列表key
+     * @param startIndex 开始索引位置
+     * @param endIndex 结束索引位置
+     */
+    public  void ltrim(String key,Integer startIndex,Integer endIndex){
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.ltrim(key, startIndex, endIndex);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 从列表的左边阻塞弹出一个元素
+     * @param key 列表的key
+     * @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞
+     * @return
+     */
+    public  List<String> blpop(String key,Integer timeout){
+        Jedis jedis = null;
+        List<String> valueList = null;
+        try {
+            jedis = getJedis();
+            valueList = jedis.blpop(timeout, key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return valueList;
+    }
+
+    /**
+     * 从列表的右边阻塞弹出一个元素
+     * @param key 列表的key
+     * @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞
+     * @return
+     */
+    public  List<String> brpop(String key,Integer timeout){
+        Jedis jedis = null;
+        List<String> valueList = null;
+        try {
+            jedis = getJedis();
+            valueList = jedis.brpop(timeout, key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return valueList;
+    }
+
+
+    /*########################  hash(哈希表)的操作  #######################*/
+    //hset hget hmset hmget hgetall hdel hkeys hvals hexists hincrby
+
+    /**
+     * 给某个hash表设置一个键值对
+     *
+     * @param key
+     * @param field
+     * @param value
+     */
+    public  void hset(String key, String field, String value) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.hset(key, field, value);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 取出某个hash表中某个field对应的value
+     *
+     * @param key key
+     * @param field field
+     * @return
+     */
+    public  String hget(String key, String field) {
+        Jedis jedis = null;
+        String hget = null;
+        try {
+            jedis = getJedis();
+            hget = jedis.hget(key, field);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return hget;
+    }
+
+    /**
+     * 某个hash表设置一个或多个键值对
+     *
+     * @param key
+     * @param kvMap
+     */
+    public  void hmset(String key, Map<String, String> kvMap) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.hmset(key, kvMap);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 取出某个hash表中任意多个key对应的value的集合
+     *
+     * @param key
+     * @param fields
+     * @return
+     */
+    public  List<String> hmget(String key, String... fields) {
+        Jedis jedis = null;
+        List<String> hmget = null;
+        try {
+            jedis = getJedis();
+            hmget = jedis.hmget(key, fields);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return hmget;
+    }
+
+    /**
+     * 取出某个hash表中所有的键值对
+     *
+     * @param key
+     * @return
+     */
+    public  Map<String, String> hgetall(String key) {
+        Jedis jedis = null;
+        Map<String, String> kvMap = null;
+        try {
+            jedis = getJedis();
+            kvMap = jedis.hgetAll(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return kvMap;
+    }
+
+    /**
+     * 判断某个hash表中的某个key是否存在
+     *
+     * @param key
+     * @param field
+     * @return
+     */
+    public  Boolean hexists(String key, String field) {
+        Jedis jedis = null;
+        Boolean exists = null;
+        try {
+            jedis = getJedis();
+            exists = jedis.hexists(key, field);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return exists;
+    }
+
+    /**
+     * 返回某个hash表中所有的key
+     *
+     * @param key
+     * @return
+     */
+    public  Set<String> hkeys(String key) {
+        Jedis jedis = null;
+        Set<String> keys = null;
+        try {
+            jedis = getJedis();
+            keys = jedis.hkeys(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return keys;
+    }
+
+    /**
+     * 返回某个hash表中所有的value
+     *
+     * @param key
+     * @return
+     */
+    public  List<String> hvals(String key) {
+        Jedis jedis = null;
+        List<String> hvals = null;
+        try {
+            jedis = getJedis();
+            hvals = jedis.hvals(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return hvals;
+    }
+
+    /**
+     * 删除某个hash表中的一个或多个键值对
+     *
+     * @param key
+     * @param fields
+     */
+    public  void hdel(String key, String... fields) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.hdel(key, fields);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+    }
+
+    /**
+     * 给某个hash表中的某个field的value增加多少
+     *
+     * @param key       hash表的key
+     * @param field     表中的某个field
+     * @param increment 增加多少
+     * @return
+     */
+    public  Long hincrby(String key, String field, Long increment) {
+        Jedis jedis = null;
+        Long result = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hincrBy(key, field, increment);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return result;
+    }
+
+    /*########################  set(集合)的操作  ###########################*/
+
+    /**
+     * 往set集合中添加一个或多个元素
+     * @param key key
+     * @param members 要添加的元素
+     * @return 添加成功的元素个数
+     */
+    public  Long sadd(String key,String... members){
+        Jedis jedis = null;
+        Long num = 0L;
+        try {
+            jedis = getJedis();
+            num = jedis.sadd(key, members);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 返回set集合中的所有元素，顺序与加入时的顺序一致
+     * @param key key
+     * @return
+     */
+    public  Set<String> smembers(String key){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.smembers(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 判断集合中是否存在某个元素
+     * @param key key
+     * @param member 某个元素
+     * @return true存在，false不存在
+     */
+    public  Boolean sismember(String key,String member){
+        Jedis jedis = null;
+        Boolean isMember = false;
+        try {
+            jedis = getJedis();
+            isMember = jedis.sismember(key, member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return isMember;
+    }
+
+    /**
+     * 返回set集合的长度
+     * @param key key
+     * @return
+     */
+    public  Long scard(String key){
+        Jedis jedis = null;
+        Long len = 0L;
+        try {
+            jedis = getJedis();
+            len = jedis.scard(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return len;
+    }
+
+    /**
+     * 删除set集合中指定的一个或多个元素
+     * @param key
+     * @param members 要删除的元素
+     * @return 删除成功的元素个数
+     */
+    public  Long srem(String key,String... members){
+        Jedis jedis = null;
+        Long num = 0L;
+        try {
+            jedis = getJedis();
+            num = jedis.srem(key,members);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 将key1中的元素key1Member移动到key2中
+     * @param key1 来源集合key
+     * @param key2 目的地集合key
+     * @param key1Member key1中的元素
+     * @return 1成功，0失败
+     */
+    public  Long smove(String key1,String key2,String key1Member){
+        Jedis jedis = null;
+        Long num = 0L;
+        try {
+            jedis = getJedis();
+            num = jedis.smove(key1,key2,key1Member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 随机查询返回集合中的指定个数的元素（若count为负数，返回的元素可能会重复）
+     * @param key key
+     * @param count 要查询返回的元素个数
+     * @return 元素list集合
+     */
+    public  List<String> srandmember(String key,int count){
+        Jedis jedis = null;
+        List<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.srandmember(key,count);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 从set集合中随机弹出指定个数个元素
+     * @param key key
+     * @param count 要弹出的个数
+     * @return 随机弹出的元素
+     */
+    public  Set<String> spop(String key,int count){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.spop(key,count);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 求交集，返回多个set集合相交的部分
+     * @param setKeys 多个set集合的key
+     * @return 相交的元素集合
+     */
+    public  Set<String> sinter(String... setKeys){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.sinter(setKeys);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 求并集，求几个set集合的并集（因为set中不会有重复的元素，合并后的集合也不会有重复的元素）
+     * @param setKeys 多个set的key
+     * @return 合并后的集合
+     */
+    public  Set<String> sunion(String... setKeys){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.sunion(setKeys);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 求差集，求几个集合之间的差集
+     * @param setKeys 多个set的key
+     * @return 差集
+     */
+    public  Set<String> sdiff(String... setKeys){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.sdiff(setKeys);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+
+    /*########################  zset(有序集合)的操作  #######################*/
+
+    /**
+     * 添加一个元素到zset
+     * @param key key
+     * @param score 元素的分数
+     * @param member 元素
+     * @return 成功添加的元素个数
+     */
+    public  Long zadd(String key,double score, String member){
+        Jedis jedis = null;
+        Long num = null;
+        try {
+            jedis = getJedis();
+            num = jedis.zadd(key,score,member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 添加一个或多个元素到zset
+     * @param key key
+     * @param memberScores 元素和分数的map集合，map的k是元素，v是分数
+     * @return 成功添加的元素个数
+     */
+    public  Long zadd(String key,Map<String,Double> memberScores){
+        Jedis jedis = null;
+        Long num = null;
+        try {
+            jedis = getJedis();
+            num = jedis.zadd(key,memberScores);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 查询指定闭区间的元素（根据分数升序）
+     * （0,-1表示全部）
+     * @param key zset的key
+     * @param start 开始区间
+     * @param end 结束区间
+     * @return 元素集合
+     */
+    public  Set<String> zrange(String key, long start, long end){
+        Jedis jedis = null;
+        Set<String> ascResult = null;
+        try {
+            jedis = getJedis();
+            ascResult = jedis.zrange(key,start,end);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return ascResult;
+    }
+
+    /**
+     * 查询指定闭区间的元素，带着分数
+     * （0,-1表示全部）
+     * @param key zset的key
+     * @param start 开始区间
+     * @param end 结束区间
+     * @return 元素集合 格式为：
+     * [{"element":"a","score":10.0,"binaryElement":"YQ=="},{"element":"b","score":20.0,"binaryElement":"Yg=="}]
+     */
+    public  Set<Tuple> zrangeWithScores(String key, long start, long end){
+        Jedis jedis = null;
+        Set<Tuple> ascResult = null;
+        try {
+            jedis = getJedis();
+            ascResult = jedis.zrangeWithScores(key,start,end);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return ascResult;
+    }
+
+    /**
+     * 查询指定索引闭区间的元素（根据分数降序）
+     * （0,-1表示全部）
+     * @param key zset的key
+     * @param start 开始区间
+     * @param end 结束区间
+     * @return 元素集合
+     */
+    public  Set<String> zrevrange(String key, long start, long end){
+        Jedis jedis = null;
+        Set<String> descResult = null;
+        try {
+            jedis = getJedis();
+            descResult = jedis.zrevrange(key,start,end);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return descResult;
+    }
+
+    /**
+     * 查询指定索引闭区间的元素，带着分数（根据分数降序）
+     * （0,-1表示全部）
+     * @param key zset的key
+     * @param start 开始区间
+     * @param end 结束区间
+     * @return 元素集合 格式为：
+     * [{"element":"b","score":20.0,"binaryElement":"Yg=="},{"element":"a","score":10.0,"binaryElement":"YQ=="}]
+     */
+    public  Set<Tuple> zrevrangeWithScores(String key, long start, long end){
+        Jedis jedis = null;
+        Set<Tuple> descResult = null;
+        try {
+            jedis = getJedis();
+            descResult = jedis.zrevrangeWithScores(key,start,end);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return descResult;
+    }
+
+    /**
+     * 返回有序集合(zset)中的元素个数
+     * @param key key
+     * @return 个数
+     */
+    public  Long zcard(String key){
+        Jedis jedis = null;
+        Long count = null;
+        try {
+            jedis = getJedis();
+            count = jedis.zcard(key);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return count;
+    }
+
+    /**
+     * 返回指定分数区间的元素个数（闭区间）
+     * @param key key
+     * @param startScore 开始分数
+     * @param endScore 结束分数
+     * @return 个数
+     */
+    public  Long zcount(String key,Long startScore,Long endScore){
+        Jedis jedis = null;
+        Long count = null;
+        try {
+            jedis = getJedis();
+            count = jedis.zcount(key,startScore,endScore);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return count;
+    }
+
+    /**
+     * 返回某元素在集合中的排名（根据分数降序排列时）
+     * @param key key
+     * @param member 集合中的元素
+     * @return 排名，从0开始
+     */
+    public  Long zrevrank(String key, String member){
+        Jedis jedis = null;
+        Long count = null;
+        try {
+            jedis = getJedis();
+            count = jedis.zrevrank(key,member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return count;
+    }
+
+    /**
+     * 返回某元素在集合中的排名（根据分数升序排列时）
+     * @param key key
+     * @param member 集合中的元素
+     * @return 排名，从0开始
+     */
+    public  Long zrank(String key, String member){
+        Jedis jedis = null;
+        Long count = null;
+        try {
+            jedis = getJedis();
+            count = jedis.zrank(key,member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return count;
+    }
+
+    /**
+     * 升序查询指定分数闭区间的元素
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @return 元素集合
+     */
+    public  Set<String> zrangeByScore(String key,double min, double max){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrangeByScore(key, min, max);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 升序查询指定分数闭区间的元素，并指定偏移量
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @param offset 偏移量
+     * @param size 数量
+     * @return 元素集合
+     */
+    public  Set<String> zrangeByScore(String key,double min, double max,int offset,int size){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrangeByScore(key, min, max,offset,size);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 升序查询指定分数闭区间的元素，带着分数
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @return 元素集合
+     */
+    public  Set<Tuple> zrangeByScoreWithScores(String key,double min, double max){
+        Jedis jedis = null;
+        Set<Tuple> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrangeByScoreWithScores(key, min, max);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 升序查询指定分数闭区间的元素，并指定偏移量，带着分数
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @param offset 偏移量
+     * @param size 数量
+     * @return 元素集合
+     */
+    public  Set<Tuple> zrangeByScoreWithScores(String key,double min, double max,int offset,int size){
+        Jedis jedis = null;
+        Set<Tuple> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrangeByScoreWithScores(key, min, max,offset,size);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 降序查询指定分数闭区间的元素
+     * @param key key
+     * @param max 最大分数
+     * @param min 最小分数
+     * @return 元素集合
+     */
+    public  Set<String> zrevrangebyscore(String key,double max,double min){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrevrangeByScore(key, max,min);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 降序查询指定分数闭区间的元素，并指定偏移量
+     * @param key key
+     * @param max 最大分数
+     * @param min 最小分数
+     * @return 元素集合
+     */
+    public  Set<String> zrevrangebyscore(String key,double max,double min,int offset,int size){
+        Jedis jedis = null;
+        Set<String> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrevrangeByScore(key, max,min,offset,size);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 降序查询指定分数闭区间的元素，并带着分数
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @return 元素集合
+     */
+    public  Set<Tuple> zrevrangeByScoreWithScores(String key,double max,double min){
+        Jedis jedis = null;
+        Set<Tuple> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrevrangeByScoreWithScores(key,max,min);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 降序查询指定分数闭区间的元素，并指定偏移量，带着分数
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @param offset 偏移量
+     * @param size 数量
+     * @return 元素集合
+     */
+    public  Set<Tuple> zrevrangeByScoreWithScores(String key,double max,double min,int offset,int size){
+        Jedis jedis = null;
+        Set<Tuple> members = null;
+        try {
+            jedis = getJedis();
+            members = jedis.zrevrangeByScoreWithScores(key, min, max,offset,size);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return members;
+    }
+
+    /**
+     * 有序集合中指定删除一或多个元素
+     * @param key
+     * @param member 元素
+     * @return 删除成功的个数
+     */
+    public  Long zrem(String key, String... member){
+        Jedis jedis = null;
+        Long num = null;
+        try {
+            jedis = getJedis();
+            num = jedis.zrem(key,member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 分数升序排名时，删除指定索引区间的元素
+     * @param key key
+     * @param start 开始索引
+     * @param end 结束索引
+     * @return 删除成功的个数
+     */
+    public  Long zremrangebyrank(String key,long start,long end){
+        Jedis jedis = null;
+        Long num = null;
+        try {
+            jedis = getJedis();
+            num = jedis.zremrangeByRank(key,start,end);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 分数升序排名时，删除指定分数区间的元素
+     * @param key key
+     * @param min 最小分数
+     * @param max 最大分数
+     * @return 删除成功的个数
+     */
+    public  Long zremrangeByScore(String key,long min,long max){
+        Jedis jedis = null;
+        Long num = null;
+        try {
+            jedis = getJedis();
+            num = jedis.zremrangeByScore(key,min,max);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return num;
+    }
+
+    /**
+     * 查询有序集合中某元素的分数
+     * @param key key
+     * @param member 元素
+     * @return 删除成功的个数
+     */
+    public  Double zscore(String key,String member){
+        Jedis jedis = null;
+        Double score = null;
+        try {
+            jedis = getJedis();
+            score = jedis.zscore(key,member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return score;
+    }
+
+    /**
+     * 给有序集合中某元素的分数增加(正数)或减少(负数)
+     * @param key key
+     * @param score 分数
+     * @param member 元素
+     * @return 新的分数
+     */
+    public  Double zincrby(String key,double score,String member){
+        Jedis jedis = null;
+        Double newScore = null;
+        try {
+            jedis = getJedis();
+            newScore = jedis.zincrby(key,score,member);
+        }finally {
+            if (jedis != null){
+                jedis.close();
+            }
+        }
+        return newScore;
+    }
+    /**
+     * 私有化构造器，不让实例化对象
+     */
+    private RedisUtils() {
+    }
+}