第一次上传

pom.xml

@@ -0,0 +1,132 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.hw</groupId>
+    <artifactId>pull-openpricedata</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.2.10.RELEASE</version>
+    </parent>
+
+    <dependencies>
+        <!--<dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starters</artifactId>
+            <version>2.2.11.RELEASE</version>
+        </dependency>-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <version>2.2.10.RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid</artifactId>
+            <version>1.2.2</version>
+        </dependency>
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper-spring-boot-starter</artifactId>
+            <version>1.3.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>2.1.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis</artifactId>
+            <version>3.5.5</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.74</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+        </dependency>
+
+        <!-- swagger2 -->
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger2</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger-ui</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <!-- 自生产代码配置 -->
+            <plugin>
+                <groupId>org.mybatis.generator</groupId>
+                <artifactId>mybatis-generator-maven-plugin</artifactId>
+                <version>1.3.5</version>
+                <dependencies>
+                    <dependency>
+                        <groupId> mysql</groupId>
+                        <artifactId> mysql-connector-java</artifactId>
+                        <version>5.1.39</version>
+                    </dependency>
+                    <dependency>
+                        <groupId>org.mybatis.generator</groupId>
+                        <artifactId>mybatis-generator-core</artifactId>
+                        <version>1.3.5</version>
+                    </dependency>
+                </dependencies>
+                <executions>
+                    <execution>
+                        <id>Generate MyBatis Artifacts</id>
+                        <phase>deploy</phase>
+                        <goals>
+                            <goal>generate</goal>
+                        </goals>
+                    </execution>
+                </executions>
+                <configuration>
+                    <!--允许移动生成的文件 -->
+                    <verbose>true</verbose>
+                    <!-- 是否覆盖 -->
+                    <overwrite>true</overwrite>
+                    <!-- 自动生成的配置 -->
+                    <configurationFile>src/main/resources/generatorConfig.xml</configurationFile>
+                </configuration>
+            </plugin>
+
+            <!-- 打包方式 -->
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

src/main/java/com/hw/PullApplication.java

@@ -0,0 +1,16 @@
+package com.hw;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@MapperScan(basePackages = {"com.hw.dao"})
+@EnableScheduling
+@SpringBootApplication
+public class PullApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(PullApplication.class);
+    }
+}

src/main/java/com/hw/config/SwaggerConfig.java

@@ -0,0 +1,41 @@
+package com.hw.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.builders.ApiInfoBuilder;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+@Configuration
+@EnableSwagger2
+public class SwaggerConfig {
+
+    //api接口包扫描路径
+    public static final String SWAGGER_SCAN_BASE_PACKAGE = "com.hw";
+
+    public static final String VERSION = "1.0.0";
+
+    @Bean
+    public Docket createRestApi() {
+        return new Docket(DocumentationType.SWAGGER_2)
+                .apiInfo(apiInfo())
+                .select()
+                .apis(RequestHandlerSelectors.basePackage(SWAGGER_SCAN_BASE_PACKAGE))
+                //.apis(RequestHandlerSelectors.any())
+                .paths(PathSelectors.any()) // 可以根据url路径设置哪些请求加入文档，忽略哪些请求
+                .build();
+    }
+
+    private ApiInfo apiInfo() {
+        return new ApiInfoBuilder()
+                .title("系统api接口文档") //设置文档的标题
+                .description("系统api接口文档") // 设置文档的描述
+                .version(VERSION) // 设置文档的版本信息-> 1.0.0 Version information
+                .termsOfServiceUrl("API TERMS URL") // 设置文档的License信息->1.3 License information
+                .build();
+    }
+}

src/main/java/com/hw/controller/GzPricesController.java

@@ -0,0 +1,29 @@
+package com.hw.controller;
+
+import com.hw.schedule.GzPricesSchedule;
+import io.swagger.annotations.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/prices")
+@Api(description = "同步数据管理")
+public class GzPricesController {
+
+    @Autowired
+    private GzPricesSchedule gzPricesSchedule;
+
+    @ApiOperation(value = "同步贵州省政府数据开放平台数据",notes = "同步贵州省政府数据开放平台数据")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "authorization",value = "贵州省政府数据开放平台用户token",dataType = "String")
+    })
+    @ApiResponse(code = 0,message = "操作成功")
+    @GetMapping("/pullData")
+    public String pullData(String authorization){
+        String message = gzPricesSchedule.pullData(authorization);
+        return message;
+    }
+
+}

src/main/java/com/hw/dao/GzPriceTypeMapper.java

@@ -0,0 +1,35 @@
+package com.hw.dao;
+
+import com.hw.entity.GzPriceType;
+
+import java.util.List;
+
+public interface GzPriceTypeMapper {
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(GzPriceType record);
+
+    int insertSelective(GzPriceType record);
+
+    GzPriceType selectByPrimaryKey(Integer id);
+
+    int updateByPrimaryKeySelective(GzPriceType record);
+
+    int updateByPrimaryKey(GzPriceType record);
+
+    /**
+     * 查询列表
+     * lym
+     * @param gzPriceType
+     * @return
+     */
+    List<GzPriceType> selectList(GzPriceType gzPriceType);
+
+    /**
+     * 查询未同步上月的类别
+     * lym
+     * @param gzPriceType
+     * @return
+     */
+    List<GzPriceType> selectNotSynList(GzPriceType gzPriceType);
+}

src/main/java/com/hw/dao/GzPricesLogMapper.java

@@ -0,0 +1,17 @@
+package com.hw.dao;
+
+import com.hw.entity.GzPricesLog;
+
+public interface GzPricesLogMapper {
+    int deleteByPrimaryKey(Long id);
+
+    int insert(GzPricesLog record);
+
+    int insertSelective(GzPricesLog record);
+
+    GzPricesLog selectByPrimaryKey(Long id);
+
+    int updateByPrimaryKeySelective(GzPricesLog record);
+
+    int updateByPrimaryKey(GzPricesLog record);
+}

src/main/java/com/hw/dao/GzPricesMapper.java

@@ -0,0 +1,28 @@
+package com.hw.dao;
+
+import com.hw.entity.GzPrices;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface GzPricesMapper {
+    int deleteByPrimaryKey(Long id);
+
+    int insert(GzPrices record);
+
+    int insertSelective(GzPrices record);
+
+    GzPrices selectByPrimaryKey(Long id);
+
+    int updateByPrimaryKeySelective(GzPrices record);
+
+    int updateByPrimaryKey(GzPrices record);
+
+    /**
+     * 批量添加
+     * lym
+     * @param list
+     * @return
+     */
+    int batchSave(@Param("list") List<GzPrices> list);
+}

src/main/java/com/hw/entity/GzPriceType.java

@@ -0,0 +1,53 @@
+package com.hw.entity;
+
+public class GzPriceType {
+    private Integer id;
+
+    private Integer parentId;
+
+    private String name;
+
+    private String remark;
+
+    private Integer sort;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(Integer parentId) {
+        this.parentId = parentId;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name == null ? null : name.trim();
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark == null ? null : remark.trim();
+    }
+
+    public Integer getSort() {
+        return sort;
+    }
+
+    public void setSort(Integer sort) {
+        this.sort = sort;
+    }
+}

