12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849 |
- 'use strict';
- module.exports = app => {
- class ScheduleMonth extends app.BaseService {
- constructor(ctx) {
- super(ctx);
- this.tableName = 'schedule_month';
- }
- async getLastPlanMonth() {
- const sql = 'SELECT `yearmonth` FROM ?? WHERE `tid` = ? ORDER BY `yearmonth` DESC Limit 0,1';
- const sqlParam = [this.tableName, this.ctx.tender.id];
- return await this.db.query(sql, sqlParam);
- }
- async add(data) {
- const transaction = await this.db.beginTransaction();
- try {
- const insertData = [];
- for (const m of data) {
- insertData.push({ tid: this.ctx.tender.id, yearmonth: m });
- }
- if (insertData.length > 0) await transaction.insert(this.tableName, insertData);
- await transaction.commit();
- return true;
- } catch (err) {
- await transaction.rollback();
- throw err;
- }
- }
- async del(data) {
- const transaction = await this.db.beginTransaction();
- try {
- for (const m of data) {
- const delData = { tid: this.ctx.tender.id, yearmonth: m };
- await transaction.delete(this.tableName, delData);
- await transaction.delete(this.ctx.service.scheduleLedgerMonth.tableName, delData);
- }
- await transaction.commit();
- return true;
- } catch (err) {
- await transaction.rollback();
- throw err;
- }
- }
- }
- return ScheduleMonth;
- };
|