|
|
@@ -0,0 +1,109 @@
|
|
|
+const BaseUtil = require('./baseUtils');
|
|
|
+const querySql = BaseUtil.querySql;
|
|
|
+const sp_status = {
|
|
|
+ sqspr: 1, // 授权审批人
|
|
|
+ gdspl: 2, // 固定审批流
|
|
|
+ gdzs: 3, // 固定终审
|
|
|
+};
|
|
|
+// 审批类型
|
|
|
+const sp_type = {
|
|
|
+ advance: 1,
|
|
|
+ ledger: 2,
|
|
|
+ revise: 3,
|
|
|
+ stage: 4,
|
|
|
+ change: 5,
|
|
|
+ material: 6,
|
|
|
+};
|
|
|
+
|
|
|
+const errorStageTimes = [];
|
|
|
+
|
|
|
+const updateShenpiAudit = async function (tender, type) {
|
|
|
+ const shenpiData = await querySql('Select * From zh_shenpi_audit where tid = ? AND sp_type = ? AND sp_status = ? ORDER BY id', [tender.id, type, sp_status.gdspl]);
|
|
|
+ if (shenpiData.length === 0) return;
|
|
|
+
|
|
|
+ for (const [i, spd] of shenpiData.entries()) {
|
|
|
+ if (spd.audit_order > 0) continue;
|
|
|
+ await querySql('UPDATE zh_shenpi_audit SET audit_order = ? WHERE id = ?', [i+1, spd.id]);
|
|
|
+ }
|
|
|
+};
|
|
|
+
|
|
|
+const updateShenpi = async function (tender) {
|
|
|
+ updateShenpiAudit(tender, sp_type.advance);
|
|
|
+ updateShenpiAudit(tender, sp_type.ledger);
|
|
|
+ updateShenpiAudit(tender, sp_type.revise);
|
|
|
+ updateShenpiAudit(tender, sp_type.stage);
|
|
|
+ updateShenpiAudit(tender, sp_type.change);
|
|
|
+ updateShenpiAudit(tender, sp_type.material);
|
|
|
+};
|
|
|
+
|
|
|
+const updateStageTimes = async function (stage, times) {
|
|
|
+ const auditData = await querySql('SELECT * FROM zh_stage_audit WHERE sid = ? AND times = ? ORDER BY `order`', [stage.id, times]);
|
|
|
+ if (auditData.length === 0) return;
|
|
|
+
|
|
|
+ const auditIds = [], filterIds = [];
|
|
|
+ for (const ad of auditData) {
|
|
|
+ if (ad.audit_order) {
|
|
|
+ if (filterIds.indexOf(ad.aid) < 0) filterIds.push(ad.aid);
|
|
|
+ } else if (auditIds.indexOf(ad.aid) < 0) auditIds.push(ad.aid);
|
|
|
+ }
|
|
|
+ if (auditIds.length === 0) return;
|
|
|
+ if (filterIds.length > 0 && auditIds.length > 0) errorStageTimes.push({ tid: stage.tid, sid: stage.id, times });
|
|
|
+ for (const [i, aid] of auditIds.entries()) {
|
|
|
+ await querySql('UPDATE zh_stage_audit SET audit_order = ? WHERE sid = ? AND times = ? AND aid = ?', [i+1, stage.id, times, aid]);
|
|
|
+ }
|
|
|
+};
|
|
|
+
|
|
|
+const updateStage = async function (stage) {
|
|
|
+ for (let i = 1; i <= stage.times; i++) {
|
|
|
+ await updateStageTimes(stage, i);
|
|
|
+ }
|
|
|
+};
|
|
|
+
|
|
|
+const doCompleteTest = async function(id) {
|
|
|
+ try {
|
|
|
+ const tender = await querySql('Select * From zh_tender where id = ?', [id]);
|
|
|
+ for (const t of tender) {
|
|
|
+ console.log(`Update Tender ${t.name}(${t.id}):`);
|
|
|
+ await updateShenpi(t);
|
|
|
+ const stages = await querySql('Select * From zh_stage where tid = ?', [t.id]);
|
|
|
+ for (const s of stages) {
|
|
|
+ await updateStage(s);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (err) {
|
|
|
+ console.log(err);
|
|
|
+ }
|
|
|
+ BaseUtil.closePool();
|
|
|
+ if (errorStageTimes.length > 0) {
|
|
|
+ console.log('ERROR stage info: ');
|
|
|
+ console.log(errorStageTimes);
|
|
|
+ }
|
|
|
+};
|
|
|
+
|
|
|
+const doComplete = async function() {
|
|
|
+ try {
|
|
|
+ const tenders = await querySql('Select * From zh_tender');
|
|
|
+ for (const t of tenders) {
|
|
|
+ console.log(`Update Tender ${t.name}(${t.id}):`);
|
|
|
+ await updateShenpi(t);
|
|
|
+ const stages = await querySql('Select * From zh_stage where tid = ?', [t.id]);
|
|
|
+ for (const s of stages) {
|
|
|
+ await updateStage(s);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (err) {
|
|
|
+ console.log(err);
|
|
|
+ }
|
|
|
+ BaseUtil.closePool();
|
|
|
+ if (errorStageTimes.length > 0) {
|
|
|
+ console.log('ERROR stage info: ');
|
|
|
+ console.log(errorStageTimes);
|
|
|
+ }
|
|
|
+};
|
|
|
+
|
|
|
+const tenderId = process.argv[3];
|
|
|
+if (tenderId) {
|
|
|
+ doCompleteTest(tenderId);
|
|
|
+} else {
|
|
|
+ doComplete()
|
|
|
+}
|
