diff --git a/consume/egg_energy_auto_exchange_green_energy.go b/consume/egg_energy_auto_exchange_green_energy.go index f83e903..ba3bac6 100644 --- a/consume/egg_energy_auto_exchange_green_energy.go +++ b/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")) } diff --git a/consume/egg_energy_start_exchange_green_energy.go b/consume/egg_energy_start_exchange_green_energy.go index a77d10b..7f8cf36 100644 --- a/consume/egg_energy_start_exchange_green_energy.go +++ b/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")) } diff --git a/go.mod b/go.mod index a915886..aede68e 100644 --- a/go.mod +++ b/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