基础配置与存入天擎站号

climate-admin/pom.xml

@@ -54,8 +54,51 @@
             <groupId>com.climate</groupId>
             <artifactId>climate-quartz</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.climate</groupId>
+            <artifactId>climate_data</artifactId>
+            <version>3.8.6</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/commons-net/commons-net -->
+        <dependency>
+            <groupId>commons-net</groupId>
+            <artifactId>commons-net</artifactId>
+            <version>3.6</version>
+        </dependency>
 
+        <!-- mybatis-plus依赖 -->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.4.1</version>
+        </dependency>
+        <!-- 引入 Apache 的 commons-lang3 包，方便操作字符串-->
+        <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.8</version>
+        </dependency>
 
+        <!-- 引入 Apache commons-io 包，方便操作文件-->
+        <!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+            <version>2.6</version>
+        </dependency>
+     <!--   <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+        </dependency>-->
+        <dependency>
+            <groupId>org.apache.xmlgraphics</groupId>
+            <artifactId>batik-css</artifactId>
+            <version>1.14</version>
+            <scope>compile</scope>
+        </dependency>
 
     </dependencies>
 
@@ -76,17 +119,17 @@
                     </execution>
                 </executions>
             </plugin>
-            <plugin>   
-                <groupId>org.apache.maven.plugins</groupId>   
-                <artifactId>maven-war-plugin</artifactId>   
-                <version>3.1.0</version>   
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-war-plugin</artifactId>
+                <version>3.1.0</version>
                 <configuration>
                     <failOnMissingWebXml>false</failOnMissingWebXml>
                     <warName>${project.artifactId}</warName>
-                </configuration>   
-           </plugin>   
+                </configuration>
+           </plugin>
         </plugins>
         <finalName>${project.artifactId}</finalName>
     </build>
 
-</project>
+</project>

climate-admin/src/main/java/com/climate/web/controller/data/CliTqStationController.java

@@ -0,0 +1,29 @@
+package com.climate.web.controller.data;
+
+import com.climate.common.core.domain.AjaxResult;
+import com.climate.data.domain.CliTqStation;
+import com.climate.data.domain.vo.TqParm;
+import com.climate.data.service.CliTqStationService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @author 站点信息
+ */
+@RestController
+@RequestMapping("/cliTqStation")
+public class CliTqStationController {
+
+    @Autowired
+    private CliTqStationService cliTqStationService;
+
+
+    @PostMapping("/listSta")
+    @ResponseBody
+    public AjaxResult listStation(@RequestBody TqParm tqParm){
+        List<CliTqStation> tqStations = cliTqStationService.listSta(tqParm.getAdminCodes());
+        return AjaxResult.success();
+    }
+}

climate-admin/src/main/resources/application-druid.yml

@@ -6,16 +6,16 @@ spring:
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://10.203.10.23:3306/ruoyi-vue?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                url: jdbc:mysql://10.203.10.23:3306/fy-climate?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                 username: FYQX
                 password: FYQX_qxqx@20
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭
                 enabled: false
-                url: 
-                username: 
-                password: 
+                url:
+                username:
+                password:
             # 初始连接数
             initialSize: 5
             # 最小连接池数量
@@ -39,7 +39,7 @@ spring:
             testWhileIdle: true
             testOnBorrow: false
             testOnReturn: false
-            webStatFilter: 
+            webStatFilter:
                 enabled: true
             statViewServlet:
                 enabled: true
@@ -58,4 +58,4 @@ spring:
                     merge-sql: true
                 wall:
                     config:
-                        multi-statement-allow: true
+                        multi-statement-allow: true

climate-admin/src/main/resources/application.yml

@@ -129,3 +129,7 @@ xss:
   excludes: /system/notice
   # 匹配链接
   urlPatterns: /system/*,/monitor/*,/tool/*
+tq:
+  name: BEGY_JB_FYGS_YHY
+  password: "Yang@18212485516"
+  clientpath: D:/ideaworksprace/climate_service/climate_data/client.config

climate-common/src/main/java/com/climate/common/core/utils/DateNewUtils.java

@@ -0,0 +1,289 @@
+package com.climate.common.core.utils;
+
+import org.apache.commons.lang3.time.DateFormatUtils;
+
+import java.lang.management.ManagementFactory;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * 时间工具类
+ *
+ * @author gybank
+ */
+public class DateNewUtils extends org.apache.commons.lang3.time.DateUtils
+{
+    public static String YYYY = "yyyy";
+
+    public static String YYYY_MM = "yyyy-MM";
+
+    public static String YYYY_MM_DD = "yyyy-MM-dd";
+
+    public static String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
+
+    public static String YYYYMMDDHHMMSSSSS = "yyyyMMddHHmmssSSS";
+
+    public static String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
+
+    private static String[] parsePatterns = {
+            "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM",
+            "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
+            "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM"};
+
+    /**
+     * 获取当前Date型日期
+     *
+     * @return Date() 当前日期
+     */
+    public static Date getNowDate()
+    {
+        return new Date();
+    }
+
+    /**
+     * 获取当前日期, 默认格式为yyyy-MM-dd
+     *
+     * @return String
+     */
+    public static String getDate()
+    {
+        return dateTimeNow(YYYY_MM_DD);
+    }
+
+    public static final String getTime()
+    {
+        return dateTimeNow(YYYY_MM_DD_HH_MM_SS);
+    }
+
+    public static final String dateTimeNow()
+    {
+        return dateTimeNow(YYYYMMDDHHMMSS);
+    }
+
+    public static final String dateTimeNow(final String format)
+    {
+        return parseDateToStr(format, new Date());
+    }
+
+    public static final String dateTime(final Date date)
+    {
+        return parseDateToStr(YYYY_MM_DD, date);
+    }
+
+    public static final String parseDateToStr(final String format, final Date date)
+    {
+        return new SimpleDateFormat(format).format(date);
+    }
+
+    public static final Date dateTime(final String format, final String ts)
+    {
+        try
+        {
+            return new SimpleDateFormat(format).parse(ts);
+        }
+        catch (ParseException e)
+        {
+            throw new RuntimeException(e);
+        }
+    }
+
+    /**
+     * 日期路径 即年/月/日 如2018/08/08
+     */
+    public static final String datePath()
+    {
+        Date now = new Date();
+        return DateFormatUtils.format(now, "yyyy/MM/dd");
+    }
+
+    /**
+     * 日期路径 即年/月/日 如20180808
+     */
+    public static final String dateTime()
+    {
+        Date now = new Date();
+        return DateFormatUtils.format(now, "yyyyMMdd");
+    }
+
+    /**
+     * 日期型字符串转化为日期 格式
+     */
+    public static Date parseDate(Object str)
+    {
+        if (str == null)
+        {
+            return null;
+        }
+        try
+        {
+            return parseDate(str.toString(), parsePatterns);
+        }
+        catch (ParseException e)
+        {
+            return null;
+        }
+    }
+
+    /**
+     * 获取服务器启动时间
+     */
+    public static Date getServerStartDate()
+    {
+        long time = ManagementFactory.getRuntimeMXBean().getStartTime();
+        return new Date(time);
+    }
+
+    /**
+     * 计算两个时间差
+     */
+    public static String getDatePoor(Date endDate, Date nowDate)
+    {
+        long nd = 1000 * 24 * 60 * 60;
+        long nh = 1000 * 60 * 60;
+        long nm = 1000 * 60;
+        // long ns = 1000;
+        // 获得两个时间的毫秒时间差异
+        long diff = endDate.getTime() - nowDate.getTime();
+        // 计算差多少天
+        long day = diff / nd;
+        // 计算差多少小时
+        long hour = diff % nd / nh;
+        // 计算差多少分钟
+        long min = diff % nd % nh / nm;
+        // 计算差多少秒//输出结果
+        // long sec = diff % nd % nh % nm / ns;
+        return day + "天" + hour + "小时" + min + "分钟";
+    }
+
+    /**
+     * 前一天日期
+     * @param date
+     * @return
+     */
+    public static String getNextDay(Date date) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.DAY_OF_MONTH, -1);
+        date = calendar.getTime();
+        return new SimpleDateFormat(YYYY_MM_DD).format(date);
+    }
+
+    /**
+     * 几小时后的时间
+     * @param date
+     * @return
+     */
+    public static String getAddHourDate(Date date,int hour) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.HOUR_OF_DAY, hour);
+        date = calendar.getTime();
+        return new SimpleDateFormat(YYYY_MM_DD_HH_MM_SS).format(date);
+    }
+
+    /**
+     * 几分钟后的时间
+     * @param date
+     * @return
+     */
+    public static String getAddMinuteDate(Date date,int minute) {
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.MINUTE, minute);
+        date = calendar.getTime();
+        return new SimpleDateFormat(YYYY_MM_DD_HH_MM_SS).format(date);
+    }
+
+    /**
+     * 获得当月第一天
+     * @return
+     */
+    public static String getFirstDay() {
+        SimpleDateFormat sdf = new SimpleDateFormat(YYYY_MM_DD);
+        Date date = new Date();
+        Calendar calendar = new GregorianCalendar();
+        calendar.setTime(date);
+        calendar.set(Calendar.DAY_OF_MONTH, calendar.getActualMinimum(Calendar.DAY_OF_MONTH));
+        String firstDay = sdf.format(calendar.getTime());
+        return firstDay;
+    }
+
+    /**
+     * 获得当月最后一天
+     * @return
+     */
+    public static String getLastDay() {
+        SimpleDateFormat sdf = new SimpleDateFormat(YYYY_MM_DD);
+        Date date = new Date();
+        Calendar calendar = new GregorianCalendar();
+        calendar.setTime(date);
+        calendar.set(Calendar.DAY_OF_MONTH, calendar.getActualMaximum(Calendar.DAY_OF_MONTH));
+        String lastDay = sdf.format(calendar.getTime());
+        return lastDay;
+    }
+
+    public static List<String> getDayByTwoDay(String startDate, String endDate) {
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+        SimpleDateFormat dayFormat = new SimpleDateFormat("yyyy-MM-dd");
+        List<String> days=new ArrayList<>();
+        if(startDate.equals(endDate)){
+            days.add(startDate);
+            return days;
+        }
+        try {
+            Calendar editStartPeriod = Calendar.getInstance();
+            editStartPeriod.setTime(format.parse(startDate));
+            Calendar editEndPeriod = Calendar.getInstance();
+            editEndPeriod.setTime(format.parse(endDate));
+            Calendar curr = editStartPeriod;
+            while (curr.before(editEndPeriod)) {
+                String toDay = dayFormat.format(curr.getTime());
+                days.add(toDay);
+                curr.add(Calendar.DATE, 1);
+            }
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        days.add(endDate);
+        return days;
+    }
+
+    /**
+     * 获取当年的最后一天
+     */
+    public static Date getCurrentLastOfYear(){
+        Calendar currCal=Calendar.getInstance();
+        int currentYear = currCal.get(Calendar.YEAR);
+        return getLastOfYear(currentYear);
+    }
+
+    /**
+     * 获取某年最后一天日期
+     * @param year 年份
+     * @return Date
+     */
+    public static Date getLastOfYear(int year){
+        Calendar calendar = Calendar.getInstance();
+        calendar.clear();
+        calendar.set(Calendar.YEAR, year);
+        calendar.roll(Calendar.DAY_OF_YEAR, -1);
+        calendar.set(Calendar.HOUR, 23);
+        calendar.set(Calendar.MINUTE, 59);
+        calendar.set(Calendar.SECOND, 59);
+        return calendar.getTime();
+    }
+
+    public static final String currentTimeSSS()
+    {
+        return dateTimeNow(YYYYMMDDHHMMSSSSS);
+    }
+
+    public static void main(String[] args) {
+
+        //DateNewUtils.getDayByTwoDay("2019-02-01","2020-01-02");
+
+        System.out.println(DateFormatUtils.format(getCurrentLastOfYear(), "yyyy-MM-dd HH:mm:ss"));
+    }
+
+}

