Merge remote-tracking branch 'origin/master'

# Conflicts:
#	gyee-sample-impala/src/main/java/com/gyee/sampleimpala/controller/CasePerformanceController.java

gyee-sample-impala/pom.xml

@@ -143,6 +143,17 @@
         </dependency>
         <!--http请求-->
 
+        <!--redis-->
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>3.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+
         <!-- 添加 lib -->
         <dependency>
             <groupId>ImpalaJDBC</groupId>

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/GyeeSampleImpalaApplication.java

@@ -3,7 +3,12 @@ package com.gyee.sampleimpala;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+
+@EnableCaching
+@EnableScheduling
 @SpringBootApplication
 @MapperScan("com.gyee.sampleimpala.mapper")
 public class GyeeSampleImpalaApplication {

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/cache/AppRedisCacheManager.java

@@ -0,0 +1,419 @@
+package com.gyee.sampleimpala.common.cache;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @description: 移动端Redis缓存实现类
+ * @author: YuXD
+ * @create: 2021-01-05 10:40
+ **/
+@Getter
+@AllArgsConstructor
+public final class AppRedisCacheManager implements IGlobalCache {
+
+    private RedisTemplate<String, Object> redisTemplate;
+
+    @Override
+    public boolean expire(String key, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.expire(key, time, TimeUnit.SECONDS);
+            }
+
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public long getExpire(String key) {
+        return redisTemplate.getExpire(key, TimeUnit.SECONDS);
+    }
+
+    @Override
+    public boolean hasKey(String key) {
+        try {
+            return redisTemplate.hasKey(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public void del(String... key) {
+        if (key != null && key.length > 0) {
+            if (key.length == 1) {
+                redisTemplate.delete(key[0]);
+            } else {
+                redisTemplate.delete(CollectionUtils.arrayToList(key));
+            }
+        }
+    }
+
+    @Override
+    public Object get(String key) {
+        return key == null ? null : redisTemplate.opsForValue().get(key);
+    }
+
+    @Override
+    public boolean set(String key, Object value) {
+        try {
+            redisTemplate.opsForValue().set(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean set(String key, Object value, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
+            } else {
+                set(key, value);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public long incr(String key, long delta) {
+        if (delta < 0) {
+            throw new RuntimeException("递增因子必须大于0");
+        }
+        return redisTemplate.opsForValue().increment(key, delta);
+    }
+
+    @Override
+    public long decr(String key, long delta) {
+        if (delta < 0) {
+            throw new RuntimeException("递减因子必须大于0");
+        }
+        return redisTemplate.opsForValue().increment(key, -delta);
+    }
+
+    @Override
+    public Object hget(String key, String item) {
+        return redisTemplate.opsForHash().get(key, item);
+    }
+
+    @Override
+    public Map<Object, Object> hmget(String key) {
+        return redisTemplate.opsForHash().entries(key);
+    }
+
+    @Override
+    public boolean hmset(String key, Map<String, Object> map) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean hmset(String key, Map<String, Object> map, long time) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean hset(String key, String item, Object value) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean hset(String key, String item, Object value, long time) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public void hdel(String key, Object... item) {
+        redisTemplate.opsForHash().delete(key, item);
+    }
+
+    @Override
+    public boolean hHasKey(String key, String item) {
+        return redisTemplate.opsForHash().hasKey(key, item);
+    }
+
+    @Override
+    public double hincr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, by);
+    }
+
+    @Override
+    public double hdecr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, -by);
+    }
+
+    @Override
+    public Set<Object> sGet(String key) {
+        try {
+            return redisTemplate.opsForSet().members(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    @Override
+    public boolean sHasKey(String key, Object value) {
+        try {
+            return redisTemplate.opsForSet().isMember(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public long sSet(String key, Object... values) {
+        try {
+            return redisTemplate.opsForSet().add(key, values);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    @Override
+    public long sSetAndTime(String key, long time, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().add(key, values);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    @Override
+    public long sGetSetSize(String key) {
+        try {
+            return redisTemplate.opsForSet().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    @Override
+    public long setRemove(String key, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().remove(key, values);
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    @Override
+    public List<Object> lGet(String key, long start, long end) {
+        try {
+            return redisTemplate.opsForList().range(key, start, end);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    @Override
+    public long lGetListSize(String key) {
+        try {
+            return redisTemplate.opsForList().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    @Override
+    public Object lGetIndex(String key, long index) {
+        try {
+            return redisTemplate.opsForList().index(key, index);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    @Override
+    public boolean lSetAll(String key, List<Object> value) {
+        try {
+            redisTemplate.opsForList().leftPushAll(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean lSet(String key, Object value) {
+        try {
+            redisTemplate.opsForList().leftPushIfPresent(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean lSet(String key, Object value, long time) {
+        try {
+            redisTemplate.opsForList().leftPush(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+
+    }
+
+    @Override
+    public boolean lSetAll(String key, List<Object> value, long time) {
+        try {
+            redisTemplate.opsForList().leftPushAll(key, value);
+            if (time > 0)
+                expire(key, time);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean rSet(String key, Object value) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean rSet(String key, Object value, long time) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+
+    }
+
+    @Override
+    public boolean rSetAll(String key, List<Object> value) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+
+    }
+
+    @Override
+    public boolean rSetAll(String key, List<Object> value, long time) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            if (time > 0)
+                expire(key, time);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public boolean lUpdateIndex(String key, long index, Object value) {
+        try {
+            redisTemplate.opsForList().set(key, index, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    @Override
+    public long lRemove(String key, long count, Object value) {
+        try {
+            Long remove = redisTemplate.opsForList().remove(key, count, value);
+            return remove;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    @Override
+    public void rangeRemove(String key, Long stard, Long end) {
+        try {
+            redisTemplate.opsForList().trim(key, stard, end);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/cache/IGlobalCache.java

@@ -0,0 +1,383 @@
+package com.gyee.sampleimpala.common.cache;
+
+import org.springframework.data.redis.core.RedisTemplate;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * 系统全局Cache接口，具体缓存方式需要实现该接口
+ *
+ * @author YuXD
+ * @date 2021-01-05 10:38
+ * @since v1.0
+ */
+public interface IGlobalCache {
+
+    /**
+     * 指定缓存失效时间
+     *
+     * @param key  键
+     * @param time 时间(秒)
+     * @return
+     */
+    boolean expire(String key, long time);
+
+    /**
+     * @param key 键 不能为null
+     * @return 时间(秒) 返回0代表为永久有效
+     */
+    long getExpire(String key);
+
+    /**
+     * 判断key是否存在
+     *
+     * @param key 键
+     * @return true 存在 false不存在
+     */
+    boolean hasKey(String key);
+
+    /**
+     * 删除缓存
+     *
+     * @param key 可以传一个值 或多个
+     */
+    void del(String... key);
+// ============================String=============================
+
+    /**
+     * 普通缓存获取
+     *
+     * @param key 键
+     * @return 值
+     */
+    Object get(String key);
+
+    /**
+     * 普通缓存放入
+     *
+     * @param key   键
+     * @param value 值
+     * @return true成功 false失败
+     */
+    boolean set(String key, Object value);
+
+    /**
+     * 普通缓存放入并设置时间
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
+     * @return true成功 false 失败
+     */
+    boolean set(String key, Object value, long time);
+
+    /**
+     * 递增
+     *
+     * @param key   键
+     * @param delta 要增加几(大于0)
+     * @return
+     */
+    long incr(String key, long delta);
+
+    /**
+     * 递减
+     *
+     * @param key   键
+     * @param delta 要减少几(小于0)
+     * @return
+     */
+    long decr(String key, long delta);
+
+    /**
+     * HashGet
+     *
+     * @param key  键 不能为null
+     * @param item 项 不能为null
+     * @return 值
+     */
+    Object hget(String key, String item);
+
+    /**
+     * 获取hashKey对应的所有键值
+     *
+     * @param key 键
+     * @return 对应的多个键值
+     */
+    Map<Object, Object> hmget(String key);
+
+    /**
+     * HashSet
+     *
+     * @param key 键
+     * @param map 对应多个键值
+     * @return true 成功 false 失败
+     */
+    boolean hmset(String key, Map<String, Object> map);
+
+    /**
+     * HashSet 并设置时间
+     *
+     * @param key  键
+     * @param map  对应多个键值
+     * @param time 时间(秒)
+     * @return true成功 false失败
+     */
+    boolean hmset(String key, Map<String, Object> map, long time);
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     *
+     * @param key   键
+     * @param item  项
+     * @param value 值
+     * @return true 成功 false失败
+     */
+    boolean hset(String key, String item, Object value);
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     *
+     * @param key   键
+     * @param item  项
+     * @param value 值
+     * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
+     * @return true 成功 false失败
+     */
+    boolean hset(String key, String item, Object value, long time);
+
+    /**
+     * 删除hash表中的值
+     *
+     * @param key  键 不能为null
+     * @param item 项 可以使多个 不能为null
+     */
+    void hdel(String key, Object... item);
+
+    /**
+     * 判断hash表中是否有该项的值
+     *
+     * @param key  键 不能为null
+     * @param item 项 不能为null
+     * @return true 存在 false不存在
+     */
+    boolean hHasKey(String key, String item);
+
+    /**
+     * hash递增 如果不存在,就会创建一个 并把新增后的值返回
+     *
+     * @param key  键
+     * @param item 项
+     * @param by   要增加几(大于0)
+     * @return
+     */
+    double hincr(String key, String item, double by);
+
+    /**
+     * hash递减
+     *
+     * @param key  键
+     * @param item 项
+     * @param by   要减少记(小于0)
+     * @return
+     */
+    double hdecr(String key, String item, double by);
+
+    /**
+     * 根据key获取Set中的所有值
+     *
+     * @param key 键
+     * @return
+     */
+    Set<Object> sGet(String key);
+
+    /**
+     * 根据value从一个set中查询,是否存在
+     *
+     * @param key   键
+     * @param value 值
+     * @return true 存在 false不存在
+     */
+    boolean sHasKey(String key, Object value);
+
+    /**
+     * 将数据放入set缓存
+     *
+     * @param key    键
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    long sSet(String key, Object... values);
+
+    /**
+     * 将set数据放入缓存
+     *
+     * @param key    键
+     * @param time   时间(秒)
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    long sSetAndTime(String key, long time, Object... values);
+
+
+    /**
+     * 获取set缓存的长度
+     *
+     * @param key 键
+     * @return
+     */
+    long sGetSetSize(String key);
+
+    /**
+     * 移除值为value的
+     *
+     * @param key    键
+     * @param values 值 可以是多个
+     * @return 移除的个数
+     */
+    long setRemove(String key, Object... values);
+
+    /**
+     * 获取list缓存的内容
+     *
+     * @param key   键
+     * @param start 开始
+     * @param end   结束 0 到 -1代表所有值
+     * @return
+     */
+    List<Object> lGet(String key, long start, long end);
+
+    /**
+     * 获取list缓存的长度
+     *
+     * @param key 键
+     * @return
+     */
+    long lGetListSize(String key);
+
+    /**
+     * 通过索引 获取list中的值
+     *
+     * @param key   键
+     * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
+     * @return
+     */
+    Object lGetIndex(String key, long index);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    boolean lSet(String key, Object value);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    boolean lSet(String key, Object value, long time);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    boolean lSetAll(String key, List<Object> value);
+
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return
+     */
+    boolean lSetAll(String key, List<Object> value, long time);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+
+    boolean rSet(String key, Object value);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return
+     */
+
+    boolean rSet(String key, Object value, long time);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    boolean rSetAll(String key, List<Object> value);
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return
+     */
+    boolean rSetAll(String key, List<Object> value, long time);
+
+    /**
+     * 根据索引修改list中的某条数据
+     *
+     * @param key   键
+     * @param index 索引
+     * @param value 值
+     * @return
+     */
+    boolean lUpdateIndex(String key, long index, Object value);
+
+    /**
+     * 移除N个值为value
+     *
+     * @param key   键
+     * @param count 移除多少个
+     * @param value 值
+     * @return 移除的个数
+     */
+    long lRemove(String key, long count, Object value);
+
+    /**
+     * 从redis集合中移除[start,end]之间的元素
+     *
+     * @param key
+     * @param stard
+     * @param end
+     * @return
+     */
+    void rangeRemove(String key, Long stard, Long end);
+
+    /**
+     * 返回当前redisTemplate
+     *
+     * @return
+     */
+    RedisTemplate getRedisTemplate();
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/config/BaseConfig.java

@@ -0,0 +1,14 @@
+package com.gyee.sampleimpala.common.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "gyee")
+public class BaseConfig {
+
+    /**数据适配器网址 **/
+    private String baseurl;
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/config/GeneratorConfig.java

@@ -1,4 +0,0 @@
-package com.gyee.sampleimpala.common.config;
-
-public class GeneratorConfig {
-}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/config/MapperGenerator.java

@@ -27,7 +27,7 @@ public class MapperGenerator {
     //作者
     private static String authorName = "chenmh";
     //要生成的表名
-    private static String[] tables = {"casefaultalg"};
+    private static String[] tables = {"caseperformance"};
     //table前缀
     private static String prefix = "";
 

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/config/RedisConfig.java

@@ -0,0 +1,107 @@
+package com.gyee.sampleimpala.common.config;
+
+import com.gyee.sampleimpala.common.cache.AppRedisCacheManager;
+import com.gyee.sampleimpala.common.cache.IGlobalCache;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.jedis.JedisClientConfiguration;
+import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.JedisPoolConfig;
+
+@EnableCaching
+//@Configuration
+public class RedisConfig {
+
+    @Value("${spring.redis.host}")
+    private String host;
+    @Value("${spring.redis.database}")
+    private Integer database;
+    @Value("${spring.redis.port}")
+    private Integer port;
+    @Value("${spring.redis.password}")
+    private String pwd;
+
+    @Value("${spring.redis.pool.maxTotal}")
+    private Integer maxTotal;
+    @Value("${spring.redis.pool.maxIdle}")
+    private Integer maxIdle;
+    @Value("${spring.redis.pool.minIdle}")
+    private Integer minIdle;
+    @Value("${spring.redis.pool.maxwait}")
+    private Integer maxwait;
+
+    @Primary
+    @Bean(name = "jedisPoolConfig")
+    @ConfigurationProperties(prefix = "spring.redis.pool")
+    public JedisPoolConfig jedisPoolConfig() {
+        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
+        jedisPoolConfig.setMaxTotal(maxTotal);
+        jedisPoolConfig.setMaxIdle(maxIdle);
+        jedisPoolConfig.setMinIdle(minIdle);
+        jedisPoolConfig.setMaxWaitMillis(maxwait);
+        return jedisPoolConfig;
+    }
+
+    @Primary
+    @Bean(name = "jedisPool")
+    public JedisPool redisPoolFactory(JedisPoolConfig jedisPoolConfig){
+
+        JedisPool jedisPool = new JedisPool(jedisPoolConfig,host,port,maxwait,pwd);
+
+        return  jedisPool;
+    }
+
+
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory(JedisPoolConfig jedisPoolConfig) {
+        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
+        redisStandaloneConfiguration.setHostName(host);
+        redisStandaloneConfiguration.setDatabase(database);
+        redisStandaloneConfiguration.setPassword(pwd);
+        redisStandaloneConfiguration.setPort(port);
+        redisStandaloneConfiguration.setDatabase(1);
+
+        JedisClientConfiguration.JedisPoolingClientConfigurationBuilder jpcb = (JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();
+        jpcb.poolConfig(jedisPoolConfig);
+        JedisClientConfiguration jedisClientConfiguration = jpcb.build();
+        return new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration);
+    }
+
+    /**
+     * 配置redisTemplate针对不同key和value场景下不同序列化的方式
+     *
+     * @param factory Redis连接工厂
+     * @return
+     */
+    @Primary
+    @Bean(name = "redisTemplate")
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(factory);
+        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
+        template.setKeySerializer(stringRedisSerializer);
+        template.setHashKeySerializer(stringRedisSerializer);
+        Jackson2JsonRedisSerializer redisSerializer = new Jackson2JsonRedisSerializer(Object.class);
+        template.setValueSerializer(redisSerializer);
+        template.setHashValueSerializer(redisSerializer);
+        template.afterPropertiesSet();
+
+        return template;
+    }
+
+    @Bean(name = "globalCache")
+    IGlobalCache cache(RedisTemplate redisTemplate) {
+        return new AppRedisCacheManager(redisTemplate);
+    }
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/constant/Constants.java

@@ -0,0 +1,17 @@
+package com.gyee.sampleimpala.common.constant;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+
+@Slf4j
+public class Constants {
+
+    // 实时欠发状态
+    public static final String RSSQFZT = "RSSQFZT";
+    // 发电机转速
+    public static final String FDJZS = "AI012";
+    public static final String FDJZSB = "AI012B";
+    // 明细状态
+    public static final String FJMXZT = "ZTMX";
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/spring/InitialRunner.java

@@ -0,0 +1,43 @@
+package com.gyee.sampleimpala.common.spring;
+
+import com.gyee.sampleimpala.common.cache.IGlobalCache;
+import com.gyee.sampleimpala.model.kudu.Windpowerstation;
+import com.gyee.sampleimpala.model.kudu.Windturbine;
+import com.gyee.sampleimpala.service.kudu.WindpowerstationService;
+import com.gyee.sampleimpala.service.kudu.WindturbineService;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.*;
+
+/**
+ * 服务启动前执行，进行全局变量初始化
+ */
+@Component
+public class InitialRunner implements CommandLineRunner {
+
+    @Resource
+    private WindturbineService windturbineService;
+    @Resource
+    private WindpowerstationService windpowerstationService;
+
+
+    // 场站所有信息
+    public static List<Windpowerstation> wpList = new ArrayList<>();
+    // 场站的风机
+    public static Map<String, List<Windturbine>> wtMap = new HashMap<>();
+
+
+    @Override
+    public void run(String... args) throws Exception {
+        wpList = windpowerstationService.getAll();
+
+        if (wpList != null && wpList.size() > 0){
+            for (Windpowerstation station : wpList){
+                List<Windturbine> winds = windturbineService.getWindTurbineId(station.getId());
+                wtMap.put(station.getId(), winds);
+            }
+        }
+    }
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/common/util/DateUtil.java

@@ -0,0 +1,88 @@
+package com.gyee.sampleimpala.common.util;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+
+@Slf4j
+public class DateUtil {
+
+    /**
+     * 获取当前时间
+     *
+     * @return
+     */
+    public static String getCurrentDate() {
+        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
+        String date = df.format(new Date());
+        return date;
+    }
+
+    /**
+     * 获取前 N 小时的时间
+     *
+     * @param hour
+     * @return
+     */
+    public static String getPreviousDate(int hour) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - hour);
+        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String date = df.format(calendar.getTime());
+        return date;
+    }
+
+    /**
+     * 获取当前时间后 N 小时的时间
+     *
+     * @param hour
+     * @return
+     */
+    public static String getNextDate(int hour) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) + hour);
+        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String date = df.format(calendar.getTime());
+        return date;
+    }
+
+    /**
+     * 获取当前时间后 N 小时的时间
+     *
+     * @param hour
+     * @return
+     */
+    public static Long getNextDateTimestamp(int hour) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) + hour);
+        long time = calendar.getTime().getTime();
+        return time;
+    }
+
+    /**
+     * 字符串时间转时间戳
+     * @param time
+     * @return
+     */
+    public static Long covertDateTimestamp(String time){
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        long stamp = 0;
+        try {
+            stamp = sdf.parse(time).getTime();
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+
+        return stamp;
+    }
+
+
+    public static void main(String[] args) {
+        System.out.println(getCurrentDate());
+        System.out.println(getPreviousDate(3 * 360 * 24));
+//        System.out.println(covertDateTimestamp("2021-05-12 00:00:00"));
+    }
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/controller/BasicQueryConditionsController.java

@@ -7,7 +7,7 @@ import com.gyee.sampleimpala.common.result.JsonResult;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.model.kudu.Knowfaulttype;
 import com.gyee.sampleimpala.model.kudu.Windpowerstation;
-import com.gyee.sampleimpala.service.TablePropService;
+import com.gyee.sampleimpala.service.custom.TablePropService;
 import com.gyee.sampleimpala.service.kudu.KnowfaulttypeService;
 import com.gyee.sampleimpala.service.kudu.WindpowerstationService;
 import com.gyee.sampleimpala.service.kudu.WindturbineService;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/controller/CasePerformanceController.java

@@ -1,5 +1,6 @@
 package com.gyee.sampleimpala.controller;
 
+<<<<<<< HEAD
 
 import com.alibaba.fastjson.JSONObject;
 import com.gyee.sampleimpala.common.result.JsonResult;
@@ -17,6 +18,12 @@ import java.util.List;
  *
  * @author w
  * @since 2021-11-17
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 性能下降样本库
  */
 @CrossOrigin
 @RestController
@@ -103,6 +110,4 @@ public class CasePerformanceController {
         return null;
     }
 
-
-
 }

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/controller/WindturbinePointController.java

@@ -7,7 +7,7 @@ import com.gyee.sampleimpala.common.result.JsonResult;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.model.custom.TsPointData;
 import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
-import com.gyee.sampleimpala.service.GoldenService;
+import com.gyee.sampleimpala.service.custom.GoldenService;
 import com.gyee.sampleimpala.service.kudu.WindturbinepointService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/CasefaultMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Casefault;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/CasefaultalgMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/kudu/CaseperformanceMapper.java

@@ -0,0 +1,16 @@
+package com.gyee.sampleimpala.mapper.kudu;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gyee.sampleimpala.model.kudu.Caseperformance;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author chenmh
+ * @since 2021-11-16
+ */
+public interface CaseperformanceMapper extends BaseMapper<Caseperformance> {
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/KnowalgMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Knowalg;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/KnowfaultfixMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Knowfaultfix;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/KnowfaultsymptomMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Knowfaultsymptom;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/KnowfaulttypeMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Knowfaulttype;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/WindpowerstationMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Windpowerstation;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/WindturbineMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Windturbine;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/WindturbinemetricsMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Windturbinemetrics;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/mapper/WindturbinepointMapper.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.mapper;
+package com.gyee.sampleimpala.mapper.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/model/custom/WindPowerStationTestingPoint2.java

@@ -0,0 +1,543 @@
+package com.gyee.sampleimpala.model.custom;
+
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+public class WindPowerStationTestingPoint2 implements Serializable {
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.CODE
+     *
+     * @mbg.generated
+     */
+    private String code;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.NAME
+     *
+     * @mbg.generated
+     */
+    private String name;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.MODEL
+     *
+     * @mbg.generated
+     */
+    private String model;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.VALUEUNIT
+     *
+     * @mbg.generated
+     */
+    private String valueunit;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.ENGLISHNAME
+     *
+     * @mbg.generated
+     */
+    private String englishname;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.TYPEID
+     *
+     * @mbg.generated
+     */
+    private String typeid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.MODELID
+     *
+     * @mbg.generated
+     */
+    private String modelid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.MAXVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal maxval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.MINVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal minval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMAXVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal reasonablemaxval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMINVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal reasonableminval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.UNIFORMCODE
+     *
+     * @mbg.generated
+     */
+    private String uniformcode;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.SHORTID
+     *
+     * @mbg.generated
+     */
+    private String shortid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.LONGID
+     *
+     * @mbg.generated
+     */
+    private String longid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.WINDPOWERSTATIONID
+     *
+     * @mbg.generated
+     */
+    private String windpowerstationid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDPOWERSTATIONTESTINGPOINT2.REALTIMEID
+     *
+     * @mbg.generated
+     */
+    private String realtimeid;
+
+    /**
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database table WINDPOWERSTATIONTESTINGPOINT2
+     *
+     * @mbg.generated
+     */
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.CODE
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.CODE
+     *
+     * @mbg.generated
+     */
+    public String getCode() {
+        return code;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.CODE
+     *
+     * @param code the value for WINDPOWERSTATIONTESTINGPOINT2.CODE
+     *
+     * @mbg.generated
+     */
+    public void setCode(String code) {
+        this.code = code == null ? null : code.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.NAME
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.NAME
+     *
+     * @mbg.generated
+     */
+    public String getName() {
+        return name;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.NAME
+     *
+     * @param name the value for WINDPOWERSTATIONTESTINGPOINT2.NAME
+     *
+     * @mbg.generated
+     */
+    public void setName(String name) {
+        this.name = name == null ? null : name.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MODEL
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.MODEL
+     *
+     * @mbg.generated
+     */
+    public String getModel() {
+        return model;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MODEL
+     *
+     * @param model the value for WINDPOWERSTATIONTESTINGPOINT2.MODEL
+     *
+     * @mbg.generated
+     */
+    public void setModel(String model) {
+        this.model = model == null ? null : model.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.VALUEUNIT
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.VALUEUNIT
+     *
+     * @mbg.generated
+     */
+    public String getValueunit() {
+        return valueunit;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.VALUEUNIT
+     *
+     * @param valueunit the value for WINDPOWERSTATIONTESTINGPOINT2.VALUEUNIT
+     *
+     * @mbg.generated
+     */
+    public void setValueunit(String valueunit) {
+        this.valueunit = valueunit == null ? null : valueunit.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.ENGLISHNAME
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.ENGLISHNAME
+     *
+     * @mbg.generated
+     */
+    public String getEnglishname() {
+        return englishname;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.ENGLISHNAME
+     *
+     * @param englishname the value for WINDPOWERSTATIONTESTINGPOINT2.ENGLISHNAME
+     *
+     * @mbg.generated
+     */
+    public void setEnglishname(String englishname) {
+        this.englishname = englishname == null ? null : englishname.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.TYPEID
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.TYPEID
+     *
+     * @mbg.generated
+     */
+    public String getTypeid() {
+        return typeid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.TYPEID
+     *
+     * @param typeid the value for WINDPOWERSTATIONTESTINGPOINT2.TYPEID
+     *
+     * @mbg.generated
+     */
+    public void setTypeid(String typeid) {
+        this.typeid = typeid == null ? null : typeid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MODELID
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.MODELID
+     *
+     * @mbg.generated
+     */
+    public String getModelid() {
+        return modelid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MODELID
+     *
+     * @param modelid the value for WINDPOWERSTATIONTESTINGPOINT2.MODELID
+     *
+     * @mbg.generated
+     */
+    public void setModelid(String modelid) {
+        this.modelid = modelid == null ? null : modelid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MAXVAL
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.MAXVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getMaxval() {
+        return maxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MAXVAL
+     *
+     * @param maxval the value for WINDPOWERSTATIONTESTINGPOINT2.MAXVAL
+     *
+     * @mbg.generated
+     */
+    public void setMaxval(BigDecimal maxval) {
+        this.maxval = maxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MINVAL
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.MINVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getMinval() {
+        return minval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.MINVAL
+     *
+     * @param minval the value for WINDPOWERSTATIONTESTINGPOINT2.MINVAL
+     *
+     * @mbg.generated
+     */
+    public void setMinval(BigDecimal minval) {
+        this.minval = minval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMAXVAL
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMAXVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getReasonablemaxval() {
+        return reasonablemaxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMAXVAL
+     *
+     * @param reasonablemaxval the value for WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMAXVAL
+     *
+     * @mbg.generated
+     */
+    public void setReasonablemaxval(BigDecimal reasonablemaxval) {
+        this.reasonablemaxval = reasonablemaxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMINVAL
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMINVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getReasonableminval() {
+        return reasonableminval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMINVAL
+     *
+     * @param reasonableminval the value for WINDPOWERSTATIONTESTINGPOINT2.REASONABLEMINVAL
+     *
+     * @mbg.generated
+     */
+    public void setReasonableminval(BigDecimal reasonableminval) {
+        this.reasonableminval = reasonableminval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.UNIFORMCODE
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.UNIFORMCODE
+     *
+     * @mbg.generated
+     */
+    public String getUniformcode() {
+        return uniformcode;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.UNIFORMCODE
+     *
+     * @param uniformcode the value for WINDPOWERSTATIONTESTINGPOINT2.UNIFORMCODE
+     *
+     * @mbg.generated
+     */
+    public void setUniformcode(String uniformcode) {
+        this.uniformcode = uniformcode == null ? null : uniformcode.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.SHORTID
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.SHORTID
+     *
+     * @mbg.generated
+     */
+    public String getShortid() {
+        return shortid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.SHORTID
+     *
+     * @param shortid the value for WINDPOWERSTATIONTESTINGPOINT2.SHORTID
+     *
+     * @mbg.generated
+     */
+    public void setShortid(String shortid) {
+        this.shortid = shortid == null ? null : shortid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.LONGID
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.LONGID
+     *
+     * @mbg.generated
+     */
+    public String getLongid() {
+        return longid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.LONGID
+     *
+     * @param longid the value for WINDPOWERSTATIONTESTINGPOINT2.LONGID
+     *
+     * @mbg.generated
+     */
+    public void setLongid(String longid) {
+        this.longid = longid == null ? null : longid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.WINDPOWERSTATIONID
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.WINDPOWERSTATIONID
+     *
+     * @mbg.generated
+     */
+    public String getWindpowerstationid() {
+        return windpowerstationid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.WINDPOWERSTATIONID
+     *
+     * @param windpowerstationid the value for WINDPOWERSTATIONTESTINGPOINT2.WINDPOWERSTATIONID
+     *
+     * @mbg.generated
+     */
+    public void setWindpowerstationid(String windpowerstationid) {
+        this.windpowerstationid = windpowerstationid == null ? null : windpowerstationid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDPOWERSTATIONTESTINGPOINT2.REALTIMEID
+     *
+     * @return the value of WINDPOWERSTATIONTESTINGPOINT2.REALTIMEID
+     *
+     * @mbg.generated
+     */
+    public String getRealtimeid() {
+        return realtimeid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDPOWERSTATIONTESTINGPOINT2.REALTIMEID
+     *
+     * @param realtimeid the value for WINDPOWERSTATIONTESTINGPOINT2.REALTIMEID
+     *
+     * @mbg.generated
+     */
+    public void setRealtimeid(String realtimeid) {
+        this.realtimeid = realtimeid == null ? null : realtimeid.trim();
+    }
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/model/custom/WindTurbineTestingPointAi2.java

@@ -0,0 +1,609 @@
+package com.gyee.sampleimpala.model.custom;
+
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+public class WindTurbineTestingPointAi2 implements Serializable {
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.ID
+     *
+     * @mbg.generated
+     */
+    private String id;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.CODE
+     *
+     * @mbg.generated
+     */
+    private String code;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.NAME
+     *
+     * @mbg.generated
+     */
+    private String name;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.MODEL
+     *
+     * @mbg.generated
+     */
+    private String model;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.VALUEUNIT
+     *
+     * @mbg.generated
+     */
+    private String valueunit;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.ENGLISHNAME
+     *
+     * @mbg.generated
+     */
+    private String englishname;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.TYPEID
+     *
+     * @mbg.generated
+     */
+    private String typeid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.MODELID
+     *
+     * @mbg.generated
+     */
+    private String modelid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.MAXVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal maxval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.MINVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal minval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.REASONABLEMAXVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal reasonablemaxval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.REASONABLEMINVAL
+     *
+     * @mbg.generated
+     */
+    private BigDecimal reasonableminval;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.WINDTURBINEID
+     *
+     * @mbg.generated
+     */
+    private String windturbineid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.UNIFORMCODE
+     *
+     * @mbg.generated
+     */
+    private String uniformcode;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.SHORTID
+     *
+     * @mbg.generated
+     */
+    private String shortid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.LONGID
+     *
+     * @mbg.generated
+     */
+    private String longid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.WINDPOWERSTATIONID
+     *
+     * @mbg.generated
+     */
+    private String windpowerstationid;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column WINDTURBINETESTINGPOINTAI2.REALTIMEID
+     *
+     * @mbg.generated
+     */
+    private String realtimeid;
+
+    /**
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database table WINDTURBINETESTINGPOINTAI2
+     *
+     * @mbg.generated
+     */
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.ID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.ID
+     *
+     * @mbg.generated
+     */
+    public String getId() {
+        return id;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.ID
+     *
+     * @param id the value for WINDTURBINETESTINGPOINTAI2.ID
+     *
+     * @mbg.generated
+     */
+    public void setId(String id) {
+        this.id = id == null ? null : id.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.CODE
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.CODE
+     *
+     * @mbg.generated
+     */
+    public String getCode() {
+        return code;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.CODE
+     *
+     * @param code the value for WINDTURBINETESTINGPOINTAI2.CODE
+     *
+     * @mbg.generated
+     */
+    public void setCode(String code) {
+        this.code = code == null ? null : code.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.NAME
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.NAME
+     *
+     * @mbg.generated
+     */
+    public String getName() {
+        return name;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.NAME
+     *
+     * @param name the value for WINDTURBINETESTINGPOINTAI2.NAME
+     *
+     * @mbg.generated
+     */
+    public void setName(String name) {
+        this.name = name == null ? null : name.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.MODEL
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.MODEL
+     *
+     * @mbg.generated
+     */
+    public String getModel() {
+        return model;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.MODEL
+     *
+     * @param model the value for WINDTURBINETESTINGPOINTAI2.MODEL
+     *
+     * @mbg.generated
+     */
+    public void setModel(String model) {
+        this.model = model == null ? null : model.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.VALUEUNIT
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.VALUEUNIT
+     *
+     * @mbg.generated
+     */
+    public String getValueunit() {
+        return valueunit;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.VALUEUNIT
+     *
+     * @param valueunit the value for WINDTURBINETESTINGPOINTAI2.VALUEUNIT
+     *
+     * @mbg.generated
+     */
+    public void setValueunit(String valueunit) {
+        this.valueunit = valueunit == null ? null : valueunit.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.ENGLISHNAME
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.ENGLISHNAME
+     *
+     * @mbg.generated
+     */
+    public String getEnglishname() {
+        return englishname;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.ENGLISHNAME
+     *
+     * @param englishname the value for WINDTURBINETESTINGPOINTAI2.ENGLISHNAME
+     *
+     * @mbg.generated
+     */
+    public void setEnglishname(String englishname) {
+        this.englishname = englishname == null ? null : englishname.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.TYPEID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.TYPEID
+     *
+     * @mbg.generated
+     */
+    public String getTypeid() {
+        return typeid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.TYPEID
+     *
+     * @param typeid the value for WINDTURBINETESTINGPOINTAI2.TYPEID
+     *
+     * @mbg.generated
+     */
+    public void setTypeid(String typeid) {
+        this.typeid = typeid == null ? null : typeid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.MODELID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.MODELID
+     *
+     * @mbg.generated
+     */
+    public String getModelid() {
+        return modelid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.MODELID
+     *
+     * @param modelid the value for WINDTURBINETESTINGPOINTAI2.MODELID
+     *
+     * @mbg.generated
+     */
+    public void setModelid(String modelid) {
+        this.modelid = modelid == null ? null : modelid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.MAXVAL
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.MAXVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getMaxval() {
+        return maxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.MAXVAL
+     *
+     * @param maxval the value for WINDTURBINETESTINGPOINTAI2.MAXVAL
+     *
+     * @mbg.generated
+     */
+    public void setMaxval(BigDecimal maxval) {
+        this.maxval = maxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.MINVAL
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.MINVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getMinval() {
+        return minval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.MINVAL
+     *
+     * @param minval the value for WINDTURBINETESTINGPOINTAI2.MINVAL
+     *
+     * @mbg.generated
+     */
+    public void setMinval(BigDecimal minval) {
+        this.minval = minval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.REASONABLEMAXVAL
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.REASONABLEMAXVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getReasonablemaxval() {
+        return reasonablemaxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.REASONABLEMAXVAL
+     *
+     * @param reasonablemaxval the value for WINDTURBINETESTINGPOINTAI2.REASONABLEMAXVAL
+     *
+     * @mbg.generated
+     */
+    public void setReasonablemaxval(BigDecimal reasonablemaxval) {
+        this.reasonablemaxval = reasonablemaxval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.REASONABLEMINVAL
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.REASONABLEMINVAL
+     *
+     * @mbg.generated
+     */
+    public BigDecimal getReasonableminval() {
+        return reasonableminval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.REASONABLEMINVAL
+     *
+     * @param reasonableminval the value for WINDTURBINETESTINGPOINTAI2.REASONABLEMINVAL
+     *
+     * @mbg.generated
+     */
+    public void setReasonableminval(BigDecimal reasonableminval) {
+        this.reasonableminval = reasonableminval;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.WINDTURBINEID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.WINDTURBINEID
+     *
+     * @mbg.generated
+     */
+    public String getWindturbineid() {
+        return windturbineid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.WINDTURBINEID
+     *
+     * @param windturbineid the value for WINDTURBINETESTINGPOINTAI2.WINDTURBINEID
+     *
+     * @mbg.generated
+     */
+    public void setWindturbineid(String windturbineid) {
+        this.windturbineid = windturbineid == null ? null : windturbineid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.UNIFORMCODE
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.UNIFORMCODE
+     *
+     * @mbg.generated
+     */
+    public String getUniformcode() {
+        return uniformcode;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.UNIFORMCODE
+     *
+     * @param uniformcode the value for WINDTURBINETESTINGPOINTAI2.UNIFORMCODE
+     *
+     * @mbg.generated
+     */
+    public void setUniformcode(String uniformcode) {
+        this.uniformcode = uniformcode == null ? null : uniformcode.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.SHORTID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.SHORTID
+     *
+     * @mbg.generated
+     */
+    public String getShortid() {
+        return shortid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.SHORTID
+     *
+     * @param shortid the value for WINDTURBINETESTINGPOINTAI2.SHORTID
+     *
+     * @mbg.generated
+     */
+    public void setShortid(String shortid) {
+        this.shortid = shortid == null ? null : shortid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.LONGID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.LONGID
+     *
+     * @mbg.generated
+     */
+    public String getLongid() {
+        return longid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.LONGID
+     *
+     * @param longid the value for WINDTURBINETESTINGPOINTAI2.LONGID
+     *
+     * @mbg.generated
+     */
+    public void setLongid(String longid) {
+        this.longid = longid == null ? null : longid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.WINDPOWERSTATIONID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.WINDPOWERSTATIONID
+     *
+     * @mbg.generated
+     */
+    public String getWindpowerstationid() {
+        return windpowerstationid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.WINDPOWERSTATIONID
+     *
+     * @param windpowerstationid the value for WINDTURBINETESTINGPOINTAI2.WINDPOWERSTATIONID
+     *
+     * @mbg.generated
+     */
+    public void setWindpowerstationid(String windpowerstationid) {
+        this.windpowerstationid = windpowerstationid == null ? null : windpowerstationid.trim();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column WINDTURBINETESTINGPOINTAI2.REALTIMEID
+     *
+     * @return the value of WINDTURBINETESTINGPOINTAI2.REALTIMEID
+     *
+     * @mbg.generated
+     */
+    public String getRealtimeid() {
+        return realtimeid;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column WINDTURBINETESTINGPOINTAI2.REALTIMEID
+     *
+     * @param realtimeid the value for WINDTURBINETESTINGPOINTAI2.REALTIMEID
+     *
+     * @mbg.generated
+     */
+    public void setRealtimeid(String realtimeid) {
+        this.realtimeid = realtimeid == null ? null : realtimeid.trim();
+    }
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/model/kudu/Caseperformance.java

@@ -0,0 +1,54 @@
+package com.gyee.sampleimpala.model.kudu;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author chenmh
+ * @since 2021-11-16
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("caseperformance")
+public class Caseperformance extends Model<Caseperformance> {
+
+    private static final long serialVersionUID=1L;
+
+      private Integer id;
+
+    private Integer tag;
+
+    private String stationen;
+
+    private String windturbineid;
+
+    private String starttime;
+
+    private String endtime;
+
+    private Integer algtype;
+
+    private String model;
+
+    private String stationcn;
+
+    private String manufacturer;
+
+    private String remark;
+
+    private String category;
+
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/schdule/TaskPerformance.java

@@ -0,0 +1,46 @@
+package com.gyee.sampleimpala.schdule;
+
+import com.gyee.sampleimpala.common.constant.Constants;
+import com.gyee.sampleimpala.common.feign.RemoteServiceBuilder;
+import com.gyee.sampleimpala.common.util.DateUtil;
+import com.gyee.sampleimpala.model.custom.TsPointData;
+import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
+import com.gyee.sampleimpala.service.kudu.WindpowerstationService;
+import com.gyee.sampleimpala.service.kudu.WindturbineService;
+import com.gyee.sampleimpala.service.kudu.WindturbinepointService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@Slf4j
+public class TaskPerformance {
+
+    @Autowired
+    private RemoteServiceBuilder remoteServiceBuilder;
+    @Autowired
+    private WindturbinepointService windturbinepointService;
+
+    /**
+     * 性能下降统计
+     * 延时30s执行
+     * 每隔60s执行一次
+     */
+//    @Scheduled(initialDelay = 30 * 1000, fixedRate = 60 * 1000)
+    public void performanceDown(){
+//        List<Windturbinepoint> nssFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FDJZS);
+//        List<Windturbinepoint> ztFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FJMXZT);
+
+        String point_nss_zs = "NSSFJ.NX_GD_NSSF_FJ_P1_L1_001_AI0012";
+        String point_nss_zt = "NSSFJJSFW.NX_GD_NSSF_FJ_P1_L1_001_CI0169";
+
+        List<TsPointData> zsData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zs,
+                DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00"));
+        List<TsPointData> ztData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zt,
+                DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00"));
+    }
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/GoldenService.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.service;
+package com.gyee.sampleimpala.service.custom;
 
 
 import com.gyee.sampleimpala.common.exception.CustomException;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/custom/IRealTimeData.java

@@ -0,0 +1,27 @@
+package com.gyee.sampleimpala.service.custom;
+
+import com.gyee.sampleimpala.common.exception.CustomException;
+import com.gyee.sampleimpala.model.custom.TsPointData;
+
+import java.util.List;
+
+public interface IRealTimeData {
+
+    /**
+     * 通过点的集合查询多条数据
+     * @param points  测点集合
+     * @return
+     * @throws CustomException
+     */
+    List<TsPointData> getRealData(List<String> points) throws CustomException;
+
+
+    /**
+     * 通过风机测点获得测点历史存储数据，存多少取多少
+     * @param point   单个测点
+     * @param startTs 开始时间
+     * @param endTs   结束时间
+     * @return
+     */
+    List<TsPointData> getHistoryDataRaw(String point, Long startTs, Long endTs);
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/TablePropService.java

@@ -1,4 +1,4 @@
-package com.gyee.sampleimpala.service;
+package com.gyee.sampleimpala.service.custom;
 
 import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/CasefaultServiceImpl.java

@@ -6,7 +6,7 @@ import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.common.util.SnowFlakeGenerator;
 import com.gyee.sampleimpala.model.kudu.Casefault;
-import com.gyee.sampleimpala.mapper.CasefaultMapper;
+import com.gyee.sampleimpala.mapper.kudu.CasefaultMapper;
 import com.gyee.sampleimpala.service.kudu.CasefaultService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.apache.commons.lang3.StringUtils;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/CasefaultalgServiceImpl.java

@@ -3,7 +3,7 @@ package com.gyee.sampleimpala.service.impl.kudu;
 
 import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
-import com.gyee.sampleimpala.mapper.CasefaultalgMapper;
+import com.gyee.sampleimpala.mapper.kudu.CasefaultalgMapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.sampleimpala.model.kudu.Casefaultalg;
 import com.gyee.sampleimpala.service.kudu.CasefaultalgService;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/CaseperformanceServiceImpl.java

@@ -0,0 +1,21 @@
+package com.gyee.sampleimpala.service.impl.kudu;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.gyee.sampleimpala.mapper.kudu.CaseperformanceMapper;
+import com.gyee.sampleimpala.model.kudu.Caseperformance;
+import com.gyee.sampleimpala.service.kudu.CaseperformanceService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author chenmh
+ * @since 2021-11-16
+ */
+@Service
+public class CaseperformanceServiceImpl extends ServiceImpl<CaseperformanceMapper, Caseperformance> implements CaseperformanceService {
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/KnowalgServiceImpl.java

@@ -1,7 +1,7 @@
 package com.gyee.sampleimpala.service.impl.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Knowalg;
-import com.gyee.sampleimpala.mapper.KnowalgMapper;
+import com.gyee.sampleimpala.mapper.kudu.KnowalgMapper;
 import com.gyee.sampleimpala.service.kudu.KnowalgService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/KnowfaultfixServiceImpl.java

@@ -5,8 +5,7 @@ import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.common.util.SnowFlakeGenerator;
 import com.gyee.sampleimpala.model.kudu.Knowfaultfix;
-import com.gyee.sampleimpala.mapper.KnowfaultfixMapper;
-import com.gyee.sampleimpala.model.kudu.Knowfaultsymptom;
+import com.gyee.sampleimpala.mapper.kudu.KnowfaultfixMapper;
 import com.gyee.sampleimpala.service.kudu.KnowfaultfixService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.apache.commons.lang3.StringUtils;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/KnowfaultsymptomServiceImpl.java

@@ -5,7 +5,7 @@ import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.common.util.SnowFlakeGenerator;
 import com.gyee.sampleimpala.model.kudu.Knowfaultsymptom;
-import com.gyee.sampleimpala.mapper.KnowfaultsymptomMapper;
+import com.gyee.sampleimpala.mapper.kudu.KnowfaultsymptomMapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.sampleimpala.service.kudu.KnowfaultsymptomService;
 import org.apache.commons.lang3.StringUtils;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/KnowfaulttypeServiceImpl.java

@@ -5,7 +5,7 @@ import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.common.util.SnowFlakeGenerator;
 import com.gyee.sampleimpala.model.kudu.Knowfaulttype;
-import com.gyee.sampleimpala.mapper.KnowfaulttypeMapper;
+import com.gyee.sampleimpala.mapper.kudu.KnowfaulttypeMapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.sampleimpala.service.kudu.KnowfaulttypeService;
 import org.apache.commons.lang3.StringUtils;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/WindpowerstationServiceImpl.java

@@ -4,9 +4,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.model.kudu.Windpowerstation;
-import com.gyee.sampleimpala.mapper.WindpowerstationMapper;
+import com.gyee.sampleimpala.mapper.kudu.WindpowerstationMapper;
 import com.gyee.sampleimpala.service.kudu.WindpowerstationService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -20,10 +21,12 @@ import java.util.List;
  * @author chenmh
  * @since 2021-10-15
  */
+@Cacheable(value = "windpowerstation")
 @Service
 public class WindpowerstationServiceImpl extends ServiceImpl<WindpowerstationMapper, Windpowerstation> implements WindpowerstationService {
 
 
+    @Cacheable(value = "station")
     @Override
     public List<Windpowerstation> getAll() {
         List<Windpowerstation> list = new ArrayList<>();

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/WindturbineServiceImpl.java

@@ -1,13 +1,15 @@
 package com.gyee.sampleimpala.service.impl.kudu;
 
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.gyee.sampleimpala.common.base.ExcludeQueryWrapper;
 import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.gyee.sampleimpala.mapper.WindturbineMapper;
+import com.gyee.sampleimpala.mapper.kudu.WindturbineMapper;
 import com.gyee.sampleimpala.model.kudu.Windturbine;
 import com.gyee.sampleimpala.service.kudu.WindturbineService;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -23,9 +25,11 @@ import java.util.Map;
  * @author chenmh
  * @since 2021-10-20
  */
+@Cacheable(value = "windturbine")
 @Service
 public class WindturbineServiceImpl extends ServiceImpl<WindturbineMapper, Windturbine> implements WindturbineService {
 
+    @Cacheable(value = "windturbineall")
     @Override
     public List<Object> getWindTurbineAll(String station) {
         List<Object> list = new ArrayList<>();
@@ -48,4 +52,22 @@ public class WindturbineServiceImpl extends ServiceImpl<WindturbineMapper, Windt
 
         return list;
     }
+
+    @Cacheable(value = "windturbineid")
+    @Override
+    public List<Windturbine> getWindTurbineId(String station) {
+        List<Windturbine> list = null;
+        try {
+            QueryWrapper<Windturbine> wrapper = new QueryWrapper<>();
+            wrapper.eq("station", station);
+
+            list = baseMapper.selectList(wrapper);
+
+        } catch (CustomException e){
+            log.error(e.getMessage());
+            throw new CustomException(ResultCode.ERROR_DATA);
+        }
+
+        return list;
+    }
 }

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/WindturbinemetricsServiceImpl.java

@@ -1,7 +1,7 @@
 package com.gyee.sampleimpala.service.impl.kudu;
 
 import com.gyee.sampleimpala.model.kudu.Windturbinemetrics;
-import com.gyee.sampleimpala.mapper.WindturbinemetricsMapper;
+import com.gyee.sampleimpala.mapper.kudu.WindturbinemetricsMapper;
 import com.gyee.sampleimpala.service.kudu.WindturbinemetricsService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/impl/kudu/WindturbinepointServiceImpl.java

@@ -5,9 +5,10 @@ import com.gyee.sampleimpala.common.base.ExcludeQueryWrapper;
 import com.gyee.sampleimpala.common.exception.CustomException;
 import com.gyee.sampleimpala.common.result.ResultCode;
 import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
-import com.gyee.sampleimpala.mapper.WindturbinepointMapper;
+import com.gyee.sampleimpala.mapper.kudu.WindturbinepointMapper;
 import com.gyee.sampleimpala.service.kudu.WindturbinepointService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -21,9 +22,11 @@ import java.util.List;
  * @author chenmh
  * @since 2021-10-17
  */
+@Cacheable(value = "windturbinepoint")
 @Service
 public class WindturbinepointServiceImpl extends ServiceImpl<WindturbinepointMapper, Windturbinepoint> implements WindturbinepointService {
 
+    @Cacheable(value = "windturbinepointall")
     @Override
     public List<Windturbinepoint> getAll(String wtId, String widget) {
         List<Windturbinepoint> list = new ArrayList<>();
@@ -43,6 +46,26 @@ public class WindturbinepointServiceImpl extends ServiceImpl<WindturbinepointMap
         return list;
     }
 
+    @Cacheable(value = "windturbinepointuniformcode")
+    @Override
+    public List<Windturbinepoint> getAllByStationAndUniformCode(String station, String uniformCode) {
+        List<Windturbinepoint> list = new ArrayList<>();
+
+        try {
+            ExcludeQueryWrapper<Windturbinepoint> wrapper = new ExcludeQueryWrapper<>();
+            wrapper.eq("stationen", station)
+                    .eq("uniformcode", uniformCode);
+
+            list = baseMapper.selectList(wrapper);
+
+        } catch (CustomException e){
+            log.error(e.getMessage());
+            throw new CustomException(ResultCode.ERROR_DATA);
+        }
+
+        return list;
+    }
+
     @Override
     public boolean editItem(Windturbinepoint obj) {
         try {

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/kudu/CaseperformanceService.java

@@ -0,0 +1,16 @@
+package com.gyee.sampleimpala.service.kudu;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.gyee.sampleimpala.model.kudu.Caseperformance;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author chenmh
+ * @since 2021-11-16
+ */
+public interface CaseperformanceService extends IService<Caseperformance> {
+
+}

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/kudu/WindturbineService.java

@@ -21,4 +21,11 @@ public interface WindturbineService extends IService<Windturbine> {
      * @return
      */
     List<Object> getWindTurbineAll(String station);
+
+    /**
+     * 获取场站的所有风机
+     * @param station
+     * @return
+     */
+    List<Windturbine> getWindTurbineId(String station);
 }

gyee-sample-impala/src/main/java/com/gyee/sampleimpala/service/kudu/WindturbinepointService.java

@@ -24,6 +24,14 @@ public interface WindturbinepointService extends IService<Windturbinepoint> {
     List<Windturbinepoint> getAll(String wtId, String widget);
 
     /**
+     * 通过场站和统一编码查询测点
+     * @param station     场站
+     * @param uniformCode 统一编码
+     * @return
+     */
+    List<Windturbinepoint> getAllByStationAndUniformCode(String station, String uniformCode);
+
+    /**
      * 编辑数据
      * @param obj
      * @return

gyee-sample-impala/src/main/resources/application.yaml

@@ -1,3 +1,7 @@
+gyee:
+  # golden实时适配器的url
+  baseurl: http://10.155.32.4:8011
+
 server:
   port: 9002
 spring:
@@ -20,7 +24,17 @@ spring:
         test-while-idle: true
         test-on-borrow: false
         test-on-return: false
-
+  redis:
+    database: 1
+    host: 10.155.32.4
+    password: gdnxfd123
+    pool:
+      maxTotal: 20
+      maxIdle: 20
+      maxwait: 60000
+      minIdle: 10
+    port: 6379
+    timeout: 60000
 
 mybatis-plus:
   configuration:
@@ -47,5 +61,6 @@ logging:
 databases:
     basictables: windpowerstation,windturbinemetrics,windturbinepoint
 
-# golden适配器的url
-goldenUrl: http://10.155.32.4:8011
+
+
+

gyee-sample-impala/src/main/resources/mapper/CasefaultMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.CasefaultMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.CasefaultMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Casefault">

gyee-sample-impala/src/main/resources/mapper/CasefaultalgMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.CasefaultalgMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.CasefaultalgMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Casefaultalg">

gyee-sample-impala/src/main/resources/mapper/CaseperformanceMapper.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.gyee.sampleimpala.mapper.CaseperformanceMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.Caseperformance">
+        <id column="id" property="id" />
+        <result column="tag" property="tag" />
+        <result column="stationen" property="stationen" />
+        <result column="windturbineid" property="windturbineid" />
+        <result column="starttime" property="starttime" />
+        <result column="endtime" property="endtime" />
+        <result column="algtype" property="algtype" />
+        <result column="model" property="model" />
+        <result column="stationcn" property="stationcn" />
+        <result column="manufacturer" property="manufacturer" />
+        <result column="remark" property="remark" />
+        <result column="category" property="category" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id, tag, stationen, windturbineid, starttime, endtime, algtype, model, stationcn, manufacturer, remark, category
+    </sql>
+
+</mapper>

gyee-sample-impala/src/main/resources/mapper/KnowalgMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.KnowalgMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.KnowalgMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Knowalg">

gyee-sample-impala/src/main/resources/mapper/KnowfaultfixMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.KnowfaultfixMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.KnowfaultfixMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Knowfaultfix">

gyee-sample-impala/src/main/resources/mapper/KnowfaultsymptomMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.KnowfaultsymptomMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.KnowfaultsymptomMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Knowfaultsymptom">

gyee-sample-impala/src/main/resources/mapper/KnowfaulttypeMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.KnowfaulttypeMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.KnowfaulttypeMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Knowfaulttype">

gyee-sample-impala/src/main/resources/mapper/WindpowerstationMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.WindpowerstationMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.WindpowerstationMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Windpowerstation">

gyee-sample-impala/src/main/resources/mapper/WindturbineMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.WindturbineMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.WindturbineMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Windturbine">

gyee-sample-impala/src/main/resources/mapper/WindturbinemetricsMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.WindturbinemetricsMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.WindturbinemetricsMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Windturbinemetrics">

gyee-sample-impala/src/main/resources/mapper/WindturbinepointMapper.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.gyee.sampleimpala.mapper.WindturbinepointMapper">
+<mapper namespace="com.gyee.sampleimpala.mapper.kudu.WindturbinepointMapper">
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.gyee.sampleimpala.model.kudu.Windturbinepoint">