golang 的 rabbitmq 消费项目
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 

126 lines
5.9 KiB

  1. package consume
  2. import (
  3. "applet/app/utils/logx"
  4. consumeMd "applet/consume/md"
  5. "time"
  6. )
  7. var (
  8. jobs = map[string]func(consumeMd.MqQueue){}
  9. )
  10. func Init() {
  11. // 初始化任务列表
  12. initConsumes()
  13. }
  14. // 增加消费任务队列
  15. func initConsumes() {
  16. //jobs[consumeMd.ZhiosGuideStoreOrderFunName] = ZhiosGuideStoreOrder
  17. //jobs[consumeMd.ZhiosIntegralProxyRechargeFunName] = ZhiosIntegralProxyRecharge
  18. //jobs[consumeMd.ZhiosUserUpLvFunName] = ZhiosUserUpLv
  19. //jobs[consumeMd.CanalGuideOrderByUserUpLvConsume] = CanalGuideOrderByUserUpLvConsume
  20. //jobs[consumeMd.ZhiosOrderFreeFunName] = ZhiosOrderFree
  21. //jobs[consumeMd.ZhiosOrderTotalFunName] = ZhiosOrderTotal
  22. //jobs[consumeMd.ZhiosOrderTotalSecondFunName] = ZhiosOrderTotalSecond
  23. ////
  24. //jobs[consumeMd.ZhiosOrderSettleTotalFunName] = ZhiosSettleTotal
  25. //jobs[consumeMd.ZhiosOrderHjyFunName] = ZhiosOrderHjy
  26. //jobs[consumeMd.ZhiosOrderBuckleFunName] = ZhiosOrderBuckle
  27. ////
  28. //jobs[consumeMd.ZhiosSupplierAfterOrderFunName] = ZhiosSupplierAfterOrder
  29. //
  30. //jobs[consumeMd.ZhiosAppreciationFunName] = ZhiosAppreciation
  31. //jobs[consumeMd.ZhiosValidUserFunName] = ZhiosValidUser
  32. //
  33. //jobs[consumeMd.ZhiosAcquisitionConditionFunName] = ZhiosAcquisitionCondition
  34. //
  35. //jobs[consumeMd.DouShenUserRegisterConsumeForOfficialFunName] = DouShenUserRegisterConsumeForOfficial
  36. //jobs[consumeMd.DouShenUserRegisterConsumeForOperationCenterFunName] = DouShenUserRegisterConsumeForOperationCenter
  37. //jobs[consumeMd.DouShenUserRegisterConsumeForMyRecommenderFunName] = DouShenUserRegisterConsumeForMyRecommender
  38. //jobs[consumeMd.DouShenUserRegisterConsumeForMyFansFunName] = DouShenUserRegisterConsumeForMyFans
  39. //jobs[consumeMd.DouShenUserRegisterConsumeForUserRegisterUpLvFunName] = DouShenUserRegisterConsumeForUserRegisterUpLv
  40. //
  41. //jobs[consumeMd.ZhiosFastReturnOrderPayFunName] = ZhiosFastReturnOrderPay
  42. //jobs[consumeMd.ZhiosFastReturnOrderSuccessFunName] = ZhiosFastReturnOrderSuccess
  43. //jobs[consumeMd.ZhiosFastReturnOrderRefundFunName] = ZhiosFastReturnOrderRefund
  44. //jobs[consumeMd.ZhiosFastReturnOrderRefundSecondFunName] = ZhiosFastReturnOrderRefundSecond
  45. //
  46. //jobs[consumeMd.YoumishangExchangeStoreFunName] = YoumishangExchangeStore
  47. //
  48. //jobs[consumeMd.ZhiosRechargeOrderFailFunName] = ZhiosRechargeOrderFail
  49. //
  50. //jobs[consumeMd.CloudIssuanceAsyncMLoginFunName] = CloudIssuanceAsyncMLoginConsume
  51. //jobs[consumeMd.ZhiosTikTokUpdateFunName] = ZhiosTikTokUpdate
  52. //jobs[consumeMd.ZhiosTikTokAllUpdateFunName] = ZhiosTikTokAllUpdate
  53. //
  54. //jobs[consumeMd.ZhiosCapitalPoolOrderTotalFunName] = ZhiosCapitalPoolOrderTotal
  55. //jobs[consumeMd.ZhiosExpressOrderFail] = ZhiosExpressOrderFail
  56. //jobs[consumeMd.ZhiosWithdrawReward] = ZhiosWithdrawReward
  57. //jobs[consumeMd.ZhiosTaskTotal] = ZhiosTaskTotal
  58. //
  59. ////////////////////////////////////// V1 /////////////////////////////////////////////////////
  60. //jobs[consumeMd.CloudIssuanceMsgCallBackFunName] = CloudIssuanceMsgCallBackConsume
  61. //////////////////////////////////////// V2 /////////////////////////////////////////////////////
  62. //jobs[consumeMd.SupplyCloudChainFenxiaoNewChangeFunName] = SupplyCloudChainFenxiaoNewChangeConsume
  63. //////////////////////////////////////// V3 /////////////////////////////////////////////////////
  64. //jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume
  65. //////////////////////////////////////// bigData /////////////////////////////////////////////////////
  66. jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume
  67. jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume
  68. jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume
  69. jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume
  70. //////////////////////////////////////// oneCircles /////////////////////////////////////////////////////
  71. //jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume
  72. //jobs[consumeMd.OneCirclesStartLevelDividendFunName] = OneCirclesStartLevelDividendConsume
  73. //jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyConsume
  74. //jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume
  75. //jobs[consumeMd.OneCirclesSettlementPublicGiveActivityCoinFunName] = OneCirclesSettlementPublicGiveActivityCoinConsume
  76. //jobs[consumeMd.OneCirclesSignInCopyGreenEnergyFunName] = OneCirclesSignInCopyGreenEnergyConsume
  77. //////////////////////////////////////// withdraw /////////////////////////////////////////////////////
  78. //jobs[consumeMd.WithdrawConsumeFunName] = WithdrawConsume
  79. //jobs[consumeMd.FlexibleEmploymentWithdrawForGongMaoConsumeFunName] = FlexibleEmploymentWithdrawForGongMaoConsume
  80. //jobs[consumeMd.FlexibleEmploymentWithdrawForPupiaoConsumeFunName] = FlexibleEmploymentWithdrawForPupiaoConsume
  81. //jobs[consumeMd.ZhiosMallGreenCoinConsumeFunName] = ZhiosMallGreenCoinConsume //绿色双链积分
  82. //jobs[consumeMd.ZhiosOneCirclesCoinConsumeFunName] = ZhiosOneCirclesCoinConsume //一个圈圈虚拟币变化
  83. //////////////////////////////////////// autoRepaid /////////////////////////////////////////////////////
  84. jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款
  85. //jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款
  86. }
  87. func Run() {
  88. for _, v := range consumeMd.RabbitMqQueueKeyList {
  89. if _, ok := jobs[v.ConsumeFunName]; ok {
  90. go doConsume(v.ConsumeFunName, *v)()
  91. }
  92. }
  93. }
  94. func doConsume(fnName string, queue consumeMd.MqQueue) func() {
  95. return func() {
  96. begin := time.Now().Local()
  97. jobs[fnName](queue)
  98. end := time.Now().Local()
  99. logx.Infof(
  100. "[%s] AutoConsume started at <%s>, ended at <%s> duration <%s>",
  101. fnName,
  102. begin.Format("2006-01-02 15:04:05.000"),
  103. end.Format("2006-01-02 15:04:05.000"),
  104. time.Duration(end.UnixNano()-begin.UnixNano()).String(),
  105. )
  106. }
  107. }