Merge branch 'master' of http://git.ycjcjy.com/fuxingfan/SpringProject

SmartCommunity/SmartCommunityV1/community-common/pom.xml

@@ -0,0 +1,104 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>spring-cloud</artifactId>
+        <groupId>com.example</groupId>
+        <version>0.0.1</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>community-common</artifactId>
+    <packaging>jar</packaging>
+    <name>community-common</name>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+        <java.version>1.8</java.version>
+        <spring-cloud.version>Finchley.SR1</spring-cloud.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.4</version>
+        </dependency>
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>2.9.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${slf4j.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.jodd</groupId>
+            <artifactId>jodd-bean</artifactId>
+            <version>3.7.1</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-collections</groupId>
+            <artifactId>commons-collections</artifactId>
+            <version>3.2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-httpclient</groupId>
+            <artifactId>commons-httpclient</artifactId>
+            <version>3.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.zxing</groupId>
+            <artifactId>core</artifactId>
+            <version>3.2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.zxing</groupId>
+            <artifactId>javase</artifactId>
+            <version>3.2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.tomcat.embed</groupId>
+            <artifactId>tomcat-embed-core</artifactId>
+            <version>8.5.16</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+            <version>4.3.16.RELEASE</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/FastJsonSerializer.java

@@ -0,0 +1,49 @@
+package com.community.commom.redis;
+
+import com.alibaba.fastjson.JSON;
+import org.springframework.stereotype.Component;
+
+import java.io.Serializable;
+import java.nio.charset.Charset;
+
+/**
+ * redis fastjson 序列化工具
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ *
+ **/
+@Component
+public class FastJsonSerializer implements RedisSerializer {
+
+
+    @Override
+    public <T> T deserialize(byte[] source, Class<T> tClass) throws SerializationFailedException {
+        try {
+            if (source == null){
+                return null;
+            }
+            if (tClass == String.class){
+                return tClass.cast(new String(source, Charset.forName("UTF-8")));
+            }
+
+            return JSON.parseObject(source,tClass);
+        } catch (Exception e) {
+            throw new SerializationFailedException("Deserialize failed:" + e, e);
+        }
+    }
+
+    @Override
+    public byte[] serialize(Object object) throws SerializationFailedException {
+        if (!(object instanceof Serializable)) {
+            throw new IllegalArgumentException("Serializer requires a Serializable payload " + "but received an object of type [" + object.getClass().getName() + "]");
+        }
+        try {
+            if (object instanceof String){
+                return object.toString().getBytes("UTF-8");
+            }
+            return JSON.toJSONString(object).getBytes("UTF-8");
+        } catch (Exception e) {
+            throw new SerializationFailedException("Serialize failed:" + object.getClass(), e);
+        }
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/RedisConfiguration.java

@@ -0,0 +1,35 @@
+package com.community.commom.redis;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.JedisPoolConfig;
+
+/**
+ * redis configuration
+ * @author gengxiang
+ * @create 2017-09-25 10:25
+ **/
+@Configuration
+public class RedisConfiguration {
+
+    @Bean(name= "jedis.pool")
+    @Autowired
+    public JedisPool jedisPool(@Qualifier("jedis.pool.config") JedisPoolConfig config,
+                               @Value("${jedis.pool.host}")String host,
+                               @Value("${jedis.pool.port}")int port) {
+        return new JedisPool(config, host, port);
+    }
+
+    @Bean(name= "jedis.pool.config")
+    public JedisPoolConfig jedisPoolConfig (@Value("${jedis.pool.config.maxTotal}")int maxTotal,
+                                            @Value("${jedis.pool.config.maxIdle}")int maxIdle) {
+        JedisPoolConfig config = new JedisPoolConfig();
+        config.setMaxTotal(maxTotal);
+        config.setMaxIdle(maxIdle);
+        return config;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/RedisJsonSerializer.java

@@ -0,0 +1,47 @@
+package com.community.commom.redis;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.Serializable;
+
+/**
+ * redis json 序列化工具
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ *
+ **/
+public class RedisJsonSerializer implements RedisSerializer {
+    private static final ObjectMapper mapper = new ObjectMapper();
+
+    static {
+        mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+    }
+
+    @Override
+    public <T> T deserialize(byte[] source, Class<T> tClass) throws SerializationFailedException {
+        try {
+            if (source == null)
+                return null;
+            if (tClass == String.class)
+                return tClass.cast(new String(source));
+            return mapper.readValue(source, tClass);
+        } catch (Exception e) {
+            throw new SerializationFailedException("Deserialize failed:" + e, e);
+        }
+    }
+
+    @Override
+    public byte[] serialize(Object object) throws SerializationFailedException {
+        if (!(object instanceof Serializable)) {
+            throw new IllegalArgumentException("Serializer requires a Serializable payload " + "but received an object of type [" + object.getClass().getName() + "]");
+        }
+        try {
+            if (object instanceof String)
+                return object.toString().getBytes();
+            return mapper.writeValueAsString(object).getBytes("UTF-8");
+        } catch (Exception e) {
+            throw new SerializationFailedException("Serialize failed:" + object.getClass(), e);
+        }
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/RedisObjectSerializer.java

@@ -0,0 +1,47 @@
+package com.community.commom.redis;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.ObjectInputStream;
+import java.io.ObjectOutputStream;
+import java.io.Serializable;
+
+/**
+ * redis json 序列化工具
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ *
+ **/
+public class RedisObjectSerializer implements RedisSerializer {
+
+    @Override
+    public <T> T deserialize(byte[] source, Class<T> tClass) throws SerializationFailedException {
+        if (source == null)
+            return null;
+        if (tClass == String.class)
+            return tClass.cast(new String(source));
+        try (ByteArrayInputStream byteStream = new ByteArrayInputStream(source);
+             ObjectInputStream objectInputStream = new ObjectInputStream(byteStream)) {
+            return tClass.cast(objectInputStream.readObject());
+        } catch (Exception e) {
+            throw new SerializationFailedException("Deserialize failed:" + e, e);
+        }
+    }
+
+    @Override
+    public byte[] serialize(Object object) throws SerializationFailedException {
+        if (!(object instanceof Serializable)) {
+            throw new IllegalArgumentException("Serializer requires a Serializable payload " + "but received an object of type [" + object.getClass().getName() + "]");
+        }
+        if (object instanceof String)
+            return object.toString().getBytes();
+        try (ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
+             ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteStream)) {
+            objectOutputStream.writeObject(object);
+            objectOutputStream.flush();
+            return byteStream.toByteArray();
+        } catch (Exception e) {
+            throw new SerializationFailedException("Serialize failed:" + object.getClass(), e);
+        }
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/RedisSerializer.java

@@ -0,0 +1,30 @@
+package com.community.commom.redis;
+
+/**
+ * redis 序列化工具接口
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ *
+ **/
+public interface RedisSerializer {
+    /**
+     * Deserialize
+     *
+     * @param source serialized data
+     * @param tClass generic class type
+     * @param <T>    generic class
+     * @return object
+     * @throws SerializationFailedException
+     */
+    <T> T deserialize(byte[] source, Class<T> tClass) throws SerializationFailedException;
+
+    /**
+     * Serialize
+     *
+     * @param object object
+     * @return serialized data
+     * @throws SerializationFailedException
+     */
+    byte[] serialize(Object object) throws SerializationFailedException;
+
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/RedisTemplate.java

@@ -0,0 +1,317 @@
+package com.community.commom.redis;
+
+
+
+import org.springframework.beans.factory.annotation.Autowired;
+import redis.clients.jedis.JedisPool;
+
+import java.nio.charset.Charset;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * redis 工具虚类
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ *
+ **/
+public abstract class RedisTemplate {
+
+    final Charset defaultCharset = Charset.forName("UTF8");
+
+    long maxLockTime = 5000L;
+
+    long lockRetryTime = 100L;
+
+    @Autowired
+    RedisSerializer serializer;
+
+    @Autowired
+    JedisPool redisPool;
+
+
+    public Charset getDefaultCharset() {
+        return defaultCharset;
+    }
+
+    public long getMaxLockTime() {
+        return maxLockTime;
+    }
+
+    public void setMaxLockTime(long maxLockTime) {
+        this.maxLockTime = maxLockTime;
+    }
+
+    public long getLockRetryTime() {
+        return lockRetryTime;
+    }
+
+    public void setLockRetryTime(long lockRetryTime) {
+        this.lockRetryTime = lockRetryTime;
+    }
+
+    public RedisSerializer getSerializer() {
+        return serializer;
+    }
+
+    public void setSerializer(RedisSerializer serializer) {
+        this.serializer = serializer;
+    }
+
+    public JedisPool getRedisPool() {
+        return redisPool;
+    }
+
+    public void setRedisPool(JedisPool redisPool) {
+        this.redisPool = redisPool;
+    }
+
+    /**
+     * Set the value of a key
+     *
+     * @param key   key
+     * @param value value
+     * @return result
+     */
+    public abstract String set(String key, Object value);
+
+    /**
+     * setnx the value of a key
+     *
+     * @param key   key
+     * @param value value
+     * @return result
+     */
+    public abstract Long setnx(String key, Object value);
+
+    /**
+     * set an expire time for a key
+     *
+     * @param key     key
+     * @param seconds expire time
+     * @return result
+     */
+    public abstract Long expire(String key, int seconds);
+
+    public abstract Long ttl(String key);
+
+    /**
+     * get a String value of a key
+     *
+     * @param key key
+     * @return object
+     */
+    public abstract String get(String key);
+
+    /**
+     * get an object of a key
+     *
+     * @param key    key
+     * @param tClass the class of object
+     * @param <T>    generic type
+     * @return object
+     */
+    public abstract <T> T get(String key, Class<T> tClass);
+
+    /**
+     * delete a value of a key
+     *
+     * @param key key
+     * @return result
+     */
+    public abstract Long del(String key);
+
+    /**
+     * delete values of keys
+     *
+     * @param keys keys
+     * @return result
+     */
+    public abstract Long del(String... keys);
+
+    /**
+     * Set the value of a hash field
+     *
+     * @param key   key
+     * @param field hash field
+     * @param value value
+     * @return result
+     */
+    public abstract Long hset(String key, String field, Object value);
+
+    /**
+     * Set the values of fields
+     *
+     * @param key key
+     * @param map key:field,value:object
+     * @return result
+     */
+    public abstract <T> String hmset(String key, Map<String, T> map);
+
+    public abstract <T> Map<String, T> hmget(String key, List<String> fields, Class<T> tClass);
+
+    /**
+     * del the value of a hash field
+     *
+     * @param key   key
+     * @param field hash field
+     * @return result
+     */
+    public abstract Long hdel(String key, String field);
+
+    /**
+     * Set the string value of a hash field
+     *
+     * @param key    key
+     * @param field  hash field
+     * @param tClass generics class type
+     * @param <T>    generics class
+     * @return value
+     */
+    public abstract <T> T hget(String key, String field, Class<T> tClass);
+
+
+    /**
+     * Set the string value of a hash field
+     *
+     * @param key    key
+     * @param tClass generics class type
+     * @param <T>    generics class
+     * @return value
+     */
+    public abstract <T> Map<String,T> hgetAll(String key, Class<T> tClass);
+
+    /**
+     * Get all the fields in a hash
+     *
+     * @param key key
+     * @return all the fields set
+     */
+    public abstract Set<String> hkeys(String key);
+
+
+    /**
+     * Get a range of elements from a list
+     *
+     * @param key    key
+     * @param tClass generic class type
+     * @param start  start number, the first is 0
+     * @param stop   stop number, the last is -1
+     * @param <T>    generic class
+     * @return list of results
+     */
+    public abstract <T> List<T> lrange(String key, Class<T> tClass, long start, long stop);
+
+    /**
+     * Get all of elements from a list
+     *
+     * @param key    key
+     * @param tClass generic class type
+     * @param <T>    generic class
+     * @return list of results
+     */
+    public abstract <T> List<T> lrange(String key, Class<T> tClass);
+
+    /**
+     * Prepend one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    public abstract Long lpush(String key, Object... values);
+
+    /**
+     * Prepend one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    public abstract Long lpush(String key, List values);
+
+    /**
+     * Append one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    public abstract Long rpush(String key, Object... values);
+
+    /**
+     * Append one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    public abstract Long rpush(String key, List values);
+
+    /**
+     * get a lock for key
+     *
+     * @param key key
+     * @return result
+     */
+    public abstract Boolean getLock(String key);
+
+    /**
+     * release lock
+     *
+     * @param key key
+     */
+    public abstract void releaseLock(String key);
+
+    /**
+     * 缓存是否存在
+     *
+     * @param key 键
+     * @return
+     */
+    public abstract boolean exists(String key);
+
+    /**
+     * 缓存是否存在
+     *
+     * @param key   键
+     * @param field
+     * @return
+     */
+    public abstract boolean hexists(String key, String field);
+
+    /**
+     * 获取hash缓存的个数
+     *
+     * @param key   键
+     * @return
+     */
+    public abstract Long hlen(String key);
+
+    /**
+     * 计数器递减
+     *
+     * @param key
+     * @return
+     */
+    public abstract Long decr(String key);
+
+    /**
+     * 计数器递增
+     *
+     * @param key
+     * @return
+     */
+    public abstract Long incr(String key);
+
+	/**
+	 * map值加
+	 * @param key
+	 * @param field
+	 * @param value
+	 * @return
+	 */
+	public abstract  Long hincrBy(final String key, final String field, final long value);
+
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/SerializationFailedException.java

@@ -0,0 +1,17 @@
+package com.community.commom.redis;
+
+/**
+ * redis 序列化异常类
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ *
+ **/
+public class SerializationFailedException extends RuntimeException {
+    public SerializationFailedException(Throwable cause) {
+        super(cause);
+    }
+
+    public SerializationFailedException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/redis/SingleRedisTemplate.java

@@ -0,0 +1,585 @@
+package com.community.commom.redis;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import redis.clients.jedis.Jedis;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * 单机redis 操作工具
+ *
+ * @author gengxiang
+ * @create 2017-09-06 18:04
+ **/
+@Component
+public class SingleRedisTemplate extends RedisTemplate {
+    private Logger log = LoggerFactory.getLogger(RedisTemplate.class);
+
+    /**
+     * 从jedis连接池中获取获取jedis对象
+     */
+    public Jedis getJedis() {
+        return redisPool.getResource();
+    }
+
+    /**
+     * 回收jedis
+     */
+    public void returnJedis(Jedis jedis) {
+        if (jedis != null)
+            jedis.close();
+    }
+
+    @Override
+    public String set(String key, Object value) {
+        String result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.set(key.getBytes(defaultCharset), serializer.serialize(value));
+        } catch (Exception e) {
+            log.error("redis set error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public Long setnx(String key, Object value) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.setnx(key.getBytes(defaultCharset), serializer.serialize(value));
+        } catch (Exception e) {
+            log.error("redis setnx error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public Long expire(String key, int seconds) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.expire(key.getBytes(defaultCharset), seconds);
+        } catch (Exception e) {
+            log.error("redis expire error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public Long ttl(String key) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.ttl(key.getBytes(defaultCharset));
+        } catch (Exception e) {
+            log.error("redis ttl error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public String get(String key) {
+        return get(key, String.class);
+    }
+
+    @Override
+    public <T> T get(String key, Class<T> tClass) {
+        byte[] result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.get(key.getBytes(defaultCharset));
+        } catch (Exception e) {
+            log.error("redis set error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return serializer.deserialize(result, tClass);
+    }
+
+    @Override
+    public Long del(String key) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.del(key.getBytes(defaultCharset));
+        } catch (Exception e) {
+            log.error("redis del error, key:" + key);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public Long del(String... keys) {
+        Long result = 0L;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            for (String key : keys)
+                result += jedis.del(key.getBytes(defaultCharset));
+        } catch (Exception e) {
+            log.error("redis del error, key:" + Arrays.toString(keys));
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Get the value of a hash field
+     *
+     * @param key   key
+     * @param field hash field
+     * @param value value
+     * @return result
+     */
+    @Override
+    public Long hset(String key, String field, Object value) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hset(key.getBytes(defaultCharset), field.getBytes(defaultCharset), serializer.serialize(value));
+        } catch (Exception e) {
+            log.error("redis hset error, key:" + key + ", field:" + field, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public <T> String hmset(String key, Map<String, T> map) {
+        String result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            Map<byte[], byte[]> data = new HashMap<byte[], byte[]>();
+            for (Map.Entry<String, T> entry : map.entrySet())
+                data.put(entry.getKey().getBytes(defaultCharset), serializer.serialize(entry.getValue()));
+            result = jedis.hmset(key.getBytes(defaultCharset), data);
+        } catch (Exception e) {
+            log.error("redis hmset error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public <T> Map<String, T> hmget(String key, List<String> fields, Class<T> tClass) {
+        Map<String, T> result = new HashMap<>();
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            List<byte[]> byteList = new ArrayList<>(fields.size());
+            for (String field : fields) {
+                byte[] s = field.getBytes(defaultCharset);
+                byteList.add(s);
+            }
+            List<byte[]> strings = jedis.hmget(key.getBytes(defaultCharset), byteList.toArray(new byte[fields.size()][]));
+            for (int i = 0; i < fields.size(); i++) {
+                result.put(fields.get(i), serializer.deserialize(strings.get(i), tClass));
+            }
+        } catch (Exception e) {
+            log.error("redis hmset error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * del the value of a hash field
+     *
+     * @param key   key
+     * @param field hash field
+     * @return result
+     */
+    @Override
+    public Long hdel(String key, String field) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hdel(key.getBytes(defaultCharset), field.getBytes(defaultCharset));
+        } catch (Exception e) {
+            log.error("redis hset error, key:" + key + ", field:" + field, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Set the string value of a hash field
+     *
+     * @param key    key
+     * @param field  hash field
+     * @param tClass generics class type
+     * @param <T>    generics class
+     * @return value
+     */
+    @Override
+    public <T> T hget(String key, String field, Class<T> tClass) {
+        byte[] result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hget(key.getBytes(defaultCharset), field.getBytes(defaultCharset));
+        } catch (Exception e) {
+            log.error("redis hget error, key:" + key + ", field:" + field, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return serializer.deserialize(result, tClass);
+    }
+
+    @Override
+    public <T> Map<String, T> hgetAll(String key, Class<T> tClass) {
+        Map<String, T> result = new HashMap<String, T>();
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            Map<byte[], byte[]> map = jedis.hgetAll(key.getBytes(defaultCharset));
+            for (Map.Entry<byte[], byte[]> entry : map.entrySet()) {
+                result.put(new String(entry.getKey(), defaultCharset), serializer.deserialize(entry.getValue(), tClass));
+            }
+        } catch (Exception e) {
+            log.error("redis hGetAll error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Get all the fields in a hash
+     *
+     * @param key key
+     * @return all the fields set
+     */
+    @Override
+    public Set<String> hkeys(String key) {
+        Set<String> result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hkeys(key);
+        } catch (Exception e) {
+            log.error("redis hkeys error, key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Get a range of elements from a list
+     *
+     * @param key    key
+     * @param tClass generic class type
+     * @param start  start number, the first is 0
+     * @param stop   stop number, the last is -1
+     * @param <T>    generic class
+     * @return list of results
+     */
+    @Override
+    public <T> List<T> lrange(String key, Class<T> tClass, long start, long stop) {
+        List<T> result = new ArrayList<>();
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            List<byte[]> list = jedis.lrange(key.getBytes(defaultCharset), start, stop);
+            for (byte[] bytes : list) {
+                result.add(serializer.deserialize(bytes, tClass));
+            }
+        } catch (Exception e) {
+            log.error("redis lrange error key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Get all of elements from a list
+     *
+     * @param key    key
+     * @param tClass generic class type
+     * @param <T>    generic class
+     * @return list of results
+     */
+    @Override
+    public <T> List<T> lrange(String key, Class<T> tClass) {
+        return lrange(key, tClass, 0L, -1L);
+    }
+
+    /**
+     * Prepend one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    @Override
+    public Long lpush(String key, Object... values) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            List<byte[]> list = new ArrayList<>();
+            for (Object o : values) {
+                list.add(serializer.serialize(o));
+            }
+            result = jedis.lpush(key.getBytes(defaultCharset), list.toArray(new byte[list.size()][]));
+        } catch (Exception e) {
+            log.error("redis lpush error key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Prepend one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    @Override
+    public Long lpush(String key, List values) {
+        return lpush(key, values.toArray());
+    }
+
+    /**
+     * Append one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    @Override
+    public Long rpush(String key, Object... values) {
+        Long result = null;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            List<byte[]> list = new ArrayList<>();
+            for (Object o : values) {
+                list.add(serializer.serialize(o));
+            }
+            result = jedis.rpush(key.getBytes(defaultCharset), list.toArray(new byte[list.size()][]));
+        } catch (Exception e) {
+            log.error("redis rpush error key:" + key, e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * Append one or multiple values to a list
+     *
+     * @param key    key
+     * @param values values
+     * @return result
+     */
+    @Override
+    public Long rpush(String key, List values) {
+        return rpush(key, values.toArray());
+    }
+
+    /**
+     * redis setnx实现分布式锁
+     *
+     * @param key key
+     * @return true:获取到锁, false: 未获取到锁
+     */
+    @Override
+    public Boolean getLock(String key) {
+        Long result;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            for (int i = 0; i < maxLockTime / lockRetryTime + 1; i++) {
+                Long now = System.currentTimeMillis();
+                result = jedis.setnx(key, String.valueOf(now + maxLockTime));
+                if (result == 1L
+                        || now > Long.parseLong(jedis.get(key))
+                        && now > Long.parseLong(jedis.getSet(key, String.valueOf(now + maxLockTime)))) {
+                    jedis.expire(key, (int) (maxLockTime / 1000));
+                    return true;
+                } else Thread.sleep(lockRetryTime);
+            }
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return false;
+    }
+
+    /**
+     * redis  释放分布式锁
+     *
+     * @param key key
+     */
+    @Override
+    public void releaseLock(String key) {
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            jedis.del(key);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+    }
+
+    /**
+     * 缓存是否存在
+     *
+     * @param key 键
+     * @return
+     */
+    @Override
+    public boolean exists(String key) {
+        boolean result = false;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.exists(key);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+
+    /**
+     * 缓存是否存在
+     *
+     * @param key 键
+     * @return
+     */
+    @Override
+    public boolean hexists(String key, String field) {
+        boolean result = false;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hexists(key, field);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * 获取hash缓存的个数
+     *
+     * @param key 键
+     * @return
+     */
+    @Override
+    public Long hlen(String key) {
+        Long result = 0L;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hlen(key);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * 计数器递减
+     *
+     * @param key
+     * @return
+     */
+    @Override
+    public Long decr(String key) {
+        Long result = 0L;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.decr(key);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    /**
+     * 计数器递增
+     *
+     * @param key
+     * @return
+     */
+    @Override
+    public Long incr(String key) {
+        Long result = 0L;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.incr(key);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+
+    @Override
+    public Long hincrBy(String key, String field, long value) {
+        Long result = 0L;
+        Jedis jedis = null;
+        try {
+            jedis = getJedis();
+            result = jedis.hincrBy(key, field, value);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            returnJedis(jedis);
+        }
+        return result;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/BeanTools.java

@@ -0,0 +1,115 @@
+package com.community.commom.utils;
+
+import jodd.bean.BeanCopy;
+import jodd.typeconverter.TypeConverterManager;
+import org.apache.commons.collections.BeanMap;
+
+import java.lang.reflect.Method;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+
+@SuppressWarnings("deprecation")
+public final class BeanTools {
+
+    private static Map<String, Object> toBeanMethodMap = new HashMap<String, Object>();
+
+    /**
+     * <pre>
+     * 功能：实现BEAN的属性对拷
+     * 创建人：JokenWang
+     * </pre>
+     *
+     * @param fromBean        待转换的源bean
+     * @param toBeanClassName 转换成目标bean的名称 形如：ItemSeries.class.getName()
+     * @return 目标BEAN类
+     */
+    public static <T> T convertBean(Object fromBean, Class<T> toBeanClassName) {
+        T toBean = null;
+        try {
+            toBean = getBeanInstance(toBeanClassName.getName());
+            return convertBean(fromBean, toBean);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return toBean;
+    }
+
+    private static <T> T convertBean(Object fromBean, T toBean) {
+        TypeConverterManager.register(String.class, new StringConverter());
+        BeanCopy.beans(fromBean, toBean).copy();
+        return toBean;
+    }
+
+    public static Method getDeclaredMethod(Object object, String methodName, Class<?>... parameterTypes) {
+        Method method;
+        for (Class<?> clazz = object.getClass(); clazz != Object.class; clazz = clazz.getSuperclass()) {
+            try {
+                method = clazz.getDeclaredMethod(methodName, parameterTypes);
+                return method;
+            } catch (Exception ignored) {
+
+            }
+        }
+        return null;
+    }
+
+    @SuppressWarnings("unchecked")
+    public static <T> T getBeanInstance(String clazzName)
+            throws InstantiationException, IllegalAccessException, ClassNotFoundException {
+
+        return (T) Class.forName(clazzName).newInstance();
+    }
+
+    public static Map<String, Object> toBeanMethodMap(String toBean)
+            throws InstantiationException, IllegalAccessException, ClassNotFoundException {
+
+        Class<?> toBeanClazz = getBeanInstance(toBean).getClass();
+        Method[] toBeanMethods = toBeanClazz.getDeclaredMethods();
+        if (!toBeanClazz.isInstance(Object.class))// 非超类Object
+        {
+            for (Method method : toBeanMethods) {
+                String methodName = method.getName();
+                toBeanMethodMap.put(methodName, method);
+            }
+
+            Class<?> toBeanSuperclazz = toBeanClazz.getSuperclass();// 获取父类
+            toBeanMethodMap(toBeanSuperclazz.getName());
+        }
+
+        return toBeanMethodMap;
+    }
+
+    public static Map<String, Object> toMap(Object object) {
+        Map<String, Object> map = new HashMap<String, Object>();
+
+        if (object == null) {
+            return map;
+        }
+
+        BeanMap beanMap;
+        beanMap = new BeanMap(object);
+        @SuppressWarnings("unchecked")
+        Iterator<String> it = beanMap.keyIterator();
+        while (it.hasNext()) {
+            String name = it.next();
+            Object value = beanMap.get(name);
+            // 转换时会将类名也转换成属性，此处去掉
+            if (value != null && !name.equals("class")) {
+                map.put(name, value);
+            }
+        }
+
+        return map;
+    }
+
+    public static Map<String, Object> toMap(Object... objs) {
+        Map<String, Object> map = new HashMap<>();
+        for (Object object : objs) {
+            if (object != null) {
+                map.putAll(toMap(object));
+            }
+        }
+        return map;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/CommonUtils.java

@@ -0,0 +1,88 @@
+package com.community.commom.utils;
+
+import org.springframework.util.StringUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 类名称：com.yincheng.jcjy.huiju.common.utils
+ * 类描述：日常工具类
+ * 创建人：Geng Xiang
+ * 创建时间：2017/11/8 14:29
+ *
+ * @version 1.0.0
+ */
+public class CommonUtils {
+
+    public static Integer str2Int(String target) {
+        if (target != null && target.trim().length() > 0) {
+            return Integer.parseInt(target);
+        }
+        return null;
+    }
+
+    public static boolean patterMatch(String target, String patternStr) {
+        Pattern pattern = Pattern.compile(patternStr);          // ""
+        Matcher matcher = pattern.matcher(target);
+        return matcher.matches();
+    }
+
+
+    /**
+     * 正则匹配获取参数
+     * 目前只取一个
+     *
+     * @param target 目标String
+     * @param parn   匹配表达式
+     * @return List<String>
+     */
+    public static List<String> formatParam(String target, String prefix, String parn) {
+        List<String> result = new ArrayList<>();
+        Pattern p = Pattern.compile(parn);
+        Matcher m = p.matcher(target);
+        while (m.find()) {
+            if (StringUtils.hasText(prefix)){
+                result.add(m.group().substring(prefix.length()));
+            } else{
+                result.add(m.group());
+            }
+        }
+
+        if (result == null || result.size() == 0){
+            result.add("");
+        }
+        return result;
+    }
+
+    /**
+     * 正则匹配获取参数 删除已匹配数据
+     * 目前只取一个
+     *
+     * @param target 目标String
+     * @param parn   匹配表达式
+     * @return List<String>
+     */
+    public static List<String> formatParam(StringBuffer target, String prefix, String parn) {
+        List<String> result = new ArrayList<>();
+        String targetStr = target.toString();
+        Pattern p = Pattern.compile(parn);
+        Matcher m = p.matcher(targetStr);
+        while (m.find()) {
+            if (StringUtils.hasText(prefix)){
+                result.add(m.group().substring(prefix.length()));
+            } else{
+                result.add(m.group());
+            }
+            //删除已匹配的参数
+            target.delete(target.indexOf(m.group()), target.indexOf(m.group())+m.group().length());
+        }
+
+        if (result == null || result.size() == 0){
+            result.add("");
+        }
+        return result;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/CookieUtil.java

@@ -0,0 +1,142 @@
+package com.community.commom.utils;
+
+
+import org.springframework.util.StringUtils;
+
+import javax.servlet.http.Cookie;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * describe: cookie 历史记录
+ * creat_user: gengxiang
+ * creat_time: 2017/12/25 9:05
+ * version V1.0
+ **/
+public class CookieUtil {
+
+    /**
+     * 获取所有的历史记录
+     *
+     * @param cookies 所有的cookie
+     * @param type    获取的cookie类型
+     * @return java.util.List<java.lang.String>
+     * @author gengxiang
+     * @date 2017/12/25 9:19
+     */
+    public static List<String> getAll(Cookie[] cookies, String type) {
+        List<String> result = new ArrayList<>();
+        Map<String, Cookie> cookieMap = toCookieMap(cookies);
+        Cookie cookie = cookieMap.get(type);
+        if (cookie != null) {
+            String value = cookie.getValue();
+            if (StringUtils.hasText(value)){
+                String[] values = value.split("#");
+                for (int i = 0; i < values.length; i++) {
+                    result.add(values[i]);
+                }
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 设置cookie
+     * @author gengxiang
+     * @date 2017/12/25 10:08
+     * @param cookies cookie array
+     * @param type  cookie name
+     * @param value cookie value
+     * @return javax.servlet.http.Cookie
+     */
+    public static Cookie setCookie(Cookie[] cookies, String type, String value) {
+
+        Map<String, Cookie> cookieMap = toCookieMap(cookies);
+        Cookie cookie = cookieMap.get(type);
+        if (cookie != null && StringUtils.hasText(cookie.getValue())
+                && !(cookie.getValue().startsWith(value) || cookie.getValue().contains("#"+value))){
+            //cookie值中“#”出现的次数
+            int times = appearTimes(cookie.getValue(), "#");
+            //10个值有9个“#”，小于9直接保存到cookie
+            if(times < 9){
+                cookie.setValue(value+"#"+cookie.getValue());
+                cookie.setMaxAge(60*60*24*30);
+                cookie.setPath("/");
+            }else {
+                String oldValue = cookie.getValue();
+                //截取最新的9个值
+                String newValue = oldValue.substring(0, oldValue.lastIndexOf("#"));
+                cookie.setValue(value + "#" + newValue);
+                cookie.setMaxAge(60*60*24*30);
+                cookie.setPath("/");
+            }
+        }else if (cookie == null || !StringUtils.hasText(cookie.getValue())){
+            cookie = new Cookie(type, value);
+            cookie.setMaxAge(60*60*24*30);
+            cookie.setPath("/");
+            cookie.setHttpOnly(true);
+        }
+        return cookie;
+    }
+
+    /**
+     * 删除 cookie
+     * @author gengxiang
+     * @date 2017/12/25 10:17
+     * @param cookies cookie array
+     * @param type  cookie name
+     * @return javax.servlet.http.Cookie
+     */
+    public static Cookie delCookie(Cookie[] cookies, String type){
+        Map<String, Cookie> cookieMap = toCookieMap(cookies);
+        Cookie cookie = cookieMap.get(type);
+        if (cookie != null){
+            cookie.setValue(null);
+            cookie.setMaxAge(0);
+            cookie.setPath("/");
+        }
+        return cookie;
+    }
+
+
+    /**
+     * cookie array to map
+     * @author gengxiang
+     * @date 2017/12/25 10:10
+     * @param cookies
+     * @return java.util.Map<java.lang.String,javax.servlet.http.Cookie>
+     */
+    public static Map<String, Cookie> toCookieMap(Cookie[] cookies) {
+        Map<String, Cookie> result = new HashMap<>();
+        if (cookies != null && cookies.length > 0) {
+            for (Cookie cookie : cookies) {
+                result.put(cookie.getName(), cookie);
+            }
+        }
+        return result;
+    }
+
+
+    /**
+     * 获取指定字符串出现的次数
+     *   
+     * @author xrq  
+     * @date 2017/12/25 15:16
+     * @param srcText 源字符串
+     * @param findText 要查找的字符串
+     * @return int  
+     */ 
+    public static int appearTimes(String srcText, String findText) {
+        int count = 0;
+        Pattern p = Pattern.compile(findText);
+        Matcher m = p.matcher(srcText);
+        while (m.find()) {
+            count++;
+        }
+        return count;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/DESUtils.java

@@ -0,0 +1,139 @@
+package com.community.commom.utils;
+
+import sun.misc.BASE64Decoder;
+import sun.misc.BASE64Encoder;
+
+import javax.crypto.Cipher;
+import javax.crypto.SecretKeyFactory;
+import javax.crypto.spec.DESKeySpec;
+import javax.crypto.spec.IvParameterSpec;
+import java.security.Key;
+import java.security.SecureRandom;
+
+/**
+ * des 加解密共通方法
+ * Created by wuxuewen on 2016/10/20.
+ */
+public class DESUtils {
+
+    Key key;
+
+    String ivParameterSpec = null;
+
+    public DESUtils(String str, String ivParameterSpec) {
+        setKey(str);// 生成密匙
+        this.ivParameterSpec = ivParameterSpec;
+    }
+
+    public DESUtils() {
+        setKey("Lnydzxkf");
+    }
+
+    /**
+     * 根据参数生成KEY
+     */
+    public void setKey(String strKey) {
+        try {
+            SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("DES");
+            this.key = keyFactory.generateSecret(new DESKeySpec(strKey.getBytes("UTF8")));
+        } catch (Exception e) {
+            throw new RuntimeException(
+                    "Error initializing SqlMap class. Cause: " + e);
+        }
+    }
+
+
+    /**
+     * 加密String明文输入,String密文输出
+     *
+     * @param strMing strMing
+     * @return result
+     */
+    public String encrypt(String strMing) {
+        byte[] byteMi;
+        byte[] byteMing;
+        String strMi = "";
+        BASE64Encoder base64en = new BASE64Encoder();
+        try {
+            byteMing = strMing.getBytes("UTF8");
+            byteMi = this.getEncCode(byteMing);
+            strMi = base64en.encode(byteMi);
+        } catch (Exception e) {
+            throw new RuntimeException(
+                    "Error initializing SqlMap class. Cause: " + e);
+        }
+        return strMi;
+    }
+
+    /**
+     * 解密 以String密文输入,String明文输出
+     *
+     * @param strMi strMi
+     * @return result
+     */
+    public String decrypt(String strMi) {
+        BASE64Decoder base64De = new BASE64Decoder();
+        byte[] byteMing;
+        byte[] byteMi;
+        String strMing;
+        try {
+            byteMi = base64De.decodeBuffer(strMi);
+            byteMing = this.getDesCode(byteMi);
+            strMing = new String(byteMing, "UTF8");
+        } catch (Exception e) {
+            throw new RuntimeException(
+                    "Error initializing SqlMap class. Cause: " + e);
+        }
+        return strMing;
+    }
+
+    /**
+     * 加密以byte[]明文输入,byte[]密文输出
+     *
+     * @param byteS byteS
+     * @return result
+     */
+    private byte[] getEncCode(byte[] byteS) {
+        byte[] byteFina;
+        Cipher cipher;
+        try {
+            cipher = Cipher.getInstance("DES/CBC/PKCS5Padding");
+            if (ivParameterSpec != null) {
+                IvParameterSpec iv = new IvParameterSpec(ivParameterSpec.getBytes("UTF8"));
+                cipher.init(Cipher.ENCRYPT_MODE, key, iv);
+            } else {
+                cipher.init(Cipher.DECRYPT_MODE, key, SecureRandom.getInstance("SHA1PRNG"));
+            }
+            byteFina = cipher.doFinal(byteS);
+        } catch (Exception e) {
+            throw new RuntimeException(
+                    "Error initializing SqlMap class. Cause: " + e);
+        }
+        return byteFina;
+    }
+
+    /**
+     * 解密以byte[]密文输入,以byte[]明文输出
+     *
+     * @param byteD byteD
+     * @return result
+     */
+    private byte[] getDesCode(byte[] byteD) {
+        Cipher cipher;
+        byte[] byteFina;
+        try {
+            cipher = Cipher.getInstance("DES/CBC/PKCS5Padding");
+            if (ivParameterSpec != null) {
+                IvParameterSpec iv = new IvParameterSpec(ivParameterSpec.getBytes("UTF8"));
+                cipher.init(Cipher.DECRYPT_MODE, key, iv);
+            } else {
+                cipher.init(Cipher.DECRYPT_MODE, key, SecureRandom.getInstance("SHA1PRNG"));
+            }
+            byteFina = cipher.doFinal(byteD);
+        } catch (Exception e) {
+            throw new RuntimeException(
+                    "Error initializing SqlMap class. Cause: " + e);
+        }
+        return byteFina;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/DateUtils.java

@@ -0,0 +1,277 @@
+package com.community.commom.utils;
+
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+
+/**
+ * 日期工具类, 继承org.apache.commons.lang.time.DateUtils类
+ */
+public class DateUtils {
+
+    /**
+     * 得到当前日期字符串 格式（yyyy-MM-dd）
+     */
+    public static String getDate() {
+        return getDate("yyyy-MM-dd");
+    }
+
+    /**
+     * 得到当前日期字符串 格式（yyyy-MM-dd） pattern可以为："yyyy-MM-dd" "HH:mm:ss" "E"
+     */
+    public static String getDate(String pattern) {
+        DateFormat sdf = new SimpleDateFormat(pattern);
+        return sdf.format(new Date());
+    }
+
+    /**
+     * 得到日期字符串 默认格式（yyyy-MM-dd） pattern可以为："yyyy-MM-dd" "HH:mm:ss" "E"
+     */
+    public static String formatDate(Date date, Object... pattern) {
+        DateFormat sdf;
+        if (pattern != null && pattern.length > 0) {
+            sdf = new SimpleDateFormat(pattern[0].toString());
+        } else {
+            sdf = new SimpleDateFormat("yyyy-MM-dd");
+        }
+        return sdf.format(date);
+    }
+
+    /**
+     * 得到日期时间字符串，转换格式（yyyy-MM-dd HH:mm:ss）
+     */
+    public static String formatDateTime(Date date) {
+        return formatDate(date, "yyyy-MM-dd HH:mm:ss");
+    }
+
+    /**
+     * 得到当前时间字符串 格式（HH:mm:ss）
+     */
+    public static String getTime() {
+        return formatDate(new Date(), "HH:mm:ss");
+    }
+
+    /**
+     * 得到当前日期和时间字符串 格式（yyyy-MM-dd HH:mm:ss）
+     */
+    public static String getDateTime() {
+        return formatDate(new Date(), "yyyy-MM-dd HH:mm:ss");
+    }
+
+    /**
+     * 得到当前年份字符串 格式（yyyy）
+     */
+    public static String getYear() {
+        return formatDate(new Date(), "yyyy");
+    }
+
+    /**
+     * 得到当前月份字符串 格式（MM）
+     */
+    public static String getMonth() {
+        return formatDate(new Date(), "MM");
+    }
+
+    /**
+     * 得到当天字符串 格式（dd）
+     */
+    public static String getDay() {
+        return formatDate(new Date(), "dd");
+    }
+
+    /**
+     * 得到当前星期字符串 格式（E）星期几
+     */
+    public static String getWeek() {
+        return formatDate(new Date(), "E");
+    }
+
+    /**
+     * 日期型字符串转化为日期 格式
+     * { "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm",
+     * "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm",
+     * "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm" }
+     */
+    public static Date parseDate(String str, String pattern) {
+        if (str == null) {
+            return null;
+        }
+        try {
+            DateFormat sdf = new SimpleDateFormat(pattern);
+            return sdf.parse(str);
+        } catch (ParseException e) {
+            return null;
+        }
+    }
+
+    /**
+     * 获取过去的天数
+     *
+     * @param date
+     * @return
+     */
+    public static long pastDays(Date date) {
+        long t = new Date().getTime() - date.getTime();
+        return t / (24 * 60 * 60 * 1000);
+    }
+
+    /**
+     * 获取过去的小时
+     *
+     * @param date
+     * @return
+     */
+    public static long pastHour(Date date) {
+        long t = new Date().getTime() - date.getTime();
+        return t / (60 * 60 * 1000);
+    }
+
+    /**
+     * 获取过去的分钟
+     *
+     * @param date
+     * @return
+     */
+    public static long pastMinutes(Date date) {
+        long t = new Date().getTime() - date.getTime();
+        return t / (60 * 1000);
+    }
+
+    /**
+     * 转换为时间（天,时:分:秒.毫秒）
+     *
+     * @param timeMillis
+     * @return
+     */
+    public static String formatDateTime(long timeMillis) {
+        long day = timeMillis / (24 * 60 * 60 * 1000);
+        long hour = (timeMillis / (60 * 60 * 1000) - day * 24);
+        long min = ((timeMillis / (60 * 1000)) - day * 24 * 60 - hour * 60);
+        long s = (timeMillis / 1000 - day * 24 * 60 * 60 - hour * 60 * 60 - min * 60);
+        long sss = (timeMillis - day * 24 * 60 * 60 * 1000 - hour * 60 * 60 * 1000 - min * 60 * 1000 - s * 1000);
+        return (day > 0 ? day + "," : "") + hour + ":" + min + ":" + s + "." + sss;
+    }
+
+    /**
+     * 获取两个日期之间的天数
+     *
+     * @param before
+     * @param after
+     * @return
+     */
+    public static double getDistanceOfTwoDate(Date before, Date after) {
+        long beforeTime = before.getTime();
+        long afterTime = after.getTime();
+        return (afterTime - beforeTime) / (1000 * 60 * 60 * 24);
+    }
+
+
+    /**
+     * 获取当前月份的第一天
+     *
+     * @return result
+     */
+    public static Date getMonthFirstDay() {
+        Calendar cal = Calendar.getInstance();
+        cal.add(Calendar.MONTH, 0);
+        cal.set(Calendar.DAY_OF_MONTH, 1);
+        return cal.getTime();
+    }
+
+    /**
+     * 获取当前月份的最后一天
+     *
+     * @return result
+     */
+    public static Date getMonthLastDay() {
+        Calendar cal = Calendar.getInstance();
+        cal.add(Calendar.MONTH, 1);
+        cal.set(Calendar.DAY_OF_MONTH, 0);
+        return cal.getTime();
+    }
+
+    /**
+     * 取出两个日期的差
+     *
+     * @param startDate 开始时间
+     * @param endDate   结束时间
+     * @return 天数差
+     */
+    public static int dayDif(Date startDate, Date endDate) {
+        double between = (endDate.getTime() - startDate.getTime()) / 1000;//除以1000是为了转换成秒
+        double day = between / (24 * 3600);
+        return (int) day;
+    }
+
+    /**
+     * 获取当前时间N个小时
+     *
+     * @param n 天数
+     * @return Date
+     */
+    public static Date getCurrentDatePreH(int n) {
+        Calendar now = Calendar.getInstance();
+        now.set(Calendar.HOUR_OF_DAY, now.get(Calendar.HOUR_OF_DAY) - n);
+        now.set(Calendar.MINUTE, 0);
+        now.set(Calendar.SECOND, 0);
+        return now.getTime();
+    }
+
+    /**
+     * 获取当前时间N个小时
+     *
+     * @param n 天数
+     * @return Date
+     */
+    public static Date getCurrentDatePreEndH(int n) {
+        Calendar now = Calendar.getInstance();
+        now.set(Calendar.HOUR_OF_DAY, now.get(Calendar.HOUR_OF_DAY) - n);
+        now.set(Calendar.MINUTE, 59);
+        now.set(Calendar.SECOND, 59);
+        return now.getTime();
+    }
+
+    /**
+     * 获取时间的N的前后时间
+     * @param date
+     * @param n 为正数获取后N天， n为负数获取时间的前N天
+     * @return
+     */
+    public static Date getDateLasyDay(Date date,Integer n){
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, n);
+        return new Date(calendar.getTimeInMillis());
+    }
+
+    /**
+     * 计算每天分配数量
+     * @param startDate  　startDate
+     * @param endDate    endDate
+     * @param totalNum   totalNum
+     * @param receiveNum receiveNum
+     * @param nextScroll nextScroll
+     * @return presentNum
+     */
+    public static int getDayAssignedNum(Date startDate, Date endDate, int totalNum, int receiveNum, boolean nextScroll) {
+        int presentNum;
+        int dayDif = DateUtils.dayDif(new Date(), endDate);
+        //是否为最后一天
+        if (dayDif == 0) {
+            presentNum = totalNum - receiveNum;
+        } else {
+            dayDif = DateUtils.dayDif(startDate, endDate) + 1;
+            presentNum = totalNum / dayDif;
+            if (nextScroll) {
+                dayDif = DateUtils.dayDif(startDate, new Date());
+                if (dayDif > 0) {
+                    presentNum += dayDif * presentNum - receiveNum;
+                }
+            }
+        }
+        return presentNum;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/EnumUtils.java

@@ -0,0 +1,120 @@
+package com.community.commom.utils;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 权举类型转换utils
+ * Created by wuxuewen on 2017/3/14.
+ */
+public class EnumUtils {
+
+    /**
+     * 把enum封成list，便于前端调用
+     *
+     * @return 例如：
+     * model.addAttribute("cateList", Enums.toList(Enums.BrandCate.class));
+     * <select cname="type" >
+     * <c:forEach var="type" items="${cateList}">
+     * <option value="${type.key}">${type.cname}</option>
+     * </c:forEach>
+     * </select>
+     */
+    public static <T extends Enum> List<T> toList(Class<T> clazz) {
+        return Arrays.asList(clazz.getEnumConstants());
+    }
+
+    /**
+     * 转为MAP
+     *
+     * @param clazz         Enums.class
+     * @param keyMethodName MethodName
+     * @param <T>           Enums
+     * @return Map<Object,Object>
+     */
+    public static <T extends Enum> Map<Object, T> toMap(Class<T> clazz, String keyMethodName) {
+        T[] universe = getEnumConstantsShared(clazz);
+        if (universe == null) {
+            return null;
+        }
+        Map<Object, T> directory = new HashMap<>();
+        for (T constant : universe)
+            try {
+                Object key;
+                if (keyMethodName != null && keyMethodName.trim().length() > 0) {
+                    Method method = constant.getClass().getMethod(keyMethodName);
+                    key = method.invoke(constant);
+                } else {
+                    key = constant.name();
+                }
+                directory.put(key, constant);
+            } catch (NoSuchMethodException | InvocationTargetException | IllegalAccessException e) {
+                e.printStackTrace();
+            }
+        return directory;
+    }
+
+    /**
+     * 转为MAP
+     *
+     * @param clazz         Enums.class
+     * @param keyMethodName MethodName
+     * @param valMethodName MethodName
+     * @param <T>           Enums
+     * @return Map<String,Object>
+     */
+    public static <T extends Enum> Map<String, Object> toMap(Class<T> clazz, String keyMethodName, String valMethodName) {
+        T[] universe = getEnumConstantsShared(clazz);
+        if (universe == null) {
+            return null;
+        }
+        Map<String, Object> directory = new HashMap<>(2 * universe.length);
+        for (T constant : universe)
+            try {
+                Object key, value;
+                if (keyMethodName != null && keyMethodName.trim().length() > 0) {
+                    Method method = constant.getClass().getMethod(keyMethodName);
+                    key = method.invoke(constant);
+                } else {
+                    key = constant.name();
+                }
+                if (valMethodName != null && valMethodName.trim().length() > 0) {
+                    Method method = constant.getClass().getMethod(valMethodName);
+                    value = method.invoke(constant);
+                } else {
+                    value = constant;
+                }
+                directory.put(key.toString(), value);
+            } catch (NoSuchMethodException | InvocationTargetException | IllegalAccessException e) {
+                e.printStackTrace();
+            }
+        return directory;
+    }
+
+
+    /**
+     * 获取权举对象列表
+     *
+     * @param clazz Enum.class
+     * @param <T>   Enum
+     * @return Enums
+     */
+    private static <T extends Enum> T[] getEnumConstantsShared(Class<T> clazz) {
+        T[] enumConstants;
+        if (!clazz.isEnum()) return null;
+        try {
+            final Method values = clazz.getMethod("values");
+            @SuppressWarnings("unchecked")
+            T[] temporaryConstants = (T[]) values.invoke(null);
+            enumConstants = temporaryConstants;
+        } catch (InvocationTargetException | NoSuchMethodException |
+                IllegalAccessException ex) {
+            return null;
+        }
+        return enumConstants;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/HttpClientUtils.java

@@ -0,0 +1,148 @@
+package com.community.commom.utils;
+
+import org.apache.commons.httpclient.methods.GetMethod;
+import org.apache.commons.httpclient.methods.PostMethod;
+import org.apache.commons.httpclient.methods.RequestEntity;
+import org.apache.commons.httpclient.methods.StringRequestEntity;
+import org.apache.commons.httpclient.params.HttpMethodParams;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.StringUtils;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ *　外部接口调用处理(HTTP方式)
+ * Created by wuxuewen on 2016/11/8.
+ */
+public class HttpClientUtils {
+
+    public static final Logger log = LoggerFactory.getLogger(HttpClientUtils.class);
+
+    public static final String HTTP_STATUS = "200";
+
+    /**
+     * 外部HTTP接口调用处理
+     *
+     * @param url               接口地址
+     * @param message           发送消息信息
+     * @param readTimeout       发送超时时间
+     * @param connectionTimeout 连接超时时间
+     * @return 接口返回
+     */
+    public static String sendMessage(final String url, final String message, final int readTimeout, final int connectionTimeout) {
+        org.apache.commons.httpclient.HttpClient client = new org.apache.commons.httpclient.HttpClient();
+        client.getHttpConnectionManager().getParams().setConnectionTimeout(connectionTimeout);
+        client.getHttpConnectionManager().getParams().setSoTimeout(readTimeout);
+        PostMethod httpPost = new PostMethod(url);
+        httpPost.setRequestHeader("Response-Type", "xml");
+        httpPost.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
+        RequestEntity requestXml = null;
+        try {
+            requestXml = new StringRequestEntity(message, "text/xml", "UTF-8");
+        } catch (UnsupportedEncodingException e1) {
+            e1.printStackTrace();
+        }
+        try {
+            httpPost.setRequestEntity(requestXml);
+            int statusCode = client.executeMethod(httpPost);
+            if (statusCode == 200) {
+                return httpPost.getResponseBodyAsString();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            httpPost.releaseConnection();
+            client.getHttpConnectionManager().closeIdleConnections(0);
+        }
+        return null;
+    }
+
+    /**
+     * HTTP GET请求调用
+     *
+     * @param url               请求地址
+     * @param readTimeout       请求超时
+     * @param connectionTimeout 连接超时
+     * @return 请求返回
+     */
+    public static String httpGet(final String url, final int readTimeout, final int connectionTimeout) {
+        String responseBody = null;
+        org.apache.commons.httpclient.HttpClient client = new org.apache.commons.httpclient.HttpClient();
+        client.getHttpConnectionManager().getParams().setConnectionTimeout(connectionTimeout);
+        client.getHttpConnectionManager().getParams().setSoTimeout(readTimeout);
+        GetMethod httpPost = new GetMethod(url);
+        try {
+            httpPost.setRequestHeader("Connection", "close");
+            client.executeMethod(httpPost);
+            InputStream in = httpPost.getResponseBodyAsStream();
+            if (in != null) {
+                BufferedReader buffer = new BufferedReader(new InputStreamReader(in, "UTF-8"));
+                StringBuffer sbf;
+                sbf = new StringBuffer();
+                String line;
+                while ((line = buffer.readLine()) != null) {
+                    sbf.append(line);
+                }
+                buffer.close();
+                responseBody = sbf.toString();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            httpPost.releaseConnection();
+            client.getHttpConnectionManager().closeIdleConnections(0);
+        }
+        return responseBody;
+    }
+
+
+    /**
+     * 共用HTTPPOST请求处理
+     *
+     * @param url    请求地址
+     * @param params 请求的参数信息
+     * @return 返回
+     * @throws Exception
+     */
+    public static Map<String, String> httpPost(String url, Map<String, Object> params) throws Exception {
+        org.apache.commons.httpclient.HttpClient client = new org.apache.commons.httpclient.HttpClient();
+        client.getHttpConnectionManager().getParams().setConnectionTimeout(2000);
+        client.getHttpConnectionManager().getParams().setSoTimeout(3000);
+        PostMethod httpPost = new PostMethod(url);
+        Map<String, String> returnMap = new HashMap<String, String>();
+        try {
+            httpPost.setRequestHeader("Connection", "close");
+            if (params != null) {
+                for (Object o : params.entrySet()) {
+                    Map.Entry entry = (Map.Entry) o;
+                    Object key = entry.getKey();
+                    String value = (String) entry.getValue();
+                    if (StringUtils.hasText(value))
+                        httpPost.addParameter(key.toString(), value);
+                }
+            }
+            httpPost.getParams().setContentCharset("UTF-8");
+            httpPost.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");
+            int statusCode = client.executeMethod(httpPost);
+            log.info("Request for method " + Thread.currentThread().getStackTrace()[3].getMethodName() +
+                    " statusCode=" + statusCode);
+            returnMap.put("statusCode", String.valueOf(statusCode));
+            String responseString = httpPost.getResponseBodyAsString();
+            log.info("Response responseString " + responseString);
+            returnMap.put("responseString", responseString);
+        } catch (Exception e) {
+            log.error("request url " + url + " Error:{}", e);
+            returnMap.put("statusCode", "-1");
+        } finally {
+            httpPost.releaseConnection();
+            client.getHttpConnectionManager().closeIdleConnections(0);
+        }
+        return returnMap;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/MD5Utils.java

@@ -0,0 +1,51 @@
+package com.community.commom.utils;
+
+import java.io.UnsupportedEncodingException;
+import java.security.MessageDigest;
+
+/**
+ * 用户密码加密
+ * Created by Administrator on 2015/8/9.
+ */
+public class MD5Utils {
+    /**
+     * MD5加密
+     *
+     * @param s 字符串
+     * @return MD5加密 字符串
+     */
+    public static String encode(String s) {
+        try {
+            return encode(s.getBytes("utf-8"));
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    private static String encode(byte[] b) {
+        char hexDigits[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
+                'a', 'b', 'c', 'd', 'e', 'f'};
+        try {
+            byte[] strTemp;
+            strTemp = b;
+            MessageDigest mdTemp = MessageDigest.getInstance("MD5");
+            mdTemp.update(strTemp);
+            byte[] md = mdTemp.digest();
+            int j = md.length;
+            char str[] = new char[j * 2];
+            int k = 0;
+            for (byte byte0 : md) {
+                str[k++] = hexDigits[byte0 >>> 4 & 0xf];
+                str[k++] = hexDigits[byte0 & 0xf];
+            }
+            return new String(str);
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
+    public static void main(String[] arge) throws Exception {
+       System.out.println(MD5Utils.encode("123456"));
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/QRCodeGeneratorUtils.java

@@ -0,0 +1,113 @@
+package com.community.commom.utils;
+
+import com.google.zxing.BarcodeFormat;
+import com.google.zxing.EncodeHintType;
+import com.google.zxing.MultiFormatWriter;
+import com.google.zxing.WriterException;
+import com.google.zxing.client.j2se.MatrixToImageWriter;
+import com.google.zxing.common.BitMatrix;
+import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
+
+import javax.imageio.ImageIO;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 二维码生成工具类
+ * Created by wuxuewen on 2017/4/17.
+ */
+public class QRCodeGeneratorUtils {
+    public static final int width = 300;
+
+    public static final int height = 300;
+
+    /**
+     * qr code generate
+     *
+     * @param url     url
+     * @param logoImg byte array of logo image
+     * @return byte array of qr code image
+     */
+    public static byte[] qrCode(String url, byte[] logoImg) {
+        try {
+            BufferedImage image = generate(url, logoImg);
+
+            ByteArrayOutputStream out = new ByteArrayOutputStream();
+            ImageIO.write(image, "png", out);
+
+            return out.toByteArray();
+        } catch (Exception e) {
+            throw new RuntimeException("Error: generate qr code.", e);
+        }
+    }
+
+    /**
+     * @param url    　　　链接地址
+     * @param logImg 　二维码图标img
+     * @return result
+     * @throws WriterException
+     * @throws IOException
+     */
+    public static BufferedImage generate(String url, byte[] logImg) throws WriterException, IOException {
+        if (logImg != null && logImg.length > 0) {
+            ByteArrayInputStream in = new ByteArrayInputStream(logImg);
+            BufferedImage logo = ImageIO.read(in);
+            return generateImg(url, logo);
+        } else {
+            return generateImg(url, null);
+        }
+    }
+
+    /**
+     * @param url    链接地址
+     * @param logImg 二维码图标img
+     * @return result
+     * @throws WriterException
+     */
+    public static BufferedImage generateImg(String url, BufferedImage logImg) throws WriterException {
+        BitMatrix bitMatrix;
+        Map<EncodeHintType, Object> hints = new HashMap<>();
+
+        if (logImg != null) {
+            hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.H);
+            bitMatrix = new MultiFormatWriter().encode(url,
+                    BarcodeFormat.QR_CODE, width, height, hints);
+            int logoSize = (int) (width / (4.0 + 20 / (url.length() + 10))); // into 4~6
+            int start = (width - logoSize) / 2;
+            bitMatrix.setRegion(start, start, logoSize, logoSize);// logo region
+            BufferedImage qrCode = MatrixToImageWriter.toBufferedImage(bitMatrix);
+
+            //combine qr code and logo
+            BufferedImage combine = new BufferedImage(width, height, BufferedImage.TYPE_INT_ARGB);
+            Graphics g = combine.getGraphics();
+            g.drawImage(qrCode, 0, 0, null);
+            g.drawImage(resizeImg(logImg, logoSize, logoSize), start, start, null);
+            return combine;
+        } else {
+            hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.L);
+            bitMatrix = new MultiFormatWriter().encode(url,
+                    BarcodeFormat.QR_CODE, width, height, hints);
+            return MatrixToImageWriter.toBufferedImage(bitMatrix);
+        }
+    }
+
+    /**
+     * resize image
+     *
+     * @param logoImg image BufferedImage
+     * @param width   resize width
+     * @param height  resize height
+     * @return resized image
+     */
+    public static BufferedImage resizeImg(BufferedImage logoImg, int width, int height) {
+        BufferedImage tag = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
+        tag.getGraphics().drawImage(logoImg.getScaledInstance(width, height, Image.SCALE_AREA_AVERAGING),
+                0, 0, null);
+        return tag;
+    }
+}

SmartCommunity/SmartCommunityV1/community-common/src/main/java/com/community/commom/utils/StringConverter.java

@@ -0,0 +1,72 @@
+package com.community.commom.utils;
+
+import jodd.typeconverter.TypeConversionException;
+import jodd.typeconverter.TypeConverter;
+import jodd.util.ArraysUtil;
+
+import java.sql.Clob;
+import java.sql.SQLException;
+import java.util.Date;
+
+public class StringConverter implements TypeConverter<String> {
+
+    public String convert(Object value) {
+        if (value == null) {
+            return null;
+        }
+
+        if (value instanceof CharSequence) { // for speed
+            return value.toString();
+        }
+        Class<?> type = value.getClass();
+        if (type == Class.class) {
+            return ((Class<?>) value).getName();
+        }
+        if (type.isArray()) {
+            if (type == char[].class) {
+                char[] charArray = (char[]) value;
+                return new String(charArray);
+            }
+            if (type == int[].class) {
+                return ArraysUtil.toString((int[]) value);
+            }
+            if (type == long[].class) {
+                return ArraysUtil.toString((long[]) value);
+            }
+            if (type == byte[].class) {
+                return ArraysUtil.toString((byte[]) value);
+            }
+            if (type == float[].class) {
+                return ArraysUtil.toString((float[]) value);
+            }
+            if (type == double[].class) {
+                return ArraysUtil.toString((double[]) value);
+            }
+            if (type == short[].class) {
+                return ArraysUtil.toString((short[]) value);
+            }
+            if (type == boolean[].class) {
+                return ArraysUtil.toString((boolean[]) value);
+            }
+            return ArraysUtil.toString((Object[]) value);
+        }
+        if (value instanceof Clob) {
+            Clob clob = (Clob) value;
+            try {
+                long length = clob.length();
+                if (length > Integer.MAX_VALUE) {
+                    throw new TypeConversionException("Clob is too big.");
+                }
+                return clob.getSubString(1, (int) length);
+            } catch (SQLException sex) {
+                throw new TypeConversionException(value, sex);
+            }
+        }
+        if (value instanceof Date) {
+            java.text.DateFormat format1 = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            return format1.format(value);
+        }
+
+        return value.toString();
+    }
+}

SmartCommunity/SmartCommunityV1/eureka-client1/pom.xml

@@ -45,6 +45,12 @@
 			<artifactId>spring-cloud-starter-openfeign</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>com.example</groupId>
+			<artifactId>community-common</artifactId>
+			<version>0.0.1</version>
+			<scope>compile</scope>
+		</dependency>
 
 		<dependency>
 			<groupId>io.springfox</groupId>
@@ -64,11 +70,6 @@
 			<version>1.3.2</version>
 		</dependency>
 
-		<!--<dependency>-->
-			<!--<groupId>mysql</groupId>-->
-			<!--<artifactId>mysql-connector-java</artifactId>-->
-			<!--<scope>runtime</scope>-->
-		<!--</dependency>-->
 
 		<dependency>
 			<groupId>mysql</groupId>

SmartCommunity/SmartCommunityV1/eureka-client1/src/main/java/com/example/demo/controller/TestController.java

@@ -1,5 +1,6 @@
 package com.example.demo.controller;
 
+import com.community.commom.redis.RedisTemplate;
 import com.example.demo.microController.MicroTestController;
 import com.example.demo.model.ScUser;
 import com.example.demo.service.ScUserServiceI;
@@ -36,10 +37,14 @@ public class TestController {
     @Autowired
     private MicroTestController microTestController;
     
+    @Autowired
+    private RedisTemplate redisTemplate;
+    
     @ApiOperation(value = "测试无参", notes = "无参")
     @RequestMapping(value = "/hello",method = RequestMethod.GET)
     @ResponseBody
     public String index(){
+        redisTemplate.set("1","1");
         return abc;
     }
     

SmartCommunity/SmartCommunityV1/pom.xml

@@ -15,7 +15,8 @@
 		<module>eureka-sever</module>
 		<module>zuul</module>
 		<module>user-server</module>
-	</modules>
+        <module>community-common</module>
+    </modules>
 
 	<name>spring-cloud</name>
 	<description>spring-cloud project for Spring Boot</description>

SmartCommunity/SmartCommunityV1/user-server/pom.xml

@@ -12,10 +12,10 @@
     <description>用户工程</description>
 
     <parent>
-        <groupId>com.example</groupId>
-        <artifactId>spring-cloud</artifactId>
-        <version>0.0.1</version>
-    </parent>
+    <groupId>com.example</groupId>
+    <artifactId>spring-cloud</artifactId>
+    <version>0.0.1</version>
+</parent>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>