静态数据接口完成，动态数据结构体创建完成

common/commUtil.go

@@ -3,7 +3,7 @@ package common
 import "log"
 
 func ErrorPrintln(str string, err error) {
-	if err != nil{
-		log.Fatal(str + ":" + err.Error())
+	if err != nil {
+		log.Println(str + ":" + err.Error())
 	}
 }
\ No newline at end of file

config/conf.ini

@@ -79,28 +79,42 @@ minelaytypeno=1
 upstreamtailings=1
 drystorage=
 drystoragewaterratio=
-tailingsparticlesize=
+tailingsparticlesize=64
 tailingsaveparticlesize=
-depositiondrybeachslope=
-personnum=
-buildingnum=
-emergencyplanfiled=
-primarysafetyunit=
-primarysafetylevel=
-designunit=
-designunitlevel=
-constructionunit=
-constructionlevel=
-supervisoryunit=
-supervisorylevel=
-safetycheckunit=
-safetychecklevel=
-safetyacceptancetime=
-safetyevaluationunit=
-safetyevaluationlevel=
-filingperson=
-filingdate=
-fillerphone=
-note=
-in_use=
-is_sync=
+depositiondrybeachslope=2
+personnum=0
+buildingnum=0
+emergencyplanfiled=是
+primarysafetyunit=山东公信安全评价有限公司
+primarysafetylevel=甲级
+designunit=山东黄金集团烟台设计研究工程有限公司
+designunitlevel=甲级
+constructionunit=山东华新建筑工程集团有限责任公司
+constructionlevel=矿山工程施工总承包一级
+supervisoryunit=北京康迪建设监理咨询有限公司
+supervisorylevel=甲级
+safetycheckunit=山东信力安全技术有限公司
+safetychecklevel=甲级
+safetyacceptancetime=2015-9-28
+safetyevaluationunit=山东信力安全技术有限公司
+safetyevaluationlevel=甲级
+filingperson=烟台中嘉矿业有限公司（岳翔宇）
+filingdate=2020-10-24
+fillerphone=18507282835
+note=无
+in_use=1
+is_sync=0
+
+[StaticSqlLanguage]
+gt_static_sql=SELECT equipno, equipname, longitude, latitude, altitude, isUsed, isSync FROM wkkInfo where equipname like '%干滩%'
+ksw_static_sql=SELECT equipno, equipname, installlocation, longitude, latitude, altitude, isUsed, isSync FROM wkkInfo a INNER JOIN (SELECT ID FROM SensorInfo WHERE Location like '%水位%') b on a.equipname = b.ID
+jrx_static_sql=SELECT equipno, equipname, holedepth, burialdepth, longitude, latitude, altitude, isUsed, isSync FROM wkkInfo a INNER JOIN (SELECT ID FROM SensorInfo WHERE Location like '%浸润线%') b on a.equipname = b.ID
+jyl_static_sql=SELECT equipno, equipname, longitude, latitude, altitude, isUsed, isSync FROM wkkInfo where equipname like '%雨量%'
+nbwy_static_sql=SELECT equipno, equipname, longitude, latitude, altitude, isUsed, isSync FROM wkkInfo a INNER JOIN (SELECT ID FROM SensorInfo WHERE Location like '%内部位移%') b on a.equipname = b.ID
+
+[RealTimeSqlLanguage]
+gt_real_time_sql=SELECT b.equipno AS sensorno, a.upTempValue AS value, a.upTime AS collectdate from TempT a inner join (select equipno, equipname from [mssensors].[dbo].[wkkInfo] where equipname like '%干滩%') b on a.ID = b.equipname
+ksw_real_time_sql=
+jrx_real_time_sql=
+jyl_real_time_sql=
+nbwy_real_time_sql=
\ No newline at end of file

config/config.go

@@ -8,11 +8,15 @@ import (
 	"shandong_datapush/common"
 	_ "github.com/denisenkom/go-mssqldb"
 	_ "github.com/lib/pq"
+    _ "github.com/go-sql-driver/mysql"
 )
 
 var (
 	DBType string
 	DBConnInfo *common.DBConnectInfo
+	TailPond *common.TailPondInfor
+	StaticSql *common.StaticSqlLanguage
+	RealTimeSql *common.RealTimeSqlLanguage
 	DB *sql.DB
     err error
 )
@@ -23,6 +27,12 @@ func init() {
 	DBType = file.Section("databaseType").Key("type").String()
 	DBConnInfo = new(common.DBConnectInfo)
 	err = file.Section("databaseConnection").MapTo(DBConnInfo)
+	TailPond = new(common.TailPondInfor)
+	err = file.Section("wkkBasicInfo").MapTo(TailPond)
+	StaticSql = new(common.StaticSqlLanguage)
+	file.Section("staticSqlLanguage").MapTo(StaticSql)
+	RealTimeSql = new(common.RealTimeSqlLanguage)
+	file.Section("RealTimeSqlLanguage").MapTo(RealTimeSql)
 	common.ErrorPrintln("数据库连接信息映射异常", err)
 }
 
@@ -31,6 +41,7 @@ func DBConnection() {
 		log.Println("当前使用pg数据库")
 		connString := fmt.Sprintf("host=%s port=%s user=%s password=%s dbname=%s sslmode=disable",DBConnInfo.Server, DBConnInfo.Port, DBConnInfo.Username, DBConnInfo.Password, DBConnInfo.DBName)
 		DB, err = sql.Open("postgres", connString)
+		common.ErrorPrintln("postgres数据库连接异常" , err)
 		err = DB.Ping()
 		if err != nil {
 			log.Fatalf("[Error] PG 数据库连接失败: %s", err.Error())
@@ -38,14 +49,26 @@ func DBConnection() {
 			log.Println("postgres 数据库连接成功！")
 		}
 	} else if DBType == "sqlserver" {
-		log.Println("当前使用SqlServer数据库")
+		log.Println("当前使用sqlserver数据库")
 		connString := fmt.Sprintf("server=%s;database=%s;user id=%s;password=%s;port=%s;encrypt=disable", DBConnInfo.Server, DBConnInfo.DBName, DBConnInfo.Username, DBConnInfo.Password, DBConnInfo.Port)
 		DB, err = sql.Open("mssql", connString)
+		common.ErrorPrintln("sqlserver数据库连接异常" , err)
 		err = DB.Ping()
 		if err != nil {
 			log.Fatalf("[Error] sqlserver 数据库连接失败: %s", err.Error())
 		}else {
 			log.Println("sqlserver 数据库连接成功！")
 		}
+	} else if DBType == "mysql" {
+		log.Println("当前使用mysql数据库")
+		connString := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8", DBConnInfo.Username, DBConnInfo.Password, DBConnInfo.Server, DBConnInfo.Port, DBConnInfo.DBName)
+		DB, err = sql.Open("mysql", connString)
+		common.ErrorPrintln("mysql数据库连接异常" , err)
+		err = DB.Ping()
+		if err != nil {
+			log.Fatalf("[Error] mysql 数据库连接失败: %s", err.Error())
+		}else {
+			log.Println("mysql 数据库连接成功！")
+		}
 	}
 }
\ No newline at end of file

dao/staticDataDao.go

+package dao
+
+import (
+	"shandong_datapush/common"
+	"shandong_datapush/config"
+)
+
+/*
+	干滩静态数据
+ */
+func GantanStaticData() []*common.DryBeachEquipInfor {
+	row, err := config.DB.Query(config.StaticSql.GtStaticSql)
+	defer func() {
+		err := row.Close()
+		common.ErrorPrintln("row 关闭异常", err)
+	}()
+	common.ErrorPrintln("干滩静态数据查询异常", err)
+	Arrs := make([]*common.DryBeachEquipInfor, 0)
+	for row.Next() {
+		dryBeachInfo := new(common.DryBeachEquipInfor)
+		err := row.Scan(&dryBeachInfo.Equipno, &dryBeachInfo.Equipname, &dryBeachInfo.Longitude, &dryBeachInfo.Latitude,&dryBeachInfo.Altitude, &dryBeachInfo.IsUsed, &dryBeachInfo.IsSync)
+		common.ErrorPrintln("scan 干滩数据读取异常", err)
+		Arrs = append(Arrs, dryBeachInfo)
+	}
+	return Arrs
+}
+
+/*
+	库水位静态数据
+ */
+func KushuiweiStaticData() []*common.ReserWaterLevelInfor {
+	row, err := config.DB.Query(config.StaticSql.KswStaticSql)
+	common.ErrorPrintln("库水位静态数据查询异常", err)
+	defer func() {
+		err := row.Close()
+		common.ErrorPrintln("row 关闭异常", err)
+	}()
+	Arrs := make([]*common.ReserWaterLevelInfor, 0)
+	for row.Next() {
+		reserwater := new(common.ReserWaterLevelInfor)
+		err := row.Scan(&reserwater.Equipno, &reserwater.Equipname, &reserwater.Installlocation, &reserwater.Longitude, &reserwater.Latitude, &reserwater.Altitude, &reserwater.IsUsed, &reserwater.IsSync)
+		common.ErrorPrintln("scan 库水位数据读取异常", err)
+		Arrs = append(Arrs, reserwater)
+	}
+	return Arrs
+}
+
+/*
+	浸润线静态数据
+ */
+func JinrunxianStaticData() []*common.SaturationLineInfor {
+	row, err := config.DB.Query(config.StaticSql.JrxStaticSql)
+	common.ErrorPrintln("浸润线静态数据查询异常", err)
+	defer func() {
+		err := row.Close()
+		common.ErrorPrintln("row 关闭异常", err)
+	}()
+	Arrs := make([]*common.SaturationLineInfor, 0)
+	for row.Next() {
+		saturation := new(common.SaturationLineInfor)
+		err := row.Scan(&saturation.Equipno, &saturation.Equipname, &saturation.Holedepth, &saturation.Burialdepth, &saturation.Longitude, &saturation.Latitude, &saturation.Altitude, &saturation.IsUsed, &saturation.IsSync)
+		common.ErrorPrintln("scan 浸润线数据读取异常", err)
+		Arrs = append(Arrs, saturation)
+	}
+	return Arrs
+}
+
+/*
+	降雨量静态数据
+*/
+func JiangyuliangStaticData() []*common.RainfallInfor {
+	row, err := config.DB.Query(config.StaticSql.JylStaticSql)
+	common.ErrorPrintln("降雨量静态数据查询异常", err)
+	defer func() {
+		err := row.Close()
+		common.ErrorPrintln("row 关闭异常", err)
+	}()
+	Arrs := make([]*common.RainfallInfor, 0)
+	for row.Next() {
+		saturation := new(common.RainfallInfor)
+		err := row.Scan(&saturation.Equipno, &saturation.Equipname, &saturation.Longitude, &saturation.Latitude, &saturation.Altitude, &saturation.IsUsed, &saturation.IsSync)
+		common.ErrorPrintln("scan 降雨量数据读取异常", err)
+		Arrs = append(Arrs, saturation)
+	}
+	return Arrs
+}
+
+
+/*
+	内部位移静态数据
+*/
+func NeibuweiyiStaticData() []*common.InclinometerInfor {
+	row, err := config.DB.Query(config.StaticSql.NbwystaticSql)
+	common.ErrorPrintln("内部位移静态数据查询异常", err)
+	defer func() {
+		err := row.Close()
+		common.ErrorPrintln("row 关闭异常", err)
+	}()
+	Arrs := make([]*common.InclinometerInfor, 0)
+	for row.Next() {
+		saturation := new(common.InclinometerInfor)
+		err := row.Scan(&saturation.Equipno, &saturation.Equipname, &saturation.Longitude, &saturation.Latitude, &saturation.Altitude, &saturation.IsUsed, &saturation.IsSync)
+		common.ErrorPrintln("scan 内部位移数据读取异常", err)
+		Arrs = append(Arrs, saturation)
+	}
+	return Arrs
+}
\ No newline at end of file

go.mod

@@ -4,6 +4,7 @@ go 1.15
 
 require (
 	github.com/denisenkom/go-mssqldb v0.0.0-20200910202707-1e08a3fab204
+	github.com/go-sql-driver/mysql v1.5.0
 	github.com/lib/pq v1.8.0
 	gopkg.in/ini.v1 v1.62.0
 )

go.sum

 github.com/denisenkom/go-mssqldb v0.0.0-20200910202707-1e08a3fab204 h1:tI48fqaIkxxYuIylVv1tdDfBp6836GKSfmmzgSyP1CY=
 github.com/denisenkom/go-mssqldb v0.0.0-20200910202707-1e08a3fab204/go.mod h1:xbL0rPBG9cCiLr28tMa8zpbdarY27NDyej4t/EjAShU=
+github.com/go-sql-driver/mysql v1.5.0 h1:ozyZYNQW3x3HtqT1jira07DN2PArx2v7/mN66gGcHOs=
+github.com/go-sql-driver/mysql v1.5.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
 github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe h1:lXe2qZdvpiX5WZkZR4hgp4KJVfY3nMkvmwbVkpv1rVY=
 github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
 github.com/lib/pq v1.8.0 h1:9xohqzkUwzR4Ga4ivdTcawVS89YSDVxXMa3xJX3cGzg=

main.go

@@ -3,9 +3,35 @@ package main
 import (
 	"log"
 	"shandong_datapush/config"
+	"shandong_datapush/service"
+	"time"
 )
 
 func main() {
 	log.Println("==================数据推送程序启动=================")
 	config.DBConnection()
+	service.WkkBasicDataProcess()
+	service.KswStaticDataProcess()
+	service.GtStaticDataProcess()
+	service.JrxStaticDataProcess()
+	service.JylStaticDataProcess()
+	service.NbwyStaticDataProcess()
+}
+
+/*
+	静态数据推送
+ */
+func staticDataPush() {
+	for range time.Tick(time.Second * 10){
+		log.Println("=======================================staticDataPush")
+	}
+}
+
+/*
+	实时数据推送
+ */
+func realTimeDataPush() {
+	for range time.Tick(time.Second * 20){
+		log.Println("=======================================realTimeDataPush")
+	}
 }
\ No newline at end of file

service/realTimeDataProcess.go

+package service
+
+/*
+	干滩实时数据
+ */
+func GtRealDataProcess()  {
+	/*row, err := config.DB.Query(config.RealTimeSql.GtRealTimeSql)
+	common.ErrorPrintln("干滩实时数据查询异常", err)
+	Arrs := make([]*common.DryBeachData, 0)
+	for row.Next() {
+		dryBeach := new(common.DryBeachData)
+		row.Scan()
+	}*/
+}
\ No newline at end of file

service/staticDataProcess.go

+package service
+
+import (
+	"bytes"
+	"encoding/xml"
+	"log"
+	"net/http"
+	"shandong_datapush/common"
+	"shandong_datapush/config"
+	"shandong_datapush/dao"
+)
+
+/*
+	尾矿库静态数据处理
+ */
+func WkkBasicDataProcess() {
+	client := &http.Client{}
+	by, err := xml.Marshal(config.TailPond)
+	log.Println(">>>>>>>>>>>>>>>>>>>", string(by))
+	common.ErrorPrintln("wkkBasicDataProcess", err)
+	req, err := http.NewRequest("POST", "https://www.baidu.com", bytes.NewReader(by))
+	client.Do(req)
+}
+
+
+/*
+	干滩静态数据处理
+ */
+func GtStaticDataProcess() {
+	gtArrs := dao.GantanStaticData()
+	by, err := xml.Marshal(gtArrs)
+	common.ErrorPrintln("干滩静态数据格式化失败", err)
+	log.Println("干滩>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>", string(by))
+}
+
+
+/*
+	库水位静态数据处理
+ */
+func KswStaticDataProcess() {
+	kswArrs := dao.KushuiweiStaticData()
+	by, err := xml.Marshal(kswArrs)
+	common.ErrorPrintln("库水位静态数据格式化失败", err)
+	log.Println("库水位>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>", string(by))
+}
+
+
+/*
+	浸润线静态数据处理
+ */
+func JrxStaticDataProcess() {
+	jrxArrs := dao.JinrunxianStaticData()
+	by, err := xml.Marshal(jrxArrs)
+	common.ErrorPrintln("浸润线静态数据格式化失败", err)
+	log.Println("浸润线>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>", string(by))
+}
+
+/*
+	降雨量静态数据处理
+*/
+func JylStaticDataProcess() {
+	jylArrs := dao.JiangyuliangStaticData()
+	by, err := xml.Marshal(jylArrs)
+	common.ErrorPrintln("降雨量静态数据格式化失败", err)
+	log.Println("降雨量>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>", string(by))
+}
+
+/*
+	降雨量静态数据处理
+*/
+func NbwyStaticDataProcess() {
+	jylArrs := dao.NeibuweiyiStaticData()
+	by, err := xml.Marshal(jylArrs)
+	common.ErrorPrintln("内部位移静态数据格式化失败", err)
+	log.Println("内部位移>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>", string(by))
+}
\ No newline at end of file