2 changed files with 53 additions and 53 deletions
Split View
Diff Options
-
+38 -38consume/init.go
-
+15 -15etc/cfg.yml
+ 38
- 38
consume/init.go
View File
| @@ -17,45 +17,45 @@ func Init() { | |||
| // 增加消费任务队列 | |||
| func initConsumes() { | |||
| //jobs[consumeMd.EggSlowAutoUpLvConsume] = EggSlowAutoUpLvConsume //缓慢 自动升级 | |||
| //jobs[consumeMd.EggEnergyUserActivityConsume] = EggEnergyUserActivityConsume //监听 自动升级 | |||
| //jobs[consumeMd.EggCanalUserConsume] = EggCanalUserConsume //监听 自动升级 | |||
| // | |||
| //jobs[consumeMd.AliyunSmsRecordFunName] = AliyunSmsRecordConsume //阿里云短信 | |||
| //jobs[consumeMd.JpushRecordFunName] = JpushRecordConsume //极光推送 | |||
| //jobs[consumeMd.UserDeleteFunName] = UserDeleteConsume // 用户注销处理 | |||
| // | |||
| //jobs[consumeMd.EggEnergyNewUserRegisterDataFunName] = EggEnergyNewUserRegisterDataConsume // 新用户注册 | |||
| //jobs[consumeMd.IMEggEnergyBatchSendMessageDataFunName] = IMEggEnergyBatchSendMessageDataConsume // 批量发送信息 | |||
| //jobs[consumeMd.IMEggEnergyDelFriendCircleDataFunName] = IMEggEnergyDelFriendCircleDataConsume // 删除朋友圈 | |||
| //jobs[consumeMd.EggFinWithdrawApplyDataConsumeFunName] = EggFinWithdrawApplyDataConsume // 提现 | |||
| // | |||
| //jobs[consumeMd.EggEnergyDealUserECPMFunName] = EggEnergyDealUserECPMConsume // 处理给用户Ecpm值 | |||
| jobs[consumeMd.EggSlowAutoUpLvConsume] = EggSlowAutoUpLvConsume //缓慢 自动升级 | |||
| jobs[consumeMd.EggEnergyUserActivityConsume] = EggEnergyUserActivityConsume //监听 自动升级 | |||
| jobs[consumeMd.EggCanalUserConsume] = EggCanalUserConsume //监听 自动升级 | |||
| jobs[consumeMd.AliyunSmsRecordFunName] = AliyunSmsRecordConsume //阿里云短信 | |||
| jobs[consumeMd.JpushRecordFunName] = JpushRecordConsume //极光推送 | |||
| jobs[consumeMd.UserDeleteFunName] = UserDeleteConsume // 用户注销处理 | |||
| jobs[consumeMd.EggEnergyNewUserRegisterDataFunName] = EggEnergyNewUserRegisterDataConsume // 新用户注册 | |||
| jobs[consumeMd.IMEggEnergyBatchSendMessageDataFunName] = IMEggEnergyBatchSendMessageDataConsume // 批量发送信息 | |||
| jobs[consumeMd.IMEggEnergyDelFriendCircleDataFunName] = IMEggEnergyDelFriendCircleDataConsume // 删除朋友圈 | |||
| jobs[consumeMd.EggFinWithdrawApplyDataConsumeFunName] = EggFinWithdrawApplyDataConsume // 提现 | |||
| jobs[consumeMd.EggEnergyDealUserECPMFunName] = EggEnergyDealUserECPMConsume // 处理给用户Ecpm值 | |||
| jobs[consumeMd.EggEnergyTemporaryDealUserECPMFunName] = TemporaryEggEnergyDealUserECPMConsume // 临时处理给用户Ecpm值 | |||
| //jobs[consumeMd.EggCanalInviteUserNumsFunName] = EggCanalInviteUserNumsConsume // 处理拉新人数 | |||
| //jobs[consumeMd.EggCanalViolateNumsFunName] = EggCanalViolateNumsConsume // 处理违规次数 | |||
| //jobs[consumeMd.IMEggEnergySendRedPackageFunName] = IMEggEnergySendRedPackageConsume // 处理用户发送红包次数 | |||
| //jobs[consumeMd.EggCanalPersonAddActivityValueFunName] = EggCanalPersonAddActivityValueConsume // 用户活跃积分变更时更新es | |||
| //jobs[consumeMd.EggRecordActiveDataFunName] = EggRecordActiveDataConsume // 用户签到后更新活跃数据 | |||
| //jobs[consumeMd.EggEnergyAutoScoreDataFunName] = EggEnergyAutoScoreConsume // 自动打分 | |||
| //jobs[consumeMd.EggSendFriendCircleDataFunName] = EggSendFriendCircleDataConsume // 用户发送朋友圈后更新es | |||
| //jobs[consumeMd.EggCommentDataFunName] = EggCommentDataConsume // 用户评论后更新es | |||
| //jobs[consumeMd.EggCanalEnergyExchangeAccountFunName] = EggCanalEnergyExchangeAccountConsume // 蛋蛋能量兑换为余额的时候更新es | |||
| // | |||
| //jobs[consumeMd.VideoRewardFunName] = VideoRewardConsume // 短视频奖励 | |||
| //jobs[consumeMd.PlayletRewardFunName] = PlayletRewardConsume // 短剧奖励 | |||
| // | |||
| //jobs[consumeMd.EggEnergyDealPlatformRevenueDataFunName] = EggEnergyDealPlatformRevenueDataConsume // 平台营收 | |||
| //jobs[consumeMd.EggEnergyDealFundDataFunName] = EggEnergyDealFundDataConsume // 资金数据 | |||
| //jobs[consumeMd.EggEnergyDealUserVirtualCoinDataFunName] = EggEnergyDealUserVirtualCoinDataConsume // 视频奖励给相应团队发放积分 | |||
| // | |||
| //jobs[consumeMd.PublicPlatoonUserRelationCommissionConsumeFunName] = AddPublicPlatoonUserRelationCommissionConsume | |||
| //jobs[consumeMd.EggEnergyStartLevelDividendFunName] = EggEnergyStartLevelDividendConsume | |||
| //jobs[consumeMd.EggEnergySettlementPublicGiveActivityCoinFunName] = EggEnergySettlementPublicGiveActivityCoinConsume | |||
| //jobs[consumeMd.EggEnergyStartExchangeGreenEnergyFunName] = EggEnergyStartExchangeGreenEnergyConsume | |||
| //jobs[consumeMd.EggEnergyAutoExchangeGreenEnergyFunName] = EggEnergyAutoExchangeGreenEnergyConsume | |||
| //jobs[consumeMd.EggEnergyTeamAssistanceConsumeFunName] = EggEnergyTeamAssistanceConsume // 更新团队助力数据 | |||
| //jobs[consumeMd.EggCanalUserVirtualCoinFlowAggregationConsumeFunName] = EggCanalUserVirtualCoinFlowAggregationConsume // 聚合流水数据 | |||
| jobs[consumeMd.EggCanalInviteUserNumsFunName] = EggCanalInviteUserNumsConsume // 处理拉新人数 | |||
| jobs[consumeMd.EggCanalViolateNumsFunName] = EggCanalViolateNumsConsume // 处理违规次数 | |||
| jobs[consumeMd.IMEggEnergySendRedPackageFunName] = IMEggEnergySendRedPackageConsume // 处理用户发送红包次数 | |||
| jobs[consumeMd.EggCanalPersonAddActivityValueFunName] = EggCanalPersonAddActivityValueConsume // 用户活跃积分变更时更新es | |||
| jobs[consumeMd.EggRecordActiveDataFunName] = EggRecordActiveDataConsume // 用户签到后更新活跃数据 | |||
| jobs[consumeMd.EggEnergyAutoScoreDataFunName] = EggEnergyAutoScoreConsume // 自动打分 | |||
| jobs[consumeMd.EggSendFriendCircleDataFunName] = EggSendFriendCircleDataConsume // 用户发送朋友圈后更新es | |||
| jobs[consumeMd.EggCommentDataFunName] = EggCommentDataConsume // 用户评论后更新es | |||
| jobs[consumeMd.EggCanalEnergyExchangeAccountFunName] = EggCanalEnergyExchangeAccountConsume // 蛋蛋能量兑换为余额的时候更新es | |||
| jobs[consumeMd.VideoRewardFunName] = VideoRewardConsume // 短视频奖励 | |||
| jobs[consumeMd.PlayletRewardFunName] = PlayletRewardConsume // 短剧奖励 | |||
| jobs[consumeMd.EggEnergyDealPlatformRevenueDataFunName] = EggEnergyDealPlatformRevenueDataConsume // 平台营收 | |||
| jobs[consumeMd.EggEnergyDealFundDataFunName] = EggEnergyDealFundDataConsume // 资金数据 | |||
| jobs[consumeMd.EggEnergyDealUserVirtualCoinDataFunName] = EggEnergyDealUserVirtualCoinDataConsume // 视频奖励给相应团队发放积分 | |||
| jobs[consumeMd.PublicPlatoonUserRelationCommissionConsumeFunName] = AddPublicPlatoonUserRelationCommissionConsume | |||
| jobs[consumeMd.EggEnergyStartLevelDividendFunName] = EggEnergyStartLevelDividendConsume | |||
| jobs[consumeMd.EggEnergySettlementPublicGiveActivityCoinFunName] = EggEnergySettlementPublicGiveActivityCoinConsume | |||
| jobs[consumeMd.EggEnergyStartExchangeGreenEnergyFunName] = EggEnergyStartExchangeGreenEnergyConsume | |||
| jobs[consumeMd.EggEnergyAutoExchangeGreenEnergyFunName] = EggEnergyAutoExchangeGreenEnergyConsume | |||
| jobs[consumeMd.EggEnergyTeamAssistanceConsumeFunName] = EggEnergyTeamAssistanceConsume // 更新团队助力数据 | |||
| jobs[consumeMd.EggCanalUserVirtualCoinFlowAggregationConsumeFunName] = EggCanalUserVirtualCoinFlowAggregationConsume // 聚合流水数据 | |||
| } | |||
| func Run() { | |||
+ 15
- 15
etc/cfg.yml
View File
| @@ -81,26 +81,26 @@ log: | |||
| file_name: 'debug.log' | |||
| # 连接RabbitMq | |||
| #mq: | |||
| # host: '120.77.153.180' | |||
| # port: '5672' | |||
| # user: 'guest' | |||
| # pwd: 'guest' | |||
| mq: | |||
| host: '116.62.62.35' | |||
| host: '120.77.153.180' | |||
| port: '5672' | |||
| user: 'zhios' | |||
| pwd: 'ZHIoscnfnuo123' | |||
| es: | |||
| url: 'http://120.55.48.175:9200' | |||
| user: 'elastic' | |||
| pwd: 'fnuo123' | |||
| user: 'guest' | |||
| pwd: 'guest' | |||
| #mq: | |||
| # host: '116.62.62.35' | |||
| # port: '5672' | |||
| # user: 'zhios' | |||
| # pwd: 'ZHIoscnfnuo123' | |||
| #es: | |||
| # url: 'http://123.57.140.192:9200' | |||
| # url: 'http://120.55.48.175:9200' | |||
| # user: 'elastic' | |||
| # pwd: 'se4BxqYyGhHyPWPA3w8Q' | |||
| # pwd: 'fnuo123' | |||
| es: | |||
| url: 'http://123.57.140.192:9200' | |||
| user: 'elastic' | |||
| pwd: 'se4BxqYyGhHyPWPA3w8Q' | |||
| im_business_rpc: | |||
| url: im-rpc-business.izhim.com | |||