d

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

@@ -79,6 +79,10 @@ class ActionAPI extends APIBase {
             case "cancelItemInvoice":
                 opResult = await this.storderitemSve.cancelInvoice(action_body);
                 break;
+            case "cancelInvoiceByDataIds":
+                opResult = await this.storderitemSve.cancelInvoiceByDataIds(action_body);
+                break;
+
             case "invoiceTrade":
                 opResult = await this.storderitemSve.invoiceTrade(action_body);
                 break;

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

@@ -64,6 +64,10 @@ class StOrderItemDao extends Dao {
     let sql = "UPDATE st_order_item SET saas_invoice_id = '' WHERE saas_invoice_id = :saas_invoice_id ";
     await this.customUpdate(sql, params, t);
   }
+  async cancelInvoiceByDataIds(params, t) {
+    let sql = "UPDATE st_order_item SET saas_invoice_id = '' WHERE id in (:data_ids) ";
+    await this.customUpdate(sql, params, t);
+  }
 
   async countItems(params, t) {
     let sql = "SELECT count(1) AS num FROM st_order_item WHERE order_id = :order_id AND trade_status = :trade_status";

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

@@ -185,5 +185,23 @@ class StOrderItemService extends ServiceBase {
       return system.getResult(null, `系统错误`);
     }
   }
+
+  /***
+   * fn:根据ID取消发票关联
+   * @param params
+   * @returns {Promise<void>}
+   */
+  async cancelInvoiceByDataIds(params){
+    if(!params.data_ids ||  params.data_ids.length==0) {
+      return system.getResult(null, `参数错误 DATA_IDS 不能为空`);
+    }
+    try{
+      let res = await this.dao.cancelInvoiceByDataIds(params);
+      return res;
+    }catch (e) {
+      console.log(e);
+      return system.getResult(null, `系统错误`);
+    }
+  }
 }
 module.exports = StOrderItemService;
\ No newline at end of file