test_query.js 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. // 计算变更令,正负变更数
  2. const defaultInfo = require('../app/const/tender_info');
  3. const BaseUtil = require('./baseUtils');
  4. const querySql = BaseUtil.querySql;
  5. const ZhCalc = BaseUtil.ZhCalc;
  6. const saveJSON = async function(obj, file) {
  7. let defineStr = JSON.stringify(obj, '', '\t');
  8. await BaseUtil.saveBufferFile(defineStr, file);
  9. };
  10. const loadReportArchiveData = async function() {
  11. //const tid = 4417, sOrder = 2;
  12. const tid = 3698, sOrder = 7;
  13. const stage = await querySql('SELECT * FROM zh_stage where tid = ? and `order` = ?', [tid, sOrder]);
  14. const rptArchive = await querySql('SELECT * FROM zh_rpt_archive where stage_id = ?', [stage[0].id]);
  15. for (const ra of rptArchive) {
  16. ra.content = ra.content ? JSON.parse(ra.content) : [];
  17. console.log(BaseUtil.getFileName('rptArchive.json'));
  18. await saveJSON(ra, BaseUtil.getFileName('rptArchive.json'));
  19. }
  20. const rptSign = await querySql('SELECT* FROM zh_rpt_archive_encryption where stage_id = ?', [stage[0].id]);
  21. for (const rs of rptSign) {
  22. rs.content = rs.content ? JSON.parse(rs.content) : [];
  23. console.log(BaseUtil.getFileName('rptSign.json'));
  24. await saveJSON(rs, BaseUtil.getFileName('rptSign.json'));
  25. }
  26. };
  27. const doCompleteTest = async function() {
  28. try {
  29. await loadReportArchiveData();
  30. } catch (err) {
  31. console.log(err);
  32. }
  33. BaseUtil.closePool();
  34. };
  35. doCompleteTest();