|
|
管理员大大，用webSockt向客户端发送消息时消息会被存到数据库中吗，如果有的话对应的表是哪张表？
如果我要用定时任务来做发待办消息的功能，消息体要怎么定义才能够让消息保存在数据库中，员工登录之后就可以查看到，我现在写的逻辑员工未登录时如果执行了定时任务，发了消息，员工登录之后是看不到的在消息提示栏里，应该怎么解决呢？感谢
附上代码，加粗的是发送websocket的方法，调用的是后台的服务，定时任务执行的时候后发送待办是正常的，但是只有当前人登录才能看到，我想要的效果是定时任务条件达到发送待办，员工不管是否在线都能收到，不在线的员工登录之后能够在消息提示栏中看到，这种该怎么实现呢？
/********************
this.entityManager; //实体管理器
this.applications; //访问系统内服务
this.organization; //组织访问
this.org; //组织快速访问方法
this.service; ///webSerivces客户端
*******************/
print("========转正待办推送服务扫描开始========");
// print(personList);
// 获取人员登记完成视图中的所有数据已提交数据
function getJobId(){
//serviceRoot 服务根
//path 路径
//string 数据字符串，json转字符串可以用 JSON.stringify( json )
var json = {filterList: []};
var resp = applications.putQuery( "x_query_assemble_surface", "/jaxrs/view/7b71c72a-2866-4a13-86c9-7d5eac89383a/bundle", JSON.stringify(json) );
// print( resp.toString() );
var result = JSON.parse( resp.toString() );
return result.data.valueList;
}
// 获取视图数据
function getViewData(){
var idList = getJobId();
var json = {filterList: [], bundleList : idList };
var resp = applications.putQuery( "x_query_assemble_surface", "/jaxrs/view/7b71c72a-2866-4a13-86c9-7d5eac89383a/execute", JSON.stringify(json) );
// print( resp.toString() );
var result = JSON.parse( resp.toString() );
return result.data.grid;
}
//获取数据字典数据
function getDictData(dictId,applicationId){
var data = {};
var serviceRoot = "x_processplatform_assemble_surface";
var path = "applicationdict/"+dictId+"/application/"+applicationId;
var resp = applications.getQuery( serviceRoot, path );
var json = JSON.parse( resp.toString() );
var result = {};
if(json.type == "success" && json.data){
result = json.data;
}
return result;
}
// 获取某个人所在的组织
function getCurrentUserInOrg(name) {
var data = {};
data["personList"] = [name];
var string = JSON.stringify(data);
var apps = this.applications;
var serviceRoot = "x_organization_assemble_express";
var path = "unit/list/person";
var resp = apps.postQuery( serviceRoot, path , string);
var json = JSON.parse( resp.toString() );
var result = {};
if(json.type == "success" && json.data) {
result = json.data;
}
return result;
}
// 发送消息
function sendMessage(type, person, title, body) {
var data = {};
data["type"] = type;
data["person"] = person;
data["title"] = title;
data["body"] = body;
var string = JSON.stringify(data);
var apps = this.applications;
var serviceRoot = "x_message_assemble_communicate";
var path = "ws";
var resp = apps.postQuery( serviceRoot, path , string);
var json = JSON.parse( resp.toString() );
var result = {};
if(json.type == "success" && json.data) {
result = json.data;
print("发消息结果 ： " + result);
}
return result;
}
for(var i = 0; i < getViewData().length; i++) {
// 获取开始时间
var start = getViewData().data.PROBATION_PERIOD_START;
// 获取结束时间
var end = getViewData().data.PROBATION_PERIOD_END;
// 获取待转正人姓名
var positivePersonName = getViewData().data.subject;
// // 获取拟稿人
// var person = getViewData().data.PERSON;
var startDate = new Date(Date.parse(start.replace(/-/g, "/")));
var endDate = new Date(Date.parse(end.replace(/-/g, "/")));
// 当前时间
var now = new Date();
var period = endDate - now;
period = period / 1000 / 60 / 60 / 24;
period = period.toFixed(0);
print(period);
// 获取拟稿人组织
var result = getCurrentUserInOrg(person);
var unitArr = result.unitList;
// 获取消息发送配置的岗位
// 查询数据字典
var dict = getDictData("2fed4681-94f2-4e3f-88f7-940d16a60f73", "5214c863-df98-4ff4-914b-a35f3126f923");
var positiveOrg = dict.data.positiveOrg;
// print(getViewData().data.IS_COMPLETED == true);
// 获取字典中配置的组织下的所有成员
if(getViewData().data.IS_COMPLETED == true && period == 89) { // 已提交的快到期的
print("-----出现匹配人员------");
for(var j = 0; j < positiveOrg.length; j++) {
print("获取人员组织: " + positiveOrg[j]);
var personList = this.org.listPersonWithUnit(positiveOrg[j]);
for(k = 0; k < personList.length; k++) {
var person = personList[k].distinguishedName;
print("需要发送消息人员：" + person);
sendMessage("task_press", person, positivePersonName + " 距离转正日期还有两周，请注意", {applicationName : "人员管理", processName : "外部人员转正"});
print("给 " + person + " 发送消息成功");
}
}
}
}
print("========转正待办推动服务扫描结束========"); |
|
[信息未更新]
