|
@@ -23,6 +23,8 @@ const ValidDskProject = {
|
|
|
zb: [4, 18, 19],
|
|
|
};
|
|
|
const DSK = require('../lib/dsk');
|
|
|
+const sendToWormhole = require('stream-wormhole');
|
|
|
+const streamToArray = require('stream-to-array');
|
|
|
|
|
|
module.exports = app => {
|
|
|
class BudgetController extends app.BaseController {
|
|
@@ -351,7 +353,7 @@ module.exports = app => {
|
|
|
const parts = await streamToArray(stream);
|
|
|
// 转化为buffer
|
|
|
const buffer = Buffer.concat(parts);
|
|
|
- const bills = relaService.importYbp(ctx.budget, buffer.toString(), needGcl);
|
|
|
+ const bills = await relaService.importYbp(ctx.budget, buffer.toString(), needGcl);
|
|
|
ctx.body = { err: 0, msg: '', data: bills };
|
|
|
} catch (err) {
|
|
|
await sendToWormhole(stream);
|