소스 검색

截止本期数据,缓存机制调整

MaiXinRong 2 년 전
부모
커밋
748d2edf0f
4개의 변경된 파일4개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      app/service/stage.js
  2. 1 0
      app/service/stage_bills_final.js
  3. 1 0
      app/service/stage_change_final.js
  4. 1 0
      app/service/stage_pos_final.js

+ 1 - 0
app/service/stage.js

@@ -545,6 +545,7 @@ module.exports = app => {
                 await transaction.delete(this.ctx.service.stageAudit.tableName, { sid: id });
                 await transaction.delete(this.ctx.service.stageBills.tableName, { sid: id });
                 await transaction.delete(this.ctx.service.stageChange.tableName, { sid: id });
+                await transaction.delete(this.ctx.service.stageChangeFinal.tableName, { sid: id });
                 await transaction.delete(this.ctx.service.stageImportChange.tableName, { sid: id });
                 await transaction.delete(this.ctx.service.stagePos.tableName, { sid: id });
                 await transaction.delete(this.ctx.service.stageDetail.tableName, { sid: id });

+ 1 - 0
app/service/stage_bills_final.js

@@ -108,6 +108,7 @@ module.exports = app => {
                 p.sid = stage.id;
                 p.sorder = stage.order;
             }
+            await transaction.delete(this.tableName, { tid: tender.id, sid: stage.id });
             await transaction.insert(this.tableName, cur ? cur.concat(pre) : pre);
         }
 

+ 1 - 0
app/service/stage_change_final.js

@@ -67,6 +67,7 @@ module.exports = app => {
                     qty: c.qty, minus: c.minus, no_value: c.no_value,
                 });
             }
+            await transaction.delete(this.tableName, { tid: tender.id, sid: stage.id });
             if (data.length > 0) await transaction.insert(this.tableName, data);
         }
 

+ 1 - 0
app/service/stage_pos_final.js

@@ -85,6 +85,7 @@ module.exports = app => {
                 p.sid = stage.id;
                 p.sorder = stage.order;
             }
+            await transaction.delete(this.tableName, { tid: tender.id, sid: stage.id });
             await transaction.insert(this.tableName, cur ? cur.concat(pre) : pre);
         }