diff --git a/app/main/api/desc/admin/admin_agent.api b/app/main/api/desc/admin/admin_agent.api index 19e1bc1..00eb8fb 100644 --- a/app/main/api/desc/admin/admin_agent.api +++ b/app/main/api/desc/admin/admin_agent.api @@ -69,6 +69,14 @@ service main { // 获取提现统计数据 @handler AdminGetWithdrawalStatistics get /agent-withdrawal/statistics (AdminGetWithdrawalStatisticsReq) returns (AdminGetWithdrawalStatisticsResp) + + // 获取代理订单统计数据 + @handler AdminGetAgentOrderStatistics + get /agent-order/statistics (AdminGetAgentOrderStatisticsReq) returns (AdminGetAgentOrderStatisticsResp) + + // 获取代理统计数据 + @handler AdminGetAgentStatistics + get /statistics (AdminGetAgentStatisticsReq) returns (AdminGetAgentStatisticsResp) } type ( @@ -419,4 +427,24 @@ type ( TotalWithdrawalAmount float64 `json:"total_withdrawal_amount"` // 总提现金额 TodayWithdrawalAmount float64 `json:"today_withdrawal_amount"` // 今日提现金额 } + + // 获取代理订单统计数据请求 + AdminGetAgentOrderStatisticsReq { + } + + // 获取代理订单统计数据响应 + AdminGetAgentOrderStatisticsResp { + TotalAgentOrderCount int64 `json:"total_agent_order_count"` // 总代理订单数 + TodayAgentOrderCount int64 `json:"today_agent_order_count"` // 今日代理订单数 + } + + // 获取代理统计数据请求 + AdminGetAgentStatisticsReq { + } + + // 获取代理统计数据响应 + AdminGetAgentStatisticsResp { + TotalAgentCount int64 `json:"total_agent_count"` // 总代理数 + TodayAgentCount int64 `json:"today_agent_count"` // 今日新增代理数 + } ) \ No newline at end of file diff --git a/app/main/api/internal/handler/admin_agent/admingetagentorderstatisticshandler.go b/app/main/api/internal/handler/admin_agent/admingetagentorderstatisticshandler.go new file mode 100644 index 0000000..b627e27 --- /dev/null +++ b/app/main/api/internal/handler/admin_agent/admingetagentorderstatisticshandler.go @@ -0,0 +1,29 @@ +package admin_agent + +import ( + "net/http" + + "github.com/zeromicro/go-zero/rest/httpx" + "tydata-server/app/main/api/internal/logic/admin_agent" + "tydata-server/app/main/api/internal/svc" + "tydata-server/app/main/api/internal/types" + "tydata-server/common/result" + "tydata-server/pkg/lzkit/validator" +) + +func AdminGetAgentOrderStatisticsHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + var req types.AdminGetAgentOrderStatisticsReq + if err := httpx.Parse(r, &req); err != nil { + result.ParamErrorResult(r, w, err) + return + } + if err := validator.Validate(req); err != nil { + result.ParamValidateErrorResult(r, w, err) + return + } + l := admin_agent.NewAdminGetAgentOrderStatisticsLogic(r.Context(), svcCtx) + resp, err := l.AdminGetAgentOrderStatistics(&req) + result.HttpResult(r, w, resp, err) + } +} diff --git a/app/main/api/internal/handler/admin_agent/admingetagentstatisticshandler.go b/app/main/api/internal/handler/admin_agent/admingetagentstatisticshandler.go new file mode 100644 index 0000000..2564870 --- /dev/null +++ b/app/main/api/internal/handler/admin_agent/admingetagentstatisticshandler.go @@ -0,0 +1,29 @@ +package admin_agent + +import ( + "net/http" + + "github.com/zeromicro/go-zero/rest/httpx" + "tydata-server/app/main/api/internal/logic/admin_agent" + "tydata-server/app/main/api/internal/svc" + "tydata-server/app/main/api/internal/types" + "tydata-server/common/result" + "tydata-server/pkg/lzkit/validator" +) + +func AdminGetAgentStatisticsHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + var req types.AdminGetAgentStatisticsReq + if err := httpx.Parse(r, &req); err != nil { + result.ParamErrorResult(r, w, err) + return + } + if err := validator.Validate(req); err != nil { + result.ParamValidateErrorResult(r, w, err) + return + } + l := admin_agent.NewAdminGetAgentStatisticsLogic(r.Context(), svcCtx) + resp, err := l.AdminGetAgentStatistics(&req) + result.HttpResult(r, w, resp, err) + } +} diff --git a/app/main/api/internal/handler/admin_agent/admingetwithdrawalstatisticshandler.go b/app/main/api/internal/handler/admin_agent/admingetwithdrawalstatisticshandler.go index e16552e..8c901af 100644 --- a/app/main/api/internal/handler/admin_agent/admingetwithdrawalstatisticshandler.go +++ b/app/main/api/internal/handler/admin_agent/admingetwithdrawalstatisticshandler.go @@ -3,12 +3,13 @@ package admin_agent import ( "net/http" - "github.com/zeromicro/go-zero/rest/httpx" "tydata-server/app/main/api/internal/logic/admin_agent" "tydata-server/app/main/api/internal/svc" "tydata-server/app/main/api/internal/types" "tydata-server/common/result" "tydata-server/pkg/lzkit/validator" + + "github.com/zeromicro/go-zero/rest/httpx" ) func AdminGetWithdrawalStatisticsHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { diff --git a/app/main/api/internal/handler/routes.go b/app/main/api/internal/handler/routes.go index c21241e..902f3ce 100644 --- a/app/main/api/internal/handler/routes.go +++ b/app/main/api/internal/handler/routes.go @@ -67,6 +67,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) { Path: "/agent-membership-recharge-order/list", Handler: admin_agent.AdminGetAgentMembershipRechargeOrderListHandler(serverCtx), }, + { + Method: http.MethodGet, + Path: "/agent-order/statistics", + Handler: admin_agent.AdminGetAgentOrderStatisticsHandler(serverCtx), + }, { Method: http.MethodGet, Path: "/agent-platform-deduction/list", @@ -107,6 +112,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) { Path: "/list", Handler: admin_agent.AdminGetAgentListHandler(serverCtx), }, + { + Method: http.MethodGet, + Path: "/statistics", + Handler: admin_agent.AdminGetAgentStatisticsHandler(serverCtx), + }, }..., ), rest.WithPrefix("/api/v1/admin/agent"), diff --git a/app/main/api/internal/logic/admin_agent/admingetagentorderstatisticslogic.go b/app/main/api/internal/logic/admin_agent/admingetagentorderstatisticslogic.go new file mode 100644 index 0000000..198fcd1 --- /dev/null +++ b/app/main/api/internal/logic/admin_agent/admingetagentorderstatisticslogic.go @@ -0,0 +1,60 @@ +package admin_agent + +import ( + "context" + "fmt" + "time" + + "tydata-server/app/main/api/internal/svc" + "tydata-server/app/main/api/internal/types" + + "github.com/zeromicro/go-zero/core/logx" +) + +type AdminGetAgentOrderStatisticsLogic struct { + logx.Logger + ctx context.Context + svcCtx *svc.ServiceContext +} + +func NewAdminGetAgentOrderStatisticsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AdminGetAgentOrderStatisticsLogic { + return &AdminGetAgentOrderStatisticsLogic{ + Logger: logx.WithContext(ctx), + ctx: ctx, + svcCtx: svcCtx, + } +} + +func (l *AdminGetAgentOrderStatisticsLogic) AdminGetAgentOrderStatistics(req *types.AdminGetAgentOrderStatisticsReq) (resp *types.AdminGetAgentOrderStatisticsResp, err error) { + // 获取今日的开始和结束时间 + today := time.Now() + startOfDay := time.Date(today.Year(), today.Month(), today.Day(), 0, 0, 0, 0, today.Location()) + endOfDay := startOfDay.Add(24 * time.Hour) + + // 构建查询条件 + builder := l.svcCtx.AgentOrderModel.SelectBuilder() + + // 查询总代理订单数 + totalBuilder := builder + totalAgentOrderCount, err := l.svcCtx.AgentOrderModel.FindCount(l.ctx, totalBuilder, "id") + if err != nil { + logx.Errorf("查询总代理订单数失败: %v", err) + return nil, fmt.Errorf("查询总代理订单数失败: %w", err) + } + + // 查询今日代理订单数 + todayBuilder := builder.Where("create_time >= ? AND create_time < ?", startOfDay, endOfDay) + todayAgentOrderCount, err := l.svcCtx.AgentOrderModel.FindCount(l.ctx, todayBuilder, "id") + if err != nil { + logx.Errorf("查询今日代理订单数失败: %v", err) + return nil, fmt.Errorf("查询今日代理订单数失败: %w", err) + } + + // 构建响应 + resp = &types.AdminGetAgentOrderStatisticsResp{ + TotalAgentOrderCount: totalAgentOrderCount, + TodayAgentOrderCount: todayAgentOrderCount, + } + + return resp, nil +} diff --git a/app/main/api/internal/logic/admin_agent/admingetagentstatisticslogic.go b/app/main/api/internal/logic/admin_agent/admingetagentstatisticslogic.go new file mode 100644 index 0000000..08cacc7 --- /dev/null +++ b/app/main/api/internal/logic/admin_agent/admingetagentstatisticslogic.go @@ -0,0 +1,56 @@ +package admin_agent + +import ( + "context" + "fmt" + "time" + + "tydata-server/app/main/api/internal/svc" + "tydata-server/app/main/api/internal/types" + + "github.com/zeromicro/go-zero/core/logx" +) + +type AdminGetAgentStatisticsLogic struct { + logx.Logger + ctx context.Context + svcCtx *svc.ServiceContext +} + +func NewAdminGetAgentStatisticsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AdminGetAgentStatisticsLogic { + return &AdminGetAgentStatisticsLogic{ + Logger: logx.WithContext(ctx), + ctx: ctx, + svcCtx: svcCtx, + } +} + +func (l *AdminGetAgentStatisticsLogic) AdminGetAgentStatistics(req *types.AdminGetAgentStatisticsReq) (resp *types.AdminGetAgentStatisticsResp, err error) { + // 使用AgentModel的SelectBuilder和FindCount方法获取总代理数 + totalBuilder := l.svcCtx.AgentModel.SelectBuilder() + totalAgentCount, err := l.svcCtx.AgentModel.FindCount(l.ctx, totalBuilder, "id") + if err != nil { + logx.Errorf("获取总代理数失败: %v", err) + return nil, fmt.Errorf("获取总代理数失败: %w", err) + } + + // 获取今日新增代理数 + todayBuilder := l.svcCtx.AgentModel.SelectBuilder() + today := time.Now() + startOfDay := time.Date(today.Year(), today.Month(), today.Day(), 0, 0, 0, 0, today.Location()) + endOfDay := startOfDay.Add(24 * time.Hour) + todayBuilder = todayBuilder.Where("create_time >= ? AND create_time < ?", startOfDay, endOfDay) + + todayAgentCount, err := l.svcCtx.AgentModel.FindCount(l.ctx, todayBuilder, "id") + if err != nil { + logx.Errorf("获取今日新增代理数失败: %v", err) + return nil, fmt.Errorf("获取今日新增代理数失败: %w", err) + } + + resp = &types.AdminGetAgentStatisticsResp{ + TotalAgentCount: totalAgentCount, + TodayAgentCount: todayAgentCount, + } + + return resp, nil +} diff --git a/app/main/api/internal/types/types.go b/app/main/api/internal/types/types.go index 9ca7472..dcc84f6 100644 --- a/app/main/api/internal/types/types.go +++ b/app/main/api/internal/types/types.go @@ -279,6 +279,14 @@ type AdminGetAgentMembershipRechargeOrderListResp struct { Items []AgentMembershipRechargeOrderListItem `json:"items"` // 列表数据 } +type AdminGetAgentOrderStatisticsReq struct { +} + +type AdminGetAgentOrderStatisticsResp struct { + TotalAgentOrderCount int64 `json:"total_agent_order_count"` // 总代理订单数 + TodayAgentOrderCount int64 `json:"today_agent_order_count"` // 今日代理订单数 +} + type AdminGetAgentPlatformDeductionListReq struct { Page int64 `form:"page"` // 页码 PageSize int64 `form:"pageSize"` // 每页数量 @@ -317,6 +325,14 @@ type AdminGetAgentRewardListResp struct { Items []AgentRewardListItem `json:"items"` // 列表数据 } +type AdminGetAgentStatisticsReq struct { +} + +type AdminGetAgentStatisticsResp struct { + TotalAgentCount int64 `json:"total_agent_count"` // 总代理数 + TodayAgentCount int64 `json:"today_agent_count"` // 今日新增代理数 +} + type AdminGetAgentWithdrawalListReq struct { Page int64 `form:"page"` // 页码 PageSize int64 `form:"pageSize"` // 每页数量 diff --git a/app/main/model/agentModel_gen.go b/app/main/model/agentModel_gen.go index d95cdf8..3d89ab5 100644 --- a/app/main/model/agentModel_gen.go +++ b/app/main/model/agentModel_gen.go @@ -27,9 +27,9 @@ var ( agentRowsExpectAutoSet = strings.Join(stringx.Remove(agentFieldNames, "`id`", "`create_time`", "`update_time`"), ",") agentRowsWithPlaceHolder = strings.Join(stringx.Remove(agentFieldNames, "`id`", "`create_time`", "`update_time`"), "=?,") + "=?" - cacheHmAgentIdPrefix = "cache:tydata:agent:id:" - cacheHmAgentMobilePrefix = "cache:tydata:agent:mobile:" - cacheHmAgentUserIdPrefix = "cache:tydata:agent:userId:" + cacheTydataAgentIdPrefix = "cache:tydata:agent:id:" + cacheTydataAgentMobilePrefix = "cache:tydata:agent:mobile:" + cacheTydataAgentUserIdPrefix = "cache:tydata:agent:userId:" ) type ( @@ -83,22 +83,22 @@ func newAgentModel(conn sqlx.SqlConn, c cache.CacheConf) *defaultAgentModel { func (m *defaultAgentModel) Insert(ctx context.Context, session sqlx.Session, data *Agent) (sql.Result, error) { data.DelState = globalkey.DelStateNo - hmAgentIdKey := fmt.Sprintf("%s%v", cacheHmAgentIdPrefix, data.Id) - hmAgentMobileKey := fmt.Sprintf("%s%v", cacheHmAgentMobilePrefix, data.Mobile) - hmAgentUserIdKey := fmt.Sprintf("%s%v", cacheHmAgentUserIdPrefix, data.UserId) + tydataAgentIdKey := fmt.Sprintf("%s%v", cacheTydataAgentIdPrefix, data.Id) + tydataAgentMobileKey := fmt.Sprintf("%s%v", cacheTydataAgentMobilePrefix, data.Mobile) + tydataAgentUserIdKey := fmt.Sprintf("%s%v", cacheTydataAgentUserIdPrefix, data.UserId) return m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) { query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, agentRowsExpectAutoSet) if session != nil { return session.ExecCtx(ctx, query, data.UserId, data.LevelName, data.Region, data.Mobile, data.WechatId, data.MembershipExpiryTime, data.DeleteTime, data.DelState, data.Version) } return conn.ExecCtx(ctx, query, data.UserId, data.LevelName, data.Region, data.Mobile, data.WechatId, data.MembershipExpiryTime, data.DeleteTime, data.DelState, data.Version) - }, hmAgentIdKey, hmAgentMobileKey, hmAgentUserIdKey) + }, tydataAgentIdKey, tydataAgentMobileKey, tydataAgentUserIdKey) } func (m *defaultAgentModel) FindOne(ctx context.Context, id int64) (*Agent, error) { - hmAgentIdKey := fmt.Sprintf("%s%v", cacheHmAgentIdPrefix, id) + tydataAgentIdKey := fmt.Sprintf("%s%v", cacheTydataAgentIdPrefix, id) var resp Agent - err := m.QueryRowCtx(ctx, &resp, hmAgentIdKey, func(ctx context.Context, conn sqlx.SqlConn, v interface{}) error { + err := m.QueryRowCtx(ctx, &resp, tydataAgentIdKey, func(ctx context.Context, conn sqlx.SqlConn, v interface{}) error { query := fmt.Sprintf("select %s from %s where `id` = ? and del_state = ? limit 1", agentRows, m.table) return conn.QueryRowCtx(ctx, v, query, id, globalkey.DelStateNo) }) @@ -113,9 +113,9 @@ func (m *defaultAgentModel) FindOne(ctx context.Context, id int64) (*Agent, erro } func (m *defaultAgentModel) FindOneByMobile(ctx context.Context, mobile string) (*Agent, error) { - hmAgentMobileKey := fmt.Sprintf("%s%v", cacheHmAgentMobilePrefix, mobile) + tydataAgentMobileKey := fmt.Sprintf("%s%v", cacheTydataAgentMobilePrefix, mobile) var resp Agent - err := m.QueryRowIndexCtx(ctx, &resp, hmAgentMobileKey, m.formatPrimary, func(ctx context.Context, conn sqlx.SqlConn, v interface{}) (i interface{}, e error) { + err := m.QueryRowIndexCtx(ctx, &resp, tydataAgentMobileKey, m.formatPrimary, func(ctx context.Context, conn sqlx.SqlConn, v interface{}) (i interface{}, e error) { query := fmt.Sprintf("select %s from %s where `mobile` = ? and del_state = ? limit 1", agentRows, m.table) if err := conn.QueryRowCtx(ctx, &resp, query, mobile, globalkey.DelStateNo); err != nil { return nil, err @@ -133,9 +133,9 @@ func (m *defaultAgentModel) FindOneByMobile(ctx context.Context, mobile string) } func (m *defaultAgentModel) FindOneByUserId(ctx context.Context, userId int64) (*Agent, error) { - hmAgentUserIdKey := fmt.Sprintf("%s%v", cacheHmAgentUserIdPrefix, userId) + tydataAgentUserIdKey := fmt.Sprintf("%s%v", cacheTydataAgentUserIdPrefix, userId) var resp Agent - err := m.QueryRowIndexCtx(ctx, &resp, hmAgentUserIdKey, m.formatPrimary, func(ctx context.Context, conn sqlx.SqlConn, v interface{}) (i interface{}, e error) { + err := m.QueryRowIndexCtx(ctx, &resp, tydataAgentUserIdKey, m.formatPrimary, func(ctx context.Context, conn sqlx.SqlConn, v interface{}) (i interface{}, e error) { query := fmt.Sprintf("select %s from %s where `user_id` = ? and del_state = ? limit 1", agentRows, m.table) if err := conn.QueryRowCtx(ctx, &resp, query, userId, globalkey.DelStateNo); err != nil { return nil, err @@ -157,16 +157,16 @@ func (m *defaultAgentModel) Update(ctx context.Context, session sqlx.Session, ne if err != nil { return nil, err } - hmAgentIdKey := fmt.Sprintf("%s%v", cacheHmAgentIdPrefix, data.Id) - hmAgentMobileKey := fmt.Sprintf("%s%v", cacheHmAgentMobilePrefix, data.Mobile) - hmAgentUserIdKey := fmt.Sprintf("%s%v", cacheHmAgentUserIdPrefix, data.UserId) + tydataAgentIdKey := fmt.Sprintf("%s%v", cacheTydataAgentIdPrefix, data.Id) + tydataAgentMobileKey := fmt.Sprintf("%s%v", cacheTydataAgentMobilePrefix, data.Mobile) + tydataAgentUserIdKey := fmt.Sprintf("%s%v", cacheTydataAgentUserIdPrefix, data.UserId) return m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) { query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, agentRowsWithPlaceHolder) if session != nil { return session.ExecCtx(ctx, query, newData.UserId, newData.LevelName, newData.Region, newData.Mobile, newData.WechatId, newData.MembershipExpiryTime, newData.DeleteTime, newData.DelState, newData.Version, newData.Id) } return conn.ExecCtx(ctx, query, newData.UserId, newData.LevelName, newData.Region, newData.Mobile, newData.WechatId, newData.MembershipExpiryTime, newData.DeleteTime, newData.DelState, newData.Version, newData.Id) - }, hmAgentIdKey, hmAgentMobileKey, hmAgentUserIdKey) + }, tydataAgentIdKey, tydataAgentMobileKey, tydataAgentUserIdKey) } func (m *defaultAgentModel) UpdateWithVersion(ctx context.Context, session sqlx.Session, newData *Agent) error { @@ -181,16 +181,16 @@ func (m *defaultAgentModel) UpdateWithVersion(ctx context.Context, session sqlx. if err != nil { return err } - hmAgentIdKey := fmt.Sprintf("%s%v", cacheHmAgentIdPrefix, data.Id) - hmAgentMobileKey := fmt.Sprintf("%s%v", cacheHmAgentMobilePrefix, data.Mobile) - hmAgentUserIdKey := fmt.Sprintf("%s%v", cacheHmAgentUserIdPrefix, data.UserId) + tydataAgentIdKey := fmt.Sprintf("%s%v", cacheTydataAgentIdPrefix, data.Id) + tydataAgentMobileKey := fmt.Sprintf("%s%v", cacheTydataAgentMobilePrefix, data.Mobile) + tydataAgentUserIdKey := fmt.Sprintf("%s%v", cacheTydataAgentUserIdPrefix, data.UserId) sqlResult, err = m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) { query := fmt.Sprintf("update %s set %s where `id` = ? and version = ? ", m.table, agentRowsWithPlaceHolder) if session != nil { return session.ExecCtx(ctx, query, newData.UserId, newData.LevelName, newData.Region, newData.Mobile, newData.WechatId, newData.MembershipExpiryTime, newData.DeleteTime, newData.DelState, newData.Version, newData.Id, oldVersion) } return conn.ExecCtx(ctx, query, newData.UserId, newData.LevelName, newData.Region, newData.Mobile, newData.WechatId, newData.MembershipExpiryTime, newData.DeleteTime, newData.DelState, newData.Version, newData.Id, oldVersion) - }, hmAgentIdKey, hmAgentMobileKey, hmAgentUserIdKey) + }, tydataAgentIdKey, tydataAgentMobileKey, tydataAgentUserIdKey) if err != nil { return err } @@ -413,20 +413,20 @@ func (m *defaultAgentModel) Delete(ctx context.Context, session sqlx.Session, id return err } - hmAgentIdKey := fmt.Sprintf("%s%v", cacheHmAgentIdPrefix, id) - hmAgentMobileKey := fmt.Sprintf("%s%v", cacheHmAgentMobilePrefix, data.Mobile) - hmAgentUserIdKey := fmt.Sprintf("%s%v", cacheHmAgentUserIdPrefix, data.UserId) + tydataAgentIdKey := fmt.Sprintf("%s%v", cacheTydataAgentIdPrefix, id) + tydataAgentMobileKey := fmt.Sprintf("%s%v", cacheTydataAgentMobilePrefix, data.Mobile) + tydataAgentUserIdKey := fmt.Sprintf("%s%v", cacheTydataAgentUserIdPrefix, data.UserId) _, err = m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) { query := fmt.Sprintf("delete from %s where `id` = ?", m.table) if session != nil { return session.ExecCtx(ctx, query, id) } return conn.ExecCtx(ctx, query, id) - }, hmAgentIdKey, hmAgentMobileKey, hmAgentUserIdKey) + }, tydataAgentIdKey, tydataAgentMobileKey, tydataAgentUserIdKey) return err } func (m *defaultAgentModel) formatPrimary(primary interface{}) string { - return fmt.Sprintf("%s%v", cacheHmAgentIdPrefix, primary) + return fmt.Sprintf("%s%v", cacheTydataAgentIdPrefix, primary) } func (m *defaultAgentModel) queryPrimary(ctx context.Context, conn sqlx.SqlConn, v, primary interface{}) error { query := fmt.Sprintf("select %s from %s where `id` = ? and del_state = ? limit 1", agentRows, m.table) diff --git a/deploy/script/gen_models.ps1 b/deploy/script/gen_models.ps1 index 2d75ec6..8472179 100644 --- a/deploy/script/gen_models.ps1 +++ b/deploy/script/gen_models.ps1 @@ -7,7 +7,7 @@ $TEMPLATE_DIR = "../template" # 表名列表 $tables = @( - # "agent", + # "agent" # "agent_active_stat", # "agent_audit", # "agent_closure", @@ -28,7 +28,7 @@ $tables = @( # "agent_withdrawal_tax_exemption" # "feature" # "global_notifications" - "order" + # "order" # "order_refund" # "product", # "product_feature"