12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703 |
- 'use strict';
- /**
- *
- *
- * @author Mai
- * @date
- * @version
- */
- const Ledger = require('../lib/ledger');
- const PayCalculator = require('../lib/pay_calc');
- const auditConst = require('../const/audit');
- const payConst = require('../const/deal_pay');
- const changeConst = require('../const/change');
- const moment = require('moment');
- const indexPre = 'id_';
- const normalPrefix = 't_', sumPrefix = 's_', specPrefix = 'ts_';
- const gatherUtils = {
- completeGatherData: function (datas, completeDatas) {
- for (const data of datas) {
- for (const cd of completeDatas) {
- data[cd.prefix + 'id'] = cd.id;
- data[cd.prefix + 'name'] = cd.name;
- data[cd.prefix + 'category'] = cd.category;
- }
- }
- },
- gatherStage: function (tender, gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + 'id'] = tender.id;
- gatherNode[prefix + 'name'] = tender.name;
- gatherNode[prefix + 'category'] = tender.category;
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
- gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
- gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);
- gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
- gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
- gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
- gatherNode[prefix + "contract_tp"] = helper.add(gatherNode[prefix + "contract_tp"], sourceNode.contract_tp);
- gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
- gatherNode[prefix + "qc_tp"] = helper.add(gatherNode[prefix + "qc_tp"], sourceNode.qc_tp);
- gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
- gatherNode[prefix + "gather_tp"] = helper.add(gatherNode[prefix + "gather_tp"], sourceNode.gather_tp);
- gatherNode[prefix + 'contract_pc_tp'] = helper.add(gatherNode[prefix + 'contract_pc_tp'], sourceNode.contract_pc_tp);
- gatherNode[prefix + 'qc_pc_tp'] = helper.add(gatherNode[prefix + 'qc_pc_tp'], sourceNode.qc_pc_tp);
- gatherNode[prefix + 'pc_tp'] = helper.add(gatherNode[prefix + 'pc_tp'], sourceNode.pc_tp);
- gatherNode[prefix + "pre_contract_qty"] = helper.add(gatherNode[prefix + "pre_contract_qty"], sourceNode.pre_contract_qty);
- gatherNode[prefix + "pre_contract_tp"] = helper.add(gatherNode[prefix + "pre_contract_tp"], sourceNode.pre_contract_tp);
- gatherNode[prefix + "pre_qc_qty"] = helper.add(gatherNode[prefix + "pre_qc_qty"], sourceNode.pre_qc_qty);
- gatherNode[prefix + "pre_qc_tp"] = helper.add(gatherNode[prefix + "pre_qc_tp"], sourceNode.pre_qc_tp);
- gatherNode[prefix + "pre_gather_qty"] = helper.add(gatherNode[prefix + "pre_gather_qty"], sourceNode.pre_gather_qty);
- gatherNode[prefix + "pre_gather_tp"] = helper.add(gatherNode[prefix + "pre_gather_tp"], sourceNode.pre_gather_tp);
- gatherNode[prefix + "end_contract_qty"] = helper.add(gatherNode[prefix + "end_contract_qty"], sourceNode.end_contract_qty);
- gatherNode[prefix + "end_contract_tp"] = helper.add(gatherNode[prefix + "end_contract_tp"], sourceNode.end_contract_tp);
- gatherNode[prefix + "end_qc_qty"] = helper.add(gatherNode[prefix + "end_qc_qty"], sourceNode.end_qc_qty);
- gatherNode[prefix + "end_qc_tp"] = helper.add(gatherNode[prefix + "end_qc_tp"], sourceNode.end_qc_tp);
- gatherNode[prefix + "end_gather_qty"] = helper.add(gatherNode[prefix + "end_gather_qty"], sourceNode.end_gather_qty);
- gatherNode[prefix + "end_gather_tp"] = helper.add(gatherNode[prefix + "end_gather_tp"], sourceNode.end_gather_tp);
- gatherNode[prefix + "deal_dgn_qty1"] = helper.add(gatherNode[prefix + "deal_dgn_qty1"], sourceNode.deal_dgn_qty1);
- gatherNode[prefix + "deal_dgn_qty2"] = helper.add(gatherNode[prefix + "deal_dgn_qty2"], sourceNode.deal_dgn_qty2);
- gatherNode[prefix + "c_dgn_qty1"] = helper.add(gatherNode[prefix + "c_dgn_qty1"], sourceNode.c_dgn_qty1);
- gatherNode[prefix + "c_dgn_qty2"] = helper.add(gatherNode[prefix + "c_dgn_qty2"], sourceNode.c_dgn_qty2);
- gatherNode[prefix + "due_qc_qty"] = helper.add(gatherNode[prefix + "due_qc_qty"], sourceNode.due_qc_qty);
- gatherNode[prefix + "due_qc_tp"] = helper.add(gatherNode[prefix + "due_qc_tp"], sourceNode.due_qc_tp);
- gatherNode[prefix + "due_qc_minus_qty"] = helper.add(gatherNode[prefix + "due_qc_minus_qty"], sourceNode.due_qc_minus_qty);
- gatherNode[prefix + "due_final_qty"] = helper.add(gatherNode[prefix + "due_final_qty"], sourceNode.due_final_qty);
- gatherNode[prefix + "due_final_tp"] = helper.add(gatherNode[prefix + "due_final_tp"], sourceNode.due_final_tp);
- gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
- gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
- gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
- gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
- gatherNode.s_dgn_qty1 = helper.add(gatherNode.s_dgn_qty1, sourceNode.dgn_qty1);
- gatherNode.s_dgn_qty2 = helper.add(gatherNode.s_dgn_qty2, sourceNode.dgn_qty2);
- gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
- gatherNode.s_contract_tp = helper.add(gatherNode.s_contract_tp, sourceNode.contract_tp);
- gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
- gatherNode.s_qc_tp = helper.add(gatherNode.s_qc_tp, sourceNode.qc_tp);
- gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
- gatherNode.s_gather_tp = helper.add(gatherNode.s_gather_tp, sourceNode.gather_tp);
- gatherNode.s_contract_pc_tp = helper.add(gatherNode.s_contract_pc_tp, sourceNode.contract_pc_tp);
- gatherNode.s_qc_pc_tp = helper.add(gatherNode.s_qc_pc_tp, sourceNode.qc_pc_tp);
- gatherNode.s_pc_tp = helper.add(gatherNode.s_pc_tp, sourceNode.pc_tp);
- gatherNode.s_pre_contract_qty = helper.add(gatherNode.s_pre_contract_qty, sourceNode.pre_contract_qty);
- gatherNode.s_pre_contract_tp = helper.add(gatherNode.s_pre_contract_tp, sourceNode.pre_contract_tp);
- gatherNode.s_pre_qc_qty = helper.add(gatherNode.s_pre_qc_qty, sourceNode.pre_qc_qty);
- gatherNode.s_pre_qc_tp = helper.add(gatherNode.s_pre_qc_tp, sourceNode.pre_qc_tp);
- gatherNode.s_pre_gather_qty = helper.add(gatherNode.s_pre_gather_qty, sourceNode.pre_gather_qty);
- gatherNode.s_pre_gather_tp = helper.add(gatherNode.s_pre_gather_tp, sourceNode.pre_gather_tp);
- gatherNode.s_end_contract_qty = helper.add(gatherNode.s_end_contract_qty, sourceNode.end_contract_qty);
- gatherNode.s_end_contract_tp = helper.add(gatherNode.s_end_contract_tp, sourceNode.end_contract_tp);
- gatherNode.s_end_qc_qty = helper.add(gatherNode.s_end_qc_qty, sourceNode.end_qc_qty);
- gatherNode.s_end_qc_tp = helper.add(gatherNode.s_end_qc_tp, sourceNode.end_qc_tp);
- gatherNode.s_end_gather_qty = helper.add(gatherNode.s_end_gather_qty, sourceNode.end_gather_qty);
- gatherNode.s_end_gather_tp = helper.add(gatherNode.s_end_gather_tp, sourceNode.end_gather_tp);
- gatherNode.s_deal_dgn_qty1 = helper.add(gatherNode.s_deal_dgn_qty1, sourceNode.deal_dgn_qty1);
- gatherNode.s_deal_dgn_qty2 = helper.add(gatherNode.s_deal_dgn_qty2, sourceNode.deal_dgn_qty2);
- gatherNode.s_c_dgn_qty1 = helper.add(gatherNode.s_c_dgn_qty1, sourceNode.c_dgn_qty1);
- gatherNode.s_c_dgn_qty2 = helper.add(gatherNode.s_c_dgn_qty2, sourceNode.c_dgn_qty2);
- gatherNode.s_due_qc_qty = helper.add(gatherNode.s_due_qc_qty, sourceNode.due_qc_qty);
- gatherNode.s_due_qc_tp = helper.add(gatherNode.s_due_qc_tp, sourceNode.due_qc_tp);
- gatherNode.s_due_qc_minus_qty = helper.add(gatherNode.s_due_qc_minus_qty, sourceNode.due_qc_minus_qty);
- gatherNode.s_due_final_qty = helper.add(gatherNode.s_due_final_qty, sourceNode.due_final_qty);
- gatherNode.s_due_final_tp = helper.add(gatherNode.s_due_final_tp, sourceNode.due_final_tp);
- },
- gatherZone: function (tender, gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + 'id'] = tender.id;
- gatherNode[prefix + 'name'] = tender.name;
- gatherNode[prefix + 'category'] = tender.category;
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
- gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
- gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);
- gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
- gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
- gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
- gatherNode[prefix + "contract_tp"] = helper.add(gatherNode[prefix + "contract_tp"], sourceNode.contract_tp);
- gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
- gatherNode[prefix + "qc_tp"] = helper.add(gatherNode[prefix + "qc_tp"], sourceNode.qc_tp);
- gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
- gatherNode[prefix + "gather_tp"] = helper.add(gatherNode[prefix + "gather_tp"], sourceNode.gather_tp);
- gatherNode[prefix + 'pc_tp'] = helper.add(gatherNode[prefix + 'pc_tp'], sourceNode.pc_tp);
- gatherNode[prefix + "deal_dgn_qty1"] = helper.add(gatherNode[prefix + "deal_dgn_qty1"], sourceNode.deal_dgn_qty1);
- gatherNode[prefix + "deal_dgn_qty2"] = helper.add(gatherNode[prefix + "deal_dgn_qty2"], sourceNode.deal_dgn_qty2);
- gatherNode[prefix + "c_dgn_qty1"] = helper.add(gatherNode[prefix + "c_dgn_qty1"], sourceNode.c_dgn_qty1);
- gatherNode[prefix + "c_dgn_qty2"] = helper.add(gatherNode[prefix + "c_dgn_qty2"], sourceNode.c_dgn_qty2);
- gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
- gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
- gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
- gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
- gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
- gatherNode.s_contract_tp = helper.add(gatherNode.s_contract_tp, sourceNode.contract_tp);
- gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
- gatherNode.s_qc_tp = helper.add(gatherNode.s_qc_tp, sourceNode.qc_tp);
- gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
- gatherNode.s_gather_tp = helper.add(gatherNode.s_gather_tp, sourceNode.gather_tp);
- gatherNode.s_pc_tp = helper.add(gatherNode.s_pc_tp, sourceNode.pc_tp);
- },
- gatherLedger: function (tender, gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + 'id'] = tender.id;
- gatherNode[prefix + 'name'] = tender.name;
- gatherNode[prefix + 'category'] = tender.category;
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
- gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
- gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);
- gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
- gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
- gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
- gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
- gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
- gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
- },
- gatherSpecial: function (gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
- gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
- gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
- },
- gatherStagePos: function (tender, gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + 'id'] = tender.id;
- gatherNode[prefix + 'name'] = tender.name;
- gatherNode[prefix + 'category'] = tender.category;
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
- gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
- gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
- gatherNode[prefix + "pre_contract_qty"] = helper.add(gatherNode[prefix + "pre_contract_qty"], sourceNode.pre_contract_qty);
- gatherNode[prefix + "pre_qc_qty"] = helper.add(gatherNode[prefix + "pre_qc_qty"], sourceNode.pre_qc_qty);
- gatherNode[prefix + "pre_gather_qty"] = helper.add(gatherNode[prefix + "pre_gather_qty"], sourceNode.pre_gather_qty);
- gatherNode[prefix + "end_contract_qty"] = helper.add(gatherNode[prefix + "end_contract_qty"], sourceNode.end_contract_qty);
- gatherNode[prefix + "end_qc_qty"] = helper.add(gatherNode[prefix + "end_qc_qty"], sourceNode.end_qc_qty);
- gatherNode[prefix + "end_gather_qty"] = helper.add(gatherNode[prefix + "end_gather_qty"], sourceNode.end_gather_qty);
- gatherNode[prefix + "due_qc_qty"] = helper.add(gatherNode[prefix + "due_qc_qty"], sourceNode.due_qc_qty);
- gatherNode[prefix + "due_final_qty"] = helper.add(gatherNode[prefix + "due_final_qty"], sourceNode.due_final_qty);
- gatherNode[prefix + "due_qc_minus_qty"] = helper.add(gatherNode[prefix + "due_qc_minus_qty"], sourceNode.due_qc_minus_qty);
- gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
- gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
- gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
- gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
- gatherNode.s_pre_contract_qty = helper.add(gatherNode.s_pre_contract_qty, sourceNode.pre_contract_qty);
- gatherNode.s_pre_qc_qty = helper.add(gatherNode.s_pre_qc_qty, sourceNode.pre_qc_qty);
- gatherNode.s_pre_gather_qty = helper.add(gatherNode.s_pre_gather_qty, sourceNode.pre_gather_qty);
- gatherNode.s_end_contract_qty = helper.add(gatherNode.s_end_contract_qty, sourceNode.end_contract_qty);
- gatherNode.s_end_qc_qty = helper.add(gatherNode.s_end_qc_qty, sourceNode.end_qc_qty);
- gatherNode.s_end_gather_qty = helper.add(gatherNode.s_end_gather_qty, sourceNode.end_gather_qty);
- gatherNode.s_due_qc_qty = helper.add(gatherNode.s_due_qc_qty, sourceNode.due_qc_qty);
- gatherNode.s_due_final_qty = helper.add(gatherNode.s_due_final_qty, sourceNode.due_final_qty);
- gatherNode.s_due_qc_minus_qty = helper.add(gatherNode.s_due_qc_minus_qty, sourceNode.due_qc_minus_qty);
- },
- gatherZonePos: function (tender, gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + 'id'] = tender.id;
- gatherNode[prefix + 'name'] = tender.name;
- gatherNode[prefix + 'category'] = tender.category;
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
- gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
- gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
- gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
- gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
- gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
- gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
- },
- gatherPos: function (tender, gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + 'id'] = tender.id;
- gatherNode[prefix + 'name'] = tender.name;
- gatherNode[prefix + 'category'] = tender.category;
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
- },
- gatherSpecialPos: function (gatherNode, sourceNode, prefix, helper) {
- gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
- },
- };
- const rmUtils = require('../lib/rm/rm_utils');
- module.exports = app => {
- class RptGatherMemory extends app.BaseService {
- /**
- * 构造函数
- *
- * @param {Object} ctx - egg全局context
- * @return {void}
- */
- constructor(ctx) {
- super(ctx);
- this.resultTree = null;
- this.resultPos = null;
- this.resultTenderInfo = [];
- this.resultDealPay = [];
- this.resultDealBills = [];
- }
- _checkFieldsExistReg(source, regStr) {
- const reg = new RegExp(regStr, 'igm');
- for (const s of source) {
- if (reg.test(s)) {
- return true;
- }
- }
- return false;
- }
- async _getValidStages(tenderId, sort = 'desc') {
- const stages = await this.db.select(this.ctx.service.stage.tableName, {
- where: { tid: tenderId },
- orders: [['order', sort]],
- });
- if (stages.length !== 0) {
- const lastStage = stages[0];
- if (lastStage.status === auditConst.stage.status.uncheck && lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
- stages.splice(0, 1);
- }
- }
- return stages;
- }
- async _getCheckedStages(tenderId) {
- const stages = await this.db.select(this.ctx.service.stage.tableName, {
- where: { tid: tenderId },
- orders: [['order', 'desc']],
- });
- if (stages.length !== 0) {
- const lastStage = stages[0];
- if (lastStage.status !== auditConst.stage.status.checked) {
- stages.splice(0, 1);
- }
- }
- return stages;
- }
- _checkSpecialTender(tender, special) {
- if (special) {
- for (const spec of special) {
- if (tender[spec.key] === true) return spec.key;
- }
- }
- return '';
- }
- async _getTimeZoneStages(tender, zone) {
- const times = zone.split(' - ');
- if (times.length !== 2) throw '选择的汇总周期无效';
- const beginTime = moment(times[0], 'YYYY-MM');
- const endTime = moment(times[1], 'YYYY-MM');
- const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
- let preStage, endStage;
- for (const stage of stages) {
- const sTime = moment(stage.s_time, 'YYYY-MM');
- if (sTime.isBetween(beginTime, endTime, null, '[]')) {
- validStages.push(stage);
- } else if (sTime.isBefore(beginTime)) {
- if (!preStage || moment(preStage.s_time, 'YYYY-MM').isBefore(sTime)) preStage = stage;
- } else if (sTime.isAfter(endTime)) {
- if (!endStage || moment(endStage.s_time, 'YYYY-MM').isAfter(sTime)) endStage = stage;
- }
- }
- return [validStages, preStage, endStage];
- }
- async _getOrderZoneStages (tender, zone) {
- let [iBegin, iEnd] = zone.split(':');
- iBegin = this.ctx.helper._.toInteger(iBegin) || 0;
- iEnd = this.ctx.helper._.toInteger(iEnd) || 0;
- const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
- let preStage, endStage;
- for (const stage of stages) {
- if (stage.order < iBegin) {
- if (!preStage || preStage.order < stage.order) preStage = stage;
- } else if (stage.order > iEnd) {
- if (!endStage || endStage.order > stage.order) endStage = stage;
- } else {
- validStages.push(stage);
- }
- }
- return [validStages, preStage, endStage];
- }
- async _getCustomZoneStages(tender, zone, timeType) {
- const times = zone.split(' - ');
- if (times.length !== 2) throw '选择的汇总周期无效';
- const beginTime = moment(times[0], 'YYYY-MM-DD');
- const endTime = moment(times[1], 'YYYY-MM-DD');
- const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
- let preStage, endStage;
- for (const stage of stages) {
- let sTime;
- switch (timeType) {
- case 'final-checked':
- if (stage.status !== auditConst.stage.status.checked) continue;
- const finalAudit = await this.ctx.service.stageAudit.getLastestAuditor(stage.id, stage.times, stage.status);
- if (!finalAudit) continue;
- sTime = moment(finalAudit.end_time).format('YYYY-MM-DD');
- break;
- case 'period-end':
- sTime = stage.period ? (stage.period.split(' ~ ')[1] ? stage.period.split(' ~ ')[1] : stage.period) : '';
- break;
- default:
- throw '配置参数错误';
- }
- stage.checked_day = sTime;
- stage.checked_time = moment(sTime, 'YYYY-MM-DD');
- if (stage.checked_time.isBetween(beginTime, endTime, null, '[]')) {
- validStages.push(stage);
- } else if (stage.checked_time.isBefore(beginTime)) {
- if (!preStage || preStage.checked_time.isBefore(stage.checked_time)) preStage = stage;
- } else if (stage.checked_time.isAfter(endTime)) {
- if (!endStage || endStage.checked_time.isAfter(stage.checked_time)) endStage = stage;
- }
- }
- return [validStages, preStage, endStage];
- }
- async _getMonthStages(tender, month) {
- const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
- for (const stage of stages) {
- if (stage.s_time === month) validStages.push(stage);
- }
- const preStage = stages.length > 0 ? stages.find(x => { return x.order === stages[0].order - 1; }) : null;
- const endStage = stages.length > 0 ? stages.find(x => { return x.order === stages[stages.length - 1].order + 1; }) : null;
- return [validStages, preStage, endStage];
- }
- /**
- * 台账数据
- */
- async _gatherStagesData(completeData, tender, stages, preStage) {
- const resultPos = this.resultPos;
- const helper = this.ctx.helper;
- completeData.id = tender.id;
- completeData.name = tender.name;
- /**
- * 汇总并合并 相关数据
- * @param {Array} index - 主数据
- * @param {Array[]}rela - 相关数据 {data, fields, prefix, relaId}
- */
- const sumAssignRelaData = function (index, rela) {
- const loadFields = function (datas, fields, prefix, relaId) {
- for (const d of datas) {
- const key = indexPre + d[relaId];
- const m = index[key];
- if (m) {
- for (const f of fields) {
- if (d[f] !== undefined) {
- m[prefix + f] = helper.add(m[prefix + f], d[f]);
- }
- }
- }
- }
- };
- for (const r of rela) {
- loadFields(r.data, r.fields, r.prefix, r.relaId);
- }
- };
- const billsTree = new Ledger.billsTree(this.ctx, {
- id: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- rootId: -1,
- keys: ['id', 'tender_id', 'ledger_id'],
- stageId: 'id',
- 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'],
- calc: function (node) {
- if (node.children && node.children.length === 0) {
- node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
- node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
- node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
- node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
- node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
- }
- node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
- node.gather_tp = helper.add(node.contract_tp, node.qc_tp);
- node.end_contract_tp = helper.add(node.pre_contract_tp, node.contract_tp);
- node.end_qc_tp = helper.add(node.pre_qc_tp, node.qc_tp);
- node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
- }
- });
- const billsData = await this.ctx.service.ledger.getData(tender.id);
- const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(tender.id);
- for (const d of dgnData) {
- const l = this.ctx.helper._.find(billsData, {id: d.id});
- this.ctx.helper._.assignIn(l, d);
- }
- const pos = new Ledger.pos({
- id: 'id', ledgerId: 'lid',
- calc: function (node) {
- node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
- node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
- node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
- node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
- node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
- },
- });
- const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: tender.id} });
- let billsIndexData = {};
- for (const bd of billsData) {
- billsIndexData[indexPre + bd.id] = bd;
- }
- let posIndexData = {};
- for (const p of posData) {
- posIndexData[indexPre + p.id] = p;
- }
- if (preStage) {
- await this.ctx.service.stage.doCheckStage(preStage);
- const endStage = await this.ctx.service.stageBillsFinal.getFinalData(tender, preStage.order);
- sumAssignRelaData(billsIndexData, [
- { data: endStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
- ]);
- const endStagePos = await this.ctx.service.stagePosFinal.getFinalData(tender, preStage.order);
- sumAssignRelaData(posIndexData, [
- {data: endStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'lid'},
- ]);
- }
- for (const stage of stages) {
- await this.ctx.service.stage.doCheckStage(stage);
- const curStage = stage.readOnly
- ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
- const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
- sumAssignRelaData(billsIndexData, [
- {data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid'},
- { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
- ]);
- const curStagePos = stage.readOnly
- ? await this.ctx.service.stagePos.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stagePos.getLastestStageData2(tender.id, stage.id);
- sumAssignRelaData(posIndexData, [
- {data: curStagePos, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid'},
- ]);
- }
- billsTree.loadDatas(billsData);
- billsTree.calculateAll();
- pos.loadDatas(posData);
- pos.calculateAll();
- this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
- gatherUtils.gatherStage(tender, gatherNode, sourceNode, completeData.prefix, helper);
- }, function (gatherNode, sourceNode) {
- const posRange = pos.getLedgerPos(sourceNode.id);
- if (!posRange || posRange.length === 0) return;
- resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
- gatherUtils.gatherStagePos(tender, gatherPos, sourcePos, completeData.prefix, helper);
- });
- });
- }
- async _gatherZoneData(tender, completeData, zone) {
- const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
- await this._gatherStagesData(completeData, tender, stages, preStage);
- }
- async _gatherIndexZoneData(tender, completeData, stageZone) {
- const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
- await this._gatherStagesData(completeData, tender, stages, preStage);
- }
- async _gatherCustomZoneData(tender, completeData, zone, timeType) {
- const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
- await this._gatherStagesData(completeData, tender, stages, preStage);
- }
- async _gatherMonthsData(tender, completeData, month) {
- const [stages, preStage, endStage] = await this._getMonthStages(tender, month);
- await this._gatherStagesData(completeData, tender, stages, preStage);
- }
- async _gatherStageData(completeData, tender, stage, hasPre) {
- const helper = this.ctx.helper;
- const resultPos = this.resultPos;
- completeData.id = tender.id;
- completeData.name = tender.name;
- const billsTree = new Ledger.billsTree(this.ctx, {
- id: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- rootId: -1,
- keys: ['id', 'tender_id', 'ledger_id'],
- stageId: 'id',
- 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',
- 'end_contract_tp', 'end_qc_tp', 'end_gather_tp',
- 'due_qc_tp', 'due_final_tp',
- ],
- calc: function (node) {
- if (node.children && node.children.length === 0) {
- node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
- node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
- node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
- node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
- node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
- node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
- }
- node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
- node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
- node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
- node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
- node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
- node.due_final_tp = helper.add(node.total_price, node.due_qc_tp);
- }
- });
- const billsData = await this.ctx.service.ledger.getData(tender.id);
- const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(tender.id);
- const changeBillsData = await this.ctx.service.changeAuditList.getBillsSum(tender.id);
- this.ctx.helper.assignRelaData(billsData, [
- { data: dgnData, fields: ['deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2'], prefix: '', relaId: 'id' },
- { data: changeBillsData, fields: ['qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'due_', relaId: 'gcl_id' },
- ]);
- const pos = new Ledger.pos({
- id: 'id', ledgerId: 'lid',
- calc: function (node) {
- node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
- node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
- node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
- node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
- node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
- node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
- },
- });
- const posData = await this.ctx.service.pos.getPosData({ tid: tender.id });
- const changePosData = await this.ctx.service.changeAuditList.getPosSum(tender.id);
- this.ctx.helper.assignRelaData(posData, [
- { data: changePosData, fields: ['qc_qty', 'qc_minus_qty'], prefix: 'due_', relaId: 'mx_id' },
- ]);
- if (stage) {
- await this.ctx.service.stage.doCheckStage(stage);
- const curStage = stage.readOnly
- ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
- const preStage = hasPre && stage.preCheckedStage ? await this.ctx.service.stageBillsFinal.getFinalData(tender, stage.preCheckedStage.order) : [];
- const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
- this.ctx.helper.assignRelaData(billsData, [
- { data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid' },
- { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
- { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
- ]);
- const curStagePos = stage.readOnly
- ? await this.ctx.service.stagePos.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stagePos.getLastestStageData2(tender.id, stage.id);
- const preStagePos = hasPre && stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(tender, stage.preCheckedStage.order) : [];
- this.ctx.helper.assignRelaData(posData, [
- { data: curStagePos, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid' },
- { data: preStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid' },
- ]);
- }
- billsTree.loadDatas(billsData);
- billsTree.calculateAll();
- pos.loadDatas(posData);
- pos.calculateAll();
- this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
- gatherUtils.gatherStage(tender, gatherNode, sourceNode, completeData.prefix, helper);
- }, function (gatherNode, sourceNode) {
- const posRange = pos.getLedgerPos(sourceNode.id);
- if (!posRange || posRange.length === 0) return;
- resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
- gatherUtils.gatherStagePos(tender, gatherPos, sourcePos, completeData.prefix, helper);
- });
- });
- }
- async _gatherMonthData(tender, completeData, month, hasPre) {
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStageData(completeData, tender, stage, hasPre);
- }
- async _gatherIndexData(tender, completeData, index, hasPre) {
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: index});
- await this._gatherStageData(completeData, tender, stage, hasPre);
- }
- async _gatherFinalData(tender, completeData, hasPre) {
- const stages = await this._getValidStages(tender.id);
- await this._gatherStageData(completeData, tender, stages[0], hasPre);
- }
- async _gatherCheckedFinalData(tender, completeData, hasPre) {
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStageData(completeData, tender, stages[0], hasPre);
- }
- async _loadGatherLedger(tender) {
- const billsTree = new Ledger.billsTree(this.ctx, {
- id: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- rootId: -1,
- keys: ['id', 'tender_id', 'ledger_id'],
- stageId: 'id',
- calcFields: ['deal_tp', 'total_price'],
- });
- const billsData = await this.ctx.service.ledger.getData(tender.id);
- billsTree.loadDatas(billsData);
- billsTree.calculateAll();
- return billsTree;
- }
- async _loadGatherPos(tender) {
- const pos = new Ledger.pos({ id: 'id', ledgerId: 'lid' });
- const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: tender.id } });
- pos.loadDatas(posData);
- return pos;
- }
- async _gatherLedgerData(tender, completeData) {
- const resultPos = this.resultPos;
- const helper = this.ctx.helper;
- const billsTree = await this._loadGatherLedger(tender);
- const pos = await this._loadGatherPos(tender);
- this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
- gatherUtils.gatherLedger(tender, gatherNode, sourceNode, completeData.prefix, helper);
- }, function (gatherNode, sourceNode) {
- const posRange = pos.getLedgerPos(sourceNode.id);
- if (!posRange || posRange.length === 0) return;
- resultPos.loadGatherPos(posRange, (gatherPos, sourcePos) => {
- gatherUtils.gatherPos(gatherPos, sourcePos, completeData.prefix, helper);
- });
- });
- }
- async _gatherSpecialData(tender, sKey) {
- const resultPos = this.resultPos;
- const helper = this.ctx.helper;
- const billsTree = await this._loadGatherLedger(tender);
- const pos = await this._loadGatherPos(tender);
- this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
- gatherUtils.gatherSpecial(gatherNode, sourceNode, 'ts_' + sKey + '_', helper);
- }, function (gatherNode, sourceNode) {
- const posRange = pos.getLedgerPos(sourceNode.id);
- if (!posRange || posRange.length === 0) return;
- resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
- gatherUtils.gatherSpecialPos(gatherPos, sourcePos, 'ts_' + sKey + '_', helper);
- });
- });
- }
- async _doGatherStageData(memFieldKeys, gsDefine, gsCustom) {
- if (this.resultTree || this.resultPos) return;
- if (!gsDefine || !gsDefine.enable) return;
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return;
- this.resultTree = new Ledger.gatherTree(this.ctx, {
- id: 'id',
- pid: 'pid',
- order: 'order',
- level: 'level',
- rootId: -1
- });
- this.resultPos = new Ledger.gatherPos({ id: 'id', ledgerId: 'lid' });
- const gsSetting = JSON.parse(gsDefine.setting);
- let commonIndex = 0;
- const completeDatas = [];
- for (const t of gsCustom.tenders) {
- const specialKey = this._checkSpecialTender(t, gsSetting.special);
- const tender = await this.ctx.service.tender.getCheckTender(t.tid);
- if (specialKey === '') {
- const completeData = {
- prefix: 't_' + commonIndex + '_',
- };
- completeDatas.push(completeData);
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthData(tender, completeData, gsCustom.month, gsSetting.hasPre);
- break;
- case 'months':
- await this._gatherMonthsData(tender, completeData, gsCustom.months);
- break;
- case 'zone':
- await this._gatherZoneData(tender, completeData, gsCustom.zone);
- break;
- case 'final':
- await this._gatherFinalData(tender, completeData, gsSetting.hasPre);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalData(tender, completeData, gsSetting.hasPre);
- break;
- case 'ledger':
- await this._gatherLedgerData(tender, completeData);
- break;
- case 'stage':
- await this._gatherIndexData(tender, completeData, gsCustom.stage, gsSetting.hasPre);
- break;
- case 'stage-zone':
- await this._gatherIndexZoneData(tender, completeData, gsCustom.stage_zone);
- break;
- case 'custom-zone':
- await this._gatherCustomZoneData(tender, completeData, gsCustom.custom_zone, gsSetting.timeType);
- break;
- }
- commonIndex++;
- } else {
- await this._gatherSpecialData(tender, specialKey);
- }
- }
- this.resultTree.resortChildrenDefault();
- gatherUtils.completeGatherData(this.resultTree.nodes, completeDatas);
- gatherUtils.completeGatherData(this.resultPos.datas, completeDatas);
- }
- async getGatherStageBills(memFieldKeys, gsDefine, gsCustom, showLevel) {
- await this._doGatherStageData(memFieldKeys, gsDefine, gsCustom);
- return this.resultTree
- ? (showLevel ? this.resultTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : this.resultTree.getDefaultDatas())
- : [];
- }
- async getGatherStagePos(memFieldKeys, gsDefine, gsCustom) {
- await this._doGatherStageData(memFieldKeys, gsDefine, gsCustom);
- return this.resultPos ? this.resultPos.getDatas() : [];
- }
- /**
- * 标段信息
- */
- async _getBaseTenderInfo(tender) {
- const info = {
- id: tender.id,
- name: tender.name,
- deal_tp: tender.deal_tp,
- tp: tender.total_price
- };
- const deal_bills_sum = await this.ctx.service.dealBills.getSum(tender.id);
- info.deal_bills_tp = deal_bills_sum ? deal_bills_sum.total_price : 0;
- if (tender.ledger_status === auditConst.ledger.status.uncheck || tender.ledger_status === auditConst.ledger.status.checkNo) {
- const sum = await this.ctx.service.ledger.addUp({tender_id: tender.id/*, is_leaf: true*/});
- info.tp = sum.total_price;
- info.deal_tp = sum.deal_tp;
- }
- info.deal_info = tender.info.deal_info;
- info.construction_unit = tender.info.construction_unit;
- info.tech_param = tender.info.tech_param;
- info.deal_param = tender.info.deal_param;
- info.pay_account = tender.info.pay_account;
- info.deal_param.contractPriceWithoutZL = this.ctx.helper.sub(info.deal_param.contractPrice,
- info.deal_param.zanLiePrice);
- info.bid_info = tender.info.bid_info;
- return info;
- }
- async _getStageTenderInfo(stage, info) {
- if (stage) {
- const helper = this.ctx.helper;
- await this.ctx.service.stage.doCheckStage(stage);
- await this.ctx.service.stage.checkStageGatherData(stage, this.ctx.session.sessionUser.is_admin);
- info.pre_contract_tp = stage.pre_contract_tp;
- info.pre_qc_tp = stage.pre_qc_tp;
- info.pre_gather_tp = helper.add(info.pre_contract_tp, info.pre_qc_tp);
- info.contract_tp = stage.contract_tp;
- info.qc_tp = stage.qc_tp;
- info.gather_tp = helper.add(info.contract_tp, info.qc_tp);
- info.end_contract_tp = helper.add(info.pre_contract_tp, info.contract_tp);
- info.end_qc_tp = helper.add(info.pre_qc_tp, info.qc_tp);
- info.end_gather_tp = helper.add(info.pre_gather_tp, info.gather_tp);
- info.yf_tp = stage.yf_tp;
- info.pre_yf_tp = stage.pre_yf_tp;
- info.end_yf_tp = helper.add(stage.yf_tp, stage.pre_yf_tp);
- info.sf_tp = stage.sf_tp;
- info.pre_sf_tp = stage.pre_sf_tp;
- info.end_sf_tp = helper.add(stage.sf_tp, stage.pre_sf_tp);
- }
- }
- async _getStagesTenderInfo(stages, info, preStage) {
- const helper = this.ctx.helper;
- if (preStage) {
- info.pre_contract_tp = helper.add(preStage.contract_tp, preStage.pre_contract_tp);
- info.pre_qc_tp = helper.add(preStage.qc_tp, preStage.pre_qc_tp);
- info.pre_gather_tp = helper.add(info.pre_contract_tp, info.pre_qc_tp);
- info.pre_yf_tp = helper.add(preStage.yf_tp, preStage.pre_yf_tp);
- }
- for (const stage of stages) {
- await this.ctx.service.stage.doCheckStage(stage);
- await this.ctx.service.stage.checkStageGatherData(stage, this.ctx.session.sessionUser.is_admin);
- info.contract_tp = helper.add(info.contract_tp, stage.contract_tp);
- info.qc_tp = helper.add(info.qc_tp, stage.qc_tp);
- info.yf_tp = helper.add(info.yf_tp, stage.yf_tp);
- }
- info.gather_tp = helper.add(info.contract_tp, info.qc_tp);
- info.end_contract_tp = helper.add(info.pre_contract_tp, info.contract_tp);
- info.end_qc_tp = helper.add(info.pre_qc_tp, info.qc_tp);
- info.end_gather_tp = helper.add(info.pre_gather_tp, info.gather_tp);
- info.end_yf_tp = helper.add(info.pre_yf_tp, info.yf_tp);
- }
- async _gatherZoneTenderInfo(tender, index, zone) {
- const info = await this._getBaseTenderInfo(tender);
- const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
- await this._getStagesTenderInfo(stages, info, preStage);
- this.resultTenderInfo.push(info);
- }
- async _gatherOrderZoneTenderInfo(tender, index, stageZone) {
- const info = await this._getBaseTenderInfo(tender);
- const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
- await this._getStagesTenderInfo(stages, info, preStage);
- this.resultTenderInfo.push(info);
- }
- async _gatherCustomZoneTenderInfo(tender, index, zone, timeType) {
- const info = await this._getBaseTenderInfo(tender);
- const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
- await this._getStagesTenderInfo(stages, info, preStage);
- this.resultTenderInfo.push(info);
- }
- async _gatherMonthTenderInfo(tender, index, month, hasPre) {
- const info = await this._getBaseTenderInfo(tender);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._getStageTenderInfo(stage, info);
- this.resultTenderInfo.push(info);
- }
- async _gatherOrderTenderInfo(tender, index, order, hasPre) {
- const info = await this._getBaseTenderInfo(tender);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._getStageTenderInfo(stage, info);
- this.resultTenderInfo.push(info);
- }
- async _gatherFinalTenderInfo(tender, index, hasPre) {
- const info = await this._getBaseTenderInfo(tender);
- const stages = await this._getValidStages(tender.id);
- await this._getStageTenderInfo(stages[0], info);
- this.resultTenderInfo.push(info);
- }
- async _gatherCheckedFinalTenderInfo(tender, index, hasPre) {
- const info = await this._getBaseTenderInfo(tender);
- const stages = await this._getCheckedStages(tender.id);
- await this._getStageTenderInfo(stages[0], info);
- this.resultTenderInfo.push(info);
- }
- async _gatherLedgerTenderInfo(tender, index) {
- const info = await this._getBaseTenderInfo(tender);
- this.resultTenderInfo.push(info);
- }
- async _gatherSpecialTenderInfo(tender, sKey) {
- const info = await this._getBaseTenderInfo(tender);
- info.spec = sKey;
- this.resultTenderInfo.push(info);
- }
- async getGatherTenderInfo(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultTenderInfo = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- let commonIndex = 0;
- for (const t of gsCustom.tenders) {
- const specialKey = this._checkSpecialTender(t, gsSetting.special);
- const tender = await this.ctx.service.tender.getCheckTender(t.tid);
- if (specialKey === '') {
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthTenderInfo(tender, commonIndex, gsCustom.month, gsSetting.hasPre);
- break;
- case 'zone':
- await this._gatherZoneTenderInfo(tender, commonIndex, gsCustom.zone);
- break;
- case 'final':
- await this._gatherFinalTenderInfo(tender, commonIndex, gsSetting.hasPre);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalTenderInfo(tender, commonIndex, gsSetting.hasPre);
- break;
- case 'ledger':
- await this._gatherLedgerTenderInfo(tender, commonIndex);
- break;
- case 'stage':
- await this._gatherOrderTenderInfo(tender, commonIndex, gsCustom.stage, gsSetting.hasPre);
- break;
- case 'stage-zone':
- await this._gatherOrderZoneTenderInfo(tender, commonIndex, gsCustom.stage_zone);
- break;
- case 'custom-zone':
- await this._gatherCustomZoneTenderInfo(tender, commonIndex, gsCustom.custom_zone, gsSetting.timeType);
- break;
- }
- commonIndex++;
- } else {
- await this._gatherSpecialTenderInfo(tender, specialKey);
- }
- }
- return this.resultTenderInfo;
- }
- /**
- * 合同支付
- */
- _gatherPayRecord(dealPay, fun) {
- let rdp;
- if (dealPay.ptype !== payConst.payType.normal) {
- rdp = this.ctx.helper._.find(this.resultDealPay, {ptype: dealPay.ptype});
- } else {
- rdp = this.ctx.helper._.find(this.resultDealPay, {
- name: dealPay.name,
- minus: dealPay.minus ? true : false,
- is_yf: dealPay.is_yf ? true : false,
- });
- }
- if (!rdp) {
- rdp = {
- ptype: dealPay.ptype,
- name: dealPay.name,
- minus: dealPay.minus ? true : false,
- is_yf: dealPay.is_yf ? true : false,
- };
- this.resultDealPay.push(rdp);
- }
- if (fun) fun(rdp, dealPay);
- }
- async _checkStagePayCalc(tender, stage, dealPay) {
- if (!stage.readOnly) {
- // 计算 本期金额
- const payCalculator = new PayCalculator(this.ctx, stage, tender.info);
- await payCalculator.calculateAll(dealPay);
- }
- }
- async _gatherStagePay(completeData, tender, stage, hasPre) {
- if (stage) {
- completeData.id = tender.id;
- completeData.name = tender.name;
- const helper = this.ctx.helper;
- await this.ctx.service.stage.doCheckStage(stage);
- const dealPay = await this.ctx.service.stagePay.getStagePays(stage);
- await this._checkStagePayCalc(tender, stage, dealPay);
- for (const dp of dealPay) {
- dp.end_tp = helper.add(dp.pre_tp, dp.tp);
- this._gatherPayRecord(dp, function (gatherData, sourceData) {
- gatherData[completeData.prefix + 'id'] = tender.id;
- gatherData[completeData.prefix + 'name'] = tender.name;
- gatherData[completeData.prefix + 'tp'] = helper.add(gatherData[completeData.prefix + 'tp'], sourceData.tp);
- gatherData[completeData.prefix + 'pre_tp'] = helper.add(gatherData[completeData.prefix + 'pre_tp'], sourceData.pre_tp);
- gatherData[completeData.prefix + 'end_tp'] = helper.add(gatherData[completeData.prefix + 'end_tp'], sourceData.end_tp);
- gatherData['s_' + 'tp'] = helper.add(gatherData['s_' + 'tp'], sourceData.tp);
- gatherData['s_' + 'pre_tp'] = helper.add(gatherData['s_' + 'pre_tp'], sourceData.pre_tp);
- gatherData['s_' + 'end_tp'] = helper.add(gatherData['s_' + 'end_tp'], sourceData.end_tp);
- });
- }
- }
- }
- async _gatherStagesPay(completeData, tender, stages, preStage) {
- const helper = this.ctx.helper;
- completeData.id = tender.id;
- completeData.name = tender.name;
- if (preStage) await this.ctx.service.stage.doCheckStage(preStage);
- const preDealPay = preStage ? await this.ctx.service.stagePay.getStagePays(preStage) : [];
- for (const dp of preDealPay) {
- dp.end_tp = helper.add(dp.pre_tp, dp.tp);
- this._gatherPayRecord(dp, function (gatherData, sourceData) {
- gatherData[completeData.prefix + 'id'] = tender.id;
- gatherData[completeData.prefix + 'name'] = tender.name;
- gatherData[completeData.prefix + 'pre_tp'] = sourceData.end_tp;
- gatherData.s_pre_tp = helper.add(gatherData.s_pre_tp, sourceData.end_tp);
- gatherData[completeData.prefix + 'end_tp'] = sourceData.end_tp;
- gatherData.s_end_tp = helper.add(gatherData.s_end_tp, sourceData.end_tp);
- });
- }
- for (const stage of stages) {
- await this.ctx.service.stage.doCheckStage(stage);
- const dealPay = await this.ctx.service.stagePay.getStagePays(stage);
- await this._checkStagePayCalc(tender, stage, dealPay);
- for (const dp of dealPay) {
- dp.end_tp = helper.add(dp.pre_tp, dp.tp);
- this._gatherPayRecord(dp, function (gatherData, sourceData) {
- gatherData[completeData.prefix + 'id'] = tender.id;
- gatherData[completeData.prefix + 'name'] = tender.name;
- gatherData[completeData.prefix + 'tp'] = helper.add(gatherData[completeData.prefix + 'tp'], sourceData.tp);
- gatherData['s_' + 'tp'] = helper.add(gatherData['s_' + 'tp'], sourceData.tp);
- gatherData[completeData.prefix + 'end_tp'] = helper.add(gatherData[completeData.prefix + 'end_tp'], sourceData.tp);
- gatherData['s_' + 'end_tp'] = helper.add(gatherData['s_' + 'end_tp'], sourceData.tp);
- });
- }
- }
- }
- async _gatherZoneStagePay(sTender, completeData, zone) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
- await this._gatherStagesPay(completeData, tender, stages, preStage);
- }
- async _gatherOrderZoneStagePay(sTender, completeData, stageZone) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
- await this._gatherStagesPay(completeData, tender, stages, preStage);
- }
- async _gatherCustomZoneStagePay(sTender, completeData, zone, timeType) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
- await this._gatherStagesPay(completeData, tender, stages, preStage);
- }
- async _gatherMonthStagePay(sTender, completeData, month, hasPre) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStagePay(completeData, tender, stage, hasPre);
- }
- async _gatherOrderStagePay(sTender, completeData, order, hasPre) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._gatherStagePay(completeData, tender, stage, hasPre);
- }
- async _gatherFinalStagePay(sTender, completeData, hasPre) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- await this._gatherStagePay(completeData, tender, stages[0], hasPre);
- }
- async _gatherCheckedFinalStagePay(sTender, completeData, hasPre) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStagePay(completeData, tender, stages[0], hasPre);
- }
- async getGatherStagePay(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultDealPay = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- let commonIndex = 0;
- const completeDatas = [];
- for (const tender of gsCustom.tenders) {
- const specialKey = this._checkSpecialTender(tender, gsSetting.special);
- if (specialKey === '') {
- const completeData = {
- prefix: 't_' + commonIndex + '_',
- };
- completeDatas.push(completeData);
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthStagePay(tender, completeData, gsCustom.month, gsSetting.hasPre);
- break;
- case 'zone':
- await this._gatherZoneStagePay(tender, completeData, gsCustom.zone);
- break;
- case 'final':
- await this._gatherFinalStagePay(tender, completeData, gsSetting.hasPre);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalStagePay(tender, completeData, gsSetting.hasPre);
- break;
- case 'stage':
- await this._gatherOrderStagePay(tender, completeData, gsCustom.stage, gsSetting.hasPre);
- break;
- case 'stage-zone':
- await this._gatherOrderZoneStagePay(tender, completeData, gsCustom.stage_zone);
- break;
- case 'custom-zone':
- await this._gatherCustomZoneStagePay(tender, completeData, gsCustom.custom_zone, gsSetting.timeType);
- break;
- }
- commonIndex++;
- }
- // 合同支付,只有在每一期中有数据,故特殊标段直接不汇总合同支付
- }
- gatherUtils.completeGatherData(this.resultDealPay, completeDatas);
- return this.resultDealPay;
- }
- /**
- * 签约清单
- */
- async _gatherDealBills(tender, fun) {
- const dealBills = await this.ctx.service.dealBills.getAllDataByCondition({
- where: { tender_id: tender.id }
- });
- for (const db of dealBills) {
- let rdb = this.ctx.helper._.find(this.resultDealBills, {
- code: db.code,
- name: db.name,
- unit: db.unit,
- unit_price: db.unit_price ? db.unit_price: 0,
- });
- if (!rdb) {
- rdb = {
- code: db.code,
- name: db.name,
- unit: db.unit,
- unit_price: db.unit_price ? db.unit_price: 0,
- };
- this.resultDealBills.push(rdb);
- }
- if (fun) fun(rdb, db);
- }
- }
- async _gatherCommonDealBills(sTender, completeData) {
- const self = this;
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- completeData.id = tender.id;
- completeData.name = tender.name;
- await this._gatherDealBills(tender, function (gatherData, sourceData) {
- gatherData[completeData.prefix + 'id'] = tender.id;
- gatherData[completeData.prefix + 'name'] = tender.name;
- gatherData[completeData.prefix + 'qty'] = sourceData.quantity;
- gatherData[completeData.prefix + 'tp'] = sourceData.total_price;
- gatherData['s_' + 'qty'] = self.ctx.helper.add(gatherData['s_' + 'qty'], sourceData.quantity);
- gatherData['s_' + 'tp'] = self.ctx.helper.add(gatherData['s_' + 'tp'], sourceData.total_price);
- });
- }
- async _gatherSpecialDealBills(sTender, sKey) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- await this._gatherDealBills(tender, function (gatherData, sourceData) {
- const prefix = 'ts_' + sKey + '_';
- gatherData[prefix + 'qty'] = sourceData.quantity;
- gatherData[prefix + 'tp'] = sourceData.total_price;
- });
- }
- async getGatherDealBills(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultTenderInfo = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- let commonIndex = 0;
- const completeDatas = [];
- for (const tender of gsCustom.tenders) {
- const specialKey = this._checkSpecialTender(tender, gsSetting.special);
- if (specialKey === '') {
- const completeData = {
- prefix: 't_' + commonIndex + '_',
- };
- completeDatas.push(completeData);
- await this._gatherCommonDealBills(tender, completeData);
- commonIndex++;
- } else {
- await this._gatherSpecialDealBills(tender, specialKey);
- }
- }
- gatherUtils.completeGatherData(this.resultDealBills, completeDatas);
- return this.resultDealBills;
- }
- _getChangeConstName(define, value) {
- for (const prop in define) {
- if (define[prop].value === value) {
- return define[prop].name;
- }
- }
- return '';
- }
- async _gatherChange(tender, hasUsed) {
- const self = this;
- try {
- const info = await this.ctx.service.tenderInfo.getTenderInfo(tender.id);
- const decimal = info.decimal, ctx = this.ctx;
- const where = { tid: tender.id, valid: 1 };
- if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.flow.status.checked;
- const change = await this.ctx.service.change.getAllDataByCondition({ where, orders: [['in_time', 'desc']] });
- for (const c of change) {
- c.tender_name = tender.name;
- const types = ctx.helper._.map(c.type.split(','), function (t) {
- return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
- });
- c.type = types.join(';');
- c.class = this._getChangeConstName(changeConst.class, c.class);
- c.quality = this._getChangeConstName(changeConst.quality, c.quality);
- c.charge = this._getChangeConstName(changeConst.charge, c.charge);
- c.attachments = await ctx.service.changeAtt.getChangeAttachment(c.cid);
- const names = ctx.helper._.map(c.attachments, function (x) {
- return x.filename + x.fileext;
- });
- c.attNames = names.join('\n');
- }
- const changeBills = hasUsed
- ? await this.ctx.service.stageChangeFinal.getChangeBillsWithUsedQty(tender.id, this.ctx.session.sessionProject.page_show.isOnlyChecked)
- : await this.ctx.service.changeAuditList.getChangeAuditBills(tender.id, this.ctx.session.sessionProject.page_show.isOnlyChecked);
- for (const d of changeBills) {
- d.tender_name = tender.name;
- d.o_qty = d.oamount;
- d.o_tp = this.ctx.helper.mul(d.o_qty, d.unit_price, decimal.tp);
- d.c_qty = d.camount;
- d.c_tp = this.ctx.helper.mul(d.c_qty, d.unit_price, decimal.tp);
- d.s_qty = d.samount ? parseFloat(d.samount) : 0;
- d.s_tp = this.ctx.helper.mul(d.s_qty, d.unit_price, decimal.tp);
- d.sp_qty = d.spamount;
- d.sp_tp = this.ctx.helper.mul(d.sp_qty, d.unit_price, decimal.tp);
- d.used_tp = this.ctx.helper.mul(d.used_qty, d.unit_price, decimal.tp);
- d.is_used = !!d.used_qty;
- const auditAmount = d.audit_amount ? d.audit_amount.split(',') : [];
- const relaChange = ctx.helper._.find(change, {cid: d.cid});
- d.relaChange = relaChange;
- if (relaChange) {
- if (d.is_used) relaChange.is_used = true;
- relaChange.used_tp = ctx.helper.add(relaChange.used_tp, d.used_tp);
- }
- for (const [i, aa] of auditAmount.entries()) {
- const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
- d[amountField] = aa ? parseFloat(aa) : 0;
- d[tpField] = ctx.helper.mul(d[amountField], d.unit_price, decimal.tp);
- if (relaChange) {
- relaChange[tpField] = ctx.helper.add(relaChange[tpField], d[tpField]);
- }
- }
- }
- for (const c of change) {
- c.is_used = !!c.is_used;
- c.used_ratio = c.total_price ? ctx.helper.mul(ctx.helper.div(c.used_tp, c.total_price), 100) : 0;
- }
- for (const cb of changeBills) {
- cb.is_used_bgl = cb.relaChange ? cb.relaChange.is_used : cb.is_used;
- delete cb.relaChange;
- }
- change.sort(function (a, b) {
- return a.code.localeCompare(b.code);
- });
- changeBills.sort(function (a, b) {
- const aCIndex = change.findIndex(function (c) {
- return c.cid === a.cid;
- });
- const bCIndex = change.findIndex(function (c) {
- return c.cid === b.cid;
- });
- return aCIndex === bCIndex
- ? ctx.helper.compareCode(a.code, b.code)
- : aCIndex - bCIndex;
- });
- return [change, changeBills];
- } catch(err) {
- this.ctx.helper.log(err);
- throw err;
- return [[], []];
- }
- }
- async getGatherChange(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- const result = { mem_gather_change: [], mem_gather_change_bills: [] };
- const hasUsed = rmUtils.checkFieldsExist(memFieldKeys, ['used_qty', 'is_used_bgl', 'is_used', 'used_ratio']);
- for (const t of gsCustom.tenders) {
- const tender = await this.ctx.service.tender.getCheckTender(t.tid);
- const [change, changeBills] = await this._gatherChange(tender, hasUsed);
- result.mem_gather_change.push(...change);
- result.mem_gather_change_bills.push(...changeBills);
- }
- return result;
- }
- async getGatherAdvancePay(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- const result = [];
- for (const t of gsCustom.tenders) {
- // const tender = await this.ctx.service.tender.getCheckTender(t.tid);
- const advance_pay = await this.ctx.service.advance.getAllDataByCondition({ where: { tid: t.tid } });
- result.push(...advance_pay);
- }
- return result;
- }
- async _gatherStageJgcl(tender, stage) {
- const data = await this.ctx.service.stageJgcl.getStageData(stage);
- const preData = stage.preCheckedStage ? await this.ctx.service.stageJgcl.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_arrive_qty = pd.arrive_qty;
- d.pre_arrive_tp = pd.arrive_tp;
- d.pre_deduct_qty = pd.deduct_qty;
- d.pre_deduct_tp = pd.deduct_tp;
- }
- d.end_arrive_qty = this.ctx.helper.add(d.pre_arrive_qty, d.arrive_qty);
- d.end_arrive_tp = this.ctx.helper.add(d.pre_arrive_tp, d.arrive_tp);
- d.end_deduct_qty = this.ctx.helper.add(d.pre_deduct_qty, d.deduct_qty);
- d.end_deduct_tp = this.ctx.helper.add(d.pre_deduct_tp, d.deduct_tp);
- d.tender_name = tender.name;
- }
- this.resultStageJgcl.push(...data);
- }
- async _gatherMonthStageJgcl(sTender, month) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStageJgcl(tender, stage);
- }
- async _gatherOrderStageJgcl(sTender, order) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._gatherStageJgcl(tender, stage);
- }
- async _gatherFinalStageJgcl(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- await this._gatherStageJgcl(tender, stages[0]);
- }
- async _gatherCheckedFinalStageJgcl(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStageJgcl(tender, stages[0]);
- }
- async getGatherStageJgcl(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultStageJgcl = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- for (const tender of gsCustom.tenders) {
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthStageJgcl(tender, gsCustom.month);
- break;
- case 'final':
- await this._gatherFinalStageJgcl(tender);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalStageJgcl(tender);
- break;
- case 'stage':
- await this._gatherOrderStageJgcl(tender, gsCustom.stage);
- break;
- }
- }
- return this.resultStageJgcl;
- }
- async _gatherStageBonus(tender, stage) {
- const data = await this.ctx.service.stageBonus.getEndStageData(tender.id, stage.order);
- for (const d of data) {
- const names = this.ctx.helper._.map(d.proof_file, function (x) {
- return x.filename + x.fileext;
- });
- d.proof = names.join('\n');
- d.tender_name = tender.name;
- }
- this.resultStageBonus.push(...data);
- }
- async _gatherMonthStageBonus(sTender, month) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStageBonus(tender, stage);
- }
- async _gatherOrderStageBonus(sTender, order) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._gatherStageBonus(tender, stage);
- }
- async _gatherFinalStageBonus(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- await this._gatherStageBonus(tender, stages[0]);
- }
- async _gatherCheckedFinalStageBonus(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStageBonus(tender, stages[0]);
- }
- async getGatherStageBonus(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultStageBonus = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- for (const tender of gsCustom.tenders) {
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthStageBonus(tender, gsCustom.month);
- break;
- case 'final':
- await this._gatherFinalStageBonus(tender);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalStageBonus(tender);
- break;
- case 'stage':
- await this._gatherOrderStageBonus(tender, gsCustom.stage);
- break;
- }
- }
- return this.resultStageBonus;
- }
- async _gatherStageOther(tender, stage) {
- const data = await this.ctx.service.stageOther.getStageData(stage);
- const preData = stage.preCheckedStage ? await this.ctx.service.stageOther.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_tp = pd.tp;
- }
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- d.tender_name = tender.name;
- }
- this.resultStageOther.push(...data);
- }
- async _gatherMonthStageOther(sTender, month) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStageOther(tender, stage);
- }
- async _gatherOrderStageOther(sTender, order) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._gatherStageOther(tender, stage);
- }
- async _gatherFinalStageOther(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- await this._gatherStageOther(tender, stages[0]);
- }
- async _gatherCheckedFinalStageOther(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStageOther(tender, stages[0]);
- }
- async getGatherStageOther(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultStageOther = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- for (const tender of gsCustom.tenders) {
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthStageOther(tender, gsCustom.month);
- break;
- case 'final':
- await this._gatherFinalStageOther(tender);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalStageOther(tender);
- break;
- case 'stage':
- await this._gatherOrderStageOther(tender, gsCustom.stage);
- break;
- }
- }
- return this.resultStageOther;
- }
- async _gatherStageSafeProd(tender, stage) {
- const data = await this.ctx.service.stageSafeProd.getStageData(stage);
- const preData = stage.preCheckedStage ? await this.ctx.service.stageSafeProd.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_qty = pd.qty;
- d.pre_tp = pd.tp;
- }
- d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- }
- const helper = this.ctx.helper;
- for (const d of data) {
- let gd = this.resultStageSafeProd.find(x => {
- return x.name === d.name && x.unit === d.unit && helper.numEqual(x.unit_price, d.unit_price);
- });
- if (!gd) {
- gd = { name: d.name, unit: d.unit, unit_price: d.unit_price };
- this.resultStageSafeProd.push(gd);
- }
- gd.s_quantity = helper.add(gd.s_quantity, d.quantity);
- gd.s_total_price = helper.add(gd.s_total_price, d.total_price);
- gd.s_qty = helper.add(gd.s_qty, d.qty);
- gd.s_tp = helper.add(gd.s_tp, d.tp);
- gd.s_pre_qty = helper.add(gd.s_pre_qty, d.pre_qty);
- gd.s_pre_tp = helper.add(gd.s_pre_tp, d.pre_tp);
- gd.s_end_qty = helper.add(gd.s_end_qty, d.end_qty);
- gd.s_end_tp = helper.add(gd.s_end_tp, d.end_tp);
- }
- }
- async _gatherMonthStageSafeProd(sTender, month) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStageSafeProd(tender, stage);
- }
- async _gatherOrderStageSafeProd(sTender, order) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._gatherStageSafeProd(tender, stage);
- }
- async _gatherFinalStageSafeProd(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- await this._gatherStageSafeProd(tender, stages[0]);
- }
- async _gatherCheckedFinalStageSafeProd(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStageSafeProd(tender, stages[0]);
- }
- async getGatherStageSafeProd(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultStageSafeProd = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- for (const tender of gsCustom.tenders) {
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthStageSafeProd(tender, gsCustom.month);
- break;
- case 'final':
- await this._gatherFinalStageSafeProd(tender);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalStageSafeProd(tender);
- break;
- case 'stage':
- await this._gatherOrderStageSafeProd(tender, gsCustom.stage);
- break;
- }
- }
- return this.resultStageSafeProd;
- }
- async _gatherStageTempLand(tender, stage) {
- const data = await this.ctx.service.stageTempLand.getStageData(stage);
- const preData = stage.preCheckedStage ? await this.ctx.service.stageTempLand.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_qty = pd.qty;
- d.pre_tp = pd.tp;
- }
- d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- }
- const helper = this.ctx.helper;
- for (const d of data) {
- let gd = this.resultStageTempLand.find(x => {
- return x.name === d.name && x.unit === d.unit && helper.numEqual(x.unit_price, d.unit_price);
- });
- if (!gd) {
- gd = { name: d.name, unit: d.unit, unit_price: d.unit_price };
- this.resultStageTempLand.push(gd);
- }
- gd.s_qty = helper.add(gd.s_qty, d.qty);
- gd.s_tp = helper.add(gd.s_tp, d.tp);
- gd.s_pre_qty = helper.add(gd.s_pre_qty, d.pre_qty);
- gd.s_pre_tp = helper.add(gd.s_pre_tp, d.pre_tp);
- gd.s_end_qty = helper.add(gd.s_end_qty, d.end_qty);
- gd.s_end_tp = helper.add(gd.s_end_tp, d.end_tp);
- }
- }
- async _gatherMonthStageTempLand(sTender, month) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {s_time: month});
- await this._gatherStageTempLand(tender, stage);
- }
- async _gatherOrderStageTempLand(sTender, order) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- const stage = this.ctx.helper._.find(stages, {order: order});
- await this._gatherStageTempLand(tender, stage);
- }
- async _gatherFinalStageTempLand(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getValidStages(tender.id);
- await this._gatherStageTempLand(tender, stages[0]);
- }
- async _gatherCheckedFinalStageTempLand(sTender) {
- const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
- const stages = await this._getCheckedStages(tender.id);
- await this._gatherStageTempLand(tender, stages[0]);
- }
- async getGatherStageTempLand(memFieldKeys, gsDefine, gsCustom) {
- if (!gsDefine || !gsDefine.enable) return [];
- if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
- this.resultStageTempLand = [];
- const gsSetting = JSON.parse(gsDefine.setting);
- for (const tender of gsCustom.tenders) {
- switch (gsSetting.type) {
- case 'month':
- await this._gatherMonthStageTempLand(tender, gsCustom.month);
- break;
- case 'final':
- await this._gatherFinalStageTempLand(tender);
- break;
- case 'checked-final':
- await this._gatherCheckedFinalStageTempLand(tender);
- break;
- case 'stage':
- await this._gatherOrderStageTempLand(tender, gsCustom.stage);
- break;
- }
- }
- return this.resultStageTempLand;
- }
- }
- return RptGatherMemory;
- };
|