huangjiajun
4 months ago
2 changed files with 42 additions and 41 deletions
Unified View
Diff Options
+ 40
- 40
consume/init.go
View File
| @@ -19,47 +19,47 @@ func Init() { | |||||
| func initConsumes() { | func initConsumes() { | ||||
| //jobs[consumeMd.ZhiosGuideStoreOrderFunName] = ZhiosGuideStoreOrder | //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.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.ZhiosOrderSettleTotalFunName] = ZhiosSettleTotal | |||||
| jobs[consumeMd.ZhiosOrderHjyFunName] = ZhiosOrderHjy | |||||
| jobs[consumeMd.ZhiosOrderBuckleFunName] = ZhiosOrderBuckle | |||||
| //jobs[consumeMd.ZhiosAppreciationFunName] = ZhiosAppreciation | |||||
| //jobs[consumeMd.ZhiosValidUserFunName] = ZhiosValidUser | |||||
| // | // | ||||
| jobs[consumeMd.ZhiosSupplierAfterOrderFunName] = ZhiosSupplierAfterOrder | |||||
| 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 | |||||
| jobs[consumeMd.ZhiosTaskTotal] = ZhiosTaskTotal | |||||
| //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.ZhiosTaskTotal] = ZhiosTaskTotal | |||||
| // | // | ||||
| @@ -96,7 +96,7 @@ func initConsumes() { | |||||
| //jobs[consumeMd.ZhiosOneCirclesCoinConsumeFunName] = ZhiosOneCirclesCoinConsume //一个圈圈虚拟币变化 | //jobs[consumeMd.ZhiosOneCirclesCoinConsumeFunName] = ZhiosOneCirclesCoinConsume //一个圈圈虚拟币变化 | ||||
| //////////////////////////////////////// autoRepaid ///////////////////////////////////////////////////// | //////////////////////////////////////// autoRepaid ///////////////////////////////////////////////////// | ||||
| //jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款 | |||||
| jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款 | |||||
| } | } | ||||
+ 2
- 1
consume/zhios_installment_payment_auto_repaid_consume.go
View File
| @@ -1,6 +1,7 @@ | |||||
| package consume | package consume | ||||
| import ( | import ( | ||||
| "applet/app/cfg" | |||||
| "applet/app/db" | "applet/app/db" | ||||
| "applet/app/utils/logx" | "applet/app/utils/logx" | ||||
| "applet/consume/md" | "applet/consume/md" | ||||
| @@ -59,7 +60,7 @@ func handleInstallmentPaymentAutoRepaidConsume(ch *rabbit.Channel, msgData []byt | |||||
| return err | return err | ||||
| } | } | ||||
| engine := db.DBs[msg.MasterId] | engine := db.DBs[msg.MasterId] | ||||
| installment_payment.Init(cfg.RedisAddr) | |||||
| //2、调用 `DealInstallmentPaymentAutoRepaid` 制度方法进行扣款 | //2、调用 `DealInstallmentPaymentAutoRepaid` 制度方法进行扣款 | ||||
| err = installment_payment.DealInstallmentPaymentAutoRepaid(engine, ch, *msg, msg.MasterId) | err = installment_payment.DealInstallmentPaymentAutoRepaid(engine, ch, *msg, msg.MasterId) | ||||
| return nil | return nil | ||||