gsb

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

@@ -66,6 +66,9 @@ class ActionAPI extends APIBase {
             case "itemTradeOfflineCB":
                 opResult = await this.storderitemSve.tradeOfflineCB(action_body);
                 break;
+            case "itemByIds":
+                opResult = await this.storderitemSve.byIds(action_body);
+                break;
 
 
             default:

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

@@ -5,6 +5,24 @@ class StOrderItemDao extends Dao {
     super(Dao.getModelName(StOrderItemDao));
   }
 
+  async byIds(params) {
+    let attrs = params.attr || "*";
+    let ids = params.ids;
+    if (!ids || ids.length == 0) {
+      return [];
+    }
+
+    let sql = [];
+    sql.push("SELECT");
+    sql.push(attrs);
+    sql.push(this.model.tableName);
+    sql.push("WHERE id IN (:ids) ");
+    if (params.trade_statuses && params.trade_statuses.length > 0) {
+      sql.push("AND trade_status IN (:trade_statuses)");
+    }
+    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

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