rpt_gather_memory.js 87 KB

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