change db and yf

change pg db add sqlserver
change pg db
13 changed files with 958 additions and 120 deletions
--- a/.gitignore
+++ b/.gitignore
@ -23,5 +23,5 @@
 # Go workspace file
 go.work
 go_mqtt
-
+go_mqtt.db

--- a/FullCpu.go
+++ b/FullCpu.go
@ -1,17 +0,0 @@
-package main
-
-import "time"
-
-func test_print(a int) {
-	for {
-
-	}
-}
-
-
-func main() {
-	for i := 0; i < 100; i++ {
-		go test_print(i)
-	}
-	time.Sleep(360000000*time.Second)
-}
--- a/beepack.sh
+++ b/beepack.sh
@ -12,7 +12,16 @@ bee pack -be GOOS=windows GOARCH=amd64

 #go build打包方式
 GOOS=windows GOARCH=amd64 go build
+GOOS=windows GOARCH=amd64 go build -o go_mqtt_pg.exe
+GOOS=windows GOARCH=amd64 go build -o go_mqtt_weather.exe

 GOOS=linux GOARCH=amd64 go build
+GOOS=linux GOARCH=amd64 go build -o go_mqtt_pg
+
+GOOS=freebsd GOARCH=amd64 go build
+GOOS=freebsd GOARCH=amd64 go build -o go_mqtt_pg
+
+GOOS=linux GOARCH=arm64 go build
+GOOS=linux GOARCH=arm64 go build -o go_mqtt_pg

 GOOS=darwin GOARCH=amd64 go build
--- a/go.mod
+++ b/go.mod
@ -2,21 +2,42 @@ module go_mqtt

 go 1.24.1

-require (
-	github.com/eclipse/paho.mqtt.golang v1.5.0
-	github.com/go-sql-driver/mysql v1.9.3
-	github.com/google/uuid v1.6.0
-	github.com/shopspring/decimal v1.4.0
-	gorm.io/driver/mysql v1.6.0
-	gorm.io/gorm v1.30.0
-)
-
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
+	github.com/denisenkom/go-mssqldb v0.12.3 // indirect
+	github.com/dustin/go-humanize v1.0.1 // indirect
+	github.com/eclipse/paho.mqtt.golang v1.5.0 // indirect
+	github.com/glebarez/go-sqlite v1.22.0 // indirect
+	github.com/glebarez/sqlite v1.11.0 // indirect
+	github.com/go-sql-driver/mysql v1.9.3 // indirect
+	github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect
+	github.com/golang-sql/sqlexp v0.1.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
 	github.com/gorilla/websocket v1.5.3 // indirect
+	github.com/jackc/pgpassfile v1.0.0 // indirect
+	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
+	github.com/jackc/pgx/v5 v5.7.5 // indirect
+	github.com/jackc/puddle/v2 v2.2.2 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mattn/go-sqlite3 v1.14.28 // indirect
+	github.com/microsoft/go-mssqldb v1.9.2 // indirect
+	github.com/ncruces/go-strftime v0.1.9 // indirect
+	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
+	github.com/shopspring/decimal v1.4.0 // indirect
+	golang.org/x/crypto v0.39.0 // indirect
+	golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b // indirect
 	golang.org/x/net v0.41.0 // indirect
 	golang.org/x/sync v0.15.0 // indirect
+	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
+	gorm.io/driver/mysql v1.6.0 // indirect
+	gorm.io/driver/postgres v1.6.0 // indirect
+	gorm.io/driver/sqlserver v1.6.0 // indirect
+	gorm.io/gorm v1.30.0 // indirect
+	modernc.org/libc v1.66.2 // indirect
+	modernc.org/mathutil v1.7.1 // indirect
+	modernc.org/memory v1.11.0 // indirect
+	modernc.org/sqlite v1.38.0 // indirect
 )
--- a/go.sum
+++ b/go.sum
@ -1,26 +1,203 @@
 filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+github.com/Azure/azure-sdk-for-go/sdk/azcore v0.19.0/go.mod h1:h6H6c8enJmmocHUbLiiGY6sx7f9i+X3m1CHdd5c6Rdw=
+github.com/Azure/azure-sdk-for-go/sdk/azcore v1.0.0/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U=
+github.com/Azure/azure-sdk-for-go/sdk/azcore v1.1.2/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U=
+github.com/Azure/azure-sdk-for-go/sdk/azidentity v0.11.0/go.mod h1:HcM1YX14R7CJcghJGOYCgdezslRSVzqwLf/q+4Y2r/0=
+github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.1.0/go.mod h1:bhXu1AjYL+wutSL/kpSq6s7733q2Rb0yuot9Zgfqa/0=
+github.com/Azure/azure-sdk-for-go/sdk/internal v0.7.0/go.mod h1:yqy467j36fJxcRV2TzfVZ1pCb5vxm4BtZPUdYWe/Xo8=
+github.com/Azure/azure-sdk-for-go/sdk/internal v1.0.0/go.mod h1:eWRD7oawr1Mu1sLCawqVc0CUiF43ia3qQMxLscsKQ9w=
+github.com/AzureAD/microsoft-authentication-library-for-go v0.5.1/go.mod h1:Vt9sXTKwMyGcOxSmLDMnGPgqsUg7m8pe215qMLrDXw4=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/denisenkom/go-mssqldb v0.12.3 h1:pBSGx9Tq67pBOTLmxNuirNTeB8Vjmf886Kx+8Y+8shw=
+github.com/denisenkom/go-mssqldb v0.12.3/go.mod h1:k0mtMFOnU+AihqFxPMiF05rtiDrorD1Vrm1KEz5hxDo=
+github.com/dnaeon/go-vcr v1.1.0/go.mod h1:M7tiix8f0r6mKKJ3Yq/kqU1OYf3MnfmBWVbPx/yU9ko=
+github.com/dnaeon/go-vcr v1.2.0/go.mod h1:R4UdLID7HZT3taECzJs4YgbbH6PIGXB6W/sc5OLb6RQ=
+github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
+github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
 github.com/eclipse/paho.mqtt.golang v1.5.0 h1:EH+bUVJNgttidWFkLLVKaQPGmkTUfQQqjOsyvMGvD6o=
 github.com/eclipse/paho.mqtt.golang v1.5.0/go.mod h1:du/2qNQVqJf/Sqs4MEL77kR8QTqANF7XU7Fk0aOTAgk=
+github.com/glebarez/go-sqlite v1.22.0 h1:uAcMJhaA6r3LHMTFgP0SifzgXg46yJkgxqyuyec+ruQ=
+github.com/glebarez/go-sqlite v1.22.0/go.mod h1:PlBIdHe0+aUEFn+r2/uthrWq4FxbzugL0L8Li6yQJbc=
+github.com/glebarez/sqlite v1.11.0 h1:wSG0irqzP6VurnMEpFGer5Li19RpIRi2qvQz++w0GMw=
+github.com/glebarez/sqlite v1.11.0/go.mod h1:h8/o8j5wiAsqSPoWELDUdJXhjAhsVliSn7bWZjOhrgQ=
 github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1aweo=
 github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=
+github.com/golang-jwt/jwt v3.2.1+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
+github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
+github.com/golang-jwt/jwt/v4 v4.2.0/go.mod h1:/xlHOz8bRuivTWchD4jCa+NbatV+wEUSzwAxVc6locg=
+github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
+github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
+github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
+github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
+github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI=
+github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/gorilla/securecookie v1.1.1/go.mod h1:ra0sb63/xPlUeL+yeDciTfxMRAA+MP+HVt/4epWDjd4=
+github.com/gorilla/sessions v1.2.1/go.mod h1:dk2InVEVJ0sfLlnXv9EAgkf6ecYs/i80K/zI+bUmuGM=
 github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
 github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
