|
|
@@ -13,6 +13,7 @@ const smsTypeConst = require('../const/sms_type');
|
|
|
const SMS = require('../lib/sms');
|
|
|
const SmsAliConst = require('../const/sms_alitemplate');
|
|
|
const wxConst = require('../const/wechat_template');
|
|
|
+const shenpiConst = require('../const/shenpi');
|
|
|
const pushType = require('../const/audit').pushType;
|
|
|
|
|
|
module.exports = app => {
|
|
|
@@ -148,17 +149,28 @@ module.exports = app => {
|
|
|
* @param {Number} times - 第几次审批
|
|
|
* @return {Promise<number>}
|
|
|
*/
|
|
|
- async addAuditor(tenderId, auditorId, times = 1) {
|
|
|
- const newOrder = await this.getNewOrder(tenderId, times);
|
|
|
- const data = {
|
|
|
- tender_id: tenderId,
|
|
|
- audit_id: auditorId,
|
|
|
- times,
|
|
|
- audit_order: newOrder,
|
|
|
- status: auditConst.status.uncheck,
|
|
|
- };
|
|
|
- const result = await this.db.insert(this.tableName, data);
|
|
|
- return (result.effectRows = 1);
|
|
|
+ async addAuditor(tenderId, auditorId, times = 1, is_gdzs = 0) {
|
|
|
+ const transaction = await this.db.beginTransaction();
|
|
|
+ try {
|
|
|
+ let newOrder = await this.getNewOrder(tenderId, times);
|
|
|
+ // 判断是否存在固定终审，存在则newOrder - 1并使终审order+1
|
|
|
+ newOrder = is_gdzs === 1 ? newOrder - 1 : newOrder;
|
|
|
+ if (is_gdzs) await this._syncOrderByDelete(transaction, tenderId, newOrder, times, '+');
|
|
|
+ const data = {
|
|
|
+ tender_id: tenderId,
|
|
|
+ audit_id: auditorId,
|
|
|
+ times,
|
|
|
+ audit_order: newOrder,
|
|
|
+ status: auditConst.status.uncheck,
|
|
|
+ };
|
|
|
+ const result = await transaction.insert(this.tableName, data);
|
|
|
+ await transaction.commit();
|
|
|
+ return (result.effectRows = 1);
|
|
|
+ } catch (err) {
|
|
|
+ await transaction.rollback();
|
|
|
+ throw err;
|
|
|
+ }
|
|
|
+ return false;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -170,7 +182,7 @@ module.exports = app => {
|
|
|
* @return {Promise<*>}
|
|
|
* @private
|
|
|
*/
|
|
|
- async _syncOrderByDelete(transaction, tenderId, order, times) {
|
|
|
+ async _syncOrderByDelete(transaction, tenderId, order, times, selfOperate = '-') {
|
|
|
this.initSqlBuilder();
|
|
|
this.sqlBuilder.setAndWhere('tender_id', {
|
|
|
value: tenderId,
|
|
|
@@ -186,7 +198,7 @@ module.exports = app => {
|
|
|
});
|
|
|
this.sqlBuilder.setUpdateData('audit_order', {
|
|
|
value: 1,
|
|
|
- selfOperate: '-',
|
|
|
+ selfOperate: selfOperate,
|
|
|
});
|
|
|
const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
|
|
|
const data = await transaction.query(sql, sqlParam);
|
|
|
@@ -230,7 +242,11 @@ module.exports = app => {
|
|
|
async start(tenderId, times = 1) {
|
|
|
const audit = await this.getDataByCondition({ tender_id: tenderId, times, audit_order: 1 });
|
|
|
if (!audit) {
|
|
|
- throw '审核人信息错误';
|
|
|
+ if(this.ctx.tender.info.shenpi.ledger === shenpiConst.sp_status.gdspl) {
|
|
|
+ throw '请联系管理员添加审批人';
|
|
|
+ } else {
|
|
|
+ throw '请先选择审批人，再上报数据';
|
|
|
+ }
|
|
|
}
|
|
|
const sum = await this.ctx.service.ledger.addUp({ tender_id: tenderId /* , is_leaf: true*/ });
|
|
|
|
|
|
@@ -511,6 +527,55 @@ module.exports = app => {
|
|
|
result.unshift(user);
|
|
|
return result;
|
|
|
}
|
|
|
+
|
|
|
+ async updateNewAuditList(tender, newIdList) {
|
|
|
+ const transaction = await this.db.beginTransaction();
|
|
|
+ try {
|
|
|
+ // 先删除旧的审批流，再添加新的
|
|
|
+ transaction.delete(this.tableName, { tender_id: tender.id, times: tender.ledger_times });
|
|
|
+ const newAuditors = [];
|
|
|
+ let order = 1;
|
|
|
+ for (const aid of newIdList) {
|
|
|
+ newAuditors.push({
|
|
|
+ tender_id: tender.id, audit_id: aid,
|
|
|
+ times: tender.ledger_times, audit_order: order, status: auditConst.status.uncheck,
|
|
|
+ });
|
|
|
+ order++;
|
|
|
+ }
|
|
|
+ if(newAuditors.length > 0) await transaction.insert(this.tableName, newAuditors);
|
|
|
+ await transaction.commit();
|
|
|
+ } catch (err) {
|
|
|
+ await transaction.rollback();
|
|
|
+ throw err;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ async updateLastAudit(tender, auditList, lastId) {
|
|
|
+ const transaction = await this.db.beginTransaction();
|
|
|
+ try {
|
|
|
+ // 先判断auditList里的aid是否与lastId相同，相同则删除并重新更新order
|
|
|
+ const idList = this._.map(auditList, 'audit_id');
|
|
|
+ let order = idList.length + 1;
|
|
|
+ if (idList.indexOf(lastId) !== -1) {
|
|
|
+ transaction.delete(this.tableName, { tender_id: tender.id, times: tender.ledger_times, audit_id: lastId });
|
|
|
+ const audit = this._.find(auditList, { 'audit_id': lastId });
|
|
|
+ // 顺移之后审核人流程顺序
|
|
|
+ await this._syncOrderByDelete(transaction, tender.id, audit.audit_order, tender.ledger_times);
|
|
|
+ order = order - 1;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加终审
|
|
|
+ const newAuditor = {
|
|
|
+ tender_id: tender.id, audit_id: lastId,
|
|
|
+ times: tender.ledger_times, audit_order: order, status: auditConst.status.uncheck,
|
|
|
+ };
|
|
|
+ await transaction.insert(this.tableName, newAuditor);
|
|
|
+ await transaction.commit();
|
|
|
+ } catch (err) {
|
|
|
+ await transaction.rollback();
|
|
|
+ throw err;
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
return LedgerAudit;
|
