From eeb46924fbc04303f848b2ba7f8e48971c29ba37 Mon Sep 17 00:00:00 2001 From: goder-zhang Date: Tue, 3 Mar 2026 01:54:22 +0000 Subject: [PATCH] change add user --- api/v1/sqs/aws-sqs.go | 56 +++++++++++++++++++++++------ config.yaml | 16 ++++----- global/model.go | 6 ++++ go.mod | 8 +++-- go.sum | 21 ++++++----- model/account/account.go | 18 ++++++++++ model/awssqs/sqs.go | 71 +++++++++++++++++++++++++++++++++++++ service/account/account.go | 72 ++++++++++++++++++++++++++++++++++++++ 8 files changed, 235 insertions(+), 33 deletions(-) create mode 100644 model/account/account.go create mode 100644 service/account/account.go diff --git a/api/v1/sqs/aws-sqs.go b/api/v1/sqs/aws-sqs.go index b0a0b9b..c5cee64 100644 --- a/api/v1/sqs/aws-sqs.go +++ b/api/v1/sqs/aws-sqs.go @@ -3,20 +3,22 @@ package sqs import ( "bygdata/global" "bygdata/model/awssqs" + "bygdata/service/account" "context" "encoding/json" "fmt" - "github.com/aws/aws-sdk-go/aws" - "github.com/aws/aws-sdk-go/aws/credentials" - "github.com/aws/aws-sdk-go/aws/session" - "github.com/aws/aws-sdk-go/service/sqs" - "go.uber.org/zap" "os" "os/signal" "strings" "sync" "syscall" "time" + + "github.com/aws/aws-sdk-go/aws" + "github.com/aws/aws-sdk-go/aws/credentials" + "github.com/aws/aws-sdk-go/aws/session" + "github.com/aws/aws-sdk-go/service/sqs" + "go.uber.org/zap" ) func ProcessSqsMessage() { @@ -189,7 +191,7 @@ func processMessage(svc *sqs.SQS, queueURL string, msg *sqs.Message) { // 如果处理时间可能较长，延长可见性超时 // 这里可以根据实际处理逻辑动态调整 - extendVisibilityTimeout(svc, queueURL, msg, 600) // 延长到 10 分钟 + //extendVisibilityTimeout(svc, queueURL, msg, 600) // 延长到 10 分钟 // 在这里处理接收到的消息 var sqsMessage awssqs.SqsMessage @@ -212,12 +214,44 @@ func processMessage(svc *sqs.SQS, queueURL string, msg *sqs.Message) { global.GVA_LOG.Info("Processing create user action", zap.String("msgId", msgId), zap.Int32("msg_action", int32(sqsMessage.Action)), zap.String("msg_content", sqsMessage.Content)) - if sqsMessage.Action == awssqs.SqsActionCreateUser { - // TODO: 实现创建用户的逻辑 - global.GVA_LOG.Info("Processing create user action", zap.String("msgId", msgId)) - // 这里应该调用实际的处理逻辑 - // processErr = handleCreateUser(sqsMessage) + global.GVA_LOG.Info("Processing SqsActionCreateUser", zap.String("msgId", msgId)) + account.CreateUser(sqsMessage.Content) + } else if sqsMessage.Action == awssqs.SqsActionIncreaseBetTotal { + global.GVA_LOG.Info("Processing SqsActionIncreaseBetTotal", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionDecreaseBetTotal { + global.GVA_LOG.Info("Processing SqsActionDecreaseBetTotal", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionDeductWithdrawLimitAfterTransfer { + // 处理"回收后才结算"的情况：创建账变记录扣除稽核流水（余额不变） + global.GVA_LOG.Info("Processing SqsActionDeductWithdrawLimitAfterTransfer", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionInviteCratesCheck { + global.GVA_LOG.Info("Processing SqsActionInviteCratesCheck", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionInviteBonusCheck { + global.GVA_LOG.Info("Processing SqsActionInviteBonusCheck", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionLoginIpCheck { + global.GVA_LOG.Info("Processing SqsActionLoginIpCheck", zap.String("msgId", msgId)) + account.CreateUserCheck(sqsMessage.Content) + } else if sqsMessage.Action == awssqs.SqsActionExportData { + global.GVA_LOG.Info("Processing SqsActionExportData", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionSendEmailVerifyCode { + global.GVA_LOG.Info("Processing SqsActionSendEmailVerifyCode", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionDailyQuestProcess { + global.GVA_LOG.Info("Processing SqsActionDailyQuestProcess", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionDepositSuccess { + var req awssqs.SqsActionDepositSuccessContent + err = json.Unmarshal([]byte(sqsMessage.Content), &req) + if err != nil { + return + } + fmt.Fprintf(os.Stderr, "[SQS处理] 解析充值成功消息成功: userno=%s, orderno=%s, depositTimes=%d, depositAmount=%s\n", + req.Userno, req.Orderno, req.DepositTimes, req.DepositAmount.String()) + } else if sqsMessage.Action == awssqs.SqsActionVisit { + global.GVA_LOG.Info("Processing SqsActionVisit", zap.String("msgId", msgId)) + account.UpdateUser(sqsMessage.Content) + } else if sqsMessage.Action == awssqs.SqsActionSaveBonus { + global.GVA_LOG.Info("Processing SqsActionSaveBonus", zap.String("msgId", msgId)) + } else if sqsMessage.Action == awssqs.SqsActionGenDepositDailyClaim { + global.GVA_LOG.Info("Processing SqsActionGenDepositDailyClaim", zap.String("msgId", msgId)) } else { global.GVA_LOG.Warn("Unknown action", zap.String("action", string(sqsMessage.Action)), diff --git a/config.yaml b/config.yaml index bff3fcd..efc6afd 100644 --- a/config.yaml +++ b/config.yaml @@ -74,16 +74,16 @@ captcha: # mysql connect configuration # 未初始化之前请勿手动修改数据库信息！！！如果一定要手动初始化请看（https://gin-vue-admin.com/docs/first_master） mysql: - path: "goder2.cpccmm68qb1d.ap-southeast-1.rds.amazonaws.com" + path: "xpink-prod-mysql.cjkmm024cf76.ap-east-1.rds.amazonaws.com" port: "3306" config: "charset=utf8mb4&parseTime=True&loc=Local" db-name: "byg_data" username: "admin" - password: "vH2GkUxz2398GmDTy" + password: "keN2