From 0ddaf5196524744e557baff2a214e08380688125 Mon Sep 17 00:00:00 2001
From: DengBiao <2319963317@qq.com>
Date: Sat, 9 Mar 2024 19:00:52 +0800
Subject: [PATCH] update

---
 consume/canal_user_virtual_coin_flow_consume.go |  3 +++
 consume/init.go                                 | 10 +++++-----
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/consume/canal_user_virtual_coin_flow_consume.go b/consume/canal_user_virtual_coin_flow_consume.go
index 5591a7a..9513de2 100644
--- a/consume/canal_user_virtual_coin_flow_consume.go
+++ b/consume/canal_user_virtual_coin_flow_consume.go
@@ -89,6 +89,9 @@ func handleCanalUserVirtualCoinFlow(msg []byte) error {
 			}
 			if userPublicPlatoonDoubleNetworkUserCoinRecord == nil {
 				userProfile, err2 := db.UserProfileFindByIDSess(engine.NewSession(), canalMsg.Data[0].Uid)
+				if userProfile == nil {
+					return errors.New("用户不存在")
+				}
 				if err2 != nil {
 					return err2
 				}
diff --git a/consume/init.go b/consume/init.go
index 3ab1115..76be831 100644
--- a/consume/init.go
+++ b/consume/init.go
@@ -72,17 +72,17 @@ func initConsumes() {
 	//jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume
 
 	//////////////////////////////////////// bigData /////////////////////////////////////////////////////
-	//jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume
-	//jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume
-	//jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume
-	//jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume
+	jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume
+	jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume
+	jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume
+	jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume
 
 	//////////////////////////////////////// oneCircles /////////////////////////////////////////////////////
 	//jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume
 	//jobs[consumeMd.OneCirclesSignInCopyGreenEnergyFunName] = OneCirclesSignInCopyGreenEnergyConsume
 
 	//////////////////////////////////////// withdraw /////////////////////////////////////////////////////
-	jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume
+	//jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume
 }
 
 func Run() {