Functions — github.com/canyuegongzi/simple-push-center

hub / github.com/canyuegongzi/simple-push-center / functions

Functions188 in github.com/canyuegongzi/simple-push-center

⨍ Functions 188◇ Types & classes 163

↓ 23 callersMethodget

(key: string)

src/config/CommonConfigService.ts:21

↓ 17 callersMethodgetUser

* 解析用户 * @param token

src/service/service/UtilService.ts:15

↓ 13 callersMethodset

(key: string, value: any, seconds?: number)

src/service/service/RedisCacheService.ts:15

↓ 7 callersMethodregister

(kafkaConfig: KafkaConfig)

src/common/kafka/KafkaModule.ts:8

↓ 3 callersMethodcreateTransport

* 构建传输器 * @param mailerTransport

src/service/service/TaskEmitEmailService.ts:16

↓ 3 callersMethodgetClient

()

src/service/service/RedisCacheService.ts:10

↓ 3 callersMethodgetNextTimeValue

* 计算下一次执行的时间 * @param timeType * @param timeValue day: HH:mm:00 hour: 01 * @param isDelay

src/service/service/TaskMainService.ts:255

↓ 2 callersMethodbuildTaskLog

* 构建一条任务记录 * @param params<CreateEmailTaskDto> * @param taskType<number> * @param config MessageConfigEntity | EmailConfigEntity

src/service/service/TaskMainService.ts:198

↓ 2 callersMethodcatch

(exception: RpcException)

src/common/error/filters/RpcExceptionFilter.ts:7

↓ 2 callersMethodconnect

()

src/common/kafka/KafkaService.ts:43

↓ 2 callersMethoddisconnect

()

src/common/kafka/KafkaService.ts:49

↓ 2 callersMethodget

* get请求数据

src/service/service/CommonHttpService.ts:12

↓ 2 callersMethodgetEmailConfigInfo

* 获取邮件配置 * @param taskConfig

src/service/service/TaskMainService.ts:163

↓ 2 callersMethodgetMessageConfigInfo

* 获取短信配置信息 * @param taskConfig

src/service/service/TaskMainService.ts:180

↓ 2 callersMethodgetTaskInfo

* 查询 * @param id

src/service/service/TaskMainService.ts:274

↓ 2 callersMethodinit

* 系统初始化

src/service/service/TaskMainService.ts:58

↓ 2 callersMethodsendMailer

* 发送邮件

src/service/service/AppKeyService.ts:36

↓ 2 callersMethodsendMessage

* 发送邮件

src/service/service/TaskEmitMessageService.ts:35

↓ 2 callersMethoduniqueName

* 唯一性 * @param params

src/service/service/TaskConfigService.ts:176

↓ 2 callersMethodupdateTask

* 更新任务 * @param id * @param task

src/service/service/TaskMainService.ts:283

↓ 1 callersFunctionSubscribeTo

(topic)

src/common/kafka/KafkaDecorator.ts:5

↓ 1 callersFunctionSubscribeToFixedGroup

(topic)

src/common/kafka/KafkaDecorator.ts:12

↓ 1 callersMethodaddAppKey

* 插入应用 * @param params

src/service/service/AppKeyService.ts:127

↓ 1 callersMethodaddEmailTask

* 创建邮件推送任务 * @param params

src/service/service/TaskMainService.ts:106

↓ 1 callersMethodaddMessageTask

* 开始一个短信任务 * @param params

src/service/service/TaskMainService.ts:137

↓ 1 callersMethodbindAllTopicToConsumer

(callback, _topic)

src/common/kafka/KafkaService.ts:55

↓ 1 callersMethodbindAllTopicToFixedConsumer

(callback, _topic)

src/common/kafka/KafkaService.ts:67

↓ 1 callersFunctionbootstrap

()

src/main.ts:11

↓ 1 callersMethoddelAppKey

* 删除应用 * @param params

src/service/service/AppKeyService.ts:179

↓ 1 callersMethodformatAppKey

* 解析app应用信息

src/service/service/UtilService.ts:32

↓ 1 callersMethodgetAppKeyByEmail

* 生成key

src/service/service/AppKeyService.ts:109

↓ 1 callersMethodgetAppKeyList

* 获取应用 * @param query * @param user

src/service/service/AppKeyService.ts:152

↓ 1 callersMethodgetErrorCode

()

src/common/error/exceptions/ApiException.ts:17

↓ 1 callersMethodgetErrorMessage

()

src/common/error/exceptions/ApiException.ts:21

↓ 1 callersMethodgetLogInfo

* 查询任务日志 * @param params

src/service/service/TaskLogService.ts:61

↓ 1 callersMethodgetLogList

