Functions — github.com/Ember-Moth/ppanel

hub / github.com/Ember-Moth/ppanel / functions

Functions1,586 in github.com/Ember-Moth/ppanel

⨍ Functions 1,586◇ Types & classes 763

↓ 1 callersMethodrenewal

( &self, user_id: i64, req: RenewalOrderRequest, )

src/service/public/order/renewal_service.rs:37

↓ 1 callersFunctionreset_sequences

(pg: &PgPool, schema: &str)

tools/mysql2postgres/src/main.rs:436

↓ 1 callersMethodreset_subscribe_traffic_by_ids

(&self, ids: &[i64])

src/repository/user/pg.rs:840

↓ 1 callersMethodreset_traffic

( &self, user_id: i64, req: ResetTrafficOrderRequest, )

src/service/public/order/reset_traffic_service.rs:34

↓ 1 callersMethodreset_user_subscribe_token

( &self, _user_id: i64, req: ResetUserSubscribeTokenRequest, )

src/service/public/user/reset_user_subscribe_token_service.rs:21

↓ 1 callersMethodresolve_ratio

(&self, server: &crate::model::entity::node::Server, protocol: &str)

src/queue/service/traffic.rs:256

↓ 1 callersMethodresolve_subscriber_ids

(&self, scope: &QuotaScope)

src/queue/service/task.rs:178

↓ 1 callersFunctionrun_migrate_tool

(cfg: &DatabaseConfig)

src/migration.rs:62

↓ 1 callersFunctionscanVersions

scanVersions lists all up-version numbers present in the embedded source dir.

tools/migrate/migrate/migrate.go:70

↓ 1 callersMethodsearch_customer

(&self, user: &User)

crates/payment/src/stripe.rs:76

↓ 1 callersFunctionsend_email

(task: Task, repos: Arc<Repositories>, config: Arc<Config>)

src/queue/handler/email.rs:10

↓ 1 callersMethodsend_message

Send a message via Telegram Bot API.

src/service/telegram/telegram_service.rs:162

↓ 1 callersFunctionsend_sms

(task: Task, repos: Arc<Repositories>, config: Arc<Config>)

src/queue/handler/sms.rs:10

↓ 1 callersFunctionsetting_telegram_bot

(config: &Config)

src/service/admin/system/setting_telegram_bot_service.rs:3

↓ 1 callersFunctionshould_reset_for_renewal

(expire_time_ms: i64, now: chrono::DateTime<Utc>)

src/queue/service/order.rs:283

↓ 1 callersFunctionsign_request

Build the canonical query string and HMAC-SHA1 signature required by Alibaba Cloud's Dysmsapi (RPC-style, API version 2017-05-25). Reference: https:/

crates/sms/src/providers/alibabacloud.rs:39

↓ 1 callersFunctionsix_months_ago

(ts: i64)

src/repository/user/pg.rs:61

↓ 1 callersFunctionsix_months_ago

(ts: i64)

src/repository/user/mysql.rs:61

↓ 1 callersFunctionsort_by_dependencies

(plans: Vec<TablePlan>, fks: Vec<(String, String)>)

tools/mysql2postgres/src/main.rs:290

↓ 1 callersFunctionsprig_b64enc

`b64enc` — base64-encodes first argument as a UTF-8 string.

src/adapter/mod.rs:256

↓ 1 callersMethodstart

Create and start the scheduler. Registers all periodic tasks (mirrors `scheduler/scheduler.go:Start()`).

src/scheduler/mod.rs:29

↓ 1 callersMethodstart

(&self)

crates/email/src/worker.rs:91

↓ 1 callersFunctionsubscribe_handler

`GET /v1/subscribe/config/:token`

src/handler/subscribe.rs:16

↓ 1 callersFunctionsuccess

Builds a success envelope wrapping `data`. Mirrors Go `result.Success`.

crates/result/src/http_result.rs:55

↓ 1 callersMethodtelegram

(&self, req: &OAthLoginRequest)

src/service/auth/oauth/o_auth_login_service.rs:96

↓ 1 callersFunctionto_dto

(u: &UserEntity, methods: &[crate::model::entity::user::AuthMethods])

src/service/public/user/query_user_info_service.rs:50

↓ 1 callersFunctiontoday

()

src/service/telemetry.rs:24

↓ 1 callersMethodtop_users_traffic_by_day

( &self, date: i64, limit: i64, )

src/repository/traffic/pg.rs:183

↓ 1 callersFunctiontraffic_info

Traffic usage report.

src/service/telegram/template.rs:45

↓ 1 callersFunctiontruncate_tables

(pg: &PgPool, schema: &str, plans: &[TablePlan])

tools/mysql2postgres/src/main.rs:331

↓ 1 callersMethodunbind_device

( &self, _user_id: i64, req: UnbindDeviceRequest, )

src/service/public/user/unbind_device_service.rs:19

↓ 1 callersMethodunbind_o_auth

( &self, user_id: i64, req: UnbindOAuthRequest, )

src/service/public/user/unbind_o_auth_service.rs:19

↓ 1 callersMethodunbind_telegram

(&self, user_id: i64)

