1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144 |
- 'use strict';
- /**
- *
- *
- * @author Mai
- * @date 2018/8/14
- * @version
- */
- const audit = require('../const/audit');
- const fs = require('fs');
- const path = require('path');
- const smsTypeConst = require('../const/sms_type');
- const SMS = require('../lib/sms');
- const SmsAliConst = require('../const/sms_alitemplate');
- const pushType = require('../const/audit').pushType;
- module.exports = app => {
- class Change extends app.BaseService {
- /**
- * 构造函数
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- constructor(ctx) {
- super(ctx);
- this.tableName = 'change';
- }
- /**
- * 查找数据
- *
- * @param {Object} data - 筛选表单中的get数据
- * @return {void}
- */
- searchFilter(data) {
- this.initSqlBuilder();
- // this.sqlBuilder.columns = ['id', 'username', 'real_name', 'create_time', 'last_login', 'login_ip',
- // 'group_id', 'token', 'can_login'];
- data.type = parseInt(data.status);
- if (data.keyword !== undefined) {
- switch (data.type) {
- // 用户名
- case 1:
- this.sqlBuilder.setAndWhere('username', {
- value: this.db.escape(data.keyword + '%'),
- operate: 'like',
- });
- break;
- // 姓名
- case 2:
- this.sqlBuilder.setAndWhere('real_name', {
- value: this.db.escape(data.keyword + '%'),
- operate: 'like',
- });
- break;
- // 联系电话
- case 3:
- this.sqlBuilder.setAndWhere('telephone', {
- value: this.db.escape(data.keyword + '%'),
- operate: 'like',
- });
- break;
- default:
- break;
- }
- }
- // 办事处筛选
- if (data.office !== undefined && data.office !== '') {
- this.sqlBuilder.setAndWhere('office', {
- value: this.db.escape(data.office),
- operate: '=',
- });
- }
- }
- async add(tenderId, userId, code, name) {
- const sql = 'SELECT COUNT(*) as count FROM ?? WHERE `tid` = ? AND ((`code` = ? AND `status` != ?) OR (`p_code` = ? AND `status` = ?))';
- const sqlParam = [this.tableName, tenderId, code, audit.flow.status.checked, code, audit.flow.status.checked];
- const codeCount = await this.db.queryOne(sql, sqlParam);
- const count = codeCount.count;
- if (count > 0) {
- throw '变更令号重复';
- }
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- const cid = this.uuid.v4();
- const change = {
- cid,
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.uncheck,
- times: 1,
- valid: true,
- in_time: new Date(),
- code,
- name,
- };
- const operate = await this.transaction.insert(this.tableName, change);
- if (operate.affectedRows <= 0) {
- throw '新建变更令数据失败';
- }
- // 把提交人信息添加到zh_change_audit
- const userInfo = await this.ctx.service.projectAccount.getDataById(userId);
- const changeaudit = [{
- tid: tenderId,
- cid,
- uid: userId,
- name: userInfo.name,
- jobs: userInfo.role,
- company: userInfo.company,
- times: 1,
- usite: 0,
- usort: 0,
- status: 2,
- }];
- // 并把之前存在的变更令审批人添加到zh_change_audit
- // 先找出标段最近存在的变更令审批人的变更令info
- const changeInfo = await this.ctx.service.change.getHaveAuditLastInfo(tenderId);
- if (changeInfo) {
- // 再获取非原报审批人
- const auditList = await this.ctx.service.changeAudit.getListGroupByTimes(changeInfo.cid, changeInfo.times);
- let sort = 1;
- for (const audit of auditList) {
- if (audit.usite !== 0) {
- const oneaudit = {
- tid: tenderId,
- cid,
- uid: audit.uid,
- name: audit.name,
- jobs: audit.jobs,
- company: audit.company,
- times: 1,
- usite: audit.usite,
- usort: sort++,
- status: 1,
- };
- changeaudit.push(oneaudit);
- }
- }
- }
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, changeaudit);
- result = change;
- this.transaction.commit();
- } catch (error) {
- console.log(error);
- // 回滚
- await this.transaction.rollback();
- }
- return result;
- }
- async getHaveAuditLastInfo(tenderId) {
- const sql = 'SELECT * FROM ?? as a LEFT JOIN ?? as b ON a.`cid` = b.`cid` WHERE a.`tid` = ? AND b.`usite` > 0 ORDER BY a.`in_time` DESC';
- const sqlParam = [this.tableName, this.ctx.service.changeAudit.tableName, tenderId];
- return await this.db.queryOne(sql, sqlParam);
- }
- async pendingDatas(tenderId, userId) {
- return await this.getAllDataByCondition({
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.checking,
- });
- }
- async uncheckDatas(tenderId, userId) {
- return await this.getAllDataByCondition({
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.uncheck,
- });
- }
- async checkingDatas(tenderId, userId) {
- return await this.getAllDataByCondition({
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.checking,
- });
- }
- async checkedDatas(tenderId, userId) {
- return await this.getAllDataByCondition({
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.checked,
- });
- }
- async checkNoDatas(tenderId, userId) {
- return await this.getAllDataByCondition({
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.checkNo,
- });
- }
- async checkNoCount(tenderId, userId) {
- return await this.count({
- tid: tenderId,
- uid: userId,
- status: audit.flow.status.checkNo,
- });
- }
- /**
- * 获取变更令列表
- * @param {int} tenderId - 标段id
- * @param {int} status - 状态
- * @param {int} hadlimit - 分页
- * @return {object} list - 列表
- */
- async getListByStatus(tenderId, status = 0, hadlimit = 1) {
- let sql = '';
- let sqlParam = '';
- switch (status) {
- case 0:// 包含你的所有变更令
- sql = 'SELECT a.* FROM ?? AS a WHERE a.tid = ? AND ' +
- '(a.uid = ? OR (a.status != ? AND a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? AND a.times = b.times GROUP BY b.cid)) OR a.status = ? ) ORDER BY a.in_time DESC';
- sqlParam = [this.tableName, tenderId, this.ctx.session.sessionUser.accountId, audit.flow.status.uncheck,
- this.ctx.service.changeAudit.tableName, this.ctx.session.sessionUser.accountId, audit.flow.status.checked];
- break;
- case 1:// 待处理(你的)
- sql = 'SELECT a.* FROM ?? as a WHERE cid in(SELECT b.cid FROM ?? as b WHERE tid = ? AND uid = ? AND status = ?) ORDER BY in_time DESC';
- sqlParam = [this.tableName, this.ctx.service.changeAudit.tableName, tenderId, this.ctx.session.sessionUser.accountId, audit.flow.auditStatus.checking];
- break;
- case 5:// 待上报(所有的)PS:取未上报和退回的变更令
- sql = 'SELECT a.* FROM ?? AS a WHERE ' +
- 'a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? GROUP BY b.cid) AND ' +
- '(a.status = ? OR a.status = ?) AND a.tid = ? ORDER BY a.in_time DESC';
- sqlParam = [this.tableName, this.ctx.service.changeAudit.tableName,
- this.ctx.session.sessionUser.accountId, audit.flow.status.uncheck, audit.flow.status.back, tenderId];
- break;
- case 2:// 进行中(所有的)
- case 4:// 终止(所有的)
- sql = 'SELECT a.* FROM ?? AS a WHERE ' +
- 'a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? AND a.times = b.times GROUP BY b.cid) AND ' +
- 'a.status = ? AND a.tid = ? ORDER BY a.in_time DESC';
- sqlParam = [this.tableName, this.ctx.service.changeAudit.tableName,
- this.ctx.session.sessionUser.accountId, status, tenderId];
- break;
- case 3:// 已完成(所有的)
- sql = 'SELECT a.* FROM ?? AS a WHERE ' +
- 'a.status = ? AND a.tid = ? ORDER BY a.in_time DESC';
- sqlParam = [this.tableName, status, tenderId];
- break;
- default:
- break;
- }
- if (hadlimit) {
- const limit = this.app.config.pageSize;
- const offset = limit * (this.ctx.page - 1);
- const limitString = offset >= 0 ? offset + ',' + limit : limit;
- sql += ' LIMIT ' + limitString;
- }
- const list = await this.db.query(sql, sqlParam);
- return list;
- }
- /**
- * 获取变更令个数
- * @param {int} tenderId - 标段id
- * @param {int} status - 状态
- * @return {void}
- */
- async getCountByStatus(tenderId, status) {
- switch (status) {
- case 0:// 包含你的所有变更令
- const sql = 'SELECT count(*) AS count FROM ?? AS a WHERE a.tid = ? AND ' +
- '(a.uid = ? OR a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? AND a.times = b.times GROUP BY b.cid))';
- const sqlParam = [this.tableName, tenderId, this.ctx.session.sessionUser.accountId,
- this.ctx.service.changeAudit.tableName, this.ctx.session.sessionUser.accountId];
- const result = await this.db.query(sql, sqlParam);
- return result[0].count;
- case 1:// 待处理(你的)
- return await this.ctx.service.changeAudit.count({
- tid: tenderId,
- uid: this.ctx.session.sessionUser.accountId,
- status: 2,
- });
- case 5:// 待上报(所有的)PS:取未上报和退回的变更令
- const sql2 = 'SELECT count(*) AS count FROM ?? AS a WHERE ' +
- 'a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? AND a.times = b.times GROUP BY b.cid) ' +
- 'AND (a.status = ? OR a.status = ?) AND a.tid = ?';
- const sqlParam2 = [this.tableName, this.ctx.service.changeAudit.tableName,
- this.ctx.session.sessionUser.accountId, audit.flow.status.uncheck, audit.flow.status.back, tenderId];
- const result2 = await this.db.query(sql2, sqlParam2);
- return result2[0].count;
- case 2:// 进行中(所有的)
- case 4:// 终止(所有的)
- const sql3 = 'SELECT count(*) AS count FROM ?? AS a WHERE ' +
- 'a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? AND a.times = b.times GROUP BY b.cid) AND a.status = ? AND a.tid = ?';
- const sqlParam3 = [this.tableName, this.ctx.service.changeAudit.tableName,
- this.ctx.session.sessionUser.accountId, status, tenderId];
- const result3 = await this.db.query(sql3, sqlParam3);
- return result3[0].count;
- case 3:// 已完成(所有的)
- const sql4 = 'SELECT count(*) AS count FROM ?? WHERE status = ? AND tid = ?';
- const sqlParam4 = [this.tableName, status, tenderId];
- const result4 = await this.db.query(sql4, sqlParam4);
- return result4[0].count;
- default:
- break;
- }
- }
- /**
- * 上报或重新上报或保存修改功能
- * @param {int} postData - 表单提交的数据
- * @param {int} tenderId - 标段id
- * @return {void}
- */
- async save(postData, tenderId) {
- const tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(tenderId);
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- // 变更令信息
- const changeInfo = await this.getDataByCondition({ cid: postData.cid });
- // 该变更令原报人信息
- const lastUser = await this.ctx.service.changeAudit.getLastUser(changeInfo.cid, changeInfo.times, 0);
- // 先删除本次原有的变更审批人和清单
- await this.ctx.service.changeAudit.deleteAuditData(this.transaction, changeInfo.cid, changeInfo.times);
- await this.transaction.delete(this.ctx.service.changeAuditList.tableName, { cid: changeInfo.cid });
- let change_status = false;
- // 获取变更令提交状态
- if (postData.changestatus !== undefined && parseInt(postData.changestatus) === 1) {
- change_status = true;
- // 更新原报人审批状态
- await this.transaction.update(this.ctx.service.changeAudit.tableName, { id: lastUser.id, status: audit.flow.auditStatus.checked, sin_time: new Date() });
- }
- // 再插入postData里的变更审批人和清单
- if (postData.changeaudit !== undefined && postData.changeaudit !== '') {
- const changeAudit = postData.changeaudit.split(',');
- const insertCA = [];
- let uSite = 1;
- let uSort = parseInt(lastUser.usort) + 1;
- for (const [index, ca] of changeAudit.entries()) {
- const auditInfo = ca.split('/%/');
- const uStatus = change_status && index === 0 ? audit.flow.auditStatus.checking : audit.flow.auditStatus.uncheck;
- const sin_time = change_status && index === 0 ? new Date() : null;
- const caArray = {
- tid: tenderId,
- cid: changeInfo.cid,
- uid: auditInfo[0],
- name: auditInfo[1],
- jobs: auditInfo[2],
- company: auditInfo[3],
- times: changeInfo.times,
- usite: uSite,
- usort: uSort,
- status: uStatus,
- sin_time,
- };
- uSite++;
- uSort++;
- insertCA.push(caArray);
- console.log(change_status, index);
- // 添加短信通知-需要审批提醒功能
- if (change_status && index === 0) {
- // const smsUser = await this.ctx.service.projectAccount.getDataById(auditInfo[0]);
- // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '' && smsUser.sms_type !== null) {
- // const smsType = JSON.parse(smsUser.sms_type);
- // if (smsType[smsTypeConst.const.BG] !== undefined && smsType[smsTypeConst.const.BG].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
- // const sms = new SMS(this.ctx);
- // const result = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeInfo.tid + '/change/' + changeInfo.cid + '/info#shenpi');
- // const content = '【纵横计量支付】' + changeInfo.code + '变更需要您审批。' + result;
- // sms.send(smsUser.auth_mobile, content);
- // }
- // }
- const sms = new SMS(this.ctx);
- const code = await sms.contentChange(changeInfo.code);
- const shenpiUrl = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeInfo.tid + '/change/' + changeInfo.cid + '/info#shenpi');
- await this.ctx.helper.sendAliSms(auditInfo[0], smsTypeConst.const.BG,
- smsTypeConst.judge.approval.toString(), SmsAliConst.template.change_check, { biangeng: code, code: shenpiUrl });
- }
- }
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, insertCA);
- }
- let changeList = [];
- if (postData.changelist !== undefined && postData.changelist !== '') {
- changeList = postData.changelist.split('^_^');
- }
- let changeWhiteList = [];
- if (postData.changewhitelist !== undefined && postData.changewhitelist !== '') {
- changeWhiteList = postData.changewhitelist.split('^_^');
- }
- changeList.push.apply(changeList, changeWhiteList);
- const insertCL = [];
- let total_price = 0;
- if (changeList.length > 0) {
- for (const cl of changeList) {
- const clInfo = cl.split(';');
- const clArray = {
- tid: tenderId,
- cid: changeInfo.cid,
- lid: clInfo[8],
- code: clInfo[0],
- name: clInfo[1],
- bwmx: clInfo[2],
- unit: clInfo[3],
- unit_price: clInfo[4],
- oamount: clInfo[5],
- camount: clInfo[6],
- samount: '',
- detail: clInfo[7],
- spamount: clInfo[6],
- };
- if (clInfo[4] === '') {
- delete clArray.unit_price;
- }
- insertCL.push(clArray);
- total_price = this.ctx.helper.accAdd(total_price,
- this.ctx.helper.mul(clArray.unit_price, clArray.spamount, tenderInfo.decimal.tp));
- }
- await this.transaction.insert(this.ctx.service.changeAuditList.tableName, insertCL);
- }
- // 修改变更令基本数据
- const cArray = {
- code: postData.code,
- name: postData.name,
- peg: postData.peg,
- org_name: postData.org_name,
- org_code: postData.org_code,
- new_name: postData.new_name,
- new_code: postData.new_code,
- content: postData.content,
- basis: postData.basis,
- expr: postData.expr,
- memo: postData.memo,
- type: postData.type.join(','),
- class: postData.class,
- quality: postData.quality,
- company: postData.company,
- charge: postData.charge,
- total_price,
- };
- const options = {
- where: {
- cid: changeInfo.cid,
- },
- };
- if (change_status) {
- cArray.status = audit.flow.status.checking;
- cArray.cin_time = Date.parse(new Date()) / 1000;
- }
- await this.transaction.update(this.tableName, cArray, options);
- await this.transaction.commit();
- result = true;
- } catch (error) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 审批通过
- * @param {Number} pid 项目id
- * @param {int} postData - 表单提交的数据
- * @param {int} changeData - 变更令的数据
- * @return {void}
- */
- async approvalSuccess(pid, postData, changeData) {
- let tenderInfo;
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- // 设置审批人通过
- const audit_update = {
- id: postData.audit_id,
- sdesc: postData.sdesc,
- status: audit.flow.auditStatus.checked,
- sin_time: new Date(),
- };
- const change_update = {
- w_code: postData.w_code,
- status: audit.flow.status.checking,
- cin_time: Date.parse(new Date()) / 1000,
- };
- await this.transaction.update(this.ctx.service.changeAudit.tableName, audit_update);
- // 清单数据更新
- const bills_list = postData.bills_list.split(',');
- let total_price = 0;
- for (const bl of bills_list) {
- const listInfo = bl.split('_');
- const lid = listInfo[0];
- const amount = listInfo[1];
- const changeListInfo = await this.ctx.service.changeAuditList.getDataById(lid);
- if (!tenderInfo) {
- tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(changeListInfo.tid);
- }
- if (changeListInfo !== undefined) {
- total_price = this.ctx.helper.add(total_price,
- this.ctx.helper.mul(changeListInfo.unit_price, amount, tenderInfo.decimal.tp));
- const audit_amount = changeListInfo.audit_amount !== null && changeListInfo.audit_amount !== '' ? changeListInfo.audit_amount.split(',') : [];
- audit_amount.push(amount);
- const list_update = {
- id: lid,
- audit_amount: audit_amount.join(','),
- spamount: parseFloat(amount),
- };
- if (postData.audit_next_id === undefined) {
- list_update.samount = amount;
- }
- await this.transaction.update(this.ctx.service.changeAuditList.tableName, list_update);
- }
- }
- if (postData.audit_next_id === undefined) {
- // 变更令审批完成
- change_update.status = audit.flow.status.checked;
- change_update.p_code = postData.p_code;
- change_update.sin_time = Date.parse(new Date()) / 1000;
- // 添加到消息推送表
- const noticeContent = await this.getNoticeContent(pid, changeData.tid, changeData.cid);
- await this.transaction.insert('zh_notice', { pid, type: pushType.change, uid: changeData.uid, status: audit.flow.status.checked, is_read: 0, content: noticeContent });
- // 添加短信通知-审批通过提醒功能
- // const mobile_array = [];
- const auditList = await this.ctx.service.changeAudit.getListGroupByTimes(changeData.cid, changeData.times);
- // for (const user of auditList) {
- // const smsUser = await this.ctx.service.projectAccount.getDataById(user.uid);
- // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '' && smsUser.sms_type !== null) {
- // const smsType = JSON.parse(smsUser.sms_type);
- // if (smsType[smsTypeConst.const.BG] !== undefined && smsType[smsTypeConst.const.BG].indexOf(smsTypeConst.judge.result.toString()) !== -1) {
- // mobile_array.push(smsUser.auth_mobile);
- // }
- // }
- // }
- // if (mobile_array.length > 0) {
- // const sms = new SMS(this.ctx);
- // const content = '【纵横计量支付】' + changeData.code + '变更,审批通过。';
- // sms.send(mobile_array, content);
- // }
- const users = this._.map(auditList, 'uid');
- const sms = new SMS(this.ctx);
- const code = await sms.contentChange(changeData.code);
- await this.ctx.helper.sendAliSms(users, smsTypeConst.const.BG,
- smsTypeConst.judge.result.toString(), SmsAliConst.template.change_result, { biangeng: code, status: SmsAliConst.status.success });
- } else {
- // 设置下一个审批人为审批状态
- const nextAudit_update = {
- id: postData.audit_next_id,
- status: audit.flow.auditStatus.checking,
- };
- await this.transaction.update(this.ctx.service.changeAudit.tableName, nextAudit_update);
- // 添加短信通知-需要审批提醒功能
- const nextAuditData = await this.ctx.service.changeAudit.getDataById(postData.audit_next_id);
- const sms = new SMS(this.ctx);
- const code = await sms.contentChange(changeData.code);
- // const smsUser = await this.ctx.service.projectAccount.getDataById(nextAuditData.uid);
- // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '' && smsUser.sms_type !== null) {
- // const smsType = JSON.parse(smsUser.sms_type);
- // if (smsType[smsTypeConst.const.BG] !== undefined && smsType[smsTypeConst.const.BG].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
- // const sms = new SMS(this.ctx);
- // const code = await sms.contentChange(changeData.code);
- // const result = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeData.tid + '/change/' + changeData.cid + '/info#shenpi');
- // const content = '【纵横计量支付】' + code + '变更需要您审批。' + result;
- // sms.send(smsUser.auth_mobile, content);
- // }
- // }
- const shenpiUrl = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeData.tid + '/change/' + changeData.cid + '/info#shenpi');
- await this.ctx.helper.sendAliSms(nextAuditData.uid, smsTypeConst.const.BG,
- smsTypeConst.judge.approval.toString(), SmsAliConst.template.change_check, { biangeng: code, code: shenpiUrl });
- }
- change_update.total_price = total_price;
- const options = {
- where: {
- cid: postData.change_id,
- },
- };
- await this.transaction.update(this.tableName, change_update, options);
- await this.transaction.commit();
- result = true;
- } catch (error) {
- console.log(error);
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 审批终止
- * @param {int} postData - 表单提交的数据
- * @return {void}
- */
- async approvalStop(postData) {
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- // 设置审批人终止
- const audit_update = {
- id: postData.audit_id,
- sdesc: postData.sdesc,
- status: 4,
- sin_time: new Date(),
- };
- await this.transaction.update(this.ctx.service.changeAudit.tableName, audit_update);
- // 设置变更令终止
- const change_update = {
- w_code: postData.w_code,
- status: 4,
- cin_time: Date.parse(new Date()) / 1000,
- };
- const options = {
- where: {
- cid: postData.change_id,
- },
- };
- await this.transaction.update(this.tableName, change_update, options);
- await this.transaction.commit();
- result = true;
- } catch (error) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 审批退回到原报人
- * @param {Number} pid 项目id
- * @param {int} postData - 表单提交的数据
- * @param {int} changeData - 变更令的数据
- * @return {void}
- */
- async approvalBack(pid, postData, changeData) {
- // 初始化事务
- const noticeContent = await this.getNoticeContent(pid, changeData.tid, changeData.cid);
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- // 添加到消息推送表
- await this.transaction.insert('zh_notice', { pid, type: pushType.change, uid: changeData.uid, status: audit.flow.status.back, is_read: 0, content: noticeContent });
- const changeInfo = await this.getDataByCondition({ cid: postData.change_id });
- const tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(changeInfo.tid);
- // 设置审批人退回
- const audit_update = {
- id: postData.audit_id,
- sdesc: postData.sdesc,
- status: audit.flow.auditStatus.back,
- sin_time: new Date(),
- };
- await this.transaction.update(this.ctx.service.changeAudit.tableName, audit_update);
- // 新增新一次的审批人列表
- // 获取当前次数审批人列表
- const auditList = await this.ctx.service.changeAudit.getListGroupByTimes(changeInfo.cid, changeInfo.times);
- const lastauditInfo = await this.ctx.service.changeAudit.getLastUser(changeInfo.cid, changeInfo.times, 1, 0);
- let usort = lastauditInfo.usort + 1;
- const newTimes = changeInfo.times + 1;
- const insert_audit_array = [];
- for (const al of auditList) {
- const insert_audit = {
- tid: al.tid,
- cid: al.cid,
- uid: al.uid,
- name: al.name,
- jobs: al.jobs,
- company: al.company,
- times: newTimes,
- usite: al.usite,
- usort,
- status: al.usite !== 0 ? audit.flow.auditStatus.uncheck : audit.flow.auditStatus.checking,
- };
- insert_audit_array.push(insert_audit);
- usort++;
- }
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, insert_audit_array);
- // 变更金额也退回
- const changeList = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: changeInfo.cid } });
- let total_price = 0;
- for (const cl of changeList) {
- total_price = this.ctx.helper.add(total_price,
- this.ctx.helper.mul(cl.unit_price, cl.camount, tenderInfo.decimal.tp));
- }
- // 设置变更令退回
- const change_update = {
- w_code: postData.w_code,
- status: audit.flow.status.back,
- times: newTimes,
- cin_time: Date.parse(new Date()) / 1000,
- total_price,
- };
- const options = {
- where: {
- cid: postData.change_id,
- },
- };
- await this.transaction.update(this.tableName, change_update, options);
- await this.transaction.commit();
- result = true;
- // 添加短信通知-审批退回提醒功能
- // const mobile_array = [];
- // for (const user of insert_audit_array) {
- // const smsUser = await this.ctx.service.projectAccount.getDataById(user.uid);
- // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '' && smsUser.sms_type !== null) {
- // const smsType = JSON.parse(smsUser.sms_type);
- // if (smsType[smsTypeConst.const.BG] !== undefined && smsType[smsTypeConst.const.BG].indexOf(smsTypeConst.judge.result.toString()) !== -1) {
- // mobile_array.push(smsUser.auth_mobile);
- // }
- // }
- // }
- // if (mobile_array.length > 0) {
- // const sms = new SMS(this.ctx);
- // const code = await sms.contentChange(changeData.code);
- // const content = '【纵横计量支付】' + code + '变更,审批退回。';
- // sms.send(mobile_array, content);
- // }
- const users = this._.map(insert_audit_array, 'uid');
- const sms = new SMS(this.ctx);
- const code = await sms.contentChange(changeData.code);
- await this.ctx.helper.sendAliSms(users, smsTypeConst.const.BG,
- smsTypeConst.judge.result.toString(), SmsAliConst.template.change_result, { biangeng: code, status: SmsAliConst.status.back });
- } catch (error) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 审批退回到上一个审批人
- * @param {int} postData - 表单提交的数据
- * @param {int} changeData - 变更令的数据
- * @return {void}
- */
- async approvalBackNew(postData, changeData) {
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- const changeInfo = await this.getDataByCondition({ cid: postData.change_id });
- const tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(changeInfo.tid);
- // 设置审批人退回
- const audit_update = {
- id: postData.audit_id,
- sdesc: postData.sdesc,
- status: audit.flow.auditStatus.backnew,
- sin_time: new Date(),
- };
- await this.transaction.update(this.ctx.service.changeAudit.tableName, audit_update);
- // 获取当前审批人信息
- const auditInfo = await this.ctx.service.changeAudit.getDataById(postData.audit_id);
- // 获取当前次数审批人列表
- const auditList = await this.ctx.service.changeAudit.getNextAuditList(changeInfo.cid, auditInfo.usort);
- let usort = auditInfo.usort + 1;
- // 获取上一个审批人信息
- const lastauditInfo = await this.ctx.service.changeAudit.getDataById(postData.audit_last_id);
- // 新增2个审批人到审批列表中
- const insert_audit1 = {
- tid: lastauditInfo.tid,
- cid: lastauditInfo.cid,
- uid: lastauditInfo.uid,
- name: lastauditInfo.name,
- jobs: lastauditInfo.jobs,
- company: lastauditInfo.company,
- times: lastauditInfo.times,
- usite: lastauditInfo.usite,
- usort,
- status: audit.flow.auditStatus.checking,
- };
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, insert_audit1);
- usort++;
- // 新增2个审批人到审批列表中
- const insert_audit2 = {
- tid: auditInfo.tid,
- cid: auditInfo.cid,
- uid: auditInfo.uid,
- name: auditInfo.name,
- jobs: auditInfo.jobs,
- company: auditInfo.company,
- times: auditInfo.times,
- usite: auditInfo.usite,
- usort,
- status: audit.flow.auditStatus.uncheck,
- };
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, insert_audit2);
- // 把接下未审批的审批人排序都加2
- for (const al of auditList) {
- const audit_update = {
- id: al.id,
- usort: al.usort + 2,
- };
- await this.transaction.update(this.ctx.service.changeAudit.tableName, audit_update);
- }
- // 审批列表数据也要回退
- const changeList = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: changeInfo.cid } });
- let total_price = 0;
- for (const cl of changeList) {
- const audit_amount = cl.audit_amount.split(',');
- const last_amount = audit_amount[audit_amount.length - 1];
- audit_amount.splice(-1, 1);
- const list_update = {
- id: cl.id,
- audit_amount: audit_amount.join(','),
- spamount: parseFloat(last_amount),
- };
- total_price = this.ctx.helper.add(total_price,
- this.ctx.helper.mul(cl.unit_price, parseFloat(last_amount), tenderInfo.decimal.tp));
- await this.transaction.update(this.ctx.service.changeAuditList.tableName, list_update);
- }
- // 设置变更令退回
- const change_update = {
- w_code: postData.w_code,
- status: audit.flow.status.backnew,
- cin_time: Date.parse(new Date()) / 1000,
- total_price,
- };
- const options = {
- where: {
- cid: postData.change_id,
- },
- };
- await this.transaction.update(this.tableName, change_update, options);
- await this.transaction.commit();
- result = true;
- // 添加短信通知-需要审批提醒功能
- // const smsUser = await this.ctx.service.projectAccount.getDataById(lastauditInfo.uid);
- // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '' && smsUser.sms_type !== null) {
- // const smsType = JSON.parse(smsUser.sms_type);
- // if (smsType[smsTypeConst.const.BG] !== undefined && smsType[smsTypeConst.const.BG].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
- // const sms = new SMS(this.ctx);
- // const code = await sms.contentChange(changeData.code);
- // const result = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeData.tid + '/change/' + changeData.cid + '/info#shenpi');
- // const content = '【纵横计量支付】' + code + '变更需要您审批。' + result;
- // sms.send(smsUser.auth_mobile, content);
- // }
- // }
- const sms = new SMS(this.ctx);
- const code = await sms.contentChange(changeData.code);
- const shenpiUrl = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeData.tid + '/change/' + changeData.cid + '/info#shenpi');
- await this.ctx.helper.sendAliSms(lastauditInfo.uid, smsTypeConst.const.BG,
- smsTypeConst.judge.approval.toString(), SmsAliConst.template.change_check, { biangeng: code, code: shenpiUrl });
- } catch (error) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 查询可用的变更令
- * @param bills - 查询的清单
- * @param pos - 查询的部位
- * @return {Promise<*>} - 可用的变更令列表
- */
- async getValidChanges(tid, bills, pos) {
- const timesLen = 100;
- const filter = 'cb.`code` = ' + this.db.escape(bills.b_code) +
- ' And cb.`name` = ' + this.db.escape(bills.name) +
- ' And cb.`unit` = ' + this.db.escape(bills.unit) +
- ' And cb.`unit_price` = ' + this.db.escape(bills.unit_price) +
- (pos ? ' And cb.`bwmx` = ' + this.db.escape(pos.name) : '');
- const sql = 'SELECT c.cid, c.code, c.name, c.w_code, c.p_code, c.peg, c.org_name, c.org_code, c.new_name, c.new_code,' +
- ' c.content, c.basis, c.memo, c.type, c.class, c.quality, c.company, c.charge, ' +
- ' cb.id As cbid, cb.code As b_code, cb.name As b_name, cb.unit As b_unit, cb.samount As b_amount, cb.detail As b_detail, cb.bwmx As b_bwmx, ' +
- ' scb.used_amount' +
- ' FROM ' + this.tableName + ' As c ' +
- ' Left Join ' + this.ctx.service.changeAuditList.tableName + ' As cb On c.cid = cb.cid ' +
- ' Left Join (' +
- ' SELECT SUM(sc.qty) As used_amount, sc.cbid' +
- ' FROM ' + this.ctx.service.stageChange.tableName + ' As sc' +
- ' INNER JOIN (SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `flow`, cbid, sid ' +
- ' FROM ' + this.ctx.service.stageChange.tableName +
- ' WHERE tid = ?' +
- ' GROUP BY cbid, sid' +
- ' ) As MF' +
- ' ON (sc.stimes * ' + timesLen + ' + sc.sorder) = MF.flow And sc.cbid = MF.cbid And sc.sid = MF.sid' +
- ' GROUP BY sc.cbid' +
- ' ) As scb ON cb.id = scb.cbid' +
- ' WHERE c.tid = ? And c.status = ? And c.valid And ' + filter +
- ' ORDER BY c.in_time';
- const sqlParam = [tid, tid, audit.flow.status.checked];
- const changes = await this.db.query(sql, sqlParam);
- for (const c of changes) {
- const aSql = 'SELECT ca.*, pa.name As u_name, pa.role As u_role ' +
- ' FROM ?? As ca ' +
- ' Left Join ?? As pa ' +
- ' On ca.uid = pa.id ' +
- ' Where ca.cid = ?';
- const aSqlParam = [this.ctx.service.changeAtt.tableName, this.ctx.service.projectAccount.tableName, c.cid];
- c.attachments = await this.db.query(aSql, aSqlParam);
- }
- return changes;
- }
- /**
- * 查询变更令 + 变更令执行
- * @param tid
- * @return {Promise<void>}
- */
- async getChangeAndUsedInfo(tid) {
- const lastStage = await this.ctx.service.stage.getLastestStage(tid, true);
- let filter;
- if (lastStage.id === this.ctx.stage.id) {
- filter = this.db.format(' And (s.`order` < ? OR (s.`order` = ? And (sChange.`stimes` < ? OR (sChange.`stimes` = ? And sChange.`sorder` <= ?))))',
- [lastStage.order, lastStage.order, this.ctx.stage.curTimes, this.ctx.stage.curTimes, this.ctx.stage.curOrder]);
- } else {
- if (lastStage.status === audit.stage.status.uncheck) {
- filter = ' And s.order < ' + lastStage.order;
- } else if (lastStage.status === audit.stage.status.checked) {
- filter = '';
- } else if (lastStage.status === audit.stage.status.checkNo) {
- filter = this.db.format(' And (s.`order` < ? OR (s.`order` = ? And sChange.`stimes` <= ?))',
- [lastStage.order, lastStage.order, lastStage.times]);
- } else {
- const curAuditor = await this.ctx.service.stageAudit.getCurAuditor(lastStage.id, lastStage.times);
- filter = this.db.format(' And (s.`order` < ? OR (s.`order` = ? And (sChange.`stimes` < ? OR (sChange.`stimes` = ? And sChange.`sorder` <= ?))))',
- [lastStage.order, lastStage.order, lastStage.times, lastStage.times, curAuditor.order - 1]);
- }
- }
- const sql = 'SELECT C.*, Sum(U.utp) As used_tp, Round(Sum(U.utp) / C.total_price * 100, 2) As used_pt' +
- ' FROM ' + this.tableName + ' As C' +
- ' LEFT JOIN (SELECT sc.tid, sc.cid, sc.cbid, Round(SUM(sc.qty) * cb.unit_price, ?) As utp' +
- ' FROM ' + this.ctx.service.stageChange.tableName + ' As sc' +
- ' INNER JOIN (' +
- ' SELECT MAX(`stimes`) As `stimes`, MAX(`sorder`) As `sorder`, `lid`, `pid`, `cbid`, sChange.`sid` ' +
- ' FROM ' + this.ctx.service.stageChange.tableName + ' As sChange ' +
- ' LEFT JOIN ' + this.ctx.service.stage.tableName + ' As s' +
- ' ON sChange.sid = s.id' +
- ' WHERE sChange.tid = ?' + filter +
- ' GROUP By `lid`, `pid`, `cbid`, `sid`' +
- ' ) As m' +
- ' ON sc.stimes = m.stimes And sc.sorder = m.sorder And sc.`cbid` = m.`cbid` AND sc.`sid` = m.`sid` And sc.`lid` = m.`lid` And sc.`pid` = m.`pid`' +
- ' LEFT JOIN ' + this.ctx.service.changeAuditList.tableName + ' As cb ON sc.cbid = cb.id' +
- ' GROUP By sc.`cbid`' +
- ' ) As U ON C.cid = U.cid' +
- ' WHERE C.tid = ? And C.status = ? And C.valid' +
- ' GROUP By C.cid' +
- ' ORDER By in_time';
- const sqlParam = [this.ctx.tender.info.decimal.tp, tid, tid, audit.flow.status.checked];
- return await this.db.query(sql, sqlParam);
- }
- /**
- * 查询可用的变更令
- * @param { string } cid - 查询的清单
- * @return {Promise<*>} - 可用的变更令列表
- */
- async delete(cid) {
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- // 先删除清单,审批人列表
- await this.transaction.delete(this.ctx.service.changeAuditList.tableName, { cid });
- await this.transaction.delete(this.ctx.service.changeAudit.tableName, { cid });
- // 再删除附件和附件文件ni zuo
- const attList = await this.ctx.service.changeAtt.getAllDataByCondition({ where: { cid } });
- if (attList.length !== 0) {
- for (const att of attList) {
- await fs.unlinkSync(path.join(this.app.baseDir, att.filepath));
- }
- await this.transaction.delete(this.ctx.service.changeAtt.tableName, { cid });
- }
- // 最后删除变更令
- await this.transaction.delete(this.tableName, { cid });
- await this.transaction.commit();
- result = true;
- } catch (e) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 重新审批变更令
- * @param { string } cid - 查询的清单
- * @return {Promise<*>} - 可用的变更令列表
- */
- async checkAgain(cid) {
- // 初始化事务
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- const changeInfo = await this.getDataByCondition({ cid });
- const tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(changeInfo.tid);
- // 获取终审
- const auditInfo = (await this.ctx.service.changeAudit.getAllDataByCondition({ where: { cid }, orders: [['usort', 'desc']], limit: 1, offset: 0 }))[0];
- let usort = auditInfo.usort + 1;
- // 新增2个审批状态到审批列表中
- const insert_audit1 = {
- tid: auditInfo.tid,
- cid: auditInfo.cid,
- uid: auditInfo.uid,
- name: auditInfo.name,
- jobs: auditInfo.jobs,
- company: auditInfo.company,
- times: auditInfo.times,
- usite: auditInfo.usite,
- usort,
- sin_time: new Date(),
- status: audit.flow.auditStatus.checkAgain,
- };
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, insert_audit1);
- usort++;
- // 新增2个审批人到审批列表中
- const insert_audit2 = {
- tid: auditInfo.tid,
- cid: auditInfo.cid,
- uid: auditInfo.uid,
- name: auditInfo.name,
- jobs: auditInfo.jobs,
- company: auditInfo.company,
- times: auditInfo.times,
- usite: auditInfo.usite,
- usort,
- status: audit.flow.auditStatus.checking,
- };
- await this.transaction.insert(this.ctx.service.changeAudit.tableName, insert_audit2);
- // 审批列表数据也要回退
- let total_price = 0;
- const changeList = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: changeInfo.cid } });
- for (const cl of changeList) {
- const audit_amount = cl.audit_amount.split(',');
- const last_amount = audit_amount[audit_amount.length - 1];
- audit_amount.splice(-1, 1);
- const list_update = {
- id: cl.id,
- audit_amount: audit_amount.join(','),
- samount: '',
- };
- total_price = this.ctx.helper.add(total_price,
- this.ctx.helper.mul(cl.unit_price, parseFloat(last_amount), tenderInfo.decimal.tp));
- await this.transaction.update(this.ctx.service.changeAuditList.tableName, list_update);
- }
- // 设置变更令审批中
- const change_update = {
- p_code: null,
- status: audit.flow.status.checking,
- cin_time: Date.parse(new Date()) / 1000,
- sin_time: null,
- total_price,
- };
- const options = {
- where: {
- cid: changeInfo.cid,
- },
- };
- await this.transaction.update(this.tableName, change_update, options);
- await this.transaction.commit();
- result = true;
- // 添加短信通知-需要审批提醒功能
- // const smsUser = await this.ctx.service.projectAccount.getDataById(auditInfo.uid);
- // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '' && smsUser.sms_type !== null) {
- // const smsType = JSON.parse(smsUser.sms_type);
- // if (smsType[smsTypeConst.const.BG] !== undefined && smsType[smsTypeConst.const.BG].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
- // const sms = new SMS(this.ctx);
- // const code = await sms.contentChange(changeInfo.code);
- // const result = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeInfo.tid + '/change/' + changeInfo.cid + '/info#shenpi');
- // const content = '【纵横计量支付】' + code + '变更需要您审批。' + result;
- // sms.send(smsUser.auth_mobile, content);
- // }
- // }
- const sms = new SMS(this.ctx);
- const code = await sms.contentChange(changeInfo.code);
- const shenpiUrl = await this.ctx.helper.urlToShort('http://' + this.ctx.request.header.host + '/wap/tender/' + changeInfo.tid + '/change/' + changeInfo.cid + '/info#shenpi');
- await this.ctx.helper.sendAliSms(auditInfo.uid, smsTypeConst.const.BG,
- smsTypeConst.judge.approval.toString(), SmsAliConst.template.change_check, { biangeng: code, code: shenpiUrl });
- } catch (error) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 判断是否有重名的变更令
- * @param cid
- * @param code
- * @param tid
- * @return {Promise<void>}
- */
- async isRepeat(cid, code, tid) {
- const sql = 'SELECT COUNT(*) as count FROM ?? WHERE ((`code` = ? AND `status` != ?) OR (`p_code` = ? AND `status` = ?)) AND `cid` != ? AND `tid` = ?';
- const sqlParam = [this.tableName, code, audit.flow.status.checked, code, audit.flow.status.checked, cid, tid];
- const result = await this.db.queryOne(sql, sqlParam);
- return result.count !== 0;
- }
- async getAllCheckedChanges(tid) {
- return await this.getAllDataByCondition({
- where: { tid, status: audit.flow.status.checked },
- orders: [['in_time', 'desc']],
- });
- }
- /**
- * 用于添加推送所需的content内容
- * @param {Number} pid 项目id
- * @param {Number} tid 台账id
- * @param {Number} cid 变更id
- */
- async getNoticeContent(pid, tid, cid) {
- const noticeSql = 'SELECT * FROM (SELECT ' +
- ' t.`id` As `tid`, t.`name`, c.`cid`, c.`code` As `c_code`, pa.`name` As `su_name`, pa.role As `su_role`' +
- ' FROM (SELECT * FROM ?? WHERE `id` = ? ) As t' +
- ' LEFT JOIN ?? As c ON c.`cid` = ?' +
- ' LEFT JOIN ?? As pa ON c.`uid` = pa.`id`' +
- ' WHERE t.`project_id` = ? ) as new_t GROUP BY new_t.`tid`';
- const noticeSqlParam = [this.ctx.service.tender.tableName, tid, this.ctx.service.change.tableName, cid, this.ctx.service.projectAccount.tableName, pid];
- const content = await this.db.query(noticeSql, noticeSqlParam);
- return content.length ? JSON.stringify(content[0]) : '';
- }
- }
- return Change;
- };
|