通知&预警

目前ADP支持站内信、邮件、微信公众号3种预警方式。

必须使用的能力为【模板消息通知】；选用能力为【流量自定义检查】、【流量控制】

上述能力必须在团队下的任务才能使用，且需要单独申请权限，申请权限时请联系客服，并告知团队名称。

若需实时监控，则需要提前租用月租机器，保证能力的实时运行。

• 【流量自定义检查】

需要与模板消息通知能力一起使用，用于监控数据流中流经该能力的数据情况，多应用在实时监控的预警流程中，报警分为3种：

1、总量超过XX阈值（例如阈值为100，则总量是101、102、103......时每次都会触发一次报警）

注：该能力常用于一次性任务，若超过阈值后只想发布一次报警信息，可在"流量自定义检查"后加"流量控制"，以防止报警信息过多对接收人造成骚扰。

2、XX时长内超过XX阈值（例如10分钟内阈值为100，则十分钟内数据量是101时即可触发一次报警）

注：能力每次有数据输入时均会计算一下当前数据之前的XX时长内是否超过阈值，若超过，则触发报警。若超过阈值后只想发布一次或每XX时长发出1次报警信息，可在"流量自定义检查"后加"流量控制"，以防止报警信息过多对接收人造成骚扰。

3、XX时长内低于XX阈值（例如10分钟内阈值为100，则十分钟内数据量不足100时即可触发一次报警）

注：该功能会从能力启动后开始计算时间，XX时长后检查一次，数据量少于阈值则报警，检查后不论是否报警计时都归零，再次到达xx时长时进行检查。

• 【流量控制】

该能力多与“模板消息通知”能力共用，可防止报警信息过多对接收人造成骚扰。主要用于对数据流进行流量控制，流经该能力的数据，XX时长内最多可流过XX条，超出部分则不流出。

• 【模板消息通知】

在“我的知识”-“消息模板”中可以查看默认模板和自定义的模板，设置好模板后，仅需要在【模板消息通知】能力中选择模板，即可进行消息发送。

模板名称：可自定义。

模板类别、描述：可为空，只是对模板的内容进行备注。

预警标题、预警内容、预警备注：可根据自己的需要进行自定义，字段参数用“”的形式。

关联链接：可为空，可以添加链接，例如：，字段名称可修改。有该字段则在微信预警时可跳转到对应url的页面。

接收者：“消息源项目全员”为该项目下的所有成员；“项目内指定用户”可指定消息接收人；“当前项目全员”目前的人员为“消息源项目全员”，后续随着开发会有人员的扩展，可暂时不用。

发送方式：“站内信”即adp平台的右上角小铃铛里的站内信息；“邮箱”即发送给用户在个人信息里登记的email邮箱；“企业微信”即微信公众号的发送，具体绑定方式见【模板消息通知】的能力说明。

（注：如果发送人没有绑定微信公众号则不能正常发送，发送日志可以在“我的知识”-“消息模板”-“发送日志”中查看）

微信接口模板：通知模板即内容在微信中显示蓝色；报警模板即显示红色。

• 具体使用方法详解：

【案例一】回溯任务完成后的通知

在能力“全网历史关键词过滤”或“全网历史判定图过滤”能力后加“模板消息通知”，使用“报警能力默认模板”,连接两个能力时用“完成信号”队列，则可在该回溯完成后微信通知到该项目下的所有人。

若只想通知到项目下的某个人，则可在“我的知识”-“消息模板”中新增模板-引用“报警能力默认模板”-修改接收人为指定成员，然后再“模板消息通知”能力中选择新增的这个模板即可。

【案例二】实时数据过少/过多预警

【案例三】一次性任务完成后的通知

"sql":"SELECT count(*) as '当日数据量' 
from `XX实时主题数据` 
where (SELECT count(*) from `XX实时主题数据` where TIMESTAMPDIFF(minute,`download_date`,now())<=20)!=0 and (SELECT count(*) from `XX实时主题数据` where TIMESTAMPDIFF(minute,`download_date`,now())<=1)=0"

【案例四】舆情负面数据的定时通报

读数据库用到的sql：

