huangjiajun
8 months ago
2 changed files with 53 additions and 42 deletions
Unified View
Diff Options
-
+40 -40consume/init.go
-
+13 -2consume/zhios_order_total_second.go
+ 40
- 40
consume/init.go
View File
| @@ -18,47 +18,47 @@ func Init() { | |||||
| // 增加消费任务队列 | // 增加消费任务队列 | ||||
| func initConsumes() { | 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 | |||||
| // | // | ||||
| @@ -84,7 +84,7 @@ func initConsumes() { | |||||
| //////////////////////////////////////// withdraw ///////////////////////////////////////////////////// | //////////////////////////////////////// withdraw ///////////////////////////////////////////////////// | ||||
| //jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume | //jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume | ||||
| jobs[consumeMd.ZhiosMallGreenCoinConsumeFunName] = ZhiosMallGreenCoinConsume //绿色双链积分 | |||||
| //jobs[consumeMd.ZhiosMallGreenCoinConsumeFunName] = ZhiosMallGreenCoinConsume //绿色双链积分 | |||||
| } | } | ||||
| func Run() { | func Run() { | ||||
+ 13
- 2
consume/zhios_order_total_second.go
View File
| @@ -119,25 +119,36 @@ func handleZhiosOrderTotalSecond(msg []byte) error { | |||||
| Date: utils.StrToInt(now), | Date: utils.StrToInt(now), | ||||
| Uid: v.Uid, | Uid: v.Uid, | ||||
| } | } | ||||
| _, err := sess.Insert(&userStatistics) | |||||
| has, err := sess.Insert(&userStatistics) | |||||
| if err != nil { | if err != nil { | ||||
| sess.Rollback() | sess.Rollback() | ||||
| return err | return err | ||||
| } | } | ||||
| if has == 0 { | |||||
| sess.Rollback() | |||||
| return errors.New("失败") | |||||
| } | |||||
| } | } | ||||
| isupdate := 0 | |||||
| if ordData.State == 4 && ordData.IsTotal == 1 { | if ordData.State == 4 && ordData.IsTotal == 1 { | ||||
| isupdate = 1 | |||||
| isTotal = 2 | isTotal = 2 | ||||
| userStatistics.Amount = utils.Float64ToStrByPrec(utils.StrToFloat64(userStatistics.Amount)-v.Amount-utils.StrToFloat64(v.AdditionalSubsidy), 4) | userStatistics.Amount = utils.Float64ToStrByPrec(utils.StrToFloat64(userStatistics.Amount)-v.Amount-utils.StrToFloat64(v.AdditionalSubsidy), 4) | ||||
| } | } | ||||
| if ordData.State != 4 && ordData.IsTotal == 0 { | if ordData.State != 4 && ordData.IsTotal == 0 { | ||||
| isupdate = 1 | |||||
| isTotal = 1 | isTotal = 1 | ||||
| userStatistics.Amount = utils.Float64ToStrByPrec(utils.StrToFloat64(userStatistics.Amount)+v.Amount+utils.StrToFloat64(v.AdditionalSubsidy), 4) | userStatistics.Amount = utils.Float64ToStrByPrec(utils.StrToFloat64(userStatistics.Amount)+v.Amount+utils.StrToFloat64(v.AdditionalSubsidy), 4) | ||||
| } | } | ||||
| _, err := sess.Where("id=?", userStatistics.Id).Cols("amount").Update(&userStatistics) | |||||
| update, err := sess.Where("id=?", userStatistics.Id).Cols("amount").Update(&userStatistics) | |||||
| if err != nil { | if err != nil { | ||||
| sess.Rollback() | sess.Rollback() | ||||
| return err | return err | ||||
| } | } | ||||
| if update == 0 && isupdate == 1 { | |||||
| sess.Rollback() | |||||
| return errors.New("失败") | |||||
| } | |||||
| } | } | ||||
| } | } | ||||
| } else { | } else { | ||||