update

consume/egg_energy_auto_exchange_green_energy.go

@@ -43,10 +43,11 @@ func EggEnergyAutoExchangeGreenEnergyConsume(queue md.MqQueue) {
 					"body": res.Body,
 					"err":  err.Error(),
 				}))
+				_ = res.Reject(true) //TODO::拒绝
+			} else {
+				err = res.Ack(true)
+				fmt.Println("err ::: ", err)
 			}
-			_ = res.Reject(true) //TODO::拒绝
-			//err = res.Ack(true)
-			fmt.Println("err ::: ", err)
 		} else {
 			panic(errors.New("error getting message"))
 		}

consume/egg_energy_start_exchange_green_energy.go

@@ -43,10 +43,11 @@ func EggEnergyStartExchangeGreenEnergyConsume(queue md.MqQueue) {
 					"body": res.Body,
 					"err":  err.Error(),
 				}))
+				_ = res.Reject(true) //TODO::拒绝
+			} else {
+				err = res.Ack(true)
+				fmt.Println("err ::: ", err)
 			}
-			_ = res.Reject(true) //TODO::拒绝
-			//err = res.Ack(true)
-			fmt.Println("err ::: ", err)
 		} else {
 			panic(errors.New("error getting message"))
 		}

go.mod

@@ -4,11 +4,11 @@ go 1.19
 
 //replace code.fnuoos.com/EggPlanet/egg_models.git => E:/company/Egg/egg_models
 
-// replace code.fnuoos.com/EggPlanet/egg_system_rules.git => E:/company/Egg/egg_system_rules
+//replace code.fnuoos.com/EggPlanet/egg_system_rules.git => E:/company/Egg/egg_system_rules
 
 require (
 	code.fnuoos.com/EggPlanet/egg_models.git v0.2.1-0.20241211055111-7c47b67b46d2
-	code.fnuoos.com/EggPlanet/egg_system_rules.git v0.0.4-0.20241211161130-ea373c032bd0
+	code.fnuoos.com/EggPlanet/egg_system_rules.git v0.0.4-0.20241212093034-fb8a9223e19f
 	code.fnuoos.com/go_rely_warehouse/zyos_go_es.git v1.0.1-0.20241118083738-0f22da9ba0be
 	code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git v0.0.5
 	github.com/boombuler/barcode v1.0.1