change runtimeCheckLog

This commit is contained in:
joseph le 2023-10-04 10:30:17 +07:00
parent d133fe98ce
commit b697175518
1 changed files with 97 additions and 103 deletions

View File

@ -134,7 +134,7 @@ export async function runtimeCheckLogs(folderPath) {
//get index SN and send to ERP //get index SN and send to ERP
// checkIndexSN(contentFile, lastLine, fileName); checkIndexSN(contentFile, lastLine, fileName);
//get list item to check //get list item to check
let listKeyValues = allValue.filter( let listKeyValues = allValue.filter(
@ -156,9 +156,9 @@ export async function runtimeCheckLogs(folderPath) {
console.log(contentFile.length) console.log(contentFile.length)
//Process file content //Process file content
if(contentFile.length>30000){ if(contentFile.length>50000){
for (let i = 0; i < contentFile.length; i += 50000) { for (let i = 0; i < contentFile.length; i += 1000) {
const chunk = contentFile.slice(i, i + 50000); const chunk = contentFile.slice(i, i + 1000);
chunk.map((line, index) => { chunk.map((line, index) => {
//check line the line with errors and exclude errors //check line the line with errors and exclude errors
@ -182,11 +182,11 @@ export async function runtimeCheckLogs(folderPath) {
); );
if (checkLog?.length === 0) { if (checkLog?.length === 0) {
// await LogReport.create({ await LogReport.create({
// detected_content: value, detected_content: value,
// line: index + 1, line: index + 1,
// id_file: log?.id_ldf, id_file: log?.id_ldf,
// }); });
lines.push(index + 1); lines.push(index + 1);
} }
} }
@ -218,11 +218,11 @@ export async function runtimeCheckLogs(folderPath) {
); );
if (checkLog?.length === 0) { if (checkLog?.length === 0) {
// await LogReport.create({ await LogReport.create({
// detected_content: value, detected_content: value,
// line: index + 1, line: index + 1,
// id_file: log?.id_ldf, id_file: log?.id_ldf,
// }); });
lines.push(index + 1); lines.push(index + 1);
} }
} }
@ -233,101 +233,95 @@ export async function runtimeCheckLogs(folderPath) {
} }
//true: import log to log_report table, send report to Zulip //true: import log to log_report table, send report to Zulip
// setTimeout(async () => { setTimeout(async () => {
// if (lines.length === 0) { if (lines.length === 0) {
// console.log(`${fileName} has changed ---Good`); console.log(`${fileName} has changed ---Good`);
// } else { } else {
// console.log( console.log(
// `${fileName} has changed ---SOS---${lines.length}` `${fileName} has changed ---SOS---${lines.length}`
// ); );
// let allReport_new = await LogReport.query() let allReport_new = await LogReport.query()
// .whereRaw(`DATE(created_at) = ?`, [today]) .whereRaw(`DATE(created_at) = ?`, [today])
// let fileDetect = allFile?.filter( let fileDetect = allFile?.filter(
// (i) => i.$original.file_name === fileName (i) => i.$original.file_name === fileName
// )[0]; )[0];
// let logsDetect = allReport_new?.filter( let logsDetect = allReport_new?.filter(
// (i) => i.$original.id_file === fileDetect?.id_ldf (i) => i.$original.id_file === fileDetect?.id_ldf
// ); );
// // console.log(logsDetect) // console.log(logsDetect)
// // await Database.rawQuery( // await Database.rawQuery(
// // "select * from log_reports where id_file = " + // "select * from log_reports where id_file = " +
// // fileDetect?.id_ldf // fileDetect?.id_ldf
// // ); // );
// //Get all report newest //Get all report newest
// let listReport = await getListLineByItem( let listReport = await getListLineByItem(
// logsDetect logsDetect
// .map((obj) => obj.$original) .map((obj) => obj.$original)
// .filter((l) => l.line > lastLine) .filter((l) => l.line > lastLine)
// ); );
// let content = let content =
// "| |Last updated at | Item/error | Line | Report \n|---|:---:|:---|:---|:-----------:\n"; "| |Last updated at | Item/error | Line | Report \n|---|:---:|:---|:---|:-----------:\n";
// let spoiler = ""; let spoiler = "";
// let issueFound = ""; let issueFound = "";
// listReport.map((log, index) => { listReport.map((log, index) => {
// let item = listExtraItem.includes(log.detected_content) let item = listExtraItem.includes(log.detected_content)
// ? ":medal: **" + log.detected_content + "**" ? ":medal: **" + log.detected_content + "**"
// : ":small_orange_diamond: " + log.detected_content; : ":small_orange_diamond: " + log.detected_content;
// log.line?.map((line) => { log.line?.map((line) => {
// issueFound = issueFound =
// issueFound + issueFound +
// "\n`" + "\n`" +
// line + line +
// "` " + "` " +
// contentFile[line - 1]?.replace( contentFile[line - 1]?.replace(
// log.detected_content, log.detected_content,
// "[" + "[" +
// log.detected_content + log.detected_content +
// "](https://logs.danielvu.com/logs/" + "](https://logs.danielvu.com/logs/" +
// fileName + fileName +
// "#" + "#" +
// line + line +
// ")" ")"
// ); );
// }); });
// content = content =
// content + content +
// "|" + "|" +
// (index + 1) + (index + 1) +
// "|**" + "|**" +
// moment(Date.now()).format("HH:mm - DD/MM") + moment(Date.now()).format("HH:mm - DD/MM") +
// "**|" + "**|" +
// item + item +
// "|" + "|" +
// log.line + log.line +
// "|[View](https://logs.danielvu.com/logs/" + "|[View](https://logs.danielvu.com/logs/" +
// fileName + fileName +
// "#" + "#" +
// log.line + log.line +
// ")\n"; ")\n";
// }); });
// sendMessToZulip( sendMessToZulip(
// "stream", "stream",
// Env.get("ZULIP_STREAM_ALERT"), Env.get("ZULIP_STREAM_ALERT"),
// Env.get("ZULIP_TOPIC_ALERT"), Env.get("ZULIP_TOPIC_ALERT"),
// "------------\n\n:warning: :warning: **" + "------------\n\n:warning: :warning: **" +
// fileName + fileName +
// "**\n\n" + "**\n\n" +
// content + content +
// "\n\n" + "\n\n" +
// spoiler + spoiler +
// "\n\n***Issue found:***\n" + "\n\n***Issue found:***\n" +
// issueFound issueFound
// ); );
// } }
// }, 3000); }, 3000)
// console.log(path + " change")
console.log(path + " change")
}); });
// await fileList.slice(0,40) // await fileList.slice(0,40)
// ?.filter((i) => fileList_old.includes(i) === false) // ?.filter((i) => fileList_old.includes(i) === false)