"sql":"select count(*) as `数据总量`,
(select count(*) from 实时主题数据 where download_date>=DATE_SUB(now(),INTERVAL 1 hour) and tag_result like '%/负面/%')  as `负面总量`,
(concat('https://adp.hylanda.com/innerApp/yujing/page-1?time_begin=',DATE_SUB(CURDATE(),INTERVAL 0 DAY),'-',hour(now())-1,'&time_end=',DATE_SUB(CURDATE(),INTERVAL 0 DAY),'-',hour(now()))) as url 
from 实时主题数据 
where download_date>=DATE_SUB(now(),INTERVAL 1 hour)"

接口用到的sql：

select '高'as warn,`fmt_title`,`release_date`,`media_name` ,`url`,count(`url_crc`) as `cnt`,replace(GROUP_CONCAT(CONCAT(media_name,':',url)),',',char(10)) as `all_url` from XX实时主题数据 where download_date>=CONCAT(substr('{{time_begin}}',1,10),' ',substr('{{time_begin}}',12,13),':00:00') and download_date<CONCAT(substr('{{time_end}}',1,10),' ',substr('{{time_end}}',12,13),':00:00') and tag_result like '%/负面/高/%'  GROUP BY title_crc
union all
select '中'as warn,`fmt_title`,`release_date`,`media_name` ,`url`,count(`url_crc`) as `cnt`,replace(GROUP_CONCAT(CONCAT(media_name,':',url)),',',char(10)) as `all_url` from XX实时主题数据 where download_date>=CONCAT(substr('{{time_begin}}',1,10),' ',substr('{{time_begin}}',12,13),':00:00') and download_date<CONCAT(substr('{{time_end}}',1,10),' ',substr('{{time_end}}',12,13),':00:00') and tag_result like '%/负面/中/%' and tag_result not like '%/负面/高/%'  GROUP BY title_crc
union all
select '低'as warn,`fmt_title`,`release_date`,`media_name` ,`url`,count(`url_crc`) as `cnt`,replace(GROUP_CONCAT(CONCAT(media_name,':',url)),',',char(10)) as `all_url` from XX实时主题数据 where download_date>=CONCAT(substr('{{time_begin}}',1,10),' ',substr('{{time_begin}}',12,13),':00:00') and download_date<CONCAT(substr('{{time_end}}',1,10),' ',substr('{{time_end}}',12,13),':00:00') and tag_result like '%/负面/低/%' and tag_result not like '%/负面/高/%' and tag_result not like '%/负面/中/%' GROUP BY title_crc

接口用到的json：

{% set highlight_words = ['北京','冬奥'] %}    //注释：需要页面上显示高亮时，在这里修改高亮词
{
    "status":0,
    "msg":null,
    "data":{ 
        "all_in_one":"
        {%- for line in rows -%}
            {%- if loop.index0 > 0 -%}\n\n{%- endif -%}
           预警等级：{{line['warn']|tojson|sub_string(1,-1)}}\n标题：{{line['fmt_title']|tojson|sub_string(1,-1)}}\n时间：{{line['release_date']}}\n来源：{{line['media_name']|tojson|sub_string(1,-1)}} 等\n数据条数：截止目前共 {{line['cnt']}} 条\n链接：\n{{line['all_url']|tojson|sub_string(1,-1)}} 
        {%- endfor -%}",
        "all_in_one_html":"
        {%- for line in rows -%}
            <p>
                预警等级：{{line['warn']|tojson|sub_string(1,-1)}}<br />
                标题：{{line['fmt_title']|highlight_keywords(highlight_words)|tojson|sub_string(1,-1)}}<br />
                时间：{{line['release_date']}}<br />
                来源：{{line['media_name']|tojson|sub_string(1,-1)}} 等<br />
                数据条数：截止目前共 {{line['cnt']}} 条<br />
                链接：{{line['url']|to_html_link|tojson|sub_string(1,-1)}} 等<br />
                全部链接：<br />{{line['all_url']|replace('\n','<br />')|tojson|sub_string(1,-1)}}
            </p>
        {%- endfor -%}"
    }
}

问题没有解决？请留言提问