设备掉线报警邮件发送

jinpengyong

2020-11-27 72026a58219a4ee7cc41a7b37204da372d16d2aa

 src/main/java/com/moral/util/RedisUtils.java

@@ -5,15 +5,12 @@
import com.moral.common.BooleanValueFilter;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;

@@ -160,12 +157,6 @@
     */
    public boolean set(final String key, Object value) {
        boolean result = false;
        RedisSerializer stringSerializer = new StringRedisSerializer();
        redisTemplate.setKeySerializer(stringSerializer);
        redisTemplate.setValueSerializer(stringSerializer);
        redisTemplate.setHashKeySerializer(stringSerializer);
        redisTemplate.setHashValueSerializer(stringSerializer);
        this.redisTemplate = redisTemplate;
        try {
           if(value!=null&&!(value instanceof String)) {
              value = JSON.toJSONString(value,new BooleanValueFilter());
@@ -179,4 +170,26 @@
        return result;
    }

    /**
     * 写入缓存
     *
     * @param key
     * @param value
     * @return
     */
    public boolean set(final String key, Object value, Long expireTime) {
        boolean result = false;
        try {
           if(value!=null&&!(value instanceof String)) {
              value = JSON.toJSONString(value, javaTypePatchValueFilter);
           }
            ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
            operations.set(key, value);
            redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);
            result = true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }
}