gsb

xggsve-trade/app/base/db/impl/trade/storderitemDao.js

@@ -50,6 +50,11 @@ class StOrderItemDao extends Dao {
     await this.customUpdate(sql, params, t);
     await this.customUpdate(sql, params, t);
   }
   }
 
 
+  async updateTradeByOrderId(orderId, tradeStatus, t) {
+    let sql = "UPDATE st_order_item SET trade_status = :tradeStatus WHERE order_id = :orderId";
+    await this.customUpdate(sql, {orderId: orderId, tradeStatus: tradeStatus}, t);
+  }
+
   async updateInvoice(params, t) {
   async updateInvoice(params, t) {
     let sql = "UPDATE st_order_item SET saas_invoice_id = :saas_invoice_id WHERE id IN (:ids) ";
     let sql = "UPDATE st_order_item SET saas_invoice_id = :saas_invoice_id WHERE id IN (:ids) ";
     await this.customUpdate(sql, params, t);
     await this.customUpdate(sql, params, t);

xggsve-trade/app/base/service/impl/trade/storderSve.js

@@ -143,10 +143,20 @@ class StOrderService extends ServiceBase {
       remark: params.remark,
       remark: params.remark,
       auditType: 2
       auditType: 2
     }
     }
-    return await this.doAudit(_params);
+    let rs = await this.doAudit(_params, async (order) => {
+      if (_params.status != "05") {
+        return;
+      }
+      order.trade_status = "00";
+      await order.save();
+      // 更新order_item状态
+      let rs = await this.storderitemDao.updateTradeByOrderId(order.id, order.trade_status);
+      console.log(rs);
+    });
+    return rs;
   }
   }
 
 
-  async doAudit(params) {
+  async doAudit(params, cb) {
     let id = this.trim(params.id);
     let id = this.trim(params.id);
     let pre = this.trim(params.pre);
     let pre = this.trim(params.pre);
     let status = params.status;
     let status = params.status;
@@ -171,7 +181,10 @@ class StOrderService extends ServiceBase {
     order[`check${auditType}_remark`] = remark;
     order[`check${auditType}_remark`] = remark;
     order.check_status = status;
     order.check_status = status;
     await order.save();
     await order.save();
-    return system.getResultSuccess();
+    if (cb) {
+      cb(order);
+    }
+    return system.getResultSuccess(order);
   }
   }
 
 
   // 打款
   // 打款