* 查询全部的日志 * @param query

src/service/service/TaskLogService.ts:23

↓ 1 callersMethodgetPredictDealTime

* 计算一下次执行时间（0: 不延时 1 ：延时） * @param isDelay * @param params

src/service/service/TaskMainService.ts:235

↓ 1 callersFunctiongetStat

* 读取路径信息 * @param {string} path 路径

src/utils/file.ts:26

↓ 1 callersMethodinit

* 邮箱推送任务启动

src/service/service/TaskEmitEmailService.ts:46

↓ 1 callersMethodinit

()

src/service/service/TaskEmitMessageService.ts:51

↓ 1 callersMethodinitEnvConfig

* 初始化配置 * @param autoConfig<CommonConfigInterface> 默认环境变量 * @return config<CommonConfigInterface>

src/config/CommonConfigService.ts:30

↓ 1 callersMethodloadHelpMd

* 加载帮助

src/controller/HelpController.ts:28

↓ 1 callersMethodmakCode

* 产生一个code

src/service/service/AppKeyService.ts:65

↓ 1 callersMethodmakeTaskCode

* 任务编号

src/service/service/TaskMainService.ts:225

↓ 1 callersFunctionmkdir

* 创建路径 * @param {string} dir 路径

src/utils/file.ts:42

↓ 1 callersMethodnextLoopTak

* 下一步执行任务

src/service/processor/NoticeMessageProcessor.ts:80

↓ 1 callersMethodnextLoopTak

* 下一步执行任务 * @param task<TaskEntity> 任务实体 * @param isSuccessFlag<boolean> 任务是否成功 * @param status<number> 任务状态 * @protected

src/service/processor/NoticeEmailProcessor.ts:95

↓ 1 callersMethodregisterTopic

()

src/service/service/TaskKafkaConsumerService.ts:19

↓ 1 callersMethodsendPushTask

* kafka推送一个消息到push-center * @param kafkaTaskDto <KafkaTaskDto>

src/service/service/TaskKafkaProductService.ts:17

↓ 1 callersMethodtoValidate

(metatype)

src/common/error/pipe/ApiParamsValidationPipe.ts:36

↓ 1 callersMethoduse

(req: any, res: any, next: () => void)

src/common/shared/middleware/LoggerMiddleware.ts:5

FunctionRoles

(...roles: string[])

src/common/shared/decorators/RolesDecorator.ts:4

Methodab2str

* ArrayBuffer转String * @param buf

src/service/service/UtilService.ts:120

MethodaddApp

(@Body() params: CreateAppKeyDto)

src/controller/AppKeyController.ts:77

MethodaddConfig

(@Body() params: CreateMessageConfigDto, @Headers('token') token: string)

src/controller/TaskMessageConfigController.ts:22

MethodaddConfig

* 创建邮箱推送配置 * @param params<CreateEmailConfigDto>

src/service/service/TaskMessageConfigService.ts:23

MethodaddEmailConfig

(@Body() params: CreateEmailConfigDto, @Headers('token') token: string)

src/controller/TaskEmailConfigController.ts:22

MethodaddEmailConfig

(@Body() params: CreateEmailConfigDto, @Headers('token') token: string)

src/controller/TaskConfigController.ts:22

MethodaddEmailConfig

* 添加邮件配置 * @param params

src/service/service/TaskConfigService.ts:130

MethodaddEmailConfig

* 创建邮箱推送配置 * @param params<CreateEmailConfigDto>

src/service/service/TaskEmailConfigService.ts:23

MethodaddEmailTask

(@Body() params: CreateEmailTaskDto, @Headers('token') token: string)

src/controller/TaskMainController.ts:64

MethodaddMessageConfig

(@Body() params: CreateMessageConfigDto, @Headers('token') token: string)

src/controller/TaskConfigController.ts:94

MethodaddMessageConfig

* 添加短信配置 * @param params

src/service/service/TaskConfigService.ts:72

MethodaddMessageTask

(@Body() params: CreateEmailTaskDto, @Headers('token') token: string)

src/controller/TaskMainController.ts:84

FunctionaddTopic

(topicName)

src/common/kafka/KafkaAbstractConsumer.ts:17

MethodappKeyList

(@Headers('token') token: string, @Body() params: AppKeyGetDto)

src/controller/AppKeyController.ts:63

MethodauthApp

(@Body('key') key: string, @Body('expiresTime') expiresTime: string, @Body('name') name: string)

src/controller/TaskMainController.ts:30

MethodbindEvents

(client: any)

src/common/shared/strategies/NatsStrategy.ts:12

MethodcanSubmit