src/main/java/com/hw/entity/GzPrices.java

@@ -0,0 +1,135 @@
+package com.hw.entity;
+
+import java.util.Date;
+
+public class GzPrices {
+    private Long id;
+
+    private Integer fkPriceTypeId;
+
+    private String name;
+
+    private String price;
+
+    private String priceUnit;
+
+    private String market;
+
+    private String region;
+
+    private String updateTime;
+
+    private String specification;
+
+    private String dataOrigion;
+
+    private String priceType;
+
+    private String lable;
+
+    private Date createTime;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Integer getFkPriceTypeId() {
+        return fkPriceTypeId;
+    }
+
+    public void setFkPriceTypeId(Integer fkPriceTypeId) {
+        this.fkPriceTypeId = fkPriceTypeId;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name == null ? null : name.trim();
+    }
+
+    public String getPrice() {
+        return price;
+    }
+
+    public void setPrice(String price) {
+        this.price = price == null ? null : price.trim();
+    }
+
+    public String getPriceUnit() {
+        return priceUnit;
+    }
+
+    public void setPriceUnit(String priceUnit) {
+        this.priceUnit = priceUnit == null ? null : priceUnit.trim();
+    }
+
+    public String getMarket() {
+        return market;
+    }
+
+    public void setMarket(String market) {
+        this.market = market == null ? null : market.trim();
+    }
+
+    public String getRegion() {
+        return region;
+    }
+
+    public void setRegion(String region) {
+        this.region = region == null ? null : region.trim();
+    }
+
+    public String getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(String updateTime) {
+        this.updateTime = updateTime == null ? null : updateTime.trim();
+    }
+
+    public String getSpecification() {
+        return specification;
+    }
+
+    public void setSpecification(String specification) {
+        this.specification = specification == null ? null : specification.trim();
+    }
+
+    public String getDataOrigion() {
+        return dataOrigion;
+    }
+
+    public void setDataOrigion(String dataOrigion) {
+        this.dataOrigion = dataOrigion == null ? null : dataOrigion.trim();
+    }
+
+    public String getPriceType() {
+        return priceType;
+    }
+
+    public void setPriceType(String priceType) {
+        this.priceType = priceType == null ? null : priceType.trim();
+    }
+
+    public String getLable() {
+        return lable;
+    }
+
+    public void setLable(String lable) {
+        this.lable = lable == null ? null : lable.trim();
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+}

src/main/java/com/hw/entity/GzPricesLog.java

@@ -0,0 +1,55 @@
+package com.hw.entity;
+
+import java.util.Date;
+
+public class GzPricesLog {
+    private Long id;
+
+    private Integer fkPriceTypeId;
+
+    private String synTime;
+
+    private Integer synNum;
+
+    private Date createTime;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Integer getFkPriceTypeId() {
+        return fkPriceTypeId;
+    }
+
+    public void setFkPriceTypeId(Integer fkPriceTypeId) {
+        this.fkPriceTypeId = fkPriceTypeId;
+    }
+
+    public String getSynTime() {
+        return synTime;
+    }
+
+    public void setSynTime(String synTime) {
+        this.synTime = synTime == null ? null : synTime.trim();
+    }
+
+    public Integer getSynNum() {
+        return synNum;
+    }
+
+    public void setSynNum(Integer synNum) {
+        this.synNum = synNum;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+}

src/main/java/com/hw/schedule/GzPricesSchedule.java

@@ -0,0 +1,173 @@
+package com.hw.schedule;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.hw.entity.GzPriceType;
+import com.hw.entity.GzPrices;
+import com.hw.entity.GzPricesLog;
+import com.hw.service.GzPriceTypeService;
+import com.hw.service.GzPricesLogService;
+import com.hw.service.GzPricesService;
+import com.hw.util.EasyHttpUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.*;
+
+@Component
+public class GzPricesSchedule {
+
+    private Logger log = LoggerFactory.getLogger(GzPricesSchedule.class);
+
+    @Autowired
+    private GzPriceTypeService gzPriceTypeService;
+    @Autowired
+    private GzPricesService gzPricesService;
+    @Autowired
+    private GzPricesLogService gzPricesLogService;
+
+    @Value("${open.url}")
+    private String OPENURL;
+    @Value("${open.authorization}")
+    private String AUTHORIZATION;
+
+    /**
+     * 定时获取数据
+     * lym
+     */
+    @Scheduled(cron = "0 0 1,4 2,5,12,20 * ?")
+    public void schedulePullData(){
+        pullData(AUTHORIZATION);
+    }
+
+    /**
+     * 拉取数据
+     * @param authorization
+     */
+    public String pullData(String authorization){
+        log.info("开始获取上月分类价格数据"+ new Date());
+        GzPriceType gzPriceType = new GzPriceType();
+        List<GzPriceType> typeList = gzPriceTypeService.selectNotSynList(gzPriceType);
+        int synNum = 0;
+        if (typeList != null && typeList.size() > 0){
+            for (GzPriceType priceType:typeList){
+                String httpUrl = getUrl(priceType.getName()); //请求路径
+                if (httpUrl != null || httpUrl != ""){ //拉取数据添加到数据库
+                    synNum += getData(httpUrl,authorization,priceType.getId(),priceType.getName());
+                }
+            }
+        }else {
+            log.info("没有未同步上月的数据");
+            return "没有未同步上月的数据";
+        }
+        log.info("结束获取上月分类价格数据,共添加" + synNum + "条数据。" + new Date() );
+        if (synNum > 0){
+            return "同步" + synNum + "条数据";
+        }
+        //0条可能数据平台还未出上月数据，也可能是访问数据平台401，500，503等
+        return "同步" + synNum + "条数据,请查看原因!";
+    }
+
+    /**
+     * 请求路径
+     * lym
+     * @param name
+     * @return
+     */
+    private String getUrl(String name){
+        String url = "";
+        switch (name){
+            case "水产类":
+                url = "opene48cee28-96e5-4e2d-b702-70d8fb136e24?classifyId=E5747585BD137E5A5A4B94A943073CB7";
+                break;
+            case "蔬菜类":
+                url = "open8d7af8cc-8992-4397-a57a-a65988e07a07?classifyId=CEEDE16B20FF344B8FC9F7FC9B590D74";
+                break;
+            case "辣椒类":
+                url = "opena207271d-91c5-41d3-83d4-cf9b62942ddd?classifyId=704DA0BE1C7D3A31868E95AC58495AFD";
+                break;
+            case "水果类":
+                url = "open2bb9b7b3-ef7b-424d-8078-6ce7b656e8cc?classifyId=D86F080303026D83CD7D08705F54FFDA";
+                break;
+            case "畜禽类":
+                url = "opencb7131e5-a612-4bf5-b353-bccc7d02b237?classifyId=E5747585BD137E5A5A4B94A943073CB7";
+                break;
+            case "食用菌":
+                url = "open6118232c-e421-403d-a18d-098b2b5936ec?classifyId=8ED038764DA0F2C86285EDB0426EF7B1";
+                break;
+            default:
+                break;
+        }
+
+        String httpUrl = "";
+        if (url != ""){
+            httpUrl = OPENURL + url + "&dataFormat=json&interfaceId=getProductMarketPriceByMonth&dataCode=aec_price_info&limitCnt=1000&userToken=E4D380711ADD4962946C5EFE20ED382D";
+        }
+        return httpUrl;
+    }
+
+    /**
+     * 查询开放
+     * @param httpUrl
+     */
+    private int getData(String httpUrl,String authorization,int priceTypeId,String typeName){
+        if (authorization == null || authorization == ""){
+            authorization = AUTHORIZATION;
+        }
+        //header请求数据
+        List<Map<String,String>> headerParams = new ArrayList<>();
+        Map<String,String> params = new HashMap<>();
+        params.put("name","Authorization");
+        params.put("value",authorization);
+        headerParams.add(params);
+        //查询数据开放平台信息
+        String data = EasyHttpUtils.LoadInstance().get(httpUrl,headerParams);
+        int synNum = 0;
+        log.info(data);
+        if (data == null || data == "") return synNum;
+
+        JSONObject jsonObject = JSONObject.parseObject(data);
+        int rowCount = 0;
+        if (jsonObject.containsKey("rowCount")){ //查询到的数据
+             rowCount = (int) jsonObject.get("rowCount");
+        }
+        if (rowCount > 0 && jsonObject.containsKey("DS")){ //分解数据
+            JSONArray list = (JSONArray) jsonObject.get("DS");
+            List<GzPrices> prices = new ArrayList<>();
+            String synTime = null; //拉取的数据时间
+            for (Object object:list){
+                JSONObject obj = (JSONObject) object;
+                GzPrices gzPrices = new GzPrices();
+                gzPrices.setMarket(obj.getString("市场"));
+                gzPrices.setName(obj.getString("产品"));
+                gzPrices.setUpdateTime(obj.getString("上传时间"));
+                gzPrices.setPrice(obj.getString("价格"));
+                gzPrices.setPriceUnit(obj.getString("价格单位"));
+                gzPrices.setPriceType(obj.getString("价格类型"));
+                gzPrices.setDataOrigion("贵州省政府数据开放平台");
+                gzPrices.setFkPriceTypeId(priceTypeId);
+                gzPrices.setLable(typeName);
+                prices.add(gzPrices);
+                if (synTime == null || synTime == ""){
+                    synTime = obj.getString("上传时间");
+                }
+            }
+
+            if (prices != null && prices.size() > 0){ //添加数据
+                int i = gzPricesService.batchSave(prices);
+                log.info("添加"+i+"条");
+                GzPricesLog log = new GzPricesLog();
+                log.setFkPriceTypeId(priceTypeId);
+                log.setSynNum(i);
+                log.setSynTime(synTime);
+                gzPricesLogService.save(log);
+                synNum += i;
+            }
+        }
+        return synNum;
+    }
+}

src/main/java/com/hw/service/GzPriceTypeService.java

@@ -0,0 +1,17 @@
+package com.hw.service;
+
+import com.hw.entity.GzPriceType;
+
+import java.util.List;
+
+public interface GzPriceTypeService {
+    List<GzPriceType> selectList(GzPriceType gzPriceType);
+
+    /**
+     * 查询未同步上月的类别
+     * lym
+     * @param gzPriceType
+     * @return
+     */
+    List<GzPriceType> selectNotSynList(GzPriceType gzPriceType);
+}

src/main/java/com/hw/service/GzPricesLogService.java

@@ -0,0 +1,8 @@
+package com.hw.service;
+
+import com.hw.entity.GzPricesLog;
+
+public interface GzPricesLogService {
+
+    int save(GzPricesLog gzPricesLog);
+}

src/main/java/com/hw/service/GzPricesService.java

@@ -0,0 +1,15 @@
+package com.hw.service;
+
+import com.hw.entity.GzPrices;
+
+import java.util.List;
+
+public interface GzPricesService {
+    /**
+     * 批量添加
+     * lym
+     * @param list
+     * @return
+     */
+    int batchSave(List<GzPrices> list);
+}

src/main/java/com/hw/service/impl/GzPriceTypeServiceImpl.java

@@ -0,0 +1,26 @@
+package com.hw.service.impl;
+
+import com.hw.dao.GzPriceTypeMapper;
+import com.hw.entity.GzPriceType;
+import com.hw.service.GzPriceTypeService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Service
+public class GzPriceTypeServiceImpl implements GzPriceTypeService {
+
+    @Resource
+    private GzPriceTypeMapper gzPriceTypeMapper;
+
+    @Override
+    public List<GzPriceType> selectList(GzPriceType gzPriceType) {
+        return gzPriceTypeMapper.selectList(gzPriceType);
+    }
+
+    @Override
+    public List<GzPriceType> selectNotSynList(GzPriceType gzPriceType) {
+        return gzPriceTypeMapper.selectNotSynList(gzPriceType);
+    }
+}

src/main/java/com/hw/service/impl/GzPricesLogServiceImpl.java

@@ -0,0 +1,22 @@
+package com.hw.service.impl;
+
+import com.hw.dao.GzPricesLogMapper;
+import com.hw.entity.GzPricesLog;
+import com.hw.service.GzPricesLogService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+@Service
+public class GzPricesLogServiceImpl implements GzPricesLogService {
+
+    @Resource
+    private GzPricesLogMapper pricesLogMapper;
+
+    @Override
+    public int save(GzPricesLog gzPricesLog) {
+        gzPricesLog.setCreateTime(new Date());
+        return pricesLogMapper.insertSelective(gzPricesLog);
+    }
+}

src/main/java/com/hw/service/impl/GzPricesServiceImpl.java

@@ -0,0 +1,21 @@
+package com.hw.service.impl;
+
+import com.hw.dao.GzPricesMapper;
+import com.hw.entity.GzPrices;
+import com.hw.service.GzPricesService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Service
+public class GzPricesServiceImpl implements GzPricesService {
+
+    @Resource
+    private GzPricesMapper gzPricesMapper;
+
+    @Override
+    public int batchSave(List<GzPrices> list) {
+        return gzPricesMapper.batchSave(list);
+    }
+}

src/main/java/com/hw/util/EasyHttpUtils.java

@@ -0,0 +1,478 @@
+/**
+ * @Title: EasyHttpUtils.java
+ * @Package com.elite.common.utils.httpclient
+ * @Description: TODO(用一句话描述该文件做什么)
+ * @author admin
+ * @date 2016年5月23日 下午5:30:48
+ * @version V1.0
+ */
+package com.hw.util;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.http.*;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.HttpRequestRetryHandler;
+import org.apache.http.client.config.CookieSpecs;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.protocol.HttpClientContext;
+import org.apache.http.conn.ConnectTimeoutException;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.conn.ssl.SSLContexts;
+import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.client.LaxRedirectStrategy;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.protocol.HttpContext;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLException;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.UnknownHostException;
+import java.nio.charset.Charset;
+import java.security.KeyManagementException;
+import java.security.KeyStore;
+import java.security.KeyStoreException;
+import java.security.NoSuchAlgorithmException;
+import java.security.cert.CertificateException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ *
+ * @version 1.0
+ */
+@Slf4j
+public class EasyHttpUtils {
+
+    private static final Logger LOGG = LoggerFactory.getLogger(EasyHttpUtils.class);
+    //连接池最大数量
+    private static final int HTTPCLIENT_CONNECTION_COUNT = 200;
+    //单个路由最大连接数量
+    private static final int HTTPCLIENT_MAXPERROUTE_COUNT = 2;
+    //连接超时
+    private static final int HTTPCLIENT_CONNECT_TIMEOUT = 600000;
+    //socket超时
+    private static final int HTTPCLIENT_SOCKET_TIMEOUT = 600000;
+
+    // 创建httpclient连接池
+    private PoolingHttpClientConnectionManager httpClientConnectionManager = null;
+
+    private static final EasyHttpUtils EASY_HTTP_UTILS = new EasyHttpUtils();
+
+
+    public static EasyHttpUtils LoadInstance() {
+
+        return EASY_HTTP_UTILS;
+    }
+
+    private EasyHttpUtils() {
+        initHttpClient();
+    }
+
+
+    /**
+     * @Title: initHttpUtils
+     * @Description: TODO(这里用一句话描述这个方法的作用)
+     */
+    private void initHttpClient() {
+        //创建httpclient连接池
+        httpClientConnectionManager = new PoolingHttpClientConnectionManager();
+        //设置连接池最大数量  
+        httpClientConnectionManager.setMaxTotal(HTTPCLIENT_CONNECTION_COUNT);
+        //设置单个路由最大连接数量  
+        httpClientConnectionManager.setDefaultMaxPerRoute(HTTPCLIENT_MAXPERROUTE_COUNT);
+    }
+
+
+    //请求重试机制
+
+    HttpRequestRetryHandler myRetryHandler = new HttpRequestRetryHandler() {
+        @Override
+        public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
+            if (executionCount >= 3) {
+                // 超过三次则不再重试请求  
+                return false;
+            }
+            if (exception instanceof InterruptedIOException) {
+                // Timeout  
+                return false;
+            }
+            if (exception instanceof UnknownHostException) {
+                // Unknown host  
+                return false;
+            }
+            if (exception instanceof ConnectTimeoutException) {
+                // Connection refused  
+                return false;
+            }
+            if (exception instanceof SSLException) {
+                // SSL handshake exception  
+                return false;
+            }
+            HttpClientContext clientContext = HttpClientContext.adapt(context);
+            HttpRequest request = clientContext.getRequest();
+            boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);
+            if (idempotent) {
+                // Retry if the request is considered idempotent  
+                return true;
+            }
+            return false;
+        }
+    };
+
+    public CloseableHttpClient getHttpClient() {
+        // 创建全局的requestConfig  
+        RequestConfig requestConfig = RequestConfig.custom()
+                .setConnectTimeout(HTTPCLIENT_CONNECT_TIMEOUT)
+                .setSocketTimeout(HTTPCLIENT_SOCKET_TIMEOUT)
+                .setCookieSpec(CookieSpecs.BEST_MATCH).build();
+        // 声明重定向策略对象  
+        LaxRedirectStrategy redirectStrategy = new LaxRedirectStrategy();
+
+        CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(httpClientConnectionManager)
+                .setDefaultRequestConfig(requestConfig)
+                .setRedirectStrategy(redirectStrategy)
+                .setRetryHandler(myRetryHandler)
+                .build();
+        return httpClient;
+    }
+
+
+    /**
+     * HttpClient连接SSL 
+     */
+    public void ssl(String urlStr, String keyPath, String keypass) {
+        CloseableHttpClient httpclient = null;
+        try {
+            RequestConfig requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(HTTPCLIENT_CONNECT_TIMEOUT)
+                    .setSocketTimeout(HTTPCLIENT_SOCKET_TIMEOUT)
+                    .setCookieSpec(CookieSpecs.BEST_MATCH).build();
+            LaxRedirectStrategy redirectStrategy = new LaxRedirectStrategy();
+            KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
+            FileInputStream instream = new FileInputStream(new File(keyPath));
+            try {
+                // 加载keyStore   
+                trustStore.load(instream, keypass.toCharArray());
+            } catch (CertificateException e) {
+                e.printStackTrace();
+            } finally {
+                try {
+                    instream.close();
+                } catch (Exception ignore) {
+                }
+            }
+            // 相信自己的CA和所有自签名的证书  
+            SSLContext sslcontext = SSLContexts.custom().loadTrustMaterial(trustStore, new TrustSelfSignedStrategy()).build();
+            // 只允许使用TLSv1协议  
+            SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[]{"TLSv1"}, null,
+                    SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
+            httpclient = HttpClients.custom().setConnectionManager(httpClientConnectionManager)
+                    .setDefaultRequestConfig(requestConfig)
+                    .setRedirectStrategy(redirectStrategy)
+                    .setRetryHandler(myRetryHandler).setSSLSocketFactory(sslsf).build();
+            // 创建http请求(get方式)  
+            HttpGet httpget = new HttpGet(urlStr);
+
+            CloseableHttpResponse response = httpclient.execute(httpget);
+            try {
+                HttpEntity entity = response.getEntity();
+                LOGG.info("----------------------------------------");
+                LOGG.info(String.valueOf(response.getStatusLine()));
+                if (entity != null) {
+                    LOGG.info("Response content length: " + entity.getContentLength());
+                    LOGG.info(EntityUtils.toString(entity));
+                    EntityUtils.consume(entity);
+                }
+            } finally {
+                response.close();
+            }
+        } catch (ParseException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } catch (KeyManagementException e) {
+            e.printStackTrace();
+        } catch (NoSuchAlgorithmException e) {
+            e.printStackTrace();
+        } catch (KeyStoreException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+    /**
+     * 发送 post请求访问本地应用并根据传递参数不同返回不同结果 
+     */
+    public void post(String urlString, Map<String, Object> params) {
+        // 创建默认的httpClient实例. 
+        LOGG.info("urlString:=========>" + urlString);
+        CloseableHttpClient httpclient = this.getHttpClient();
+        if ("".equals(urlString) || urlString == null) {
+            return;
+        }
+        // 创建httppost    
+        HttpPost httppost = new HttpPost(urlString);
+        // 创建参数队列    
+        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
+        if (params != null && params.size() > 0) {
+            for (String key : params.keySet()) {
+                formparams.add(new BasicNameValuePair(key, (String) params.get(key)));
+            }
+        }
+        UrlEncodedFormEntity uefEntity;
+        try {
+            uefEntity = new UrlEncodedFormEntity(formparams, "UTF-8");
+            httppost.setEntity(uefEntity);
+            LOGG.info("executing request " + httppost.getURI());
+            CloseableHttpResponse response = httpclient.execute(httppost);
+            try {
+                HttpEntity entity = response.getEntity();
+                if (entity != null) {
+                    EntityUtils.consume(entity);
+                }
+            } finally {
+                response.close();
+            }
+        } catch (ClientProtocolException e) {
+            e.printStackTrace();
+        } catch (UnsupportedEncodingException e1) {
+            e1.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public String post(String urlString, JSONObject params) {
+        StringBuilder result = new StringBuilder();
+        // 创建默认的httpClient实例.    
+        CloseableHttpClient httpclient = this.getHttpClient();
+        if ("".equals(urlString) || urlString == null) {
+            return null;
+        }
+        // 创建httppost    
+        HttpPost httppost = new HttpPost(urlString);
+        // 创建参数队列   
+        httppost.addHeader("Content-type", "application/json; charset=utf-8");
+        httppost.setHeader("Accept", "application/json");
+        httppost.setEntity(new StringEntity(params.toJSONString(), Charset.forName("UTF-8")));
+        try {
+            LOGG.info("executing request " + httppost.getURI());
+            CloseableHttpResponse response = httpclient.execute(httppost);
+            HttpEntity entity = null;
+            try {
+                int httpCode = response.getStatusLine().getStatusCode();
+                if (httpCode == HttpURLConnection.HTTP_OK && response != null) {
+                    entity = response.getEntity();
+                    //读取服务器返回的json数据（接受json服务器数据）
+                    InputStream inputStream = entity.getContent();
+                    InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
+                    // 读字符串用的。
+                    BufferedReader reader = new BufferedReader(inputStreamReader);
+                    String str;
+                    while ((str = reader.readLine()) != null) {
+                        result.append(str);
+                    }
+                    reader.close();
+                    return result.toString();
+                }
+            } finally {
+                EntityUtils.consume(entity);
+                response.close();
+            }
+        } catch (ClientProtocolException e) {
+            LOGG.error(e.getMessage(), e);
+        } catch (UnsupportedEncodingException e) {
+            LOGG.error(e.getMessage(), e);
+        } catch (IOException e) {
+            LOGG.error(e.getMessage(), e);
+        }
+        return null;
+    }
+
+    /**
+     * 发送 get请求
+     */
+    public String get(String urlStr) {
+        StringBuilder result = new StringBuilder();
+        CloseableHttpClient httpclient = this.getHttpClient();
+        try {
+            // 创建httpget.
+            HttpGet httpget = new HttpGet(urlStr);
+            LOGG.info("executing request " + httpget.getURI());
+            // 执行get请求.
+            CloseableHttpResponse response = httpclient.execute(httpget);
+            HttpEntity entity = null;
+            try {
+                int httpCode = response.getStatusLine().getStatusCode();
+                if (httpCode == HttpURLConnection.HTTP_OK && response != null) {
+                    entity = response.getEntity();
+                    //读取服务器返回的json数据（接受json服务器数据）
+                    InputStream inputStream = entity.getContent();
+                    InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
+                    // 读字符串用的。
+                    BufferedReader reader = new BufferedReader(inputStreamReader);
+                    String str;
+                    while ((str = reader.readLine()) != null) {
+                        result.append(str);
+                    }
+                    reader.close();
+                    return result.toString();
+                }
+
+            } finally {
+                EntityUtils.consume(entity);
+                response.close();
+            }
+        } catch (ClientProtocolException e) {
+            e.printStackTrace();
+        } catch (ParseException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    /**
+     * 发送 get请求 有header
+     */
+    public String get(String urlStr,List<Map<String,String>> headerParams) {
+        StringBuilder result = new StringBuilder();
+        CloseableHttpClient httpclient = this.getHttpClient();
+        try {
+            // 创建httpget.
+            HttpGet httpget = new HttpGet(urlStr);
+            LOGG.info("executing request " + httpget.getURI());
+            if (headerParams != null && headerParams.size() > 0){
+                for (Map<String,String> map:headerParams){
+                    httpget.setHeader(map.get("name"),map.get("value"));
+                }
+            }
+
+            // 执行get请求.
+            CloseableHttpResponse response = httpclient.execute(httpget);
+            HttpEntity entity = null;
+            try {
+                int httpCode = response.getStatusLine().getStatusCode();
+                log.info(String.valueOf(httpCode));
+                if (httpCode == HttpURLConnection.HTTP_OK && response != null) {
+                    entity = response.getEntity();
+                    //读取服务器返回的json数据（接受json服务器数据）
+                    InputStream inputStream = entity.getContent();
+                    InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
+                    // 读字符串用的。
+                    BufferedReader reader = new BufferedReader(inputStreamReader);
+                    String str;
+                    while ((str = reader.readLine()) != null) {
+                        result.append(str);
+                    }
+                    reader.close();
+                    return result.toString();
+                }
+
+            } finally {
+                EntityUtils.consume(entity);
+                response.close();
+            }
+        } catch (ClientProtocolException e) {
+            e.printStackTrace();
+        } catch (ParseException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+
+    public String getUrlToImg(String urlStr,String fileName,String filePath) {
+        StringBuilder result = new StringBuilder();
+        CloseableHttpClient httpclient = this.getHttpClient();
+        try {
+            // 创建httpget.
+            HttpGet httpget = new HttpGet(urlStr);
+            LOGG.info("executing request " + httpget.getURI());
+            // 执行get请求.
+            CloseableHttpResponse response = httpclient.execute(httpget);
+            HttpEntity entity = null;
+            FileOutputStream fos = null;
+            try {
+                File file = new File(fileName);
+                int httpCode = response.getStatusLine().getStatusCode();
+                if (httpCode == HttpURLConnection.HTTP_OK && response != null) {
+                    entity = response.getEntity();
+                    //读取服务器返回的json数据（接受json服务器数据）
+                    InputStream inputStream = entity.getContent();
+                    Header header = entity.getContentType();
+                    log.info("==============>{}",header.getName());
+                    log.info("==============>{}",header.getValue());
+                    log.info("==============>{}",header.getElements());
+                    String type = header.getValue();
+                    String imageType="jpeg";
+                    if(type.indexOf("/")!=-1){
+                        int flagIndex = type.indexOf("/");
+                        imageType = type.substring(flagIndex + 1);
+                        if (!imageType.equals("gif")) {
+                            imageType = "jpeg";
+                        }
+                    }
+                    byte[] imageData = this.readInputStream(inputStream);
+                    log.info("filePath=====================>{}",filePath);
+                    File saveDir = new File(filePath);
+                    if (!saveDir.exists()) {
+                        saveDir.mkdir();
+                    }
+                    File saveFile = new File(saveDir +File.separator+fileName + "." + imageType);
+                    fos = new FileOutputStream(saveFile);
+                    fos.write(imageData);
+                    if (fos != null) {
+                        fos.flush();
+                        fos.close();
+                    }
+                    if (inputStream != null) {
+                        inputStream.close();
+                    }
+                    log.info("info:{}{}.{}download success",filePath,fileName,imageType);
+                    return imageType;
+                }
+            } finally {
+                EntityUtils.consume(entity);
+                response.close();
+                fos.close();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    private byte[] readInputStream(InputStream inputStream) throws IOException {
+        byte[] buffer = new byte[1024];
+        int len = 0;
+        ByteArrayOutputStream bos = new ByteArrayOutputStream();
+        while ((len = inputStream.read(buffer)) != -1) {
+            bos.write(buffer, 0, len);
+        }
+        bos.close();
+        return bos.toByteArray();
+    }
+
+}
+	
+	
+

src/main/resources/application-dev.properties

@@ -0,0 +1,38 @@
+server.port=18001
+spring.application.name=pull-openpricedata
+
+#mysql datasource setting
+spring.datasource.driver-class-name=com.mysql.jdbc.Driver
+spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
+spring.datasource.url=jdbc:mysql://172.16.90.33:3306/price_publishing_logistics_park?characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&autoReconnect=true&useSSL=false&&allowMultiQueries=true
+spring.datasource.username=root
+spring.datasource.password=123456
+spring.datasource.initialSize=5
+spring.datasource.minIdle=5
+spring.datasource.maxActive=20
+spring.datasource.maxWait=60000
+spring.datasource.timeBetweenEvictionRunsMillis=60000
+spring.datasource.minEvictableIdleTimeMillis=30000
+spring.datasource.validationQuery=SELECT 1
+spring.datasource.testWhileIdle=true
+spring.datasource.testOnBorrow=false
+spring.datasource.testOnReturn=false
+spring.datasource.poolPreparedStatements=true
+spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
+spring.datasource.filters=stat,wall
+spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=2000
+#mybatis setting
+mybatis.type-aliases-package=com.hw.entity
+mybatis.mapper-locations=classpath:mappers/*.xml
+mybatis.check-config-location=true
+mybatis.executor-type=simple
+#pagehelper setting
+pagehelper.helperDialect=mysql
+pagehelper.reasonable=true
+pagehelper.supportMethodsArguments=true
+pagehelper.params=count=countSql
+
+#贵州省政府数据开放平台路径 http://data.guizhou.gov.cn
+open.url=http://data.guizhou.gov.cn:8000/
+#开放平台authorization
+open.authorization=Basic Z3podzEyMy1uUk1vZ0FHVzplNTI1YjlmNzYzZmQ0MjA2YTZkM2IyMmVmODNjYzczYg==

src/main/resources/application-pro.properties

@@ -0,0 +1 @@
+server.port=18001

src/main/resources/application-test.properties

@@ -0,0 +1 @@
+server.port=18002

src/main/resources/application.properties

@@ -0,0 +1 @@
+spring.profiles.active=dev

src/main/resources/generatorConfig.xml

@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE generatorConfiguration
+        PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
+        "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
+<generatorConfiguration>
+    <context id="DB2Tables" targetRuntime="MyBatis3">
+        <commentGenerator>
+            <property name="suppressDate" value="true"/>
+            <property name="suppressAllComments" value="true"/>
+        </commentGenerator>
+        <!--数据库链接地址账号密码-->
+        <jdbcConnection driverClass="com.mysql.jdbc.Driver"
+                        connectionURL="jdbc:mysql://172.16.90.33:3306/price_publishing_logistics_park?characterEncoding=UTF-8"
+                        userId="root" password="123456">
+        </jdbcConnection>
+        <javaTypeResolver>
+            <property name="forceBigDecimals" value="false"/>
+        </javaTypeResolver>
+        <!--生成Model类存放位置-->
+        <javaModelGenerator targetPackage="com.hw.entity"
+                            targetProject="src/main/java">
+            <property name="enableSubPackages" value="true"/>
+            <property name="trimStrings" value="true"/>
+        </javaModelGenerator>
+        <!--生成映射文件存放位置-->
+        <sqlMapGenerator targetPackage="mappers" targetProject="src/main/resources">
+            <property name="enableSubPackages" value="true"/>
+        </sqlMapGenerator>
+        <!--生成Dao类存放位置-->
+        <!-- 客户端代码，生成易于使用的针对Model对象和XML配置文件 的代码
+                type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper对象
+                type="MIXEDMAPPER",生成基于注解的Java Model 和相应的Mapper对象
+                type="XMLMAPPER",生成SQLMap XML文件和独立的Mapper接口
+        -->
+        <javaClientGenerator type="XMLMAPPER" targetPackage="com.hw.dao"
+                             targetProject="src/main/java">
+            <property name="enableSubPackages" value="true"/>
+        </javaClientGenerator>
+        <!--生成对应表及类名-->
+        <table tableName="t_gz_prices_log" domainObjectName="GzPricesLog" enableCountByExample="false"
+               enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false"
+               selectByExampleQueryId="false"></table>
+        <!--<table tableName="t_base_dictionary_type" domainObjectName="BaseDictionaryType" enableCountByExample="false"
+               enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false"
+               selectByExampleQueryId="false"></table>-->
+    </context>
+</generatorConfiguration>

src/main/resources/mappers/GzPriceTypeMapper.xml

@@ -0,0 +1,128 @@
+<?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.hw.dao.GzPriceTypeMapper">
+  <resultMap id="BaseResultMap" type="com.hw.entity.GzPriceType">
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="parent_id" jdbcType="INTEGER" property="parentId" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="remark" jdbcType="VARCHAR" property="remark" />
+    <result column="sort" jdbcType="INTEGER" property="sort" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, parent_id, name, remark, sort
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_gz_price_type
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer">
+    delete from t_gz_price_type
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.hw.entity.GzPriceType">
+    insert into t_gz_price_type (id, parent_id, name, 
+      remark, sort)
+    values (#{id,jdbcType=INTEGER}, #{parentId,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR}, 
+      #{remark,jdbcType=VARCHAR}, #{sort,jdbcType=INTEGER})
+  </insert>
+  <insert id="insertSelective" parameterType="com.hw.entity.GzPriceType">
+    insert into t_gz_price_type
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="parentId != null">
+        parent_id,
+      </if>
+      <if test="name != null">
+        name,
+      </if>
+      <if test="remark != null">
+        remark,
+      </if>
+      <if test="sort != null">
+        sort,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="parentId != null">
+        #{parentId,jdbcType=INTEGER},
+      </if>
+      <if test="name != null">
+        #{name,jdbcType=VARCHAR},
+      </if>
+      <if test="remark != null">
+        #{remark,jdbcType=VARCHAR},
+      </if>
+      <if test="sort != null">
+        #{sort,jdbcType=INTEGER},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.hw.entity.GzPriceType">
+    update t_gz_price_type
+    <set>
+      <if test="parentId != null">
+        parent_id = #{parentId,jdbcType=INTEGER},
+      </if>
+      <if test="name != null">
+        name = #{name,jdbcType=VARCHAR},
+      </if>
+      <if test="remark != null">
+        remark = #{remark,jdbcType=VARCHAR},
+      </if>
+      <if test="sort != null">
+        sort = #{sort,jdbcType=INTEGER},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.hw.entity.GzPriceType">
+    update t_gz_price_type
+    set parent_id = #{parentId,jdbcType=INTEGER},
+      name = #{name,jdbcType=VARCHAR},
+      remark = #{remark,jdbcType=VARCHAR},
+      sort = #{sort,jdbcType=INTEGER}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+
+  <select id="selectList" parameterType="com.hw.entity.GzPriceType" resultMap="BaseResultMap">
+    select <include refid="Base_Column_List"/> from t_gz_price_type
+    where 1=1
+    <if test="parentId != null">
+      AND parent_id = #{parentId,jdbcType=INTEGER}
+    </if>
+    <if test="name != null">
+      AND name LIKE CONCAT("%",#{name,jdbcType=VARCHAR},"%")
+    </if>
+    <if test="remark != null">
+      AND remark LIKE CONCAT("%",#{remark,jdbcType=VARCHAR},"%")
+    </if>
+    order by sort asc
+  </select>
+
+  <!-- 查询未同步上月的类别 lym -->
+  <select id="selectNotSynList" parameterType="com.hw.entity.GzPriceType" resultMap="BaseResultMap">
+    select <include refid="Base_Column_List"/> from t_gz_price_type
+    where id NOT IN (
+      SELECT a.id FROM t_gz_price_type a
+      LEFT JOIN t_gz_prices_log b ON a.id = b.fk_price_type_id
+      WHERE DATE_FORMAT(b.syn_time,"%Y-%m") = DATE_FORMAT(DATE_SUB(NOW(),INTERVAL 1 MONTH),"%Y-%m")
+    )
+    <if test="parentId != null">
+      AND parent_id = #{parentId,jdbcType=INTEGER}
+    </if>
+    <if test="name != null">
+      AND name LIKE CONCAT("%",#{name,jdbcType=VARCHAR},"%")
+    </if>
+    <if test="remark != null">
+      AND remark LIKE CONCAT("%",#{remark,jdbcType=VARCHAR},"%")
+    </if>
+    order by sort asc
+  </select>
+</mapper>

src/main/resources/mappers/GzPricesLogMapper.xml

@@ -0,0 +1,93 @@
+<?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.hw.dao.GzPricesLogMapper">
+  <resultMap id="BaseResultMap" type="com.hw.entity.GzPricesLog">
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="fk_price_type_id" jdbcType="INTEGER" property="fkPriceTypeId" />
+    <result column="syn_time" jdbcType="VARCHAR" property="synTime" />
+    <result column="syn_num" jdbcType="INTEGER" property="synNum" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, fk_price_type_id, syn_time, syn_num, create_time
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_gz_prices_log
+    where id = #{id,jdbcType=BIGINT}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+    delete from t_gz_prices_log
+    where id = #{id,jdbcType=BIGINT}
+  </delete>
+  <insert id="insert" parameterType="com.hw.entity.GzPricesLog">
+    insert into t_gz_prices_log (id, fk_price_type_id, syn_time, 
+      syn_num, create_time)
+    values (#{id,jdbcType=BIGINT}, #{fkPriceTypeId,jdbcType=INTEGER}, #{synTime,jdbcType=VARCHAR}, 
+      #{synNum,jdbcType=INTEGER}, #{createTime,jdbcType=TIMESTAMP})
+  </insert>
+  <insert id="insertSelective" parameterType="com.hw.entity.GzPricesLog">
+    insert into t_gz_prices_log
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="fkPriceTypeId != null">
+        fk_price_type_id,
+      </if>
+      <if test="synTime != null">
+        syn_time,
+      </if>
+      <if test="synNum != null">
+        syn_num,
+      </if>
+      <if test="createTime != null">
+        create_time,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=BIGINT},
+      </if>
+      <if test="fkPriceTypeId != null">
+        #{fkPriceTypeId,jdbcType=INTEGER},
+      </if>
+      <if test="synTime != null">
+        #{synTime,jdbcType=VARCHAR},
+      </if>
+      <if test="synNum != null">
+        #{synNum,jdbcType=INTEGER},
+      </if>
+      <if test="createTime != null">
+        #{createTime,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.hw.entity.GzPricesLog">
+    update t_gz_prices_log
+    <set>
+      <if test="fkPriceTypeId != null">
+        fk_price_type_id = #{fkPriceTypeId,jdbcType=INTEGER},
+      </if>
+      <if test="synTime != null">
+        syn_time = #{synTime,jdbcType=VARCHAR},
+      </if>
+      <if test="synNum != null">
+        syn_num = #{synNum,jdbcType=INTEGER},
+      </if>
+      <if test="createTime != null">
+        create_time = #{createTime,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.hw.entity.GzPricesLog">
+    update t_gz_prices_log
+    set fk_price_type_id = #{fkPriceTypeId,jdbcType=INTEGER},
+      syn_time = #{synTime,jdbcType=VARCHAR},
+      syn_num = #{synNum,jdbcType=INTEGER},
+      create_time = #{createTime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+</mapper>

src/main/resources/mappers/GzPricesMapper.xml

@@ -0,0 +1,191 @@
+<?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.hw.dao.GzPricesMapper">
+  <resultMap id="BaseResultMap" type="com.hw.entity.GzPrices">
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="fk_price_type_id" jdbcType="INTEGER" property="fkPriceTypeId" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="price" jdbcType="VARCHAR" property="price" />
+    <result column="price_unit" jdbcType="VARCHAR" property="priceUnit" />
+    <result column="market" jdbcType="VARCHAR" property="market" />
+    <result column="region" jdbcType="VARCHAR" property="region" />
+    <result column="update_time" jdbcType="VARCHAR" property="updateTime" />
+    <result column="specification" jdbcType="VARCHAR" property="specification" />
+    <result column="data_origion" jdbcType="VARCHAR" property="dataOrigion" />
+    <result column="price_type" jdbcType="VARCHAR" property="priceType" />
+    <result column="lable" jdbcType="VARCHAR" property="lable" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    id, fk_price_type_id, name, price, price_unit, market, region, update_time, specification, 
+    data_origion, price_type, lable
+  </sql>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from t_gz_prices
+    where id = #{id,jdbcType=BIGINT}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+    delete from t_gz_prices
+    where id = #{id,jdbcType=BIGINT}
+  </delete>
+  <insert id="insert" parameterType="com.hw.entity.GzPrices">
+    insert into t_gz_prices (id, fk_price_type_id, name, 
+      price, price_unit, market, 
+      region, update_time, specification, 
+      data_origion, price_type, lable
+      )
+    values (#{id,jdbcType=BIGINT}, #{fkPriceTypeId,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR}, 
+      #{price,jdbcType=VARCHAR}, #{priceUnit,jdbcType=VARCHAR}, #{market,jdbcType=VARCHAR}, 
+      #{region,jdbcType=VARCHAR}, #{updateTime,jdbcType=VARCHAR}, #{specification,jdbcType=VARCHAR}, 
+      #{dataOrigion,jdbcType=VARCHAR}, #{priceType,jdbcType=VARCHAR}, #{lable,jdbcType=VARCHAR}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.hw.entity.GzPrices">
+    insert into t_gz_prices
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="fkPriceTypeId != null">
+        fk_price_type_id,
+      </if>
+      <if test="name != null">
+        name,
+      </if>
+      <if test="price != null">
+        price,
+      </if>
+      <if test="priceUnit != null">
+        price_unit,
+      </if>
+      <if test="market != null">
+        market,
+      </if>
+      <if test="region != null">
+        region,
+      </if>
+      <if test="updateTime != null">
+        update_time,
+      </if>
+      <if test="specification != null">
+        specification,
+      </if>
+      <if test="dataOrigion != null">
+        data_origion,
+      </if>
+      <if test="priceType != null">
+        price_type,
+      </if>
+      <if test="lable != null">
+        lable,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=BIGINT},
+      </if>
+      <if test="fkPriceTypeId != null">
+        #{fkPriceTypeId,jdbcType=INTEGER},
+      </if>
+      <if test="name != null">
+        #{name,jdbcType=VARCHAR},
+      </if>
+      <if test="price != null">
+        #{price,jdbcType=VARCHAR},
+      </if>
+      <if test="priceUnit != null">
+        #{priceUnit,jdbcType=VARCHAR},
+      </if>
+      <if test="market != null">
+        #{market,jdbcType=VARCHAR},
+      </if>
+      <if test="region != null">
+        #{region,jdbcType=VARCHAR},
+      </if>
+      <if test="updateTime != null">
+        #{updateTime,jdbcType=VARCHAR},
+      </if>
+      <if test="specification != null">
+        #{specification,jdbcType=VARCHAR},
+      </if>
+      <if test="dataOrigion != null">
+        #{dataOrigion,jdbcType=VARCHAR},
+      </if>
+      <if test="priceType != null">
+        #{priceType,jdbcType=VARCHAR},
+      </if>
+      <if test="lable != null">
+        #{lable,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.hw.entity.GzPrices">
+    update t_gz_prices
+    <set>
+      <if test="fkPriceTypeId != null">
+        fk_price_type_id = #{fkPriceTypeId,jdbcType=INTEGER},
+      </if>
+      <if test="name != null">
+        name = #{name,jdbcType=VARCHAR},
+      </if>
+      <if test="price != null">
+        price = #{price,jdbcType=VARCHAR},
+      </if>
+      <if test="priceUnit != null">
+        price_unit = #{priceUnit,jdbcType=VARCHAR},
+      </if>
+      <if test="market != null">
+        market = #{market,jdbcType=VARCHAR},
+      </if>
+      <if test="region != null">
+        region = #{region,jdbcType=VARCHAR},
+      </if>
+      <if test="updateTime != null">
+        update_time = #{updateTime,jdbcType=VARCHAR},
+      </if>
+      <if test="specification != null">
+        specification = #{specification,jdbcType=VARCHAR},
+      </if>
+      <if test="dataOrigion != null">
+        data_origion = #{dataOrigion,jdbcType=VARCHAR},
+      </if>
+      <if test="priceType != null">
+        price_type = #{priceType,jdbcType=VARCHAR},
+      </if>
+      <if test="lable != null">
+        lable = #{lable,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.hw.entity.GzPrices">
+    update t_gz_prices
+    set fk_price_type_id = #{fkPriceTypeId,jdbcType=INTEGER},
+      name = #{name,jdbcType=VARCHAR},
+      price = #{price,jdbcType=VARCHAR},
+      price_unit = #{priceUnit,jdbcType=VARCHAR},
+      market = #{market,jdbcType=VARCHAR},
+      region = #{region,jdbcType=VARCHAR},
+      update_time = #{updateTime,jdbcType=VARCHAR},
+      specification = #{specification,jdbcType=VARCHAR},
+      data_origion = #{dataOrigion,jdbcType=VARCHAR},
+      price_type = #{priceType,jdbcType=VARCHAR},
+      lable = #{lable,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=BIGINT}
+  </update>
+
+  <!-- 批量添加 lym -->
+  <insert id="batchSave" parameterType="com.hw.entity.GzPrices">
+    insert into t_gz_prices (fk_price_type_id, name,
+      price, price_unit, market,update_time,
+      data_origion, price_type, lable,create_time
+      ) values
+      <foreach collection="list" item="item" separator=",">
+        (#{item.fkPriceTypeId,jdbcType=INTEGER}, #{item.name,jdbcType=VARCHAR},
+        #{item.price,jdbcType=VARCHAR}, #{item.priceUnit,jdbcType=VARCHAR}, #{item.market,jdbcType=VARCHAR},
+        #{item.updateTime,jdbcType=VARCHAR},#{item.dataOrigion,jdbcType=VARCHAR}, #{item.priceType,jdbcType=VARCHAR},
+        #{item.lable,jdbcType=VARCHAR},NOW())
+      </foreach>
+  </insert>
+</mapper>

src/main/resources/swagger-ui.html

@@ -0,0 +1,56 @@
+<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <title>Swagger UI</title>
+    <link rel="icon" type="image/png" href="webjars/springfox-swagger-ui/images/favicon-32x32.png" sizes="32x32"/>
+    <link rel="icon" type="image/png" href="webjars/springfox-swagger-ui/images/favicon-16x16.png" sizes="16x16"/>
+    <link href='webjars/springfox-swagger-ui/css/typography.css' media='screen' rel='stylesheet' type='text/css'/>
+    <link href='webjars/springfox-swagger-ui/css/reset.css' media='screen' rel='stylesheet' type='text/css'/>
+    <link href='webjars/springfox-swagger-ui/css/screen.css' media='screen' rel='stylesheet' type='text/css'/>
+    <link href='webjars/springfox-swagger-ui/css/reset.css' media='print' rel='stylesheet' type='text/css'/>
+    <link href='webjars/springfox-swagger-ui/css/print.css' media='print' rel='stylesheet' type='text/css'/>
+
+    <script src='webjars/springfox-swagger-ui/lib/object-assign-pollyfill.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/jquery-1.8.0.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/jquery.slideto.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/jquery.wiggle.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/jquery.ba-bbq.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/handlebars-4.0.5.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/lodash.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/backbone-min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/swagger-ui.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/highlight.9.1.0.pack.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/highlight.9.1.0.pack_extended.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/jsoneditor.min.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/marked.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lib/swagger-oauth.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/springfox.js' type='text/javascript'></script>
+
+    <!--国际化操作：选择中文版 -->
+    <script src='webjars/springfox-swagger-ui/lang/translator.js' type='text/javascript'></script>
+    <script src='webjars/springfox-swagger-ui/lang/zh-cn.js' type='text/javascript'></script>
+
+</head>
+
+<body class="swagger-section">
+<div id='header'>
+    <div class="swagger-ui-wrap">
+        <a id="logo" href="http://swagger.io">![](webjars/springfox-swagger-ui/images/logo_small.png)<span
+                class="logo__title">swagger</span></a>
+        <form id='api_selector'>
+            <div class='input'>
+                <select id="select_baseUrl" name="select_baseUrl"></select>
+            </div>
+            <div class='input'><input placeholder="http://example.com/api" id="input_baseUrl" name="baseUrl"
+                                      type="text"/></div>
+            <div id='auth_container'></div>
+            <div class='input'><a id="explore" class="header__btn" href="#" data-sw-translate>Explore</a></div>
+        </form>
+    </div>
+</div>
+
+<div id="message-bar" class="swagger-ui-wrap" data-sw-translate></div>
+<div id="swagger-ui-container" class="swagger-ui-wrap"></div>
+</body>
+</html>