diff --git a/adaptors/光电光栅中科to明月峡.go b/adaptors/光电光栅中科to明月峡.go index 19b35cd..7e433a7 100644 --- a/adaptors/光电光栅中科to明月峡.go +++ b/adaptors/光电光栅中科to明月峡.go @@ -3,8 +3,8 @@ package adaptors import ( "bytes" "fmt" - "goUpload/consumers/MYX" - "goUpload/utils" + "goInOut/consumers/MYX" + "goInOut/utils" "log" "strconv" "strings" diff --git a/adaptors/安心云es主题to河北矿山监测.go b/adaptors/安心云es主题to河北矿山监测.go index c25e3f5..0549c93 100644 --- a/adaptors/安心云es主题to河北矿山监测.go +++ b/adaptors/安心云es主题to河北矿山监测.go @@ -4,7 +4,7 @@ import ( "bytes" "encoding/json" "fmt" - "goUpload/models" + "goInOut/models" "log" "math" "strings" diff --git a/adaptors/安心云最新设备数据toES.go b/adaptors/安心云最新设备数据toES.go index d361ca7..7b18115 100644 --- a/adaptors/安心云最新设备数据toES.go +++ b/adaptors/安心云最新设备数据toES.go @@ -3,9 +3,9 @@ package adaptors import ( "encoding/json" "fmt" - "goUpload/consumers/AXYraw" - "goUpload/dbHelper" - "goUpload/models" + "goInOut/consumers/AXYraw" + "goInOut/dbHelper" + "goInOut/models" "log" "time" ) diff --git a/adaptors/振动to明月峡.go b/adaptors/振动to明月峡.go index 8c258de..5b17ed8 100644 --- a/adaptors/振动to明月峡.go +++ b/adaptors/振动to明月峡.go @@ -3,8 +3,8 @@ package adaptors import ( "encoding/json" "fmt" - "goUpload/models" - "goUpload/utils" + "goInOut/models" + "goInOut/utils" "log" "strings" "time" diff --git a/adaptors/振动to湘潭健康监测.go b/adaptors/振动to湘潭健康监测.go index c68edff..09e58ad 100644 --- a/adaptors/振动to湘潭健康监测.go +++ b/adaptors/振动to湘潭健康监测.go @@ -2,7 +2,7 @@ package adaptors import ( "encoding/json" - "goUpload/models" + "goInOut/models" "log" "math" "time" diff --git a/adaptors/振动to重庆资管.go b/adaptors/振动to重庆资管.go index 2469978..08ec265 100644 --- a/adaptors/振动to重庆资管.go +++ b/adaptors/振动to重庆资管.go @@ -3,9 +3,9 @@ package adaptors import ( "crypto/rc4" "encoding/json" - "goUpload/consumers/CQZG/protoFiles" - "goUpload/models" - "goUpload/utils" + "goInOut/consumers/CQZG/protoFiles" + "goInOut/models" + "goInOut/utils" "google.golang.org/protobuf/proto" "log" ) diff --git a/adaptors/欧乐称重to重庆资管.go b/adaptors/欧乐称重to重庆资管.go index 5842290..7afe8d3 100644 --- a/adaptors/欧乐称重to重庆资管.go +++ b/adaptors/欧乐称重to重庆资管.go @@ -4,9 +4,9 @@ import ( "crypto/rc4" "encoding/hex" "encoding/json" - "goUpload/consumers/CQZG/protoFiles" - "goUpload/models" - "goUpload/utils" + "goInOut/consumers/CQZG/protoFiles" + "goInOut/models" + "goInOut/utils" "google.golang.org/protobuf/proto" "log" "strconv" diff --git a/adaptors/知物云主题数据to广州高支模省平台.go b/adaptors/知物云主题数据to广州高支模省平台.go index aed06e8..023a78e 100644 --- a/adaptors/知物云主题数据to广州高支模省平台.go +++ b/adaptors/知物云主题数据to广州高支模省平台.go @@ -3,8 +3,8 @@ package adaptors import ( "encoding/json" "fmt" - "goUpload/consumers/GZGZM" - "goUpload/models" + "goInOut/consumers/GZGZM" + "goInOut/models" "log" "math" "strconv" diff --git a/adaptors/统一采集to明月峡.go b/adaptors/统一采集to明月峡.go index d0b728b..d20b01c 100644 --- a/adaptors/统一采集to明月峡.go +++ b/adaptors/统一采集to明月峡.go @@ -3,7 +3,7 @@ package adaptors import ( "encoding/json" "fmt" - "goUpload/models" + "goInOut/models" "log" "strings" "time" diff --git a/adaptors/统一采集to江苏省农村公路桥梁监测.go b/adaptors/统一采集to江苏省农村公路桥梁监测.go index a79886a..2f3d612 100644 --- a/adaptors/统一采集to江苏省农村公路桥梁监测.go +++ b/adaptors/统一采集to江苏省农村公路桥梁监测.go @@ -3,8 +3,8 @@ package adaptors import ( "encoding/json" "fmt" - "goUpload/models" - "goUpload/utils" + "goInOut/models" + "goInOut/utils" "log" "time" ) diff --git a/adaptors/统一采集to湘潭健康监测.go b/adaptors/统一采集to湘潭健康监测.go index d5aa38c..5eb8830 100644 --- a/adaptors/统一采集to湘潭健康监测.go +++ b/adaptors/统一采集to湘潭健康监测.go @@ -3,7 +3,7 @@ package adaptors import ( "encoding/hex" "encoding/json" - "goUpload/models" + "goInOut/models" "log" "math" "time" diff --git a/adaptors/统一采集to重庆资管.go b/adaptors/统一采集to重庆资管.go index 654b9d0..71e16aa 100644 --- a/adaptors/统一采集to重庆资管.go +++ b/adaptors/统一采集to重庆资管.go @@ -4,9 +4,9 @@ import ( "crypto/rc4" "encoding/hex" "encoding/json" - "goUpload/consumers/CQZG/protoFiles" - "goUpload/models" - "goUpload/utils" + "goInOut/consumers/CQZG/protoFiles" + "goInOut/models" + "goInOut/utils" "google.golang.org/protobuf/proto" "log" "time" diff --git a/adaptors/视觉位移to魏家滑坡.go b/adaptors/视觉位移to魏家滑坡.go index 79f40ec..78d8144 100644 --- a/adaptors/视觉位移to魏家滑坡.go +++ b/adaptors/视觉位移to魏家滑坡.go @@ -3,7 +3,7 @@ package adaptors import ( "encoding/json" "fmt" - "goUpload/consumers/WJHP" + "goInOut/consumers/WJHP" "log" "strconv" "time" diff --git a/consumers/AXYraw/config.go b/consumers/AXYraw/config.go index d3911fe..300bd34 100644 --- a/consumers/AXYraw/config.go +++ b/consumers/AXYraw/config.go @@ -1,6 +1,6 @@ package AXYraw -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/CDJYSN/config.go b/consumers/CDJYSN/config.go index 9352fd5..52f4bb7 100644 --- a/consumers/CDJYSN/config.go +++ b/consumers/CDJYSN/config.go @@ -1,6 +1,6 @@ package CDJYSN -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/CQZG/config.go b/consumers/CQZG/config.go index 7b1951b..58fbe19 100644 --- a/consumers/CQZG/config.go +++ b/consumers/CQZG/config.go @@ -1,6 +1,6 @@ package CQZG -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/GZGZM/config.go b/consumers/GZGZM/config.go index 6a91f52..71b1ea3 100644 --- a/consumers/GZGZM/config.go +++ b/consumers/GZGZM/config.go @@ -1,6 +1,6 @@ package GZGZM -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/HTJC/config.go b/consumers/HTJC/config.go index bd02b66..6e08e07 100644 --- a/consumers/HTJC/config.go +++ b/consumers/HTJC/config.go @@ -1,6 +1,6 @@ package HTJC -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/JSNCGLQL/config.go b/consumers/JSNCGLQL/config.go index af6f61c..2eea35c 100644 --- a/consumers/JSNCGLQL/config.go +++ b/consumers/JSNCGLQL/config.go @@ -1,6 +1,6 @@ package JSNCGLQL -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/MYX/config.go b/consumers/MYX/config.go index f7ced8c..16c7d78 100644 --- a/consumers/MYX/config.go +++ b/consumers/MYX/config.go @@ -1,6 +1,6 @@ package MYX -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/WJHP/config.go b/consumers/WJHP/config.go index 33e4bee..005f462 100644 --- a/consumers/WJHP/config.go +++ b/consumers/WJHP/config.go @@ -1,6 +1,6 @@ package WJHP -import "goUpload/config" +import "goInOut/config" type ConfigFile struct { config.Consumer diff --git a/consumers/consumerAXYraw.go b/consumers/consumerAXYraw.go index 2c28651..ae309f8 100644 --- a/consumers/consumerAXYraw.go +++ b/consumers/consumerAXYraw.go @@ -2,11 +2,11 @@ package consumers import ( "encoding/json" - "goUpload/adaptors" - "goUpload/consumers/AXYraw" - "goUpload/dbHelper" - "goUpload/dbHelper/_kafka" - "goUpload/models" + "goInOut/adaptors" + "goInOut/consumers/AXYraw" + "goInOut/dbHelper" + "goInOut/dbHelper/_kafka" + "goInOut/models" "log" "sync" "time" diff --git a/consumers/consumerCDJYSN.go b/consumers/consumerCDJYSN.go index b47fc8d..c4a7d26 100644 --- a/consumers/consumerCDJYSN.go +++ b/consumers/consumerCDJYSN.go @@ -4,11 +4,11 @@ import ( "encoding/json" "fmt" "github.com/robfig/cron/v3" - "goUpload/adaptors" - "goUpload/consumers/CDJYSN" - "goUpload/dbHelper" - "goUpload/monitors" - "goUpload/utils" + "goInOut/adaptors" + "goInOut/consumers/CDJYSN" + "goInOut/dbHelper" + "goInOut/monitors" + "goInOut/utils" "log" "path" "time" diff --git a/consumers/consumerCQZG.go b/consumers/consumerCQZG.go index 4fe9e55..bfb6329 100644 --- a/consumers/consumerCQZG.go +++ b/consumers/consumerCQZG.go @@ -2,9 +2,9 @@ package consumers import ( "encoding/json" - "goUpload/adaptors" - "goUpload/consumers/CQZG" - "goUpload/dbHelper" + "goInOut/adaptors" + "goInOut/consumers/CQZG" + "goInOut/dbHelper" "log" "os" "strings" diff --git a/consumers/consumerGZGZM.go b/consumers/consumerGZGZM.go index 61e722c..17c88aa 100644 --- a/consumers/consumerGZGZM.go +++ b/consumers/consumerGZGZM.go @@ -4,10 +4,10 @@ import ( "crypto/md5" "encoding/json" "fmt" - "goUpload/adaptors" - "goUpload/consumers/GZGZM" - "goUpload/dbHelper" - "goUpload/dbHelper/_kafka" + "goInOut/adaptors" + "goInOut/consumers/GZGZM" + "goInOut/dbHelper" + "goInOut/dbHelper/_kafka" "io" "log" "math/rand" diff --git a/consumers/consumerHTJC.go b/consumers/consumerHTJC.go index 69d7260..4069803 100644 --- a/consumers/consumerHTJC.go +++ b/consumers/consumerHTJC.go @@ -2,9 +2,9 @@ package consumers import ( "encoding/json" - "goUpload/adaptors" - "goUpload/consumers/HTJC" - "goUpload/dbHelper" + "goInOut/adaptors" + "goInOut/consumers/HTJC" + "goInOut/dbHelper" "log" "strings" "time" diff --git a/consumers/consumerJSNCGLQL.go b/consumers/consumerJSNCGLQL.go index aeba710..11ed88c 100644 --- a/consumers/consumerJSNCGLQL.go +++ b/consumers/consumerJSNCGLQL.go @@ -2,9 +2,9 @@ package consumers import ( "encoding/json" - "goUpload/adaptors" - "goUpload/consumers/JSNCGLQL" - "goUpload/dbHelper" + "goInOut/adaptors" + "goInOut/consumers/JSNCGLQL" + "goInOut/dbHelper" "log" "strings" "time" diff --git a/consumers/consumerMYX.go b/consumers/consumerMYX.go index 51309a6..a140a17 100644 --- a/consumers/consumerMYX.go +++ b/consumers/consumerMYX.go @@ -5,10 +5,10 @@ import ( "encoding/csv" "encoding/json" "fmt" - "goUpload/adaptors" - "goUpload/consumers/MYX" - "goUpload/dbHelper" - "goUpload/monitors" + "goInOut/adaptors" + "goInOut/consumers/MYX" + "goInOut/dbHelper" + "goInOut/monitors" "golang.org/x/text/encoding/unicode" "log" "os" diff --git a/consumers/consumerWJHP.go b/consumers/consumerWJHP.go index d2996fa..9e3f778 100644 --- a/consumers/consumerWJHP.go +++ b/consumers/consumerWJHP.go @@ -2,10 +2,10 @@ package consumers import ( "encoding/json" - "goUpload/adaptors" - "goUpload/consumers/WJHP" - "goUpload/dbHelper" - "goUpload/monitors" + "goInOut/adaptors" + "goInOut/consumers/WJHP" + "goInOut/dbHelper" + "goInOut/monitors" "log" "strings" "time" diff --git a/dbHelper/elasticsearchHelper.go b/dbHelper/elasticsearchHelper.go index b616537..bc14491 100644 --- a/dbHelper/elasticsearchHelper.go +++ b/dbHelper/elasticsearchHelper.go @@ -7,7 +7,7 @@ import ( "fmt" elasticsearch6 "github.com/elastic/go-elasticsearch/v6" "github.com/elastic/go-elasticsearch/v6/esapi" - "goUpload/models" + "goInOut/models" "io" "log" "strings" diff --git a/go.mod b/go.mod index 777e577..685dc9a 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module goUpload +module goInOut go 1.21 diff --git a/main.go b/main.go index c1555e1..1446613 100644 --- a/main.go +++ b/main.go @@ -2,8 +2,8 @@ package main import ( "fmt" - "goUpload/config" - "goUpload/consumers" + "goInOut/config" + "goInOut/consumers" "gopkg.in/natefinch/lumberjack.v2" "io" "log" diff --git a/monitors/httpMonitor.go b/monitors/httpMonitor.go index 83c31d6..124e0e0 100644 --- a/monitors/httpMonitor.go +++ b/monitors/httpMonitor.go @@ -1,6 +1,6 @@ package monitors -import "goUpload/dbHelper" +import "goInOut/dbHelper" type HttpMonitor struct { HttpClient *dbHelper.HttpHelper