MiFaZhan
35 lines
2.1 KiB
Go
35 lines
2.1 KiB
Go
package consts
|
|
|
|
const (
|
|
QueueTrafficUsageDailyRetry = "iotlcm.traffic_usage.daily.retry"
|
|
QueueTrafficUsageMonthlyRetry = "iotlcm.traffic_usage.monthly.retry"
|
|
QueueTrafficUsageMonthlyStart = "iotlcm.traffic_usage.monthly.start"
|
|
// QueueTrafficUsageDailyStart carries one command per full daily usage run.
|
|
// Admin publishes it; Worker owns the card scan and Redis production.
|
|
QueueTrafficUsageDailyStart = "iotlcm.traffic_usage.daily.start"
|
|
// QueueTrafficUsageMonthlyHistoryStart carries one command per full monthly
|
|
// usage history run, which writes the TDengine monthly table. It is distinct
|
|
// from QueueTrafficUsageMonthlyStart, which fills the MySQL current-month
|
|
// snapshot.
|
|
QueueTrafficUsageMonthlyHistoryStart = "iotlcm.traffic_usage.monthly_history.start"
|
|
QueueSimStatusQueueStart = "iotlcm.sim_status.queue.start"
|
|
QueueSimStatusQueueTask = "iotlcm.sim_status.queue.task"
|
|
QueueImeiQueueStart = "iotlcm.imei.queue.start"
|
|
QueueWorkOrderAutoClose = "iotlcm.work_order.auto_close"
|
|
QueueBalanceRechargeTimeout = "iotlcm.balance.recharge.timeout"
|
|
QueueBalanceRechargeDelay = "iotlcm.balance.recharge.delay"
|
|
QueueWorkerDiagnostic = "iotlcm.worker.diagnostic"
|
|
QueueBatchExecute = "iotlcm.batch.execute"
|
|
QueueBatchExecuteRetry = "iotlcm.batch.execute.retry"
|
|
QueueBatchExecuteDeadLetter = "iotlcm.batch.execute.dlq"
|
|
QueueBatchRestartResumeDelay = "iotlcm.batch.restart.resume.delay"
|
|
QueuePackageCustomerSync = "iotlcm.package_customer.sync"
|
|
QueueChannelRefresh = "iotlcm.channel.refresh"
|
|
// QueueDataReviewQuery 承载"手动同步上游结果"命令：Admin 发布父批号，
|
|
// Worker 只对既有 operationId 做只读补查并回写，绝不重发办理。
|
|
QueueDataReviewQuery = "iotlcm.data.review.query"
|
|
// QueueBalanceRechargeDeadLetter 保存重试次数耗尽后仍失败的充值超时消息，
|
|
// 供人工排查（例如支付宝凭据未配置导致的永久失败），不再自动重投。
|
|
QueueBalanceRechargeDeadLetter = "iotlcm.balance.recharge.dlq"
|
|
)
|