climate-common/src/main/java/com/climate/common/core/utils/SnowflakeIdWorker.java

@@ -0,0 +1,203 @@
+package com.climate.common.core.utils;
+
+import org.apache.commons.lang3.RandomUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.SystemUtils;
+
+import java.net.Inet4Address;
+import java.net.UnknownHostException;
+import java.util.Random;
+
+/**
+ * Twitter_Snowflake<br>
+ * SnowFlake的结构如下(每部分用-分开):<br>
+ * 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000 <br>
+ * 1位标识，由于long基本类型在Java中是带符号的，最高位是符号位，正数是0，负数是1，所以id一般是正数，最高位是0<br>
+ * 41位时间截(毫秒级)，注意，41位时间截不是存储当前时间的时间截，而是存储时间截的差值（当前时间截 - 开始时间截)
+ * 得到的值），这里的的开始时间截，一般是我们的id生成器开始使用的时间，由我们程序来指定的（如下下面程序IdWorker类的startTime属性）。41位的时间截，可以使用69年，年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69<br>
+ * 10位的数据机器位，可以部署在1024个节点，包括5位datacenterId和5位workerId<br>
+ * 12位序列，毫秒内的计数，12位的计数顺序号支持每个节点每毫秒(同一机器，同一时间截)产生4096个ID序号<br>
+ * 加起来刚好64位，为一个Long型。<br>
+ * SnowFlake的优点是，整体上按照时间自增排序，并且整个分布式系统内不会产生ID碰撞(由数据中心ID和机器ID作区分)，并且效率较高，经测试，SnowFlake每秒能够产生26万ID左右。
+ */
+public class SnowflakeIdWorker {
+
+    // ==============================Fields===========================================
+    /** 开始时间截 (2015-01-01) */
+    private final long twepoch = 1489111610226L;
+
+    /** 机器id所占的位数 */
+    private final long workerIdBits = 5L;
+
+    /** 数据标识id所占的位数 */
+    private final long dataCenterIdBits = 5L;
+
+    /** 支持的最大机器id，结果是31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数) */
+    private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
+
+    /** 支持的最大数据标识id，结果是31 */
+    private final long maxDataCenterId = -1L ^ (-1L << dataCenterIdBits);
+
+    /** 序列在id中占的位数 */
+    private final long sequenceBits = 12L;
+
+    /** 机器ID向左移12位 */
+    private final long workerIdShift = sequenceBits;
+
+    /** 数据标识id向左移17位(12+5) */
+    private final long dataCenterIdShift = sequenceBits + workerIdBits;
+
+    /** 时间截向左移22位(5+5+12) */
+    private final long timestampLeftShift = sequenceBits + workerIdBits + dataCenterIdBits;
+
+    /** 生成序列的掩码，这里为4095 (0b111111111111=0xfff=4095) */
+    private final long sequenceMask = -1L ^ (-1L << sequenceBits);
+
+    /** 工作机器ID(0~31) */
+    private long workerId;
+
+    /** 数据中心ID(0~31) */
+    private long dataCenterId;
+
+    /** 毫秒内序列(0~4095) */
+    private long sequence = 0L;
+
+    /** 上次生成ID的时间截 */
+    private long lastTimestamp = -1L;
+
+    private static SnowflakeIdWorker idWorker;
+
+    static {
+        idWorker = new SnowflakeIdWorker(getWorkId(),getDataCenterId());
+    }
+
+    //==============================Constructors=====================================
+    /**
+     * 构造函数
+     * @param workerId 工作ID (0~31)
+     * @param dataCenterId 数据中心ID (0~31)
+     */
+    public SnowflakeIdWorker(long workerId, long dataCenterId) {
+        if (workerId > maxWorkerId || workerId < 0) {
+            throw new IllegalArgumentException(String.format("workerId can't be greater than %d or less than 0", maxWorkerId));
+        }
+        if (dataCenterId > maxDataCenterId || dataCenterId < 0) {
+            throw new IllegalArgumentException(String.format("dataCenterId can't be greater than %d or less than 0", maxDataCenterId));
+        }
+        this.workerId = workerId;
+        this.dataCenterId = dataCenterId;
+    }
+
+    // ==============================Methods==========================================
+    /**
+     * 获得下一个ID (该方法是线程安全的)
+     * @return SnowflakeId
+     */
+    public synchronized long nextId() {
+        long timestamp = timeGen();
+
+        //如果当前时间小于上一次ID生成的时间戳，说明系统时钟回退过这个时候应当抛出异常
+        if (timestamp < lastTimestamp) {
+            throw new RuntimeException(
+                    String.format("Clock moved backwards.  Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));
+        }
+
+        //如果是同一时间生成的，则进行毫秒内序列
+        if (lastTimestamp == timestamp) {
+            sequence = (sequence + 1) & sequenceMask;
+            //毫秒内序列溢出
+            if (sequence == 0) {
+                //阻塞到下一个毫秒,获得新的时间戳
+                timestamp = tilNextMillis(lastTimestamp);
+            }
+        }
+        //时间戳改变，毫秒内序列重置
+        else {
+            sequence = 0L;
+        }
+
+        //上次生成ID的时间截
+        lastTimestamp = timestamp;
+
+        //移位并通过或运算拼到一起组成64位的ID
+        return ((timestamp - twepoch) << timestampLeftShift)
+                | (dataCenterId << dataCenterIdShift)
+                | (workerId << workerIdShift)
+                | sequence;
+    }
+
+    /**
+     * 阻塞到下一个毫秒，直到获得新的时间戳
+     * @param lastTimestamp 上次生成ID的时间截
+     * @return 当前时间戳
+     */
+    protected long tilNextMillis(long lastTimestamp) {
+        long timestamp = timeGen();
+        while (timestamp <= lastTimestamp) {
+            timestamp = timeGen();
+        }
+        return timestamp;
+    }
+
+    /**
+     * 返回以毫秒为单位的当前时间
+     * @return 当前时间(毫秒)
+     */
+    protected long timeGen() {
+        return System.currentTimeMillis();
+    }
+
+    private static Long getWorkId(){
+        try {
+            String hostAddress = Inet4Address.getLocalHost().getHostAddress();
+            int[] ints = StringUtils.toCodePoints(hostAddress);
+            int sums = 0;
+            for(int b : ints){
+                sums += b;
+            }
+            return (long)(sums % 32);
+        } catch (UnknownHostException e) {
+            // 如果获取失败，则使用随机数备用
+            return RandomUtils.nextLong(0,31);
+        }
+    }
+
+    private static Long getDataCenterId(){
+        int[] ints = StringUtils.toCodePoints(SystemUtils.getHostName());
+        int sums = 0;
+        for (int i: ints) {
+            sums += i;
+        }
+        return (long)(sums % 32);
+    }
+
+
+    /**
+     * 静态工具类
+     *
+     * @return
+     */
+    public static synchronized Long generateId(){
+        long id = idWorker.nextId();
+        return id;
+    }
+
+
+    public static synchronized String getNo(String prefix){
+        StringBuilder sb = new StringBuilder(prefix);
+        String currentTimeSSS = DateNewUtils.currentTimeSSS();
+        Random rd = new Random();
+        int randomInt = rd.nextInt(10);
+        sb.append(currentTimeSSS);
+        sb.append(randomInt);
+        return sb.toString();
+    }
+
+    public static void main(String[] args) {
+        for (int i = 0; i < 57; i++) {
+            Long id = SnowflakeIdWorker.generateId();
+            System.out.println(id);
+        }
+    }
+
+}

climate_data/pom.xml

@@ -29,7 +29,12 @@
             <artifactId>druid-spring-boot-starter</artifactId>
             <version>${druid.version}</version>
         </dependency>
-
+        <!-- mybatis-plus依赖 -->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.4.1</version>
+        </dependency>
         <!-- 解析客户端操作系统、浏览器等 -->
         <dependency>
             <groupId>eu.bitwalker</groupId>
@@ -145,8 +150,68 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-context</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.tianqin</groupId>
+            <artifactId>tianqin-sdk</artifactId>
+            <version>1.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.protobuf</groupId>
+            <artifactId>protobuf-sdk</artifactId>
+            <version>1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.13</version>
+        </dependency>
+
+        <!-- excel工具 -->
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi-ooxml</artifactId>
+            <version>${poi.version}</version>
+        </dependency>
+        <!-- JSON 解析器和生成器 -->
+        <dependency>
+            <groupId>com.alibaba.fastjson2</groupId>
+            <artifactId>fastjson2</artifactId>
+            <version>${fastjson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.78</version>
+        </dependency>
+
 
     </dependencies>
+    <build>
+        <resources>
+            <resource>
+                <directory>src/main/java</directory>
+                <includes>
+                    <include>**/*.properties</include>
+                    <include>**/*.xml</include>
+                </includes>
+                <filtering>false</filtering>
+            </resource>
+            <resource>
+                <directory>src/main/resources</directory>
+                <includes>
+                    <include>**/*.properties</include>
+                    <include>**/*.xml</include>
+                </includes>
+                <filtering>false</filtering>
+            </resource>
+        </resources>
+    </build>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

climate_data/src/main/java/com/climate/data/config/RestTemplateConfig.java

@@ -0,0 +1,13 @@
+package com.climate.data.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+@Component
+public class RestTemplateConfig {
+    @Bean
+    public RestTemplate restTemplateFeign() {
+        return new RestTemplate();
+    }
+}

climate_data/src/main/java/com/climate/data/domain/CliComfort.java

@@ -0,0 +1,27 @@
+package com.climate.data.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/**
+ * 气候舒适表里面包含人体舒适指数、气候度假指数
+ */
+@Data
+public class CliComfort {
+	/** 主键id */
+	private Long id;
+	/** 时间 */
+	@JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+	@DateTimeFormat(pattern="yyyy-MM-dd")
+	private Date dataTime;
+	/** 区县名 */
+	private String cnty;
+	/** 人体舒适指数 */
+	private Double peoComIndex;
+	/** 气候度假指数 */
+	private Double cliVacIndex;
+
+}

climate_data/src/main/java/com/climate/data/domain/CliTqStation.java

@@ -0,0 +1,27 @@
+package com.climate.data.domain;
+
+
+import lombok.Data;
+
+/**
+ * 天擎站点信息表
+ */
+@Data
+public class CliTqStation {
+	/** 主键id */
+	private Long id;
+	/** 站号 */
+	private String stationId;
+	/** 站名 */
+	private String stationName;
+	/** 省名 */
+	private String province;
+	/** 地市名 */
+	private String city;
+	/** 区县名 */
+	private String cnty;
+	/** 行政编码 */
+	private String adminCode;
+	/** 站的类型（0是国家站，1是区域站） */
+	private Integer type;
+}

climate_data/src/main/java/com/climate/data/domain/vo/TqParm.java

@@ -0,0 +1,116 @@
+package com.climate.data.domain.vo;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 参数实体
+ * @author yhy
+ */
+@Data
+public class TqParm {
+
+    /**
+     * 区站号(字符)
+     **/
+    private String distStationId;
+    /**
+     * 站名
+     **/
+    private String stationName;
+    /**
+     *
+     * */
+    private Integer pageNum;
+    /**
+     * 页面大小
+     * */
+    private Integer pageSize;
+
+    /**
+     * 传入查询时间
+     */
+    private String time;
+    /**
+     * 结束时间
+     */
+    private String endTime;
+    /**
+     * 开始时间
+     */
+    private String startTime;
+    /**
+     * 经度
+     */
+    private BigDecimal geomLongitu;
+
+    /**
+     * 纬度
+     */
+    private BigDecimal geomLatitu;
+
+    /**
+     * 根据站号集合查询站点信息的参数
+     */
+    private List<String> stationId;
+    /**
+     * 根据站号查询站点信息的参数
+     */
+    private String staId;
+
+    /**
+     * 起始经度
+     */
+    private String minLon;
+
+    /**
+     * 起始纬度
+     */
+    private String minLat;
+
+    /**
+     * 终止经度
+     */
+    private String maxLon;
+
+    /**
+     * 终止纬度
+     */
+    private String maxLat;
+
+    /**
+     * 风场数据请求时间
+     */
+    private String observedTime;
+
+    /**
+     * 区域码
+     * */
+    private String adminCodes;
+    /**
+     * 类型 0-存入降水数据 1-存入平均温度数据
+     * */
+    private int type;
+    /**
+     * 获取多少年数据
+     * */
+    private int years;
+    /**
+     * 等级预报天数
+     * */
+    private int foreDays;
+    /**
+     * 等级2.0需要时间
+     * 示例：2023-12-20 14:00:00
+     * */
+    private String foreTime;
+    /**
+     * 类型 1-风速 2-气温 3-湿度 4-雪深
+     * */
+    private  int num;
+    //  private Integer hour;
+
+}
+

climate_data/src/main/java/com/climate/data/mapper/CliComfortMapper.java

@@ -0,0 +1,67 @@
+package com.climate.data.mapper;
+
+import com.climate.data.domain.CliComfort;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+@Mapper
+public interface CliComfortMapper {
+
+	/**
+     * 查询所有记录
+     *
+     * @return 返回集合，没有返回空List
+     */
+	List<CliComfort> listAll();
+
+
+	/**
+     * 根据主键查询
+     *
+     * @param id 主键
+     * @return 返回记录，没有返回null
+     */
+	CliComfort getById(Long id);
+
+	/**
+     * 新增，插入所有字段
+     *
+     * @param cliComfort 新增的记录
+     * @return 返回影响行数
+     */
+	int insert(CliComfort cliComfort);
+
+	/**
+     * 新增，忽略null字段
+     *
+     * @param cliComfort 新增的记录
+     * @return 返回影响行数
+     */
+	int insertIgnoreNull(CliComfort cliComfort);
+
+	/**
+     * 修改，修改所有字段
+     *
+     * @param cliComfort 修改的记录
+     * @return 返回影响行数
+     */
+	int update(CliComfort cliComfort);
+
+	/**
+     * 修改，忽略null字段
+     *
+     * @param cliComfort 修改的记录
+     * @return 返回影响行数
+     */
+	int updateIgnoreNull(CliComfort cliComfort);
+
+	/**
+     * 删除记录
+     *
+     * @param cliComfort 待删除的记录
+     * @return 返回影响行数
+     */
+	int delete(CliComfort cliComfort);
+
+}

climate_data/src/main/java/com/climate/data/mapper/CliTqStationMapper.java

@@ -0,0 +1,79 @@
+package com.climate.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.climate.data.domain.CliTqStation;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @author
+ */
+@Mapper
+@Repository
+public interface CliTqStationMapper extends BaseMapper<CliTqStation> {
+
+	/**
+     * 查询所有记录
+     *
+     * @return 返回集合，没有返回空List
+     */
+	List<CliTqStation> listAll();
+
+
+	/**
+     * 根据主键查询
+     *
+     * @param id 主键
+     * @return 返回记录，没有返回null
+     */
+	CliTqStation getById(Long id);
+
+	/**
+     * 新增，插入所有字段
+     *
+     * @param cliTqStation 新增的记录
+     * @return 返回影响行数
+     */
+	int insertGeom(CliTqStation cliTqStation);
+	/**
+	 * 批量插入
+	 * @param cliTqStations
+	 * @return
+	 * */
+	int insertBatch(List<CliTqStation> cliTqStations);
+
+	/**
+     * 新增，忽略null字段
+     *
+     * @param cliTqStation 新增的记录
+     * @return 返回影响行数
+     */
+	int insertIgnoreNull(CliTqStation cliTqStation);
+
+	/**
+     * 修改，修改所有字段
+     *
+     * @param cliTqStation 修改的记录
+     * @return 返回影响行数
+     */
+	int update(CliTqStation cliTqStation);
+
+	/**
+     * 修改，忽略null字段
+     *
+     * @param cliTqStation 修改的记录
+     * @return 返回影响行数
+     */
+	int updateIgnoreNull(CliTqStation cliTqStation);
+
+	/**
+     * 删除记录
+     *
+     * @param cliTqStation 待删除的记录
+     * @return 返回影响行数
+     */
+	int delete(CliTqStation cliTqStation);
+
+}

climate_data/src/main/java/com/climate/data/run/ApplicationRunnerImpl.java

@@ -0,0 +1,28 @@
+package com.climate.data.run;
+
+import com.climate.data.utils.QueryClient;
+import com.climate.data.utils.QueryUtils;
+import com.climate.data.utils.TqConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class ApplicationRunnerImpl implements ApplicationRunner {
+    @Autowired
+    private TqConfig tqConfig;
+
+    @Override
+    public void run(ApplicationArguments args) {
+        log.info("初始化天擎--开始");
+        QueryClient queryClient = new QueryClient(tqConfig.getPath());
+        if(queryClient !=null){
+            QueryUtils queryUtils = new QueryUtils(queryClient);
+            log.info("初始化天擎--完成");
+        }
+    }
+
+}

climate_data/src/main/java/com/climate/data/service/CliComfortService.java

@@ -0,0 +1,11 @@
+package com.climate.data.service;
+
+/**
+ * @author 小p同学
+ */
+
+public interface CliComfortService {
+
+
+
+}

climate_data/src/main/java/com/climate/data/service/CliTqStationService.java

@@ -0,0 +1,32 @@
+package com.climate.data.service;
+
+import com.climate.data.domain.CliTqStation;
+
+import java.util.List;
+
+/**
+ * @author 小p同学
+ */
+
+public interface CliTqStationService {
+
+    /**
+     * 新增，插入所有字段
+     *
+     * @param cliTqStation 新增的记录
+     * @return 返回影响行数
+     */
+    int insertGeom(CliTqStation cliTqStation);
+
+    /**
+     * 批量插入
+     * @param cliTqStations
+     * @return
+     * */
+    int insertBatch(List<CliTqStation> cliTqStations);
+
+    /**
+     * 将贵州区域的区域站的所有站号信息写入数据库
+     * */
+    List<CliTqStation> listSta(String adminCodes);
+}

climate_data/src/main/java/com/climate/data/service/impl/CliComfortServiceImpl.java

@@ -0,0 +1,13 @@
+package com.climate.data.service.impl;
+
+import com.climate.data.service.CliComfortService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author 小p同学
+ */
+@Service
+@Slf4j
+public class CliComfortServiceImpl implements CliComfortService {
+}

climate_data/src/main/java/com/climate/data/service/impl/CliTqStationServiceImpl.java

@@ -0,0 +1,128 @@
+package com.climate.data.service.impl;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.climate.common.core.utils.SnowflakeIdWorker;
+import com.climate.data.domain.CliTqStation;
+import com.climate.data.mapper.CliTqStationMapper;
+import com.climate.data.service.CliTqStationService;
+import com.climate.data.utils.QueryUtils;
+import com.climate.data.utils.TqConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.ListUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @author 小p同学
+ */
+@Service
+@Slf4j
+public class CliTqStationServiceImpl implements CliTqStationService {
+    @Autowired
+    private CliTqStationMapper cliTqStationMapper;
+    @Autowired
+    private TqConfig tqConfig;
+
+    @Override
+    public int insertGeom(CliTqStation cliTqStation) {
+        return cliTqStationMapper.insertGeom(cliTqStation);
+    }
+
+    @Override
+    public int insertBatch(List<CliTqStation> cliTqStations) {
+        return cliTqStationMapper.insertBatch(cliTqStations);
+    }
+
+    @Override
+    public List<CliTqStation> listSta(String adminCodes) {
+        /** 2. 调用方法的参数定义，并赋值
+         /** 2.1  接口ID */
+        // 根据时间跟地区获取实时数据
+        String interfaceId = "getSurfEleInRegionByTime";
+
+        /** 2.2  接口参数，多个参数间无顺序 */
+        HashMap<String, String> params = new HashMap<String, String>();
+
+        /** 必选参数  资料代码 */
+        params.put("dataCode", "SURF_CHN_MUL_DAY");
+        /**
+         * 检索时间
+         * */
+        /**检索时间* */
+        params.put("times", "20240114000000");
+        // 检索站号
+        params.put("adminCodes", adminCodes);
+        /**
+         * 检索要素：、省名、地市名、站名、区县名、区站号(字符)、行政编码、经度、纬度
+         * */
+        params.put("elements", "Province,City,Station_Name,Cnty,Station_Id_C,Admin_Code_CHN");
+
+        /**
+         * 可选参数*/
+        /**排序：按照站号从小到大*/
+
+        /** 2.4 返回文件的格式 */
+        String dataFormat = "json";
+        /** 2.5 返回字符串 */
+        StringBuffer retStr = new StringBuffer();
+        List<JSONObject> objectList = new ArrayList<>();
+        // 返回出去的集合
+        List<CliTqStation> stationList = new ArrayList<>();
+        /** 3. 调用接口 */
+        try {
+            //调用接口
+            int rst = QueryUtils.queryClient.callAPI_to_serializedStr(tqConfig.getUsername(), tqConfig.getPassword(), interfaceId, params, dataFormat, retStr);
+            //输出结果
+            //正常返回
+            if (rst == 0) {
+                JSONObject json = JSONObject.parseObject(retStr.toString());
+                System.out.println(json);
+                objectList.add(json);
+                /**将原数据存入，再分别存其他字段*/
+                /**获取第一层键*/
+                JSONArray jsonArray = json.getJSONArray("DS");
+                for (Object o : jsonArray) {
+                    JSONObject jsonObject = JSONObject.parseObject(o.toString());
+                    CliTqStation station = new CliTqStation();
+                    // 手动获取无法自动处理的
+                    String province = jsonObject.getString("Province");
+                    String city = jsonObject.getString("City");
+                    String stationName = jsonObject.getString("Station_Name");
+                    String cnty = jsonObject.getString("Cnty");
+                    String stationIdC = jsonObject.getString("Station_Id_C");
+                    String adminCodeChn = jsonObject.getString("Admin_Code_CHN");
+                    station.setId(SnowflakeIdWorker.generateId());
+                    station.setProvince(province);
+                    station.setCity(city);
+                    station.setCnty(cnty);
+                    station.setStationId(stationIdC);
+                    station.setAdminCode(adminCodeChn);
+                    station.setStationName(stationName);
+                    station.setType(1);
+                    stationList.add(station);
+                }
+                //切分数据
+                List<List<CliTqStation>> partition = ListUtils.partition(stationList, 500);
+                System.out.println(partition);
+                for (int i = 0; i < partition.size(); i++) {
+                    List<CliTqStation> weaTqstaList = partition.get(i);
+                    int insert = cliTqStationMapper.insertBatch(weaTqstaList);
+                    if (insert > 0) {
+                        System.out.println("插入成功");
+                    } else {
+                        throw new RuntimeException("插入数据库失败");
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException("序列化失败");
+        }
+        return stationList;
+    }
+}

climate_data/src/main/java/com/climate/data/service/impl/tq.java

@@ -1,4 +0,0 @@
-package com.climate.data.service.impl;
-
-public class tq {
-}

climate_data/src/main/java/com/climate/data/service/tq.java

@@ -1,4 +0,0 @@
-package com.climate.data.service;
-
-public interface tq {
-}

climate_data/src/main/java/com/climate/data/utils/QueryClient.java

@@ -0,0 +1,785 @@
+package com.climate.data.utils;
+import cma.music.*;
+import cma.music.utils.CommHelper;
+import cma.music.utils.ConfigHelper;
+import cma.music.utils.HttpDownLoad;
+import com.alibaba.fastjson.JSON;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.*;
+
+/**
+ * @author 小p同学
+ */
+public class QueryClient {
+    /*static final String config = "D:\\ideaworksprace\\weather_service\\weather-modules\\weather-data\\client.config";*/
+    private static String basicUrl = "http://ip:port/music-ws/api?serviceNodeId=serverId&";
+    String config = null;
+    String serverIp = "";
+    String serverPort = "80";
+    int connTimeOut = 3000;
+    int readTimeOut = 900000;
+    String serverID = "NMIC_MUSIC_CMADAAS";
+    static final int OTHER_ERROR = -10001;
+    static String language = "JAVA";
+    static String clientVersion = "V2.0.0";
+    static String getwayFlag = "\"flag\":\"slb\"";
+    static final String serverKey = "music_server";
+    static final String portKey = "music_port";
+    static final String connTimeoutKey = "music_connTimeout";
+    static final String readTimeoutKey = "music_readTimeout";
+    static final String defaultServiceIdKey = "music_ServiceId";
+    static final String storeBackStageKey = "music_store_backstage";
+    static final String localMountKey = "music_local_mount";
+    static final String serverMountKey = "music_server_mount";
+    static int tick = 0;
+
+    public QueryClient(String path) {
+        this.config = path;
+    }
+
+
+    public void initResources() throws Exception {
+        File f = new File(this.config);
+        if (!f.exists()) {
+            throw new Exception("Error,client.config not exists  ");
+        } else {
+            this.readClientConfig(this.config);
+        }
+    }
+
+    public void initResources(String path) throws Exception {
+        File f = new File(path);
+        if (!f.exists()) {
+            throw new Exception("Error,client.config not exists  ");
+        } else {
+            this.readClientConfig(path);
+        }
+    }
+
+    public void initResources(String musicIp, String musicPort) throws Exception {
+        this.initResources();
+        if (musicIp != null && !musicIp.isEmpty()) {
+            this.serverIp = musicIp;
+        }
+
+        if (musicPort != null && !musicPort.isEmpty()) {
+            this.serverPort = musicPort;
+        }
+
+    }
+
+    public void initResources(String musicIp, String musicPort, int connTimeout, int readTimeout) throws Exception {
+        this.initResources();
+        if (musicIp != null && !musicIp.isEmpty()) {
+            this.serverIp = musicIp;
+        }
+
+        if (musicPort != null && !musicPort.isEmpty()) {
+            this.serverPort = musicPort;
+        }
+
+        if (connTimeout > 0 && connTimeout < 2147483647) {
+            this.connTimeOut = connTimeout * 1000;
+        }
+
+        if (readTimeout > 0 && readTimeout < 2147483647) {
+            this.readTimeOut = readTimeout * 1000;
+        }
+
+    }
+
+    public void destroyResources() {
+        ++tick;
+        if (tick > 50) {
+            System.gc();
+            tick = 0;
+        }
+
+    }
+
+    public int callAPI_to_array2D(String userId, String pwd, String interfaceId, HashMap<String, String> params, RetArray2D retArray2D) {
+        return this.callAPI_to_array2D(userId, pwd, interfaceId, (String) null, params, retArray2D);
+    }
+
+    public int callAPI_to_array2D(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, RetArray2D retArray2D) {
+        String method = "callAPI_to_array2D";
+
+        int retCode;
+        try {
+            List<byte[]> retBytes = new ArrayList();
+            this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = (byte[]) retBytes.get(0);
+
+            String retStr = new String(buf);
+            if (retStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retArray2D.setRequestInfo(new RequestInfo());
+                retArray2D.getRequestInfo().setErrorCode(retCode);
+                retArray2D.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+            } else {
+                Apiinterface.RetArray2D _retArray2D = Apiinterface.RetArray2D.parseFrom(buf);
+                RetArray2D retArray2d = null;
+                retArray2d = DataFormatChange.getArray2D(_retArray2D);
+                if (retArray2d != null) {
+                    retCode = retArray2d.getRequestInfo().getErrorCode();
+                    retArray2D.setRequestInfo(retArray2d.getRequestInfo());
+                    retArray2D.data = retArray2d.data;
+                    retArray2D.setCol(retArray2d.getCol());
+                    retArray2D.setRow(retArray2d.getRow());
+                    retArray2D.setElementNames(retArray2d.getElementNames());
+                } else {
+                    retCode = -10001;
+                    retArray2D.setRequestInfo(new RequestInfo());
+                    retArray2D.getRequestInfo().setErrorCode(-10001);
+                    retArray2D.getRequestInfo().setErrorMessage("error:DataFormatChange.getArray2D");
+                }
+
+                retBytes.clear();
+            }
+
+            retStr = null;
+        } catch (IOException var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retArray2D.setRequestInfo(new RequestInfo());
+            retArray2D.getRequestInfo().setErrorCode(-10001);
+            retArray2D.getRequestInfo().setErrorMessage(var14.getMessage());
+        } catch (Exception var15) {
+            var15.printStackTrace();
+            retCode = -10001;
+            retArray2D.setRequestInfo(new RequestInfo());
+            retArray2D.getRequestInfo().setErrorCode(-10001);
+            retArray2D.getRequestInfo().setErrorMessage(var15.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_gridArray2D(String userId, String pwd, String interfaceId, HashMap<String, String> params, RetGridArray2D retGridArray2D) {
+        return this.callAPI_to_gridArray2D(userId, pwd, interfaceId, (String) null, params, retGridArray2D);
+    }
+
+    public int callAPI_to_gridArray2D(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, RetGridArray2D retGridArray2D) {
+        RetGridArray2D retArray2d = null;
+        if (retGridArray2D == null) {
+            retGridArray2D = new RetGridArray2D();
+        }
+
+
+        String method = "callAPI_to_gridArray2D";
+
+        int retCode;
+        try {
+            List<byte[]> retBytes = new ArrayList();
+            this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = retBytes.get(0);
+            String retStr = new String(buf);
+            if (retStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retGridArray2D.setRequestInfo(new RequestInfo());
+                retGridArray2D.getRequestInfo().setErrorCode(retCode);
+                retGridArray2D.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+            } else {
+                Apiinterface.RetGridArray2D _retArray2D = Apiinterface.RetGridArray2D.parseFrom(buf);
+                retArray2d = DataFormatChange.getGridArray2D(_retArray2D);
+                if (retArray2d != null) {
+                    retCode = retArray2d.getRequestInfo().getErrorCode();
+                    retGridArray2D.setRequestInfo(retArray2d.getRequestInfo());
+                    retGridArray2D.data = retArray2d.data;
+                    retGridArray2D.setStartLat(retArray2d.getStartLat());
+                    retGridArray2D.setStartLon(retArray2d.getStartLon());
+                    retGridArray2D.setEndLat(retArray2d.getEndLat());
+                    retGridArray2D.setEndLon(retArray2d.getEndLon());
+                    retGridArray2D.setLatCount(retArray2d.getLatCount());
+                    retGridArray2D.setLonCount(retArray2d.getLonCount());
+                    retGridArray2D.setLonStep(retArray2d.getLonStep());
+                    retGridArray2D.setLatStep(retArray2d.getLatStep());
+                    retGridArray2D.setUnits(retArray2d.getUnits());
+                    retGridArray2D.setUserEleName(retArray2d.getUserEleName());
+                    retGridArray2D.setLats(retArray2d.getLats());
+                    retGridArray2D.setLons(retArray2d.getLons());
+                } else {
+                    retCode = -10001;
+                    retGridArray2D.setRequestInfo(new RequestInfo());
+                    retGridArray2D.getRequestInfo().setErrorCode(-10001);
+                    retGridArray2D.getRequestInfo().setErrorMessage("error:DataFormatChange.getGridArray2D");
+                }
+
+                retBytes.clear();
+            }
+
+            retStr = null;
+        } catch (Exception var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retGridArray2D.setRequestInfo(new RequestInfo());
+            retGridArray2D.getRequestInfo().setErrorCode(-10001);
+            retGridArray2D.getRequestInfo().setErrorMessage(var14.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_gridScalar2D(String userId, String pwd, String interfaceId, HashMap<String, String> params, RetGridScalar2D retGridArray2D) {
+        return this.callAPI_to_gridScalar2D(userId, pwd, interfaceId, (String) null, params, retGridArray2D);
+    }
+
+    public int callAPI_to_gridScalar2D(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, RetGridScalar2D retGridArray2D) {
+        RetGridScalar2D retArray2d = null;
+        if (retGridArray2D == null) {
+            retGridArray2D = new RetGridScalar2D();
+        }
+
+        String method = "callAPI_to_gridScalar2D";
+
+        int retCode;
+        try {
+            List<byte[]> retBytes = new ArrayList();
+            this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = retBytes.get(0);
+            String retStr = new String(buf);
+            if (retStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retGridArray2D.setRequestInfo(new RequestInfo());
+                retGridArray2D.getRequestInfo().setErrorCode(retCode);
+                retGridArray2D.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+            } else {
+                Apiinterface.RetGridScalar2D _retArray2D = Apiinterface.RetGridScalar2D.parseFrom(buf);
+                retArray2d = DataFormatChange.getGridScalar2D(_retArray2D);
+                if (retArray2d != null) {
+                    retCode = retArray2d.getRequestInfo().getErrorCode();
+                    retGridArray2D.setRequestInfo(retArray2d.getRequestInfo());
+                    retGridArray2D.setDatas(retArray2d.getDatas());
+                    retGridArray2D.setEndLat(retArray2d.getEndLat());
+                    retGridArray2D.setEndLon(retArray2d.getEndLon());
+                    retGridArray2D.setStartLat(retArray2d.getStartLat());
+                    retGridArray2D.setStartLon(retArray2d.getStartLon());
+                    retGridArray2D.setLatCount(retArray2d.getLatCount());
+                    retGridArray2D.setLonCount(retArray2d.getLonCount());
+                    retGridArray2D.setLonStep(retArray2d.getLonStep());
+                    retGridArray2D.setLatStep(retArray2d.getLatStep());
+                    retGridArray2D.setUnits(retArray2d.getUnits());
+                    retGridArray2D.setUserEleName(retArray2d.getUserEleName());
+                    retGridArray2D.setLats(retArray2d.getLats());
+                    retGridArray2D.setLons(retArray2d.getLons());
+                } else {
+                    retCode = -10001;
+                    retGridArray2D.setRequestInfo(new RequestInfo());
+                    retGridArray2D.getRequestInfo().setErrorCode(-10001);
+                    retGridArray2D.getRequestInfo().setErrorMessage("error:DataFormatChange.getGridScalar2D");
+                }
+
+                retBytes.clear();
+            }
+
+            retStr = null;
+        } catch (Exception var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retGridArray2D.setRequestInfo(new RequestInfo());
+            retGridArray2D.getRequestInfo().setErrorCode(-10001);
+            retGridArray2D.getRequestInfo().setErrorMessage(var14.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_gridVector2D(String userId, String pwd, String interfaceId, HashMap<String, String> params, RetGridVector2D retGridArray2D) {
+        return this.callAPI_to_gridVector2D(userId, pwd, interfaceId, (String) null, params, retGridArray2D);
+    }
+
+    public int callAPI_to_gridVector2D(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, RetGridVector2D retGridArray2D) {
+        RetGridVector2D retArray2d = null;
+        if (retGridArray2D == null) {
+            retGridArray2D = new RetGridVector2D();
+        }
+
+        String method = "callAPI_to_gridVector2D";
+
+        int retCode;
+        try {
+            List<byte[]> retBytes = new ArrayList();
+            this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = retBytes.get(0);
+            ;
+            String retStr = new String(buf);
+            if (retStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retGridArray2D.setRequestInfo(new RequestInfo());
+                retGridArray2D.getRequestInfo().setErrorCode(retCode);
+                retGridArray2D.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+            } else {
+                Apiinterface.RetGridVector2D _retArray2D = Apiinterface.RetGridVector2D.parseFrom(buf);
+                retArray2d = DataFormatChange.getGridVector2D(_retArray2D);
+                if (retArray2d != null) {
+                    retCode = retArray2d.getRequestInfo().getErrorCode();
+                    retGridArray2D.setU_datas(retArray2d.getU_datas());
+                    retGridArray2D.setV_datas(retArray2d.getV_datas());
+                    retGridArray2D.setRequestInfo(retArray2d.getRequestInfo());
+                    retGridArray2D.setEndLat(retArray2d.getEndLat());
+                    retGridArray2D.setEndLon(retArray2d.getEndLon());
+                    retGridArray2D.setStartLat(retArray2d.getStartLat());
+                    retGridArray2D.setStartLon(retArray2d.getStartLon());
+                    retGridArray2D.setLatCount(retArray2d.getLatCount());
+                    retGridArray2D.setLonCount(retArray2d.getLonCount());
+                    retGridArray2D.setLonStep(retArray2d.getLonStep());
+                    retGridArray2D.setLatStep(retArray2d.getLatStep());
+                    retGridArray2D.setU_EleName(retArray2d.getU_EleName());
+                    retGridArray2D.setV_EleName(retArray2d.getV_EleName());
+                    retGridArray2D.setLats(retArray2d.getLats());
+                    retGridArray2D.setLons(retArray2d.getLons());
+                } else {
+                    retCode = -10001;
+                    retGridArray2D.setRequestInfo(new RequestInfo());
+                    retGridArray2D.getRequestInfo().setErrorCode(-10001);
+                    retGridArray2D.getRequestInfo().setErrorMessage("error:DataFormatChange.getGridVector2D");
+                }
+
+                retBytes.clear();
+            }
+
+            retStr = null;
+        } catch (Exception var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retGridArray2D.setRequestInfo(new RequestInfo());
+            retGridArray2D.getRequestInfo().setErrorCode(-10001);
+            retGridArray2D.getRequestInfo().setErrorMessage(var14.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_fileList(String userId, String pwd, String interfaceId, HashMap<String, String> params, RetFilesInfo retFilesInfo) {
+        return this.callAPI_to_fileList(userId, pwd, interfaceId, (String) null, params, retFilesInfo);
+    }
+
+    public int callAPI_to_fileList(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, RetFilesInfo retFilesInfo) {
+        RetFilesInfo retFileList = null;
+        if (retFilesInfo == null) {
+            retFilesInfo = new RetFilesInfo();
+        }
+
+
+        String method = "callAPI_to_fileList";
+
+        int retCode;
+        try {
+            List<byte[]> retBytes = new ArrayList();
+            this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = retBytes.get(0);
+            String retStr = new String(buf);
+            if (retStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retFilesInfo.setRequestInfo(new RequestInfo());
+                retFilesInfo.getRequestInfo().setErrorCode(retCode);
+                retFilesInfo.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+            } else {
+                Apiinterface.RetFilesInfo _pbResult = Apiinterface.RetFilesInfo.parseFrom(buf);
+                retFileList = DataFormatChange.getRetFilesInfo(_pbResult);
+                if (retFileList != null) {
+                    retCode = retFileList.getRequestInfo().getErrorCode();
+                    retFilesInfo.setRequestInfo(retFileList.getRequestInfo());
+                    retFilesInfo.fileInfos = retFileList.fileInfos;
+                    retFilesInfo.setCount(retFileList.getCount());
+                } else {
+                    retCode = -10001;
+                    retFilesInfo.setRequestInfo(new RequestInfo());
+                    retFilesInfo.getRequestInfo().setErrorCode(-10001);
+                    retFilesInfo.getRequestInfo().setErrorMessage("error:DataFormatChange.getRetFilesInfo");
+                }
+
+                retBytes.clear();
+            }
+
+            retStr = null;
+        } catch (Exception var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retFilesInfo.setRequestInfo(new RequestInfo());
+            retFilesInfo.getRequestInfo().setErrorCode(-10001);
+            retFilesInfo.getRequestInfo().setErrorMessage(var14.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_serializedStr(String userId, String pwd, String interfaceId, HashMap<String, String> params, String dataFormat, StringBuffer retStr) {
+        return this.callAPI_to_serializedStr(userId, pwd, interfaceId, (String) null, params, dataFormat, retStr);
+    }
+
+    public int callAPI_to_serializedStr(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, String dataFormat, StringBuffer retStr) {
+
+        String method = "callAPI_to_serializedStr";
+        params.put("dataFormat", dataFormat);
+
+        int retCode;
+        try {
+            List<byte[]> retBytes = new ArrayList();
+            retCode = this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = retBytes.get(0);
+            String retValStr = new String(buf);
+            if (retValStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retValStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retStr.append(retGetway.getReturnMessage());
+            } else {
+                String retStrValue = new String(buf, "UTF-8");
+                retStr.append(retStrValue);
+                retBytes.clear();
+            }
+
+            retValStr = null;
+        } catch (Exception var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retStr.append(var14.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_saveAsFile(String userId, String pwd, String interfaceId, HashMap<String, String> params, String dataFormat, String savePath, RetFilesInfo retFilesInfo) {
+        return this.callAPI_to_saveAsFile(userId, pwd, interfaceId, (String) null, params, dataFormat, savePath, retFilesInfo);
+    }
+
+    public int callAPI_to_saveAsFile(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, String dataFormat, String savePath, RetFilesInfo retFilesInfo) {
+        int retCode = -10001;
+        RetFilesInfo retFileList = null;
+        if (retFilesInfo == null) {
+            retFilesInfo = new RetFilesInfo();
+        }
+
+        if (savePath != null && savePath.length() >= 1) {
+            CommHelper.createDir(savePath);
+            params.put("savePath", savePath);
+            params.put("dataFormat", dataFormat);
+            String method = "callAPI_to_saveAsFile";
+            try {
+                List<byte[]> retBytes = new ArrayList();
+                this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+                byte[] buf = retBytes.get(0);;
+                String retStr = new String(buf);
+                if (retStr.contains(getwayFlag)) {
+                    RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                    retCode = retGetway.getReturnCode();
+                    retFilesInfo.setRequestInfo(new RequestInfo());
+                    retFilesInfo.getRequestInfo().setErrorCode(retCode);
+                    retFilesInfo.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+                } else {
+                    Apiinterface.RetFilesInfo _pbResult = Apiinterface.RetFilesInfo.parseFrom(buf);
+                    retFileList = DataFormatChange.getRetFilesInfo(_pbResult);
+                    if (retFileList != null) {
+                        retCode = retFileList.getRequestInfo().getErrorCode();
+                        retFilesInfo.fileInfos = retFileList.fileInfos;
+                        retFilesInfo.setRequestInfo(retFileList.getRequestInfo());
+                        retFilesInfo.setCount(retFileList.getCount());
+                    } else {
+                        retCode = -10001;
+                        retFilesInfo.setRequestInfo(new RequestInfo());
+                        retFilesInfo.getRequestInfo().setErrorCode(-10001);
+                        retFilesInfo.getRequestInfo().setErrorMessage("error:DataFormatChange.getRetFilesInfo");
+                    }
+
+                    retBytes.clear();
+                }
+
+                retStr = null;
+            } catch (Exception var16) {
+                var16.printStackTrace();
+                retCode = -10001;
+                retFilesInfo.setRequestInfo(new RequestInfo());
+                retFilesInfo.getRequestInfo().setErrorCode(-10001);
+                retFilesInfo.getRequestInfo().setErrorMessage(var16.getMessage());
+            }
+
+            if (retCode == 0) {
+                String fileurl = retFilesInfo.fileInfos[0].getFileUrl();
+                boolean ret = HttpDownLoad.httpDownload(fileurl, savePath);
+                if (ret) {
+                    retCode = 0;
+                } else {
+                    retFilesInfo.getRequestInfo().setErrorCode(-10001);
+                    retFilesInfo.getRequestInfo().setErrorMessage("error,httpDownload file:" + fileurl);
+                }
+            }
+
+            return retCode;
+        } else {
+            System.out.println("error:savePath can't is null");
+            retFilesInfo.setRequestInfo(new RequestInfo());
+            retFilesInfo.getRequestInfo().setErrorCode(retCode);
+            retFilesInfo.getRequestInfo().setErrorMessage("error:savePath can't is null,the format is dir/file.formart(ex. /data/saveas.xml)");
+            return retCode;
+        }
+    }
+
+    public int callAPI_to_downFile(String userId, String pwd, String interfaceId, HashMap<String, String> params, String saveDir, RetFilesInfo retFilesInfo) {
+        return this.callAPI_to_downFile(userId, pwd, interfaceId, (String) null, params, saveDir, retFilesInfo);
+    }
+
+    public int callAPI_to_downFile(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, String saveDir, RetFilesInfo retFilesInfo) {
+        CommHelper.createDir(saveDir);
+        CommHelper.createSingleDir(saveDir);
+        int retCode = this.callAPI_to_fileList(userId, pwd, interfaceId, serverID, params, retFilesInfo);
+        if (retCode == 0 && retFilesInfo != null) {
+            FileInfo[] var12;
+            int var11 = (var12 = retFilesInfo.fileInfos).length;
+
+            for (int var10 = 0; var10 < var11; ++var10) {
+                FileInfo fileinfo = var12[var10];
+                String fileURL = fileinfo.getFileUrl();
+                String savePath = saveDir + fileinfo.getFileName();
+                if (!HttpDownLoad.httpDownload(fileURL, savePath)) {
+                    retCode = -10001;
+                    retFilesInfo.getRequestInfo().setErrorCode(-10001);
+                    retFilesInfo.getRequestInfo().setErrorMessage("download file error,fileURL=" + fileURL + "savePath=" + savePath);
+                    break;
+                }
+            }
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_dataBlock(String userId, String pwd, String interfaceId, HashMap<String, String> params, RetDataBlock retDataBlock) {
+        return this.callAPI_to_dataBlock(userId, pwd, interfaceId, (String) null, params, retDataBlock);
+    }
+
+    public int callAPI_to_dataBlock(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, RetDataBlock retDataBlock) {
+        RetDataBlock dataBlock = null;
+        if (retDataBlock == null) {
+            retDataBlock = new RetDataBlock();
+        }
+
+        String method = "callAPI_to_dataBlock";
+
+        int retCode;
+        try {
+
+            List<byte[]> retBytes = new ArrayList();
+            this.getQueryBytes(userId, pwd, interfaceId, serverID, params, method, retBytes);
+            byte[] buf = (byte[]) retBytes.get(0);
+            String retStr = new String(buf);
+            if (retStr.contains(getwayFlag)) {
+                RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                retCode = retGetway.getReturnCode();
+                retDataBlock.setRequestInfo(new RequestInfo());
+                retDataBlock.getRequestInfo().setErrorCode(retCode);
+                retDataBlock.getRequestInfo().setErrorMessage(retGetway.getReturnMessage());
+            } else {
+                Apiinterface.RetDataBlock _retDataBlock = Apiinterface.RetDataBlock.parseFrom(buf);
+                dataBlock = DataFormatChange.getRetDataBlock(_retDataBlock);
+                if (dataBlock != null) {
+                    retCode = dataBlock.getRequestInfo().getErrorCode();
+                    retDataBlock.setByteArray(dataBlock.getByteArray());
+                    retDataBlock.setDataName(dataBlock.getDataName());
+                    retDataBlock.setRequestInfo(dataBlock.getRequestInfo());
+                } else {
+                    retCode = -10001;
+                    retDataBlock.setRequestInfo(new RequestInfo());
+                    retDataBlock.getRequestInfo().setErrorCode(retCode);
+                    retDataBlock.getRequestInfo().setErrorMessage("error:DataFormatChange.getRetDataBlock");
+                }
+
+                retBytes.clear();
+            }
+
+            retStr = null;
+        } catch (Exception var14) {
+            var14.printStackTrace();
+            retCode = -10001;
+            retDataBlock.setRequestInfo(new RequestInfo());
+            retDataBlock.getRequestInfo().setErrorCode(retCode);
+            retDataBlock.getRequestInfo().setErrorMessage(var14.getMessage());
+        }
+
+        return retCode;
+    }
+
+    public int callAPI_to_downFile_ByUrl(String fileURL, String save_as) {
+        int errorCode = -10001;
+        if (fileURL != null && !fileURL.isEmpty() && save_as != null && !save_as.isEmpty()) {
+            if (HttpDownLoad.httpDownload(fileURL, save_as)) {
+                errorCode = 0;
+            } else {
+                System.out.println("下载文件失败");
+            }
+        } else {
+            System.out.println("下载文件url或保存路径为空");
+        }
+
+        return errorCode;
+    }
+
+    public byte[] callAPI_to_downFileByte(String fileURL) {
+        byte[] buffer = null;
+        if (fileURL != null && fileURL.length() != 0) {
+            try {
+                buffer = HttpDownLoad.httpDownloadByte(fileURL);
+                String retStr = new String(buffer);
+                if (retStr.contains(getwayFlag)) {
+                    RetGetway retGetway = (RetGetway) JSON.parseObject(retStr, RetGetway.class);
+                    System.out.println("slb error:returnCode=" + retGetway.getReturnCode() + " returnMessage=" + retGetway.getReturnMessage());
+                    return null;
+                }
+            } catch (Exception var5) {
+                var5.printStackTrace();
+                return null;
+            }
+        }
+
+        return buffer;
+    }
+
+    private int getQueryBytes(String userId, String pwd, String interfaceId, String serverID, HashMap<String, String> params, String method, List<byte[]> retBytes) throws Exception, IOException {
+
+        if (serverID == null || serverID.isEmpty()) {
+            serverID = this.serverID;
+        }
+
+        String url = basicUrl;
+        url = url.replace("ip", this.serverIp);
+        url = url.replace("port", this.serverPort);
+        url = url.replace("serverId", serverID);
+        StringBuilder newUrl = new StringBuilder(url);
+        newUrl.append("method=" + method);
+        newUrl.append("&language=" + language);
+        newUrl.append("&clientversion=" + clientVersion);
+        newUrl.append("&userId=" + userId);
+        newUrl.append("&interfaceid=" + interfaceId);
+        if (params == null) {
+            throw new Exception("error,params is null");
+        } else {
+            Iterator var12 = params.keySet().iterator();
+
+            String key;
+            while (var12.hasNext()) {
+                key = (String) var12.next();
+                if (key != null && !key.trim().equalsIgnoreCase("")) {
+                    newUrl.append("&" + key.trim()).append("=" + ((String) params.get(key)).trim());
+                }
+            }
+
+            key = String.valueOf(System.currentTimeMillis());
+            String nonce = UUID.randomUUID().toString();
+            newUrl.append("&timestamp=").append(key);
+            newUrl.append("&nonce=").append(nonce);
+            HashMap<String, String> signParam = new HashMap();
+            signParam.putAll(params);
+            signParam.put("serviceNodeId", serverID);
+            signParam.put("method", method);
+            signParam.put("language", language);
+            signParam.put("clientversion", clientVersion);
+            signParam.put("userId", userId);
+            signParam.put("interfaceid", interfaceId);
+            signParam.put("timestamp", key);
+            signParam.put("nonce", nonce);
+            signParam.put("pwd", pwd);
+            String sign = CommHelper.getSign(signParam);
+            if (sign.equals("")) {
+                throw new Exception("generate sign error");
+            } else {
+                newUrl.append("&sign=").append(sign);
+                CloseableHttpClient httpClient = HttpClients.createDefault();
+                HttpGet httpGet = new HttpGet(newUrl.toString());
+                CloseableHttpResponse response = null;
+
+                byte retCode;
+                try {
+                    RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(this.connTimeOut).setSocketTimeout(this.readTimeOut).build();
+                    httpGet.setConfig(requestConfig);
+                    response = httpClient.execute(httpGet);
+                    HttpEntity entity = response.getEntity();
+                    int stateCode = response.getStatusLine().getStatusCode();
+                    if (stateCode != 200) {
+                        throw new Exception(response.getStatusLine().getReasonPhrase());
+                    }
+
+                    byte[] buf = EntityUtils.toByteArray(entity);
+                    retBytes.add(buf);
+                    retCode = 0;
+                } catch (IOException var29) {
+                    throw var29;
+                } finally {
+                    try {
+                        if (response != null) {
+                            response.close();
+                        }
+
+                        if (httpClient != null) {
+                            httpClient.close();
+                        }
+                    } catch (Exception var28) {
+                        var28.printStackTrace();
+                    }
+
+                }
+
+                return retCode;
+            }
+        }
+    }
+
+    private boolean readClientConfig(String path) throws Exception {
+        ConfigHelper.initProperties(path);
+        String value = ConfigHelper.getProperty("music_server");
+        if (value != null && value.length() > 3) {
+            this.serverIp = value.trim();
+            value = ConfigHelper.getProperty("music_port");
+            if (value != null && !value.equalsIgnoreCase("")) {
+                this.serverPort = value.trim();
+            } else {
+                this.serverPort = "80";
+            }
+
+            value = ConfigHelper.getProperty("music_connTimeout");
+            int ivalue;
+            if (value != null && !value.equalsIgnoreCase("")) {
+                try {
+                    ivalue = Integer.parseInt(value.trim());
+                    if (ivalue > 0 && ivalue < 2147483647) {
+                        this.connTimeOut = ivalue * 1000;
+                    }
+                } catch (Exception var5) {
+                    var5.printStackTrace();
+                }
+            }
+
+            value = ConfigHelper.getProperty("music_readTimeout");
+            if (value != null && !value.equalsIgnoreCase("")) {
+                try {
+                    ivalue = Integer.parseInt(value.trim());
+                    if (ivalue > 0 && ivalue < 2147483647) {
+                        this.readTimeOut = ivalue * 1000;
+                    }
+                } catch (Exception var4) {
+                    var4.printStackTrace();
+                }
+            }
+
+            value = ConfigHelper.getProperty("music_ServiceId");
+            if (value != null && !value.equalsIgnoreCase("")) {
+                this.serverID = value.trim();
+            }
+
+            return true;
+        } else {
+            throw new Exception("Error:can't find music_server value in client.config");
+        }
+    }
+}

climate_data/src/main/java/com/climate/data/utils/QueryUtils.java

@@ -0,0 +1,21 @@
+package com.climate.data.utils;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class QueryUtils {
+    private static final Logger log = LoggerFactory.getLogger(QueryUtils.class);
+
+    public static QueryClient queryClient;
+
+    public QueryUtils(QueryClient queryClient) {
+        QueryUtils.queryClient = queryClient;
+        //初始化接口服务连接资源
+        try {
+            queryClient.initResources();
+        } catch (Exception e) {
+            log.error("天擎初始化接口服务连接资源失败！");
+        }
+
+    }
+}

climate_data/src/main/java/com/climate/data/utils/TqConfig.java

@@ -0,0 +1,27 @@
+package com.climate.data.utils;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+@Component
+@Data
+public class TqConfig {
+    /**
+     * 调取天擎接口的用户名
+     * */
+    @Value("${tq.name}")
+    private String username;
+    /**
+     * 调取天擎接口的密码
+     * */
+    @Value("${tq.password}")
+    private String password;
+    /**
+     * sdk配置文件的路径
+     * */
+    @Value("${tq.clientpath}")
+    private String path;
+
+
+}

climate_data/src/main/resources/mapper.data/CliComfortMapper.xml

@@ -0,0 +1,7 @@
+<?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.climate.data.mapper.CliComfortMapper">
+
+
+
+</mapper>

climate_data/src/main/resources/mapper.data/CliTqStationMapper.xml

@@ -0,0 +1,56 @@
+<?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.climate.data.mapper.CliTqStationMapper">
+
+
+
+    <!-- 插入数据 -->
+    <insert id="insertGeom">
+        INSERT INTO "cli_tq_station" (
+            "id",
+            "station_id",
+            "station_name",
+            "province",
+            "city",
+            "cnty",
+            "type"
+        ) VALUES (
+                     #{id},
+                     #{stationId},
+                     #{stationName},
+                     #{province},
+                     #{city},
+                     #{cnty},
+                     #{adminCode},
+                     #{type}
+                 )
+
+    </insert>
+
+    <!-- 批量插入数据 -->
+    <insert id="insertBatch">
+        INSERT INTO "cli_tq_station" (
+        "id",
+        "station_id",
+        "station_name",
+        "province",
+        "city",
+        "cnty",
+        "admin_code",
+        "type"
+        ) VALUES
+        <foreach collection="list" item="item" separator=",">
+            (
+            #{item.id},
+            #{item.stationId},
+            #{item.stationName},
+            #{item.province},
+            #{item.city},
+            #{item.cnty},
+            #{item.adminCode},
+            #{item.type}
+            )
+        </foreach>
+    </insert>
+
+</mapper>

pom.xml

@@ -170,6 +170,56 @@
                 <version>${climate.version}</version>
             </dependency>
 
+            <dependency>
+                <groupId>com.tianqin</groupId>
+                <artifactId>tianqin-sdk</artifactId>
+                <version>1.0</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.protobuf</groupId>
+                <artifactId>protobuf-sdk</artifactId>
+                <version>1.0</version>
+            </dependency>
+
+            <!-- https://mvnrepository.com/artifact/commons-net/commons-net -->
+            <dependency>
+                <groupId>commons-net</groupId>
+                <artifactId>commons-net</artifactId>
+                <version>3.6</version>
+            </dependency>
+
+            <!-- mybatis-plus依赖 -->
+            <dependency>
+                <groupId>com.baomidou</groupId>
+                <artifactId>mybatis-plus-boot-starter</artifactId>
+                <version>3.4.1</version>
+            </dependency>
+            <!-- 引入 Apache 的 commons-lang3 包，方便操作字符串-->
+            <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
+            <dependency>
+                <groupId>org.apache.commons</groupId>
+                <artifactId>commons-lang3</artifactId>
+                <version>3.8</version>
+            </dependency>
+
+            <!-- 引入 Apache commons-io 包，方便操作文件-->
+            <!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
+            <dependency>
+                <groupId>commons-io</groupId>
+                <artifactId>commons-io</artifactId>
+                <version>2.6</version>
+            </dependency>
+            <dependency>
+                <groupId>org.assertj</groupId>
+                <artifactId>assertj-core</artifactId>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.xmlgraphics</groupId>
+                <artifactId>batik-css</artifactId>
+                <version>1.14</version>
+                <scope>compile</scope>
+            </dependency>
         </dependencies>
     </dependencyManagement>