Parcourir la source

其他台账,截止数据计算问题

MaiXinRong il y a 5 ans
Parent
commit
87653571e9
1 fichiers modifiés avec 11 ajouts et 2 suppressions
  1. 11 2
      app/service/stage_other.js

+ 11 - 2
app/service/stage_other.js

@@ -37,14 +37,22 @@ module.exports = app => {
         }
 
         async getPreStageData(sorder) {
-            const sql = 'SELECT uuid, Sum(tp) as tp From ' + this.tableName + ' WHERE sorder < ? And tid = ? GROUP By uuid';
+            const sql = 'SELECT o.uuid, Sum(o.tp) as tp ' +
+                '  From ' + this.tableName + ' o ' +
+                '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON s.id = o.sid' +
+                '  WHERE s.order < ? And o.tid = ?' +
+                '  GROUP By uuid';
             const sqlParam = [sorder, this.ctx.tender.id];
             const data = await this.db.query(sql, sqlParam);
             return data;
         }
 
         async getEndStageData(sorder) {
-            const sql = 'SELECT uuid, Sum(tp) as tp From' + this.tableName + ' WHERE sorder <= ? And tid = ? GROUP By uuid';
+            const sql = 'SELECT o.uuid, Sum(o.tp) as tp ' +
+                '  From ' + this.tableName + ' o ' +
+                '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON s.id = o.sid' +
+                '  WHERE s.order <= ? And o.tid = ?' +
+                '  GROUP By uuid';
             const sqlParam = [sorder, this.ctx.tender.id];
             const data = await this.db.query(sql, sqlParam);
             return data;
@@ -179,6 +187,7 @@ module.exports = app => {
                     pd.pre_used = pd.pre_used || !this.ctx.helper.checkZero(pd.tp);
                     delete pd.tp;
                     pd.sid = stage.id;
+                    pd.sorder = stage.order;
                 }
                 const result = await transaction.insert(this.tableName, preDatas);
                 return result.affectedRows === preDatas.length;