|
@@ -448,7 +448,7 @@ module.exports = app => {
|
|
|
add_time: addTime, update_time: addTime,
|
|
|
cache_tp: JSON.stringify(calcModel.cache_tp), cache_org_tp: JSON.stringify(calcModel.cache_org_tp),
|
|
|
};
|
|
|
- await conn.insert(this.tableName, data);
|
|
|
+ const addRela = await conn.insert(this.tableName, data);
|
|
|
if (calcModel.stageBills.length > 0) await conn.insert(this.ctx.service.stageRelaBills.tableName, calcModel.stageBills);
|
|
|
if (calcModel.stageBillsFinal.length > 0) await conn.insert(this.ctx.service.stageRelaBillsFinal.tableName, calcModel.stageBillsFinal);
|
|
|
if (calcModel.stagePos.length > 0) await conn.insert(this.ctx.service.stageRelaPos.tableName, calcModel.stagePos);
|
|
@@ -457,6 +457,7 @@ module.exports = app => {
|
|
|
if (calcModel.stageImBills.length > 0) await conn.insert(this.ctx.service.stageRelaImBills.tableName, calcModel.stageImBills);
|
|
|
await conn.update(this.ctx.service.stage.tableName, { id: this.ctx.stage.id, check_calc: 1 });
|
|
|
await conn.commit();
|
|
|
+ return addRela.insertId;
|
|
|
} catch (err) {
|
|
|
await conn.rollback();
|
|
|
throw err;
|