src/service/public/user/unbind_telegram_service.rs:19

↓ 1 callersMethodunsubscribe

( &self, _user_id: i64, req: UnsubscribeRequest, )

src/service/public/user/unsubscribe_service.rs:20

↓ 1 callersMethodupdate

(&self, data: &Coupon)

src/repository/coupon/pg.rs:54

↓ 1 callersMethodupdate

(&self, data: &Coupon)

src/repository/coupon/mysql.rs:59

↓ 1 callersMethodupdate_auth_method

(&self, data: &AuthMethods)

src/repository/user/pg.rs:304

↓ 1 callersMethodupdate_bind_email

( &self, user_id: i64, req: UpdateBindEmailRequest, )

src/service/public/user/update_bind_email_service.rs:20

↓ 1 callersMethodupdate_bind_mobile

( &self, user_id: i64, req: UpdateBindMobileRequest, )

src/service/public/user/update_bind_mobile_service.rs:20

↓ 1 callersMethodupdate_group

(&self, data: &Group)

src/repository/subscribe/pg.rs:117

↓ 1 callersMethodupdate_node_multiplier_config

(&self, config: &str)

src/repository/system/mod.rs:58

↓ 1 callersMethodupdate_node_sort

(&self, id: i64, sort: i64)

src/repository/node/pg.rs:408

↓ 1 callersMethodupdate_override

(&self, data: &ServerConfigOverride)

src/repository/node/pg.rs:161

↓ 1 callersMethodupdate_server_sort

(&self, id: i64, sort: i64)

src/repository/node/pg.rs:250

↓ 1 callersMethodupdate_sort

(&self, items: &[Subscribe])

src/repository/subscribe/pg.rs:168

↓ 1 callersMethodupdate_user_notify

( &self, user_id: i64, req: UpdateUserNotifyRequest, )

src/service/public/user/update_user_notify_service.rs:20

↓ 1 callersMethodupdate_user_password

( &self, user_id: i64, req: UpdateUserPasswordRequest, )

src/service/public/user/update_user_password_service.rs:20

↓ 1 callersMethodupdate_user_rules

( &self, user_id: i64, req: UpdateUserRulesRequest, )

src/service/public/user/update_user_rules_service.rs:20

↓ 1 callersMethodupdate_user_subscribe_note

( &self, _user_id: i64, req: UpdateUserSubscribeNoteRequest, )

src/service/public/user/update_user_subscribe_note_service.rs:20

↓ 1 callersMethodupdate_user_subscribe_with_traffic

( &self, id: i64, download: i64, upload: i64, )

src/repository/user/pg.rs:1010

↓ 1 callersFunctionurl_encode_password

(s: &str)

src/db.rs:112

↓ 1 callersFunctionuuid_v4_simple

()

crates/sms/src/providers/alibabacloud.rs:119

↓ 1 callersFunctionvalidate_auth_data

(data: &AuthData, bot_token: &[u8])

crates/oauth/src/telegram.rs:50

↓ 1 callersMethodvalidate_coupon

Coupon validation matching Go's pre-purchase block.

src/service/public/order/purchase_service.rs:293

↓ 1 callersMethodvalidate_coupon

( &self, coupon_info: &Coupon, user_id: i64, subscribe_id: i64, )

src/service/public/order/renewal_service.rs:212

↓ 1 callersMethodvalidate_coupon

Verify the coupon is enabled, has remaining quota, and applies to the chosen plan. Mirrors Go's `if err := ensureCouponEnabled(…); …` block in preCrea

src/service/public/order/pre_create_order_service.rs:159

↓ 1 callersFunctionvalidate_token

( token: &str, secret: &str, )

crates/jwt/src/lib.rs:48

↓ 1 callersMethodverify_email

( &self, user_id: i64, req: VerifyEmailRequest, )

src/service/public/user/verify_email_service.rs:21

↓ 1 callersFunctionverify_password

验证密码与编码后的密码哈希是否匹配。预期格式：`$pbkdf2-sha512$<salt>$<hash>`。 # 示例 ``` let encoded = password::encode_password("mypassword").unwrap(); assert!(password::v

crates/password/src/lib.rs:67

↓ 1 callersMethodverify_sign

(&self, params: &std::collections::HashMap<String, String>)

crates/payment/src/epay.rs:85

↓ 1 callersFunctionverify_with_key

Verify with idempotency key (prevents the same token being accepted twice).

crates/turnstile/src/lib.rs:35

↓ 1 callersFunctionwelcome

`/start` welcome message.

src/service/telegram/template.rs:26

FunctionMigrate

Migrate returns a configured golang-migrate instance that reads SQL files from the embedded sql/{postgres,mysql}/ directories, based on the requested

tools/migrate/migrate/migrate.go:40

FunctionRunUp

RunUp applies all pending migrations. Unlike m.Up(), it correctly handles the "database is already at the latest version" case under the iofs source d

tools/migrate/migrate/migrate.go:101

Function_now_ms

()

src/service/public/user/query_user_info_service.rs:98

Function_silence

(a: Auth)

src/service/admin/auth_method/get_auth_method_list_service.rs:95

