huangjiajun
11 months ago
2 changed files with 52 additions and 49 deletions
Split View
Diff Options
-
+49 -49consume/init.go
-
+3 -0consume/zhios_user_up_lv.go
+ 49
- 49
consume/init.go
View File
| @@ -17,56 +17,56 @@ func Init() { | |||
| // 增加消费任务队列 | |||
| func initConsumes() { | |||
| //jobs[consumeMd.ZhiosUserUpLvFunName] = ZhiosUserUpLv | |||
| //jobs[consumeMd.CanalGuideOrderByUserUpLvConsume] = CanalGuideOrderByUserUpLvConsume | |||
| //jobs[consumeMd.ZhiosOrderFreeFunName] = ZhiosOrderFree | |||
| //jobs[consumeMd.ZhiosOrderTotalFunName] = ZhiosOrderTotal | |||
| //jobs[consumeMd.ZhiosOrderTotalSecondFunName] = ZhiosOrderTotalSecond | |||
| //// | |||
| //jobs[consumeMd.ZhiosOrderSettleTotalFunName] = ZhiosSettleTotal | |||
| //jobs[consumeMd.ZhiosOrderHjyFunName] = ZhiosOrderHjy | |||
| //jobs[consumeMd.ZhiosOrderBuckleFunName] = ZhiosOrderBuckle | |||
| //// | |||
| //jobs[consumeMd.ZhiosSupplierAfterOrderFunName] = ZhiosSupplierAfterOrder | |||
| //jobs[consumeMd.ZhiosGuideStoreOrderFunName] = ZhiosGuideStoreOrder | |||
| jobs[consumeMd.ZhiosUserUpLvFunName] = ZhiosUserUpLv | |||
| jobs[consumeMd.CanalGuideOrderByUserUpLvConsume] = CanalGuideOrderByUserUpLvConsume | |||
| jobs[consumeMd.ZhiosOrderFreeFunName] = ZhiosOrderFree | |||
| jobs[consumeMd.ZhiosOrderTotalFunName] = ZhiosOrderTotal | |||
| jobs[consumeMd.ZhiosOrderTotalSecondFunName] = ZhiosOrderTotalSecond | |||
| // | |||
| ////jobs[consumeMd.ZhiosAppreciationDevFunName] = ZhiosAppreciation | |||
| jobs[consumeMd.ZhiosOrderSettleTotalFunName] = ZhiosSettleTotal | |||
| jobs[consumeMd.ZhiosOrderHjyFunName] = ZhiosOrderHjy | |||
| jobs[consumeMd.ZhiosOrderBuckleFunName] = ZhiosOrderBuckle | |||
| // | |||
| //jobs[consumeMd.ZhiosAppreciationFunName] = ZhiosAppreciation | |||
| //jobs[consumeMd.ZhiosValidUserFunName] = ZhiosValidUser | |||
| // | |||
| ////jobs[consumeMd.ZhiosAcquisitionConditionDevFunName] = ZhiosAcquisitionCondition | |||
| // | |||
| //jobs[consumeMd.ZhiosAcquisitionConditionFunName] = ZhiosAcquisitionCondition | |||
| //jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume | |||
| //jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume | |||
| //jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume | |||
| // | |||
| //jobs[consumeMd.DouShenUserRegisterConsumeForOfficialFunName] = DouShenUserRegisterConsumeForOfficial | |||
| //jobs[consumeMd.DouShenUserRegisterConsumeForOperationCenterFunName] = DouShenUserRegisterConsumeForOperationCenter | |||
| //jobs[consumeMd.DouShenUserRegisterConsumeForMyRecommenderFunName] = DouShenUserRegisterConsumeForMyRecommender | |||
| //jobs[consumeMd.DouShenUserRegisterConsumeForMyFansFunName] = DouShenUserRegisterConsumeForMyFans | |||
| //jobs[consumeMd.DouShenUserRegisterConsumeForUserRegisterUpLvFunName] = DouShenUserRegisterConsumeForUserRegisterUpLv | |||
| // | |||
| //jobs[consumeMd.ZhiosFastReturnOrderPayFunName] = ZhiosFastReturnOrderPay | |||
| //jobs[consumeMd.ZhiosFastReturnOrderSuccessFunName] = ZhiosFastReturnOrderSuccess | |||
| //jobs[consumeMd.ZhiosFastReturnOrderRefundFunName] = ZhiosFastReturnOrderRefund | |||
| //jobs[consumeMd.ZhiosFastReturnOrderRefundSecondFunName] = ZhiosFastReturnOrderRefundSecond | |||
| // | |||
| ////jobs[consumeMd.CanalMallOrdForYouMiShangFunName] = CanalMallOrdForYouMiShang | |||
| //jobs[consumeMd.YoumishangExchangeStoreFunName] = YoumishangExchangeStore | |||
| // | |||
| //jobs[consumeMd.ZhiosRechargeOrderFailFunName] = ZhiosRechargeOrderFail | |||
| // | |||
| //jobs[consumeMd.CloudIssuanceAsyncMLoginFunName] = CloudIssuanceAsyncMLoginConsume | |||
| //jobs[consumeMd.ZhiosTikTokUpdateFunName] = ZhiosTikTokUpdate | |||
| //jobs[consumeMd.ZhiosTikTokAllUpdateFunName] = ZhiosTikTokAllUpdate | |||
| // | |||
| //jobs[consumeMd.ZhiosCapitalPoolOrderTotalFunName] = ZhiosCapitalPoolOrderTotal | |||
| //jobs[consumeMd.ZhiosExpressOrderFail] = ZhiosExpressOrderFail | |||
| //jobs[consumeMd.ZhiosWithdrawReward] = ZhiosWithdrawReward | |||
| // | |||
| //jobs[consumeMd.ZhiosRechargeOrderFailDevFunName] = ZhiosRechargeOrderFailDev | |||
| jobs[consumeMd.ZhiosSupplierAfterOrderFunName] = ZhiosSupplierAfterOrder | |||
| jobs[consumeMd.ZhiosGuideStoreOrderFunName] = ZhiosGuideStoreOrder | |||
| //jobs[consumeMd.ZhiosAppreciationDevFunName] = ZhiosAppreciation | |||
| jobs[consumeMd.ZhiosAppreciationFunName] = ZhiosAppreciation | |||
| jobs[consumeMd.ZhiosValidUserFunName] = ZhiosValidUser | |||
| //jobs[consumeMd.ZhiosAcquisitionConditionDevFunName] = ZhiosAcquisitionCondition | |||
| jobs[consumeMd.ZhiosAcquisitionConditionFunName] = ZhiosAcquisitionCondition | |||
| jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume | |||
| jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume | |||
| jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume | |||
| jobs[consumeMd.DouShenUserRegisterConsumeForOfficialFunName] = DouShenUserRegisterConsumeForOfficial | |||
| jobs[consumeMd.DouShenUserRegisterConsumeForOperationCenterFunName] = DouShenUserRegisterConsumeForOperationCenter | |||
| jobs[consumeMd.DouShenUserRegisterConsumeForMyRecommenderFunName] = DouShenUserRegisterConsumeForMyRecommender | |||
| jobs[consumeMd.DouShenUserRegisterConsumeForMyFansFunName] = DouShenUserRegisterConsumeForMyFans | |||
| jobs[consumeMd.DouShenUserRegisterConsumeForUserRegisterUpLvFunName] = DouShenUserRegisterConsumeForUserRegisterUpLv | |||
| jobs[consumeMd.ZhiosFastReturnOrderPayFunName] = ZhiosFastReturnOrderPay | |||
| jobs[consumeMd.ZhiosFastReturnOrderSuccessFunName] = ZhiosFastReturnOrderSuccess | |||
| jobs[consumeMd.ZhiosFastReturnOrderRefundFunName] = ZhiosFastReturnOrderRefund | |||
| jobs[consumeMd.ZhiosFastReturnOrderRefundSecondFunName] = ZhiosFastReturnOrderRefundSecond | |||
| //jobs[consumeMd.CanalMallOrdForYouMiShangFunName] = CanalMallOrdForYouMiShang | |||
| jobs[consumeMd.YoumishangExchangeStoreFunName] = YoumishangExchangeStore | |||
| jobs[consumeMd.ZhiosRechargeOrderFailFunName] = ZhiosRechargeOrderFail | |||
| jobs[consumeMd.CloudIssuanceAsyncMLoginFunName] = CloudIssuanceAsyncMLoginConsume | |||
| jobs[consumeMd.ZhiosTikTokUpdateFunName] = ZhiosTikTokUpdate | |||
| jobs[consumeMd.ZhiosTikTokAllUpdateFunName] = ZhiosTikTokAllUpdate | |||
| jobs[consumeMd.ZhiosCapitalPoolOrderTotalFunName] = ZhiosCapitalPoolOrderTotal | |||
| jobs[consumeMd.ZhiosExpressOrderFail] = ZhiosExpressOrderFail | |||
| jobs[consumeMd.ZhiosWithdrawReward] = ZhiosWithdrawReward | |||
| jobs[consumeMd.ZhiosRechargeOrderFailDevFunName] = ZhiosRechargeOrderFailDev | |||
| ////////////////////////////////////// V1 ///////////////////////////////////////////////////// | |||
| //jobs[consumeMd.CloudIssuanceMsgCallBackFunName] = CloudIssuanceMsgCallBackConsume | |||
| @@ -75,7 +75,7 @@ func initConsumes() { | |||
| //jobs[consumeMd.SupplyCloudChainFenxiaoNewChangeFunName] = SupplyCloudChainFenxiaoNewChangeConsume | |||
| //////////////////////////////////////// V3 ///////////////////////////////////////////////////// | |||
| jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume | |||
| //jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume | |||
| } | |||
+ 3
- 0
consume/zhios_user_up_lv.go
View File
| @@ -62,6 +62,9 @@ func handleUserUpLv(msg []byte) error { | |||
| } | |||
| mid := canalMsg.Mid | |||
| eg := db.DBs[mid] | |||
| if eg == nil { | |||
| return nil | |||
| } | |||
| uid := canalMsg.Uid | |||
| levelList, _ := db.UserLevlEgAll(eg) | |||
| isAuto := 0 | |||