rpt_yanghu_data_util.js 74 KB

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