@@ -2,7 +2,6 @@ package consume | |||||
import ( | import ( | ||||
"applet/app/cfg" | "applet/app/cfg" | ||||
"applet/app/db" | |||||
"applet/app/utils/logx" | "applet/app/utils/logx" | ||||
"applet/consume/md" | "applet/consume/md" | ||||
"code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit" | "code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit" | ||||
@@ -56,8 +55,8 @@ func handleOneCirclesSignInGreenEnergy(msgData []byte) error { | |||||
return err | return err | ||||
} | } | ||||
engine := db.DBs[msg.MasterId] | |||||
err = one_circles.HandleSettlementSignInGreenEnergy(engine, msg.MasterId, msg.Id, msg.Uid) | |||||
//engine := db.DBs[msg.MasterId] | |||||
//err = one_circles.HandleSettlementSignInGreenEnergy(engine, msg.MasterId, msg.Id, msg.Uid) | |||||
fmt.Println("err::::", err) | fmt.Println("err::::", err) | ||||
if err != nil { | if err != nil { | ||||
return err | return err | ||||
@@ -2,7 +2,6 @@ package consume | |||||
import ( | import ( | ||||
"applet/app/cfg" | "applet/app/cfg" | ||||
"applet/app/db" | |||||
"applet/app/utils/logx" | "applet/app/utils/logx" | ||||
"applet/consume/md" | "applet/consume/md" | ||||
"code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit" | "code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git/rabbit" | ||||
@@ -56,8 +55,8 @@ func handleOneCirclesSignInCopyGreenEnergy(msgData []byte) error { | |||||
return err | return err | ||||
} | } | ||||
engine := db.DBs[msg.MasterId] | |||||
err = one_circles.HandleSettlementSignInGreenEnergy(engine, msg.MasterId, msg.Id, msg.Uid) | |||||
//engine := db.DBs[msg.MasterId] | |||||
//err = one_circles.HandleSettlementSignInGreenEnergy(engine, msg.MasterId, msg.Id, msg.Uid) | |||||
fmt.Println("err::::", err) | fmt.Println("err::::", err) | ||||
if err != nil { | if err != nil { | ||||
return err | return err | ||||