123

2_PRODUCT_FACTORY/hy_batch_factory.js

@@ -358,6 +358,7 @@ CMD.update_filter_data = async function(FilterConfig,data) {
 
                                 if(main_info.pay_type==0){
                                     table_data.book_platform = config.platform_heiyanmf
+                                    table_data.product_parent_id = data.product_parent_id
                                 }
                                 //没有找到 可以创建
                                 await video_applet_product_controllers.createAppletProductData(table_data)

MAIN_SERVE_FACTORY/MAIN_SERVE_FACTORY.js

@@ -60,7 +60,8 @@ async function processSyncMainTask(){
                 main_info.app_id,
                 0,
                 0,
-                material_platform_id
+                material_platform_id,
+                item.product_parent_id
             ]);
             // let table_name = "video_applet_product"
             // const insertSQL = `
@@ -71,7 +72,7 @@ async function processSyncMainTask(){
             // `;
             const insertSQL = `
             INSERT INTO video_applet_product
-            (product_name, product_id, book_platform, main_id, dy_small_applet_app_id, status, wait_status,material_platform_id)
+            (product_name, product_id, book_platform, main_id, dy_small_applet_app_id, status, wait_status,material_platform_id,product_parent_id)
             VALUES ?
             ON DUPLICATE KEY UPDATE 
                 product_name = VALUES(product_name),

etc/config.json

@@ -1,5 +1,5 @@
 {
-    "isDebug":false,
+    "isDebug":true,
     "redis_config": {
         "host": "127.0.0.1",
         "port": 6379

src/data_manager/Controllers/video_applet_product_controllers.js

@@ -165,7 +165,7 @@ class video_applet_product_controllers {
             }
 
             const status = params.status;
-            const filterData = await video_applet_product_model.findDataByLimit({ status: status,wait_status :params.wait_status,book_platform:params.book_platform},limit);
+            const filterData = await video_applet_product_model.findDataByLimit({ status: status,wait_status :params.wait_status,book_platform:params.book_platform},limit,"weight");
 
             if (!filterData) {
                 return {

src/data_manager/QueryBuilder.js

@@ -39,6 +39,9 @@ class QueryBuilder {
     }
 
     orderBy(field, direction = 'ASC') {
+        if(field==null){
+            return this;
+        }
         if(direction!=""){
             this.query += ` ORDER BY ${field} ${direction} `;
         }

src/data_manager/TaskDbBaseModel.js

@@ -49,13 +49,14 @@ class TaskDbBaseModel {
             return await db.query(sql, params);
     }
 
-    async findDataByLimit(conditions,limit=1) {
+    async findDataByLimit(conditions,limit=1,orderBy=null) {
         this.queryBuilder.clear()
         const { sql, params } = this.queryBuilder
             .select()
             .from(this.tableName)
             .where(conditions)
             .limit(limit)
+            .orderBy(orderBy,"DESC")
             .getQuery();
         const results = await db.query(sql, params);
         return results || null;