+github.com/hashicorp/go-uuid v1.0.2/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
+github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
+github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
+github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 h1:iCEnooe7UlwOQYpKFhBabPMi4aNAfoODPEFNiAnClxo=
+github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
+github.com/jackc/pgx/v5 v5.7.5 h1:JHGfMnQY+IEtGM63d+NGMjoRpysB2JBwDr5fsngwmJs=
+github.com/jackc/pgx/v5 v5.7.5/go.mod h1:aruU7o91Tc2q2cFp5h4uP3f6ztExVpyVv88Xl/8Vl8M=
+github.com/jackc/puddle/v2 v2.2.2 h1:PR8nw+E/1w0GLuRFSmiioY6UooMp6KJv0/61nB7icHo=
+github.com/jackc/puddle/v2 v2.2.2/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
+github.com/jcmturner/aescts/v2 v2.0.0/go.mod h1:AiaICIRyfYg35RUkr8yESTqvSy7csK90qZ5xfvvsoNs=
+github.com/jcmturner/dnsutils/v2 v2.0.0/go.mod h1:b0TnjGOvI/n42bZa+hmXL+kFJZsFT7G4t3HTlQ184QM=
+github.com/jcmturner/gofork v1.0.0/go.mod h1:MK8+TM0La+2rjBD4jE12Kj1pCCxK7d2LK/UM3ncEo0o=
+github.com/jcmturner/goidentity/v6 v6.0.1/go.mod h1:X1YW3bgtvwAXju7V3LCIMpY0Gbxyjn/mY9zx4tFonSg=
+github.com/jcmturner/gokrb5/v8 v8.4.2/go.mod h1:sb+Xq/fTY5yktf/VxLsE3wlfPqQjp0aWNYyvBVK62bc=
+github.com/jcmturner/rpc/v2 v2.0.3/go.mod h1:VUJYCIDm3PVOEHw8sgt091/20OJjskO/YJki3ELg/Hc=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
 github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
+github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
+github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
+github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+github.com/mattn/go-sqlite3 v1.14.28 h1:ThEiQrnbtumT+QMknw63Befp/ce/nUPgBPMlRFEum7A=
+github.com/mattn/go-sqlite3 v1.14.28/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
+github.com/microsoft/go-mssqldb v0.19.0/go.mod h1:ukJCBnnzLzpVF0qYRT+eg1e+eSwjeQ7IvenUv8QPook=
+github.com/microsoft/go-mssqldb v1.9.2 h1:nY8TmFMQOHpm2qVWo6y4I2mAmVdZqlGiMGAYt64Ibbs=
+github.com/microsoft/go-mssqldb v1.9.2/go.mod h1:GBbW9ASTiDC+mpgWDGKdm3FnFLTUsLYN3iFL90lQ+PA=
+github.com/modocache/gover v0.0.0-20171022184752-b58185e213c5/go.mod h1:caMODM3PzxT8aQXRPkAt8xlV/e7d7w8GM5g0fa5F0D8=
+github.com/montanaflynn/stats v0.6.6/go.mod h1:etXPPgVO6n31NxCd9KQUMvCM+ve0ruNzt6R8Bnaayow=
+github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4=
+github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=
+github.com/pkg/browser v0.0.0-20180916011732-0a3d74bf9ce4/go.mod h1:4OwLy04Bl9Ef3GJJCoec+30X3LQs/0/m4HFRt/2LUSA=
+github.com/pkg/browser v0.0.0-20210115035449-ce105d075bb4/go.mod h1:N6UoU20jOqggOuDwUaBQpluzLNDqif3kq9z2wpdYEfQ=
+github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8/go.mod h1:HKlIX3XHQyzLZPlr7++PzdhaXEj94dEiJgZDTsxEqUI=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
+github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
 github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/crypto v0.0.0-20201016220609-9e8e0b390897/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/crypto v0.0.0-20201112155050-0c6587e931a9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
+golang.org/x/crypto v0.0.0-20220511200225-c6db032c6c88/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
+golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
+golang.org/x/crypto v0.13.0/go.mod h1:y6Z2r+Rw4iayiXXAIxJIDAJ1zMW4yaTpebo8fPOliYc=
+golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU=
+golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8=
+golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=
+golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=
+golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b h1:M2rDM6z3Fhozi9O7NWsxAkg/yqS/lQJ6PmkyIV3YP+o=
+golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b/go.mod h1:3//PLf8L/X+8b4vuAfHzxeRUl04Adcb341+IGKfnqS8=
+golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
+golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
+golang.org/x/mod v0.12.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
+golang.org/x/mod v0.15.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20201010224723-4f7140c49acb/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
+golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
+golang.org/x/net v0.0.0-20210610132358-84b48f89b13b/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20220425223048-2871e0cb64e4/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
+golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
+golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
+golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk=
+golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
+golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM=
 golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=
 golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.3.0/go.mod h1:FU7BRWz2tNW+3quACPkgCx/L+uEAv1htQ0V83Z9Rj+Y=
+golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.9.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sync v0.15.0 h1:KWH3jNZsfyT6xfAfKiz6MRNmd46ByHDYaZ7KSkCtdW8=
 golang.org/x/sync v0.15.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20210616045830-e2b7044e8c71/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220224120231-95c6836cb0e7/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
+golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2/go.mod h1:TeRTkGYfJXctD9OcfyVLyj2J3IxLnKwHJR8f4D8a3YE=
+golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
+golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
+golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
+golang.org/x/term v0.12.0/go.mod h1:owVbMEjm3cBLCHdkQu9b1opXd4ETQWc3BhuQGKgXgvU=
+golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk=
+golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
+golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
+golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
+golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
+golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
+golang.org/x/text v0.20.0/go.mod h1:D4IsuqiFMhST5bX19pQ9ikHC2GsaKyk/oF+pn3ducp4=
 golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
 golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
+golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
+golang.org/x/tools v0.13.0/go.mod h1:HvlwmtVNQAhOuCjW7xxvovg8wbNq7LwfXh/k7wXUl58=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/natefinch/npipe.v2 v2.0.0-20160621034901-c1b8fa8bdcce/go.mod h1:5AcXVHNjg+BDxry382+8OKon8SEWiKktQR07RKPsv1c=
+gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gorm.io/driver/mysql v1.6.0 h1:eNbLmNTpPpTOVZi8MMxCi2aaIm0ZpInbORNXDwyLGvg=
 gorm.io/driver/mysql v1.6.0/go.mod h1:D/oCC2GWK3M/dqoLxnOlaNKmXz8WNTfcS9y5ovaSqKo=
+gorm.io/driver/postgres v1.6.0 h1:2dxzU8xJ+ivvqTRph34QX+WrRaJlmfyPqXmoGVjMBa4=
+gorm.io/driver/postgres v1.6.0/go.mod h1:vUw0mrGgrTK+uPHEhAdV4sfFELrByKVGnaVRkXDhtWo=
+gorm.io/driver/sqlserver v1.6.0 h1:VZOBQVsVhkHU/NzNhRJKoANt5pZGQAS1Bwc6m6dgfnc=
+gorm.io/driver/sqlserver v1.6.0/go.mod h1:WQzt4IJo/WHKnckU9jXBLMJIVNMVeTu25dnOzehntWw=
 gorm.io/gorm v1.30.0 h1:qbT5aPv1UH8gI99OsRlvDToLxW5zR7FzS9acZDOZcgs=
 gorm.io/gorm v1.30.0/go.mod h1:8Z33v652h4//uMA76KjeDH8mJXPm1QNCYrMeatR0DOE=
