pay_order.js 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. const BaseUtil = require('./baseUtils');
  2. const querySql = BaseUtil.querySql;
  3. const checkPayOrder = async function (tid) {
  4. const pays = await querySql('SELECT * FROM zh_pay WHERE tid = ? and valid = 1 order by `order`', [tid]);
  5. for (const [i, pay] of pays.entries()) {
  6. if (pay.order !== i + 1) await querySql('Update zh_pay Set `order` = ? Where id = ?', [i+1, pay.id]);
  7. }
  8. };
  9. const doComplete = async function() {
  10. try {
  11. const tender = await querySql('Select * From zh_tender');
  12. for (const t of tender) {
  13. console.log(`Update Tender ${t.id}`);
  14. await checkPayOrder(t.id);
  15. }
  16. } catch (err) {
  17. console.log(err);
  18. }
  19. BaseUtil.closePool();
  20. };
  21. const doCompleteTest = async function(tid) {
  22. try {
  23. const tender = await querySql('Select * From zh_tender where id = ?', [tid]);
  24. for (const t of tender) {
  25. console.log(`Update Tender ${t.id}`);
  26. await checkPayOrder(t.id);
  27. }
  28. } catch (err) {
  29. console.log(err);
  30. }
  31. BaseUtil.closePool();
  32. };
  33. const tenderId = process.argv[3];
  34. if (tenderId) {
  35. console.log(tenderId);
  36. doCompleteTest(tenderId);
  37. } else {
  38. doComplete()
  39. }