pay_order.js 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  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.order]);
  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. doCompleteTest(tenderId);
  36. } else {
  37. doComplete()
  38. }