signature_used.js 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. 'use strict';
  2. /**
  3. * Created by EllisRan on 2020/3/3.
  4. */
  5. const BaseService = require('../base/base_service');
  6. module.exports = app => {
  7. class SignatureUsed extends BaseService {
  8. /**
  9. * 构造函数
  10. *
  11. * @param {Object} ctx - egg全局变量
  12. * @return {void}
  13. */
  14. constructor(ctx) {
  15. super(ctx);
  16. this.tableName = 'signature_used';
  17. this.dataId = 'id';
  18. }
  19. async getSignatureUsedByTenderId(tenderId) {
  20. this.initSqlBuilder();
  21. this.sqlBuilder.setAndWhere('tender_id', {
  22. value: tenderId,
  23. operate: '=',
  24. });
  25. // this.sqlBuilder.columns = ['id', 'uid', 'prj_id', 'tender_id', 'used_time'];
  26. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  27. const list = await this.db.query(sql, sqlParam);
  28. return list;
  29. }
  30. async updateUsed(data, used_time) {
  31. let rst = null;
  32. this.transaction = await this.db.beginTransaction();
  33. try {
  34. const used = await this.getDataByCondition({ uid: data.uid, prj_id: data.prj_id, tender_id: data.tender_id });
  35. if (!used) {
  36. const insertData = {
  37. uid: data.uid,
  38. prj_id: data.prj_id,
  39. tender_id: data.tender_id,
  40. used_time,
  41. };
  42. rst = await this.transaction.insert(this.tableName, insertData);
  43. } else {
  44. const updateData = {
  45. id: used.id,
  46. used_time,
  47. };
  48. rst = await this.transaction.insert(this.tableName, updateData);
  49. }
  50. await this.transaction.commit();
  51. } catch (ex) {
  52. console.log(ex);
  53. // 回滚
  54. await this.transaction.rollback();
  55. }
  56. return rst;
  57. }
  58. }
  59. return SignatureUsed;
  60. };