更新 项目包名称为 goInOut

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"

adaptors/安心云es主题to河北矿山监测.go

@@ -4,7 +4,7 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"goUpload/models"
+	"goInOut/models"
 	"log"
 	"math"
 	"strings"

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"
 )

adaptors/振动to明月峡.go

@@ -3,8 +3,8 @@ package adaptors
 import (
 	"encoding/json"
 	"fmt"
-	"goUpload/models"
-	"goUpload/utils"
+	"goInOut/models"
+	"goInOut/utils"
 	"log"
 	"strings"
 	"time"

adaptors/振动to湘潭健康监测.go

@@ -2,7 +2,7 @@ package adaptors
 
 import (
 	"encoding/json"
-	"goUpload/models"
+	"goInOut/models"
 	"log"
 	"math"
 	"time"

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"
 )

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"

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"

adaptors/统一采集to明月峡.go

@@ -3,7 +3,7 @@ package adaptors
 import (
 	"encoding/json"
 	"fmt"
-	"goUpload/models"
+	"goInOut/models"
 	"log"
 	"strings"
 	"time"

adaptors/统一采集to江苏省农村公路桥梁监测.go

@@ -3,8 +3,8 @@ package adaptors
 import (
 	"encoding/json"
 	"fmt"
-	"goUpload/models"
-	"goUpload/utils"
+	"goInOut/models"
+	"goInOut/utils"
 	"log"
 	"time"
 )

adaptors/统一采集to湘潭健康监测.go

@@ -3,7 +3,7 @@ package adaptors
 import (
 	"encoding/hex"
 	"encoding/json"
-	"goUpload/models"
+	"goInOut/models"
 	"log"
 	"math"
 	"time"

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"

adaptors/视觉位移to魏家滑坡.go

@@ -3,7 +3,7 @@ package adaptors
 import (
 	"encoding/json"
 	"fmt"
-	"goUpload/consumers/WJHP"
+	"goInOut/consumers/WJHP"
 	"log"
 	"strconv"
 	"time"

consumers/AXYraw/config.go

@@ -1,6 +1,6 @@
 package AXYraw
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/CDJYSN/config.go

@@ -1,6 +1,6 @@
 package CDJYSN
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/CQZG/config.go

@@ -1,6 +1,6 @@
 package CQZG
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/GZGZM/config.go

@@ -1,6 +1,6 @@
 package GZGZM
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/HTJC/config.go

@@ -1,6 +1,6 @@
 package HTJC
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/JSNCGLQL/config.go

@@ -1,6 +1,6 @@
 package JSNCGLQL
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/MYX/config.go

@@ -1,6 +1,6 @@
 package MYX
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

consumers/WJHP/config.go

@@ -1,6 +1,6 @@
 package WJHP
 
-import "goUpload/config"
+import "goInOut/config"
 
 type ConfigFile struct {
 	config.Consumer

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"

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"

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"

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"

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"

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"

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"

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"

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"

go.mod

@@ -1,4 +1,4 @@
-module goUpload
+module goInOut
 
 go 1.21
 

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"

monitors/httpMonitor.go

@@ -1,6 +1,6 @@
 package monitors
 
-import "goUpload/dbHelper"
+import "goInOut/dbHelper"
 
 type HttpMonitor struct {
 	HttpClient *dbHelper.HttpHelper