防控指挥调度记录
__ZLuP7RGirprZZ6SCdiX
__ZLuP7RGirprZZ6SCdiX
published
UTF-8
get
/fkzh/dispatchingRecord
json
" + com_video_room_sql);
//创建表单对象
var process = getDocumentProcess();
var formService = getFormProcess();
var subform = formService.doView("__FMc2pC4vY3ZdpMn2POX");
var com_video_room_data = queryByDSName(dbName, com_video_room_sql);
if (com_video_room_data.size() > 0 ) {
for (var iterator = com_video_room_data.iterator(); iterator.hasNext();) {
var userProcess1 = new Packages.cn.myapps.base.web.WebUser();
var webuser1 = userProcess1.getWebUserInstance("__A7yVvj33RRHsOLgvt0d");
println("webuser1 ===========>" + webuser1);
var map = iterator.next();
var yardmanTaskName = map.get("yardmanTaskName");
var yardmanName = map.get("yardmanName");
var startTime = map.get("startTime");
var comVideoRoomId = map.get("comVideoRoomId");
//根据公司对数据进行分类添加
var domainIdSQL = "SELECT domainId FROM per_video_room WHERE isSponsor != 1 and comVideoRoomId = '" + comVideoRoomId + "' GROUP BY domainId";
println("domainIdSQL根据公司对数据进行分类添加" + domainIdSQL)
var domainIdDatas = queryByDSName(dbName, domainIdSQL);
if (domainIdDatas != null) {
for (var domainIdDatasIterator = domainIdDatas.iterator(); domainIdDatasIterator.hasNext();) {
var doc = process.doNew(subform, webuser1, createParamsTable());
doc.addStringItem("originator", yardmanName);
doc.addStringItem("reason", yardmanTaskName);
doc.addStringItem("startTime", startTime);
doc.addStringItem("comVideoRoomId", comVideoRoomId);
var map2 = domainIdDatasIterator.next();//取值
var domainId = map2.get("domainId");
//获取公司名称
var domainidSQL = "SELECT name FROM obpm2.t_domain WHERE id = '" + domainId + "'";
println("获取公司名称sql =============>" + domainidSQL);
var domainidDatas = queryByDSName("baibaodunFlow", domainidSQL);
if (domainidDatas != null) {
for (var domainidDatas = domainidDatas.iterator(); domainidDatas.hasNext();) {
var map0000 = domainidDatas.next();//取值
var name1111 = map0000.get("name");
doc.addStringItem("targetCompany", name1111);
}
}
//统计人数
var countSQL = "SELECT count(*) as total FROM per_video_room WHERE comVideoRoomId = '" + comVideoRoomId + "' and domainId = '" + domainId + "'";
var countData = queryByDSName(dbName, countSQL);
if (countData != null) {
for (var countDataIterator = countData.iterator(); countDataIterator.hasNext();) {
var map3 = countDataIterator.next();//取值
var sum = map3.get("total");
doc.addStringItem("dispatchNumber", sum);
//获取
var sqlNotRes = "SELECT personId,attendExpoStatus FROM per_video_room WHERE comVideoRoomId = '" + comVideoRoomId + "' and domainId = '" + domainId + "'";
var sqlNotResData = queryByDSName(dbName, sqlNotRes);
var status0 = "";
var status1 = "";
var status9 = "";
if (sqlNotResData != null) {
var t1 = 0;
for (var sqlNotResDataIterator = sqlNotResData.iterator(); sqlNotResDataIterator.hasNext();) {
var map4 = sqlNotResDataIterator.next();
if (map4.get("attendExpoStatus") == 0) {
status0 += "'" + map4.get("personId") + "',";
}
if (map4.get("attendExpoStatus") == 1) {
status1 += "'" + map4.get("personId") + "',"
t1++
}
if (map4.get("attendExpoStatus") == 9) {
status9 += "'" + map4.get("personId") + "',"
}
}
if (t1 == sum) {
doc.addStringItem("status", "全部响应");
} else if (t1 == 0) {
doc.addStringItem("status", "未响应");
} else {
doc.addStringItem("status", "部分响应");
}
//随意拼接消除逗号
status0 += "'zzd'";
status1 += "'zzd'";
status9 += "'zzd'";
println("status0,status1,status9" + status0 + status1 + status9)
//获取接受的人
var acceptPeopleSql = "SELECT name FROM obpm2.t_user WHERE id in (" + status1 + ")";
var acceptPeopleSqlCount = "SELECT count(*) as total FROM obpm2.t_user WHERE id in (" + status1 + ")";
var acceptDatas = queryByDSName("baibaodunFlow", acceptPeopleSql);
var acceptPeopleSqlCountData = queryByDSName("baibaodunFlow", acceptPeopleSqlCount);
var tempAcceptDatas = "";
if (acceptDatas != null) {
for (var acceptDatasiterator = acceptDatas.iterator(); acceptDatasiterator.hasNext();) {
var acceptDatasMap = acceptDatasiterator.next();//取值
tempAcceptDatas += acceptDatasMap.get("name");
tempAcceptDatas += " "
}
}
doc.addStringItem("acceptPeopleCount", acceptPeopleSqlCountData.iterator().next().get("total"));
doc.addStringItem("acceptPeople", tempAcceptDatas);
//获取拒绝的人
var rejectPeopleSql = "SELECT name FROM obpm2.t_user WHERE id in (" + status0 + ")";
var rejectPeopleSqlCount = "SELECT count(*) as total FROM obpm2.t_user WHERE id in (" + status0 + ")";
var rejectDatas = queryByDSName("baibaodunFlow", rejectPeopleSql);
var rejectPeopleSqlCountData = queryByDSName("baibaodunFlow", rejectPeopleSqlCount);
var tempRejectDatas = "";
if (rejectDatas != null) {
for (var tempRejectDatasIterator = rejectDatas.iterator(); tempRejectDatasIterator.hasNext();) {
var tempRejectDatasIteratorDatasMap = tempRejectDatasIterator.next();//取值
tempRejectDatas += tempRejectDatasIteratorDatasMap.get("name");
tempRejectDatas += " "
}
}
doc.addStringItem("acceptPeople", tempRejectDatas);
doc.addStringItem("rejectPeopleCount", rejectPeopleSqlCountData.iterator().next().get("total"));
//获取未响应的人
var noResponsePeopleSql = "SELECT name FROM obpm2.t_user WHERE id in (" + status9 + ")";
var noResponsePeopleSqlCount = "SELECT count(*) as total FROM obpm2.t_user WHERE id in (" + status9 + ")";
println("noResponsePeopleSql" + noResponsePeopleSql)
println("noResponsePeopleSqlCount" + noResponsePeopleSqlCount)
var noResponseDatas = queryByDSName("baibaodunFlow", noResponsePeopleSql);
var noResponsePeopleSqlCountData = queryByDSName("baibaodunFlow", noResponsePeopleSqlCount);
var tempnoResponse = "";
if (noResponseDatas != null) {
for (var tempRejectDatasIterator = noResponseDatas.iterator(); tempRejectDatasIterator.hasNext();) {
var tempRejectDatasIteratorDatasMap = tempRejectDatasIterator.next();//取值
tempnoResponse += tempRejectDatasIteratorDatasMap.get("name");
tempnoResponse += " "
}
}
doc.addStringItem("noResponsePeople", tempnoResponse);
doc.addStringItem("noResponsePeopleCount", noResponsePeopleSqlCountData.iterator().next().get("total"));
process.doCreate(doc);
}
}
}
}
}
}
println("com_video_room_data ==============>" + com_video_room_data);
}
})()]]>