Methodactivate_pending_subscribes_by_subscribe_id

( &self, subscribe_id: i64, )

src/repository/user/mysql.rs:991

Functionalipay_notify_handler

`POST /v1/notify/alipay/:token`

src/handler/notify/payment_notify_handler.rs:19

Functionapple_login_callback

( State(state): State<AppState>, Json(req): Json<AppleLoginCallbackRequest>, )

src/handler/auth/oauth/apple_login_callback_handler.rs:12

Functionapply_override

Apply per-server override on top of global values (in-place). Mirrors Go `ApplyOverride`.

src/service/nodeconfig/override.rs:116

Functionauth_middleware

( State(state): State<AppState>, mut request: Request, next: Next, )

src/middleware/auth_middleware.rs:21

Methodbalance

Record a balance change (recharge, withdraw, payment, refund, reward, adjust). `type_` should be one of the `BALANCE_TYPE_*` constants from `model::e

src/service/telemetry.rs:106

Methodbatch_delete

(&self, ids: &[i64])

src/repository/coupon/mysql.rs:156

Functionbatch_delete_coupon

( repo: &dyn CouponRepo, req: BatchDeleteCouponRequest, )

src/service/admin/coupon/batch_delete_coupon_service.rs:6

Functionbatch_delete_coupon

( State(state): State<AppState>, Json(req): Json<BatchDeleteCouponRequest>, )

src/handler/admin/coupon/batch_delete_coupon_handler.rs:9

Functionbatch_delete_document

( repo: &dyn DocumentRepo, req: BatchDeleteDocumentRequest, )

src/service/admin/document/batch_delete_document_service.rs:6

Functionbatch_delete_document

( State(state): State<AppState>, Json(req): Json<BatchDeleteDocumentRequest>, )

src/handler/admin/document/batch_delete_document_handler.rs:9

Methodbatch_delete_group

(&self, ids: &[i64])

src/repository/subscribe/mysql.rs:158

Functionbatch_delete_subscribe

( repo: &dyn SubscribeRepo, req: BatchDeleteSubscribeRequest, )

src/service/admin/subscribe/batch_delete_subscribe_service.rs:6

Functionbatch_delete_subscribe

( State(state): State<AppState>, Json(req): Json<BatchDeleteSubscribeRequest>, )

src/handler/admin/subscribe/batch_delete_subscribe_handler.rs:9

Functionbatch_delete_subscribe_group

( repo: &dyn SubscribeRepo, req: BatchDeleteSubscribeGroupRequest, )

src/service/admin/subscribe/batch_delete_subscribe_group_service.rs:6

Functionbatch_delete_subscribe_group

( State(state): State<AppState>, Json(req): Json<BatchDeleteSubscribeGroupRequest>, )

src/handler/admin/subscribe/batch_delete_subscribe_group_handler.rs:9

Functionbatch_delete_user

( repos: &Arc<Repositories>, req: BatchDeleteUserRequest, )

src/service/admin/user/batch_delete_user_service.rs:8

Functionbatch_delete_user

( State(state): State<AppState>, Json(req): Json<BatchDeleteUserRequest>, )

src/handler/admin/user/batch_delete_user_handler.rs:9

Methodbatch_delete_users

(&self, ids: &[i64])

src/repository/user/mysql.rs:745

Functionbelow_threshold_returns_one

()

src/service/public/order/get_discount.rs:67

Functionbind_o_auth

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Json(req): Json<BindOAut

src/handler/public/user/bind_o_auth_handler.rs:11

Functionbind_o_auth_callback

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Json(req): Json<BindOAut

src/handler/public/user/bind_o_auth_callback_handler.rs:11

Functionbind_telegram

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, )

src/handler/public/user/bind_telegram_handler.rs:9

Functionbuild_http_result_code_error

()

crates/result/src/http_result.rs:192

Functionbuild_http_result_generic_error

()

crates/result/src/http_result.rs:203

Functionbuild_http_result_success

()

crates/result/src/http_result.rs:181

Functionbuild_param_error_result_works

()

crates/result/src/http_result.rs:213

Functionbuild_protocol_config

(p: &Protocol)

src/service/server/get_server_config_service.rs:82

Methodbulk_insert

(&self, rows: &[TrafficLog])

src/repository/traffic/pg.rs:71

Methodbulk_insert

(&self, rows: &[TrafficLog])

src/repository/traffic/mysql.rs:75

Functioncalculate_remaining_amount

Helper for computing the deductible remainder of a subscription at unsubscribe time. Ported from the Go logic in `server/internal/logic/public/user/ca

src/service/public/user/calculate_remaining_amount.rs:5

Methodcheck

( &self, req: TelephoneCheckUserRequest, )

src/service/auth/check_user_telephone_service.rs:24

Methodcheck

( &self, req: CheckVerificationCodeRequest, )

src/service/common/check_verification_code_service.rs:27

Functioncheck_user

( State(state): State<AppState>, Json(req): Json<CheckUserRequest>, )

src/handler/auth/check_user_handler.rs:8

← previous next →401–500 of 1,586, ranked by callers