数据转换

common/common-entity/src/main/java/com/yihu/jw/iot/data_input/DataStandardDO.java

@@ -0,0 +1,35 @@
package com.yihu.jw.iot.data_input;
import com.yihu.jw.IdEntityWithOperation;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
import java.io.Serializable;
@Entity
@Table("iot_base_data_def")
public class DataStandardDO extends IdEntityWithOperation implements Serializable {
    @Column(name = "base_name")
    private String baseName;
    @Column(name = "item_code")
    private String itemCode;
    @Column(name = "item_name")
    private String itemName;
    @Column(name = "item_type")
    private String itemType;
    @Column(name = "required")
    private String required;
    @Column(name = "item_value_min")
    private String itemValueMin;
    @Column(name = "item_value_max")
    private String itemValueMax;
}

svr/svr-iot/pom.xml

@@ -18,6 +18,10 @@
            <groupId>com.yihu.jw</groupId>
            <artifactId>common-entity</artifactId>
        </dependency>
        <dependency>
            <groupId>com.yihu.base</groupId>
            <artifactId>common-data-es</artifactId>
        </dependency>
        <dependency>
            <groupId>com.yihu.jw</groupId>
            <artifactId>common-request-mapping</artifactId>

svr/svr-iot/src/main/java/com/yihu/iot/data_input/DataInputEnrty.java

@@ -0,0 +1,4 @@
package com.yihu.iot.data_input;
public class DataInputEnrty {
}

svr/svr-iot/src/main/java/com/yihu/iot/data_input/DataStandardConvert.java

@@ -0,0 +1,9 @@
package com.yihu.iot.data_input;
/**
 * 数据标准转换
 */
public class DataStandardConvert {
}

svr/svr-iot/src/main/java/com/yihu/iot/data_input/DataStandardDao.java

@@ -0,0 +1,14 @@
package com.yihu.iot.data_input;
import com.yihu.jw.iot.data_input.DataStandardDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.List;
public interface DataStandardDao extends PagingAndSortingRepository<DataStandardDO, Long>, JpaSpecificationExecutor<DataStandardDO> {
    @Query("baseName,itemCode,itemName,itemType,required,itemValueMin,itemValueMax from DataStandardDO" )
    List<DataStandardDO>  getList();
}

svr/svr-iot/src/main/java/com/yihu/iot/data_input/DataStandardService.java

@@ -0,0 +1,10 @@
package com.yihu.iot.data_input;
import com.yihu.base.mysql.query.BaseJpaService;
import com.yihu.jw.iot.data_input.DataStandardDO;
public class DataStandardService extends BaseJpaService<DataStandardDO,DataStandardDao> {
}

svr/svr-iot/src/main/resources/application.yml

@@ -45,6 +45,38 @@ fast-dfs:
    max-size: 20
    wait-time: 500
#es配置
es:
  host:  59.61.92.90
  port: 9067 #默认是9200
  tPort: 9068 #http端口 默认是9300
  clusterName: jkzl
spring:
  data:
    elasticsearch: #ElasticsearchProperties
      cluster-name: jkzl #默认即为elasticsearch  集群名
      cluster-nodes: 172.17.110.217:9300,172.17.110.128:9300 #配置es节点信息，逗号分隔，如果没有指定，则启动ClientNode
      local: false ##是否本地连接
      properties: # Additional properties used to configure the client.
  # JEST (Elasticsearch HTTP client) (JestProperties)
  elasticsearch:
    jest:
      uris: http://localhost:9200
      connection-timeout: # Connection timeout in milliseconds.
      multi-threaded: true # Enable connection requests from multiple execution threads.
      username: # Login user.
      password: # Login password.
      proxy.port:  # Proxy port the HTTP client should use.
      proxy.host:  # Proxy host the HTTP client should use.
---
spring:
  profiles: jwdev