构建字典树 @param sensDict @return

构建企业微信下发消息的对象 @param taskInfo @param agentId 应用ID @return

普通发送执行流程 1. 前置参数校验 2. 组装参数 3. 后置参数校验 4. 发送消息至MQ @return

消费消息 @param lists

统计未删除的条数 @return

统计未删除的条数 @param deleted @return

读取csv文件，获取文件里的行数 @param path @param countFileRowHandler

创建执行器 @param xxlJobGroup @return BasicResultVO

群推前需要构建taskId @param pushParam @return http result

1. 数量超限 2. 时间超限 @return

去重 @param param

获取得到当前消息模板所有的去重Key @param taskInfo @return

删除定时任务 @param taskId @return BasicResultVO

钉钉素材上传 @param file @param sendAccount @param fileType @return

get 请求 @param url 请求url地址 @return string

处理阻塞队列的元素 真正方法 @param list

企业微信（应用消息）素材上传 @param file @param sendAccount @param fileType @return

企业微信（机器人）素材上传 @param file @param sendAccount @param fileType @return

执行指定的lua脚本返回执行结果 --KEYS[1]: 限流 key --ARGV[1]: 限流窗口 --ARGV[2]: 当前时间戳（作为score） --ARGV[3]: 阈值 --ARGV[4]: score 对应的唯一value @param redisScript @param keys

如果指定类型是手机号，检测输入手机号是否合法 如果指定类型是邮件，检测输入邮件是否合法 @param taskInfo

根据创建者检索相关的记录 @param creator @return

查询 列表 @param deleted 0：未删除 1：删除 @param channelType 渠道值 @param creator 创建者 @return

通过日期和手机号找到发送记录 @param phone @param sendDate @return

将List对象转换成Map(无嵌套) @param param @return

通过code获取企业微信机器人的Type值 @param code @return

生成任务唯一Id @return

对url添加平台参数（用于追踪数据)

通过taskInfo构建小程序订阅消息 @param @return AlipayMiniProgramParam

【这个方法不用看】，纯粹为了适配amis前端 <p> 得到模板的参数 组装好 返回给前端展示 @param alipayTemplateId @param templateList @return

通过code获取class @param code @return

【这个方法不用看】，纯粹为了适配amis前端 <p> 得到渠道账号信息，返回给前端做展示 @return

业务：消费pending队列实际的线程池 配置：核心线程可以被回收，当线程池无被引用且无核心线程数，应当被回收 动态线程池且被Spring管理：false @return

获取 contentModel，替换模板msgContent中占位符信息

读取csv文件，每读取一行都会调用 csvRowHandler 对应的方法 @param path @param csvRowHandler

从businessId切割出日期

获取钉钉 access_token @param account 钉钉工作消息 账号信息 @return 钉钉 access_token

通过code获取钉钉机器人的Type值 @param code @return

通过code获取钉钉工作通知的Type值 @param code @return

【这个方法不用看】，纯粹为了适配amis前端 获取 EchartsVo @param anchorResult @param businessId @return

通过code获取企业微信机器人的Type值 @param code @return

获取个推的 access_token @param account 创建个推账号时的元信息 @return 个推的 access_token

获取kafkaConsumer @param topicName @param groupId @return

如模板指定具体的明确账号，则优先发其账号，否则走到流量配置 <p> 流量配置每种类型都会有其下发渠道账号的配置(流量占比也会配置里面) <p> 样例： key：msgTypeSmsConfig value：[{"message_type_10":[{"weights":80,"scriptName"

从文件的每一行数据获取到params信息 [{key:value},{key:value}] @param fieldMap @return

获取占位符的参数 @param content @return

得到限流值的配置 <p> apollo配置样例 key：flowControl value：{"flow_control_40":1} <p> 渠道枚举可看：com.java3y.austin.common.enums.ChannelType @param channelCode

读取 远程链接 返回File对象 @param path 文件路径 @param remoteUrl cdn/oss文件访问链接 @return

如果有输入链接，则把链接拼在文案后 <p> PS: 这里可以考虑将链接 转 短链 PS: 如果是营销类的短信，需考虑拼接 回TD退订 之类的文案

【这个方法不用看】，纯粹为了适配amis前端 获取 SmsTimeLineVo @return

【这个方法不用看】，纯粹为了适配amis前端 <p> 获取占位符的参数 @param msgContent @return

获取全链路追踪 消息自身维度信息 @param messageId 消息 @return

获取全链路追踪 消息模板维度信息 @param businessId 业务ID（如果传入消息模板ID，则生成当天的业务ID） @return

获取短信下发记录 @param dataParam @return

获取全链路追踪 用户维度信息 @param receiver 接收者 @return

根据权重重新生成服务元数据列表，权重越高的元数据，会在最终的列表中出现的次数越多 例如，权重为1，最终出现1次，权重为2，最终出现2次，权重为3，最终出现3次，依此类推...

构建订阅消息参数 @param data 模板参数 @returnp

【这个方法不用看】，纯粹为了适配amis前端 <p> 得到模板的参数 组装好 返回给前端展示 @param wxTemplateId @param templateList @return

【这个方法不用看】，纯粹为了适配amis前端 <p> 1、得到微信服务号的【带参数】二维码返回给前端 2、让前端轮询请求 接口看是否已登录 @return

构建模板消息参数 @param data 模板参数 @return

【这个方法不用看】，纯粹为了适配amis前端 <p> 得到模板的参数 组装好 返回给前端展示 @param wxTemplateId @param allPrivateTemplate @return

业务：接收到xxl-job请求的线程池 配置：不丢弃消息，核心线程数不会随着keepAliveTime而减少(不会被回收) 动态线程池且被Spring管理：true @return

hGetAll @param key

处理具体的逻辑 @param messageTemplateId

消费阻塞队列元素时的方法 @param t

为每个渠道不同的消息类型 创建一个Receiver对象

初始化渠道与Handler的映射关系

初始化配置信息

初始化微信小程序 access_token 用redis存储 @return

初始化路由器 扫码、关注、取消关注

初始化状态信息 @param messageTemplate

具体执行逻辑 @param redisAsyncCommands @return

lLen 方法

lPop 方法

lpush 方法 并指定 过期时间

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

列表信息 @param creator @return

mGet将结果封装为Map @param keys

文件遍历结束时 1. 暂停单线程池消费(最后会回收线程池资源) 2. 更改消息模板的状态(暂未实现) @param row @param countCsvRow @param crowdBatchTaskPending @param messageTemplateId

将元素放入阻塞队列中 @param t

封装pipeline操作

pipeline 设置 key-value 并设置过期时间

执行前检查，出错则抛出异常 @param context 执行上下文 @throws ProcessException 异常信息

打印异常日志 @param ex

打印请求日志 @param methodSignature @param argObs

存入redis 实现去重 @param readyPutRedisReceiver

根据渠道标识查询账号信息 @param channelType 渠道标识 @param creator 创建者 @return

根据就配置文件的内容获取jobGroupId，没有则创建 @return

查询未删除的模板列表（分页) @param messageTemplateParam @return

实时数据存入Redis 1.用户维度(查看用户当天收到消息的链路详情)，数量级大，只保留当天 2.消息模板维度(查看消息模板整体下发情况)，数量级小，保留30天 @param info

消息撤回执行流程 1.组装参数 2.发送MQ @return