rpt_gather_memory.js 91 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const Ledger = require('../lib/ledger');
  10. const PayCalculator = require('../lib/pay_calc');
  11. const auditConst = require('../const/audit');
  12. const payConst = require('../const/deal_pay');
  13. const changeConst = require('../const/change');
  14. const moment = require('moment');
  15. const indexPre = 'id_';
  16. const normalPrefix = 't_', sumPrefix = 's_', specPrefix = 'ts_';
  17. const gatherUtils = {
  18. completeGatherData: function (datas, completeDatas) {
  19. for (const data of datas) {
  20. for (const cd of completeDatas) {
  21. data[cd.prefix + 'id'] = cd.id;
  22. data[cd.prefix + 'name'] = cd.name;
  23. data[cd.prefix + 'category'] = cd.category;
  24. }
  25. }
  26. },
  27. gatherStage: function (tender, gatherNode, sourceNode, prefix, helper) {
  28. gatherNode[prefix + 'id'] = tender.id;
  29. gatherNode[prefix + 'name'] = tender.name;
  30. gatherNode[prefix + 'category'] = tender.category;
  31. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  32. gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
  33. gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
  34. gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);
  35. gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
  36. gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
  37. gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
  38. gatherNode[prefix + "contract_tp"] = helper.add(gatherNode[prefix + "contract_tp"], sourceNode.contract_tp);
  39. gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
  40. gatherNode[prefix + "qc_tp"] = helper.add(gatherNode[prefix + "qc_tp"], sourceNode.qc_tp);
  41. gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
  42. gatherNode[prefix + "gather_tp"] = helper.add(gatherNode[prefix + "gather_tp"], sourceNode.gather_tp);
  43. gatherNode[prefix + 'contract_pc_tp'] = helper.add(gatherNode[prefix + 'contract_pc_tp'], sourceNode.contract_pc_tp);
  44. gatherNode[prefix + 'qc_pc_tp'] = helper.add(gatherNode[prefix + 'qc_pc_tp'], sourceNode.qc_pc_tp);
  45. gatherNode[prefix + 'pc_tp'] = helper.add(gatherNode[prefix + 'pc_tp'], sourceNode.pc_tp);
  46. gatherNode[prefix + "pre_contract_qty"] = helper.add(gatherNode[prefix + "pre_contract_qty"], sourceNode.pre_contract_qty);
  47. gatherNode[prefix + "pre_contract_tp"] = helper.add(gatherNode[prefix + "pre_contract_tp"], sourceNode.pre_contract_tp);
  48. gatherNode[prefix + "pre_qc_qty"] = helper.add(gatherNode[prefix + "pre_qc_qty"], sourceNode.pre_qc_qty);
  49. gatherNode[prefix + "pre_qc_tp"] = helper.add(gatherNode[prefix + "pre_qc_tp"], sourceNode.pre_qc_tp);
  50. gatherNode[prefix + "pre_gather_qty"] = helper.add(gatherNode[prefix + "pre_gather_qty"], sourceNode.pre_gather_qty);
  51. gatherNode[prefix + "pre_gather_tp"] = helper.add(gatherNode[prefix + "pre_gather_tp"], sourceNode.pre_gather_tp);
  52. gatherNode[prefix + "end_contract_qty"] = helper.add(gatherNode[prefix + "end_contract_qty"], sourceNode.end_contract_qty);
  53. gatherNode[prefix + "end_contract_tp"] = helper.add(gatherNode[prefix + "end_contract_tp"], sourceNode.end_contract_tp);
  54. gatherNode[prefix + "end_qc_qty"] = helper.add(gatherNode[prefix + "end_qc_qty"], sourceNode.end_qc_qty);
  55. gatherNode[prefix + "end_qc_tp"] = helper.add(gatherNode[prefix + "end_qc_tp"], sourceNode.end_qc_tp);
  56. gatherNode[prefix + "end_gather_qty"] = helper.add(gatherNode[prefix + "end_gather_qty"], sourceNode.end_gather_qty);
  57. gatherNode[prefix + "end_gather_tp"] = helper.add(gatherNode[prefix + "end_gather_tp"], sourceNode.end_gather_tp);
  58. gatherNode[prefix + "deal_dgn_qty1"] = helper.add(gatherNode[prefix + "deal_dgn_qty1"], sourceNode.deal_dgn_qty1);
  59. gatherNode[prefix + "deal_dgn_qty2"] = helper.add(gatherNode[prefix + "deal_dgn_qty2"], sourceNode.deal_dgn_qty2);
  60. gatherNode[prefix + "c_dgn_qty1"] = helper.add(gatherNode[prefix + "c_dgn_qty1"], sourceNode.c_dgn_qty1);
  61. gatherNode[prefix + "c_dgn_qty2"] = helper.add(gatherNode[prefix + "c_dgn_qty2"], sourceNode.c_dgn_qty2);
  62. gatherNode[prefix + "due_qc_qty"] = helper.add(gatherNode[prefix + "due_qc_qty"], sourceNode.due_qc_qty);
  63. gatherNode[prefix + "due_qc_tp"] = helper.add(gatherNode[prefix + "due_qc_tp"], sourceNode.due_qc_tp);
  64. gatherNode[prefix + "due_qc_minus_qty"] = helper.add(gatherNode[prefix + "due_qc_minus_qty"], sourceNode.due_qc_minus_qty);
  65. gatherNode[prefix + "due_final_qty"] = helper.add(gatherNode[prefix + "due_final_qty"], sourceNode.due_final_qty);
  66. gatherNode[prefix + "due_final_tp"] = helper.add(gatherNode[prefix + "due_final_tp"], sourceNode.due_final_tp);
  67. gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
  68. gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
  69. gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
  70. gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
  71. gatherNode.s_dgn_qty1 = helper.add(gatherNode.s_dgn_qty1, sourceNode.dgn_qty1);
  72. gatherNode.s_dgn_qty2 = helper.add(gatherNode.s_dgn_qty2, sourceNode.dgn_qty2);
  73. gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
  74. gatherNode.s_contract_tp = helper.add(gatherNode.s_contract_tp, sourceNode.contract_tp);
  75. gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
  76. gatherNode.s_qc_tp = helper.add(gatherNode.s_qc_tp, sourceNode.qc_tp);
  77. gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
  78. gatherNode.s_gather_tp = helper.add(gatherNode.s_gather_tp, sourceNode.gather_tp);
  79. gatherNode.s_contract_pc_tp = helper.add(gatherNode.s_contract_pc_tp, sourceNode.contract_pc_tp);
  80. gatherNode.s_qc_pc_tp = helper.add(gatherNode.s_qc_pc_tp, sourceNode.qc_pc_tp);
  81. gatherNode.s_pc_tp = helper.add(gatherNode.s_pc_tp, sourceNode.pc_tp);
  82. gatherNode.s_pre_contract_qty = helper.add(gatherNode.s_pre_contract_qty, sourceNode.pre_contract_qty);
  83. gatherNode.s_pre_contract_tp = helper.add(gatherNode.s_pre_contract_tp, sourceNode.pre_contract_tp);
  84. gatherNode.s_pre_qc_qty = helper.add(gatherNode.s_pre_qc_qty, sourceNode.pre_qc_qty);
  85. gatherNode.s_pre_qc_tp = helper.add(gatherNode.s_pre_qc_tp, sourceNode.pre_qc_tp);
  86. gatherNode.s_pre_gather_qty = helper.add(gatherNode.s_pre_gather_qty, sourceNode.pre_gather_qty);
  87. gatherNode.s_pre_gather_tp = helper.add(gatherNode.s_pre_gather_tp, sourceNode.pre_gather_tp);
  88. gatherNode.s_end_contract_qty = helper.add(gatherNode.s_end_contract_qty, sourceNode.end_contract_qty);
  89. gatherNode.s_end_contract_tp = helper.add(gatherNode.s_end_contract_tp, sourceNode.end_contract_tp);
  90. gatherNode.s_end_qc_qty = helper.add(gatherNode.s_end_qc_qty, sourceNode.end_qc_qty);
  91. gatherNode.s_end_qc_tp = helper.add(gatherNode.s_end_qc_tp, sourceNode.end_qc_tp);
  92. gatherNode.s_end_gather_qty = helper.add(gatherNode.s_end_gather_qty, sourceNode.end_gather_qty);
  93. gatherNode.s_end_gather_tp = helper.add(gatherNode.s_end_gather_tp, sourceNode.end_gather_tp);
  94. gatherNode.s_deal_dgn_qty1 = helper.add(gatherNode.s_deal_dgn_qty1, sourceNode.deal_dgn_qty1);
  95. gatherNode.s_deal_dgn_qty2 = helper.add(gatherNode.s_deal_dgn_qty2, sourceNode.deal_dgn_qty2);
  96. gatherNode.s_c_dgn_qty1 = helper.add(gatherNode.s_c_dgn_qty1, sourceNode.c_dgn_qty1);
  97. gatherNode.s_c_dgn_qty2 = helper.add(gatherNode.s_c_dgn_qty2, sourceNode.c_dgn_qty2);
  98. gatherNode.s_due_qc_qty = helper.add(gatherNode.s_due_qc_qty, sourceNode.due_qc_qty);
  99. gatherNode.s_due_qc_tp = helper.add(gatherNode.s_due_qc_tp, sourceNode.due_qc_tp);
  100. gatherNode.s_due_qc_minus_qty = helper.add(gatherNode.s_due_qc_minus_qty, sourceNode.due_qc_minus_qty);
  101. gatherNode.s_due_final_qty = helper.add(gatherNode.s_due_final_qty, sourceNode.due_final_qty);
  102. gatherNode.s_due_final_tp = helper.add(gatherNode.s_due_final_tp, sourceNode.due_final_tp);
  103. },
  104. gatherZone: function (tender, gatherNode, sourceNode, prefix, helper) {
  105. gatherNode[prefix + 'id'] = tender.id;
  106. gatherNode[prefix + 'name'] = tender.name;
  107. gatherNode[prefix + 'category'] = tender.category;
  108. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  109. gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
  110. gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
  111. gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);
  112. gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
  113. gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
  114. gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
  115. gatherNode[prefix + "contract_tp"] = helper.add(gatherNode[prefix + "contract_tp"], sourceNode.contract_tp);
  116. gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
  117. gatherNode[prefix + "qc_tp"] = helper.add(gatherNode[prefix + "qc_tp"], sourceNode.qc_tp);
  118. gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
  119. gatherNode[prefix + "gather_tp"] = helper.add(gatherNode[prefix + "gather_tp"], sourceNode.gather_tp);
  120. gatherNode[prefix + 'pc_tp'] = helper.add(gatherNode[prefix + 'pc_tp'], sourceNode.pc_tp);
  121. gatherNode[prefix + "deal_dgn_qty1"] = helper.add(gatherNode[prefix + "deal_dgn_qty1"], sourceNode.deal_dgn_qty1);
  122. gatherNode[prefix + "deal_dgn_qty2"] = helper.add(gatherNode[prefix + "deal_dgn_qty2"], sourceNode.deal_dgn_qty2);
  123. gatherNode[prefix + "c_dgn_qty1"] = helper.add(gatherNode[prefix + "c_dgn_qty1"], sourceNode.c_dgn_qty1);
  124. gatherNode[prefix + "c_dgn_qty2"] = helper.add(gatherNode[prefix + "c_dgn_qty2"], sourceNode.c_dgn_qty2);
  125. gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
  126. gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
  127. gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
  128. gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
  129. gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
  130. gatherNode.s_contract_tp = helper.add(gatherNode.s_contract_tp, sourceNode.contract_tp);
  131. gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
  132. gatherNode.s_qc_tp = helper.add(gatherNode.s_qc_tp, sourceNode.qc_tp);
  133. gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
  134. gatherNode.s_gather_tp = helper.add(gatherNode.s_gather_tp, sourceNode.gather_tp);
  135. gatherNode.s_pc_tp = helper.add(gatherNode.s_pc_tp, sourceNode.pc_tp);
  136. },
  137. gatherLedger: function (tender, gatherNode, sourceNode, prefix, helper) {
  138. gatherNode[prefix + 'id'] = tender.id;
  139. gatherNode[prefix + 'name'] = tender.name;
  140. gatherNode[prefix + 'category'] = tender.category;
  141. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  142. gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
  143. gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
  144. gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);
  145. gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
  146. gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
  147. gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
  148. gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
  149. gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
  150. gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
  151. },
  152. gatherSpecial: function (gatherNode, sourceNode, prefix, helper) {
  153. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  154. gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
  155. gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
  156. gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
  157. },
  158. gatherStagePos: function (tender, gatherNode, sourceNode, prefix, helper) {
  159. gatherNode[prefix + 'id'] = tender.id;
  160. gatherNode[prefix + 'name'] = tender.name;
  161. gatherNode[prefix + 'category'] = tender.category;
  162. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  163. gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
  164. gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
  165. gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
  166. gatherNode[prefix + "pre_contract_qty"] = helper.add(gatherNode[prefix + "pre_contract_qty"], sourceNode.pre_contract_qty);
  167. gatherNode[prefix + "pre_qc_qty"] = helper.add(gatherNode[prefix + "pre_qc_qty"], sourceNode.pre_qc_qty);
  168. gatherNode[prefix + "pre_gather_qty"] = helper.add(gatherNode[prefix + "pre_gather_qty"], sourceNode.pre_gather_qty);
  169. gatherNode[prefix + "end_contract_qty"] = helper.add(gatherNode[prefix + "end_contract_qty"], sourceNode.end_contract_qty);
  170. gatherNode[prefix + "end_qc_qty"] = helper.add(gatherNode[prefix + "end_qc_qty"], sourceNode.end_qc_qty);
  171. gatherNode[prefix + "end_gather_qty"] = helper.add(gatherNode[prefix + "end_gather_qty"], sourceNode.end_gather_qty);
  172. gatherNode[prefix + "due_qc_qty"] = helper.add(gatherNode[prefix + "due_qc_qty"], sourceNode.due_qc_qty);
  173. gatherNode[prefix + "due_final_qty"] = helper.add(gatherNode[prefix + "due_final_qty"], sourceNode.due_final_qty);
  174. gatherNode[prefix + "due_qc_minus_qty"] = helper.add(gatherNode[prefix + "due_qc_minus_qty"], sourceNode.due_qc_minus_qty);
  175. gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
  176. gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
  177. gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
  178. gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
  179. gatherNode.s_pre_contract_qty = helper.add(gatherNode.s_pre_contract_qty, sourceNode.pre_contract_qty);
  180. gatherNode.s_pre_qc_qty = helper.add(gatherNode.s_pre_qc_qty, sourceNode.pre_qc_qty);
  181. gatherNode.s_pre_gather_qty = helper.add(gatherNode.s_pre_gather_qty, sourceNode.pre_gather_qty);
  182. gatherNode.s_end_contract_qty = helper.add(gatherNode.s_end_contract_qty, sourceNode.end_contract_qty);
  183. gatherNode.s_end_qc_qty = helper.add(gatherNode.s_end_qc_qty, sourceNode.end_qc_qty);
  184. gatherNode.s_end_gather_qty = helper.add(gatherNode.s_end_gather_qty, sourceNode.end_gather_qty);
  185. gatherNode.s_due_qc_qty = helper.add(gatherNode.s_due_qc_qty, sourceNode.due_qc_qty);
  186. gatherNode.s_due_final_qty = helper.add(gatherNode.s_due_final_qty, sourceNode.due_final_qty);
  187. gatherNode.s_due_qc_minus_qty = helper.add(gatherNode.s_due_qc_minus_qty, sourceNode.due_qc_minus_qty);
  188. },
  189. gatherZonePos: function (tender, gatherNode, sourceNode, prefix, helper) {
  190. gatherNode[prefix + 'id'] = tender.id;
  191. gatherNode[prefix + 'name'] = tender.name;
  192. gatherNode[prefix + 'category'] = tender.category;
  193. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  194. gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
  195. gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
  196. gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
  197. gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
  198. gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
  199. gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
  200. gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
  201. },
  202. gatherPos: function (tender, gatherNode, sourceNode, prefix, helper) {
  203. gatherNode[prefix + 'id'] = tender.id;
  204. gatherNode[prefix + 'name'] = tender.name;
  205. gatherNode[prefix + 'category'] = tender.category;
  206. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  207. gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
  208. },
  209. gatherSpecialPos: function (gatherNode, sourceNode, prefix, helper) {
  210. gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
  211. },
  212. };
  213. const rmUtils = require('../lib/rm/rm_utils');
  214. module.exports = app => {
  215. class RptGatherMemory extends app.BaseService {
  216. /**
  217. * 构造函数
  218. *
  219. * @param {Object} ctx - egg全局context
  220. * @return {void}
  221. */
  222. constructor(ctx) {
  223. super(ctx);
  224. this.resultTree = null;
  225. this.resultPos = null;
  226. this.resultTenderInfo = [];
  227. this.resultDealPay = [];
  228. this.resultDealBills = [];
  229. }
  230. _checkFieldsExistReg(source, regStr) {
  231. const reg = new RegExp(regStr, 'igm');
  232. for (const s of source) {
  233. if (reg.test(s)) {
  234. return true;
  235. }
  236. }
  237. return false;
  238. }
  239. async _getValidStages(tenderId, sort = 'desc') {
  240. const stages = await this.db.select(this.ctx.service.stage.tableName, {
  241. where: { tid: tenderId },
  242. orders: [['order', sort]],
  243. });
  244. if (stages.length !== 0) {
  245. const lastStage = stages[0];
  246. if (lastStage.status === auditConst.stage.status.uncheck && lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
  247. stages.splice(0, 1);
  248. }
  249. }
  250. return stages;
  251. }
  252. async _getCheckedStages(tenderId) {
  253. const stages = await this.db.select(this.ctx.service.stage.tableName, {
  254. where: { tid: tenderId },
  255. orders: [['order', 'desc']],
  256. });
  257. if (stages.length !== 0) {
  258. const lastStage = stages[0];
  259. if (lastStage.status !== auditConst.stage.status.checked) {
  260. stages.splice(0, 1);
  261. }
  262. }
  263. return stages;
  264. }
  265. _checkSpecialTender(tender, special) {
  266. if (special) {
  267. for (const spec of special) {
  268. if (tender[spec.key] === true) return spec.key;
  269. }
  270. }
  271. return '';
  272. }
  273. async _getTimeZoneStages(tender, zone) {
  274. const times = zone.split(' - ');
  275. if (times.length !== 2) throw '选择的汇总周期无效';
  276. const beginTime = moment(times[0], 'YYYY-MM');
  277. const endTime = moment(times[1], 'YYYY-MM');
  278. const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
  279. let preStage, endStage;
  280. for (const stage of stages) {
  281. const sTime = moment(stage.s_time, 'YYYY-MM');
  282. if (sTime.isBetween(beginTime, endTime, null, '[]')) {
  283. validStages.push(stage);
  284. } else if (sTime.isBefore(beginTime)) {
  285. if (!preStage || moment(preStage.s_time, 'YYYY-MM').isBefore(sTime)) preStage = stage;
  286. } else if (sTime.isAfter(endTime)) {
  287. if (!endStage || moment(endStage.s_time, 'YYYY-MM').isAfter(sTime)) endStage = stage;
  288. }
  289. }
  290. return [validStages, preStage, endStage];
  291. }
  292. async _getOrderZoneStages (tender, zone) {
  293. let [iBegin, iEnd] = zone.split(':');
  294. iBegin = this.ctx.helper._.toInteger(iBegin) || 0;
  295. iEnd = this.ctx.helper._.toInteger(iEnd) || 0;
  296. const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
  297. let preStage, endStage;
  298. for (const stage of stages) {
  299. if (stage.order < iBegin) {
  300. if (!preStage || preStage.order < stage.order) preStage = stage;
  301. } else if (stage.order > iEnd) {
  302. if (!endStage || endStage.order > stage.order) endStage = stage;
  303. } else {
  304. validStages.push(stage);
  305. }
  306. }
  307. return [validStages, preStage, endStage];
  308. }
  309. async _getCustomZoneStages(tender, zone, timeType) {
  310. const times = zone.split(' - ');
  311. if (times.length !== 2) throw '选择的汇总周期无效';
  312. const beginTime = moment(times[0], 'YYYY-MM-DD');
  313. const endTime = moment(times[1], 'YYYY-MM-DD');
  314. const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
  315. let preStage, endStage;
  316. for (const stage of stages) {
  317. let sTime;
  318. switch (timeType) {
  319. case 'final-checked':
  320. if (stage.status !== auditConst.stage.status.checked) continue;
  321. const finalAudit = await this.ctx.service.stageAudit.getLastestAuditor(stage.id, stage.times, stage.status);
  322. if (!finalAudit) continue;
  323. sTime = moment(finalAudit.end_time).format('YYYY-MM-DD');
  324. break;
  325. case 'period-end':
  326. sTime = stage.period ? (stage.period.split(' ~ ')[1] ? stage.period.split(' ~ ')[1] : stage.period) : '';
  327. break;
  328. default:
  329. throw '配置参数错误';
  330. }
  331. stage.checked_day = sTime;
  332. stage.checked_time = moment(sTime, 'YYYY-MM-DD');
  333. if (stage.checked_time.isBetween(beginTime, endTime, null, '[]')) {
  334. validStages.push(stage);
  335. } else if (stage.checked_time.isBefore(beginTime)) {
  336. if (!preStage || preStage.checked_time.isBefore(stage.checked_time)) preStage = stage;
  337. } else if (stage.checked_time.isAfter(endTime)) {
  338. if (!endStage || endStage.checked_time.isAfter(stage.checked_time)) endStage = stage;
  339. }
  340. }
  341. return [validStages, preStage, endStage];
  342. }
  343. async _getMonthStages(tender, month) {
  344. const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
  345. for (const stage of stages) {
  346. if (stage.s_time === month) validStages.push(stage);
  347. }
  348. const preStage = stages.length > 0 ? stages.find(x => { return x.order === stages[0].order - 1; }) : null;
  349. const endStage = stages.length > 0 ? stages.find(x => { return x.order === stages[stages.length - 1].order + 1; }) : null;
  350. return [validStages, preStage, endStage];
  351. }
  352. /**
  353. * 台账数据
  354. */
  355. async _gatherStagesData(completeData, tender, stages, preStage) {
  356. const resultPos = this.resultPos;
  357. const helper = this.ctx.helper;
  358. completeData.id = tender.id;
  359. completeData.name = tender.name;
  360. /**
  361. * 汇总并合并 相关数据
  362. * @param {Array} index - 主数据
  363. * @param {Array[]}rela - 相关数据 {data, fields, prefix, relaId}
  364. */
  365. const sumAssignRelaData = function (index, rela) {
  366. const loadFields = function (datas, fields, prefix, relaId) {
  367. for (const d of datas) {
  368. const key = indexPre + d[relaId];
  369. const m = index[key];
  370. if (m) {
  371. for (const f of fields) {
  372. if (d[f] !== undefined) {
  373. m[prefix + f] = helper.add(m[prefix + f], d[f]);
  374. }
  375. }
  376. }
  377. }
  378. };
  379. for (const r of rela) {
  380. loadFields(r.data, r.fields, r.prefix, r.relaId);
  381. }
  382. };
  383. const billsTree = new Ledger.billsTree(this.ctx, {
  384. id: 'ledger_id',
  385. pid: 'ledger_pid',
  386. order: 'order',
  387. level: 'level',
  388. rootId: -1,
  389. keys: ['id', 'tender_id', 'ledger_id'],
  390. stageId: 'id',
  391. calcFields: ['deal_tp', 'total_price', 'contract_tp', 'qc_tp', 'gather_tp', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp'],
  392. calc: function (node) {
  393. if (node.children && node.children.length === 0) {
  394. node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
  395. node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
  396. node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
  397. node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
  398. node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
  399. }
  400. node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
  401. node.gather_tp = helper.add(node.contract_tp, node.qc_tp);
  402. node.end_contract_tp = helper.add(node.pre_contract_tp, node.contract_tp);
  403. node.end_qc_tp = helper.add(node.pre_qc_tp, node.qc_tp);
  404. node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
  405. }
  406. });
  407. const billsData = await this.ctx.service.ledger.getData(tender.id);
  408. const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(tender.id);
  409. for (const d of dgnData) {
  410. const l = this.ctx.helper._.find(billsData, {id: d.id});
  411. this.ctx.helper._.assignIn(l, d);
  412. }
  413. const pos = new Ledger.pos({
  414. id: 'id', ledgerId: 'lid',
  415. calc: function (node) {
  416. node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
  417. node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
  418. node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
  419. node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
  420. node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
  421. },
  422. });
  423. const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: tender.id} });
  424. let billsIndexData = {};
  425. for (const bd of billsData) {
  426. billsIndexData[indexPre + bd.id] = bd;
  427. }
  428. let posIndexData = {};
  429. for (const p of posData) {
  430. posIndexData[indexPre + p.id] = p;
  431. }
  432. if (preStage) {
  433. await this.ctx.service.stage.doCheckStage(preStage);
  434. const endStage = await this.ctx.service.stageBillsFinal.getFinalData(tender, preStage.order);
  435. sumAssignRelaData(billsIndexData, [
  436. { data: endStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
  437. ]);
  438. const endStagePos = await this.ctx.service.stagePosFinal.getFinalData(tender, preStage.order);
  439. sumAssignRelaData(posIndexData, [
  440. {data: endStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'lid'},
  441. ]);
  442. }
  443. for (const stage of stages) {
  444. await this.ctx.service.stage.doCheckStage(stage);
  445. const curStage = stage.readOnly
  446. ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
  447. : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
  448. const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
  449. sumAssignRelaData(billsIndexData, [
  450. {data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid'},
  451. { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
  452. ]);
  453. const curStagePos = stage.readOnly
  454. ? await this.ctx.service.stagePos.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
  455. : await this.ctx.service.stagePos.getLastestStageData2(tender.id, stage.id);
  456. sumAssignRelaData(posIndexData, [
  457. {data: curStagePos, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid'},
  458. ]);
  459. }
  460. billsTree.loadDatas(billsData);
  461. billsTree.calculateAll();
  462. pos.loadDatas(posData);
  463. pos.calculateAll();
  464. this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
  465. gatherUtils.gatherStage(tender, gatherNode, sourceNode, completeData.prefix, helper);
  466. }, function (gatherNode, sourceNode) {
  467. const posRange = pos.getLedgerPos(sourceNode.id);
  468. if (!posRange || posRange.length === 0) return;
  469. resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
  470. gatherUtils.gatherStagePos(tender, gatherPos, sourcePos, completeData.prefix, helper);
  471. });
  472. });
  473. }
  474. async _gatherZoneData(tender, completeData, zone) {
  475. const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
  476. await this._gatherStagesData(completeData, tender, stages, preStage);
  477. }
  478. async _gatherIndexZoneData(tender, completeData, stageZone) {
  479. const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
  480. await this._gatherStagesData(completeData, tender, stages, preStage);
  481. }
  482. async _gatherCustomZoneData(tender, completeData, zone, timeType) {
  483. const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
  484. await this._gatherStagesData(completeData, tender, stages, preStage);
  485. }
  486. async _gatherMonthsData(tender, completeData, month) {
  487. const [stages, preStage, endStage] = await this._getMonthStages(tender, month);
  488. await this._gatherStagesData(completeData, tender, stages, preStage);
  489. }
  490. async _gatherStageData(completeData, tender, stage, hasPre) {
  491. const helper = this.ctx.helper;
  492. const resultPos = this.resultPos;
  493. completeData.id = tender.id;
  494. completeData.name = tender.name;
  495. const billsTree = new Ledger.billsTree(this.ctx, {
  496. id: 'ledger_id',
  497. pid: 'ledger_pid',
  498. order: 'order',
  499. level: 'level',
  500. rootId: -1,
  501. keys: ['id', 'tender_id', 'ledger_id'],
  502. stageId: 'id',
  503. calcFields: ['deal_tp', 'total_price',
  504. 'contract_tp', 'qc_tp', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'gather_tp',
  505. 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp',
  506. 'end_contract_tp', 'end_qc_tp', 'end_gather_tp',
  507. 'due_qc_tp', 'due_final_tp',
  508. ],
  509. calc: function (node) {
  510. if (node.children && node.children.length === 0) {
  511. node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
  512. node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
  513. node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
  514. node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
  515. node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
  516. node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
  517. }
  518. node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
  519. node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
  520. node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
  521. node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
  522. node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
  523. node.due_final_tp = helper.add(node.total_price, node.due_qc_tp);
  524. }
  525. });
  526. const billsData = await this.ctx.service.ledger.getData(tender.id);
  527. const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(tender.id);
  528. const changeBillsData = await this.ctx.service.changeAuditList.getBillsSum(tender.id);
  529. this.ctx.helper.assignRelaData(billsData, [
  530. { data: dgnData, fields: ['deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2'], prefix: '', relaId: 'id' },
  531. { data: changeBillsData, fields: ['qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'due_', relaId: 'gcl_id' },
  532. ]);
  533. const pos = new Ledger.pos({
  534. id: 'id', ledgerId: 'lid',
  535. calc: function (node) {
  536. node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
  537. node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
  538. node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
  539. node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
  540. node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
  541. node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
  542. },
  543. });
  544. const posData = await this.ctx.service.pos.getPosData({ tid: tender.id });
  545. const changePosData = await this.ctx.service.changeAuditList.getPosSum(tender.id);
  546. this.ctx.helper.assignRelaData(posData, [
  547. { data: changePosData, fields: ['qc_qty', 'qc_minus_qty'], prefix: 'due_', relaId: 'mx_id' },
  548. ]);
  549. if (stage) {
  550. await this.ctx.service.stage.doCheckStage(stage);
  551. const curStage = stage.readOnly
  552. ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
  553. : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
  554. const preStage = hasPre && stage.preCheckedStage ? await this.ctx.service.stageBillsFinal.getFinalData(tender, stage.preCheckedStage.order) : [];
  555. const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
  556. this.ctx.helper.assignRelaData(billsData, [
  557. { data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid' },
  558. { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
  559. { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
  560. ]);
  561. const curStagePos = stage.readOnly
  562. ? await this.ctx.service.stagePos.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
  563. : await this.ctx.service.stagePos.getLastestStageData2(tender.id, stage.id);
  564. const preStagePos = hasPre && stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(tender, stage.preCheckedStage.order) : [];
  565. this.ctx.helper.assignRelaData(posData, [
  566. { data: curStagePos, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid' },
  567. { data: preStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid' },
  568. ]);
  569. }
  570. billsTree.loadDatas(billsData);
  571. billsTree.calculateAll();
  572. pos.loadDatas(posData);
  573. pos.calculateAll();
  574. this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
  575. gatherUtils.gatherStage(tender, gatherNode, sourceNode, completeData.prefix, helper);
  576. }, function (gatherNode, sourceNode) {
  577. const posRange = pos.getLedgerPos(sourceNode.id);
  578. if (!posRange || posRange.length === 0) return;
  579. resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
  580. gatherUtils.gatherStagePos(tender, gatherPos, sourcePos, completeData.prefix, helper);
  581. });
  582. });
  583. }
  584. async _gatherMonthData(tender, completeData, month, hasPre) {
  585. const stages = await this._getValidStages(tender.id);
  586. const stage = this.ctx.helper._.find(stages, {s_time: month});
  587. await this._gatherStageData(completeData, tender, stage, hasPre);
  588. }
  589. async _gatherIndexData(tender, completeData, index, hasPre) {
  590. const stages = await this._getValidStages(tender.id);
  591. const stage = this.ctx.helper._.find(stages, {order: index});
  592. await this._gatherStageData(completeData, tender, stage, hasPre);
  593. }
  594. async _gatherFinalData(tender, completeData, hasPre) {
  595. const stages = await this._getValidStages(tender.id);
  596. await this._gatherStageData(completeData, tender, stages[0], hasPre);
  597. }
  598. async _gatherCheckedFinalData(tender, completeData, hasPre) {
  599. const stages = await this._getCheckedStages(tender.id);
  600. await this._gatherStageData(completeData, tender, stages[0], hasPre);
  601. }
  602. async _loadGatherLedger(tender) {
  603. const billsTree = new Ledger.billsTree(this.ctx, {
  604. id: 'ledger_id',
  605. pid: 'ledger_pid',
  606. order: 'order',
  607. level: 'level',
  608. rootId: -1,
  609. keys: ['id', 'tender_id', 'ledger_id'],
  610. stageId: 'id',
  611. calcFields: ['deal_tp', 'total_price'],
  612. });
  613. const billsData = await this.ctx.service.ledger.getData(tender.id);
  614. billsTree.loadDatas(billsData);
  615. billsTree.calculateAll();
  616. return billsTree;
  617. }
  618. async _loadGatherPos(tender) {
  619. const pos = new Ledger.pos({ id: 'id', ledgerId: 'lid' });
  620. const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: tender.id } });
  621. pos.loadDatas(posData);
  622. return pos;
  623. }
  624. async _gatherLedgerData(tender, completeData) {
  625. const resultPos = this.resultPos;
  626. const helper = this.ctx.helper;
  627. const billsTree = await this._loadGatherLedger(tender);
  628. const pos = await this._loadGatherPos(tender);
  629. this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
  630. gatherUtils.gatherLedger(tender, gatherNode, sourceNode, completeData.prefix, helper);
  631. }, function (gatherNode, sourceNode) {
  632. const posRange = pos.getLedgerPos(sourceNode.id);
  633. if (!posRange || posRange.length === 0) return;
  634. resultPos.loadGatherPos(posRange, (gatherPos, sourcePos) => {
  635. gatherUtils.gatherPos(gatherPos, sourcePos, completeData.prefix, helper);
  636. });
  637. });
  638. }
  639. async _gatherSpecialData(tender, sKey) {
  640. const resultPos = this.resultPos;
  641. const helper = this.ctx.helper;
  642. const billsTree = await this._loadGatherLedger(tender);
  643. const pos = await this._loadGatherPos(tender);
  644. this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
  645. gatherUtils.gatherSpecial(gatherNode, sourceNode, 'ts_' + sKey + '_', helper);
  646. }, function (gatherNode, sourceNode) {
  647. const posRange = pos.getLedgerPos(sourceNode.id);
  648. if (!posRange || posRange.length === 0) return;
  649. resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
  650. gatherUtils.gatherSpecialPos(gatherPos, sourcePos, 'ts_' + sKey + '_', helper);
  651. });
  652. });
  653. }
  654. async _doGatherStageData(memFieldKeys, gsDefine, gsCustom) {
  655. if (this.resultTree || this.resultPos) return;
  656. if (!gsDefine || !gsDefine.enable) return;
  657. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return;
  658. this.resultTree = new Ledger.gatherTree(this.ctx, {
  659. id: 'id',
  660. pid: 'pid',
  661. order: 'order',
  662. level: 'level',
  663. rootId: -1
  664. });
  665. this.resultPos = new Ledger.gatherPos({ id: 'id', ledgerId: 'lid' });
  666. const gsSetting = JSON.parse(gsDefine.setting);
  667. let commonIndex = 0;
  668. const completeDatas = [];
  669. for (const t of gsCustom.tenders) {
  670. const specialKey = this._checkSpecialTender(t, gsSetting.special);
  671. const tender = await this.ctx.service.tender.getCheckTender(t.tid);
  672. if (specialKey === '') {
  673. const completeData = {
  674. prefix: 't_' + commonIndex + '_',
  675. };
  676. completeDatas.push(completeData);
  677. switch (gsSetting.type) {
  678. case 'month':
  679. await this._gatherMonthData(tender, completeData, gsCustom.month, gsSetting.hasPre);
  680. break;
  681. case 'months':
  682. await this._gatherMonthsData(tender, completeData, gsCustom.months);
  683. break;
  684. case 'zone':
  685. await this._gatherZoneData(tender, completeData, gsCustom.zone);
  686. break;
  687. case 'final':
  688. await this._gatherFinalData(tender, completeData, gsSetting.hasPre);
  689. break;
  690. case 'checked-final':
  691. await this._gatherCheckedFinalData(tender, completeData, gsSetting.hasPre);
  692. break;
  693. case 'ledger':
  694. await this._gatherLedgerData(tender, completeData);
  695. break;
  696. case 'stage':
  697. await this._gatherIndexData(tender, completeData, gsCustom.stage, gsSetting.hasPre);
  698. break;
  699. case 'stage-zone':
  700. await this._gatherIndexZoneData(tender, completeData, gsCustom.stage_zone);
  701. break;
  702. case 'custom-zone':
  703. await this._gatherCustomZoneData(tender, completeData, gsCustom.custom_zone, gsSetting.timeType);
  704. break;
  705. }
  706. commonIndex++;
  707. } else {
  708. await this._gatherSpecialData(tender, specialKey);
  709. }
  710. }
  711. this.resultTree.resortChildrenDefault();
  712. gatherUtils.completeGatherData(this.resultTree.nodes, completeDatas);
  713. gatherUtils.completeGatherData(this.resultPos.datas, completeDatas);
  714. }
  715. async getGatherStageBills(memFieldKeys, gsDefine, gsCustom, showLevel) {
  716. await this._doGatherStageData(memFieldKeys, gsDefine, gsCustom);
  717. return this.resultTree
  718. ? (showLevel ? this.resultTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : this.resultTree.getDefaultDatas())
  719. : [];
  720. }
  721. async getGatherStagePos(memFieldKeys, gsDefine, gsCustom) {
  722. await this._doGatherStageData(memFieldKeys, gsDefine, gsCustom);
  723. return this.resultPos ? this.resultPos.getDatas() : [];
  724. }
  725. /**
  726. * 标段信息
  727. */
  728. async _getBaseTenderInfo(tender) {
  729. const info = {
  730. id: tender.id,
  731. name: tender.name,
  732. deal_tp: tender.deal_tp,
  733. tp: tender.total_price
  734. };
  735. const deal_bills_sum = await this.ctx.service.dealBills.getSum(tender.id);
  736. info.deal_bills_tp = deal_bills_sum ? deal_bills_sum.total_price : 0;
  737. if (tender.ledger_status === auditConst.ledger.status.uncheck || tender.ledger_status === auditConst.ledger.status.checkNo) {
  738. const sum = await this.ctx.service.ledger.addUp({tender_id: tender.id/*, is_leaf: true*/});
  739. info.tp = sum.total_price;
  740. info.deal_tp = sum.deal_tp;
  741. }
  742. info.deal_info = tender.info.deal_info;
  743. info.construction_unit = tender.info.construction_unit;
  744. info.tech_param = tender.info.tech_param;
  745. info.deal_param = tender.info.deal_param;
  746. info.pay_account = tender.info.pay_account;
  747. info.deal_param.contractPriceWithoutZL = this.ctx.helper.sub(info.deal_param.contractPrice,
  748. info.deal_param.zanLiePrice);
  749. info.bid_info = tender.info.bid_info;
  750. return info;
  751. }
  752. async _getStageTenderInfo(stage, info) {
  753. if (stage) {
  754. const helper = this.ctx.helper;
  755. await this.ctx.service.stage.doCheckStage(stage);
  756. await this.ctx.service.stage.checkStageGatherData(stage, this.ctx.session.sessionUser.is_admin);
  757. info.pre_contract_tp = stage.pre_contract_tp;
  758. info.pre_qc_tp = stage.pre_qc_tp;
  759. info.pre_gather_tp = helper.add(info.pre_contract_tp, info.pre_qc_tp);
  760. info.contract_tp = stage.contract_tp;
  761. info.qc_tp = stage.qc_tp;
  762. info.gather_tp = helper.add(info.contract_tp, info.qc_tp);
  763. info.end_contract_tp = helper.add(info.pre_contract_tp, info.contract_tp);
  764. info.end_qc_tp = helper.add(info.pre_qc_tp, info.qc_tp);
  765. info.end_gather_tp = helper.add(info.pre_gather_tp, info.gather_tp);
  766. info.yf_tp = stage.yf_tp;
  767. info.pre_yf_tp = stage.pre_yf_tp;
  768. info.end_yf_tp = helper.add(stage.yf_tp, stage.pre_yf_tp);
  769. info.sf_tp = stage.sf_tp;
  770. info.pre_sf_tp = stage.pre_sf_tp;
  771. info.end_sf_tp = helper.add(stage.sf_tp, stage.pre_sf_tp);
  772. }
  773. }
  774. async _getStagesTenderInfo(stages, info, preStage) {
  775. const helper = this.ctx.helper;
  776. if (preStage) {
  777. info.pre_contract_tp = helper.add(preStage.contract_tp, preStage.pre_contract_tp);
  778. info.pre_qc_tp = helper.add(preStage.qc_tp, preStage.pre_qc_tp);
  779. info.pre_gather_tp = helper.add(info.pre_contract_tp, info.pre_qc_tp);
  780. info.pre_yf_tp = helper.add(preStage.yf_tp, preStage.pre_yf_tp);
  781. }
  782. for (const stage of stages) {
  783. await this.ctx.service.stage.doCheckStage(stage);
  784. await this.ctx.service.stage.checkStageGatherData(stage, this.ctx.session.sessionUser.is_admin);
  785. info.contract_tp = helper.add(info.contract_tp, stage.contract_tp);
  786. info.qc_tp = helper.add(info.qc_tp, stage.qc_tp);
  787. info.yf_tp = helper.add(info.yf_tp, stage.yf_tp);
  788. }
  789. info.gather_tp = helper.add(info.contract_tp, info.qc_tp);
  790. info.end_contract_tp = helper.add(info.pre_contract_tp, info.contract_tp);
  791. info.end_qc_tp = helper.add(info.pre_qc_tp, info.qc_tp);
  792. info.end_gather_tp = helper.add(info.pre_gather_tp, info.gather_tp);
  793. info.end_yf_tp = helper.add(info.pre_yf_tp, info.yf_tp);
  794. }
  795. async _gatherZoneTenderInfo(tender, index, zone) {
  796. const info = await this._getBaseTenderInfo(tender);
  797. const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
  798. await this._getStagesTenderInfo(stages, info, preStage);
  799. this.resultTenderInfo.push(info);
  800. }
  801. async _gatherOrderZoneTenderInfo(tender, index, stageZone) {
  802. const info = await this._getBaseTenderInfo(tender);
  803. const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
  804. await this._getStagesTenderInfo(stages, info, preStage);
  805. this.resultTenderInfo.push(info);
  806. }
  807. async _gatherCustomZoneTenderInfo(tender, index, zone, timeType) {
  808. const info = await this._getBaseTenderInfo(tender);
  809. const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
  810. await this._getStagesTenderInfo(stages, info, preStage);
  811. this.resultTenderInfo.push(info);
  812. }
  813. async _gatherMonthTenderInfo(tender, index, month, hasPre) {
  814. const info = await this._getBaseTenderInfo(tender);
  815. const stages = await this._getValidStages(tender.id);
  816. const stage = this.ctx.helper._.find(stages, {s_time: month});
  817. await this._getStageTenderInfo(stage, info);
  818. this.resultTenderInfo.push(info);
  819. }
  820. async _gatherOrderTenderInfo(tender, index, order, hasPre) {
  821. const info = await this._getBaseTenderInfo(tender);
  822. const stages = await this._getValidStages(tender.id);
  823. const stage = this.ctx.helper._.find(stages, {order: order});
  824. await this._getStageTenderInfo(stage, info);
  825. this.resultTenderInfo.push(info);
  826. }
  827. async _gatherFinalTenderInfo(tender, index, hasPre) {
  828. const info = await this._getBaseTenderInfo(tender);
  829. const stages = await this._getValidStages(tender.id);
  830. await this._getStageTenderInfo(stages[0], info);
  831. this.resultTenderInfo.push(info);
  832. }
  833. async _gatherCheckedFinalTenderInfo(tender, index, hasPre) {
  834. const info = await this._getBaseTenderInfo(tender);
  835. const stages = await this._getCheckedStages(tender.id);
  836. await this._getStageTenderInfo(stages[0], info);
  837. this.resultTenderInfo.push(info);
  838. }
  839. async _gatherLedgerTenderInfo(tender, index) {
  840. const info = await this._getBaseTenderInfo(tender);
  841. this.resultTenderInfo.push(info);
  842. }
  843. async _gatherSpecialTenderInfo(tender, sKey) {
  844. const info = await this._getBaseTenderInfo(tender);
  845. info.spec = sKey;
  846. this.resultTenderInfo.push(info);
  847. }
  848. async getGatherTenderInfo(memFieldKeys, gsDefine, gsCustom) {
  849. if (!gsDefine || !gsDefine.enable) return [];
  850. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  851. this.resultTenderInfo = [];
  852. const gsSetting = JSON.parse(gsDefine.setting);
  853. let commonIndex = 0;
  854. for (const t of gsCustom.tenders) {
  855. const specialKey = this._checkSpecialTender(t, gsSetting.special);
  856. const tender = await this.ctx.service.tender.getCheckTender(t.tid);
  857. if (specialKey === '') {
  858. switch (gsSetting.type) {
  859. case 'month':
  860. await this._gatherMonthTenderInfo(tender, commonIndex, gsCustom.month, gsSetting.hasPre);
  861. break;
  862. case 'zone':
  863. await this._gatherZoneTenderInfo(tender, commonIndex, gsCustom.zone);
  864. break;
  865. case 'final':
  866. await this._gatherFinalTenderInfo(tender, commonIndex, gsSetting.hasPre);
  867. break;
  868. case 'checked-final':
  869. await this._gatherCheckedFinalTenderInfo(tender, commonIndex, gsSetting.hasPre);
  870. break;
  871. case 'ledger':
  872. await this._gatherLedgerTenderInfo(tender, commonIndex);
  873. break;
  874. case 'stage':
  875. await this._gatherOrderTenderInfo(tender, commonIndex, gsCustom.stage, gsSetting.hasPre);
  876. break;
  877. case 'stage-zone':
  878. await this._gatherOrderZoneTenderInfo(tender, commonIndex, gsCustom.stage_zone);
  879. break;
  880. case 'custom-zone':
  881. await this._gatherCustomZoneTenderInfo(tender, commonIndex, gsCustom.custom_zone, gsSetting.timeType);
  882. break;
  883. }
  884. commonIndex++;
  885. } else {
  886. await this._gatherSpecialTenderInfo(tender, specialKey);
  887. }
  888. }
  889. return this.resultTenderInfo;
  890. }
  891. /**
  892. * 合同支付
  893. */
  894. _gatherPayRecord(dealPay, fun) {
  895. let rdp;
  896. if (dealPay.ptype !== payConst.payType.normal) {
  897. rdp = this.ctx.helper._.find(this.resultDealPay, {ptype: dealPay.ptype});
  898. } else {
  899. rdp = this.ctx.helper._.find(this.resultDealPay, {
  900. name: dealPay.name,
  901. minus: dealPay.minus ? true : false,
  902. is_yf: dealPay.is_yf ? true : false,
  903. });
  904. }
  905. if (!rdp) {
  906. rdp = {
  907. ptype: dealPay.ptype,
  908. name: dealPay.name,
  909. minus: dealPay.minus ? true : false,
  910. is_yf: dealPay.is_yf ? true : false,
  911. };
  912. this.resultDealPay.push(rdp);
  913. }
  914. if (fun) fun(rdp, dealPay);
  915. }
  916. async _checkStagePayCalc(tender, stage, dealPay) {
  917. if (!stage.readOnly) {
  918. // 计算 本期金额
  919. const payCalculator = new PayCalculator(this.ctx, stage, tender.info);
  920. await payCalculator.calculateAll(dealPay);
  921. }
  922. }
  923. async _gatherStagePay(completeData, tender, stage, hasPre) {
  924. if (stage) {
  925. completeData.id = tender.id;
  926. completeData.name = tender.name;
  927. const helper = this.ctx.helper;
  928. await this.ctx.service.stage.doCheckStage(stage);
  929. const dealPay = await this.ctx.service.stagePay.getStagePays(stage);
  930. await this._checkStagePayCalc(tender, stage, dealPay);
  931. for (const dp of dealPay) {
  932. dp.end_tp = helper.add(dp.pre_tp, dp.tp);
  933. this._gatherPayRecord(dp, function (gatherData, sourceData) {
  934. gatherData[completeData.prefix + 'id'] = tender.id;
  935. gatherData[completeData.prefix + 'name'] = tender.name;
  936. gatherData[completeData.prefix + 'tp'] = helper.add(gatherData[completeData.prefix + 'tp'], sourceData.tp);
  937. gatherData[completeData.prefix + 'pre_tp'] = helper.add(gatherData[completeData.prefix + 'pre_tp'], sourceData.pre_tp);
  938. gatherData[completeData.prefix + 'end_tp'] = helper.add(gatherData[completeData.prefix + 'end_tp'], sourceData.end_tp);
  939. gatherData['s_' + 'tp'] = helper.add(gatherData['s_' + 'tp'], sourceData.tp);
  940. gatherData['s_' + 'pre_tp'] = helper.add(gatherData['s_' + 'pre_tp'], sourceData.pre_tp);
  941. gatherData['s_' + 'end_tp'] = helper.add(gatherData['s_' + 'end_tp'], sourceData.end_tp);
  942. });
  943. }
  944. }
  945. }
  946. async _gatherStagesPay(completeData, tender, stages, preStage) {
  947. const helper = this.ctx.helper;
  948. completeData.id = tender.id;
  949. completeData.name = tender.name;
  950. if (preStage) await this.ctx.service.stage.doCheckStage(preStage);
  951. const preDealPay = preStage ? await this.ctx.service.stagePay.getStagePays(preStage) : [];
  952. for (const dp of preDealPay) {
  953. dp.end_tp = helper.add(dp.pre_tp, dp.tp);
  954. this._gatherPayRecord(dp, function (gatherData, sourceData) {
  955. gatherData[completeData.prefix + 'id'] = tender.id;
  956. gatherData[completeData.prefix + 'name'] = tender.name;
  957. gatherData[completeData.prefix + 'pre_tp'] = sourceData.end_tp;
  958. gatherData.s_pre_tp = helper.add(gatherData.s_pre_tp, sourceData.end_tp);
  959. gatherData[completeData.prefix + 'end_tp'] = sourceData.end_tp;
  960. gatherData.s_end_tp = helper.add(gatherData.s_end_tp, sourceData.end_tp);
  961. });
  962. }
  963. for (const stage of stages) {
  964. await this.ctx.service.stage.doCheckStage(stage);
  965. const dealPay = await this.ctx.service.stagePay.getStagePays(stage);
  966. await this._checkStagePayCalc(tender, stage, dealPay);
  967. for (const dp of dealPay) {
  968. dp.end_tp = helper.add(dp.pre_tp, dp.tp);
  969. this._gatherPayRecord(dp, function (gatherData, sourceData) {
  970. gatherData[completeData.prefix + 'id'] = tender.id;
  971. gatherData[completeData.prefix + 'name'] = tender.name;
  972. gatherData[completeData.prefix + 'tp'] = helper.add(gatherData[completeData.prefix + 'tp'], sourceData.tp);
  973. gatherData['s_' + 'tp'] = helper.add(gatherData['s_' + 'tp'], sourceData.tp);
  974. gatherData[completeData.prefix + 'end_tp'] = helper.add(gatherData[completeData.prefix + 'end_tp'], sourceData.tp);
  975. gatherData['s_' + 'end_tp'] = helper.add(gatherData['s_' + 'end_tp'], sourceData.tp);
  976. });
  977. }
  978. }
  979. }
  980. async _gatherZoneStagePay(sTender, completeData, zone) {
  981. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  982. const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
  983. await this._gatherStagesPay(completeData, tender, stages, preStage);
  984. }
  985. async _gatherOrderZoneStagePay(sTender, completeData, stageZone) {
  986. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  987. const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
  988. await this._gatherStagesPay(completeData, tender, stages, preStage);
  989. }
  990. async _gatherCustomZoneStagePay(sTender, completeData, zone, timeType) {
  991. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  992. const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
  993. await this._gatherStagesPay(completeData, tender, stages, preStage);
  994. }
  995. async _gatherMonthStagePay(sTender, completeData, month, hasPre) {
  996. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  997. const stages = await this._getValidStages(tender.id);
  998. const stage = this.ctx.helper._.find(stages, {s_time: month});
  999. await this._gatherStagePay(completeData, tender, stage, hasPre);
  1000. }
  1001. async _gatherOrderStagePay(sTender, completeData, order, hasPre) {
  1002. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1003. const stages = await this._getValidStages(tender.id);
  1004. const stage = this.ctx.helper._.find(stages, {order: order});
  1005. await this._gatherStagePay(completeData, tender, stage, hasPre);
  1006. }
  1007. async _gatherFinalStagePay(sTender, completeData, hasPre) {
  1008. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1009. const stages = await this._getValidStages(tender.id);
  1010. await this._gatherStagePay(completeData, tender, stages[0], hasPre);
  1011. }
  1012. async _gatherCheckedFinalStagePay(sTender, completeData, hasPre) {
  1013. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1014. const stages = await this._getCheckedStages(tender.id);
  1015. await this._gatherStagePay(completeData, tender, stages[0], hasPre);
  1016. }
  1017. async getGatherStagePay(memFieldKeys, gsDefine, gsCustom) {
  1018. if (!gsDefine || !gsDefine.enable) return [];
  1019. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1020. this.resultDealPay = [];
  1021. const gsSetting = JSON.parse(gsDefine.setting);
  1022. let commonIndex = 0;
  1023. const completeDatas = [];
  1024. for (const tender of gsCustom.tenders) {
  1025. const specialKey = this._checkSpecialTender(tender, gsSetting.special);
  1026. if (specialKey === '') {
  1027. const completeData = {
  1028. prefix: 't_' + commonIndex + '_',
  1029. };
  1030. completeDatas.push(completeData);
  1031. switch (gsSetting.type) {
  1032. case 'month':
  1033. await this._gatherMonthStagePay(tender, completeData, gsCustom.month, gsSetting.hasPre);
  1034. break;
  1035. case 'zone':
  1036. await this._gatherZoneStagePay(tender, completeData, gsCustom.zone);
  1037. break;
  1038. case 'final':
  1039. await this._gatherFinalStagePay(tender, completeData, gsSetting.hasPre);
  1040. break;
  1041. case 'checked-final':
  1042. await this._gatherCheckedFinalStagePay(tender, completeData, gsSetting.hasPre);
  1043. break;
  1044. case 'stage':
  1045. await this._gatherOrderStagePay(tender, completeData, gsCustom.stage, gsSetting.hasPre);
  1046. break;
  1047. case 'stage-zone':
  1048. await this._gatherOrderZoneStagePay(tender, completeData, gsCustom.stage_zone);
  1049. break;
  1050. case 'custom-zone':
  1051. await this._gatherCustomZoneStagePay(tender, completeData, gsCustom.custom_zone, gsSetting.timeType);
  1052. break;
  1053. }
  1054. commonIndex++;
  1055. }
  1056. // 合同支付,只有在每一期中有数据,故特殊标段直接不汇总合同支付
  1057. }
  1058. gatherUtils.completeGatherData(this.resultDealPay, completeDatas);
  1059. return this.resultDealPay;
  1060. }
  1061. /**
  1062. * 签约清单
  1063. */
  1064. async _gatherDealBills(tender, fun) {
  1065. const dealBills = await this.ctx.service.dealBills.getAllDataByCondition({
  1066. where: { tender_id: tender.id }
  1067. });
  1068. for (const db of dealBills) {
  1069. let rdb = this.ctx.helper._.find(this.resultDealBills, {
  1070. code: db.code,
  1071. name: db.name,
  1072. unit: db.unit,
  1073. unit_price: db.unit_price ? db.unit_price: 0,
  1074. });
  1075. if (!rdb) {
  1076. rdb = {
  1077. code: db.code,
  1078. name: db.name,
  1079. unit: db.unit,
  1080. unit_price: db.unit_price ? db.unit_price: 0,
  1081. };
  1082. this.resultDealBills.push(rdb);
  1083. }
  1084. if (fun) fun(rdb, db);
  1085. }
  1086. }
  1087. async _gatherCommonDealBills(sTender, completeData) {
  1088. const self = this;
  1089. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1090. completeData.id = tender.id;
  1091. completeData.name = tender.name;
  1092. await this._gatherDealBills(tender, function (gatherData, sourceData) {
  1093. gatherData[completeData.prefix + 'id'] = tender.id;
  1094. gatherData[completeData.prefix + 'name'] = tender.name;
  1095. gatherData[completeData.prefix + 'qty'] = sourceData.quantity;
  1096. gatherData[completeData.prefix + 'tp'] = sourceData.total_price;
  1097. gatherData['s_' + 'qty'] = self.ctx.helper.add(gatherData['s_' + 'qty'], sourceData.quantity);
  1098. gatherData['s_' + 'tp'] = self.ctx.helper.add(gatherData['s_' + 'tp'], sourceData.total_price);
  1099. });
  1100. }
  1101. async _gatherSpecialDealBills(sTender, sKey) {
  1102. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1103. await this._gatherDealBills(tender, function (gatherData, sourceData) {
  1104. const prefix = 'ts_' + sKey + '_';
  1105. gatherData[prefix + 'qty'] = sourceData.quantity;
  1106. gatherData[prefix + 'tp'] = sourceData.total_price;
  1107. });
  1108. }
  1109. async getGatherDealBills(memFieldKeys, gsDefine, gsCustom) {
  1110. if (!gsDefine || !gsDefine.enable) return [];
  1111. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1112. this.resultTenderInfo = [];
  1113. const gsSetting = JSON.parse(gsDefine.setting);
  1114. let commonIndex = 0;
  1115. const completeDatas = [];
  1116. for (const tender of gsCustom.tenders) {
  1117. const specialKey = this._checkSpecialTender(tender, gsSetting.special);
  1118. if (specialKey === '') {
  1119. const completeData = {
  1120. prefix: 't_' + commonIndex + '_',
  1121. };
  1122. completeDatas.push(completeData);
  1123. await this._gatherCommonDealBills(tender, completeData);
  1124. commonIndex++;
  1125. } else {
  1126. await this._gatherSpecialDealBills(tender, specialKey);
  1127. }
  1128. }
  1129. gatherUtils.completeGatherData(this.resultDealBills, completeDatas);
  1130. return this.resultDealBills;
  1131. }
  1132. _getChangeConstName(define, value) {
  1133. for (const prop in define) {
  1134. if (define[prop].value === value) {
  1135. return define[prop].name;
  1136. }
  1137. }
  1138. return '';
  1139. }
  1140. async _gatherChange(tender, hasUsed) {
  1141. const self = this;
  1142. try {
  1143. const info = await this.ctx.service.tenderInfo.getTenderInfo(tender.id);
  1144. const decimal = info.decimal, ctx = this.ctx;
  1145. const where = { tid: tender.id, valid: 1 };
  1146. if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.flow.status.checked;
  1147. const change = await this.ctx.service.change.getAllDataByCondition({ where, orders: [['in_time', 'desc']] });
  1148. for (const c of change) {
  1149. c.tender_name = tender.name;
  1150. const types = ctx.helper._.map(c.type.split(','), function (t) {
  1151. return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
  1152. });
  1153. c.type = types.join(';');
  1154. c.class = this._getChangeConstName(changeConst.class, c.class);
  1155. c.quality = this._getChangeConstName(changeConst.quality, c.quality);
  1156. c.charge = this._getChangeConstName(changeConst.charge, c.charge);
  1157. c.attachments = await ctx.service.changeAtt.getChangeAttachment(c.cid);
  1158. const names = ctx.helper._.map(c.attachments, function (x) {
  1159. return x.filename + x.fileext;
  1160. });
  1161. c.attNames = names.join('\n');
  1162. }
  1163. const changeBills = hasUsed
  1164. ? await this.ctx.service.stageChangeFinal.getChangeBillsWithUsedQty(tender.id, this.ctx.session.sessionProject.page_show.isOnlyChecked)
  1165. : await this.ctx.service.changeAuditList.getChangeAuditBills(tender.id, this.ctx.session.sessionProject.page_show.isOnlyChecked);
  1166. for (const d of changeBills) {
  1167. d.tender_name = tender.name;
  1168. d.o_qty = d.oamount;
  1169. d.o_tp = this.ctx.helper.mul(d.o_qty, d.unit_price, decimal.tp);
  1170. d.c_qty = d.camount;
  1171. d.c_tp = this.ctx.helper.mul(d.c_qty, d.unit_price, decimal.tp);
  1172. d.s_qty = d.samount ? parseFloat(d.samount) : 0;
  1173. d.s_tp = this.ctx.helper.mul(d.s_qty, d.unit_price, decimal.tp);
  1174. d.sp_qty = d.spamount;
  1175. d.sp_tp = this.ctx.helper.mul(d.sp_qty, d.unit_price, decimal.tp);
  1176. d.used_tp = this.ctx.helper.mul(d.used_qty, d.unit_price, decimal.tp);
  1177. d.is_used = !!d.used_qty;
  1178. const auditAmount = d.audit_amount ? d.audit_amount.split(',') : [];
  1179. const relaChange = ctx.helper._.find(change, {cid: d.cid});
  1180. d.relaChange = relaChange;
  1181. if (relaChange) {
  1182. if (d.is_used) relaChange.is_used = true;
  1183. relaChange.used_tp = ctx.helper.add(relaChange.used_tp, d.used_tp);
  1184. }
  1185. for (const [i, aa] of auditAmount.entries()) {
  1186. const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
  1187. d[amountField] = aa ? parseFloat(aa) : 0;
  1188. d[tpField] = ctx.helper.mul(d[amountField], d.unit_price, decimal.tp);
  1189. if (relaChange) {
  1190. relaChange[tpField] = ctx.helper.add(relaChange[tpField], d[tpField]);
  1191. }
  1192. }
  1193. }
  1194. for (const c of change) {
  1195. c.is_used = !!c.is_used;
  1196. c.used_ratio = c.total_price ? ctx.helper.mul(ctx.helper.div(c.used_tp, c.total_price), 100) : 0;
  1197. }
  1198. for (const cb of changeBills) {
  1199. cb.is_used_bgl = cb.relaChange ? cb.relaChange.is_used : cb.is_used;
  1200. delete cb.relaChange;
  1201. }
  1202. change.sort(function (a, b) {
  1203. return a.code.localeCompare(b.code);
  1204. });
  1205. changeBills.sort(function (a, b) {
  1206. const aCIndex = change.findIndex(function (c) {
  1207. return c.cid === a.cid;
  1208. });
  1209. const bCIndex = change.findIndex(function (c) {
  1210. return c.cid === b.cid;
  1211. });
  1212. return aCIndex === bCIndex
  1213. ? ctx.helper.compareCode(a.code, b.code)
  1214. : aCIndex - bCIndex;
  1215. });
  1216. return [change, changeBills];
  1217. } catch(err) {
  1218. this.ctx.helper.log(err);
  1219. throw err;
  1220. return [[], []];
  1221. }
  1222. }
  1223. async getGatherChange(memFieldKeys, gsDefine, gsCustom) {
  1224. if (!gsDefine || !gsDefine.enable) return [];
  1225. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1226. const result = { mem_gather_change: [], mem_gather_change_bills: [] };
  1227. const hasUsed = rmUtils.checkFieldsExist(memFieldKeys, ['used_qty', 'is_used_bgl', 'is_used', 'used_ratio']);
  1228. for (const t of gsCustom.tenders) {
  1229. const tender = await this.ctx.service.tender.getCheckTender(t.tid);
  1230. const [change, changeBills] = await this._gatherChange(tender, hasUsed);
  1231. result.mem_gather_change.push(...change);
  1232. result.mem_gather_change_bills.push(...changeBills);
  1233. }
  1234. return result;
  1235. }
  1236. async getGatherAdvancePay(memFieldKeys, gsDefine, gsCustom) {
  1237. if (!gsDefine || !gsDefine.enable) return [];
  1238. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1239. const result = [];
  1240. for (const t of gsCustom.tenders) {
  1241. // const tender = await this.ctx.service.tender.getCheckTender(t.tid);
  1242. const advance_pay = await this.ctx.service.advance.getAllDataByCondition({ where: { tid: t.tid } });
  1243. result.push(...advance_pay);
  1244. }
  1245. return result;
  1246. }
  1247. async _gatherStageJgcl(tender, stage) {
  1248. const data = await this.ctx.service.stageJgcl.getStageData(stage);
  1249. const preData = stage.preCheckedStage ? await this.ctx.service.stageJgcl.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
  1250. for (const d of data) {
  1251. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1252. if (pd) {
  1253. d.pre_arrive_qty = pd.arrive_qty;
  1254. d.pre_arrive_tp = pd.arrive_tp;
  1255. d.pre_deduct_qty = pd.deduct_qty;
  1256. d.pre_deduct_tp = pd.deduct_tp;
  1257. }
  1258. d.end_arrive_qty = this.ctx.helper.add(d.pre_arrive_qty, d.arrive_qty);
  1259. d.end_arrive_tp = this.ctx.helper.add(d.pre_arrive_tp, d.arrive_tp);
  1260. d.end_deduct_qty = this.ctx.helper.add(d.pre_deduct_qty, d.deduct_qty);
  1261. d.end_deduct_tp = this.ctx.helper.add(d.pre_deduct_tp, d.deduct_tp);
  1262. d.tender_name = tender.name;
  1263. }
  1264. this.resultStageJgcl.push(...data);
  1265. }
  1266. async _gatherMonthStageJgcl(sTender, month) {
  1267. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1268. const stages = await this._getValidStages(tender.id);
  1269. const stage = this.ctx.helper._.find(stages, {s_time: month});
  1270. await this._gatherStageJgcl(tender, stage);
  1271. }
  1272. async _gatherOrderStageJgcl(sTender, order) {
  1273. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1274. const stages = await this._getValidStages(tender.id);
  1275. const stage = this.ctx.helper._.find(stages, {order: order});
  1276. await this._gatherStageJgcl(tender, stage);
  1277. }
  1278. async _gatherFinalStageJgcl(sTender) {
  1279. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1280. const stages = await this._getValidStages(tender.id);
  1281. await this._gatherStageJgcl(tender, stages[0]);
  1282. }
  1283. async _gatherCheckedFinalStageJgcl(sTender) {
  1284. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1285. const stages = await this._getCheckedStages(tender.id);
  1286. await this._gatherStageJgcl(tender, stages[0]);
  1287. }
  1288. async getGatherStageJgcl(memFieldKeys, gsDefine, gsCustom) {
  1289. if (!gsDefine || !gsDefine.enable) return [];
  1290. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1291. this.resultStageJgcl = [];
  1292. const gsSetting = JSON.parse(gsDefine.setting);
  1293. for (const tender of gsCustom.tenders) {
  1294. switch (gsSetting.type) {
  1295. case 'month':
  1296. await this._gatherMonthStageJgcl(tender, gsCustom.month);
  1297. break;
  1298. case 'final':
  1299. await this._gatherFinalStageJgcl(tender);
  1300. break;
  1301. case 'checked-final':
  1302. await this._gatherCheckedFinalStageJgcl(tender);
  1303. break;
  1304. case 'stage':
  1305. await this._gatherOrderStageJgcl(tender, gsCustom.stage);
  1306. break;
  1307. }
  1308. }
  1309. return this.resultStageJgcl;
  1310. }
  1311. async _gatherStageBonus(tender, stage) {
  1312. const data = await this.ctx.service.stageBonus.getEndStageData(tender.id, stage.order);
  1313. for (const d of data) {
  1314. const names = this.ctx.helper._.map(d.proof_file, function (x) {
  1315. return x.filename + x.fileext;
  1316. });
  1317. d.proof = names.join('\n');
  1318. d.tender_name = tender.name;
  1319. }
  1320. this.resultStageBonus.push(...data);
  1321. }
  1322. async _gatherMonthStageBonus(sTender, month) {
  1323. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1324. const stages = await this._getValidStages(tender.id);
  1325. const stage = this.ctx.helper._.find(stages, {s_time: month});
  1326. await this._gatherStageBonus(tender, stage);
  1327. }
  1328. async _gatherOrderStageBonus(sTender, order) {
  1329. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1330. const stages = await this._getValidStages(tender.id);
  1331. const stage = this.ctx.helper._.find(stages, {order: order});
  1332. await this._gatherStageBonus(tender, stage);
  1333. }
  1334. async _gatherFinalStageBonus(sTender) {
  1335. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1336. const stages = await this._getValidStages(tender.id);
  1337. await this._gatherStageBonus(tender, stages[0]);
  1338. }
  1339. async _gatherCheckedFinalStageBonus(sTender) {
  1340. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1341. const stages = await this._getCheckedStages(tender.id);
  1342. await this._gatherStageBonus(tender, stages[0]);
  1343. }
  1344. async getGatherStageBonus(memFieldKeys, gsDefine, gsCustom) {
  1345. if (!gsDefine || !gsDefine.enable) return [];
  1346. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1347. this.resultStageBonus = [];
  1348. const gsSetting = JSON.parse(gsDefine.setting);
  1349. for (const tender of gsCustom.tenders) {
  1350. switch (gsSetting.type) {
  1351. case 'month':
  1352. await this._gatherMonthStageBonus(tender, gsCustom.month);
  1353. break;
  1354. case 'final':
  1355. await this._gatherFinalStageBonus(tender);
  1356. break;
  1357. case 'checked-final':
  1358. await this._gatherCheckedFinalStageBonus(tender);
  1359. break;
  1360. case 'stage':
  1361. await this._gatherOrderStageBonus(tender, gsCustom.stage);
  1362. break;
  1363. }
  1364. }
  1365. return this.resultStageBonus;
  1366. }
  1367. async _gatherStageOther(tender, stage) {
  1368. const data = await this.ctx.service.stageOther.getStageData(stage);
  1369. const preData = stage.preCheckedStage ? await this.ctx.service.stageOther.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
  1370. for (const d of data) {
  1371. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1372. if (pd) {
  1373. d.pre_tp = pd.tp;
  1374. }
  1375. d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
  1376. d.tender_name = tender.name;
  1377. }
  1378. this.resultStageOther.push(...data);
  1379. }
  1380. async _gatherMonthStageOther(sTender, month) {
  1381. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1382. const stages = await this._getValidStages(tender.id);
  1383. const stage = this.ctx.helper._.find(stages, {s_time: month});
  1384. await this._gatherStageOther(tender, stage);
  1385. }
  1386. async _gatherOrderStageOther(sTender, order) {
  1387. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1388. const stages = await this._getValidStages(tender.id);
  1389. const stage = this.ctx.helper._.find(stages, {order: order});
  1390. await this._gatherStageOther(tender, stage);
  1391. }
  1392. async _gatherFinalStageOther(sTender) {
  1393. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1394. const stages = await this._getValidStages(tender.id);
  1395. await this._gatherStageOther(tender, stages[0]);
  1396. }
  1397. async _gatherCheckedFinalStageOther(sTender) {
  1398. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1399. const stages = await this._getCheckedStages(tender.id);
  1400. await this._gatherStageOther(tender, stages[0]);
  1401. }
  1402. async getGatherStageOther(memFieldKeys, gsDefine, gsCustom) {
  1403. if (!gsDefine || !gsDefine.enable) return [];
  1404. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1405. this.resultStageOther = [];
  1406. const gsSetting = JSON.parse(gsDefine.setting);
  1407. for (const tender of gsCustom.tenders) {
  1408. switch (gsSetting.type) {
  1409. case 'month':
  1410. await this._gatherMonthStageOther(tender, gsCustom.month);
  1411. break;
  1412. case 'final':
  1413. await this._gatherFinalStageOther(tender);
  1414. break;
  1415. case 'checked-final':
  1416. await this._gatherCheckedFinalStageOther(tender);
  1417. break;
  1418. case 'stage':
  1419. await this._gatherOrderStageOther(tender, gsCustom.stage);
  1420. break;
  1421. }
  1422. }
  1423. return this.resultStageOther;
  1424. }
  1425. async _gatherStageSafeProd(tender, stage) {
  1426. const data = await this.ctx.service.stageSafeProd.getStageData(stage);
  1427. const preData = stage.preCheckedStage ? await this.ctx.service.stageSafeProd.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
  1428. for (const d of data) {
  1429. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1430. if (pd) {
  1431. d.pre_qty = pd.qty;
  1432. d.pre_tp = pd.tp;
  1433. }
  1434. d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
  1435. d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
  1436. }
  1437. const helper = this.ctx.helper;
  1438. for (const d of data) {
  1439. let gd = this.resultStageSafeProd.find(x => {
  1440. return x.name === d.name && x.unit === d.unit && helper.numEqual(x.unit_price, d.unit_price);
  1441. });
  1442. if (!gd) {
  1443. gd = { name: d.name, unit: d.unit, unit_price: d.unit_price };
  1444. this.resultStageSafeProd.push(gd);
  1445. }
  1446. gd.s_quantity = helper.add(gd.s_quantity, d.quantity);
  1447. gd.s_total_price = helper.add(gd.s_total_price, d.total_price);
  1448. gd.s_qty = helper.add(gd.s_qty, d.qty);
  1449. gd.s_tp = helper.add(gd.s_tp, d.tp);
  1450. gd.s_pre_qty = helper.add(gd.s_pre_qty, d.pre_qty);
  1451. gd.s_pre_tp = helper.add(gd.s_pre_tp, d.pre_tp);
  1452. gd.s_end_qty = helper.add(gd.s_end_qty, d.end_qty);
  1453. gd.s_end_tp = helper.add(gd.s_end_tp, d.end_tp);
  1454. }
  1455. }
  1456. async _gatherMonthStageSafeProd(sTender, month) {
  1457. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1458. const stages = await this._getValidStages(tender.id);
  1459. const stage = this.ctx.helper._.find(stages, {s_time: month});
  1460. await this._gatherStageSafeProd(tender, stage);
  1461. }
  1462. async _gatherOrderStageSafeProd(sTender, order) {
  1463. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1464. const stages = await this._getValidStages(tender.id);
  1465. const stage = this.ctx.helper._.find(stages, {order: order});
  1466. await this._gatherStageSafeProd(tender, stage);
  1467. }
  1468. async _gatherFinalStageSafeProd(sTender) {
  1469. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1470. const stages = await this._getValidStages(tender.id);
  1471. await this._gatherStageSafeProd(tender, stages[0]);
  1472. }
  1473. async _gatherCheckedFinalStageSafeProd(sTender) {
  1474. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1475. const stages = await this._getCheckedStages(tender.id);
  1476. await this._gatherStageSafeProd(tender, stages[0]);
  1477. }
  1478. async getGatherStageSafeProd(memFieldKeys, gsDefine, gsCustom) {
  1479. if (!gsDefine || !gsDefine.enable) return [];
  1480. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1481. this.resultStageSafeProd = [];
  1482. const gsSetting = JSON.parse(gsDefine.setting);
  1483. for (const tender of gsCustom.tenders) {
  1484. switch (gsSetting.type) {
  1485. case 'month':
  1486. await this._gatherMonthStageSafeProd(tender, gsCustom.month);
  1487. break;
  1488. case 'final':
  1489. await this._gatherFinalStageSafeProd(tender);
  1490. break;
  1491. case 'checked-final':
  1492. await this._gatherCheckedFinalStageSafeProd(tender);
  1493. break;
  1494. case 'stage':
  1495. await this._gatherOrderStageSafeProd(tender, gsCustom.stage);
  1496. break;
  1497. }
  1498. }
  1499. return this.resultStageSafeProd;
  1500. }
  1501. async _gatherStageTempLand(tender, stage) {
  1502. const data = await this.ctx.service.stageTempLand.getStageData(stage);
  1503. const preData = stage.preCheckedStage ? await this.ctx.service.stageTempLand.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
  1504. for (const d of data) {
  1505. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1506. if (pd) {
  1507. d.pre_qty = pd.qty;
  1508. d.pre_tp = pd.tp;
  1509. }
  1510. d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
  1511. d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
  1512. }
  1513. const helper = this.ctx.helper;
  1514. for (const d of data) {
  1515. let gd = this.resultStageTempLand.find(x => {
  1516. return x.name === d.name && x.unit === d.unit && helper.numEqual(x.unit_price, d.unit_price);
  1517. });
  1518. if (!gd) {
  1519. gd = { name: d.name, unit: d.unit, unit_price: d.unit_price };
  1520. this.resultStageTempLand.push(gd);
  1521. }
  1522. gd.s_qty = helper.add(gd.s_qty, d.qty);
  1523. gd.s_tp = helper.add(gd.s_tp, d.tp);
  1524. gd.s_pre_qty = helper.add(gd.s_pre_qty, d.pre_qty);
  1525. gd.s_pre_tp = helper.add(gd.s_pre_tp, d.pre_tp);
  1526. gd.s_end_qty = helper.add(gd.s_end_qty, d.end_qty);
  1527. gd.s_end_tp = helper.add(gd.s_end_tp, d.end_tp);
  1528. }
  1529. }
  1530. async _gatherMonthStageTempLand(sTender, month) {
  1531. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1532. const stages = await this._getValidStages(tender.id);
  1533. const stage = this.ctx.helper._.find(stages, {s_time: month});
  1534. await this._gatherStageTempLand(tender, stage);
  1535. }
  1536. async _gatherOrderStageTempLand(sTender, order) {
  1537. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1538. const stages = await this._getValidStages(tender.id);
  1539. const stage = this.ctx.helper._.find(stages, {order: order});
  1540. await this._gatherStageTempLand(tender, stage);
  1541. }
  1542. async _gatherFinalStageTempLand(sTender) {
  1543. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1544. const stages = await this._getValidStages(tender.id);
  1545. await this._gatherStageTempLand(tender, stages[0]);
  1546. }
  1547. async _gatherCheckedFinalStageTempLand(sTender) {
  1548. const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
  1549. const stages = await this._getCheckedStages(tender.id);
  1550. await this._gatherStageTempLand(tender, stages[0]);
  1551. }
  1552. async getGatherStageTempLand(memFieldKeys, gsDefine, gsCustom) {
  1553. if (!gsDefine || !gsDefine.enable) return [];
  1554. if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
  1555. this.resultStageTempLand = [];
  1556. const gsSetting = JSON.parse(gsDefine.setting);
  1557. for (const tender of gsCustom.tenders) {
  1558. switch (gsSetting.type) {
  1559. case 'month':
  1560. await this._gatherMonthStageTempLand(tender, gsCustom.month);
  1561. break;
  1562. case 'final':
  1563. await this._gatherFinalStageTempLand(tender);
  1564. break;
  1565. case 'checked-final':
  1566. await this._gatherCheckedFinalStageTempLand(tender);
  1567. break;
  1568. case 'stage':
  1569. await this._gatherOrderStageTempLand(tender, gsCustom.stage);
  1570. break;
  1571. }
  1572. }
  1573. return this.resultStageTempLand;
  1574. }
  1575. }
  1576. return RptGatherMemory;
  1577. };