test_query.js 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738
  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 stage = await querySql('SELECT * FROM zh_stage where tid = ? and `order` = ?', [tid, sOrder]);
  13. const rptArchive = await querySql('SELECT * FROM zh_rpt_archive where stage_id = ?', [stage[0].id]);
  14. for (const ra of rptArchive) {
  15. ra.content = ra.content ? JSON.parse(ra.content) : [];
  16. console.log(BaseUtil.getFileName('rptArchive.json'));
  17. await saveJSON(ra, BaseUtil.getFileName('rptArchive.json'));
  18. }
  19. const rptSign = await querySql('SELECT* FROM zh_rpt_archive_encryption where stage_id = ?', [stage[0].id]);
  20. for (const rs of rptSign) {
  21. rs.content = rs.content ? JSON.parse(rs.content) : [];
  22. await saveJSON(rs, BaseUtil.getFileName('rptSign.json'));
  23. }
  24. };
  25. const doCompleteTest = async function() {
  26. try {
  27. await loadReportArchiveData();
  28. } catch (err) {
  29. console.log(err);
  30. }
  31. BaseUtil.closePool();
  32. };
  33. doCompleteTest();