tender_cache.js 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const { app, assert } = require('egg-mock/bootstrap');
  10. // const completeTenderCache = async function () {
  11. // const ctx = app.mockContext();
  12. // const tenders = await ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > 0');
  13. // console.log(tenders.length);
  14. // for (const t of tenders) {
  15. // await ctx.service.tenderCache.refreshTenderCache(t);
  16. // console.log(`complete ${t.name}(${t.id})`);
  17. // }
  18. // };
  19. // completeTenderCache();
  20. // const depart = 100;
  21. // describe('refreshTenderCache.js', () => {
  22. // it('refreshTenderCache', function* () {
  23. // let ctx = app.mockContext();
  24. // const lastTender = yield ctx.app.mysql.queryOne(`Select * From zh_tender WHERE id > 0 ORDER By id DESC`);
  25. // let iBegin = 0;
  26. // while (iBegin < lastTender.id) {
  27. // ctx = app.mockContext();
  28. // const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', [iBegin, iBegin+depart]);
  29. // for (const t of tenders) {
  30. // yield ctx.service.tenderCache.refreshTenderCache(t);
  31. // console.log(`complete ${t.name}(${t.id})`);
  32. // }
  33. // iBegin = iBegin + depart;
  34. // }
  35. // });
  36. // });
  37. const iBegin = 0;
  38. //const iBegin = 5000;
  39. //const iBegin = 10000;
  40. const tenderRange = [
  41. [iBegin + 0, iBegin + 500],
  42. [iBegin + 500, iBegin + 1000],
  43. [iBegin + 1000, iBegin + 1500],
  44. [iBegin + 1500, iBegin + 2000],
  45. [iBegin + 2000, iBegin + 2500],
  46. [iBegin + 2500, iBegin + 3000],
  47. [iBegin + 3000, iBegin + 3500],
  48. [iBegin + 3500, iBegin + 4000],
  49. [iBegin + 4000, iBegin + 4500],
  50. [iBegin + 4500, iBegin + 5000]
  51. ];
  52. describe('refreshTenderCache.js', () => {
  53. it('refreshTenderCache', function* () {
  54. const ctx = app.mockContext();
  55. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[0]);
  56. console.log(tenderRange[0], tenders.length);
  57. for (const t of tenders) {
  58. yield ctx.service.tenderCache.refreshTenderCache(t);
  59. console.log(`complete ${t.name}(${t.id})`);
  60. }
  61. });
  62. it('refreshTenderCache', function* () {
  63. const ctx = app.mockContext();
  64. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[1]);
  65. console.log(tenderRange[1], tenders.length);
  66. for (const t of tenders) {
  67. yield ctx.service.tenderCache.refreshTenderCache(t);
  68. console.log(`complete ${t.name}(${t.id})`);
  69. }
  70. });
  71. it('refreshTenderCache', function* () {
  72. const ctx = app.mockContext();
  73. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[2]);
  74. console.log(tenderRange[2], tenders.length);
  75. for (const t of tenders) {
  76. yield ctx.service.tenderCache.refreshTenderCache(t);
  77. console.log(`complete ${t.name}(${t.id})`);
  78. }
  79. });
  80. it('refreshTenderCache', function* () {
  81. const ctx = app.mockContext();
  82. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[3]);
  83. console.log(tenderRange[3], tenders.length);
  84. for (const t of tenders) {
  85. yield ctx.service.tenderCache.refreshTenderCache(t);
  86. console.log(`complete ${t.name}(${t.id})`);
  87. }
  88. });
  89. it('refreshTenderCache', function* () {
  90. const ctx = app.mockContext();
  91. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[4]);
  92. console.log(tenderRange[4], tenders.length);
  93. for (const t of tenders) {
  94. yield ctx.service.tenderCache.refreshTenderCache(t);
  95. console.log(`complete ${t.name}(${t.id})`);
  96. }
  97. });
  98. it('refreshTenderCache', function* () {
  99. const ctx = app.mockContext();
  100. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[5]);
  101. console.log(tenderRange[5], tenders.length);
  102. for (const t of tenders) {
  103. yield ctx.service.tenderCache.refreshTenderCache(t);
  104. console.log(`complete ${t.name}(${t.id})`);
  105. }
  106. });
  107. it('refreshTenderCache', function* () {
  108. const ctx = app.mockContext();
  109. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[6]);
  110. console.log(tenderRange[6], tenders.length);
  111. for (const t of tenders) {
  112. yield ctx.service.tenderCache.refreshTenderCache(t);
  113. console.log(`complete ${t.name}(${t.id})`);
  114. }
  115. });
  116. it('refreshTenderCache', function* () {
  117. const ctx = app.mockContext();
  118. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[7]);
  119. console.log(tenderRange[7], tenders.length);
  120. for (const t of tenders) {
  121. yield ctx.service.tenderCache.refreshTenderCache(t);
  122. console.log(`complete ${t.name}(${t.id})`);
  123. }
  124. });
  125. it('refreshTenderCache', function* () {
  126. const ctx = app.mockContext();
  127. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[8]);
  128. console.log(tenderRange[8], tenders.length);
  129. for (const t of tenders) {
  130. yield ctx.service.tenderCache.refreshTenderCache(t);
  131. console.log(`complete ${t.name}(${t.id})`);
  132. }
  133. });
  134. it('refreshTenderCache', function* () {
  135. const ctx = app.mockContext();
  136. const tenders = yield ctx.app.mysql.query('SELECT * FROM zh_tender WHERE id > ? and id <= ?', tenderRange[9]);
  137. console.log(tenderRange[9], tenders.length);
  138. for (const t of tenders) {
  139. yield ctx.service.tenderCache.refreshTenderCache(t);
  140. console.log(`complete ${t.name}(${t.id})`);
  141. }
  142. });
  143. });