|
|
@@ -39,11 +39,12 @@ func OneCirclesSignInGreenEnergyConsume(queue md.MqQueue) { |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
fmt.Println("err ::: ", err) |
|
|
fmt.Println("err ::: ", err) |
|
|
utils.FilePutContents("OneCirclesSignInGreenEnergyConsume_ERR", "[err]:"+err.Error()) |
|
|
utils.FilePutContents("OneCirclesSignInGreenEnergyConsume_ERR", "[err]:"+err.Error()) |
|
|
_ = res.Reject(false) |
|
|
|
|
|
//TODO::重新推回队列末尾，避免造成队列堵塞 |
|
|
|
|
|
var msg *md.OneCirclesStructForSignIn |
|
|
|
|
|
json.Unmarshal(res.Body, &msg) |
|
|
|
|
|
ch.Publish(queue.ExchangeName, msg, queue.RoutKey) |
|
|
|
|
|
|
|
|
_ = res.Reject(true) |
|
|
|
|
|
//_ = res.Reject(false) |
|
|
|
|
|
////TODO::重新推回队列末尾，避免造成队列堵塞 |
|
|
|
|
|
//var msg *md.OneCirclesStructForSignIn |
|
|
|
|
|
//json.Unmarshal(res.Body, &msg) |
|
|
|
|
|
//ch.Publish(queue.ExchangeName, msg, queue.RoutKey) |
|
|
} else { |
|
|
} else { |
|
|
_ = res.Ack(true) |
|
|
_ = res.Ack(true) |
|
|
} |
|
|
} |
|
|
|
