gsb

xggsve-invoice/app/base/service/impl/invoice/iinvoiceSve.js

@@ -128,20 +128,24 @@ class IInvoiceService extends ServiceBase {
     _invoice.mail_addr = this.trim(params.mail_addr) || "";
     _invoice.mail_addr = this.trim(params.mail_addr) || "";
 
 
     try {
     try {
+
+      let processList = await this.buildProcess(_invoice.product_id) || [];
+      if (!processList || processList.length == 0) {
+        return system.getResult(null, "产品流程未配置");
+      }
+      _invoice.status = processList[0].status;
+
       await this.db.transaction(async t => {
       await this.db.transaction(async t => {
         _invoice = await this.dao.create(_invoice,t);
         _invoice = await this.dao.create(_invoice,t);
         await this.iinvoiceinforegDao.create({id:_invoice.id},t); 
         await this.iinvoiceinforegDao.create({id:_invoice.id},t); 
         await this.iinvoicesummaryinfoDao.create({id:_invoice.id},t); 
         await this.iinvoicesummaryinfoDao.create({id:_invoice.id},t); 
-      });
-      let processList = await this.buildProcess(_invoice.product_id) || [];
-      for(let process of processList) {
-        process.invoice_id = _invoice.id;
-      }
-      let invoiceProperty = {};
-      invoiceProperty.status = processList[0].status;
-      invoiceProperty.id = _invoice.id;
 
 
-      await this.dao.update(invoiceProperty,t);
+        for(let process of processList) {
+          process.invoice_id = _invoice.id;
+        }
+        await this.iinvoiceprocessDao.model.bulkCreate(processList, { transaction: t });
+      });
+      
       
       
       return system.getResult(`success`);
       return system.getResult(`success`);
     } catch (error) {
     } catch (error) {