技术文章
1、O2Server服务器正常运行,系统安装部署请参考文档《如何在服务器上安装部署O2OA》
2、以拥有管理员权限的用户账号登录O2OA(翱途)开发平台,如:xadmin
3、O2OA Version:V7.2.0
O2OA开发平台从V7.2开始可以对消息和通道进行配置。
消息(message)是指服务器在运行中由不同事件产生不同的消息内容,不同的事件产生不同的消息,目前支持的事件类型有52种,以及自定义消息类型。
消息通道是指如何处理产生的消息。
下述内容以O2OA流程引擎创建流程待办为例,说明消息的处理机制:
o2oa/o2server服务器内的消息类型是内置编码实现完成的,7.2.0版本支持以下52种事件类型以及自定义消息类型:
application_create:创建应用
application_update:更新应用
application_delete:删除应用
process_create:创建流程
process_update:更新流程
process_delete:删除流程
activity_message:有新的工作通过消息节点
work_to_workCompleted:工作完成转已完成工作
work_create:创建工作
work_delete:删除工作
workCompleted_create:创建已完成工作
workCompleted_delete:删除已完成工作
task_to_taskCompleted:待办完成转已办
task_create:创建待办
task_delete:删除待办
task_urge:待办即将过期催办
task_expire:待办过期
task_press:待办提醒
taskCompleted_create:已办创建
taskCompleted_delete:删除已办
read_to_readCompleted:待阅转已阅
read_create:待阅创建
read_delete:待阅删除
readCompleted_create:已阅创建
readCompleted_delete:已阅删除
review_create:创建参阅
review_delete:删除参阅
meeting_invite:会议邀请
meeting_delete:会议删除
meeting_accept:会议邀请接受
meeting_reject:会议邀请拒绝
attachment_create:创建附件
attachment_delete:删除附件
attachment_share:附件分享
attachment_shareCancel:附件取消分享
attachment_editor:附件可编辑设置
attachment_editorCancel:附件可编辑取消
attachment_editorModify:附件可编辑修改
calendar_alarm:日历通知
custom_create:自定义消息创建
teamwork_taskCreate:工作管理任务创建
teamwork_taskUpdate:工作管理任务更新
teamwork_taskDelete:工作管理任务删除
teamwork_taskOvertime:工作管理任务超时
teamwork_chat:工作管理聊天
cms_publish:内容管理发布
cms_publish_to_creator:内容管理发布创建者通知
bbs_subjectCreate:论坛创建贴子
bbs_replyCreate:论坛创建回复
mind_fileSend:脑图文件发送
mind_fileShare:脑图文件分享
im_create:IM 聊天消息发送
custom_:自定义消息
O2OA支持将以custom_作为前缀的消息类型被识别为自定义消息。
O2OA服务器消息通道是用于处理接收到的消息内容,V7.2设计以下通道来处理消息内容:
ws:webSocket消息发送. pmsinner:推送消息. calendar:日历 dingding:钉钉 welink:华为welink zhengwudingding:政务钉钉 qiyeweixin:企业微信 mpweixin:微信公众号 kafka:kafka消息队列 activemq:activemq消息队列 restful:restful调用 mail:邮件发送 api:系统内部借口调用 jdbc:jdbc写入 table:自建表 hadoop:dfs写入
消息产生后将被送到通道进行消费处理.
默认情况下对部分消息(如:task_create:创建待办)等类型和通道进行了配置,默认情况下已经实现了待办的通知等功能.大部分消息都会通过默认配置自动处理.
默认配置会将创建待办消息通过webSocket,pmsinner,dingding,welink,zhengwudingding,qiyeweixin,mpweixin进行发送.
后续演示几种典型的消息使用场景
新建一个邮件通道
选择"邮件",进行smtp配置,图片给出腾讯企业邮配置样例,设置通道的名称为"consumer_mail"
3.添加通道,将刚刚创建的通道添加到task_create消息类型中
至此,当有待办创建时将调用consumer_mail通道通过邮件的smtp服务发送邮件通知给待办人.后面将进一步设置邮件过滤和邮件内容.
如果需要进行条件过滤,譬如不给"张三"用户发送邮件通知,那么可以通过过滤脚本来实现.
return message.person.indexOf("张三")>-1;
返回值 true 表示需要进行处理, false 不进行处理.
message 消息体根据不同的时间类型来自不同的消息,其内容和格式不同.具体格式内容可以通过print语句查看.
完成过滤后再来对消息体内容进行定制,通过创建加载器来实现.
/* *message 对象是消息体,有脚本执行上下文环境环境自动注入,其中有四个字段 message.title: 标题 message.person: 发送对象 message.type: 消息类型,task_create message.body: 消息体,类型是task_create的消息中消息体是json格式存储的task(待办)数据 return 返回的message对象 */ message.title = "您有一份标题为:"+message.body.title+"的待办需要处理。"; message.body = "<a href='http://testing.o2oa.net/x_desktop/work.html?workid="+ message.body.work + "'>您有新的待办需要处理,标题为:" + message.body.title + "</a>"; return message;
通过加载器定制邮件内容.
工作流转完成后尝试将部分数据写入到制定的数据库表中
先准备一个数据库并创建一个表,表中定义id,title,total字段.
创建一个jdbc(数据库表)通道
我们先创建一个jdbc的通道,指向testdb数据库的workdata表.
创建一个加载器来设定写入的内容
var id = message.body.work; var resp = this.applications.getQuery("x_processplatform_assemble_surface", "data/work/"+ id);//根据workid获取到业务数据data var data = JSON.parse(resp.toString()).data //修改body属性同步到数据库表中 message.body.id = message.body.id; message.body.title = data.$work.title; message.body.total = data.total; return message;
在类型(workCompleted_create)中选择添加通道consumer_jdbc
至此就完成了将数据同步到数据库的配置.
下面对6中非默认通道进行说明.
将消息推送到kafka队列中,配置参数说明:
bootstrapServers:服务器地址
topic:消息类别
securityProtocol:安全协议
saslMechanism:SASL认证机制
username:用户名
password:密钥
将消息推送到activemq队列,配置参数说明:
url: 消息队列地址
queueName: 队列名称
username: 用户名
password: 密码
调用restful服务,配置参数说明:
url: restful调用地址
method: 调用方法get,post,put,delete.
internal: 是否是系统内调用,如果是系统内调用将强制带上服务器标识以通过啊权限认证.
调用smtp服务器发送邮件,配置参数说明:
host: smtp服务器地址
port: smtp服务端口,默认465
sslEnable: smtp传输是否启用ssl加密
auth: 是否启用用户认证
from: 邮件发送人
password: smtp登录密码
调用数据库链接,将数据写入数据库表,配置参数说明:
driverClass: jdbc驱动类
url: jdbc地址
catalog: 编目
schema: 数据库
table: 数据库表
username: 用户名
password: 密码
将数据写入hadoop文件系统,配置参数说明
fsDefaultFS: hadoop服务地址.
path: 写入目录.
username: 指定系统账户.
下一篇:o2server配置外部存储