diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index eee6f42..249c54a 100755
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -5,9 +5,10 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="9f8c3ce4-c378-4191-b7a4-3d5acbc0ebbc" name="Changes" comment="rrddf">
+      <change afterPath="$PROJECT_DIR$/models/Useryf.go" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/models/Order.go" beforeDir="false" afterPath="$PROJECT_DIR$/models/Order.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/models/Product.go" beforeDir="false" afterPath="$PROJECT_DIR$/models/Product.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/main.go" beforeDir="false" afterPath="$PROJECT_DIR$/main.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/mydb/initialize.go" beforeDir="false" afterPath="$PROJECT_DIR$/mydb/initialize.go" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
diff --git a/main.go b/main.go
index 095f699..63219bd 100755
--- a/main.go
+++ b/main.go
@@ -538,6 +538,26 @@ MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCYwvInDUICXbmWcOAR5hm86mz7WlKL
 			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])
diff --git a/models/Useryf.go b/models/Useryf.go
new file mode 100644
index 0000000..07868b8
--- /dev/null
+++ b/models/Useryf.go
@@ -0,0 +1,71 @@
+package models
+
+import (
+"errors"
+"fmt"
+"go_mqtt/mydb"
+"gorm.io/gorm"
+)
+
+type Useryf struct {
+	Username     	string `gorm:"primaryKey;size:255"`
+	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{})
+}
+
+// TableName 会将 User 的表名重写为 `user`
+func (Useryf) TableName() string {
+	return "useryf"
+}
+
+func SaveUseryf(user *Useryf) {
+	result := mydb.DB.Create(&user)
+	if result.Error != nil {
+		fmt.Println("Failed to create User:", result.Error)
+	} else {
+		fmt.Println("User created successfully!")
+	}
+}
+
+func UpdateUseryf(item *Useryf) {
+	fmt.Println("用户存在,更新操作")
+	var user Useryf
+	mydb.DB.First(&user, item.Username)
+	user.Password=item.Password
+	user.Date=item.Date
+	user.Name=item.Name
+	user.Nfc=item.Nfc
+	mydb.DB.Save(&user)
+}
+
+func GetUseryf(item *Useryf) bool {
+	var user Useryf
+	//mydb.DB.First(&user, item.Username)
+
+
+
+	result := mydb.DB.First(&user, item.Username).Error
+	fmt.Println("-----user---->>")
+	fmt.Println(user)
+
+	if errors.Is(result, gorm.ErrRecordNotFound) {
+		// 记录不存在
+		fmt.Println("用户不存在")
+	} else if result == nil {
+		// 记录存在
+		fmt.Println("用户存在")
+		return true
+	} else {
+		// 其他错误
+		fmt.Println("查询出错")
+	}
+	return false
+}
+
diff --git a/mydb/initialize.go b/mydb/initialize.go
index 89bd764..84be8f1 100755
--- a/mydb/initialize.go
+++ b/mydb/initialize.go
@@ -19,8 +19,8 @@ func initDatabase() {
 
 	//dsn := "root:Skyinno251,@tcp(192.168.2.18: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.29: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.24:3306)/appserver?charset=utf8mb4&parseTime=True&loc=Local"
 
 	db, err := gorm.Open(mysql.New(mysql.Config{
 		DSN:                       dsn,   // DSN data source name