gsb

xggsve-trade/app/base/api/impl/op/action.js

@@ -69,6 +69,9 @@ class ActionAPI extends APIBase {
             case "itemByIds":
                 opResult = await this.storderitemSve.byIds(action_body);
                 break;
+            case "itemByInvoiceId":
+                opResult = await this.storderitemSve.bySaasInvoiceId(action_body);
+                break;
             case "updateItemInvoice":
                 opResult = await this.storderitemSve.updateInvoice(action_body);
                 break;

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

@@ -31,6 +31,17 @@ class StOrderItemDao extends Dao {
     return await this.customQuery(sql.join(" "), params);
   }
 
+  async bySaasInvoiceId(params) {
+    let attrs = params.attrs || "*";
+    let sql = [];
+    sql.push("SELECT");
+    sql.push(attrs);
+    sql.push("FROM");
+    sql.push(this.model.tableName);
+    sql.push("WHERE saas_invoice_id = :saas_invoice_id ");
+    return await this.customQuery(sql.join(" "), params);
+  }
+
   async updateTrade(params, t) {
     let sql = "UPDATE st_order_item SET trade_time = :trade_time, trade_status = '00', trade_desc = :trade_desc WHERE id IN (:ids) AND trade_status = '01' ";
     await this.customUpdate(sql, params, t);

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

@@ -78,6 +78,11 @@ class StOrderItemService extends ServiceBase {
     let list = await this.dao.byIds(params);
     return system.getResultSuccess(list);
   }
+
+  async bySaasInvoiceId(params) {
+    let rs = await this.dao.bySaasInvoiceId(params);
+    return system.getResultSuccess(rs);
+  }
 }
 
 module.exports = StOrderItemService;