(@Body('key') key: string, @Body('expiresTime') expiresTime: string, @Body('submitType') submitType = 1, @Body

src/controller/TaskMainController.ts:49

MethodcanSubmit

* 鉴权能否继续提交任务到任务队列 * @param key * @param expiresTime * @param taskType 1: 邮件 2 短信 * @param token * @param submitType 1：自己配置

src/service/service/TaskMainService.ts:75

MethodcancleEmailTask

(@Body() params: CancleEmailTaskDto)

src/controller/TaskMainController.ts:154

MethodcancleEmailTask

* 任务取消 * @param params

src/service/service/TaskMainService.ts:386

Methodcatch

(exception: WsException, client)

src/common/error/filters/WsExceptionFilter.ts:6

Methodcatch

(exception, host: ArgumentsHost)

src/common/error/filters/HttpExceptionFilter.ts:7

Functionconstructor

()

src/common/kafka/KafkaAbstractConsumer.ts:7

Methodconstructor

( @Inject(TaskLogService) private readonly taskLogService: TaskLogService, @Inject(TaskMainSer

src/controller/TaskMainController.ts:18

Methodconstructor

(private readonly taskKafkaProductService: TaskKafkaProductService)

src/controller/KafkaTaskController.ts:9

Methodconstructor

( @Inject(TaskEmailConfigService) private readonly taskConfigService: TaskEmailConfigService,

src/controller/TaskEmailConfigController.ts:11

Methodconstructor

(@Inject(AppKeyService) private readonly appKeyService: AppKeyService, @Inject(UtilService) private readonly u

src/controller/AppKeyController.ts:13

Methodconstructor

( @Inject(HelpService) private readonly helpService: HelpService, )

src/controller/HelpController.ts:8

Methodconstructor

( @Inject(TaskMessageConfigService) private readonly taskConfigService: TaskMessageConfigService,

src/controller/TaskMessageConfigController.ts:11

Methodconstructor

( @Inject(TaskCommonConfigService) private readonly taskConfigService: TaskCommonConfigService,

src/controller/TaskCommonConfigController.ts:10

Methodconstructor

( @Inject(TaskConfigService) private readonly taskConfigService: TaskConfigService, @Inject(Ut

src/controller/TaskConfigController.ts:13

Methodconstructor

()

src/service/service/UtilService.ts:9

Methodconstructor

(@Inject(HttpService) private readonly httpService: HttpService)

src/service/service/CommonHttpService.ts:7

Methodconstructor

(private readonly nestEventEmitter: NestEventEmitter)

src/service/service/TaskKafkaConsumerService.ts:14

Methodconstructor

( @Inject(RedisCacheService) private readonly redisCacheService: RedisCacheService, @InjectRep

src/service/service/TaskConfigService.ts:18

Methodconstructor

(private readonly kafkaService: KafkaService)

src/service/service/TaskKafkaProductService.ts:11

Methodconstructor

()

src/service/service/TaskEmitEmailService.ts:8

Methodconstructor

( @InjectRepository(AppKeyEntity) private readonly appKeyEntityRepository: Repository<AppKeyEntity>,

src/service/service/AppKeyService.ts:26

Methodconstructor

( @InjectQueue('email') private readonly emailNoticeQueue: Queue, @InjectQueue('message') priv

src/service/service/TaskMainService.ts:35

Methodconstructor

( @Inject(RedisCacheService) private readonly redisCacheService: RedisCacheService, @InjectRep

src/service/service/TaskCommonConfigService.ts:15

Methodconstructor

(@Inject(RedisService) private redisService: RedisService)

src/service/service/RedisCacheService.ts:6

Methodconstructor

( @Inject(RedisCacheService) private readonly redisCacheService: RedisCacheService, @InjectRep

src/service/service/TaskEmailConfigService.ts:14

Methodconstructor

( @Inject(RedisCacheService) private readonly redisCacheService: RedisCacheService, @InjectRep

src/service/service/TaskMessageConfigService.ts:14

Methodconstructor

()

src/service/service/HelpService.ts:5

Methodconstructor

()

src/service/service/TaskEmitMessageService.ts:10

Methodconstructor

( @InjectRepository(TaskLogEntity) private readonly taskLogEntityRepository: MongoRepository<TaskLogEn

src/service/service/TaskLogService.ts:15

Methodconstructor

( @InjectQueue('message') private readonly messageNoticeQueue: Queue, private readonly taskLog

src/service/processor/NoticeMessageProcessor.ts:20

Methodconstructor

( @InjectQueue('email') private readonly emailNoticeQueue: Queue, private readonly taskEmitEma

src/service/processor/NoticeEmailProcessor.ts:19

next →1–100 of 188, ranked by callers