dailylogschedulefunctions
__K9C0HmAjnqJZgTI2sjd
__K9C0HmAjnqJZgTI2sjd
='" + dailylogdate + "'";
var insertSql = "";
var deleteSql = "";
try {
var query = queryByDSName(dsName, planSql);
if (query != null) {
var iter = query.iterator();
try {
//beginTransaction(dsName);
var totalCount = 0;
while (iter != null && iter.hasNext()) {
doc = iter.next();
var extensionData = {};
extensionData["NAME"] = getSqlValue(doc, "ITEM_NAME"); //doc.get("ITEM_NAME");
extensionData["CUSTOMERID"] = getSqlValue(doc, "ITEM_CUSTOMERID"); //doc.get("ITEM_CUSTOMERID");
extensionData["CUSTOMERNAME"] = getSqlValue(doc, "ITEM_CUSTOMERNAME"); // doc.get("ITEM_CUSTOMERNAME");
extensionData["PLANEDTIME"] = getSqlValue(doc, "ITEM_PLANEDTIME"); //doc.get("ITEM_PLANEDTIME");
extensionData["PLANCONTENT"] = getSqlValue(doc, "ITEM_PLANCONTENT"); // doc.get("ITEM_PLANCONTENT");
extensionData["CONTACTID"] = getSqlValue(doc, "ITEM_CONTACTID"); // doc.get("ITEM_CONTACTID");
var sql = "insert into test_logs(NAME)VALUES('18-02-01:2-WHILE-begin to execute task-02')";
insertByDSName(dsName, sql);
var planId = getValue(doc, "ID"); // doc.get("ITEM_CONTACTID");
var logId = format(getToday(), "yyyyMMdd") + "#" + planId;
insertSql = getTlkInsertSql("tlk_dailylog", "ITEM_BUSINESSID,ITEM_TYPE, ITEM_DATA", doc, {
"ID": logId
});
insertSql += ",'" + planId + "'" + ",'plan'" + ",'" + encodeSql(JSON.stringify(extensionData)) + "')";
try {
//deleteSql = "delete from tlk_dailylog where ID='"+logId+"'";
//deleteByDSName(dsName,"delete from tlk_dailylog where ID='"+logId+"'");
var sql = "insert into test_logs(NAME)VALUES('开始插入生成的每日日报:" + logId + "')";
insertByDSName(dsName, sql);
insertByDSName(dsName, insertSql);
totalCount++;
var sql = "完成[" + totalCount + "]跟进计划的导入:" + getValue(doc, "ID") + "')";
insertByDSName(dsName, sql);
} catch(e2) {
var sql = "insert into test_logs(NAME)VALUES('生成日报失败:" + logId + " 详细错误=" + e2 + "')";
insertByDSName(dsName, sql);
}
}
//commitTransaction(dsName);
} catch(e) {
var sql = "insert into test_logs(NAME)VALUES('每日日报生成发生异常:" + e + "')";
insertByDSName(dsName, sql);
throw new TypeError("test error:" + e + " insertSql=" + insertSql + " deleteSql=" + deleteSql);
//rollbackTransaction(dsName);
}
} else {
sql = "insert into test_logs(NAME)VALUES('无可生成日报内容:" + dailylogdate + "')";
insertByDSName(dsName, sql);
}
//commitTransaction(dsName);
} catch(ex) {
throw new TypeError("跟进计划日报生成出错:" + ex + ", sql=" + planSql + " insertSql=" + insertSql + " deleteSql=" + deleteSql);
}
}
}]]>
0