rpt_construct_data_util.js 51 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342
  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 treeUtil = require('../../../public/treeUtil');
  11. let projectConst = consts.projectConst;
  12. let projectConstList = consts.projectConstList;
  13. const GLJ_TYPE = {
  14. Labour: 1,
  15. Material: 2,
  16. Machine: 3,
  17. Main_Material: 4,
  18. Equipment: 5
  19. };
  20. class Rpt_Common{
  21. initialize(rpt_tpl, currentDataObj) {
  22. this.template = rpt_tpl;
  23. this.currentDataObj = currentDataObj;
  24. };
  25. Multiply(val1, val2, fixFormat) {
  26. let rst = [], maxLen = val1.length, minLen = val2.length;
  27. if (minLen > maxLen) {
  28. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  29. }
  30. for (let i = 0; i < maxLen; i++) {
  31. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) * ((i < val2.length)?val2[i]:val2[minLen - 1]);
  32. if (value === null || value === undefined) {
  33. value = '0';
  34. }
  35. if (fixFormat) value = value.toFixed(fixFormat);
  36. rst.push(value);
  37. }
  38. return rst;
  39. };
  40. Divide(val1, val2, fixFormat) {
  41. let rst = [], maxLen = val1.length, minLen = val2.length;
  42. if (minLen > maxLen) {
  43. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  44. }
  45. for (let i = 0; i < maxLen; i++) {
  46. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) / ((i < val2.length)?val2[i]:val2[minLen - 1]);
  47. if (fixFormat) value = value.toFixed(fixFormat);
  48. rst.push(value);
  49. }
  50. return rst;
  51. };
  52. Plus(val1, val2, fixFormat) {
  53. let rst = [], maxLen = val1.length, minLen = val2.length;
  54. if (minLen > maxLen) {
  55. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  56. }
  57. for (let i = 0; i < maxLen; i++) {
  58. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) + ((i < val2.length)?val2[i]:val2[minLen - 1]);
  59. if (fixFormat) value = value.toFixed(fixFormat);
  60. rst.push(value);
  61. }
  62. return rst;
  63. };
  64. MultiPlus(arrVal, fixFormat) {
  65. let rst = [];
  66. for (let i = 0; i < arrVal.length; i++) {
  67. let valItem = arrVal[i];
  68. if (i === 0) {
  69. for (let dtl of valItem) {
  70. let value = parseFloat(dtl);
  71. if (fixFormat) value = value.toFixed(fixFormat);
  72. rst.push(value);
  73. }
  74. } else {
  75. for (let j = 0; j < valItem.length; j++) {
  76. if (j < rst.length) {
  77. let value = rst[j] + valItem[j];
  78. if (fixFormat) value = value.toFixed(fixFormat);
  79. rst[j] = value;
  80. } else {
  81. let value = parseFloat(valItem[j]);
  82. if (fixFormat) value = value.toFixed(fixFormat);
  83. rst.push(value);
  84. }
  85. }
  86. }
  87. }
  88. return rst;
  89. };
  90. Minus(val1, val2, fixFormat) {
  91. let rst = [], maxLen = val1.length, minLen = val2.length;
  92. if (minLen > maxLen) {
  93. maxLen = maxLen + minLen; minLen = maxLen - minLen; maxLen = maxLen - minLen;
  94. }
  95. for (let i = 0; i < maxLen; i++) {
  96. let value = ((i < val1.length)?val1[i]:val1[minLen - 1]) - ((i < val2.length)?val2[i]:val2[minLen - 1]);
  97. if (fixFormat) value = value.toFixed(fixFormat);
  98. rst.push(value);
  99. }
  100. return rst;
  101. };
  102. FormatString(arrVal, formatStr){
  103. let rst = [];
  104. for (let val of arrVal) {
  105. rst.push(stringUtil.replaceAll(formatStr, '%S', val));
  106. }
  107. return rst;
  108. };
  109. }
  110. class Rpt_Data_Extractor {
  111. constructor () {
  112. this.COMMON = new Rpt_Common();
  113. };
  114. initialize(tpl) {
  115. this.rptTpl = tpl;
  116. };
  117. //-- 根据报表模板映射指标(非离散指标)的定义,罗列出所有需要用到的data对象key,作为数据请求的过滤依据
  118. getDataRequestFilter() {
  119. let rst = [];
  120. let tpl = this.rptTpl;
  121. let pri_func_chk_filter = function (field) {
  122. for (let key of projectConstList) {
  123. if (rst.indexOf(key) < 0) {
  124. if (field[JV.PROP_FIELD_EXP_MAP]) {
  125. if (field[JV.PROP_FIELD_EXP_MAP].indexOf('.' + key + '.') >= 0) {
  126. rst.push(key);
  127. if (key === projectConst.RATION_GLJ && (rst.indexOf(projectConst.PROJECTGLJ) < 0)) {
  128. rst.push(projectConst.PROJECTGLJ);
  129. }
  130. if (key === projectConst.PROJECTGLJ && (rst.indexOf(projectConst.RATION_GLJ) < 0)) {
  131. rst.push(projectConst.RATION_GLJ);
  132. }
  133. }
  134. }
  135. }
  136. }
  137. };
  138. let pri_setup_filter = function (FIELD_LIST_KEY) {
  139. if (tpl[JV.NODE_FIELD_MAP][FIELD_LIST_KEY]) {
  140. for (let field of tpl[JV.NODE_FIELD_MAP][FIELD_LIST_KEY]) {
  141. pri_func_chk_filter(field);
  142. }
  143. }
  144. };
  145. pri_setup_filter(JV.NODE_DISCRETE_FIELDS);
  146. pri_setup_filter(JV.NODE_MASTER_FIELDS);
  147. pri_setup_filter(JV.NODE_DETAIL_FIELDS);
  148. pri_setup_filter(JV.NODE_MASTER_FIELDS_EX);
  149. pri_setup_filter(JV.NODE_DETAIL_FIELDS_EX);
  150. if (tpl[JV.NODE_MAP_DATA_HANDLE_INFO] && tpl[JV.NODE_MAP_DATA_HANDLE_INFO].length > 0) {
  151. for (let preHandle of tpl[JV.NODE_MAP_DATA_HANDLE_INFO]) {
  152. if (rst.indexOf(preHandle[JV.PROP_DATA_KEY]) < 0) {
  153. rst.push(preHandle[JV.PROP_DATA_KEY]);
  154. }
  155. if (preHandle[JV.PROP_HANDLE_TYPE] === JV.PROP_HANDLE_TYPE_FILTER) {
  156. if (preHandle[JV.PROP_FILTER_KEYS]) {
  157. for (let filter of preHandle[JV.PROP_FILTER_KEYS]) {
  158. if (filter[JV.PROP_FILTER_COMPARE_OBJ] && rst.indexOf(filter[JV.PROP_FILTER_COMPARE_OBJ]) < 0) {
  159. rst.push(filter[JV.PROP_FILTER_COMPARE_OBJ]);
  160. }
  161. }
  162. }
  163. } else if (preHandle[JV.PROP_HANDLE_TYPE] === JV.PROP_HANDLE_TYPE_SUM) {
  164. if (preHandle[JV.PROP_SUM_GROUP_KEYS]) {
  165. for (let grpKey of preHandle[JV.PROP_SUM_GROUP_KEYS]) {
  166. if (grpKey.seeking_parent && rst.indexOf(grpKey.seeking_parent) < 0) {
  167. rst.push(grpKey.seeking_parent);
  168. }
  169. }
  170. }
  171. } else if (preHandle[JV.PROP_PARENT_CHILD_SORT_KEY] && preHandle[JV.PROP_PARENT_CHILD_SORT_KEY].length > 0) {
  172. for (let item of preHandle[JV.PROP_PARENT_CHILD_SORT_KEY]) {
  173. if (rst.indexOf(item[JV.PROP_PARENT_DATA_KEY]) < 0) {
  174. rst.push(item[JV.PROP_PARENT_DATA_KEY]);
  175. }
  176. }
  177. }
  178. }
  179. }
  180. if (rst.length === 0) {
  181. rst.push(projectConst.RATION_ASS);
  182. }
  183. return rst;
  184. };
  185. //--- 装配数据(把收集到的数据,依据报表模板的指示,预处理(如:排序、过滤、合计)及装配到相关指标) ---//
  186. assembleData(rawDataObj) {
  187. let $PROJECT = {"COMMON": null, "MAIN": {}, "DETAIL": {}};
  188. let tpl = this.rptTpl;
  189. this.COMMON.initialize(tpl, rawDataObj);
  190. $PROJECT.COMMON = this.COMMON;
  191. $PROJECT.MAIN["myOwnRawDataObj"] = rawDataObj.prj._doc;
  192. $PROJECT.MAIN.getProperty = ext_mainGetPropety;
  193. $PROJECT.MAIN.getFee = ext_mainGetFee;
  194. for (let item of rawDataObj.prjData) {
  195. setupFunc($PROJECT.DETAIL, item.moduleName, item);
  196. }
  197. if (tpl[JV.NODE_MAP_DATA_HANDLE_INFO]) {
  198. for (let preHandle of tpl[JV.NODE_MAP_DATA_HANDLE_INFO]) {
  199. let srcData = getModuleDataByKey(rawDataObj.prjData, preHandle[JV.PROP_DATA_KEY]);
  200. switch(preHandle[JV.PROP_HANDLE_TYPE]) {
  201. case JV.PROP_HANDLE_TYPE_SORT:
  202. sortData(srcData, preHandle, rawDataObj.prjData);
  203. break;
  204. case JV.PROP_HANDLE_TYPE_FILTER:
  205. filterData(srcData, preHandle, rawDataObj.prjData);
  206. break;
  207. case JV.PROP_HANDLE_TYPE_SUM:
  208. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/insertedRawDataData10.jsp");
  209. summaryData(srcData, preHandle, rawDataObj.prjData);
  210. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/insertedRawDataData11.jsp");
  211. break;
  212. case JV.PROP_HANDLE_TYPE_ADD_DUMMY:
  213. addDummyData(srcData, preHandle);
  214. break;
  215. case JV.PROP_HANDLE_TYPE_ADJUST:
  216. adjustData(srcData, preHandle);
  217. break;
  218. case JV.PROP_HANDLE_TYPE_BILLS_DATA_MOVE:
  219. moveRationData(srcData, rawDataObj);
  220. break;
  221. default:
  222. break;
  223. }
  224. }
  225. }
  226. let rptDataObj = {};
  227. rptDataObj[JV.DATA_DISCRETE_DATA] = [];
  228. rptDataObj[JV.DATA_MASTER_DATA] = [];
  229. rptDataObj[JV.DATA_DETAIL_DATA] = [];
  230. rptDataObj[JV.DATA_MASTER_DATA_EX] = [];
  231. rptDataObj[JV.DATA_DETAIL_DATA_EX] = [];
  232. rptDataObj.DecimalObj = {};
  233. rptDataObj.DecimalObj.prjDecimal = $PROJECT.MAIN["myOwnRawDataObj"].decimal; //为函数 P_REF() 准备数据
  234. rptDataObj.DecimalObj.unitDecimal = getUnitDecimal($PROJECT.MAIN["myOwnRawDataObj"].billsQuantityDecimal); //为函数 U_REF() 准备数据
  235. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_DISCRETE_FIELDS], rptDataObj[JV.DATA_DISCRETE_DATA], $PROJECT);
  236. // console.log(JV.DATA_DISCRETE_DATA);
  237. // console.log(rptDataObj[JV.DATA_DISCRETE_DATA]);
  238. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_MASTER_FIELDS], rptDataObj[JV.DATA_MASTER_DATA], $PROJECT);
  239. // console.log(JV.DATA_MASTER_DATA);
  240. // console.log(rptDataObj[JV.DATA_MASTER_DATA]);
  241. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_DETAIL_FIELDS], rptDataObj[JV.DATA_DETAIL_DATA], $PROJECT);
  242. // console.log(JV.DATA_DETAIL_DATA);
  243. // console.log(rptDataObj[JV.DATA_DETAIL_DATA]);
  244. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_MASTER_FIELDS_EX], rptDataObj[JV.DATA_MASTER_DATA_EX], $PROJECT);
  245. // console.log(JV.DATA_MASTER_DATA_EX);
  246. // console.log(rptDataObj[JV.DATA_MASTER_DATA_EX]);
  247. assembleFields(tpl[JV.NODE_FIELD_MAP][JV.NODE_DETAIL_FIELDS_EX], rptDataObj[JV.DATA_DETAIL_DATA_EX], $PROJECT);
  248. // console.log(JV.DATA_DETAIL_DATA_EX);
  249. // console.log(rptDataObj[JV.DATA_DETAIL_DATA_EX]);
  250. // fsUtil.writeObjToFile(rptDataObj, "D:/GitHome/ConstructionCost/tmp/insertedOriginalData.jsp");
  251. // fsUtil.writeObjToFile(rawDataObj, "D:/GitHome/ConstructionCost/tmp/insertedRawDataData.jsp");
  252. // fsUtil.writeObjToFile($PROJECT, "D:/GitHome/ConstructionCost/tmp/$PROJECTData.jsp");
  253. return rptDataObj;
  254. };
  255. }
  256. //小数位数依据单位来调整(如吨、公斤的精度要求就不同)
  257. function getUnitDecimal(unitDecimalArr) {
  258. let rst = {"default_decimal": 2};
  259. if (unitDecimalArr) {
  260. for (let item of unitDecimalArr) {
  261. if (item.unit === "其他未列单位") {
  262. rst["default_decimal"] = item.decimal;
  263. } else {
  264. rst['unit_decimal_' + item.unit] = item.decimal;
  265. }
  266. }
  267. }
  268. return rst;
  269. }
  270. function getModuleDataByKey(prjData, key) {
  271. let rst = null;
  272. for (let item of prjData) {
  273. if (item.moduleName === key) {
  274. rst = item;
  275. break;
  276. }
  277. }
  278. return rst;
  279. }
  280. function summaryData(sourceData, handleCfg, prjData){
  281. let rstArr = [], tempRstArr = [];
  282. let curParentPrjData = {};
  283. for (let item of sourceData.data) {
  284. if (item._doc) {
  285. tempRstArr.push(item._doc);
  286. } else {
  287. tempRstArr.push(item);
  288. }
  289. }
  290. let private_cal_before_sum = function () {
  291. for (let calcAheadObj of handleCfg[JV.PROP_SUM_CALC_AHEAD]) {
  292. if (!curParentPrjData[calcAheadObj["seeking_parent"]]) curParentPrjData[calcAheadObj["seeking_parent"]] = getModuleDataByKey(prjData, calcAheadObj["seeking_parent"]);
  293. for (let idxP = 0; idxP < curParentPrjData[calcAheadObj["seeking_parent"]].data.length; idxP++) {
  294. let pDataItem = curParentPrjData[calcAheadObj["seeking_parent"]].data[idxP];
  295. let data = (pDataItem._doc)?pDataItem._doc:pDataItem;
  296. for (let idx = 0; idx < tempRstArr.length; idx++) {
  297. let dtlItem = tempRstArr[idx];
  298. if (dtlItem[calcAheadObj["seeking_key"]] === data[calcAheadObj["parent_key"]]) {
  299. for (let sumKey of handleCfg[JV.PROP_SUM_SUM_KEYS]) {
  300. switch (calcAheadObj[JV.PROP_SUM_CACL_TYPE]) {
  301. case "+":
  302. dtlItem[sumKey] = parseFloat(dtlItem[sumKey]) + parseFloat(data[calcAheadObj["calc_property"]]);
  303. break;
  304. case "-":
  305. dtlItem[sumKey] = parseFloat(dtlItem[sumKey]) - parseFloat(data[calcAheadObj["calc_property"]]);
  306. break;
  307. case "*":
  308. dtlItem[sumKey] = dtlItem[sumKey] * parseFloat(data[calcAheadObj["calc_property"]]).toFixed(4);
  309. break;
  310. case "/":
  311. dtlItem[sumKey] = dtlItem[sumKey] / parseFloat(data[calcAheadObj["calc_property"]]).toFixed(4);
  312. break;
  313. default:
  314. break;
  315. }
  316. }
  317. // break;
  318. }
  319. }
  320. }
  321. }
  322. };
  323. let private_get_grp_key = function (item) {
  324. let keys = [];
  325. for (let cfg of handleCfg[JV.PROP_SUM_GROUP_KEYS]) {
  326. if (typeof cfg === "string") {
  327. keys.push(item[cfg]);
  328. } else {
  329. if (!curParentPrjData[cfg["seeking_parent"]]) curParentPrjData[cfg["seeking_parent"]] = getModuleDataByKey(prjData, cfg["seeking_parent"]);
  330. for (let pDataItem of curParentPrjData[cfg["seeking_parent"]].data) {
  331. let data = (pDataItem._doc)?pDataItem._doc:pDataItem;
  332. if (item[cfg["seeking_key"]] === data[cfg["parent_key"]]) {
  333. keys.push(data[cfg["parent_grp_key"]]);
  334. break;
  335. }
  336. }
  337. }
  338. }
  339. return ( "grp_key_" + keys.join('_'));
  340. };
  341. let sumObj = {};
  342. if (handleCfg[JV.PROP_SUM_CALC_AHEAD] && handleCfg[JV.PROP_SUM_CALC_AHEAD].length > 0) {
  343. private_cal_before_sum();
  344. }
  345. for (let dtl of tempRstArr) {
  346. let grpKey = private_get_grp_key(dtl);
  347. if (sumObj[grpKey] === null || sumObj[grpKey] === undefined) {
  348. sumObj[grpKey] = dtl;
  349. rstArr.push(dtl);
  350. } else {
  351. for (let sumKey of handleCfg[JV.PROP_SUM_SUM_KEYS]) {
  352. if (dtl[sumKey]) {
  353. // sumObj[grpKey][sumKey] += dtl[sumKey];
  354. sumObj[grpKey][sumKey] = parseFloat(sumObj[grpKey][sumKey]) + parseFloat(dtl[sumKey]);
  355. }
  356. }
  357. }
  358. }
  359. delete sourceData.data;
  360. sourceData.data = rstArr;
  361. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/sumRst.jsp");
  362. }
  363. function filterData(sourceData, handleCfg, prjData) {
  364. let rstArr = [], tempRstArr = [];
  365. for (let item of sourceData.data) {
  366. if (item._doc) {
  367. tempRstArr.push(item._doc);
  368. } else {
  369. tempRstArr.push(item);
  370. }
  371. }
  372. let private_chkVal = function (src, compVal, compStr) {
  373. let rst = true;
  374. switch (compStr) {
  375. case "==" :
  376. rst = (src == compVal);
  377. break;
  378. case "===" :
  379. rst = (src === compVal);
  380. break;
  381. case ">" :
  382. rst = (src > compVal);
  383. break;
  384. case ">=" :
  385. rst = (src >= compVal);
  386. break;
  387. case "<" :
  388. rst = (src < compVal);
  389. break;
  390. case "<=" :
  391. rst = (src <= compVal);
  392. break;
  393. case "!=" :
  394. rst = (src != compVal);
  395. break;
  396. case "!==" :
  397. rst = (src !== compVal);
  398. break;
  399. case "in" :
  400. if (compVal instanceof Array) {
  401. rst = compVal.indexOf(src) >= 0;
  402. } else {
  403. //string,需要转类型
  404. let newCv = JSON.parse(compVal);
  405. if (newCv instanceof Array) {
  406. rst = newCv.indexOf(src) >= 0;
  407. } else {
  408. rst = false;
  409. }
  410. }
  411. break;
  412. case "not in":
  413. if (compVal instanceof Array) {
  414. rst = compVal.indexOf(src) < 0;
  415. } else {
  416. //string,需要转类型
  417. let newCv = JSON.parse(compVal);
  418. if (newCv instanceof Array) {
  419. rst = newCv.indexOf(src) < 0;
  420. } else {
  421. rst = true;
  422. }
  423. }
  424. break;
  425. default:
  426. rst = true;
  427. }
  428. return rst;
  429. };
  430. let private_chkArrVal = function(arr, key, compVal, compStr){
  431. let rst = false;
  432. for (let arrItem of arr) {
  433. if (arrItem[key]) {
  434. rst = private_chkVal(arrItem[key], compVal, compStr);
  435. }
  436. if (rst) {
  437. break;
  438. }
  439. }
  440. return rst;
  441. };
  442. let private_filter_compare = function (item, filterCfg) {
  443. let compareObj = {};
  444. let compRst = true;
  445. let curComparePrjData = null;
  446. let startIdx = 0;
  447. for (let cfg of filterCfg[JV.PROP_FILTER_KEYS]) {
  448. if (cfg[JV.PROP_FILTER_COMPARE_VAL]) {
  449. //比较key值
  450. let keys = cfg.key.split(".");
  451. if (keys.length > 1) {
  452. let lastObj = item;
  453. for (let i = 0; i < keys.length - 1; i++) {
  454. lastObj = item[keys[i]];
  455. if (!(lastObj)) {
  456. compRst = false;
  457. break;
  458. }
  459. }
  460. if (lastObj) {
  461. if (lastObj instanceof Array) {
  462. compRst = private_chkArrVal(lastObj, keys[keys.length - 1], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  463. } else {
  464. compRst = private_chkVal(lastObj[keys[keys.length - 1]], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  465. }
  466. }
  467. } else {
  468. compRst = private_chkVal(item[cfg.key], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  469. }
  470. } else if (cfg[JV.PROP_FILTER_COMPARE_OBJ] && cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]){
  471. //通过其他对象来过滤
  472. if (!curComparePrjData) {
  473. curComparePrjData = getModuleDataByKey(prjData, cfg[JV.PROP_FILTER_COMPARE_OBJ]);
  474. }
  475. if (cfg[JV.PROP_FILTER_CONDITION] === "in" || cfg[JV.PROP_FILTER_CONDITION] === "not in") {
  476. let compareArr = null;
  477. if (!compareObj.hasOwnProperty(cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString())) {
  478. compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()] = [];
  479. compareArr = compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()];
  480. for (let data of curComparePrjData.data) {
  481. if (compareArr.indexOf(data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]]) < 0) {
  482. compareArr.push(data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]]);
  483. }
  484. }
  485. } else {
  486. compareArr = compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()];
  487. }
  488. compRst = private_chkVal(item[cfg.key], compareArr, cfg[JV.PROP_FILTER_CONDITION]);
  489. } else {
  490. for (let data of curComparePrjData.data) {
  491. compRst = private_chkVal(item[cfg.key], data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]], cfg[JV.PROP_FILTER_CONDITION]);
  492. if (compRst) break;
  493. }
  494. }
  495. }
  496. startIdx++;
  497. }
  498. return compRst;
  499. };
  500. for (let item of tempRstArr) {
  501. if (private_filter_compare(item, handleCfg)) {
  502. rstArr.push(item);
  503. }
  504. }
  505. if (handleCfg[JV.PROP_OTHER_SUB_FILTER] && handleCfg[JV.PROP_OTHER_SUB_FILTER].length > 0) {
  506. let newRstArr = [];
  507. for (let dtlItem of rstArr) {
  508. let cmpRst = false;
  509. for (let dtlCfg of handleCfg[JV.PROP_OTHER_SUB_FILTER]) {
  510. cmpRst = private_filter_compare(dtlItem, dtlCfg);
  511. if (cmpRst) {
  512. newRstArr.push(dtlItem);
  513. break;
  514. }
  515. }
  516. }
  517. rstArr = newRstArr;
  518. }
  519. delete sourceData.data;
  520. sourceData.data = rstArr;
  521. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/filteredRst.js");
  522. }
  523. function adjustData(sourceData, adjustCfg) {
  524. let rstArr = [];
  525. for (let item of sourceData.data) {
  526. if (item._doc) {
  527. rstArr.push(item._doc);
  528. } else {
  529. rstArr.push(item);
  530. }
  531. }
  532. for (let item of adjustCfg[JV.PROP_ADJUST_COLLECTION]) {
  533. for (let rec of rstArr) {
  534. if (item[JV.PROP_ADJUST_ACTION] === "prefix") {
  535. rec[item.key] = item[JV.PROP_ADJUST_ACTION_VAL] + rec[item.key];
  536. } else if (item[JV.PROP_ADJUST_ACTION] === "suffix") {
  537. rec[item.key] = rec[item.key] + item[JV.PROP_ADJUST_ACTION_VAL];
  538. }
  539. }
  540. }
  541. delete sourceData.data;
  542. sourceData.data = rstArr;
  543. }
  544. function moveRationData(rationData, rawDataObj) {
  545. if (rawDataObj) {
  546. // let rationData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION);
  547. let rationGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION_GLJ);
  548. let prjGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.PROJECTGLJ);
  549. let dummyCode = " ", dummyPRJID = 10101010;
  550. for (let rationItem of rationData.data) {
  551. if (rationItem.type === 2 || rationItem.type === 3) {
  552. //2: 量材(人工/材料/机械/主材/设备) 3:材料(材料/主材/设备)
  553. let copyItem = {};
  554. copyItem.ID = rationItem.ID;
  555. copyItem.projectID = rationItem.projectID;
  556. copyItem.GLJID = rationItem.GLJID;
  557. copyItem.rationID = rationItem.ID;
  558. copyItem.rationItemQuantity = 1;
  559. copyItem.quantity = 1;
  560. // copyItem.specialType_quantity = rationItem.quantity;
  561. copyItem.name = rationItem.name;
  562. if (rationItem.code) {
  563. copyItem.code = rationItem.ID + "_" + rationItem.code;
  564. } else {
  565. copyItem.code = dummyCode;
  566. dummyCode = dummyCode + " ";
  567. }
  568. copyItem.original_code = rationItem.original_code;
  569. copyItem.unit = rationItem.unit;
  570. copyItem.specs = rationItem.specs;
  571. copyItem.shortName = rationItem.shortName;
  572. copyItem.billsItemID = rationItem.billsItemID;
  573. copyItem.type = rationItem.subType;
  574. if (rationItem.projectGLJID) {
  575. copyItem.projectGLJID = rationItem.projectGLJID;
  576. } else {
  577. //add dummy project GLJ
  578. let dummyPrjItem = {};
  579. copyItem.projectGLJID = dummyPRJID;
  580. dummyPrjItem.id = dummyPRJID;
  581. dummyPRJID++;
  582. dummyPrjItem.unit_price = {};
  583. dummyPrjItem.unit_price.base_price = 0;
  584. dummyPrjItem.unit_price.market_price = (rationItem["marketUnitFee"])?rationItem["marketUnitFee"]:0;
  585. dummyPrjItem.quantity = 0;
  586. dummyPrjItem.is_evaluate = 0;
  587. prjGljData.data.gljList.push(dummyPrjItem);
  588. }
  589. rationGljData.data.push(copyItem);
  590. }
  591. }
  592. // fsUtil.writeObjToFile(rationGljData.data, "D:/GitHome/ConstructionCost/tmp/afterMoveGLJ.jsp");
  593. }
  594. }
  595. function getDupGrpKeyVals(sourceData, segKeys) {
  596. let rst = [];
  597. function pushKeyVal(item) {
  598. let tr = {};
  599. for (let i = 0; i < segKeys.length; i++) {
  600. tr[segKeys[i]] = item[segKeys[i]];
  601. }
  602. rst.push(tr);
  603. }
  604. for (let idx = 0; idx < sourceData.length; idx++) {
  605. let itemRec = sourceData[idx];
  606. if (idx === 0) {
  607. pushKeyVal(itemRec);
  608. continue;
  609. }
  610. let hasDiff = false;
  611. for (let i = 0; i < segKeys.length; i++) {
  612. if (itemRec[segKeys[i]] !== sourceData[idx - 1][segKeys[i]]) {
  613. hasDiff = true;
  614. break;
  615. }
  616. }
  617. if (hasDiff) {
  618. pushKeyVal(itemRec);
  619. }
  620. }
  621. return rst;
  622. }
  623. function addDummyData(sourceData, addCfg) {
  624. let rstArr = [], tempRstArr = [];
  625. for (let item of sourceData.data) {
  626. if (item._doc) {
  627. tempRstArr.push(item._doc);
  628. } else {
  629. tempRstArr.push(item);
  630. }
  631. }
  632. for (let item of addCfg[JV.PROP_DUMMY_COLLECTION]) {
  633. let newRecStr = JSON.stringify(item[JV.PROP_DUMMY_VAL]), cacheGrpKeyRecs = null;
  634. if (item[JV.PROP_FREQUENCY] === "OncePerGrp") {
  635. if (!cacheGrpKeyRecs) {
  636. cacheGrpKeyRecs = {};
  637. }
  638. let cacheKey = "";
  639. for (let key of item[JV.PROP_GRP_KEYS]) {
  640. cacheKey += "_" + key;
  641. }
  642. if (!cacheGrpKeyRecs[cacheKey]) {
  643. cacheGrpKeyRecs[cacheKey] = getDupGrpKeyVals(tempRstArr, item[JV.PROP_GRP_KEYS]);
  644. }
  645. for (let kv of cacheGrpKeyRecs[cacheKey]) {
  646. let rec = JSON.parse(newRecStr);
  647. for (let key of item[JV.PROP_GRP_KEYS]) {
  648. rec[key] = kv[key];
  649. }
  650. rstArr.push(rec);
  651. }
  652. } else if (item[JV.PROP_FREQUENCY] === "Once") {
  653. rstArr.push(JSON.parse(newRecStr));
  654. }
  655. }
  656. rstArr = rstArr.concat(tempRstArr);
  657. delete sourceData.data;
  658. sourceData.data = rstArr;
  659. }
  660. function getGLJBizType(orgType, orgCode, orgName) {
  661. let rst = orgType;
  662. if (orgName.indexOf("其他材料费") >= 0) {
  663. rst = 299;
  664. } else if (orgType === GLJ_TYPE.Labour) {
  665. rst = 11;
  666. if (orgCode === "000000") rst = 10;
  667. } else if (orgType === GLJ_TYPE.Main_Material || orgType === GLJ_TYPE.Equipment) {
  668. //未计价材料(主材 + 设备)
  669. rst = 30 + orgType;
  670. } else if (orgType === GLJ_TYPE.Material || (orgType >= 200 && orgType < 300)) {
  671. //材料
  672. if (orgCode === "000000") {
  673. rst = 20; //2.材料
  674. } else if (orgCode === "000000_1") {
  675. rst = 30; //(1) 未计价材料
  676. } else if (orgCode === "000000_2") {
  677. rst = 40; //(2) 辅助材料
  678. } else if (orgCode === "000000_3") {
  679. rst = 50; //(3) 其他材料费
  680. } else {
  681. rst = 45; //到这里就只有辅助材料没有预处理了
  682. }
  683. } else if (orgType === GLJ_TYPE.Machine || (orgType >= 300 && orgType < 400)) {
  684. //机械
  685. if (orgCode === "000000") {
  686. rst = 300; //3.机械
  687. } else if (orgType === GLJ_TYPE.Machine) {
  688. rst = 300.5;
  689. } else {
  690. rst = orgType;
  691. }
  692. }
  693. return rst;
  694. }
  695. function sortData(sourceData, sortCfg, prjData) {
  696. let rst = sourceData.data, tempRstArr = [];
  697. let sortType = sortCfg[JV.PROP_SORT_TYPE];
  698. for (let item of sourceData.data) {
  699. if (item._doc) {
  700. tempRstArr.push(item._doc);
  701. } else {
  702. tempRstArr.push(item);
  703. }
  704. }
  705. function private_normal_sort(destArr, sortKeys) {
  706. destArr.sort(function(a, b){
  707. let compRst = 0;
  708. for (let comp of sortKeys) {
  709. let reverse = (comp.order === 'ascend')?1:(-1);
  710. //
  711. if (a[comp.key] > b[comp.key]) {
  712. compRst = reverse;
  713. break;
  714. } else if (a[comp.key] < b[comp.key]) {
  715. compRst = -reverse;
  716. break;
  717. }
  718. }
  719. return compRst;
  720. });
  721. }
  722. function private_parent_sort(parentArr, parentKeys, childArr, childKeys) {
  723. let tmpRst = {}, rst = [];
  724. for (let pItem of parentArr) {
  725. let pKey = "key";
  726. for (let key of parentKeys) {
  727. pKey += "_" + pItem[key];
  728. }
  729. tmpRst[pKey] = [];
  730. }
  731. for (let cItem of childArr) {
  732. let cKey = "key";
  733. for (let key of childKeys) {
  734. cKey += "_" + cItem[key];
  735. }
  736. if (tmpRst[cKey]) {
  737. tmpRst[cKey].push(cItem);
  738. } else {
  739. //unknown child value! should be filtered!
  740. }
  741. }
  742. // childArr.splice(0);
  743. for (let pItem of parentArr) {
  744. let pKey = "key";
  745. for (let key of parentKeys) {
  746. pKey += "_" + pItem[key];
  747. }
  748. rst.push(tmpRst[pKey]);
  749. // for (let rItem of tmpRst[pKey]) {
  750. // childArr.push(rItem);
  751. // }
  752. }
  753. return rst;
  754. }
  755. switch (sortType) {
  756. case "tree":
  757. let addLevel = true;
  758. rst = treeUtil.buildTreeNodeDirectly(tempRstArr, addLevel);
  759. let newTopArr = [];
  760. if ((sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES] && sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES].length > 0) ||
  761. (sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES] && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].length > 0)) {
  762. let local_check_bills = function(tItem) {
  763. let chkDtl = false;
  764. if (tItem.flags && tItem.flags.length > 0) {
  765. for (let flagItem of tItem.flags) {
  766. if (sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].indexOf(flagItem.flag) >= 0) {
  767. newTopArr.push(tItem);
  768. chkDtl = true;
  769. break;
  770. }
  771. }
  772. }
  773. if (!chkDtl && tItem.items && tItem.items.length > 0) {
  774. for (let dtlItem of tItem.items) {
  775. local_check_bills(dtlItem);
  776. }
  777. }
  778. };
  779. for (let topItem of rst) {
  780. let chkTop = false;
  781. if (topItem.flags && topItem.flags.length > 0) {
  782. for (let flagItem of topItem.flags) {
  783. if (sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES].indexOf(flagItem.flag) >= 0) {
  784. newTopArr.push(topItem);
  785. chkTop = true;
  786. break;
  787. }
  788. }
  789. }
  790. if (!chkTop && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES] && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].length > 0) {
  791. local_check_bills(topItem);
  792. }
  793. }
  794. } else {
  795. newTopArr = rst;
  796. }
  797. let destArr = [];
  798. treeUtil.getFlatArray(newTopArr, destArr);
  799. delete sourceData.data;
  800. sourceData.data = destArr;
  801. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/sortedAndFlattedRst.jsp");
  802. break;
  803. case "normal":
  804. private_normal_sort(tempRstArr, sortCfg[JV.PROP_SORT_KEYS]);
  805. delete sourceData.data;
  806. sourceData.data = tempRstArr;
  807. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/normalSortedRst.jsp");
  808. break;
  809. case "accord_to_parent":
  810. let pcKey = sortCfg[JV.PROP_PARENT_CHILD_SORT_KEY];
  811. let parentSrcData = getModuleDataByKey(prjData, pcKey[JV.PROP_PARENT_DATA_KEY]);
  812. if (parentSrcData) {
  813. let tempParentArr = [];
  814. for (let item of parentSrcData.data) {
  815. if (item._doc) {
  816. tempParentArr.push(item._doc);
  817. } else {
  818. tempParentArr.push(item);
  819. }
  820. }
  821. let sortedRstArr = private_parent_sort(tempParentArr, pcKey[JV.PROP_PARENT_SORT_KEYS], tempRstArr, pcKey[JV.PROP_CHILD_SORT_KEYS]);
  822. if (sortCfg[JV.PROP_OTHER_SUB_SORT] && sortCfg[JV.PROP_OTHER_SUB_SORT].length > 0) {
  823. for (let sort of sortCfg[JV.PROP_OTHER_SUB_SORT]) {
  824. if (sort[JV.PROP_SORT_TYPE] === 'normal') {
  825. for (let subArr of sortedRstArr) {
  826. private_normal_sort(subArr, sort[JV.PROP_SORT_KEYS]);
  827. }
  828. } else if (sort[JV.PROP_SORT_TYPE] === 'self_define') {
  829. for (let subArr of sortedRstArr) {
  830. // console.log(subArr);
  831. let selfDefFunc = null;
  832. eval('selfDefFunc = ' + sort[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]);
  833. subArr.sort(selfDefFunc);
  834. // console.log(subArr);
  835. }
  836. }
  837. }
  838. }
  839. tempRstArr.splice(0);
  840. for (let item of sortedRstArr) {
  841. for (let subItem of item) {
  842. tempRstArr.push(subItem);
  843. }
  844. }
  845. }
  846. delete sourceData.data;
  847. sourceData.data = tempRstArr;
  848. break;
  849. case "self_define":
  850. if (sortCfg[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]) {
  851. let selfDefFunc = null;
  852. eval('selfDefFunc = ' + sortCfg[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]);
  853. tempRstArr.sort(selfDefFunc);
  854. }
  855. delete sourceData.data;
  856. sourceData.data = tempRstArr;
  857. break;
  858. default:
  859. //
  860. }
  861. return rst;
  862. }
  863. function setupFunc(obj, prop, ownRawObj) {
  864. obj[prop] = {};
  865. obj[prop]["myOwnRawDataObj"] = ownRawObj;
  866. obj[prop]["myOwnOrgRawDataObj"] = ownRawObj.data;
  867. obj[prop].getProperty = ext_getPropety;
  868. obj[prop].getPropertyByRefId = ext_getPropertyByRefId;
  869. obj[prop].getFee = ext_getFee;
  870. obj[prop].getPropertyByForeignId = ext_getPropertyByForeignId;
  871. obj[prop].getArrayValues = ext_getArrayValues;
  872. obj[prop].getArrayItemByKey = ext_getArrayItemByKey;
  873. obj[prop].getPropertyByFlag = ext_getPropertyByFlag;
  874. obj[prop].getBlank = ext_getBlank;
  875. if (prop === projectConst.CALC_PROGRAM) obj[prop].getCalcProperty = ext_getCalcProperty;
  876. if (prop === projectConst.FEERATE) obj[prop].getFeeRate = ext_getFeeRate;
  877. }
  878. function assembleFields(fieldList, rstDataArr, $PROJECT) {
  879. if (fieldList) {
  880. for (let field of fieldList) {
  881. shielded_exec_env($PROJECT, field, rstDataArr);
  882. }
  883. }
  884. }
  885. function shielded_exec_env($PROJECT, $ME, rptDataItemObj) {
  886. if ($ME[JV.PROP_FIELD_EXP_MAP]) {
  887. rptDataItemObj.push(eval($ME[JV.PROP_FIELD_EXP_MAP]));
  888. }
  889. }
  890. function getActPropertyVal(firstPropKey, secPropKey, orgObj) {
  891. let rst = null;
  892. if (orgObj[firstPropKey]) {
  893. rst = orgObj[firstPropKey];
  894. } else if (orgObj[secPropKey]){
  895. rst = orgObj[secPropKey];
  896. }
  897. return rst;
  898. }
  899. function getDeepProperty(propKey, orgObj, destArr) {
  900. let keys = propKey.split(".");
  901. let dftPropKey = "key", dftPropVal = "value", secDftPropVal = "items";
  902. let parent = orgObj, lastVal = null;
  903. for (let key of keys) {
  904. if (parent instanceof Array) {
  905. for (let item of parent) {
  906. if (item[dftPropKey] === key) {
  907. lastVal = getActPropertyVal(dftPropVal, secDftPropVal, item);
  908. break;
  909. }
  910. }
  911. } else {
  912. lastVal = null;
  913. if (parent[key] !== undefined) {
  914. lastVal = parent[key];
  915. } else if (parent[secDftPropVal]){
  916. for (let item of parent[secDftPropVal]) {
  917. if (item[dftPropKey] === key) {
  918. // lastVal = item[dftPropVal];
  919. lastVal = getActPropertyVal(dftPropVal, secDftPropVal, item);
  920. break;
  921. }
  922. }
  923. }
  924. }
  925. parent = lastVal;
  926. if (parent === null) break;
  927. }
  928. if (destArr && destArr instanceof Array) {
  929. destArr.push(lastVal);
  930. }
  931. }
  932. function ext_mainGetPropety(propKey) {
  933. let rst = [], parentObj = this;
  934. let dtObj = parentObj["myOwnRawDataObj"];
  935. if (propKey && dtObj) {
  936. if (dtObj.hasOwnProperty("property")) {
  937. if (!dtObj["property"][propKey] && dtObj[propKey]) {
  938. rst.push(dtObj[propKey]);
  939. } else {
  940. getDeepProperty(propKey, dtObj["property"], rst);
  941. }
  942. } else {
  943. // rst.push(dtObj[propKey]);
  944. getDeepProperty(propKey, dtObj, rst);
  945. }
  946. }
  947. return rst;
  948. }
  949. function ext_getPropety(propKey) {
  950. let rst = [], parentObj = this;
  951. let dtObj = parentObj["myOwnRawDataObj"];
  952. if (propKey && dtObj) {
  953. for (let dItem of dtObj.data) {
  954. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  955. if (propKey instanceof Array) {
  956. for (let pi = 0; pi < propKey.length; pi++) {
  957. if (doc.hasOwnProperty("property")) {
  958. if (doc["property"].hasOwnProperty(propKey[pi])) {
  959. rst.push(doc["property"][propKey[pi]]);
  960. break;
  961. }
  962. } else if (doc.hasOwnProperty(propKey[pi])) {
  963. rst.push(doc[propKey[pi]]);
  964. break;
  965. }
  966. if (pi === propKey.length - 1) rst.push('');
  967. }
  968. } else {
  969. if (doc.hasOwnProperty("property")) {
  970. rst.push(doc["property"][propKey]);
  971. } else if (doc.hasOwnProperty(propKey)) {
  972. rst.push(doc[propKey]);
  973. } else {
  974. rst.push('');
  975. }
  976. }
  977. }
  978. }
  979. return rst;
  980. }
  981. function ext_getPropertyByRefId(baseKey, refIDKey, propertyKey){
  982. let rst = [], parentObj = this;
  983. let dtObj = parentObj["myOwnRawDataObj"];
  984. let orgDtObj = parentObj["myOwnOrgRawDataObj"];
  985. if (baseKey && refIDKey && propertyKey && dtObj) {
  986. for (let dItem of dtObj.data) {
  987. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  988. let tmpRst = doc[baseKey];
  989. if (typeof tmpRst === "string" && tmpRst[0] === "@") {
  990. let refKey = tmpRst.slice(1);
  991. let hasGetRef = false;
  992. for (let orgDItem of orgDtObj) {
  993. let oDoc = (orgDItem._doc === null || orgDItem._doc === undefined)?orgDItem:orgDItem._doc;
  994. if (oDoc[refIDKey] === refKey) {
  995. rst.push(oDoc[propertyKey]);
  996. hasGetRef = true;
  997. break;
  998. }
  999. }
  1000. if (!hasGetRef) {
  1001. rst.push(tmpRst);
  1002. }
  1003. } else {
  1004. rst.push(tmpRst);
  1005. }
  1006. }
  1007. }
  1008. return rst;
  1009. }
  1010. function ext_mainGetFee(feeKey, dtlFeeKey) {
  1011. let rst = [];
  1012. let parentObj = this;
  1013. let dtObj = parentObj["myOwnRawDataObj"];
  1014. if ((dtObj) && (feeKey)) {
  1015. if (dtObj.hasOwnProperty("fees")) {
  1016. for (let fee of dtObj["fees"]) {
  1017. if (fee["fieldName"] === feeKey) {
  1018. if (dtlFeeKey) {
  1019. rst.push(fee[dtlFeeKey]);
  1020. } else {
  1021. rst.push(fee["unitFee"]);
  1022. }
  1023. break;
  1024. }
  1025. }
  1026. } else if (dtObj.hasOwnProperty(feeKey)) {
  1027. rst.push(dtObj[feeKey]);
  1028. } else {
  1029. //
  1030. }
  1031. }
  1032. return rst;
  1033. }
  1034. function ext_getFee(feeKey, dtlFeeKey) {
  1035. let rst = [], parentObj = this;
  1036. let dtObj = parentObj["myOwnRawDataObj"];
  1037. if (feeKey && dtObj) {
  1038. for (let dItem of dtObj.data) {
  1039. rst.push(pri_getFee(dItem, feeKey, dtlFeeKey));
  1040. }
  1041. }
  1042. for (let i = 0; i < rst.length; i++) {
  1043. rst[i] = parseFloat(rst[i]);
  1044. }
  1045. return rst;
  1046. }
  1047. function pri_getFee(dItem, feeKey, dtlFeeKey) {
  1048. let rst = 0;
  1049. let hasValue = false;
  1050. if (dItem["fees"]) {
  1051. for (let fee of dItem["fees"]) {
  1052. if (fee["fieldName"] === feeKey) {
  1053. if (dtlFeeKey) {
  1054. rst = fee[dtlFeeKey];
  1055. } else {
  1056. rst = fee["unitFee"];
  1057. }
  1058. hasValue = true;
  1059. break;
  1060. }
  1061. }
  1062. } else if (dItem[feeKey]) {
  1063. hasValue = true;
  1064. rst = dItem[feeKey];
  1065. } else {
  1066. hasValue = true;
  1067. rst = 0;
  1068. }
  1069. if (!hasValue) {
  1070. rst = 0;
  1071. }
  1072. return rst;
  1073. }
  1074. function ext_getCalcProperty(templateIDs, calcItemKey, calcItemKeyVal, calcItemRstKey){
  1075. let rst = [], parentObj = this; //this should be "calc_program" object
  1076. let dtObj = parentObj["myOwnRawDataObj"];
  1077. let optimizeObj = {};
  1078. let private_getProperty = function (cId) {
  1079. let calcTplObj = optimizeObj["calc_program_" + cId];
  1080. if (!calcTplObj) {
  1081. let templates = (dtObj.data._doc)?dtObj.data._doc.templates:dtObj.data.templates;
  1082. for (let tpl of templates) {
  1083. if (cId === tpl.ID) {
  1084. optimizeObj["calc_program_" + cId] = tpl;
  1085. calcTplObj = tpl;
  1086. break;
  1087. }
  1088. }
  1089. }
  1090. if (calcTplObj) {
  1091. for (let calcItem of calcTplObj.calcItems) {
  1092. if (calcItem[calcItemKey] === calcItemKeyVal) {
  1093. rst.push(calcItem[calcItemRstKey]);
  1094. break;
  1095. }
  1096. }
  1097. }
  1098. };
  1099. if (templateIDs instanceof Array) {
  1100. for (let tplId of templateIDs) {
  1101. private_getProperty(tplId);
  1102. }
  1103. } else {
  1104. private_getProperty(templateIDs);
  1105. }
  1106. optimizeObj = null;
  1107. return rst;
  1108. }
  1109. function ext_getFeeRate(fee_Ids){
  1110. let rst = [], parentObj = this; //this should be "feeRate" object
  1111. let dtObj = parentObj["myOwnRawDataObj"];
  1112. let optimizeObj = {};
  1113. let private_getFeeRate = function (fId) {
  1114. let feeRateItemObj = optimizeObj["fee_rates_" + fId];
  1115. if (!feeRateItemObj) {
  1116. let rates = (dtObj.data._doc)?dtObj.data._doc.rates:dtObj.data.rates;
  1117. for (let feeItem of rates) {
  1118. if (fId === feeItem.ID) {
  1119. optimizeObj["fee_rates_" + fId] = feeItem;
  1120. feeRateItemObj = feeItem;
  1121. break;
  1122. }
  1123. }
  1124. }
  1125. if (feeRateItemObj) {
  1126. rst.push(feeRateItemObj.rate);
  1127. } else {
  1128. rst.push(0);
  1129. }
  1130. };
  1131. if (fee_Ids instanceof Array) {
  1132. for (let fId of fee_Ids) {
  1133. private_getFeeRate(fId);
  1134. }
  1135. } else {
  1136. private_getFeeRate(fee_Ids);
  1137. }
  1138. optimizeObj = null;
  1139. return rst;
  1140. }
  1141. function ext_getArrayValues(itemKey) {
  1142. let rst = [], parentObj = this;
  1143. let dtObj = parentObj["myOwnRawDataObj"];
  1144. let keysArr = itemKey.split(".");
  1145. for (let dataItem of dtObj.data) {
  1146. let itemArr = [];
  1147. if (keysArr.length <= 2) {
  1148. if (dataItem[keysArr[0]] instanceof Array) {
  1149. if (keysArr.length === 2) {
  1150. for (let item of dataItem[keysArr[0]]) {
  1151. itemArr.push(item[keysArr[1]]);
  1152. }
  1153. } else {
  1154. itemArr = itemArr.concat(dataItem[keysArr[0]]);
  1155. }
  1156. } else {
  1157. if (keysArr.length === 2) {
  1158. let subProperty = dataItem[keysArr[0]][keysArr[1]];
  1159. if (subProperty instanceof Array) {
  1160. itemArr = itemArr.concat(subProperty);
  1161. } else {
  1162. itemArr.push(subProperty);
  1163. }
  1164. } else {
  1165. itemArr.push(dataItem[keysArr[0]]);
  1166. }
  1167. }
  1168. }
  1169. rst.push(itemArr);
  1170. }
  1171. return rst;
  1172. }
  1173. function ext_getArrayItemByKey(arrayKey, itemKey, itemKeyValue, itemRstKey){
  1174. let rst = [], parentObj = this;
  1175. let dtObj = parentObj["myOwnRawDataObj"];
  1176. let private_getItemValue = function (arr, dtlItKV) {
  1177. for (let item of arr) {
  1178. if (item[itemKey] === dtlItKV) {
  1179. if (itemRstKey) {
  1180. rst.push(item[itemRstKey]);
  1181. } else {
  1182. rst.push(item);
  1183. }
  1184. break;
  1185. }
  1186. }
  1187. };
  1188. let arr = dtObj[arrayKey];
  1189. if (arr && arr instanceof Array) {
  1190. if (itemKeyValue instanceof Array) {
  1191. for (let dtlItemKeyVal of itemKeyValue) {
  1192. private_getItemValue(arr, dtlItemKeyVal);
  1193. }
  1194. } else {
  1195. private_getItemValue(arr, itemKeyValue);
  1196. }
  1197. }
  1198. }
  1199. function ext_getBlank(dftVal) {
  1200. let rst = [], parentObj = this;
  1201. let dtObj = parentObj["myOwnRawDataObj"];
  1202. if (dtObj) {
  1203. for (let i = 0; i < dtObj.data.length; i++) {
  1204. if (dftVal !== null && dftVal !== undefined) {
  1205. rst.push(dftVal)
  1206. } else rst.push('');
  1207. }
  1208. }
  1209. return rst;
  1210. }
  1211. function ext_getPropertyByFlag(flagVal, rstKey, dftValIfEmpty) {
  1212. let rst = [], parentObj = this;
  1213. let dtObj = parentObj["myOwnRawDataObj"];
  1214. if (flagVal && rstKey && dtObj) {
  1215. let isArr = (flagVal instanceof Array);
  1216. for (let dItem of dtObj.data) {
  1217. let doc = (dItem._doc)?dItem._doc:dItem;
  1218. if (doc.hasOwnProperty("flags")) {
  1219. let bFlag = false;
  1220. for (let flagItem of doc.flags) {
  1221. if (isArr) {
  1222. bFlag = (flagVal.indexOf(flagItem.flag) >= 0);
  1223. } else {
  1224. if (flagItem.flag === flagVal) {
  1225. bFlag = true;
  1226. }
  1227. }
  1228. if (bFlag) break;
  1229. }
  1230. if (bFlag) {
  1231. let keys = rstKey.split(".");
  1232. if (keys[0] === "fees") {
  1233. rst.push(pri_getFee(doc, "common", keys[1]));
  1234. } else {
  1235. //其他,比如名称什么
  1236. }
  1237. break;
  1238. }
  1239. }
  1240. }
  1241. }
  1242. if (rst.length === 0 && dftValIfEmpty !== null) {
  1243. rst.push(dftValIfEmpty);
  1244. }
  1245. return rst;
  1246. }
  1247. function ext_getPropertyByForeignId(foreignIdVal, adHocIdKey, propKey, dftValIfNotFound) {
  1248. let rst = [], parentObj = this;
  1249. let IdKey = (adHocIdKey)?adHocIdKey:"ID";
  1250. let dtObj = parentObj["myOwnRawDataObj"];
  1251. let splitPKey = propKey.split(".");
  1252. if (foreignIdVal !== null && foreignIdVal !== undefined) {
  1253. let isFound = false;
  1254. if (foreignIdVal instanceof Array) {
  1255. for (let idVal of foreignIdVal) {
  1256. isFound = false;
  1257. let dataArr = dtObj.data;
  1258. if (dtObj.moduleName === "projectGLJ") dataArr = dtObj.data.gljList;
  1259. for (let i = 0; i < dataArr.length; i++) {
  1260. let item = (dataArr[i]._doc)?dataArr[i]._doc:dataArr[i];
  1261. if (item[IdKey] === idVal) {
  1262. if (splitPKey.length > 1) {
  1263. let rstP = null;
  1264. for (let i = 0; i < splitPKey.length; i++) {
  1265. if (i === 0) {
  1266. rstP = item[splitPKey[i]];
  1267. } else {
  1268. if (splitPKey[i].indexOf("[") === 0 && splitPKey[i].indexOf("]") === (splitPKey[i].length - 1)) {
  1269. //考虑数组情况^_^!!!
  1270. } else {
  1271. //
  1272. }
  1273. rstP = rstP[splitPKey[i]];
  1274. }
  1275. }
  1276. rst.push(rstP);
  1277. } else {
  1278. rst.push(item[propKey]);
  1279. }
  1280. isFound = true;
  1281. break;
  1282. }
  1283. }
  1284. if (!isFound) {
  1285. rst.push(dftValIfNotFound);
  1286. }
  1287. }
  1288. } else {
  1289. for (let item of dtObj.data) {
  1290. if (item[IdKey] === foreignIdVal) {
  1291. rst.push(item[propKey]);
  1292. isFound = true;
  1293. break;
  1294. }
  1295. }
  1296. if (!isFound) {
  1297. rst.push(dftValIfNotFound);
  1298. }
  1299. }
  1300. }
  1301. return rst;
  1302. }
  1303. export default Rpt_Data_Extractor;