标签:redis elasticsearch nlu
防骚扰定时任务
线程 CheckAnnoyResultThread
扫描防骚扰文本进行防骚扰判断线程
常量
redis的键值
FSRNOTIFY_TRANS_REPORT
判断长度,程序入口
FSRNOTIFY_REPORT_OPENAPI
附上Json的数据格式
{
"fileId": "/home/sftp_pingan/fsrnotify/201710101810/20171010181019_1702_018638781928_60834560",
"content": "[{\"content\":\"好请问您是一张红旗张先生吗;time=20490 22960\",\"talkertype\":\"2\"}]",
"callTime": "2017-10-10 18:10:19",
"voiceId": "1659dc9c8909a430:0000050326:2909708",
"seatId": "2909708",
"callPhone": "18638781928",
"voicePath": "/home/sftp_pingan/fsrnotify/201710101810/20171010181019_1702_018638781928_60834560.pcm",
"platForm": "XQD-CCOD"
}
读取数据,调用NLU
读取常量FSRNOTIFY_TRANS_REPORT
数据,正如上面Json格式说明,获取到content内容,每一句都去调用NLU去获取,同时默认文本内容不超过2000,每一句都会追加一个cmd
字段,目前只有用户的话去调用,得到正常,骚扰,拒绝,敏感等cmd
标识。
调用NLU传递的参数以及返回结果
返回获取智能客服回答结果,回答类型,以及类别判断
QuestionProtocol protocol = new QuestionProtocol();
//拼装请求参数
protocol.appKey = SystemParameter.getREALTIME_TEST_APPKEY();
protocol.languageMark = SystemParameter.getLANGUAGEMARK();
protocol.platformConnType = SystemParameter.getPLATFORMCONNTYPE();
protocol.platformId = SystemParameter.getPLATFORMID();
//设置请求问题
protocol.query = question;
protocol.queryType = SystemParameter.getQUERYTYPE();
protocol.receiverId = robotHash;
//设置robot哈希值
protocol.robotHashCode = robotHash;
protocol.sendTime = System.currentTimeMillis()/1000;
protocol.talkerId = SystemParameter.getTALKERID();
protocol.userId = "LX-"+phone;
protocol.userLocationInfo = SystemParameter.getUSERLOCATIONINFO();
protocol.userNickName = SystemParameter.getUSERNICKNAME();
处理过程
- 从后往前处理content的cmd指令。优先级为敏感|拒绝|骚扰,获取到最前面的命中规则的一条content,记录这句话的索引
- 从这个索引开始,依次获取客服的话语,去掉语气词,分析出挽留得分,分数大于0.8,并且用户之后的话语长度大于50,即可确认挽留成功
- 保存到ES数据库中,同时查询到历史骚扰拼接字段保存在ANNOY_HISTORY_TYPE中。
- 还会涉及到将部分字段保存到redis的FSRNOTIFY_REPORT_OPENAPI键值中,Json格式内容
- 针对3,4条中提到的内容,见下图
历史ES数据的查询语句
历史数据查询地址: http://192.169.51.4:9200/pa_annoy*/annoy/
查询语句:
{
"query": {
"bool": {
"must": [
{
"terms": {
"CALL_PHONE": [
"15887660578"
]
}
},
{
"range": {
"CREATE_TIME": {
"gte": "2017-06-22 10:42:23",
"lte": "2017-09-22 10:42:23"
}
}
}
]
}
},
"aggs": {
"annoyType": {
"terms": {
"field": "ANNOY_TYPE"
}
}
},
"size": 0
}
查询返回结果:
{
"hits": {
"total": 1,
"hits": [
],
"max_score": 0.0
},
"_shards": {
"total": 30,
"failed": 0,
"successful": 30
},
"timed_out": false,
"took": 3,
"aggregations": {
"annoyType": {
"sum_other_doc_count": 0,
"buckets": [
{
"doc_count": 1,
"key": "正常"
}
],
"doc_count_error_upper_bound": 0
}
}
}
redis键值FSRNOTIFY_REPORT_OPENAPI
中保存的数据
{
"harassType": "骚扰",
"harassRemark": "哦不用了谢谢[00:36]",
"realCallId": "3e59dd81c9083aa9:0000050337:2906024",
"qaDate": "2017-10-11 10:28:27",
"agentId": "2906024",
"callId": "/home/sftp_pingan/fsrnotify/201710111025/20171011102827_1670_013110236686_80148988",
"platForm": "XQD-CCOD",
"url": "/pingan_sap/history/historyDetail?callId=3e59dd81c9083aa9:0000050337:2906024&agentId=2906024&callHappenTime=2017-10-11 10:28:27&backFlag=1"
}
隐藏逻辑
读取完防止多线程出现空值的情况,设置数据为空睡眠5毫秒
访问 防骚扰处理逻辑(二) 了解详情。
有问题欢迎咨询邮箱[1]