/api/backupProduct

This commit is contained in:
joseph le 2023-09-28 16:37:31 +07:00
parent 8d43f2ce06
commit 088c252872
1 changed files with 3 additions and 4 deletions

View File

@ -375,12 +375,10 @@ Route.post("/api/gitea-webhook", ({ request, response }) => {
Route.post("/api/backupProduct", async ({ request, response }) => { Route.post("/api/backupProduct", async ({ request, response }) => {
try { try {
const date = moment(Date.now()).format("YYYYMMDD"); const date = moment(Date.now()).format("YYYYMMDD");
const token =
"eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpZF91c2VyIjoxLCJ1c2VybmFtZSI6ImVycHVzZXIiLCJjcmVhdGVkQXQiOiIyMDIzLTA4LTIzVDE1OjI4OjAxLjAwMCsxMDowMCIsInVwZGF0ZWRBdCI6IjIwMjMtMDgtMjNUMTU6Mjg6MDEuMDAwKzEwOjAwIiwiaWF0IjoxNjk1MjY0NTQwLCJleHAiOjE3MjY4MDA1NDB9.vBlZAc7TGKbOrsP7UjQzVY2hIoJCGXQDe3KUxYyv294";
const res = await axios.post( const res = await axios.post(
"https://logs.danielvu.com/api/getIndexSerialNumber", "https://logs.danielvu.com/api/getIndexSerialNumber",
{ from: date, to: date }, { from: date, to: date },
{ headers: { Authorization: token } } { headers: { Authorization: request.headers().authorization?.replace(/"/g, "") } }
); );
res.data.map((obj, index)=>{ res.data.map((obj, index)=>{
@ -393,11 +391,12 @@ Route.post("/api/backupProduct", async ({ request, response }) => {
warehouse:res.data[index].warehouse warehouse:res.data[index].warehouse
} }
}) })
const addProduct = await Product.createMany(res.data) const addProduct = await Product.createMany(res.data)
// console.log(addProduct) // console.log(addProduct)
response.status(200).send("Add "+res.data.length+" success!"); response.status(200).send("Add "+res.data.length+" success!");
await sendMessToZulip("stream", "networkToolBot", "Log service", "Backup product "+date+" success with "+res.data.length+"products")
} catch (error) { } catch (error) {
response.status(500).send(error); response.status(500).send(error);
await sendMessToZulip("stream", "networkToolBot", "Log service", "Backup product fail. Please check!")
} }
}); });