ledger_cooperation.js 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2018/6/1
  7. * @version
  8. */
  9. module.exports = app => {
  10. class LedgerCooperation extends app.BaseService {
  11. /**
  12. * 构造函数
  13. *
  14. * @param {Object} ctx - egg全局变量
  15. * @return {void}
  16. */
  17. constructor(ctx) {
  18. super(ctx);
  19. this.tableName = 'ledger_cooperation';
  20. }
  21. async save(data) {
  22. delete data.type;
  23. data.tid = this.ctx.tender.id;
  24. const info = await this.getDataByCondition({ tid: this.ctx.tender.id, ledger_id: data.ledger_id, user_id: data.user_id });
  25. if (data.pwd === '' && info) {
  26. await this.deleteById(info.id);
  27. } else if (data.pwd !== '' && !info) {
  28. const result = await this.db.insert(this.tableName, data);
  29. data.id = result.insertId;
  30. } else if (data.pwd !== '' && info) {
  31. data.id = info.id;
  32. await this.db.update(this.tableName, data);
  33. }
  34. return data;
  35. }
  36. async changeAllStatus(status) {
  37. const options = {
  38. where: {
  39. tid: this.ctx.tender.id,
  40. },
  41. };
  42. const updateData = {
  43. status,
  44. };
  45. return await this.db.update(this.ctx.service.ledgerCooperation.tableName, updateData, options);
  46. }
  47. async saveSign(id, path) {
  48. const updateData = {
  49. id,
  50. sign_path: path,
  51. };
  52. return await this.db.update(this.tableName, updateData);
  53. }
  54. async getValidData(tid, uid) {
  55. const condition = { where: { tid, status: 1 } };
  56. if (uid) {
  57. condition.where.user_id = uid;
  58. condition.colums = ['ledger_id', 'pwd'];
  59. }
  60. return await this.getAllDataByCondition(condition);
  61. }
  62. }
  63. return LedgerCooperation;
  64. };