material_audit.js 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2019/2/27
  7. * @version
  8. */
  9. const auditConst = require('../const/audit').material;
  10. const pushType = require('../const/audit').pushType;
  11. const smsTypeConst = require('../const/sms_type');
  12. const wxConst = require('../const/wechat_template');
  13. module.exports = app => {
  14. class MaterialAudit extends app.BaseService {
  15. /**
  16. * 构造函数
  17. *
  18. * @param {Object} ctx - egg全局变量
  19. * @return {void}
  20. */
  21. constructor(ctx) {
  22. super(ctx);
  23. this.tableName = 'material_audit';
  24. }
  25. /**
  26. * 获取 审核人信息
  27. *
  28. * @param {Number} materialId - 材料调差期id
  29. * @param {Number} auditorId - 审核人id
  30. * @param {Number} times - 第几次审批
  31. * @return {Promise<*>}
  32. */
  33. async getAuditor(materialId, auditorId, times = 1) {
  34. const sql = 'SELECT la.`aid`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time` ' +
  35. 'FROM ?? AS la, ?? AS pa ' +
  36. 'WHERE la.`mid` = ? and la.`aid` = ? and la.`times` = ?' +
  37. ' and la.`aid` = pa.`id`';
  38. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, materialId, auditorId, times];
  39. return await this.db.queryOne(sql, sqlParam);
  40. }
  41. /**
  42. * 获取 审核列表信息
  43. *
  44. * @param {Number} materialId - 材料调差期id
  45. * @param {Number} times - 第几次审批
  46. * @return {Promise<*>}
  47. */
  48. async getAuditors(materialId, times = 1) {
  49. const sql = 'SELECT la.`aid`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time`, g.`sort` ' +
  50. 'FROM ?? AS la, ?? AS pa, (SELECT `aid`,(@i:=@i+1) as `sort` FROM ??, (select @i:=0) as it WHERE `mid` = ? AND `times` = ? GROUP BY `aid`) as g ' +
  51. 'WHERE la.`mid` = ? and la.`times` = ? and la.`aid` = pa.`id` and g.`aid` = la.`aid` order by la.`order`';
  52. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, this.tableName, materialId, times, materialId, times];
  53. const result = await this.db.query(sql, sqlParam);
  54. const sql2 = 'SELECT COUNT(a.`aid`) as num FROM (SELECT `aid` FROM ?? WHERE `mid` = ? AND `times` = ? GROUP BY `aid`) as a';
  55. const sqlParam2 = [this.tableName, materialId, times];
  56. const count = await this.db.queryOne(sql2, sqlParam2);
  57. for (const i in result) {
  58. result[i].max_sort = count.num;
  59. }
  60. return result;
  61. }
  62. /**
  63. * 获取 当前审核人
  64. *
  65. * @param {Number} materialId - 材料调差期id
  66. * @param {Number} times - 第几次审批
  67. * @return {Promise<*>}
  68. */
  69. async getCurAuditor(materialId, times = 1) {
  70. const sql = 'SELECT la.`aid`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time` ' +
  71. 'FROM ?? AS la, ?? AS pa ' +
  72. 'WHERE la.`mid` = ? and la.`status` = ? and la.`times` = ?' +
  73. ' and la.`aid` = pa.`id`';
  74. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, materialId, auditConst.status.checking, times];
  75. return await this.db.queryOne(sql, sqlParam);
  76. }
  77. /**
  78. * 获取 最新审核顺序
  79. *
  80. * @param {Number} materialId - 材料调差期id
  81. * @param {Number} times - 第几次审批
  82. * @return {Promise<number>}
  83. */
  84. async getNewOrder(materialId, times = 1) {
  85. const sql = 'SELECT Max(??) As max_order FROM ?? Where `mid` = ? and `times` = ?';
  86. const sqlParam = ['order', this.tableName, materialId, times];
  87. const result = await this.db.queryOne(sql, sqlParam);
  88. return result && result.max_order ? result.max_order + 1 : 1;
  89. }
  90. /**
  91. * 新增审核人
  92. *
  93. * @param {Number} materialId - 材料调差期id
  94. * @param {Number} auditorId - 审核人id
  95. * @param {Number} times - 第几次审批
  96. * @return {Promise<number>}
  97. */
  98. async addAuditor(materialId, auditorId, times = 1) {
  99. const newOrder = await this.getNewOrder(materialId, times);
  100. const data = {
  101. tid: this.ctx.tender.id,
  102. mid: materialId,
  103. aid: auditorId,
  104. times,
  105. order: newOrder,
  106. status: auditConst.status.uncheck,
  107. };
  108. const result = await this.db.insert(this.tableName, data);
  109. return result.effectRows = 1;
  110. }
  111. /**
  112. * 移除审核人时,同步其后审核人order
  113. * @param transaction - 事务
  114. * @param {Number} materialId - 材料调差期id
  115. * @param {Number} auditorId - 审核人id
  116. * @param {Number} times - 第几次审批
  117. * @return {Promise<*>}
  118. * @private
  119. */
  120. async _syncOrderByDelete(transaction, materialId, order, times) {
  121. this.initSqlBuilder();
  122. this.sqlBuilder.setAndWhere('mid', {
  123. value: materialId,
  124. operate: '=',
  125. });
  126. this.sqlBuilder.setAndWhere('order', {
  127. value: order,
  128. operate: '>=',
  129. });
  130. this.sqlBuilder.setAndWhere('times', {
  131. value: times,
  132. operate: '=',
  133. });
  134. this.sqlBuilder.setUpdateData('order', {
  135. value: 1,
  136. selfOperate: '-',
  137. });
  138. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
  139. const data = await transaction.query(sql, sqlParam);
  140. return data;
  141. }
  142. /**
  143. * 移除审核人
  144. *
  145. * @param {Number} materialId - 材料调差期id
  146. * @param {Number} auditorId - 审核人id
  147. * @param {Number} times - 第几次审批
  148. * @return {Promise<boolean>}
  149. */
  150. async deleteAuditor(materialId, auditorId, times = 1) {
  151. const transaction = await this.db.beginTransaction();
  152. try {
  153. const condition = { mid: materialId, aid: auditorId, times };
  154. const auditor = await this.getDataByCondition(condition);
  155. if (!auditor) {
  156. throw '该审核人不存在';
  157. }
  158. await this._syncOrderByDelete(transaction, materialId, auditor.order, times);
  159. await transaction.delete(this.tableName, condition);
  160. await transaction.commit();
  161. } catch (err) {
  162. await transaction.rollback();
  163. throw err;
  164. }
  165. return true;
  166. }
  167. /**
  168. * 开始审批
  169. * @param {Number} materialId - 材料调差期id
  170. * @param {Number} times - 第几次审批
  171. * @return {Promise<boolean>}
  172. */
  173. async start(materialId, times = 1) {
  174. const audit = await this.getDataByCondition({ mid: materialId, times, order: 1 });
  175. if (!audit) {
  176. throw '请先选择审批人,再上报数据';
  177. }
  178. const transaction = await this.db.beginTransaction();
  179. try {
  180. await transaction.update(this.tableName, { id: audit.id, status: auditConst.status.checking, begin_time: new Date() });
  181. await transaction.update(this.ctx.service.material.tableName, {
  182. id: materialId, status: auditConst.status.checking,
  183. });
  184. // 本期一些必要数据(如应耗数量和上期调差金额)插入到material_bills_history表里
  185. const materialBillsData = await this.ctx.service.materialBills.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
  186. if (materialBillsData.length === 0) {
  187. throw '调差工料不能为空';
  188. }
  189. const mbhList = [];
  190. for (const mb of materialBillsData) {
  191. if (mb.code === '') {
  192. throw '调差工料编号不能为空';
  193. }
  194. const newMbh = {
  195. tid: this.ctx.tender.id,
  196. mid: this.ctx.material.id,
  197. order: this.ctx.material.order,
  198. mb_id: mb.id,
  199. quantity: mb.quantity,
  200. expr: mb.expr,
  201. msg_tp: mb.msg_tp,
  202. msg_times: mb.msg_times,
  203. msg_spread: mb.msg_spread,
  204. m_up_risk: mb.m_up_risk,
  205. m_down_risk: mb.m_down_risk,
  206. m_spread: mb.m_spread,
  207. m_tp: mb.m_tp,
  208. pre_tp: mb.pre_tp,
  209. is_summary: mb.is_summary,
  210. };
  211. mbhList.push(newMbh);
  212. }
  213. await transaction.insert(this.ctx.service.materialBillsHistory.tableName, mbhList);
  214. // 微信模板通知
  215. const materialInfo = await this.ctx.service.material.getDataById(materialId);
  216. const wechatData = {
  217. qi: materialInfo.order,
  218. status: wxConst.status.check,
  219. tips: wxConst.tips.check,
  220. begin_time: Date.parse(new Date()),
  221. m_tp: this.ctx.helper.round(materialInfo.m_tp, 2),
  222. hs_m_tp: this.ctx.helper.round(this.ctx.helper.mul(materialInfo.m_tp, 1+materialInfo.rate/100), 2),
  223. };
  224. await this.ctx.helper.sendWechat(audit.aid, smsTypeConst.const.TC, smsTypeConst.judge.approval.toString(), wxConst.template.material, wechatData);
  225. // 添加短信通知-需要审批提醒功能
  226. // const smsUser = await this.ctx.service.projectAccount.getDataById(audit.aid);
  227. // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '') {
  228. // const smsType = JSON.parse(smsUser.sms_type);
  229. // if (smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
  230. // const tenderInfo = await this.ctx.service.tender.getDataById(audit.tid);
  231. // const stageInfo = await this.ctx.service.stage.getDataById(audit.sid);
  232. // const sms = new SMS(this.ctx);
  233. // const tenderName = await sms.contentChange(tenderInfo.name);
  234. // const content = '【纵横计量支付】' + tenderName + '第' + stageInfo.order + '期,需要您审批。';
  235. // sms.send(smsUser.auth_mobile, content);
  236. // }
  237. // }
  238. // todo 更新标段tender状态 ?
  239. await transaction.commit();
  240. } catch (err) {
  241. await transaction.rollback();
  242. throw err;
  243. }
  244. return true;
  245. }
  246. async _checked(pid, materialId, checkData, times) {
  247. const time = new Date();
  248. // 整理当前流程审核人状态更新
  249. const audit = await this.getDataByCondition({ mid: materialId, times, status: auditConst.status.checking });
  250. if (!audit) {
  251. throw '审核数据错误';
  252. }
  253. // 获取审核人列表
  254. const sql = 'SELECT `tid`, `mid`, `aid`, `order` FROM ?? WHERE `mid` = ? and `times` = ? GROUP BY `aid` ORDER BY `id` ASC';
  255. const sqlParam = [this.tableName, materialId, times];
  256. const auditors = await this.db.query(sql, sqlParam);
  257. const nextAudit = await this.getDataByCondition({ mid: materialId, times, order: audit.order + 1 });
  258. const transaction = await this.db.beginTransaction();
  259. try {
  260. await transaction.update(this.tableName, { id: audit.id, status: checkData.checkType, opinion: checkData.opinion, end_time: time });
  261. // 获取推送必要信息
  262. const noticeContent = await this.getNoticeContent(pid, audit.tid, materialId, audit.aid);
  263. // 添加推送
  264. const records = [{ pid, type: pushType.material, uid: this.ctx.material.user_id, status: auditConst.status.checked, content: noticeContent }];
  265. auditors.forEach(audit => {
  266. records.push({ pid, type: pushType.material, uid: audit.aid, status: auditConst.status.checked, content: noticeContent });
  267. });
  268. await transaction.insert('zh_notice', records);
  269. const begin_audit = await this.getDataByCondition({
  270. mid: materialId,
  271. order: 1,
  272. });
  273. const materialInfo = await this.ctx.service.material.getDataById(materialId);
  274. // 无下一审核人表示,审核结束
  275. if (nextAudit) {
  276. // 复制一份下一审核人数据
  277. // await this.ctx.service.stagePay.copyAuditStagePays(this.ctx.stage, this.ctx.stage.times, nextAudit.order, transaction);
  278. // 流程至下一审批人
  279. await transaction.update(this.tableName, { id: nextAudit.id, status: auditConst.status.checking, begin_time: time });
  280. // 同步 期信息
  281. await transaction.update(this.ctx.service.material.tableName, {
  282. id: materialId, status: auditConst.status.checking,
  283. });
  284. // 微信模板通知
  285. const wechatData = {
  286. qi: materialInfo.order,
  287. status: wxConst.status.check,
  288. tips: wxConst.tips.check,
  289. begin_time: Date.parse(begin_audit.begin_time),
  290. m_tp: this.ctx.helper.round(materialInfo.m_tp, 2),
  291. hs_m_tp: this.ctx.helper.round(this.ctx.helper.mul(materialInfo.m_tp, 1+materialInfo.rate/100), 2),
  292. };
  293. await this.ctx.helper.sendWechat(nextAudit.aid, smsTypeConst.const.TC, smsTypeConst.judge.approval.toString(), wxConst.template.material, wechatData);
  294. // 添加短信通知-需要审批提醒功能
  295. // const smsUser = await this.ctx.service.projectAccount.getDataById(nextAudit.aid);
  296. // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '') {
  297. // const smsType = JSON.parse(smsUser.sms_type);
  298. // if (smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
  299. // const tenderInfo = await this.ctx.service.tender.getDataById(nextAudit.tid);
  300. // const stageInfo = await this.ctx.service.stage.getDataById(nextAudit.sid);
  301. // const sms = new SMS(this.ctx);
  302. // const tenderName = await sms.contentChange(tenderInfo.name);
  303. // const content = '【纵横计量支付】' + tenderName + '第' + stageInfo.order + '期,需要您审批。';
  304. // sms.send(smsUser.auth_mobile, content);
  305. // }
  306. // }
  307. } else {
  308. // 本期结束
  309. // 生成截止本期数据 final数据
  310. // console.time('generatePre');
  311. // await this.ctx.service.stageBillsFinal.generateFinalData(transaction, this.ctx.tender, this.ctx.stage);
  312. // await this.ctx.service.stagePosFinal.generateFinalData(transaction, this.ctx.tender, this.ctx.stage);
  313. // console.timeEnd('generatePre');
  314. // 同步 期信息
  315. await transaction.update(this.ctx.service.material.tableName, {
  316. id: materialId, status: checkData.checkType,
  317. });
  318. // 微信模板通知
  319. const users = this._.uniq(this._.concat(this._.map(auditors, 'aid'), materialInfo.user_id));
  320. const wechatData = {
  321. qi: materialInfo.order,
  322. status: wxConst.status.success,
  323. tips: wxConst.tips.success,
  324. begin_time: Date.parse(begin_audit.begin_time),
  325. m_tp: this.ctx.helper.round(materialInfo.m_tp, 2),
  326. hs_m_tp: this.ctx.helper.round(this.ctx.helper.mul(materialInfo.m_tp, 1+materialInfo.rate/100), 2),
  327. };
  328. await this.ctx.helper.sendWechat(users, smsTypeConst.const.TC, smsTypeConst.judge.result.toString(), wxConst.template.material, wechatData);
  329. // 添加短信通知-审批通过提醒功能
  330. // const mobile_array = [];
  331. // const stageInfo = await this.ctx.service.stage.getDataById(stageId);
  332. // const auditList = await this.getAuditors(stageId, stageInfo.times);
  333. // const smsUser1 = await this.ctx.service.projectAccount.getDataById(stageInfo.user_id);
  334. // if (smsUser1.auth_mobile !== undefined && smsUser1.sms_type !== '') {
  335. // const smsType = JSON.parse(smsUser1.sms_type);
  336. // if (smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.result.toString()) !== -1) {
  337. // mobile_array.push(smsUser1.auth_mobile);
  338. // }
  339. // }
  340. // for (const user of auditList) {
  341. // const smsUser = await this.ctx.service.projectAccount.getDataById(user.aid);
  342. // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '') {
  343. // const smsType = JSON.parse(smsUser.sms_type);
  344. // if (mobile_array.indexOf(smsUser.auth_mobile) === -1 && smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.result.toString()) !== -1) {
  345. // mobile_array.push(smsUser.auth_mobile);
  346. // }
  347. // }
  348. // }
  349. // if (mobile_array.length > 0) {
  350. // const tenderInfo = await this.ctx.service.tender.getDataById(stageInfo.tid);
  351. // const sms = new SMS(this.ctx);
  352. // const tenderName = await sms.contentChange(tenderInfo.name);
  353. // const content = '【纵横计量支付】' + tenderName + '第' + stageInfo.order + '期,审批通过。';
  354. // sms.send(mobile_array, content);
  355. // }
  356. }
  357. await transaction.commit();
  358. } catch (err) {
  359. await transaction.rollback();
  360. throw err;
  361. }
  362. }
  363. async _checkNo(pid, materialId, checkData, times) {
  364. const time = new Date();
  365. // 整理当前流程审核人状态更新
  366. const audit = await this.getDataByCondition({ mid: materialId, times, status: auditConst.status.checking });
  367. if (!audit) {
  368. throw '审核数据错误';
  369. }
  370. const sql = 'SELECT `tid`, `mid`, `aid`, `order` FROM ?? WHERE `mid` = ? and `times` = ? GROUP BY `aid` ORDER BY `id` ASC';
  371. const sqlParam = [this.tableName, materialId, times];
  372. const auditors = await this.db.query(sql, sqlParam);
  373. let order = 1;
  374. for (const a of auditors) {
  375. a.times = times + 1;
  376. a.order = order;
  377. a.status = auditConst.status.uncheck;
  378. order++;
  379. }
  380. const transaction = await this.db.beginTransaction();
  381. try {
  382. await transaction.update(this.tableName, { id: audit.id, status: checkData.checkType, opinion: checkData.opinion, end_time: time });
  383. // 添加到消息推送表
  384. const noticeContent = await this.getNoticeContent(pid, audit.tid, materialId, audit.aid);
  385. const records = [{ pid, type: pushType.material, uid: this.ctx.material.user_id, status: auditConst.status.checkNo, content: noticeContent }];
  386. auditors.forEach(audit => {
  387. records.push({ pid, type: pushType.material, uid: audit.aid, status: auditConst.status.checkNo, content: noticeContent });
  388. });
  389. await transaction.insert(this.ctx.service.noticePush.tableName, records);
  390. // 同步期信息
  391. await transaction.update(this.ctx.service.material.tableName, {
  392. id: materialId, status: checkData.checkType,
  393. times: times + 1,
  394. });
  395. // 拷贝新一次审核流程列表
  396. await transaction.insert(this.tableName, auditors);
  397. // 删除material_bills_history信息
  398. await transaction.delete(this.ctx.service.materialBillsHistory.tableName, {
  399. tid: this.ctx.tender.id,
  400. order: this.ctx.material.order,
  401. });
  402. // 微信模板通知
  403. const begin_audit = await this.getDataByCondition({
  404. mid: materialId,
  405. order: 1,
  406. });
  407. const materialInfo = await this.ctx.service.material.getDataById(materialId);
  408. const users = this._.uniq(this._.concat(this._.map(auditors, 'aid'), materialInfo.user_id));
  409. const wechatData = {
  410. qi: materialInfo.order,
  411. status: wxConst.status.back,
  412. tips: wxConst.tips.back,
  413. begin_time: Date.parse(begin_audit.begin_time),
  414. m_tp: this.ctx.helper.round(materialInfo.m_tp, 2),
  415. hs_m_tp: this.ctx.helper.round(this.ctx.helper.mul(materialInfo.m_tp, 1+materialInfo.rate/100), 2),
  416. };
  417. await this.ctx.helper.sendWechat(users, smsTypeConst.const.TC, smsTypeConst.judge.result.toString(), wxConst.template.material, wechatData);
  418. // 计算该审批人最终数据
  419. // await this.ctx.service.stagePay.calcAllStagePays(this.ctx.stage, transaction);
  420. // 复制一份最新数据给原报
  421. // await this.ctx.service.stagePay.copyAuditStagePays(this.ctx.stage, this.ctx.stage.times + 1, 0, transaction);
  422. // 添加短信通知-审批退回提醒功能
  423. // const mobile_array = [];
  424. // const stageInfo = await this.ctx.service.stage.getDataById(stageId);
  425. // const auditList = await this.getAuditors(stageId, stageInfo.times);
  426. // const smsUser1 = await this.ctx.service.projectAccount.getDataById(stageInfo.user_id);
  427. // if (smsUser1.auth_mobile !== '' && smsUser1.auth_mobile !== undefined && smsUser1.sms_type !== '') {
  428. // const smsType = JSON.parse(smsUser1.sms_type);
  429. // if (smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.result.toString()) !== -1) {
  430. // mobile_array.push(smsUser1.auth_mobile);
  431. // }
  432. // }
  433. // for (const user of auditList) {
  434. // const smsUser = await this.ctx.service.projectAccount.getDataById(user.aid);
  435. // if (smsUser.auth_mobile !== '' && smsUser.auth_mobile !== undefined && smsUser.sms_type !== '') {
  436. // const smsType = JSON.parse(smsUser.sms_type);
  437. // if (mobile_array.indexOf(smsUser.auth_mobile) === -1 && smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.result.toString()) !== -1) {
  438. // mobile_array.push(smsUser.auth_mobile);
  439. // }
  440. // }
  441. // }
  442. // if (mobile_array.length > 0) {
  443. // const tenderInfo = await this.ctx.service.tender.getDataById(stageInfo.tid);
  444. // const sms = new SMS(this.ctx);
  445. // const tenderName = await sms.contentChange(tenderInfo.name);
  446. // const content = '【纵横计量支付】' + tenderName + '第' + stageInfo.order + '期,审批退回。';
  447. // sms.send(mobile_array, content);
  448. // }
  449. await transaction.commit();
  450. } catch (err) {
  451. await transaction.rollback();
  452. throw err;
  453. }
  454. }
  455. async _checkNoPre(pid, materialId, checkData, times) {
  456. const time = new Date();
  457. // 整理当前流程审核人状态更新
  458. const audit = await this.getDataByCondition({ mid: materialId, times, status: auditConst.status.checking });
  459. if (!audit || audit.order <= 1) {
  460. throw '审核数据错误';
  461. }
  462. // 添加重新审批后,不能用order-1,取groupby值里的上一个才对
  463. const auditors2 = await this.getAuditGroupByList(materialId, times);
  464. const auditorIndex = await auditors2.findIndex(function(item) {
  465. return item.aid === audit.aid;
  466. });
  467. const preAuditor = auditors2[auditorIndex - 1];
  468. const noticeContent = await this.getNoticeContent(pid, audit.tid, materialId, audit.aid);
  469. const transaction = await this.db.beginTransaction();
  470. try {
  471. // 添加到消息推送表
  472. const records = [{ pid, type: pushType.material, uid: this.ctx.material.user_id, status: auditConst.status.checkNoPre, content: noticeContent }];
  473. auditors2.forEach(audit => {
  474. records.push({ pid, type: pushType.material, uid: audit.aid, status: auditConst.status.checkNoPre, content: noticeContent });
  475. });
  476. await transaction.insert('zh_notice', records);
  477. await transaction.update(this.tableName, { id: audit.id, status: checkData.checkType, opinion: checkData.opinion, end_time: time });
  478. // 顺移气候审核人流程顺序
  479. this.initSqlBuilder();
  480. this.sqlBuilder.setAndWhere('mid', { value: materialId, operate: '=' });
  481. this.sqlBuilder.setAndWhere('order', { value: audit.order, operate: '>' });
  482. this.sqlBuilder.setUpdateData('order', { value: 2, selfOperate: '+' });
  483. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
  484. const data = await transaction.query(sql, sqlParam);
  485. const newAuditors = [];
  486. newAuditors.push({
  487. tid: audit.tid, mid: audit.mid, aid: preAuditor.aid,
  488. times: audit.times, order: audit.order + 1, status: auditConst.status.checking,
  489. begin_time: time,
  490. });
  491. newAuditors.push({
  492. tid: audit.tid, mid: audit.mid, aid: audit.aid,
  493. times: audit.times, order: audit.order + 2, status: auditConst.status.uncheck,
  494. });
  495. // 微信模板通知
  496. const begin_audit = await this.getDataByCondition({
  497. mid: materialId,
  498. order: 1,
  499. });
  500. const materialInfo = await this.ctx.service.material.getDataById(materialId);
  501. const wechatData = {
  502. qi: materialInfo.order,
  503. status: wxConst.status.check,
  504. tips: wxConst.tips.check,
  505. begin_time: Date.parse(begin_audit.begin_time),
  506. m_tp: this.ctx.helper.round(materialInfo.m_tp, 2),
  507. hs_m_tp: this.ctx.helper.round(this.ctx.helper.mul(materialInfo.m_tp, 1+materialInfo.rate/100), 2),
  508. };
  509. await this.ctx.helper.sendWechat(preAuditor.aid, smsTypeConst.const.TC, smsTypeConst.judge.approval.toString(), wxConst.template.material, wechatData);
  510. await transaction.insert(this.tableName, newAuditors);
  511. await transaction.commit();
  512. } catch (error) {
  513. await transaction.rollback();
  514. throw error;
  515. }
  516. }
  517. /**
  518. * 审批
  519. * @param {Number} materialId - 材料调差期id
  520. * @param {auditConst.status.checked|auditConst.status.checkNo} checkType - 审批结果
  521. * @param {Number} times - 第几次审批
  522. * @return {Promise<void>}
  523. */
  524. async check(materialId, checkData, times = 1) {
  525. if (checkData.checkType !== auditConst.status.checked && checkData.checkType !== auditConst.status.checkNo && checkData.checkType !== auditConst.status.checkNoPre) {
  526. throw '提交数据错误';
  527. }
  528. const pid = this.ctx.session.sessionProject.id;
  529. switch (checkData.checkType) {
  530. case auditConst.status.checked:
  531. await this._checked(pid, materialId, checkData, times);
  532. break;
  533. case auditConst.status.checkNo:
  534. await this._checkNo(pid, materialId, checkData, times);
  535. break;
  536. case auditConst.status.checkNoPre:
  537. await this._checkNoPre(pid, materialId, checkData, times);
  538. break;
  539. default:
  540. throw '无效审批操作';
  541. }
  542. }
  543. /**
  544. * 用于添加推送所需的content内容
  545. * @param {Number} pid 项目id
  546. * @param {Number} tid 台账id
  547. * @param {Number} mid 期id
  548. * @param {Number} uid 审批人id
  549. */
  550. async getNoticeContent(pid, tid, mid, uid) {
  551. const noticeSql = 'SELECT * FROM (SELECT ' +
  552. ' t.`id` As `tid`, ma.`mid`, t.`name`, m.`order`, pa.`name` As `su_name`, pa.role As `su_role`' +
  553. ' FROM (SELECT * FROM ?? WHERE `id` = ? ) As t' +
  554. ' LEFT JOIN ?? As m On t.`id` = m.`tid` AND m.`id` = ?' +
  555. ' LEFT JOIN ?? As ma ON m.`id` = ma.`mid`' +
  556. ' LEFT JOIN ?? As pa ON pa.`id` = ?' +
  557. ' WHERE t.`project_id` = ? ) as new_t GROUP BY new_t.`tid`';
  558. const noticeSqlParam = [this.ctx.service.tender.tableName, tid, this.ctx.service.material.tableName, mid, this.tableName, this.ctx.service.projectAccount.tableName, uid, pid];
  559. const content = await this.db.query(noticeSql, noticeSqlParam);
  560. return content.length ? JSON.stringify(content[0]) : '';
  561. }
  562. /**
  563. * 审批
  564. * @param {Number} materialId - 材料调差期id
  565. * @param {Number} times - 第几次审批
  566. * @return {Promise<void>}
  567. */
  568. async checkAgain(materialId, times = 1) {
  569. const time = new Date();
  570. // 整理当前流程审核人状态更新
  571. const audit = (await this.getAllDataByCondition({ where: { mid: materialId, times }, orders: [['order', 'desc']], limit: 1, offset: 0 }))[0];
  572. if (!audit || audit.order <= 1) {
  573. throw '审核数据错误';
  574. }
  575. const transaction = await this.db.beginTransaction();
  576. try {
  577. // 当前审批人2次添加至流程中
  578. const newAuditors = [];
  579. newAuditors.push({
  580. tid: audit.tid, mid: audit.mid, aid: audit.aid,
  581. times: audit.times, order: audit.order + 1, status: auditConst.status.checkAgain,
  582. begin_time: time, end_time: time, opinion: '',
  583. });
  584. newAuditors.push({
  585. tid: audit.tid, mid: audit.mid, aid: audit.aid,
  586. times: audit.times, order: audit.order + 2, status: auditConst.status.checking,
  587. begin_time: time,
  588. });
  589. await transaction.insert(this.tableName, newAuditors);
  590. // 复制一份最新数据给下一人
  591. // await this.ctx.service.stagePay.copyAuditStagePays(this.ctx.stage, this.ctx.stage.times, audit.order + 2, transaction);
  592. // 本期结束
  593. // 生成截止本期数据 final数据
  594. // await this.ctx.service.stageBillsFinal.delGenerateFinalData(transaction, this.ctx.tender, this.ctx.stage);
  595. // await this.ctx.service.stagePosFinal.delGenerateFinalData(transaction, this.ctx.tender, this.ctx.stage);
  596. // 同步 期信息
  597. await transaction.update(this.ctx.service.material.tableName, {
  598. id: materialId, status: auditConst.status.checking,
  599. });
  600. // // 添加短信通知-需要审批提醒功能
  601. // const smsUser = await this.ctx.service.projectAccount.getDataById(audit.aid);
  602. // if (smsUser.auth_mobile !== undefined && smsUser.sms_type !== '') {
  603. // const smsType = JSON.parse(smsUser.sms_type);
  604. // if (smsType[smsTypeConst.const.JL] !== undefined && smsType[smsTypeConst.const.JL].indexOf(smsTypeConst.judge.approval.toString()) !== -1) {
  605. // const tenderInfo = await this.ctx.service.tender.getDataById(audit.tid);
  606. // const stageInfo = await this.ctx.service.stage.getDataById(audit.sid);
  607. // const sms = new SMS(this.ctx);
  608. // const tenderName = await sms.contentChange(tenderInfo.name);
  609. // const content = '【纵横计量支付】' + tenderName + '第' + stageInfo.order + '期,需要您审批。';
  610. // sms.send(smsUser.auth_mobile, content);
  611. // }
  612. // }
  613. await transaction.commit();
  614. } catch (err) {
  615. await transaction.rollback();
  616. throw err;
  617. }
  618. }
  619. /**
  620. * 获取审核人需要审核的期列表
  621. *
  622. * @param auditorId
  623. * @return {Promise<*>}
  624. */
  625. async getAuditMaterial(auditorId) {
  626. const sql = 'SELECT ma.`aid`, ma.`times`, ma.`order`, ma.`begin_time`, ma.`end_time`, ma.`tid`, ma.`mid`,' +
  627. ' m.`order` As `morder`, m.`status` As `mstatus`,' +
  628. ' t.`name`, t.`project_id`, t.`type`, t.`user_id` ' +
  629. ' FROM ?? AS ma, ?? AS m, ?? As t ' +
  630. ' WHERE ((ma.`aid` = ? and ma.`status` = ?) OR (m.`user_id` = ? and ma.`status` = ? and m.`status` = ? and ma.`times` = (m.`times`-1)))' +
  631. ' and ma.`mid` = m.`id` and ma.`tid` = t.`id` ORDER BY ma.`begin_time` DESC';
  632. const sqlParam = [this.tableName, this.ctx.service.material.tableName, this.ctx.service.tender.tableName, auditorId, auditConst.status.checking, auditorId, auditConst.status.checkNo, auditConst.status.checkNo];
  633. return await this.db.query(sql, sqlParam);
  634. }
  635. /**
  636. * 获取 某时间后 审批进度 更新的期
  637. * @param {Number} pid - 查询标段
  638. * @param {Number} uid - 查询人
  639. * @param {Date} time - 查询时间
  640. * @return {Promise<*>}
  641. */
  642. async getNoticeMaterial(pid, uid, time) {
  643. // const sql = 'SELECT * FROM (SELECT t.`name`, t.`project_id`, t.`type`, t.`user_id`, ' +
  644. // ' m.`order` As `m_order`, m.`status` As `m_status`, ' +
  645. // ' ma.`aid`, ma.`times`, ma.`order`, ma.`end_time`, ma.`tid`, ma.`mid`, ma.`status`, ' +
  646. // ' pa.`name` As `su_name`, pa.role As `su_role`, pa.company As `su_company`' +
  647. // ' FROM (SELECT * FROM ?? WHERE `user_id` = ? OR `id` in (SELECT `tid` FROM ?? WHERE `aid` = ? GROUP BY `tid`)) As t' +
  648. // ' LEFT JOIN ?? As m On t.`id` = m.`tid`' +
  649. // ' LEFT JOIN ?? As ma ON m.`id` = ma.`mid`' +
  650. // ' LEFT JOIN ?? As pa ON ma.`aid` = pa.`id`' +
  651. // ' WHERE ma.`end_time` > ? and t.`project_id` = ?' +
  652. // ' ORDER By ma.`end_time` DESC LIMIT 1000) as new_t GROUP BY new_t.`tid`' +
  653. // ' ORDER BY new_t.`end_time`';
  654. // const sqlParam = [this.ctx.service.tender.tableName, uid, this.tableName, uid, this.ctx.service.material.tableName, this.tableName,
  655. // this.ctx.service.projectAccount.tableName, time, pid];
  656. // return await this.db.query(sql, sqlParam);
  657. let notice = await this.db.select('zh_notice', {
  658. where: { pid, type: pushType.material, uid },
  659. orders: [['create_time', 'desc']],
  660. limit: 10, offset: 0,
  661. });
  662. notice = notice.map(v => {
  663. const extra = JSON.parse(v.content);
  664. delete v.content;
  665. return { ...v, ...extra };
  666. });
  667. return notice;
  668. }
  669. /**
  670. * 获取审核人流程列表
  671. *
  672. * @param auditorId
  673. * @return {Promise<*>}
  674. */
  675. async getAuditGroupByList(materialId, times) {
  676. const sql = 'SELECT la.`aid`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`mid`, la.`aid`, la.`order` ' +
  677. 'FROM ?? AS la, ?? AS pa ' +
  678. 'WHERE la.`mid` = ? and la.`times` = ? and la.`aid` = pa.`id` GROUP BY la.`aid` ORDER BY la.`order`';
  679. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, materialId, times];
  680. return await this.db.query(sql, sqlParam);
  681. }
  682. /**
  683. * 获取审核人流程列表(包括原报)
  684. * @param {Number} materialId 调差id
  685. * @param {Number} times 审核次数
  686. * @return {Promise<Array>} 查询结果集(包括原报)
  687. */
  688. async getAuditorsWithOwner(materialId, times = 1) {
  689. const result = await this.getAuditGroupByList(materialId, times);
  690. const sql =
  691. 'SELECT pa.`id` As aid, pa.`name`, pa.`company`, pa.`role`, ? As times, ? As mid, 0 As `order`' +
  692. ' FROM ' +
  693. this.ctx.service.material.tableName +
  694. ' As s' +
  695. ' LEFT JOIN ' +
  696. this.ctx.service.projectAccount.tableName +
  697. ' As pa' +
  698. ' ON s.user_id = pa.id' +
  699. ' WHERE s.id = ?';
  700. const sqlParam = [times, materialId, materialId];
  701. const user = await this.db.queryOne(sql, sqlParam);
  702. result.unshift(user);
  703. return result;
  704. }
  705. /**
  706. * 复制上一期的审批人列表给最新一期
  707. *
  708. * @param transaction - 新增一期的事务
  709. * @param {Object} preMaterial - 上一期
  710. * @param {Object} newaMaterial - 最新一期
  711. * @return {Promise<*>}
  712. */
  713. async copyPreMaterialAuditors(transaction, preMaterial, newMaterial) {
  714. const auditors = await this.getAuditGroupByList(preMaterial.id, preMaterial.times);
  715. const newAuditors = [];
  716. for (const a of auditors) {
  717. const na = {
  718. tid: preMaterial.tid,
  719. mid: newMaterial.id,
  720. aid: a.aid,
  721. times: newMaterial.times,
  722. order: newAuditors.length + 1,
  723. status: auditConst.status.uncheck,
  724. };
  725. newAuditors.push(na);
  726. }
  727. const result = await transaction.insert(this.tableName, newAuditors);
  728. return result.affectedRows === auditors.length;
  729. }
  730. /**
  731. * 移除审核人
  732. *
  733. * @param {Number} materialId - 材料调差期id
  734. * @param {Number} status - 期状态
  735. * @param {Number} status - 期次数
  736. * @return {Promise<boolean>}
  737. */
  738. async getAuditorByStatus(materialId, status, times = 1) {
  739. let auditor = null;
  740. let sql = '';
  741. let sqlParam = '';
  742. switch (status) {
  743. case auditConst.status.checking :
  744. case auditConst.status.checked :
  745. case auditConst.status.checkNoPre :
  746. sql = 'SELECT la.`aid`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`mid`, la.`aid`, la.`order` ' +
  747. 'FROM ?? AS la, ?? AS pa ' +
  748. 'WHERE la.`mid` = ? and la.`status` = ? and la.`aid` = pa.`id` order by la.`times` desc, la.`order` desc';
  749. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, materialId, status];
  750. auditor = await this.db.queryOne(sql, sqlParam);
  751. break;
  752. case auditConst.status.checkNo :
  753. sql = 'SELECT la.`aid`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`mid`, la.`aid`, la.`order` ' +
  754. 'FROM ?? AS la, ?? AS pa ' +
  755. 'WHERE la.`mid` = ? and la.`status` = ? and la.`times` = ? and la.`aid` = pa.`id` order by la.`times` desc, la.`order` desc';
  756. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, materialId, auditConst.status.checkNo, parseInt(times) - 1];
  757. auditor = await this.db.queryOne(sql, sqlParam);
  758. break;
  759. case auditConst.status.uncheck :
  760. default:break;
  761. }
  762. return auditor;
  763. }
  764. async getAllAuditors(tenderId) {
  765. const sql = 'SELECT ma.aid, ma.tid FROM ' + this.tableName + ' ma' +
  766. ' LEFT JOIN ' + this.ctx.service.tender.tableName + ' t On ma.tid = t.id' +
  767. ' WHERE t.id = ?' +
  768. ' GROUP BY ma.aid';
  769. const sqlParam = [tenderId];
  770. return this.db.query(sql, sqlParam);
  771. }
  772. }
  773. return MaterialAudit;
  774. };