rpt_yanghu_data_util.js 74 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841
  1. /**
  2. * Created by Tony on 2017/7/14.
  3. * 报表数据提取class,是协助报表模板里指标字段自主提取数据的工具类
  4. */
  5. let JV = require('../rpt_component/jpc_value_define');
  6. let $JE = require('../rpt_component/jpc_rte');
  7. let consts = require('../../../modules/main/models/project_consts');
  8. let fsUtil = require("../../../public/fsUtil");
  9. let stringUtil = require("../../../public/stringUtil");
  10. let scMathUtil = require("../../../public/scMathUtil");
  11. let _ = require("lodash");
  12. let treeUtil = require('../../../public/treeUtil');
  13. let projectConst = consts.projectConst;
  14. let projectConstList = consts.projectConstList;
  15. const gljUtil = require('../../../public/gljUtil');
  16. const gljType = require('../../common/const/glj_type_const');
  17. // const pm_facade = require('../../pm/facade/pm_facade');
  18. const GLJID_PRE = `gljId_`, COMPONENT_GLJID_PRE = `componetGljId_`;
  19. const GLJ_TYPE = {
  20. Labour: 1,
  21. Material: 2,
  22. Machine: 3,
  23. Main_Material: 4,
  24. Equipment: 5,
  25. OTHER_MATERIAL: 207,
  26. MACHINE_LABOUR: 303,
  27. INSTRUMENT: 304,
  28. FUEL_POWER_FEE: 305
  29. };
  30. const oprMachines = [306, 307, 308, 309, 310, 311, 312];
  31. class Rpt_Common{
  32. initialize(rpt_tpl, currentDataObj) {
  33. this.template = rpt_tpl;
  34. this.currentDataObj = currentDataObj;
  35. };
  36. Multiply(val1, val2, fixFormat) {
  37. let rst = [], maxLen = val1.length, minLen = val2.length;
  38. if (minLen > maxLen) {
  39. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  40. }
  41. for (let i = 0; i < maxLen; i++) {
  42. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) * ((i < val2.length)?val2[i]:val2[minLen - 1]);
  43. if (value === null || value === undefined) {
  44. value = '0';
  45. }
  46. if (fixFormat) value = value.toFixed(fixFormat);
  47. rst.push(value);
  48. }
  49. return rst;
  50. };
  51. Divide(val1, val2, fixFormat) {
  52. let rst = [], maxLen = val1.length, minLen = val2.length;
  53. if (minLen > maxLen) {
  54. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  55. }
  56. for (let i = 0; i < maxLen; i++) {
  57. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) / ((i < val2.length)?val2[i]:val2[minLen - 1]);
  58. if (fixFormat) value = value.toFixed(fixFormat);
  59. rst.push(value);
  60. }
  61. return rst;
  62. };
  63. Plus(val1, val2, fixFormat) {
  64. let rst = [], maxLen = val1.length, minLen = val2.length;
  65. if (minLen > maxLen) {
  66. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  67. }
  68. for (let i = 0; i < maxLen; i++) {
  69. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) + ((i < val2.length)?val2[i]:val2[minLen - 1]);
  70. if (fixFormat) value = value.toFixed(fixFormat);
  71. rst.push(value);
  72. }
  73. return rst;
  74. };
  75. MultiPlus(arrVal, fixFormat) {
  76. let rst = [];
  77. for (let i = 0; i < arrVal.length; i++) {
  78. let valItem = arrVal[i];
  79. if (i === 0) {
  80. for (let dtl of valItem) {
  81. let value = parseFloat(dtl);
  82. if (fixFormat) value = value.toFixed(fixFormat);
  83. rst.push(value);
  84. }
  85. } else {
  86. for (let j = 0; j < valItem.length; j++) {
  87. if (j < rst.length) {
  88. let value = rst[j] + valItem[j];
  89. if (fixFormat) value = value.toFixed(fixFormat);
  90. rst[j] = value;
  91. } else {
  92. let value = parseFloat(valItem[j]);
  93. if (fixFormat) value = value.toFixed(fixFormat);
  94. rst.push(value);
  95. }
  96. }
  97. }
  98. }
  99. return rst;
  100. };
  101. Minus(val1, val2, fixFormat) {
  102. let rst = [], maxLen = val1.length, minLen = val2.length;
  103. if (minLen > maxLen) {
  104. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  105. }
  106. for (let i = 0; i < maxLen; i++) {
  107. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) - ((i < val2.length)?val2[i]:val2[minLen - 1]);
  108. if (fixFormat) value = value.toFixed(fixFormat);
  109. rst.push(value);
  110. }
  111. return rst;
  112. };
  113. FormatString(arrVal, formatStr){
  114. let rst = [];
  115. for (let val of arrVal) {
  116. rst.push(stringUtil.replaceAll(formatStr, '%S', val));
  117. }
  118. return rst;
  119. };
  120. }
  121. class Rpt_Data_Extractor {
  122. constructor () {
  123. this.COMMON = new Rpt_Common();
  124. };
  125. initialize(tpl) {
  126. this.rptTpl = tpl;
  127. };
  128. //-- 根据报表模板映射指标(非离散指标)的定义,罗列出所有需要用到的data对象key,作为数据请求的过滤依据
  129. getDataRequestFilter(summaryRst) {
  130. let rst = [];
  131. let tpl = this.rptTpl;
  132. let pri_func_chk_filter = function (field) {
  133. for (let key of projectConstList) {
  134. if (rst.indexOf(key) < 0) {
  135. if (field[JV.PROP_FIELD_EXP_MAP]) {
  136. if (field[JV.PROP_FIELD_EXP_MAP].indexOf('.' + key + '.') >= 0) {
  137. rst.push(key);
  138. if (key === projectConst.RATION_GLJ && (rst.indexOf(projectConst.PROJECTGLJ) < 0)) {
  139. rst.push(projectConst.PROJECTGLJ);
  140. }
  141. if (key === projectConst.PROJECTGLJ) {
  142. if (rst.indexOf(projectConst.RATION_GLJ) < 0) rst.push(projectConst.RATION_GLJ);
  143. if (field[JV.PROP_FIELD_EXP_MAP].indexOf("'quantity'") > 0 ||
  144. field[JV.PROP_FIELD_EXP_MAP].indexOf("'subdivisionQuantity'") > 0 ||
  145. field[JV.PROP_FIELD_EXP_MAP].indexOf("'techQuantity'") > 0 ) {
  146. if (rst.indexOf(projectConst.RATION) < 0) rst.push(projectConst.RATION);
  147. if (rst.indexOf(projectConst.BILLS) < 0) rst.push(projectConst.BILLS);
  148. }
  149. }
  150. }
  151. }
  152. } else if (key === projectConst.PROJECTGLJ) {
  153. if (rst.indexOf(projectConst.RATION_GLJ) < 0) rst.push(projectConst.RATION_GLJ);
  154. if (field[JV.PROP_FIELD_EXP_MAP].indexOf("'quantity'") > 0 ||
  155. field[JV.PROP_FIELD_EXP_MAP].indexOf("'subdivisionQuantity'") > 0 ||
  156. field[JV.PROP_FIELD_EXP_MAP].indexOf("'techQuantity'") > 0 ) {
  157. if (rst.indexOf(projectConst.RATION) < 0) rst.push(projectConst.RATION);
  158. if (rst.indexOf(projectConst.BILLS) < 0) rst.push(projectConst.BILLS);
  159. }
  160. }
  161. }
  162. if (summaryRst instanceof Array) {
  163. for (let key of consts.summaryConstList) {
  164. if (summaryRst.indexOf(key) < 0) {
  165. if (field[JV.PROP_FIELD_EXP_MAP]) {
  166. if (field[JV.PROP_FIELD_EXP_MAP].indexOf('.' + key + '.') >= 0) {
  167. summaryRst.push(key);
  168. }
  169. }
  170. }
  171. }
  172. }
  173. };
  174. let pri_setup_filter = function (FIELD_LIST_KEY) {
  175. if (tpl[JV.NODE_FIELD_MAP][FIELD_LIST_KEY]) {
  176. for (let field of tpl[JV.NODE_FIELD_MAP][FIELD_LIST_KEY]) {
  177. pri_func_chk_filter(field);
  178. }
  179. }
  180. };
  181. pri_setup_filter(JV.NODE_DISCRETE_FIELDS);
  182. pri_setup_filter(JV.NODE_MASTER_FIELDS);
  183. pri_setup_filter(JV.NODE_DETAIL_FIELDS);
  184. pri_setup_filter(JV.NODE_MASTER_FIELDS_EX);
  185. pri_setup_filter(JV.NODE_DETAIL_FIELDS_EX);
  186. if (tpl[JV.NODE_MAP_DATA_HANDLE_INFO] && tpl[JV.NODE_MAP_DATA_HANDLE_INFO].length > 0) {
  187. for (let preHandle of tpl[JV.NODE_MAP_DATA_HANDLE_INFO]) {
  188. if (rst.indexOf(preHandle[JV.PROP_DATA_KEY]) < 0) {
  189. rst.push(preHandle[JV.PROP_DATA_KEY]);
  190. }
  191. if (preHandle[JV.PROP_HANDLE_TYPE] === JV.PROP_HANDLE_TYPE_FILTER) {
  192. if (preHandle[JV.PROP_FILTER_KEYS]) {
  193. for (let filter of preHandle[JV.PROP_FILTER_KEYS]) {
  194. if (filter[JV.PROP_FILTER_COMPARE_OBJ] && rst.indexOf(filter[JV.PROP_FILTER_COMPARE_OBJ]) < 0) {
  195. rst.push(filter[JV.PROP_FILTER_COMPARE_OBJ]);
  196. }
  197. }
  198. }
  199. } else if (preHandle[JV.PROP_HANDLE_TYPE] === JV.PROP_HANDLE_TYPE_SUM) {
  200. if (preHandle[JV.PROP_SUM_GROUP_KEYS]) {
  201. for (let grpKey of preHandle[JV.PROP_SUM_GROUP_KEYS]) {
  202. if (grpKey.seeking_parent && rst.indexOf(grpKey.seeking_parent) < 0) {
  203. rst.push(grpKey.seeking_parent);
  204. }
  205. }
  206. }
  207. } else if (preHandle[JV.PROP_PARENT_CHILD_SORT_KEY] && preHandle[JV.PROP_PARENT_CHILD_SORT_KEY].length > 0) {
  208. for (let item of preHandle[JV.PROP_PARENT_CHILD_SORT_KEY]) {
  209. if (rst.indexOf(item[JV.PROP_PARENT_DATA_KEY]) < 0) {
  210. rst.push(item[JV.PROP_PARENT_DATA_KEY]);
  211. }
  212. }
  213. }
  214. }
  215. }
  216. if (rst.indexOf(projectConst.RATION) >= 0 &&
  217. rst.indexOf(projectConst.RATION_GLJ) >= 0 && rst.indexOf(projectConst.RATION_COE) < 0) {
  218. rst.push(projectConst.RATION_COE);
  219. //备注:在此情况下,根据业务特点,有可能需要额外计算project工料机的基价单价及市场单价,需要用到一些额外信息处理。
  220. // 这里也不精细控制,直接多加一个请求类型。以后说不定还有其他类型的请求,到时候再加。
  221. }
  222. if (rst.length === 0) {
  223. rst.push(projectConst.RATION_ASS);
  224. }
  225. return rst;
  226. };
  227. //--- 装配数据(把收集到的数据,依据报表模板的指示,预处理(如:排序、过滤、合计)及装配到相关指标) ---//
  228. assembleData(rawDataObj) {
  229. let $PROJECT = {"COMMON": null, "MAIN": {}, "DETAIL": {}};
  230. let tpl = this.rptTpl;
  231. this.COMMON.initialize(tpl, rawDataObj);
  232. $PROJECT.COMMON = this.COMMON;
  233. if (rawDataObj.hasOwnProperty(`prj`) && rawDataObj.hasOwnProperty(`prjData`)) {
  234. setupMainFunc($PROJECT, `MAIN`, rawDataObj.prj._doc);
  235. // $PROJECT.MAIN["myOwnRawDataObj"] = rawDataObj.prj._doc;
  236. // $PROJECT.MAIN.getProperty = ext_mainGetPropety;
  237. // $PROJECT.MAIN.getFee = ext_mainGetFee;
  238. for (let item of rawDataObj.prjData) {
  239. setupFunc($PROJECT.DETAIL, item.moduleName, item);
  240. }
  241. let projectGLJDatas = getModuleDataByKey(rawDataObj.prjData, "projectGLJ");
  242. if (projectGLJDatas) {
  243. //增加一个辅助对象,方便通过gljid key直接获取数据,省去循环时间
  244. let gljAssitantObj = {"gljIds": {}, "componentGljIds": {}};
  245. projectGLJDatas.data.gljAssistant = gljAssitantObj;
  246. for (let gljItem of projectGLJDatas.data.gljList) {
  247. gljAssitantObj.gljIds[GLJID_PRE + gljItem.id] = gljItem;
  248. if (!(gljItem.ratio_data) || gljItem.ratio_data.length === 0) {
  249. gljAssitantObj.componentGljIds[COMPONENT_GLJID_PRE + gljItem.glj_id] = gljItem;
  250. }
  251. }
  252. //顺便做个排序(跟UI一致的排序)
  253. }
  254. let rationGLJDatas = getModuleDataByKey(rawDataObj.prjData, "ration_glj");
  255. let rationDatas = getModuleDataByKey(rawDataObj.prjData, "ration");
  256. let billsDatas = getModuleDataByKey(rawDataObj.prjData, "bills");
  257. let decimal = rawDataObj.prj.property.decimal.glj.quantity;
  258. if (projectGLJDatas && rationGLJDatas && rationDatas && billsDatas) {
  259. gljUtil.calcProjectGLJQuantity(projectGLJDatas.data, rationGLJDatas.data, rationDatas.data, billsDatas.data, decimal);
  260. }
  261. }
  262. //还有汇总的...
  263. if (rawDataObj.hasOwnProperty(`Construct`) || rawDataObj.hasOwnProperty(`ConstructDetail`) || rawDataObj.hasOwnProperty(`Segment`) || rawDataObj.hasOwnProperty(`SegmentDetail`)
  264. || rawDataObj.hasOwnProperty(`SummaryAudit`) || rawDataObj.hasOwnProperty(`SummaryAuditDetail`)) {
  265. $PROJECT.SUMMARY = {};
  266. if (rawDataObj.Construct) {
  267. setupMainFunc($PROJECT.SUMMARY, `Construct`, rawDataObj.Construct);
  268. }
  269. if (rawDataObj.ConstructDetail) {
  270. setupFunc($PROJECT.SUMMARY, `ConstructDetail`, {"data": rawDataObj.ConstructDetail});
  271. }
  272. if (rawDataObj.Segment) {
  273. setupMainFunc($PROJECT.SUMMARY, `Segment`, rawDataObj.Segment);
  274. }
  275. if (rawDataObj.SegmentDetail) {
  276. setupFunc($PROJECT.SUMMARY, `SegmentDetail`, {"data": rawDataObj.SegmentDetail});
  277. }
  278. if (rawDataObj.SummaryAudit) {
  279. setupMainFunc($PROJECT.SUMMARY, `SummaryAudit`, rawDataObj.SummaryAudit);
  280. }
  281. if (rawDataObj.SummaryAuditDetail) {
  282. setupFunc($PROJECT.SUMMARY, `SummaryAuditDetail`, {"data": rawDataObj.SummaryAuditDetail});
  283. }
  284. }
  285. //综合费率
  286. let feeRate = getModuleDataByKey(rawDataObj.prjData, "feeRate");
  287. if (feeRate) {
  288. //把综合费率树结构数据拉扁
  289. // console.log(feeRate);
  290. let newFeeRates = setupFeeRate(feeRate.data._doc);
  291. // console.log(newFeeRates);
  292. feeRate.data._doc.rates = newFeeRates;
  293. }
  294. if (tpl[JV.NODE_MAP_DATA_HANDLE_INFO]) {
  295. for (let preHandle of tpl[JV.NODE_MAP_DATA_HANDLE_INFO]) {
  296. let srcData = getModuleDataByKey(rawDataObj.prjData, preHandle[JV.PROP_DATA_KEY]);
  297. switch(preHandle[JV.PROP_HANDLE_TYPE]) {
  298. case JV.PROP_HANDLE_TYPE_SORT:
  299. sortData(srcData, preHandle, rawDataObj.prjData);
  300. break;
  301. case JV.PROP_HANDLE_TYPE_FILTER:
  302. filterData(srcData, preHandle, rawDataObj.prjData);
  303. break;
  304. case JV.PROP_HANDLE_TYPE_SUM:
  305. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/insertedRawDataData10.jsp");
  306. summaryData(srcData, preHandle, rawDataObj.prjData, rawDataObj.prj);
  307. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/insertedRawDataData11.jsp");
  308. break;
  309. case JV.PROP_HANDLE_TYPE_ADD_DUMMY:
  310. addDummyData(srcData, preHandle);
  311. break;
  312. case JV.PROP_HANDLE_TYPE_ADJUST:
  313. adjustData(srcData, preHandle);
  314. break;
  315. case JV.PROP_HANDLE_TYPE_BILLS_DATA_MOVE:
  316. //把显示在清单中的量材转移到工料机去
  317. moveRationData(srcData, rawDataObj);
  318. break;
  319. case JV.PROP_HANDLE_TYPE_COMPONENT_REPLACEMENT:
  320. //重庆2018 09-x表专用,机械数据用 组成物替换掉 ^_^!
  321. componentReplacement(rawDataObj);
  322. break;
  323. default:
  324. break;
  325. }
  326. }
  327. }
  328. //一些计算(不保存数据,需要动态计算的)
  329. if (rawDataObj.hasOwnProperty(`prj`) && rawDataObj.hasOwnProperty(`prjData`)) {
  330. let calcOptions = rawDataObj.prj._doc.property.calcOptions;
  331. let decimalObj = rawDataObj.prj._doc.property.decimal;
  332. let labourCoeDatas = getModuleDataByKey(rawDataObj.prjData, "labour_coe");
  333. let prjGLJDatas = getModuleDataByKey(rawDataObj.prjData, "projectGLJ");
  334. let rationDatas = getModuleDataByKey(rawDataObj.prjData, "ration");
  335. if (calcOptions && decimalObj && labourCoeDatas && labourCoeDatas && prjGLJDatas && rationDatas) {
  336. for (let rationItem of rationDatas.data) {
  337. let glj = _.find(prjGLJDatas.data.gljList, {'id': rationItem.projectGLJID});
  338. if (glj) {
  339. let newGlj = gljUtil.getGLJPrice(glj, prjGLJDatas.data, calcOptions, labourCoeDatas, decimalObj, false, _, scMathUtil);
  340. rationItem.marketPrice = newGlj.marketPrice;
  341. rationItem.basePrice = newGlj.basePrice;
  342. rationItem.adjustPrice = newGlj.adjustPrice;
  343. rationItem.marketUnitFee = newGlj.marketPrice;//更新树节点市场单价列的值
  344. }
  345. }
  346. }
  347. // console.log("重新计算!");
  348. }
  349. //
  350. let rptDataObj = {};
  351. rptDataObj[JV.DATA_DISCRETE_DATA] = [];
  352. rptDataObj[JV.DATA_MASTER_DATA] = [];
  353. rptDataObj[JV.DATA_DETAIL_DATA] = [];
  354. rptDataObj[JV.DATA_MASTER_DATA_EX] = [];
  355. rptDataObj[JV.DATA_DETAIL_DATA_EX] = [];
  356. if (rawDataObj.hasOwnProperty(`prj`) && rawDataObj.hasOwnProperty(`prjData`)) {
  357. rptDataObj.DecimalObj = {};
  358. rptDataObj.DecimalObj.prjDecimal = $PROJECT.MAIN["myOwnRawDataObj"].decimal; //为函数 P_REF() 准备数据
  359. rptDataObj.DecimalObj.unitDecimal = getUnitDecimal($PROJECT.MAIN["myOwnRawDataObj"].billsQuantityDecimal); //为函数 U_REF() 准备数据
  360. }
  361. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_DISCRETE_FIELDS], rptDataObj[JV.DATA_DISCRETE_DATA], $PROJECT);
  362. // console.log(JV.DATA_DISCRETE_DATA);
  363. // console.log(rptDataObj[JV.DATA_DISCRETE_DATA]);
  364. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_MASTER_FIELDS], rptDataObj[JV.DATA_MASTER_DATA], $PROJECT);
  365. // console.log(JV.DATA_MASTER_DATA);
  366. // console.log(rptDataObj[JV.DATA_MASTER_DATA]);
  367. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_DETAIL_FIELDS], rptDataObj[JV.DATA_DETAIL_DATA], $PROJECT);
  368. // console.log(JV.DATA_DETAIL_DATA);
  369. // console.log(rptDataObj[JV.DATA_DETAIL_DATA]);
  370. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_MASTER_FIELDS_EX], rptDataObj[JV.DATA_MASTER_DATA_EX], $PROJECT);
  371. // console.log(JV.DATA_MASTER_DATA_EX);
  372. // console.log(rptDataObj[JV.DATA_MASTER_DATA_EX]);
  373. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_DETAIL_FIELDS_EX], rptDataObj[JV.DATA_DETAIL_DATA_EX], $PROJECT);
  374. // console.log(JV.DATA_DETAIL_DATA_EX);
  375. // console.log(rptDataObj[JV.DATA_DETAIL_DATA_EX]);
  376. // fsUtil.writeObjToFile(rptDataObj, "D:/GitHome/ConstructionCost/tmp/insertedOriginalData.jsp");
  377. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/insertedRawDataData.jsp");
  378. // fsUtil.writeObjToFile($PROJECT, "D:/GitHome/ConstructionCost/tmp/$PROJECTData.jsp");
  379. // fsUtil.writeObjToFile(tpl[JV.NODE_FIELD_MAP][JV.NODE_MASTER_FIELDS], "D:/GitHome/ConstructionCost/tmp/masterFieldsAfterAssemble.jsp");
  380. // fsUtil.writeObjToFile(tpl[JV.NODE_FIELD_MAP][JV.NODE_DETAIL_FIELDS], "D:/GitHome/ConstructionCost/tmp/detailFieldsAfterAssemble.jsp");
  381. return rptDataObj;
  382. };
  383. }
  384. //小数位数依据单位来调整(如吨、公斤的精度要求就不同)
  385. function getUnitDecimal(unitDecimalArr) {
  386. let rst = {"default_decimal": 2};
  387. if (unitDecimalArr) {
  388. for (let item of unitDecimalArr) {
  389. if (item.unit === "其他未列单位") {
  390. rst["default_decimal"] = item.decimal;
  391. } else {
  392. rst['unit_decimal_' + item.unit] = item.decimal;
  393. }
  394. }
  395. }
  396. return rst;
  397. }
  398. function getModuleDataByKey(prjData, key) {
  399. let rst = null;
  400. if (prjData) {
  401. for (let item of prjData) {
  402. if (item.moduleName === key) {
  403. rst = item;
  404. break;
  405. }
  406. }
  407. }
  408. return rst;
  409. }
  410. function summaryData(sourceData, handleCfg, prjData, prjMain){
  411. let rstArr = [], tempRstArr = [];
  412. let curParentPrjData = {};
  413. let precision = 6;
  414. if (handleCfg[JV.PROP_HANDLE_TYPE_PRECISION]) {
  415. if (isNaN(parseInt(handleCfg[JV.PROP_HANDLE_TYPE_PRECISION]))) {
  416. let properties = handleCfg[JV.PROP_HANDLE_TYPE_PRECISION].split('.');
  417. let currentProperty = prjMain[properties[0]];
  418. for (let idx = 1; idx < properties.length; idx++) {
  419. currentProperty = currentProperty[properties[idx]];
  420. }
  421. if (!isNaN(parseInt(currentProperty))) {
  422. precision = parseInt(currentProperty);
  423. }
  424. } else {
  425. precision = parseInt(handleCfg[JV.PROP_HANDLE_TYPE_PRECISION]);
  426. }
  427. }
  428. for (let item of getActDataArr(sourceData)) {
  429. if (item._doc) {
  430. tempRstArr.push(item._doc);
  431. } else {
  432. tempRstArr.push(item);
  433. }
  434. }
  435. let private_cal_before_sum = function () {
  436. for (let calcAheadObj of handleCfg[JV.PROP_SUM_CALC_AHEAD]) {
  437. if (!curParentPrjData[calcAheadObj["seeking_parent"]]) curParentPrjData[calcAheadObj["seeking_parent"]] = getModuleDataByKey(prjData, calcAheadObj["seeking_parent"]);
  438. for (let idxP = 0; idxP < curParentPrjData[calcAheadObj["seeking_parent"]].data.length; idxP++) {
  439. let pDataItem = curParentPrjData[calcAheadObj["seeking_parent"]].data[idxP];
  440. let data = (pDataItem._doc)?pDataItem._doc:pDataItem;
  441. for (let idx = 0; idx < tempRstArr.length; idx++) {
  442. let dtlItem = tempRstArr[idx];
  443. if (dtlItem[calcAheadObj["seeking_key"]] === data[calcAheadObj["parent_key"]]) {
  444. for (let sumKey of handleCfg[JV.PROP_SUM_SUM_KEYS]) {
  445. switch (calcAheadObj[JV.PROP_SUM_CACL_TYPE]) {
  446. case "+":
  447. dtlItem[sumKey] = parseFloat(dtlItem[sumKey]) + parseFloat(data[calcAheadObj["calc_property"]]);
  448. break;
  449. case "-":
  450. dtlItem[sumKey] = parseFloat(dtlItem[sumKey]) - parseFloat(data[calcAheadObj["calc_property"]]);
  451. break;
  452. case "*":
  453. dtlItem[sumKey] = dtlItem[sumKey] * parseFloat(data[calcAheadObj["calc_property"]]);
  454. break;
  455. case "/":
  456. dtlItem[sumKey] = dtlItem[sumKey] / parseFloat(data[calcAheadObj["calc_property"]]);
  457. break;
  458. default:
  459. break;
  460. }
  461. }
  462. // break;
  463. }
  464. }
  465. }
  466. }
  467. };
  468. let private_get_grp_key = function (item) {
  469. let keys = [];
  470. for (let cfg of handleCfg[JV.PROP_SUM_GROUP_KEYS]) {
  471. if (typeof cfg === "string") {
  472. keys.push(item[cfg]);
  473. } else {
  474. if (!curParentPrjData[cfg["seeking_parent"]]) curParentPrjData[cfg["seeking_parent"]] = getModuleDataByKey(prjData, cfg["seeking_parent"]);
  475. for (let pDataItem of curParentPrjData[cfg["seeking_parent"]].data) {
  476. let data = (pDataItem._doc)?pDataItem._doc:pDataItem;
  477. if (item[cfg["seeking_key"]] === data[cfg["parent_key"]]) {
  478. keys.push(data[cfg["parent_grp_key"]]);
  479. break;
  480. }
  481. }
  482. }
  483. }
  484. return ( "grp_key_" + keys.join('_'));
  485. };
  486. let sumObj = {};
  487. if (handleCfg[JV.PROP_SUM_CALC_AHEAD] && handleCfg[JV.PROP_SUM_CALC_AHEAD].length > 0) {
  488. private_cal_before_sum();
  489. }
  490. for (let dtl of tempRstArr) {
  491. let grpKey = private_get_grp_key(dtl);
  492. if (sumObj[grpKey] === null || sumObj[grpKey] === undefined) {
  493. sumObj[grpKey] = dtl;
  494. rstArr.push(dtl);
  495. } else {
  496. for (let sumKey of handleCfg[JV.PROP_SUM_SUM_KEYS]) {
  497. if (dtl[sumKey]) {
  498. // sumObj[grpKey][sumKey] += dtl[sumKey];
  499. sumObj[grpKey][sumKey] = parseFloat(parseFloat(sumObj[grpKey][sumKey]).toFixed(precision)) + parseFloat(parseFloat(dtl[sumKey]).toFixed(precision));
  500. }
  501. }
  502. }
  503. }
  504. replaceActDataArr(sourceData, rstArr);
  505. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/sumRst.jsp");
  506. }
  507. function filterData(sourceData, handleCfg, prjData) {
  508. let rstArr = [], tempRstArr = [];
  509. for (let item of getActDataArr(sourceData)) {
  510. if (item._doc) {
  511. tempRstArr.push(item._doc);
  512. } else {
  513. tempRstArr.push(item);
  514. }
  515. }
  516. let private_chkVal = function (src, compVal, compStr) {
  517. let rst = true;
  518. switch (compStr) {
  519. case "==" :
  520. rst = (src == compVal);
  521. break;
  522. case "===" :
  523. rst = (src === compVal);
  524. break;
  525. case ">" :
  526. rst = (src > compVal);
  527. break;
  528. case ">=" :
  529. rst = (src >= compVal);
  530. break;
  531. case "<" :
  532. rst = (src < compVal);
  533. break;
  534. case "<=" :
  535. rst = (src <= compVal);
  536. break;
  537. case "!=" :
  538. rst = (src != compVal);
  539. break;
  540. case "!==" :
  541. rst = (src !== compVal);
  542. break;
  543. case "in" :
  544. if (compVal instanceof Array) {
  545. rst = compVal.indexOf(src) >= 0;
  546. } else {
  547. //string,需要转类型
  548. let newInCv = JSON.parse(compVal);
  549. if (newInCv instanceof Array) {
  550. rst = newInCv.indexOf(src) >= 0;
  551. } else {
  552. rst = false;
  553. }
  554. }
  555. break;
  556. case "not in":
  557. if (compVal instanceof Array) {
  558. rst = compVal.indexOf(src) < 0;
  559. } else {
  560. //string,需要转类型
  561. let newNotInCv = JSON.parse(compVal);
  562. if (newNotInCv instanceof Array) {
  563. rst = (newNotInCv.indexOf(src) < 0);
  564. } else {
  565. rst = true;
  566. }
  567. }
  568. break;
  569. default:
  570. rst = true;
  571. }
  572. return rst;
  573. };
  574. let private_chkArrVal = function(arr, key, compVal, compStr){
  575. let rst = false;
  576. if (arr.length > 0) {
  577. for (let arrItem of arr) {
  578. if (arrItem[key]) {
  579. rst = private_chkVal(arrItem[key], compVal, compStr);
  580. }
  581. if (rst) {
  582. break;
  583. }
  584. }
  585. } else {
  586. //在某些判断条件下(含有'非'判断),如arr没有数组项,默认结果反而是true
  587. switch (compStr) {
  588. case "!=" :
  589. case "!==" :
  590. case "not in":
  591. rst = true;
  592. break;
  593. default:
  594. break;
  595. }
  596. }
  597. return rst;
  598. };
  599. let private_filter_compare = function (item, filterCfg) {
  600. let compareObj = {};
  601. let compRst = true;
  602. let curComparePrjData = null;
  603. let startIdx = 0;
  604. let private_ref_join = function(refKey, targetDataKey, targetPropertyKey) {
  605. let rst = null, objDataArr = null;
  606. curComparePrjData = getModuleDataByKey(prjData, targetDataKey);
  607. try {
  608. if (curComparePrjData !== null) {
  609. objDataArr = getActDataArr(curComparePrjData);
  610. for (let dtl of objDataArr) {
  611. if (item[refKey] === dtl[targetPropertyKey]) {
  612. rst = dtl;
  613. break;
  614. }
  615. }
  616. }
  617. } finally {
  618. curComparePrjData = null;
  619. }
  620. return rst;
  621. };
  622. for (let cfg of filterCfg[JV.PROP_FILTER_KEYS]) {
  623. if (cfg[JV.PROP_FILTER_COMPARE_VAL]) {
  624. //比较key值
  625. let keys = cfg.key.split(".");
  626. if (keys.length > 1) {
  627. let lastObj = item;
  628. for (let i = 0; i < keys.length - 1; i++) {
  629. if (keys[i].indexOf("ref_join(") === 0) {
  630. let params = keys[i].slice(9, keys[i].length - 1).split(",");
  631. if (params.length === 3) {
  632. lastObj = private_ref_join(params[0], params[1], params[2]);
  633. }
  634. if (!(lastObj)) {
  635. compRst = false;
  636. break;
  637. }
  638. } else {
  639. lastObj = item[keys[i]];
  640. if (!(lastObj)) {
  641. compRst = false;
  642. break;
  643. }
  644. }
  645. }
  646. if (lastObj) {
  647. if (lastObj instanceof Array) {
  648. compRst = private_chkArrVal(lastObj, keys[keys.length - 1], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  649. } else {
  650. compRst = private_chkVal(lastObj[keys[keys.length - 1]], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  651. }
  652. }
  653. } else {
  654. compRst = private_chkVal(item[cfg.key], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  655. }
  656. } else if (cfg[JV.PROP_FILTER_COMPARE_OBJ] && cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]){
  657. //通过其他对象来过滤
  658. if (!curComparePrjData) {
  659. curComparePrjData = getModuleDataByKey(prjData, cfg[JV.PROP_FILTER_COMPARE_OBJ]);
  660. }
  661. if (cfg[JV.PROP_FILTER_CONDITION] === "in" || cfg[JV.PROP_FILTER_CONDITION] === "not in") {
  662. let compareArr = null;
  663. if (!compareObj.hasOwnProperty(cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString())) {
  664. compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()] = [];
  665. compareArr = compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()];
  666. for (let data of getActDataArr(curComparePrjData)) {
  667. if (compareArr.indexOf(data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]]) < 0) {
  668. compareArr.push(data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]]);
  669. }
  670. }
  671. } else {
  672. compareArr = compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()];
  673. }
  674. compRst = private_chkVal(item[cfg.key], compareArr, cfg[JV.PROP_FILTER_CONDITION]);
  675. } else {
  676. for (let data of getActDataArr(curComparePrjData)) {
  677. compRst = private_chkVal(item[cfg.key], data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]], cfg[JV.PROP_FILTER_CONDITION]);
  678. if (compRst) break;
  679. }
  680. }
  681. }
  682. startIdx++;
  683. if (!compRst) {
  684. break; //有不符合条件的数据则退出(这里的判断条件是and关系)
  685. }
  686. }
  687. return compRst;
  688. };
  689. let private_sub_filter_compare = function (dtlItem, subFilters) {
  690. let cmpRst = false;
  691. for (let dtlCfg of subFilters) {
  692. cmpRst = private_filter_compare(dtlItem, dtlCfg);
  693. if (cmpRst) {
  694. if (dtlCfg[JV.PROP_OTHER_SUB_FILTER] && dtlCfg[JV.PROP_OTHER_SUB_FILTER].length > 0) {
  695. cmpRst = private_sub_filter_compare(dtlItem, dtlCfg[JV.PROP_OTHER_SUB_FILTER]);
  696. if (cmpRst) break;
  697. } else {
  698. break;
  699. }
  700. }
  701. }
  702. return cmpRst;
  703. };
  704. for (let item of tempRstArr) {
  705. if (private_filter_compare(item, handleCfg)) {
  706. rstArr.push(item);
  707. }
  708. }
  709. if (handleCfg[JV.PROP_OTHER_SUB_FILTER] && handleCfg[JV.PROP_OTHER_SUB_FILTER].length > 0) {
  710. let newRstArr = [];
  711. for (let dtlItem of rstArr) {
  712. let cmpRst = private_sub_filter_compare(dtlItem, handleCfg[JV.PROP_OTHER_SUB_FILTER]);
  713. if (cmpRst) {
  714. newRstArr.push(dtlItem);
  715. }
  716. }
  717. rstArr = newRstArr;
  718. }
  719. replaceActDataArr(sourceData, rstArr);
  720. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/filteredRst.jsp");
  721. }
  722. function adjustData(sourceData, adjustCfg) {
  723. let rstArr = [];
  724. for (let item of getActDataArr(sourceData)) {
  725. if (item._doc) {
  726. rstArr.push(item._doc);
  727. } else {
  728. rstArr.push(item);
  729. }
  730. }
  731. for (let item of adjustCfg[JV.PROP_ADJUST_COLLECTION]) {
  732. for (let rec of rstArr) {
  733. if (item[JV.PROP_ADJUST_ACTION] === "prefix") {
  734. rec[item.key] = item[JV.PROP_ADJUST_ACTION_VAL] + rec[item.key];
  735. } else if (item[JV.PROP_ADJUST_ACTION] === "suffix") {
  736. rec[item.key] = rec[item.key] + item[JV.PROP_ADJUST_ACTION_VAL];
  737. }
  738. }
  739. }
  740. replaceActDataArr(sourceData, rstArr);
  741. }
  742. function componentReplacement(rawDataObj) {
  743. let rationGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION_GLJ),
  744. prjGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.PROJECTGLJ),
  745. gljAssistant = prjGljData.data.gljAssistant;
  746. let connectStrArr = [], dataArr = getActDataArr(rationGljData), rvRGljIds = [], replaceGljItems = [];
  747. for (let idx = 0; idx < dataArr.length; idx++) {
  748. let rationGljItem = dataArr[idx];
  749. if (rationGljItem.type === 301 || rationGljItem.type === 302) {
  750. connectStrArr[0] = rationGljItem.code;
  751. connectStrArr[1] = rationGljItem.name;
  752. connectStrArr[2] = rationGljItem.specs;
  753. connectStrArr[3] = rationGljItem.unit;
  754. connectStrArr[4] = rationGljItem.type;
  755. let mapData = prjGljData.data.mixRatioMap[connectStrArr.join('|-|')];
  756. if (mapData) {
  757. rvRGljIds.push(idx);
  758. let rgItems = [];
  759. replaceGljItems.push(rgItems);
  760. for (let mapItem of mapData) {
  761. let copyItem = {};
  762. rgItems.push(copyItem);
  763. copyItem.ID = `Replace_` + rationGljItem.ID;
  764. copyItem.projectID = rationGljItem.projectID;
  765. copyItem.GLJID = rationGljItem.GLJID;
  766. copyItem.rationID = rationGljItem.rationID;
  767. if (gljAssistant.componentGljIds[COMPONENT_GLJID_PRE + mapItem.glj_id]) {
  768. copyItem.projectGLJID = gljAssistant.componentGljIds[COMPONENT_GLJID_PRE + mapItem.glj_id].id; //关键key
  769. } else {
  770. copyItem.projectGLJID = mapItem.glj_id; //不应该走到这一步,否则就是错误!!!
  771. }
  772. copyItem.rationItemQuantity = rationGljItem.rationItemQuantity;
  773. // copyItem.quantity = rationGljItem.quantity;
  774. copyItem.quantity = rationGljItem.quantity * mapItem.consumption;
  775. copyItem.name = mapItem.name;
  776. copyItem.code = mapItem.code;
  777. copyItem.original_code = mapItem.code;
  778. copyItem.unit = mapItem.unit;
  779. copyItem.specs = mapItem.specs;
  780. copyItem.model = gljAssistant.gljIds['gljId_'+rationGljItem.projectGLJID].model;
  781. copyItem.shortName = mapItem.shortName;
  782. copyItem.billsItemID = rationGljItem.billsItemID;
  783. copyItem.type = mapItem.type; //关键key
  784. }
  785. }
  786. }
  787. }
  788. if (rvRGljIds.length > 0) {
  789. for (let lIdx = rvRGljIds.length - 1; lIdx >= 0; lIdx--) {
  790. dataArr.splice(rvRGljIds[lIdx],1);
  791. }
  792. for (let componentItems of replaceGljItems) {
  793. for (let compItem of componentItems) {
  794. dataArr.push(compItem);
  795. //gljAssistant[COMPONENT_GLJID_PRE + mapItem.glj_id]
  796. }
  797. }
  798. }
  799. }
  800. function moveRationData(rationData, rawDataObj) {
  801. if (rawDataObj) {
  802. // let rationData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION);
  803. let rationGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION_GLJ);
  804. let prjGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.PROJECTGLJ);
  805. let dummyCode = " ", dummyPRJID = 10101010;
  806. for (let rationItem of getActDataArr(rationData)) {
  807. if (rationItem.type === 2 || rationItem.type === 3) {
  808. //2: 量材(人工/材料/机械/主材/设备) 3:材料(材料/主材/设备)
  809. let copyItem = {};
  810. copyItem.ID = rationItem.ID;
  811. copyItem.projectID = rationItem.projectID;
  812. copyItem.GLJID = rationItem.GLJID;
  813. copyItem.rationID = rationItem.ID;
  814. copyItem.rationItemQuantity = 1;
  815. copyItem.quantity = 1;
  816. // copyItem.specialType_quantity = rationItem.quantity;
  817. copyItem.name = rationItem.name;
  818. if (rationItem.code) {
  819. copyItem.code = rationItem.ID + "_" + rationItem.code;
  820. } else {
  821. copyItem.code = dummyCode;
  822. dummyCode = dummyCode + " ";
  823. }
  824. copyItem.original_code = rationItem.original_code;
  825. copyItem.unit = rationItem.unit;
  826. copyItem.specs = rationItem.specs;
  827. copyItem.shortName = rationItem.shortName;
  828. copyItem.billsItemID = rationItem.billsItemID;
  829. copyItem.type = rationItem.subType;
  830. if (rationItem.projectGLJID) {
  831. copyItem.projectGLJID = rationItem.projectGLJID;
  832. } else {
  833. //add dummy project GLJ
  834. let dummyPrjItem = {};
  835. copyItem.projectGLJID = dummyPRJID;
  836. dummyPrjItem.id = dummyPRJID;
  837. dummyPRJID++;
  838. dummyPrjItem.unit_price = {};
  839. dummyPrjItem.unit_price.base_price = 0;
  840. dummyPrjItem.unit_price.market_price = (rationItem["marketUnitFee"])?rationItem["marketUnitFee"]:0;
  841. dummyPrjItem.quantity = 0;
  842. dummyPrjItem.is_evaluate = 0;
  843. prjGljData.data.gljList.push(dummyPrjItem);
  844. }
  845. rationGljData.data.push(copyItem);
  846. }
  847. }
  848. // fsUtil.writeObjToFile(rationGljData.data, "D:/GitHome/ConstructionCost/tmp/afterMoveGLJ.jsp");
  849. }
  850. }
  851. function getDupGrpKeyVals(sourceData, segKeys) {
  852. let rst = [];
  853. function pushKeyVal(item) {
  854. let tr = {};
  855. for (let i = 0; i < segKeys.length; i++) {
  856. tr[segKeys[i]] = item[segKeys[i]];
  857. }
  858. rst.push(tr);
  859. }
  860. for (let idx = 0; idx < sourceData.length; idx++) {
  861. let itemRec = sourceData[idx];
  862. if (idx === 0) {
  863. pushKeyVal(itemRec);
  864. continue;
  865. }
  866. let hasDiff = false;
  867. for (let i = 0; i < segKeys.length; i++) {
  868. if (itemRec[segKeys[i]] !== sourceData[idx - 1][segKeys[i]]) {
  869. hasDiff = true;
  870. break;
  871. }
  872. }
  873. if (hasDiff) {
  874. pushKeyVal(itemRec);
  875. }
  876. }
  877. return rst;
  878. }
  879. function addDummyData(sourceData, addCfg) {
  880. let rstArr = [], tempRstArr = [];
  881. for (let item of getActDataArr(sourceData)) {
  882. if (item._doc) {
  883. tempRstArr.push(item._doc);
  884. } else {
  885. tempRstArr.push(item);
  886. }
  887. }
  888. for (let item of addCfg[JV.PROP_DUMMY_COLLECTION]) {
  889. let newRecStr = JSON.stringify(item[JV.PROP_DUMMY_VAL]), cacheGrpKeyRecs = null;
  890. if (item[JV.PROP_FREQUENCY] === "OncePerGrp") {
  891. if (!cacheGrpKeyRecs) {
  892. cacheGrpKeyRecs = {};
  893. }
  894. let cacheKey = "";
  895. for (let key of item[JV.PROP_GRP_KEYS]) {
  896. cacheKey += "_" + key;
  897. }
  898. if (!cacheGrpKeyRecs[cacheKey]) {
  899. cacheGrpKeyRecs[cacheKey] = getDupGrpKeyVals(tempRstArr, item[JV.PROP_GRP_KEYS]);
  900. }
  901. for (let kv of cacheGrpKeyRecs[cacheKey]) {
  902. let rec = JSON.parse(newRecStr);
  903. for (let key of item[JV.PROP_GRP_KEYS]) {
  904. rec[key] = kv[key];
  905. }
  906. rstArr.push(rec);
  907. }
  908. } else if (item[JV.PROP_FREQUENCY] === "Once") {
  909. rstArr.push(JSON.parse(newRecStr));
  910. }
  911. }
  912. rstArr = rstArr.concat(tempRstArr);
  913. replaceActDataArr(sourceData, rstArr);
  914. }
  915. function getGLJBizType2018(orgType, orgCode, orgName) {
  916. let rst = orgType;
  917. if (orgType === GLJ_TYPE.Labour) {
  918. rst = 11;
  919. if (orgCode === "000000") rst = 10;
  920. } else if (orgType === GLJ_TYPE.Material || (orgType >= 200 && orgType < 300)) {
  921. //材料
  922. if (orgCode === "000000") {
  923. rst = 200; //2.材料
  924. } else if (orgCode === "000000_1") {
  925. rst = 230; //(1) 计价材料
  926. } else if (orgCode === "000000_2") {
  927. rst = 240; //(2) 其他材料费
  928. } else {
  929. if (orgType === GLJ_TYPE.OTHER_MATERIAL) {
  930. //其他材料
  931. rst = 245;
  932. } else {
  933. //计价材料
  934. rst = 235;
  935. }
  936. }
  937. } else if (orgType === GLJ_TYPE.Machine || (orgType >= 300 && orgType < 400)) {
  938. //机械
  939. if (orgCode === "000000") {
  940. rst = 300; //3.机械
  941. } else if (orgCode === "000000_1") {
  942. rst = 330; //(1) 机上人工
  943. } else if (orgCode === "000000_2") {
  944. rst = 340; //(2) 燃油动力费
  945. } else if (orgCode === "000000_3") {
  946. rst = 350; //(2) 施工机具摊销费
  947. } else {
  948. if (orgType === GLJ_TYPE.MACHINE_LABOUR) {
  949. //机上人工
  950. rst = 335;
  951. } else if (orgType === GLJ_TYPE.FUEL_POWER_FEE) {
  952. //燃油动力费
  953. rst = 345;
  954. } else if (oprMachines.indexOf(orgType) >= 0) {
  955. //施工机具摊销费
  956. rst = 355 + oprMachines.indexOf(orgType);
  957. }
  958. }
  959. }
  960. return rst;
  961. }
  962. function getGLJBizType(orgType, orgCode, orgName) {
  963. let rst = orgType;
  964. if (orgName.indexOf("其他材料费") >= 0) {
  965. rst = 299;
  966. } else if (orgType === GLJ_TYPE.Labour) {
  967. rst = 11;
  968. if (orgCode === "000000") rst = 10;
  969. } else if (orgType === GLJ_TYPE.Main_Material || orgType === GLJ_TYPE.Equipment) {
  970. //未计价材料(主材 + 设备)
  971. rst = 30 + orgType;
  972. } else if (orgType === GLJ_TYPE.Material || (orgType >= 200 && orgType < 300)) {
  973. //材料
  974. if (orgCode === "000000") {
  975. rst = 20; //2.材料
  976. } else if (orgCode === "000000_1") {
  977. rst = 30; //(1) 未计价材料
  978. } else if (orgCode === "000000_2") {
  979. rst = 40; //(2) 辅助材料
  980. } else if (orgCode === "000000_3") {
  981. rst = 50; //(3) 其他材料费
  982. } else {
  983. rst = 45; //到这里就只有辅助材料没有预处理了
  984. }
  985. } else if (orgType === GLJ_TYPE.Machine || (orgType >= 300 && orgType < 400)) {
  986. //机械
  987. if (orgCode === "000000") {
  988. rst = 300; //3.机械
  989. } else if (orgType === GLJ_TYPE.Machine) {
  990. rst = 300.5;
  991. } else {
  992. rst = orgType;
  993. }
  994. }
  995. return rst;
  996. }
  997. function sortData(sourceData, sortCfg, prjData) {
  998. let rst = getActDataArr(sourceData), tempRstArr = [];
  999. let sortType = sortCfg[JV.PROP_SORT_TYPE];
  1000. let srcData = getActDataArr(sourceData);
  1001. for (let item of srcData) {
  1002. if (item._doc) {
  1003. tempRstArr.push(item._doc);
  1004. } else {
  1005. tempRstArr.push(item);
  1006. }
  1007. }
  1008. function private_normal_sort(destArr, sortKeys) {
  1009. destArr.sort(function(a, b){
  1010. let compRst = 0;
  1011. for (let comp of sortKeys) {
  1012. let reverse = (comp.order === 'ascend')?1:(-1);
  1013. //
  1014. if (a[comp.key] > b[comp.key]) {
  1015. compRst = reverse;
  1016. break;
  1017. } else if (a[comp.key] < b[comp.key]) {
  1018. compRst = -reverse;
  1019. break;
  1020. }
  1021. }
  1022. return compRst;
  1023. });
  1024. }
  1025. function private_parent_sort(parentArr, parentKeys, childArr, childKeys) {
  1026. let tmpRst = {}, rst = [];
  1027. for (let pItem of parentArr) {
  1028. let pKey = "key";
  1029. for (let key of parentKeys) {
  1030. pKey += "_" + pItem[key];
  1031. }
  1032. tmpRst[pKey] = [];
  1033. }
  1034. for (let cItem of childArr) {
  1035. let cKey = "key";
  1036. for (let key of childKeys) {
  1037. cKey += "_" + cItem[key];
  1038. }
  1039. if (tmpRst[cKey]) {
  1040. tmpRst[cKey].push(cItem);
  1041. } else {
  1042. //unknown child value! should be filtered!
  1043. }
  1044. }
  1045. // childArr.splice(0);
  1046. for (let pItem of parentArr) {
  1047. let pKey = "key";
  1048. for (let key of parentKeys) {
  1049. pKey += "_" + pItem[key];
  1050. }
  1051. rst.push(tmpRst[pKey]);
  1052. // for (let rItem of tmpRst[pKey]) {
  1053. // childArr.push(rItem);
  1054. // }
  1055. }
  1056. return rst;
  1057. }
  1058. switch (sortType) {
  1059. case "tree":
  1060. let addLevel = true;
  1061. rst = treeUtil.buildTreeNodeDirectly(tempRstArr, addLevel);
  1062. let newTopArr = [];
  1063. if ((sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES] && sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES].length > 0) ||
  1064. (sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES] && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].length > 0)) {
  1065. let local_check_bills = function(tItem) {
  1066. let chkDtl = false;
  1067. if (tItem.flags && tItem.flags.length > 0) {
  1068. for (let flagItem of tItem.flags) {
  1069. if (sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].indexOf(flagItem.flag) >= 0) {
  1070. newTopArr.push(tItem);
  1071. chkDtl = true;
  1072. break;
  1073. }
  1074. }
  1075. }
  1076. if (!chkDtl && tItem.items && tItem.items.length > 0) {
  1077. for (let dtlItem of tItem.items) {
  1078. local_check_bills(dtlItem);
  1079. }
  1080. }
  1081. };
  1082. for (let topItem of rst) {
  1083. let chkTop = false;
  1084. if (topItem.flags && topItem.flags.length > 0) {
  1085. for (let flagItem of topItem.flags) {
  1086. if (sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES].indexOf(flagItem.flag) >= 0) {
  1087. newTopArr.push(topItem);
  1088. chkTop = true;
  1089. break;
  1090. }
  1091. }
  1092. }
  1093. if (!chkTop && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES] && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].length > 0) {
  1094. local_check_bills(topItem);
  1095. }
  1096. }
  1097. } else {
  1098. newTopArr = rst;
  1099. }
  1100. let destArr = [];
  1101. // fsUtil.writeObjToFile(newTopArr, "D:/GitHome/ConstructionCost/tmp/sortedAndFlattedRstBefore.jsp");
  1102. treeUtil.getFlatArray(newTopArr, destArr, true);
  1103. // console.log(destArr);
  1104. replaceActDataArr(sourceData, destArr);
  1105. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/sortedAndFlattedRst.jsp");
  1106. break;
  1107. case "normal":
  1108. private_normal_sort(tempRstArr, sortCfg[JV.PROP_SORT_KEYS]);
  1109. replaceActDataArr(sourceData, tempRstArr);
  1110. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/normalSortedRst.jsp");
  1111. break;
  1112. case "accord_to_parent":
  1113. let pcKey = sortCfg[JV.PROP_PARENT_CHILD_SORT_KEY];
  1114. let parentSrcData = getModuleDataByKey(prjData, pcKey[JV.PROP_PARENT_DATA_KEY]);
  1115. if (parentSrcData) {
  1116. let tempParentArr = [];
  1117. for (let item of getActDataArr(parentSrcData)) {
  1118. if (item._doc) {
  1119. tempParentArr.push(item._doc);
  1120. } else {
  1121. tempParentArr.push(item);
  1122. }
  1123. }
  1124. let sortedRstArr = private_parent_sort(tempParentArr, pcKey[JV.PROP_PARENT_SORT_KEYS], tempRstArr, pcKey[JV.PROP_CHILD_SORT_KEYS]);
  1125. if (sortCfg[JV.PROP_OTHER_SUB_SORT] && sortCfg[JV.PROP_OTHER_SUB_SORT].length > 0) {
  1126. for (let sort of sortCfg[JV.PROP_OTHER_SUB_SORT]) {
  1127. if (sort[JV.PROP_SORT_TYPE] === 'normal') {
  1128. for (let subArr of sortedRstArr) {
  1129. private_normal_sort(subArr, sort[JV.PROP_SORT_KEYS]);
  1130. }
  1131. } else if (sort[JV.PROP_SORT_TYPE] === 'self_define') {
  1132. for (let subArr of sortedRstArr) {
  1133. // console.log(subArr);
  1134. let selfDefFunc = null;
  1135. eval('selfDefFunc = ' + sort[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]);
  1136. subArr.sort(selfDefFunc);
  1137. // console.log(subArr);
  1138. }
  1139. }
  1140. }
  1141. }
  1142. tempRstArr.splice(0);
  1143. for (let item of sortedRstArr) {
  1144. for (let subItem of item) {
  1145. tempRstArr.push(subItem);
  1146. }
  1147. }
  1148. }
  1149. replaceActDataArr(sourceData, tempRstArr);
  1150. break;
  1151. case "self_define":
  1152. if (sortCfg[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]) {
  1153. let selfDefFuncA = null;
  1154. eval('selfDefFuncA = ' + sortCfg[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]);
  1155. if (selfDefFuncA !== null) {
  1156. tempRstArr.sort(selfDefFuncA);
  1157. } else {
  1158. console.log('sorting function is null!!!');
  1159. }
  1160. }
  1161. replaceActDataArr(sourceData, tempRstArr);
  1162. break;
  1163. default:
  1164. //
  1165. }
  1166. return rst;
  1167. }
  1168. function setupMainFunc(obj, prop, ownRawObj) {
  1169. obj[prop] = {};
  1170. obj[prop]["myOwnRawDataObj"] = ownRawObj;
  1171. obj[prop].getProperty = ext_mainGetPropety;
  1172. obj[prop].getFee = ext_mainGetFee;
  1173. }
  1174. function setupFeeRate(feeRateData){
  1175. let cacheObj = {}, topArr = [], rstArr = [], id_pre = 'ID_';
  1176. const rateProperties = [];
  1177. for (let rate of feeRateData.rates) {
  1178. cacheObj[id_pre + rate._doc.ID] = {"obj": rate._doc, "items": []};
  1179. // cacheObj[id_pre + rate.ID].items = [];
  1180. if (rate._doc.ParentID === null || rate._doc.ParentID === undefined) {
  1181. topArr.push(cacheObj[id_pre + rate._doc.ID]);
  1182. }
  1183. }
  1184. for (let rate of feeRateData.rates) {
  1185. if (rate._doc.ParentID && cacheObj[id_pre + rate._doc.ParentID]) {
  1186. cacheObj[id_pre + rate._doc.ParentID].items.push(cacheObj[id_pre + rate._doc.ID]);
  1187. if (rateProperties.indexOf(rate._doc.name) < 0) {
  1188. rateProperties.push(rate._doc.name);
  1189. }
  1190. }
  1191. }
  1192. let pri_func_set_property_rate = function (orgRateItem, rstRateItem) {
  1193. rstRateItem[orgRateItem.obj.name] = orgRateItem.obj.rate;
  1194. for (let subOrgRateItem of orgRateItem.items) {
  1195. pri_func_set_property_rate(subOrgRateItem, rstRateItem);
  1196. }
  1197. };
  1198. for (let topRate of topArr) {
  1199. let rstItem = {"name": topRate.obj.name, "ID": topRate.obj.ID};
  1200. for (let property of rateProperties) {
  1201. rstItem[property] = 0;
  1202. }
  1203. for (let dtlRateItem of topRate.items) {
  1204. pri_func_set_property_rate(dtlRateItem, rstItem);
  1205. }
  1206. rstArr.push(rstItem);
  1207. }
  1208. return rstArr;
  1209. }
  1210. function setupFunc(obj, prop, ownRawObj) {
  1211. obj[prop] = {};
  1212. obj[prop]["myOwnRawDataObj"] = ownRawObj;
  1213. obj[prop]["myOwnOrgRawDataObj"] = ownRawObj.data;
  1214. obj[prop].getProperty = ext_getProperty;
  1215. obj[prop].getPropertyByRefId = ext_getPropertyByRefId;
  1216. obj[prop].getFee = ext_getFee;
  1217. obj[prop].getPropertyByForeignId = ext_getPropertyByForeignId;
  1218. obj[prop].getArrayValues = ext_getArrayValues;
  1219. obj[prop].getArrayItemByKey = ext_getArrayItemByKey;
  1220. obj[prop].getPropertyByFlag = ext_getPropertyByFlag;
  1221. obj[prop].getSubRateProperty = ext_getRateProperty;
  1222. obj[prop].getRateProperty = ext_getRateProperty;
  1223. obj[prop].getBlank = ext_getBlank;
  1224. obj[prop].getRatioDataProperty = ext_getRatioDataProperty;
  1225. obj[prop].getRatioDataParentProperty = ext_getRatioDataParentProperty;
  1226. obj[prop].getRatioDataPriceMapProperty = ext_getRatioDataPriceMapProperty;
  1227. if (prop === projectConst.CALC_PROGRAM) obj[prop].getCalcProperty = ext_getCalcProperty;
  1228. if (prop === projectConst.FEERATE) obj[prop].getFeeRate = ext_getFeeRate;
  1229. }
  1230. function assembleFields(fieldList, rstDataArr, $PROJECT) {
  1231. if (fieldList) {
  1232. for (let field of fieldList) {
  1233. shielded_exec_env($PROJECT, field, rstDataArr);
  1234. if ("Precision" in field) {
  1235. if (field["Precision"]["type"] === "fixed") {
  1236. let vrst = eval(field["Precision"]["fixedMapExpression"]);
  1237. if (vrst && vrst.length === 1) {
  1238. field.fixedPrecisionNum = vrst[0];
  1239. vrst.splice(0,1);
  1240. }
  1241. } else if (field["Precision"]["type"] === "flexible") {
  1242. let vrst = eval(field["Precision"]["flexibleMapExpression"]);
  1243. if (vrst && vrst.length === 1) {
  1244. field.flexiblePrecisionRefObj =vrst[0];
  1245. vrst.splice(0,1);
  1246. }
  1247. }
  1248. }
  1249. }
  1250. }
  1251. }
  1252. function shielded_exec_env($PROJECT, $ME, rptDataItemObj) {
  1253. if ($ME[JV.PROP_FIELD_EXP_MAP]) {
  1254. rptDataItemObj.push(eval($ME[JV.PROP_FIELD_EXP_MAP]));
  1255. }
  1256. }
  1257. function getActPropertyVal(firstPropKey, secPropKey, orgObj) {
  1258. let rst = null;
  1259. if (orgObj[firstPropKey]) {
  1260. rst = orgObj[firstPropKey];
  1261. } else if (orgObj[secPropKey]){
  1262. rst = orgObj[secPropKey];
  1263. }
  1264. return rst;
  1265. }
  1266. function getDeepProperty(propKey, orgObj, destArr) {
  1267. let keys = propKey.split(".");
  1268. let dftPropKey = "key", dftPropVal = "value", secDftPropVal = "items";
  1269. let parent = orgObj, lastVal = null;
  1270. for (let key of keys) {
  1271. if (parent instanceof Array) {
  1272. for (let item of parent) {
  1273. if (item[dftPropKey] === key) {
  1274. lastVal = getActPropertyVal(dftPropVal, secDftPropVal, item);
  1275. break;
  1276. }
  1277. }
  1278. } else {
  1279. lastVal = null;
  1280. if (parent[key] !== undefined) {
  1281. lastVal = parent[key];
  1282. } else if (parent[secDftPropVal]){
  1283. for (let item of parent[secDftPropVal]) {
  1284. if (item[dftPropKey] === key) {
  1285. // lastVal = item[dftPropVal];
  1286. lastVal = getActPropertyVal(dftPropVal, secDftPropVal, item);
  1287. break;
  1288. }
  1289. }
  1290. }
  1291. }
  1292. parent = lastVal;
  1293. if (parent === null) break;
  1294. }
  1295. if (destArr && destArr instanceof Array) {
  1296. destArr.push(lastVal);
  1297. }
  1298. }
  1299. function ext_mainGetPropety(propKey) {
  1300. let rst = [], parentObj = this;
  1301. let dtObj = parentObj["myOwnRawDataObj"];
  1302. if (propKey && dtObj) {
  1303. if (dtObj.hasOwnProperty("property")) {
  1304. if (!dtObj["property"][propKey] && dtObj[propKey]) {
  1305. rst.push(dtObj[propKey]);
  1306. } else {
  1307. getDeepProperty(propKey, dtObj["property"], rst);
  1308. }
  1309. } else {
  1310. // rst.push(dtObj[propKey]);
  1311. getDeepProperty(propKey, dtObj, rst);
  1312. }
  1313. }
  1314. return rst;
  1315. }
  1316. function ext_getRateProperty(propKey) {
  1317. let rst = [], parentObj = this;
  1318. let dtObj = parentObj["myOwnRawDataObj"];
  1319. if (propKey && dtObj) {
  1320. for (let rate of dtObj.data._doc.rates) {
  1321. rst.push(rate[propKey]);
  1322. }
  1323. }
  1324. return rst;
  1325. }
  1326. function ext_getRatioDataProperty(propKey) {
  1327. //获取工料机的组成物属性
  1328. let rst = [], parentObj = this;
  1329. let dtObj = parentObj["myOwnRawDataObj"];
  1330. if (propKey && dtObj) {
  1331. for (let dItem of getActDataArr(dtObj)) {
  1332. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  1333. for (let ratioItem of doc.ratio_data) {
  1334. rst.push(ratioItem[propKey]);
  1335. }
  1336. }
  1337. }
  1338. return rst;
  1339. }
  1340. function pri_push_property(propKey, doc, rst) {
  1341. if (propKey instanceof Array) {
  1342. //备注:这里的key数组表示取value的优先级
  1343. for (let pi = 0; pi < propKey.length; pi++) {
  1344. if (doc.hasOwnProperty("property")) {
  1345. if (doc["property"].hasOwnProperty(propKey[pi])) {
  1346. rst.push(doc["property"][propKey[pi]]);
  1347. break;
  1348. }
  1349. } else if (doc.hasOwnProperty(propKey[pi])) {
  1350. rst.push(doc[propKey[pi]]);
  1351. break;
  1352. } else {
  1353. let lenBefore = rst.length;
  1354. getDeepProperty(propKey[pi], doc, rst);
  1355. if (rst.length === (lenBefore + 1)) {
  1356. if (rst[lenBefore] !== null && rst[lenBefore] !== undefined && rst[lenBefore] !== "") {
  1357. break;
  1358. } else {
  1359. rst.splice(-1, 1); //删除末尾一条数据,给后面留空间
  1360. }
  1361. }
  1362. }
  1363. if (pi === propKey.length - 1) rst.push('');
  1364. }
  1365. } else {
  1366. if (doc.hasOwnProperty("property") && doc["property"].hasOwnProperty(propKey)) {
  1367. rst.push(doc["property"][propKey]);
  1368. } else if (doc.hasOwnProperty(propKey)) {
  1369. rst.push(doc[propKey]);
  1370. } else {
  1371. getDeepProperty(propKey, doc, rst);
  1372. }
  1373. }
  1374. }
  1375. function ext_getRatioDataParentProperty(propKey) {
  1376. //获取组成物的父项属性
  1377. let rst = [], parentObj = this;
  1378. let dtObj = parentObj["myOwnRawDataObj"];
  1379. if (propKey && dtObj) {
  1380. for (let dItem of getActDataArr(dtObj)) {
  1381. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  1382. for (let ratioItem of doc.ratio_data) {
  1383. pri_push_property(propKey, doc, rst);
  1384. }
  1385. }
  1386. }
  1387. return rst;
  1388. }
  1389. function ext_getRatioDataPriceMapProperty(propKey) {
  1390. //获取组成物的单价映射属性
  1391. let rst = [], parentObj = this;
  1392. let dtObj = parentObj["myOwnRawDataObj"];
  1393. if (propKey && dtObj) {
  1394. let unitPriceMap = dtObj.data.unitPriceMap;
  1395. let upmDoc = (unitPriceMap._doc === null || unitPriceMap._doc === undefined)?unitPriceMap:unitPriceMap._doc;
  1396. for (let dItem of getActDataArr(dtObj)) {
  1397. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  1398. for (let ratioItem of doc.ratio_data) {
  1399. let connectionKeys = [];
  1400. connectionKeys.push(ratioItem.code);
  1401. connectionKeys.push(ratioItem.name);
  1402. connectionKeys.push((ratioItem.specs === "")?"null":ratioItem.specs);
  1403. connectionKeys.push(ratioItem.unit);
  1404. connectionKeys.push(ratioItem.type);
  1405. connectionKeys.join("|-|");
  1406. let strPK = connectionKeys.join("|-|");
  1407. let dtlDoc = (upmDoc[strPK]._doc)?upmDoc[strPK]._doc:upmDoc[strPK];
  1408. rst.push(dtlDoc[propKey]);
  1409. }
  1410. }
  1411. }
  1412. return rst;
  1413. }
  1414. function ext_getAdHocGljProperty(adhocDataKey, propKey) {
  1415. let rst = [], parentObj = this;
  1416. let dtObj = parentObj["myOwnRawDataObj"];
  1417. if (propKey && dtObj) {
  1418. // for (let dItem of getActDataArr(dtObj)) {
  1419. // let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  1420. // pri_push_property(propKey, doc, rst);
  1421. // }
  1422. }
  1423. return rst;
  1424. }
  1425. function ext_getProperty(propKey) {
  1426. let rst = [], parentObj = this;
  1427. let dtObj = parentObj["myOwnRawDataObj"];
  1428. if (propKey && dtObj) {
  1429. for (let dItem of getActDataArr(dtObj)) {
  1430. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  1431. pri_push_property(propKey, doc, rst);
  1432. }
  1433. }
  1434. return rst;
  1435. }
  1436. function ext_getPropertyByRefId(baseKey, refIDKey, propertyKey){
  1437. let rst = [], parentObj = this;
  1438. let dtObj = parentObj["myOwnRawDataObj"];
  1439. let orgDtObj = parentObj["myOwnOrgRawDataObj"];
  1440. if (baseKey && refIDKey && propertyKey && dtObj) {
  1441. for (let dItem of getActDataArr(dtObj)) {
  1442. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  1443. let tmpRst = doc[baseKey];
  1444. if (typeof tmpRst === "string" && tmpRst[0] === "@") {
  1445. let refKey = tmpRst.slice(1);
  1446. let hasGetRef = false;
  1447. for (let orgDItem of orgDtObj) {
  1448. let oDoc = (orgDItem._doc === null || orgDItem._doc === undefined)?orgDItem:orgDItem._doc;
  1449. if (oDoc[refIDKey] === refKey) {
  1450. rst.push(oDoc[propertyKey]);
  1451. hasGetRef = true;
  1452. break;
  1453. }
  1454. }
  1455. if (!hasGetRef) {
  1456. rst.push(tmpRst);
  1457. }
  1458. } else {
  1459. rst.push(tmpRst);
  1460. }
  1461. }
  1462. }
  1463. return rst;
  1464. }
  1465. function ext_mainGetFee(feeKey, dtlFeeKey) {
  1466. let rst = [];
  1467. let parentObj = this;
  1468. let dtObj = parentObj["myOwnRawDataObj"];
  1469. if ((dtObj) && (feeKey)) {
  1470. if (dtObj.hasOwnProperty("fees")) {
  1471. for (let fee of dtObj["fees"]) {
  1472. if (fee["fieldName"] === feeKey) {
  1473. if (dtlFeeKey) {
  1474. rst.push(fee[dtlFeeKey]);
  1475. } else {
  1476. rst.push(fee["unitFee"]);
  1477. }
  1478. break;
  1479. }
  1480. }
  1481. } else if (dtObj.hasOwnProperty(feeKey)) {
  1482. rst.push(dtObj[feeKey]);
  1483. } else {
  1484. //
  1485. }
  1486. }
  1487. return rst;
  1488. }
  1489. function ext_getFee(feeKey, dtlFeeKey) {
  1490. let rst = [], parentObj = this;
  1491. let dtObj = parentObj["myOwnRawDataObj"];
  1492. if (feeKey && dtObj) {
  1493. for (let dItem of getActDataArr(dtObj)) {
  1494. rst.push(pri_getFee(dItem, feeKey, dtlFeeKey));
  1495. }
  1496. }
  1497. for (let i = 0; i < rst.length; i++) {
  1498. rst[i] = parseFloat(rst[i]);
  1499. }
  1500. return rst;
  1501. }
  1502. function pri_getFee(dItem, feeKey, dtlFeeKey) {
  1503. let rst = 0;
  1504. let hasValue = false;
  1505. if (dItem["fees"]) {
  1506. for (let fee of dItem["fees"]) {
  1507. if (fee["fieldName"] === feeKey) {
  1508. if (dtlFeeKey) {
  1509. rst = fee[dtlFeeKey];
  1510. } else {
  1511. rst = fee["unitFee"];
  1512. }
  1513. hasValue = true;
  1514. break;
  1515. }
  1516. }
  1517. } else if (dItem[feeKey]) {
  1518. hasValue = true;
  1519. rst = parseFloat(dItem[feeKey]);
  1520. } else {
  1521. hasValue = true;
  1522. rst = 0;
  1523. }
  1524. if (!hasValue) {
  1525. rst = 0;
  1526. }
  1527. return rst;
  1528. }
  1529. function ext_getCalcProperty(templateIDs, calcItemKey, calcItemKeyVal, calcItemRstKey){
  1530. let rst = [], parentObj = this; //this should be "calc_program" object
  1531. let dtObj = parentObj["myOwnRawDataObj"];
  1532. let optimizeObj = {};
  1533. let private_getProperty = function (cId) {
  1534. let calcTplObj = optimizeObj["calc_program_" + cId];
  1535. if (!calcTplObj) {
  1536. let templates = (dtObj.data._doc)?dtObj.data._doc.templates:dtObj.data.templates;
  1537. for (let tpl of templates) {
  1538. if (cId === tpl.ID) {
  1539. optimizeObj["calc_program_" + cId] = tpl;
  1540. calcTplObj = tpl;
  1541. break;
  1542. }
  1543. }
  1544. }
  1545. if (calcTplObj) {
  1546. for (let calcItem of calcTplObj.calcItems) {
  1547. if (calcItem[calcItemKey] === calcItemKeyVal) {
  1548. rst.push(calcItem[calcItemRstKey]);
  1549. break;
  1550. }
  1551. }
  1552. }
  1553. };
  1554. if (templateIDs instanceof Array) {
  1555. for (let tplId of templateIDs) {
  1556. private_getProperty(tplId);
  1557. }
  1558. } else {
  1559. private_getProperty(templateIDs);
  1560. }
  1561. optimizeObj = null;
  1562. return rst;
  1563. }
  1564. function ext_getFeeRate(fee_Ids, feeName){
  1565. let rst = [], parentObj = this; //this should be "feeRate" object
  1566. let dtObj = parentObj["myOwnRawDataObj"];
  1567. let optimizeObj = {};
  1568. let private_getFeeRate = function (fId) {
  1569. let feeRateItemObj = optimizeObj["fee_rates_" + fId];
  1570. if (!feeRateItemObj) {
  1571. let rates = (dtObj.data._doc)?dtObj.data._doc.rates:dtObj.data.rates;
  1572. for (let feeItem of rates) {
  1573. if (fId === feeItem.ID) {
  1574. optimizeObj["fee_rates_" + fId] = feeItem;
  1575. feeRateItemObj = feeItem;
  1576. break;
  1577. }
  1578. }
  1579. }
  1580. if (feeRateItemObj) {
  1581. //rst.push(feeRateItemObj.rate);
  1582. rst.push(feeRateItemObj[feeName]);
  1583. } else {
  1584. rst.push(0);
  1585. }
  1586. };
  1587. if (fee_Ids instanceof Array) {
  1588. for (let fId of fee_Ids) {
  1589. private_getFeeRate(fId);
  1590. }
  1591. } else {
  1592. private_getFeeRate(fee_Ids);
  1593. }
  1594. optimizeObj = null;
  1595. return rst;
  1596. }
  1597. function ext_getArrayValues(itemKey) {
  1598. let rst = [], parentObj = this;
  1599. let dtObj = parentObj["myOwnRawDataObj"];
  1600. let keysArr = itemKey.split(".");
  1601. for (let dataItem of getActDataArr(dtObj)) {
  1602. let itemArr = [];
  1603. if (keysArr.length <= 2) {
  1604. if (dataItem[keysArr[0]] instanceof Array) {
  1605. if (keysArr.length === 2) {
  1606. for (let item of dataItem[keysArr[0]]) {
  1607. itemArr.push(item[keysArr[1]]);
  1608. }
  1609. } else {
  1610. itemArr = itemArr.concat(dataItem[keysArr[0]]);
  1611. }
  1612. } else {
  1613. if (keysArr.length === 2) {
  1614. let subProperty = dataItem[keysArr[0]][keysArr[1]];
  1615. if (subProperty instanceof Array) {
  1616. itemArr = itemArr.concat(subProperty);
  1617. } else {
  1618. itemArr.push(subProperty);
  1619. }
  1620. } else {
  1621. itemArr.push(dataItem[keysArr[0]]);
  1622. }
  1623. }
  1624. }
  1625. rst.push(itemArr);
  1626. }
  1627. return rst;
  1628. }
  1629. function ext_getArrayItemByKey(arrayKey, itemKey, itemKeyValue, itemRstKey){
  1630. let rst = [], parentObj = this;
  1631. let dtObj = parentObj["myOwnRawDataObj"];
  1632. let private_getItemValue = function (arr, dtlItKV) {
  1633. for (let item of arr) {
  1634. if (item[itemKey] === dtlItKV) {
  1635. if (itemRstKey) {
  1636. rst.push(item[itemRstKey]);
  1637. } else {
  1638. rst.push(item);
  1639. }
  1640. break;
  1641. }
  1642. }
  1643. };
  1644. let arr = dtObj[arrayKey];
  1645. if (arr && arr instanceof Array) {
  1646. if (itemKeyValue instanceof Array) {
  1647. for (let dtlItemKeyVal of itemKeyValue) {
  1648. private_getItemValue(arr, dtlItemKeyVal);
  1649. }
  1650. } else {
  1651. private_getItemValue(arr, itemKeyValue);
  1652. }
  1653. }
  1654. }
  1655. function ext_getBlank(dftVal) {
  1656. let rst = [], parentObj = this;
  1657. let dtObj = parentObj["myOwnRawDataObj"];
  1658. if (dtObj) {
  1659. let dtData = getActDataArr(dtObj);
  1660. for (let i = 0; i < dtData.length; i++) {
  1661. if (dftVal !== null && dftVal !== undefined) {
  1662. rst.push(dftVal)
  1663. } else rst.push('');
  1664. }
  1665. }
  1666. return rst;
  1667. }
  1668. function ext_getPropertyByFlag(flagVal, rstKey, dftValIfEmpty) {
  1669. let rst = [], parentObj = this;
  1670. let dtObj = parentObj["myOwnRawDataObj"];
  1671. if (flagVal && rstKey && dtObj) {
  1672. let isArr = (flagVal instanceof Array);
  1673. for (let dItem of getActDataArr(dtObj)) {
  1674. let doc = (dItem._doc)?dItem._doc:dItem;
  1675. if (doc.hasOwnProperty("flags")) {
  1676. let bFlag = false;
  1677. for (let flagItem of doc.flags) {
  1678. if (isArr) {
  1679. bFlag = (flagVal.indexOf(flagItem.flag) >= 0);
  1680. } else {
  1681. if (flagItem.flag === flagVal) {
  1682. bFlag = true;
  1683. }
  1684. }
  1685. if (bFlag) break;
  1686. }
  1687. if (bFlag) {
  1688. let keys = rstKey.split(".");
  1689. if (keys[0] === "fees") {
  1690. rst.push(pri_getFee(doc, "common", keys[1]));
  1691. } else {
  1692. //其他,比如名称什么
  1693. }
  1694. break;
  1695. }
  1696. }
  1697. }
  1698. }
  1699. if (rst.length === 0 && dftValIfEmpty !== null) {
  1700. rst.push(dftValIfEmpty);
  1701. }
  1702. return rst;
  1703. }
  1704. function ext_getPropertyByForeignId(foreignIdVal, adHocIdKey, propKey, dftValIfNotFound) {
  1705. let rst = [], parentObj = this;
  1706. let IdKey = (adHocIdKey)?adHocIdKey:"ID";
  1707. let dtObj = parentObj["myOwnRawDataObj"];
  1708. let splitPKey = propKey.split(".");
  1709. if (foreignIdVal !== null && foreignIdVal !== undefined) {
  1710. let isFound = false;
  1711. if (foreignIdVal instanceof Array) {
  1712. for (let idVal of foreignIdVal) {
  1713. isFound = false;
  1714. let dataArr = getActDataArr(dtObj);
  1715. for (let i = 0; i < dataArr.length; i++) {
  1716. let item = (dataArr[i]._doc)?dataArr[i]._doc:dataArr[i];
  1717. if (item[IdKey] === idVal) {
  1718. if (splitPKey.length > 1) {
  1719. let rstP = null;
  1720. for (let i = 0; i < splitPKey.length; i++) {
  1721. if (i === 0) {
  1722. rstP = item[splitPKey[i]];
  1723. } else {
  1724. if (splitPKey[i].indexOf("[") === 0 && splitPKey[i].indexOf("]") === (splitPKey[i].length - 1)) {
  1725. //考虑数组情况^_^!!!
  1726. } else {
  1727. //
  1728. }
  1729. rstP = rstP[splitPKey[i]];
  1730. }
  1731. }
  1732. rst.push(rstP);
  1733. } else {
  1734. rst.push(item[propKey]);
  1735. }
  1736. isFound = true;
  1737. break;
  1738. }
  1739. }
  1740. if (!isFound) {
  1741. rst.push(dftValIfNotFound);
  1742. }
  1743. }
  1744. } else {
  1745. for (let item of getActDataArr(dtObj)) {
  1746. if (item[IdKey] === foreignIdVal) {
  1747. rst.push(item[propKey]);
  1748. isFound = true;
  1749. break;
  1750. }
  1751. }
  1752. if (!isFound) {
  1753. rst.push(dftValIfNotFound);
  1754. }
  1755. }
  1756. }
  1757. return rst;
  1758. }
  1759. function getActDataArr(dtObj, adhocKey) {
  1760. let rst = null;
  1761. if (dtObj) {
  1762. rst = dtObj.data;
  1763. if (dtObj.moduleName === "projectGLJ") {
  1764. if (adhocKey) {
  1765. rst = dtObj.data[adhocKey];
  1766. } else {
  1767. rst = dtObj.data.gljList;
  1768. }
  1769. }
  1770. if (dtObj.moduleName === "calc_program") {
  1771. rst = dtObj.data.templates;
  1772. }
  1773. }
  1774. return rst;
  1775. }
  1776. function replaceActDataArr(dtObj, newArr) {
  1777. if (dtObj.moduleName === "projectGLJ") {
  1778. delete dtObj.data.gljList;
  1779. dtObj.data.gljList = newArr;
  1780. } else {
  1781. delete dtObj.data;
  1782. dtObj.data = newArr;
  1783. }
  1784. }
  1785. export default Rpt_Data_Extractor;