+modernc.org/libc v1.66.2 h1:JCBxlJzZOIwZY54fzjHN3Wsn8Ty5PUTPr/xioRkmecI=
+modernc.org/libc v1.66.2/go.mod h1:ceIGzvXxP+JV3pgVjP9avPZo6Chlsfof2egXBH3YT5Q=
+modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
+modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
+modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=
+modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
+modernc.org/sqlite v1.38.0 h1:+4OrfPQ8pxHKuWG4md1JpR/EYAh3Md7TdejuuzE7EUI=
+modernc.org/sqlite v1.38.0/go.mod h1:1Bj+yES4SVvBZ4cBOpVZ6QgesMCKpJZDq0nxYzOpmNE=
--- a/install_goget.sh
+++ b/install_goget.sh
@ -9,6 +9,12 @@

 #mysql driver
 go get -u github.com/go-sql-driver/mysql
+#sqlite driver
+go get -u github.com/glebarez/sqlite
+#postgres driver
+go get -u gorm.io/driver/postgres
+#sqlserver driver
+go get -u "gorm.io/driver/sqlserver"
 #uuid
 go get github.com/google/uuid
 #gorm
--- a/main.go
+++ b/main.go
@ -24,6 +24,8 @@ import (
 	"time"
 )

+var ExitFlag bool = false
+
 func getMySqlDB() (*sql.DB, error) {
 	dsn := "root:Skyinno251,@tcp(47.242.184.139:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
 	db, err := sql.Open("mysql", dsn)
@ -186,7 +188,6 @@ func dbTest() {
 	stmt.Exec(1)
 }

-
 // GenRsaKey generates an PKCS#1 RSA keypair of the given bit size in PEM format.
 func GenRsaKey(bits int) (prvkey, pubkey []byte, err error) {
 	// Generates private key.
@ -215,7 +216,6 @@ func GenRsaKey(bits int) (prvkey, pubkey []byte, err error) {
 	return
 }

-
 func ParseRSAPrivateKeyFromPEM(pemData string) (*rsa.PrivateKey, error) {
 	var keyData = []byte(pemData)
 	// 解析PEM块
@ -436,7 +436,6 @@ func RsaEncryptBlock(src []byte, path string) (bytesEncrypt []byte, err error) {
 	return
 }

-
 func timing(client mqtt.Client) {
 	//定时器，10秒钟执行一次
 	ticker := time.NewTicker(10 * time.Second)
@ -475,7 +474,6 @@ func timing(client mqtt.Client) {
 			//fmt.Println("解密后的字符串：")
 			//fmt.Println(string(decrptCode))

-
 		}
 	}
 }
@ -488,7 +486,6 @@ var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Me
 	fmt.Println(message)
 	fmt.Println(topic)

-
 	//privatePath := "/Users/edao/GolandProjects/go_mqtt/privateKey.pem"
 	privateKeyPEM := `-----BEGIN PRIVATE KEY-----
 MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL3dDf12MSeIY2jm5QpUSSoMhrJOWLbOt5fXQepPaNO0M30A+3C4SFZrM/9WA5ehazO1u1m1LAkYzoSDRH3MMJsrJC3lCGDeOROteu+safuP9k/npU1YQu/+Ll2xEJNxyvUx4jLGM4LamiMI6ytM3gdnOAGP4YRQo9Etwo6I986yg/seCQC5rza9M4iBamoin7U8h9yOMKrM6xK/k9CcY/vn5+Uhe3Pvk4qj/2Ff3OXkkc1wfdILqdLwLOKL0Tb3ZciwG0p1CKO80yf5hyYoWjqZk5Rcd07nTo2gqTFGfLl9sqI9/+ipMDtnHlAgMBAAECggEATJd5yCC6lusdMRO5FOBUyUaUi9X2i1AU+RZKAynQySvSnbavUgExW58tRCHBUrGW9gJp59ft1N8J8hHhSO18NDY4H7laBlVdnwmYjRqtFo2VQO6sD4G8JRDION5f2iIxn/b2fYDI9H8vILfJRbNgtTSILyGlzTYUZzhLKxCh+8IsN96Nic8wa5COd1vZZmdhf2y8TG8clFWmozaScNSAATx7y+8XLVWjjWiIRZ6xQvx0uQPUParc9KihXXTKR2pA22yPIdz+U4MGD4kC0eczlcFKZ/dYv9e7OIGgnJfT0idSCu7nYb1pxJ1LxD9fS6IScNTF5dSe0OIL98e+XdyoAQKBgQDRep+5cW4iAKrEMH+djmcXAkoMiYtNVtnu0efLE8dP6vjYytQi368X9SdcASbfrQ31eEZmr/xQnlUF8oyHGkI38YS8dpAHzQcrkP3BljbbzB/3gJZaUdghGsDrK0xAJIzzmFKQpeKnGtr23vxUgaGrNsCYvQ0eQ7+5056KXS4r5QKBgQC6r8xtRSaje6L4WIydjWvYywsmRO0Of0aJLMDA/Wt2MWhHfh7ba9oI1cKGN80ap7xB2a9lQLgpv+C53wNtE5SpvjxsikAj96nUMMhGy9ojXrUith6HQhiINETz6Shnznd+AyrXP6KI/RpfA5nkDB5nrJxODwtYLP467IL7Cv7OAQKBgQCl4KxKdH/5fP28jYsAgJsxpSZt9xzQCU5Zxu396ZOSvUaApVyGoQpNtluMh3z48lhzYOKevgzW6gn5w69z7F8zXZT2iAxVoQ1kelP2z7RxKJrHqpNkwhqbXEwX7RlcUZUr8BqxYCqymJl7k+fMIzqaEalBSbLxnEReKi0I8/Bz4QKBgHK4b0ZCtVDHPEmimJ6E9l4dv/c/afF7swu+zaCK2ouiJvOwBCRQbYb6XPR/u/GCXASXUdpF4CX/vIhcDE3uN2/r8FO+zVWM7vbvF1OyF5WesG7pPW9e5ZZlkG3WvLa1wOZV6fCmMSo/ZwI2Q05JSDHrd43cXttLotrw1jiQ9C4BAoGBAKi4SOoOVQ5J5HQCDkBwPbG1AOLHFinzfoDl26GF/8Hy7fmmd1JiRTFldQp/A9VTAABz3sVYmMB92HSIaJhuDMoYJNI2Cf/cZifsv7vUL8cbLn+lPsKsebiuB0m0g4P2qLwLfegfNGEgA7lA5HIz3SELqbdp3iuqJeQl1fsJqD74
@ -502,7 +499,6 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 		}
 		//decrptCode := RSA_Decrypts(decodeByte, privatePath)

-
 		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)

 		fmt.Println("解密后的字符串：")
@ -564,6 +560,8 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 		fmt.Println(result[1])

 		now := time.Now()
+		fmt.Println("---------now--------")
+		fmt.Println(now)
 		temperature := new(models.Temperature)
 		temperature.CreateDate = now
 		temperature.DataDate = now.Format("2006-01-02")
@ -585,9 +583,6 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 		models.SaveTemperature(temperature)
 	}

-
-
-
 	//uuid := uuid.New()
 	//models.SaveProduct()
 	//models.SaveUser(uuid.String())
@ -653,7 +648,12 @@ func subAppPushDyw(client mqtt.Client) {
 	token.Wait()
 	fmt.Printf("Subscribed to topic: %s", topic)
 }
-
+func subAppPushYf(client mqtt.Client) {
+	topic := "app_push_yf"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}

 func publish(client mqtt.Client) {
 	num := 999999000000000000
@ -666,7 +666,7 @@ func publish(client mqtt.Client) {
 	}
 }

-func main() {
+func main1() {

 	uuid := uuid.New()
 	fmt.Println("Generated UUID:", uuid)
@ -694,7 +694,12 @@ func main() {
 	subTemperature(client)
 	subAppPush(client)
 	subAppPushDyw(client)
-	publish(client)
+	subAppPushYf(client)
+	//publish(client)
+
+	for true {
+		time.Sleep(5 * time.Second)
+	}

 	//client.Disconnect(1000)

--- a/main_hwy.go
+++ b/main_hwy.go
@ -0,0 +1,229 @@
+package main
+
+import (
+	"encoding/base64"
+	"encoding/json"
+	"fmt"
+	mqtt "github.com/eclipse/paho.mqtt.golang"
+	"github.com/google/uuid"
+	"go_mqtt/models"
+	"strings"
+	"time"
+)
+
+func timing01(client mqtt.Client) {
+	//定时器，10秒钟执行一次
+	ticker := time.NewTicker(10 * time.Second)
+	for {
+		time := <-ticker.C
+		fmt.Println("定时器====>", time.String())
+		if !client.IsConnectionOpen() {
+			client.Connect()
+		} else {
+			fmt.Println("client has connect")
+		}
+	}
+}
+
+var messagePubHandler01 mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
+	fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
+
+	message := fmt.Sprintf("%s", msg.Payload())
+	topic := fmt.Sprintf("%s", msg.Topic())
+	fmt.Println(message)
+	fmt.Println(topic)
+
+	//privatePath := "/Users/edao/GolandProjects/go_mqtt/privateKey.pem"
+	privateKeyPEM := `-----BEGIN PRIVATE KEY-----
+MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL3dDf12MSeIY2jm5QpUSSoMhrJOWLbOt5fXQepPaNO0M30A+3C4SFZrM/9WA5ehazO1u1m1LAkYzoSDRH3MMJsrJC3lCGDeOROteu+safuP9k/npU1YQu/+Ll2xEJNxyvUx4jLGM4LamiMI6ytM3gdnOAGP4YRQo9Etwo6I986yg/seCQC5rza9M4iBamoin7U8h9yOMKrM6xK/k9CcY/vn5+Uhe3Pvk4qj/2Ff3OXkkc1wfdILqdLwLOKL0Tb3ZciwG0p1CKO80yf5hyYoWjqZk5Rcd07nTo2gqTFGfLl9sqI9/+ipMDtnHlAgMBAAECggEATJd5yCC6lusdMRO5FOBUyUaUi9X2i1AU+RZKAynQySvSnbavUgExW58tRCHBUrGW9gJp59ft1N8J8hHhSO18NDY4H7laBlVdnwmYjRqtFo2VQO6sD4G8JRDION5f2iIxn/b2fYDI9H8vILfJRbNgtTSILyGlzTYUZzhLKxCh+8IsN96Nic8wa5COd1vZZmdhf2y8TG8clFWmozaScNSAATx7y+8XLVWjjWiIRZ6xQvx0uQPUParc9KihXXTKR2pA22yPIdz+U4MGD4kC0eczlcFKZ/dYv9e7OIGgnJfT0idSCu7nYb1pxJ1LxD9fS6IScNTF5dSe0OIL98e+XdyoAQKBgQDRep+5cW4iAKrEMH+djmcXAkoMiYtNVtnu0efLE8dP6vjYytQi368X9SdcASbfrQ31eEZmr/xQnlUF8oyHGkI38YS8dpAHzQcrkP3BljbbzB/3gJZaUdghGsDrK0xAJIzzmFKQpeKnGtr23vxUgaGrNsCYvQ0eQ7+5056KXS4r5QKBgQC6r8xtRSaje6L4WIydjWvYywsmRO0Of0aJLMDA/Wt2MWhHfh7ba9oI1cKGN80ap7xB2a9lQLgpv+C53wNtE5SpvjxsikAj96nUMMhGy9ojXrUith6HQhiINETz6Shnznd+AyrXP6KI/RpfA5nkDB5nrJxODwtYLP467IL7Cv7OAQKBgQCl4KxKdH/5fP28jYsAgJsxpSZt9xzQCU5Zxu396ZOSvUaApVyGoQpNtluMh3z48lhzYOKevgzW6gn5w69z7F8zXZT2iAxVoQ1kelP2z7RxKJrHqpNkwhqbXEwX7RlcUZUr8BqxYCqymJl7k+fMIzqaEalBSbLxnEReKi0I8/Bz4QKBgHK4b0ZCtVDHPEmimJ6E9l4dv/c/afF7swu+zaCK2ouiJvOwBCRQbYb6XPR/u/GCXASXUdpF4CX/vIhcDE3uN2/r8FO+zVWM7vbvF1OyF5WesG7pPW9e5ZZlkG3WvLa1wOZV6fCmMSo/ZwI2Q05JSDHrd43cXttLotrw1jiQ9C4BAoGBAKi4SOoOVQ5J5HQCDkBwPbG1AOLHFinzfoDl26GF/8Hy7fmmd1JiRTFldQp/A9VTAABz3sVYmMB92HSIaJhuDMoYJNI2Cf/cZifsv7vUL8cbLn+lPsKsebiuB0m0g4P2qLwLfegfNGEgA7lA5HIz3SELqbdp3iuqJeQl1fsJqD74
+-----END PRIVATE KEY-----`
+
+	if topic == "app_push" {
+		fmt.Println("珠海电厂APP收到mqtt消息")
+		decodeByte, err := base64.StdEncoding.DecodeString(message)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		//decrptCode := RSA_Decrypts(decodeByte, privatePath)
+
+		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
+
+		fmt.Println("解密后的字符串：")
+		fmt.Println(string(decrptCode))
+		fmt.Println("-----user--------")
+		var user models.User
+		json.Unmarshal(decrptCode, &user)
+		fmt.Println(user)
+
+		if models.GetUser(&user) {
+			models.UpdateUser(&user)
+		} else {
+			models.SaveUser(&user)
+		}
+
+	} else if topic == "app_push_dyw" {
+		fmt.Println("大亚湾电厂APP收到mqtt消息")
+		decodeByte, err := base64.StdEncoding.DecodeString(message)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
+		fmt.Println("解密后的字符串：")
+		fmt.Println(string(decrptCode))
+		fmt.Println("-----userdyw--------")
+		var user models.Userdyw
+		json.Unmarshal(decrptCode, &user)
+		fmt.Println(user)
+
+		if models.GetUserdyw(&user) {
+			models.UpdateUserdyw(&user)
+		} else {
+			models.SaveUserdyw(&user)
+		}
+
+	} else if topic == "app_push_yf" {
+		fmt.Println("云浮电厂APP收到mqtt消息")
+		decodeByte, err := base64.StdEncoding.DecodeString(message)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
+		fmt.Println("解密后的字符串：")
+		fmt.Println(string(decrptCode))
+		fmt.Println("-----userdyw--------")
+		var user models.Useryf
+		json.Unmarshal(decrptCode, &user)
+		fmt.Println(user)
+
+		if models.GetUseryf(&user) {
+			models.UpdateUseryf(&user)
+		} else {
+			models.SaveUseryf(&user)
+		}
+
+	} else {
+		result := strings.Split(message, " ")
+		fmt.Println(result[0])
+		fmt.Println(result[1])
+
+		now := time.Now()
+		fmt.Println("---------now--------")
+		fmt.Println(now)
+		temperature := new(models.Temperature)
+		temperature.CreateDate = now
+		temperature.DataDate = now.Format("2006-01-02")
+		temperature.DataHour = now.Format("2006-01-02 15")
+		temperature.DataMinute = now.Format("2006-01-02 15:04")
+		temperature.Humidity = result[0]
+		temperature.Temperature = result[1]
+		temperature.Topic = topic
+		if topic == "WifiSHT/7C87CE9CA4E6/SHT20" {
+			temperature.LocationDesc = "广东省珠海市高新区唐家湾镇东岸村水风三街28号501"
+		}
+		if topic == "WifiSHT/7C87CE9F5CBF/SHT20" {
+			temperature.LocationDesc = "广东省珠海市金湾区三灶镇百川路1号1栋1单元1508房"
+		}
+		if topic == "WifiSHT/4CEBD686B6AA/SHT20" {
+			temperature.LocationDesc = "广西壮族自治区崇左市天等县天等镇荣华村弄在屯113号"
+		}
+		fmt.Println("测温传感器地点:", temperature.LocationDesc)
+		models.SaveTemperature(temperature)
+	}
+
+	//uuid := uuid.New()
+	//models.SaveProduct()
+	//models.SaveUser(uuid.String())
+	//models.SaveOrder()
+
+	//var users []models.User
+	//var orders []models.Order
+	//var user models.User
+	//mydb.DB.Where("name = ?", "wenfei").First(&user)
+	//fmt.Println(user)
+
+	// 查询多条记录
+	//mydb.DB.Find(&users) // 查询所有产品信息
+	//mydb.DB.Order("id desc").Limit(2).Offset(0).Find(&users) // 按价格降序排序，取前 10 条记录
+	//fmt.Println("users:", users)
+
+	// 查询多条记录
+	//mydb.DB.Find(&users) // 查询所有产品信息
+	//mydb.DB.Where("id > ? and id < ?", 60,65).Find(&orders)
+	//fmt.Println("orders:", orders)
+
+	// 原生 SQL 查询
+	//var products []models.Product
+	//mydb.DB.Raw("SELECT * FROM product WHERE price > ?", 1000).Scan(&products) // 查询价格大于 1000 的产品信息
+	//fmt.Println("Products:", products)
+
+}
+
+var connectHandler01 mqtt.OnConnectHandler = func(client mqtt.Client) {
+	fmt.Println("Connected")
+	subTemperature01(client)
+	subAppPush01(client)
+	subAppPushDyw01(client)
+	subAppPushYf01(client)
+}
+
+var connectLostHandler01 mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
+	fmt.Printf("Connect lost: %v", err)
+}
+
+func subTemperature01(client mqtt.Client) {
+	topic := "WifiSHT/+/SHT20"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+
+func subAppPush01(client mqtt.Client) {
+	topic := "app_push"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+func subAppPushDyw01(client mqtt.Client) {
+	topic := "app_push_dyw"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+func subAppPushYf01(client mqtt.Client) {
+	topic := "app_push_yf"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+
+func main() {
+
+	uuid := uuid.New()
+	fmt.Println("Generated UUID:", uuid)
+
+	var broker = "mqtt.fileview123.com"
+	var port = 1883
+	opts := mqtt.NewClientOptions()
+	opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
+	opts.SetClientID(uuid.String())
+	opts.SetUsername("admin")
+	opts.SetPassword("publish452131wW452131wW$")
+	opts.SetDefaultPublishHandler(messagePubHandler01)
+	opts.OnConnect = connectHandler01
+	opts.OnConnectionLost = connectLostHandler01
+	client := mqtt.NewClient(opts)
+	if token := client.Connect(); token.Wait() && token.Error() != nil {
+		fmt.Println(token.Error())
+	}
+
+	go timing01(client)
+
+	subTemperature01(client)
+	subAppPush01(client)
+	subAppPushDyw01(client)
+	subAppPushYf01(client)
+
+	for true {
+		time.Sleep(5 * time.Second)
+	}
+}
--- a/models/User.go
+++ b/models/User.go
@ -8,7 +8,7 @@ import (
 )

 type User struct {
-	Username     	string `gorm:"primaryKey;size:255"`
+	Username   string `gorm:"primaryKey;size:100"`
 	Password   string `gorm:"size:255"`
 	Date       string `gorm:"size:255"`
 	Imeinum    string `gorm:"size:50"`
@ -17,6 +17,7 @@ type User struct {
 	Appversion string `gorm:"size:255"`
 	Name       string `gorm:"size:255"`
 }
+
 // Userdyw
 func init() {
 	fmt.Println("User init()")
@ -40,7 +41,8 @@ func SaveUser(user *User) {
 func UpdateUser(item *User) {
 	fmt.Println("用户存在,更新操作")
 	var user User
-	mydb.DB.First(&user, item.Username)
+	//mydb.DB.First(&user, item.Username)
+	mydb.DB.Where("username = ?", item.Username).First(&user)
 	user.Password = item.Password
 	user.Date = item.Date
 	user.Imeinum = item.Imeinum
@ -55,9 +57,8 @@ func GetUser(item *User) bool {
 	var user User
 	//mydb.DB.First(&user, item.Username)

-
-
-	result := mydb.DB.First(&user, item.Username).Error
+	//result := mydb.DB.First(&user, item.Username).Error
+	result := mydb.DB.Where("username = ?", item.Username).First(&user).Error
 	fmt.Println("-----user---->>")
 	fmt.Println(user)

--- a/models/Userdyw.go
+++ b/models/Userdyw.go
@ -8,7 +8,7 @@ import (
 )

 type Userdyw struct {
-	Username     	string `gorm:"primaryKey;size:255"`
+	Username   string `gorm:"primaryKey;size:100"`
 	Password   string `gorm:"size:255"`
 	Date       string `gorm:"size:255"`
 	Imeinum    string `gorm:"size:50"`
@ -17,7 +17,7 @@ type Userdyw struct {
 	Appversion string `gorm:"size:255"`
 	Name       string `gorm:"size:255"`
 }
-//
+
 func init() {
 	fmt.Println("Userdyw init()")
 	mydb.DB.AutoMigrate(&Userdyw{})
@ -40,7 +40,9 @@ func SaveUserdyw(user *Userdyw) {
 func UpdateUserdyw(item *Userdyw) {
 	fmt.Println("用户存在,更新操作")
 	var user Userdyw
-	mydb.DB.First(&user, item.Username)
+	//mydb.DB.First(&user, item.Username)
+	mydb.DB.Where("username = ?", item.Username).First(&user)
+
 	user.Password = item.Password
 	user.Date = item.Date
 	user.Imeinum = item.Imeinum
@ -55,9 +57,8 @@ func GetUserdyw(item *Userdyw) bool {
 	var user Userdyw
 	//mydb.DB.First(&user, item.Username)

-
-
-	result := mydb.DB.First(&user, item.Username).Error
+	//result := mydb.DB.First(&user, item.Username).Error
+	result := mydb.DB.Where("username = ?", item.Username).First(&user).Error
 	fmt.Println("-----user---->>")
 	fmt.Println(user)

@ -74,4 +75,3 @@ func GetUserdyw(item *Userdyw) bool {
 	}
 	return false
 }
-
--- a/models/Useryf.go
+++ b/models/Useryf.go
@ -8,13 +8,13 @@ import (
 )

 type Useryf struct {
-	Username     	string `gorm:"primaryKey;size:255"`
+	Username string `gorm:"primaryKey;size:100"`
 	Password string `gorm:"size:255"`
 	Date     string `gorm:"size:32"`
 	Nfc      string `gorm:"size:255"`
 	Name     string `gorm:"size:255"`
 }
-//
+
 func init() {
 	fmt.Println("Useryf init()")
 	mydb.DB.AutoMigrate(&Useryf{})
@ -37,7 +37,8 @@ func SaveUseryf(user *Useryf) {
 func UpdateUseryf(item *Useryf) {
 	fmt.Println("用户存在,更新操作")
 	var user Useryf
-	mydb.DB.First(&user, item.Username)
+	//mydb.DB.First(&user, item.Username)
+	mydb.DB.Where("username = ?", item.Username).First(&user)
 	user.Password = item.Password
 	user.Date = item.Date
 	user.Name = item.Name
@ -49,9 +50,8 @@ func GetUseryf(item *Useryf) bool {
 	var user Useryf
 	//mydb.DB.First(&user, item.Username)

-
-
-	result := mydb.DB.First(&user, item.Username).Error
+	//result := mydb.DB.First(&user, item.Username).Error
+	result := mydb.DB.Where("username = ?", item.Username).First(&user).Error
 	fmt.Println("-----user---->>")
 	fmt.Println(user)

@ -68,4 +68,3 @@ func GetUseryf(item *Useryf) bool {
 	}
 	return false
 }
-
--- a/mqtt/main_mqtt.go
+++ b/mqtt/main_mqtt.go
@ -0,0 +1,390 @@
+package mqtt
+
+import (
+	"bytes"
+	"crypto/rand"
+	"crypto/rsa"
+	"crypto/x509"
+	"encoding/base64"
+	"encoding/json"
+	"encoding/pem"
+	"fmt"
+	mqtt "github.com/eclipse/paho.mqtt.golang"
+	"github.com/google/uuid"
+	"go_mqtt/models"
+	"io/ioutil"
+	"log"
+	"os"
+	"strings"
+	"time"
+)
+
+// RSA_Decrypts RSA解密支持分段解密
+func RSA_Decrypts(cipherText []byte, path string) []byte {
+	//打开文件
+	var bytesDecrypt []byte
+	//file, err := os.Open(path)
+	//if err != nil {
+	//	fmt.Println(err)
+	//}
+	//
+	////获取文件内容
+	//info, _ := file.Stat()
+	//buf := make([]byte, info.Size())
+	//file.Read(buf)
+
+	// 读取私钥文件
+	keyData, err := ioutil.ReadFile(path)
+	if err != nil {
+		return nil
+	}
+
+	//pem解码
+	block, _ := pem.Decode(keyData)
+	//X509解码
+	privateKey, err := x509.ParsePKCS8PrivateKey(block.Bytes)
+	if err != nil {
+		fmt.Println(err.Error())
+		os.Exit(0)
+	}
+	p := privateKey.(*rsa.PrivateKey)
+	keySize := p.Size()
+	srcSize := len(cipherText)
+	log.Println("密钥长度", keySize, "密文长度", srcSize)
+	var offSet = 0
+	var buffer = bytes.Buffer{}
+	for offSet < srcSize {
+		endIndex := offSet + keySize
+		if endIndex > srcSize {
+			endIndex = srcSize
+		}
+		bytesOnce, err := rsa.DecryptPKCS1v15(rand.Reader, p, cipherText[offSet:endIndex])
+		if err != nil {
+			return nil
+		}
+		buffer.Write(bytesOnce)
+		offSet = endIndex
+	}
+	bytesDecrypt = buffer.Bytes()
+	return bytesDecrypt
+}
+
+// RSA_DecryptsOne RSA解密支持分段解密
+func RSA_DecryptsOne(cipherText []byte, privateKeyStr string) []byte {
+	//打开文件
+	var bytesDecrypt []byte
+	// 读取私钥文件转成字节数组
+	keyData := []byte(privateKeyStr)
+
+	//pem解码
+	block, _ := pem.Decode(keyData)
+	//X509解码
+	privateKey, err := x509.ParsePKCS8PrivateKey(block.Bytes)
+	if err != nil {
+		fmt.Println(err.Error())
+		os.Exit(0)
+	}
+	p := privateKey.(*rsa.PrivateKey)
+	keySize := p.Size()
+	srcSize := len(cipherText)
+	log.Println("密钥长度", keySize, "密文长度", srcSize)
+	var offSet = 0
+	var buffer = bytes.Buffer{}
+	for offSet < srcSize {
+		endIndex := offSet + keySize
+		if endIndex > srcSize {
+			endIndex = srcSize
+		}
+		bytesOnce, err := rsa.DecryptPKCS1v15(rand.Reader, p, cipherText[offSet:endIndex])
+		if err != nil {
+			return nil
+		}
+		buffer.Write(bytesOnce)
+		offSet = endIndex
+	}
+	bytesDecrypt = buffer.Bytes()
+	return bytesDecrypt
+}
+
+// RsaEncryptBlock 公钥加密-分段
+func RsaEncryptBlock(src []byte, path string) (bytesEncrypt []byte, err error) {
+	//打开文件
+	//file, err := os.Open(path)
+	//if err != nil {
+	//	return
+	//}
+	//
+	////读取文件的内容
+	//info, _ := file.Stat()
+	//buf := make([]byte, info.Size())
+	//file.Read(buf)
+
+	// 读取公钥文件
+	keyData, err := ioutil.ReadFile(path)
+	if err != nil {
+		return nil, err
+	}
+
+	//pem解码
+	block, _ := pem.Decode(keyData)
+	//x509解码
+	publicKeyInterface, err := x509.ParsePKIXPublicKey(block.Bytes)
+	if err != nil {
+		fmt.Println(err)
+	}
+	//类型断言
+	publicKey := publicKeyInterface.(*rsa.PublicKey)
+	keySize, srcSize := publicKey.Size(), len(src)
+	log.Println("密钥长度", keySize, "明文长度", srcSize)
+	offSet, once := 0, keySize-11
+	buffer := bytes.Buffer{}
+	for offSet < srcSize {
+		endIndex := offSet + once
+		if endIndex > srcSize {
+			endIndex = srcSize
+		}
+		// 加密一部分
+		bytesOnce, err := rsa.EncryptPKCS1v15(rand.Reader, publicKey, src[offSet:endIndex])
+		if err != nil {
+			return nil, err
+		}
+		buffer.Write(bytesOnce)
+		offSet = endIndex
+	}
+	bytesEncrypt = buffer.Bytes()
+	return
+}
+
+func timing(client mqtt.Client) {
+	//定时器，10秒钟执行一次
+	ticker := time.NewTicker(10 * time.Second)
+	for {
+		time := <-ticker.C
+		fmt.Println("定时器====>", time.String())
+		if !client.IsConnectionOpen() {
+			client.Connect()
+		} else {
+			fmt.Println("client has connect")
+		}
+	}
+}
+
+var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
+	fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
+
+	message := fmt.Sprintf("%s", msg.Payload())
+	topic := fmt.Sprintf("%s", msg.Topic())
+	fmt.Println(message)
+	fmt.Println(topic)
+
+	//privatePath := "/Users/edao/GolandProjects/go_mqtt/privateKey.pem"
+	privateKeyPEM := `-----BEGIN PRIVATE KEY-----
+MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL3dDf12MSeIY2jm5QpUSSoMhrJOWLbOt5fXQepPaNO0M30A+3C4SFZrM/9WA5ehazO1u1m1LAkYzoSDRH3MMJsrJC3lCGDeOROteu+safuP9k/npU1YQu/+Ll2xEJNxyvUx4jLGM4LamiMI6ytM3gdnOAGP4YRQo9Etwo6I986yg/seCQC5rza9M4iBamoin7U8h9yOMKrM6xK/k9CcY/vn5+Uhe3Pvk4qj/2Ff3OXkkc1wfdILqdLwLOKL0Tb3ZciwG0p1CKO80yf5hyYoWjqZk5Rcd07nTo2gqTFGfLl9sqI9/+ipMDtnHlAgMBAAECggEATJd5yCC6lusdMRO5FOBUyUaUi9X2i1AU+RZKAynQySvSnbavUgExW58tRCHBUrGW9gJp59ft1N8J8hHhSO18NDY4H7laBlVdnwmYjRqtFo2VQO6sD4G8JRDION5f2iIxn/b2fYDI9H8vILfJRbNgtTSILyGlzTYUZzhLKxCh+8IsN96Nic8wa5COd1vZZmdhf2y8TG8clFWmozaScNSAATx7y+8XLVWjjWiIRZ6xQvx0uQPUParc9KihXXTKR2pA22yPIdz+U4MGD4kC0eczlcFKZ/dYv9e7OIGgnJfT0idSCu7nYb1pxJ1LxD9fS6IScNTF5dSe0OIL98e+XdyoAQKBgQDRep+5cW4iAKrEMH+djmcXAkoMiYtNVtnu0efLE8dP6vjYytQi368X9SdcASbfrQ31eEZmr/xQnlUF8oyHGkI38YS8dpAHzQcrkP3BljbbzB/3gJZaUdghGsDrK0xAJIzzmFKQpeKnGtr23vxUgaGrNsCYvQ0eQ7+5056KXS4r5QKBgQC6r8xtRSaje6L4WIydjWvYywsmRO0Of0aJLMDA/Wt2MWhHfh7ba9oI1cKGN80ap7xB2a9lQLgpv+C53wNtE5SpvjxsikAj96nUMMhGy9ojXrUith6HQhiINETz6Shnznd+AyrXP6KI/RpfA5nkDB5nrJxODwtYLP467IL7Cv7OAQKBgQCl4KxKdH/5fP28jYsAgJsxpSZt9xzQCU5Zxu396ZOSvUaApVyGoQpNtluMh3z48lhzYOKevgzW6gn5w69z7F8zXZT2iAxVoQ1kelP2z7RxKJrHqpNkwhqbXEwX7RlcUZUr8BqxYCqymJl7k+fMIzqaEalBSbLxnEReKi0I8/Bz4QKBgHK4b0ZCtVDHPEmimJ6E9l4dv/c/afF7swu+zaCK2ouiJvOwBCRQbYb6XPR/u/GCXASXUdpF4CX/vIhcDE3uN2/r8FO+zVWM7vbvF1OyF5WesG7pPW9e5ZZlkG3WvLa1wOZV6fCmMSo/ZwI2Q05JSDHrd43cXttLotrw1jiQ9C4BAoGBAKi4SOoOVQ5J5HQCDkBwPbG1AOLHFinzfoDl26GF/8Hy7fmmd1JiRTFldQp/A9VTAABz3sVYmMB92HSIaJhuDMoYJNI2Cf/cZifsv7vUL8cbLn+lPsKsebiuB0m0g4P2qLwLfegfNGEgA7lA5HIz3SELqbdp3iuqJeQl1fsJqD74
+-----END PRIVATE KEY-----`
+
+	if topic == "app_push" {
+		fmt.Println("珠海电厂APP收到mqtt消息")
+		decodeByte, err := base64.StdEncoding.DecodeString(message)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		//decrptCode := RSA_Decrypts(decodeByte, privatePath)
+
+		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
+
+		fmt.Println("解密后的字符串：")
+		fmt.Println(string(decrptCode))
+		fmt.Println("-----user--------")
+		var user models.User
+		json.Unmarshal(decrptCode, &user)
+		fmt.Println(user)
+
+		if models.GetUser(&user) {
+			models.UpdateUser(&user)
+		} else {
+			models.SaveUser(&user)
+		}
+
+	} else if topic == "app_push_dyw" {
+		fmt.Println("大亚湾电厂APP收到mqtt消息")
+		decodeByte, err := base64.StdEncoding.DecodeString(message)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
+		fmt.Println("解密后的字符串：")
+		fmt.Println(string(decrptCode))
+		fmt.Println("-----userdyw--------")
+		var user models.Userdyw
+		json.Unmarshal(decrptCode, &user)
+		fmt.Println(user)
+
+		if models.GetUserdyw(&user) {
+			models.UpdateUserdyw(&user)
+		} else {
+			models.SaveUserdyw(&user)
+		}
+
+	} else if topic == "app_push_yf" {
+		fmt.Println("云浮电厂APP收到mqtt消息")
+		decodeByte, err := base64.StdEncoding.DecodeString(message)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		decrptCode := RSA_DecryptsOne(decodeByte, privateKeyPEM)
+		fmt.Println("解密后的字符串：")
+		fmt.Println(string(decrptCode))
+		fmt.Println("-----userdyw--------")
+		var user models.Useryf
+		json.Unmarshal(decrptCode, &user)
+		fmt.Println(user)
+
+		if models.GetUseryf(&user) {
+			models.UpdateUseryf(&user)
+		} else {
+			models.SaveUseryf(&user)
+		}
+
+	} else {
+		result := strings.Split(message, " ")
+		fmt.Println(result[0])
+		fmt.Println(result[1])
+
+		now := time.Now()
+		fmt.Println("---------now--------")
+		fmt.Println(now)
+		temperature := new(models.Temperature)
+		temperature.CreateDate = now
+		temperature.DataDate = now.Format("2006-01-02")
+		temperature.DataHour = now.Format("2006-01-02 15")
+		temperature.DataMinute = now.Format("2006-01-02 15:04")
+		temperature.Humidity = result[0]
+		temperature.Temperature = result[1]
+		temperature.Topic = topic
+		if topic == "WifiSHT/7C87CE9CA4E6/SHT20" {
+			temperature.LocationDesc = "广东省珠海市高新区唐家湾镇东岸村水风三街28号501"
+		}
+		if topic == "WifiSHT/7C87CE9F5CBF/SHT20" {
+			temperature.LocationDesc = "广东省珠海市金湾区三灶镇百川路1号1栋1单元1508房"
+		}
+		if topic == "WifiSHT/4CEBD686B6AA/SHT20" {
+			temperature.LocationDesc = "广西壮族自治区崇左市天等县天等镇荣华村弄在屯113号"
+		}
+		fmt.Println("测温传感器地点:", temperature.LocationDesc)
+		models.SaveTemperature(temperature)
+	}
+
+	//uuid := uuid.New()
+	//models.SaveProduct()
+	//models.SaveUser(uuid.String())
+	//models.SaveOrder()
+
+	//var users []models.User
+	//var orders []models.Order
+	//var user models.User
+	//mydb.DB.Where("name = ?", "wenfei").First(&user)
+	//fmt.Println(user)
+
+	// 查询多条记录
+	//mydb.DB.Find(&users) // 查询所有产品信息
+	//mydb.DB.Order("id desc").Limit(2).Offset(0).Find(&users) // 按价格降序排序，取前 10 条记录
+	//fmt.Println("users:", users)
+
+	// 查询多条记录
+	//mydb.DB.Find(&users) // 查询所有产品信息
+	//mydb.DB.Where("id > ? and id < ?", 60,65).Find(&orders)
+	//fmt.Println("orders:", orders)
+
+	// 原生 SQL 查询
+	//var products []models.Product
+	//mydb.DB.Raw("SELECT * FROM product WHERE price > ?", 1000).Scan(&products) // 查询价格大于 1000 的产品信息
+	//fmt.Println("Products:", products)
+
+}
+
+var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
+	fmt.Println("Connected")
+	subTemperature(client)
+	subAppPush(client)
+	subAppPushDyw(client)
+}
+
+var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
+	fmt.Printf("Connect lost: %v", err)
+}
+
+func sub(client mqtt.Client) {
+	topic := "gomqtt01"
+	token := client.Subscribe(topic, 1, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+
+func subTemperature(client mqtt.Client) {
+	topic := "WifiSHT/+/SHT20"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+
+func subAppPush(client mqtt.Client) {
+	topic := "app_push"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+func subAppPushDyw(client mqtt.Client) {
+	topic := "app_push_dyw"
+	token := client.Subscribe(topic, 2, nil)
+	token.Wait()
+	fmt.Printf("Subscribed to topic: %s", topic)
+}
+
+func publish(client mqtt.Client) {
+	num := 999999000000000000
+	for i := 0; i < num; i++ {
+		text := fmt.Sprintf("Message %d", i)
+		token := client.Publish("gomqtt01", 0, false, text)
+		token.Wait()
+		fmt.Println(i)
+		time.Sleep(6 * time.Second)
+	}
+}
+
+func main() {
+
+	uuid := uuid.New()
+	fmt.Println("Generated UUID:", uuid)
+
+	var broker = "47.242.184.139"
+	var port = 1883
+	opts := mqtt.NewClientOptions()
+	opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
+	opts.SetClientID(uuid.String())
+	opts.SetUsername("admin")
+	opts.SetPassword("publish452131wW452131wW$")
+	opts.SetDefaultPublishHandler(messagePubHandler)
+	opts.OnConnect = connectHandler
+	opts.OnConnectionLost = connectLostHandler
+	client := mqtt.NewClient(opts)
+	if token := client.Connect(); token.Wait() && token.Error() != nil {
+		fmt.Println(token.Error())
+	}
+
+	//client.IsConnectionOpen()
+
+	go timing(client)
+
+	//sub(client)
+	subTemperature(client)
+	subAppPush(client)
+	subAppPushDyw(client)
+	//publish(client)
+
+	for true {
+		time.Sleep(5 * time.Second)
+	}
+
+	//client.Disconnect(1000)
+
+}
--- a/mydb/initialize.go
+++ b/mydb/initialize.go
@ -2,14 +2,17 @@ package mydb

 import (
 	"fmt"
-	"gorm.io/driver/mysql"
+	//"gorm.io/driver/postgres"
+
+	"gorm.io/driver/postgres"
+
 	"gorm.io/gorm"
 	"log"
 	"time"
 )

 func init() {
-	fmt.Println("mydb init()")
+	fmt.Println("db init()")
 	initDatabase()
 }

@ -17,22 +20,37 @@ var DB *gorm.DB

 func initDatabase() {

-	//dsn := "root:Skyinno251,@tcp(192.168.2.18:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
+	//mysql
+	//dsn := "root:Skyinno251,@tcp(192.168.2.25:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
 	//dsn := "root:Skyinno251,@tcp(47.242.184.139:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
 	//dsn := "root:Skyinno251,@tcp(localhost:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
-	dsn := "root:Skyinno251,@tcp(192.168.3.9:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
+	//dsn := "root:Skyinno251,@tcp(192.168.3.9:3306)/gorm?charset=utf8mb4&parseTime=True&loc=Local"
 	//dsn := "root:Skyinno251,@tcp(localhost:3306)/go_mqtt?charset=utf8mb4&parseTime=True&loc=Local"

-	db, err := gorm.Open(mysql.New(mysql.Config{
-		DSN:                       dsn,   // DSN data source name
-		DefaultStringSize:         255,   // string 类型字段的默认长度
-		DisableDatetimePrecision:  true,  // 禁用 datetime 精度，MySQL 5.6 之前的数据库不支持
-		DontSupportRenameIndex:    true,  // 重命名索引时采用删除并新建的方式，MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引
-		DontSupportRenameColumn:   true,  // 用 `change` 重命名列，MySQL 8 之前的数据库和 MariaDB 不支持重命名列
-		SkipInitializeWithVersion: false, // 根据当前 MySQL 版本自动配置
-	}), &gorm.Config{})
-
+	//db, err := gorm.Open(mysql.New(mysql.Config{
+	//	DSN:                       dsn,   // DSN data source name
+	//	DefaultStringSize:         255,   // string 类型字段的默认长度
+	//	DisableDatetimePrecision:  true,  // 禁用 datetime 精度，MySQL 5.6 之前的数据库不支持
+	//	DontSupportRenameIndex:    true,  // 重命名索引时采用删除并新建的方式，MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引
+	//	DontSupportRenameColumn:   true,  // 用 `change` 重命名列，MySQL 8 之前的数据库和 MariaDB 不支持重命名列
+	//	SkipInitializeWithVersion: false, // 根据当前 MySQL 版本自动配置
+	//}), &gorm.Config{})
 	//db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
+
+	//sqlite
+	//db, err := gorm.Open(sqlite.Open("/media/cat/sd/home/cat/go_mqtt/go_mqtt.db"), &gorm.Config{})
+	//db, err := gorm.Open(sqlite.Open("go_mqtt.db"), &gorm.Config{})
+
+	//postgres
+	//3.30: 10.19.1.219   3.29:10.19.1.154  localhost
+	//dsn := "host=localhost user=postgres password=452131wW dbname=postgres port=5432 sslmode=disable"
+	dsn := "host=192.168.2.25 user=postgres password=452131wW dbname=weather port=5432 sslmode=disable"
+	db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
+
+	//sqlserver
+	//dsn := "sqlserver://sa:452131wW@192.168.3.29:1433?database=go_mqtt"
+	//db, err := gorm.Open(sqlserver.Open(dsn), &gorm.Config{})
+
 	if err != nil {
 		fmt.Println("failed to connect database")
 	}
Author	SHA1	Message	Date
wenfei	d32b5695fd	change db and yf	3 weeks ago
wenfei	2d4344de18	change pg db add sqlserver	5 months ago
wenfei	a40e3feacd	change pg db	5 months ago
wenfei	a9d0cb0675	final	5 months ago
wenfei	a89c331383	add sqlite db	5 months ago