post 请求, 请求数据为 xml 的字符串 @param url 请求url地址 @param xml 请求数据, xml 字符串 @return string

重写equals方法 @param o @return

重写equals方法 @param o @return

重写equals方法 @param o @return

处理 夜间屏蔽(次日早上9点发送的任务)

每小时请求一次接口刷新（以防失效)

每小时请求一次接口刷新（以防失效)

只切AustinAspect注解

FastJson 消息转换器 格式化输出json @return

针对tag消息过滤 producer 将tag写进header里 @return true 消息将会被丢弃

查询 列表（分页) @param deleted 0：未删除 1：删除 @param pageable 分页对象 @return

根据渠道进行流量控制 @param taskInfo @param flowControlParam

根据渠道进行流量控制 @param taskInfo @param flowControlParam

一次性读取csv文件整个内容 1. 获取第一行信息(id,paramsKey1,params2Key2)，第一列默认为接收者Id 2. 把文件信息塞进对象内 3. 把对象返回 @param path @return @Deprecated 可能会导致内存爆炸

临时给微信服务号登录使用（生成二维码），正常消息推送平台不会有此接口 返回二维码图片url 和 sceneId @return

给每个Receiver对象的consumer方法 @KafkaListener赋值相应的groupId

扫码事件 (暂不实现逻辑) @param wxMessage @param context @param wxMpService @param sessionManager @return

拿到场景值和用户信息，写入到redis @param wxMessage @param context @param wxMpService @param sessionManager @return

重写hashCode方法 @return

重写hashCode方法 @return

重写hashCode方法 @return

重写hashCode方法 @return

初始化调度线程池

给每个渠道，每种消息类型初始化一个线程池

单线程消费 阻塞队列的数据

@param service 去重器对象 @param taskInfo @param param 去重参数 @return 返回不符合条件的手机号码

所有的渠道账号信息

初始化敏感词字典

参考{@link org.springframework.scheduling.concurrent.ExecutorConfigurationSupport#shutdown()} @param event the event to respond to

销毁调用

销毁调用

onDestroy

pipeline 设置 key-value 并设置过期时间 @param seconds 过期时间 @param delta 自增的步长

过滤逻辑 @param context @see com.java3y.austin.common.enums.ChannelType

执行责任链 @param context @return 返回上下文内容

pipeline流程控制器 后续扩展则加BusinessCode和ProcessTemplate @return

拉取回执 @param id 渠道账号的ID @return 渠道商回执接口返回值

拉取回执 未完成；当前未拉取钉钉应用消息的回执信息 @param accountId 需要拉取的账号

根据渠道标识查询渠道账号相关的信息