|
|
@@ -17,47 +17,47 @@ func Init() { |
|
|
|
|
|
|
|
// 增加消费任务队列 |
|
|
|
func initConsumes() { |
|
|
|
//jobs[consumeMd.ZhiosIntegralProxyRechargeFunName] = ZhiosIntegralProxyRecharge |
|
|
|
//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.ZhiosIntegralProxyRechargeFunName] = ZhiosIntegralProxyRecharge |
|
|
|
jobs[consumeMd.ZhiosUserUpLvFunName] = ZhiosUserUpLv |
|
|
|
jobs[consumeMd.CanalGuideOrderByUserUpLvConsume] = CanalGuideOrderByUserUpLvConsume |
|
|
|
jobs[consumeMd.ZhiosOrderFreeFunName] = ZhiosOrderFree |
|
|
|
jobs[consumeMd.ZhiosOrderTotalFunName] = ZhiosOrderTotal |
|
|
|
jobs[consumeMd.ZhiosOrderTotalSecondFunName] = ZhiosOrderTotalSecond |
|
|
|
// |
|
|
|
//jobs[consumeMd.ZhiosAppreciationFunName] = ZhiosAppreciation |
|
|
|
//jobs[consumeMd.ZhiosValidUserFunName] = ZhiosValidUser |
|
|
|
jobs[consumeMd.ZhiosOrderSettleTotalFunName] = ZhiosSettleTotal |
|
|
|
jobs[consumeMd.ZhiosOrderHjyFunName] = ZhiosOrderHjy |
|
|
|
jobs[consumeMd.ZhiosOrderBuckleFunName] = ZhiosOrderBuckle |
|
|
|
// |
|
|
|
//jobs[consumeMd.ZhiosAcquisitionConditionFunName] = ZhiosAcquisitionCondition |
|
|
|
// |
|
|
|
//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.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.ZhiosSupplierAfterOrderFunName] = ZhiosSupplierAfterOrder |
|
|
|
jobs[consumeMd.ZhiosGuideStoreOrderFunName] = ZhiosGuideStoreOrder |
|
|
|
|
|
|
|
jobs[consumeMd.ZhiosAppreciationFunName] = ZhiosAppreciation |
|
|
|
jobs[consumeMd.ZhiosValidUserFunName] = ZhiosValidUser |
|
|
|
|
|
|
|
jobs[consumeMd.ZhiosAcquisitionConditionFunName] = ZhiosAcquisitionCondition |
|
|
|
|
|
|
|
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.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 |
|
|
|
// |
|
|
|
|
|
|
|
////////////////////////////////////// V1 ///////////////////////////////////////////////////// |
|
|
@@ -70,10 +70,10 @@ 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 |
|
|
|
} |
|
|
|
|
|
|
|
func Run() { |
|
|
|