|
@@ -31,6 +31,7 @@ async function processTask(){
|
|
await connection.execute(
|
|
await connection.execute(
|
|
`UPDATE video_product SET publish_time = "${publish_time}" WHERE id = ${video_product_info.id} `
|
|
`UPDATE video_product SET publish_time = "${publish_time}" WHERE id = ${video_product_info.id} `
|
|
);
|
|
);
|
|
|
|
+ await new Promise(resolve => setTimeout(resolve,1000));
|
|
}else{
|
|
}else{
|
|
// await connection.execute(
|
|
// await connection.execute(
|
|
// ` delete from video_product where id = ${video_product_info.id}; `
|
|
// ` delete from video_product where id = ${video_product_info.id}; `
|