rpt_construct_data_util.js 49 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306
  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_get_grp_key = function (item) {
  291. let keys = [];
  292. for (let cfg of handleCfg[JV.PROP_SUM_GROUP_KEYS]) {
  293. if (typeof cfg === "string") {
  294. keys.push(item[cfg]);
  295. } else {
  296. if (!curParentPrjData[cfg["seeking_parent"]]) curParentPrjData[cfg["seeking_parent"]] = getModuleDataByKey(prjData, cfg["seeking_parent"]);
  297. for (let pDataItem of curParentPrjData[cfg["seeking_parent"]].data) {
  298. let data = (pDataItem._doc)?pDataItem._doc:pDataItem;
  299. if (item[cfg["seeking_key"]] === data[cfg["parent_key"]]) {
  300. keys.push(data[cfg["parent_grp_key"]]);
  301. break;
  302. }
  303. }
  304. }
  305. }
  306. return ( "grp_key_" + keys.join('_'));
  307. };
  308. let sumObj = {};
  309. for (let dtl of tempRstArr) {
  310. let grpKey = private_get_grp_key(dtl);
  311. if (sumObj[grpKey] === null || sumObj[grpKey] === undefined) {
  312. sumObj[grpKey] = dtl;
  313. rstArr.push(dtl);
  314. } else {
  315. for (let sumKey of handleCfg[JV.PROP_SUM_SUM_KEYS]) {
  316. if (dtl[sumKey]) {
  317. // sumObj[grpKey][sumKey] += dtl[sumKey];
  318. sumObj[grpKey][sumKey] = parseFloat(sumObj[grpKey][sumKey]) + parseFloat(dtl[sumKey]);
  319. }
  320. }
  321. }
  322. }
  323. delete sourceData.data;
  324. sourceData.data = rstArr;
  325. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/sumRst.jsp");
  326. }
  327. function filterData(sourceData, handleCfg, prjData) {
  328. let rstArr = [], tempRstArr = [];
  329. for (let item of sourceData.data) {
  330. if (item._doc) {
  331. tempRstArr.push(item._doc);
  332. } else {
  333. tempRstArr.push(item);
  334. }
  335. }
  336. let private_chkVal = function (src, compVal, compStr) {
  337. let rst = true;
  338. switch (compStr) {
  339. case "==" :
  340. rst = (src == compVal);
  341. break;
  342. case "===" :
  343. rst = (src === compVal);
  344. break;
  345. case ">" :
  346. rst = (src > compVal);
  347. break;
  348. case ">=" :
  349. rst = (src >= compVal);
  350. break;
  351. case "<" :
  352. rst = (src < compVal);
  353. break;
  354. case "<=" :
  355. rst = (src <= compVal);
  356. break;
  357. case "!=" :
  358. rst = (src != compVal);
  359. break;
  360. case "!==" :
  361. rst = (src !== compVal);
  362. break;
  363. case "in" :
  364. if (compVal instanceof Array) {
  365. rst = compVal.indexOf(src) >= 0;
  366. } else {
  367. //string,需要转类型
  368. let newCv = JSON.parse(compVal);
  369. if (newCv instanceof Array) {
  370. rst = newCv.indexOf(src) >= 0;
  371. } else {
  372. rst = false;
  373. }
  374. }
  375. break;
  376. case "not in":
  377. if (compVal instanceof Array) {
  378. rst = compVal.indexOf(src) < 0;
  379. } else {
  380. //string,需要转类型
  381. let newCv = JSON.parse(compVal);
  382. if (newCv instanceof Array) {
  383. rst = newCv.indexOf(src) < 0;
  384. } else {
  385. rst = true;
  386. }
  387. }
  388. break;
  389. default:
  390. rst = true;
  391. }
  392. return rst;
  393. };
  394. let private_chkArrVal = function(arr, key, compVal, compStr){
  395. let rst = false;
  396. for (let arrItem of arr) {
  397. if (arrItem[key]) {
  398. rst = private_chkVal(arrItem[key], compVal, compStr);
  399. }
  400. if (rst) {
  401. break;
  402. }
  403. }
  404. return rst;
  405. };
  406. let private_filter_compare = function (item, filterCfg) {
  407. let compareObj = {};
  408. let compRst = true;
  409. let curComparePrjData = null;
  410. let startIdx = 0;
  411. for (let cfg of filterCfg[JV.PROP_FILTER_KEYS]) {
  412. if (cfg[JV.PROP_FILTER_COMPARE_VAL]) {
  413. //比较key值
  414. let keys = cfg.key.split(".");
  415. if (keys.length > 1) {
  416. let lastObj = item;
  417. for (let i = 0; i < keys.length - 1; i++) {
  418. lastObj = item[keys[i]];
  419. if (!(lastObj)) {
  420. compRst = false;
  421. break;
  422. }
  423. }
  424. if (lastObj) {
  425. if (lastObj instanceof Array) {
  426. compRst = private_chkArrVal(lastObj, keys[keys.length - 1], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  427. } else {
  428. compRst = private_chkVal(lastObj[keys[keys.length - 1]], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  429. }
  430. }
  431. } else {
  432. compRst = private_chkVal(item[cfg.key], cfg[JV.PROP_FILTER_COMPARE_VAL], cfg[JV.PROP_FILTER_CONDITION]);
  433. }
  434. } else if (cfg[JV.PROP_FILTER_COMPARE_OBJ] && cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]){
  435. //通过其他对象来过滤
  436. if (!curComparePrjData) {
  437. curComparePrjData = getModuleDataByKey(prjData, cfg[JV.PROP_FILTER_COMPARE_OBJ]);
  438. }
  439. if (cfg[JV.PROP_FILTER_CONDITION] === "in" || cfg[JV.PROP_FILTER_CONDITION] === "not in") {
  440. let compareArr = null;
  441. if (!compareObj.hasOwnProperty(cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString())) {
  442. compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()] = [];
  443. compareArr = compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()];
  444. for (let data of curComparePrjData.data) {
  445. if (compareArr.indexOf(data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]]) < 0) {
  446. compareArr.push(data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]]);
  447. }
  448. }
  449. } else {
  450. compareArr = compareObj[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY] + startIdx.toString()];
  451. }
  452. compRst = private_chkVal(item[cfg.key], compareArr, cfg[JV.PROP_FILTER_CONDITION]);
  453. } else {
  454. for (let data of curComparePrjData.data) {
  455. compRst = private_chkVal(item[cfg.key], data[cfg[JV.PROP_FILTER_COMPARE_OBJ_KEY]], cfg[JV.PROP_FILTER_CONDITION]);
  456. if (compRst) break;
  457. }
  458. }
  459. }
  460. startIdx++;
  461. }
  462. return compRst;
  463. };
  464. for (let item of tempRstArr) {
  465. if (private_filter_compare(item, handleCfg)) {
  466. rstArr.push(item);
  467. }
  468. }
  469. if (handleCfg[JV.PROP_OTHER_SUB_FILTER] && handleCfg[JV.PROP_OTHER_SUB_FILTER].length > 0) {
  470. let newRstArr = [];
  471. for (let dtlItem of rstArr) {
  472. let cmpRst = false;
  473. for (let dtlCfg of handleCfg[JV.PROP_OTHER_SUB_FILTER]) {
  474. cmpRst = private_filter_compare(dtlItem, dtlCfg);
  475. if (cmpRst) {
  476. newRstArr.push(dtlItem);
  477. break;
  478. }
  479. }
  480. }
  481. rstArr = newRstArr;
  482. }
  483. delete sourceData.data;
  484. sourceData.data = rstArr;
  485. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/filteredRst.js");
  486. }
  487. function adjustData(sourceData, adjustCfg) {
  488. let rstArr = [];
  489. for (let item of sourceData.data) {
  490. if (item._doc) {
  491. rstArr.push(item._doc);
  492. } else {
  493. rstArr.push(item);
  494. }
  495. }
  496. for (let item of adjustCfg[JV.PROP_ADJUST_COLLECTION]) {
  497. for (let rec of rstArr) {
  498. if (item[JV.PROP_ADJUST_ACTION] === "prefix") {
  499. rec[item.key] = item[JV.PROP_ADJUST_ACTION_VAL] + rec[item.key];
  500. } else if (item[JV.PROP_ADJUST_ACTION] === "suffix") {
  501. rec[item.key] = rec[item.key] + item[JV.PROP_ADJUST_ACTION_VAL];
  502. }
  503. }
  504. }
  505. delete sourceData.data;
  506. sourceData.data = rstArr;
  507. }
  508. function moveRationData(rationData, rawDataObj) {
  509. if (rawDataObj) {
  510. // let rationData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION);
  511. let rationGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.RATION_GLJ);
  512. let prjGljData = getModuleDataByKey(rawDataObj.prjData, projectConst.PROJECTGLJ);
  513. let dummyCode = " ", dummyPRJID = 10101010;
  514. for (let rationItem of rationData.data) {
  515. if (rationItem.type === 2 || rationItem.type === 3) {
  516. //2: 量材(人工/材料/机械/主材/设备) 3:材料(材料/主材/设备)
  517. let copyItem = {};
  518. copyItem.ID = rationItem.ID;
  519. copyItem.projectID = rationItem.projectID;
  520. copyItem.GLJID = rationItem.GLJID;
  521. copyItem.rationID = rationItem.ID;
  522. copyItem.rationItemQuantity = 1;
  523. copyItem.quantity = 1;
  524. // copyItem.specialType_quantity = rationItem.quantity;
  525. copyItem.name = rationItem.name;
  526. if (rationItem.code) {
  527. copyItem.code = rationItem.ID + "_" + rationItem.code;
  528. } else {
  529. copyItem.code = dummyCode;
  530. dummyCode = dummyCode + " ";
  531. }
  532. copyItem.original_code = rationItem.original_code;
  533. copyItem.unit = rationItem.unit;
  534. copyItem.specs = rationItem.specs;
  535. copyItem.shortName = rationItem.shortName;
  536. copyItem.billsItemID = rationItem.billsItemID;
  537. copyItem.type = rationItem.subType;
  538. if (rationItem.projectGLJID) {
  539. copyItem.projectGLJID = rationItem.projectGLJID;
  540. } else {
  541. //add dummy project GLJ
  542. let dummyPrjItem = {};
  543. copyItem.projectGLJID = dummyPRJID;
  544. dummyPrjItem.id = dummyPRJID;
  545. dummyPRJID++;
  546. dummyPrjItem.unit_price = {};
  547. dummyPrjItem.unit_price.base_price = 0;
  548. dummyPrjItem.unit_price.market_price = (rationItem["marketUnitFee"])?rationItem["marketUnitFee"]:0;
  549. dummyPrjItem.quantity = 0;
  550. dummyPrjItem.is_evaluate = 0;
  551. prjGljData.data.gljList.push(dummyPrjItem);
  552. }
  553. rationGljData.data.push(copyItem);
  554. }
  555. }
  556. // fsUtil.writeObjToFile(rationGljData.data, "D:/GitHome/ConstructionCost/tmp/afterMoveGLJ.jsp");
  557. }
  558. }
  559. function getDupGrpKeyVals(sourceData, segKeys) {
  560. let rst = [];
  561. function pushKeyVal(item) {
  562. let tr = {};
  563. for (let i = 0; i < segKeys.length; i++) {
  564. tr[segKeys[i]] = item[segKeys[i]];
  565. }
  566. rst.push(tr);
  567. }
  568. for (let idx = 0; idx < sourceData.length; idx++) {
  569. let itemRec = sourceData[idx];
  570. if (idx === 0) {
  571. pushKeyVal(itemRec);
  572. continue;
  573. }
  574. let hasDiff = false;
  575. for (let i = 0; i < segKeys.length; i++) {
  576. if (itemRec[segKeys[i]] !== sourceData[idx - 1][segKeys[i]]) {
  577. hasDiff = true;
  578. break;
  579. }
  580. }
  581. if (hasDiff) {
  582. pushKeyVal(itemRec);
  583. }
  584. }
  585. return rst;
  586. }
  587. function addDummyData(sourceData, addCfg) {
  588. let rstArr = [], tempRstArr = [];
  589. for (let item of sourceData.data) {
  590. if (item._doc) {
  591. tempRstArr.push(item._doc);
  592. } else {
  593. tempRstArr.push(item);
  594. }
  595. }
  596. for (let item of addCfg[JV.PROP_DUMMY_COLLECTION]) {
  597. let newRecStr = JSON.stringify(item[JV.PROP_DUMMY_VAL]), cacheGrpKeyRecs = null;
  598. if (item[JV.PROP_FREQUENCY] === "OncePerGrp") {
  599. if (!cacheGrpKeyRecs) {
  600. cacheGrpKeyRecs = {};
  601. }
  602. let cacheKey = "";
  603. for (let key of item[JV.PROP_GRP_KEYS]) {
  604. cacheKey += "_" + key;
  605. }
  606. if (!cacheGrpKeyRecs[cacheKey]) {
  607. cacheGrpKeyRecs[cacheKey] = getDupGrpKeyVals(tempRstArr, item[JV.PROP_GRP_KEYS]);
  608. }
  609. for (let kv of cacheGrpKeyRecs[cacheKey]) {
  610. let rec = JSON.parse(newRecStr);
  611. for (let key of item[JV.PROP_GRP_KEYS]) {
  612. rec[key] = kv[key];
  613. }
  614. rstArr.push(rec);
  615. }
  616. } else if (item[JV.PROP_FREQUENCY] === "Once") {
  617. rstArr.push(JSON.parse(newRecStr));
  618. }
  619. }
  620. rstArr = rstArr.concat(tempRstArr);
  621. delete sourceData.data;
  622. sourceData.data = rstArr;
  623. }
  624. function getGLJBizType(orgType, orgCode, orgName) {
  625. let rst = orgType;
  626. if (orgName.indexOf("其他材料费") >= 0) {
  627. rst = 299;
  628. } else if (orgType === GLJ_TYPE.Labour) {
  629. rst = 11;
  630. if (orgCode === "000000") rst = 10;
  631. } else if (orgType === GLJ_TYPE.Main_Material || orgType === GLJ_TYPE.Equipment) {
  632. //未计价材料(主材 + 设备)
  633. rst = 30 + orgType;
  634. } else if (orgType === GLJ_TYPE.Material || (orgType >= 200 && orgType < 300)) {
  635. //材料
  636. if (orgCode === "000000") {
  637. rst = 20; //2.材料
  638. } else if (orgCode === "000000_1") {
  639. rst = 30; //(1) 未计价材料
  640. } else if (orgCode === "000000_2") {
  641. rst = 40; //(2) 辅助材料
  642. } else if (orgCode === "000000_3") {
  643. rst = 50; //(3) 其他材料费
  644. } else {
  645. rst = 45; //到这里就只有辅助材料没有预处理了
  646. }
  647. } else if (orgType === GLJ_TYPE.Machine || (orgType >= 300 && orgType < 400)) {
  648. //机械
  649. if (orgCode === "000000") {
  650. rst = 300; //3.机械
  651. } else if (orgType === GLJ_TYPE.Machine) {
  652. rst = 300.5;
  653. } else {
  654. rst = orgType;
  655. }
  656. }
  657. return rst;
  658. }
  659. function sortData(sourceData, sortCfg, prjData) {
  660. let rst = sourceData.data, tempRstArr = [];
  661. let sortType = sortCfg[JV.PROP_SORT_TYPE];
  662. for (let item of sourceData.data) {
  663. if (item._doc) {
  664. tempRstArr.push(item._doc);
  665. } else {
  666. tempRstArr.push(item);
  667. }
  668. }
  669. function private_normal_sort(destArr, sortKeys) {
  670. destArr.sort(function(a, b){
  671. let compRst = 0;
  672. for (let comp of sortKeys) {
  673. let reverse = (comp.order === 'ascend')?1:(-1);
  674. //
  675. if (a[comp.key] > b[comp.key]) {
  676. compRst = reverse;
  677. break;
  678. } else if (a[comp.key] < b[comp.key]) {
  679. compRst = -reverse;
  680. break;
  681. }
  682. }
  683. return compRst;
  684. });
  685. }
  686. function private_parent_sort(parentArr, parentKeys, childArr, childKeys) {
  687. let tmpRst = {}, rst = [];
  688. for (let pItem of parentArr) {
  689. let pKey = "key";
  690. for (let key of parentKeys) {
  691. pKey += "_" + pItem[key];
  692. }
  693. tmpRst[pKey] = [];
  694. }
  695. for (let cItem of childArr) {
  696. let cKey = "key";
  697. for (let key of childKeys) {
  698. cKey += "_" + cItem[key];
  699. }
  700. if (tmpRst[cKey]) {
  701. tmpRst[cKey].push(cItem);
  702. } else {
  703. //unknown child value! should be filtered!
  704. }
  705. }
  706. // childArr.splice(0);
  707. for (let pItem of parentArr) {
  708. let pKey = "key";
  709. for (let key of parentKeys) {
  710. pKey += "_" + pItem[key];
  711. }
  712. rst.push(tmpRst[pKey]);
  713. // for (let rItem of tmpRst[pKey]) {
  714. // childArr.push(rItem);
  715. // }
  716. }
  717. return rst;
  718. }
  719. switch (sortType) {
  720. case "tree":
  721. let addLevel = true;
  722. rst = treeUtil.buildTreeNodeDirectly(tempRstArr, addLevel);
  723. let newTopArr = [];
  724. if ((sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES] && sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES].length > 0) ||
  725. (sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES] && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].length > 0)) {
  726. let local_check_bills = function(tItem) {
  727. let chkDtl = false;
  728. if (tItem.flags && tItem.flags.length > 0) {
  729. for (let flagItem of tItem.flags) {
  730. if (sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].indexOf(flagItem.flag) >= 0) {
  731. newTopArr.push(tItem);
  732. chkDtl = true;
  733. break;
  734. }
  735. }
  736. }
  737. if (!chkDtl && tItem.items && tItem.items.length > 0) {
  738. for (let dtlItem of tItem.items) {
  739. local_check_bills(dtlItem);
  740. }
  741. }
  742. };
  743. for (let topItem of rst) {
  744. let chkTop = false;
  745. if (topItem.flags && topItem.flags.length > 0) {
  746. for (let flagItem of topItem.flags) {
  747. if (sortCfg[JV.PROP_FILTER_TOP_BILLS_NODES].indexOf(flagItem.flag) >= 0) {
  748. newTopArr.push(topItem);
  749. chkTop = true;
  750. break;
  751. }
  752. }
  753. }
  754. if (!chkTop && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES] && sortCfg[JV.PROP_FILTER_OTHER_BILLS_NODES].length > 0) {
  755. local_check_bills(topItem);
  756. }
  757. }
  758. } else {
  759. newTopArr = rst;
  760. }
  761. let destArr = [];
  762. treeUtil.getFlatArray(newTopArr, destArr);
  763. delete sourceData.data;
  764. sourceData.data = destArr;
  765. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/sortedAndFlattedRst.jsp");
  766. break;
  767. case "normal":
  768. private_normal_sort(tempRstArr, sortCfg[JV.PROP_SORT_KEYS]);
  769. delete sourceData.data;
  770. sourceData.data = tempRstArr;
  771. // fsUtil.writeObjToFile(sourceData.data, "D:/GitHome/ConstructionCost/tmp/normalSortedRst.jsp");
  772. break;
  773. case "accord_to_parent":
  774. let pcKey = sortCfg[JV.PROP_PARENT_CHILD_SORT_KEY];
  775. let parentSrcData = getModuleDataByKey(prjData, pcKey[JV.PROP_PARENT_DATA_KEY]);
  776. if (parentSrcData) {
  777. let tempParentArr = [];
  778. for (let item of parentSrcData.data) {
  779. if (item._doc) {
  780. tempParentArr.push(item._doc);
  781. } else {
  782. tempParentArr.push(item);
  783. }
  784. }
  785. let sortedRstArr = private_parent_sort(tempParentArr, pcKey[JV.PROP_PARENT_SORT_KEYS], tempRstArr, pcKey[JV.PROP_CHILD_SORT_KEYS]);
  786. if (sortCfg[JV.PROP_OTHER_SUB_SORT] && sortCfg[JV.PROP_OTHER_SUB_SORT].length > 0) {
  787. for (let sort of sortCfg[JV.PROP_OTHER_SUB_SORT]) {
  788. if (sort[JV.PROP_SORT_TYPE] === 'normal') {
  789. for (let subArr of sortedRstArr) {
  790. private_normal_sort(subArr, sort[JV.PROP_SORT_KEYS]);
  791. }
  792. } else if (sort[JV.PROP_SORT_TYPE] === 'self_define') {
  793. for (let subArr of sortedRstArr) {
  794. // console.log(subArr);
  795. let selfDefFunc = null;
  796. eval('selfDefFunc = ' + sort[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]);
  797. subArr.sort(selfDefFunc);
  798. // console.log(subArr);
  799. }
  800. }
  801. }
  802. }
  803. tempRstArr.splice(0);
  804. for (let item of sortedRstArr) {
  805. for (let subItem of item) {
  806. tempRstArr.push(subItem);
  807. }
  808. }
  809. }
  810. delete sourceData.data;
  811. sourceData.data = tempRstArr;
  812. break;
  813. case "self_define":
  814. if (sortCfg[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]) {
  815. let selfDefFunc = null;
  816. eval('selfDefFunc = ' + sortCfg[JV.PROP_SORT_TYPE_SELF_DEFINE_LOGIC]);
  817. tempRstArr.sort(selfDefFunc);
  818. }
  819. delete sourceData.data;
  820. sourceData.data = tempRstArr;
  821. break;
  822. default:
  823. //
  824. }
  825. return rst;
  826. }
  827. function setupFunc(obj, prop, ownRawObj) {
  828. obj[prop] = {};
  829. obj[prop]["myOwnRawDataObj"] = ownRawObj;
  830. obj[prop]["myOwnOrgRawDataObj"] = ownRawObj.data;
  831. obj[prop].getProperty = ext_getPropety;
  832. obj[prop].getPropertyByRefId = ext_getPropertyByRefId;
  833. obj[prop].getFee = ext_getFee;
  834. obj[prop].getPropertyByForeignId = ext_getPropertyByForeignId;
  835. obj[prop].getArrayValues = ext_getArrayValues;
  836. obj[prop].getArrayItemByKey = ext_getArrayItemByKey;
  837. obj[prop].getPropertyByFlag = ext_getPropertyByFlag;
  838. obj[prop].getBlank = ext_getBlank;
  839. if (prop === projectConst.CALC_PROGRAM) obj[prop].getCalcProperty = ext_getCalcProperty;
  840. if (prop === projectConst.FEERATE) obj[prop].getFeeRate = ext_getFeeRate;
  841. }
  842. function assembleFields(fieldList, rstDataArr, $PROJECT) {
  843. if (fieldList) {
  844. for (let field of fieldList) {
  845. shielded_exec_env($PROJECT, field, rstDataArr);
  846. }
  847. }
  848. }
  849. function shielded_exec_env($PROJECT, $ME, rptDataItemObj) {
  850. if ($ME[JV.PROP_FIELD_EXP_MAP]) {
  851. rptDataItemObj.push(eval($ME[JV.PROP_FIELD_EXP_MAP]));
  852. }
  853. }
  854. function getActPropertyVal(firstPropKey, secPropKey, orgObj) {
  855. let rst = null;
  856. if (orgObj[firstPropKey]) {
  857. rst = orgObj[firstPropKey];
  858. } else if (orgObj[secPropKey]){
  859. rst = orgObj[secPropKey];
  860. }
  861. return rst;
  862. }
  863. function getDeepProperty(propKey, orgObj, destArr) {
  864. let keys = propKey.split(".");
  865. let dftPropKey = "key", dftPropVal = "value", secDftPropVal = "items";
  866. let parent = orgObj, lastVal = null;
  867. for (let key of keys) {
  868. if (parent instanceof Array) {
  869. for (let item of parent) {
  870. if (item[dftPropKey] === key) {
  871. lastVal = getActPropertyVal(dftPropVal, secDftPropVal, item);
  872. break;
  873. }
  874. }
  875. } else {
  876. lastVal = null;
  877. if (parent[key] !== undefined) {
  878. lastVal = parent[key];
  879. } else if (parent[secDftPropVal]){
  880. for (let item of parent[secDftPropVal]) {
  881. if (item[dftPropKey] === key) {
  882. // lastVal = item[dftPropVal];
  883. lastVal = getActPropertyVal(dftPropVal, secDftPropVal, item);
  884. break;
  885. }
  886. }
  887. }
  888. }
  889. parent = lastVal;
  890. if (parent === null) break;
  891. }
  892. if (destArr && destArr instanceof Array) {
  893. destArr.push(lastVal);
  894. }
  895. }
  896. function ext_mainGetPropety(propKey) {
  897. let rst = [], parentObj = this;
  898. let dtObj = parentObj["myOwnRawDataObj"];
  899. if (propKey && dtObj) {
  900. if (dtObj.hasOwnProperty("property")) {
  901. if (!dtObj["property"][propKey] && dtObj[propKey]) {
  902. rst.push(dtObj[propKey]);
  903. } else {
  904. getDeepProperty(propKey, dtObj["property"], rst);
  905. }
  906. } else {
  907. // rst.push(dtObj[propKey]);
  908. getDeepProperty(propKey, dtObj, rst);
  909. }
  910. }
  911. return rst;
  912. }
  913. function ext_getPropety(propKey) {
  914. let rst = [], parentObj = this;
  915. let dtObj = parentObj["myOwnRawDataObj"];
  916. if (propKey && dtObj) {
  917. for (let dItem of dtObj.data) {
  918. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  919. if (propKey instanceof Array) {
  920. for (let pi = 0; pi < propKey.length; pi++) {
  921. if (doc.hasOwnProperty("property")) {
  922. if (doc["property"].hasOwnProperty(propKey[pi])) {
  923. rst.push(doc["property"][propKey[pi]]);
  924. break;
  925. }
  926. } else if (doc.hasOwnProperty(propKey[pi])) {
  927. rst.push(doc[propKey[pi]]);
  928. break;
  929. }
  930. if (pi === propKey.length - 1) rst.push('');
  931. }
  932. } else {
  933. if (doc.hasOwnProperty("property")) {
  934. rst.push(doc["property"][propKey]);
  935. } else if (doc.hasOwnProperty(propKey)) {
  936. rst.push(doc[propKey]);
  937. } else {
  938. rst.push('');
  939. }
  940. }
  941. }
  942. }
  943. return rst;
  944. }
  945. function ext_getPropertyByRefId(baseKey, refIDKey, propertyKey){
  946. let rst = [], parentObj = this;
  947. let dtObj = parentObj["myOwnRawDataObj"];
  948. let orgDtObj = parentObj["myOwnOrgRawDataObj"];
  949. if (baseKey && refIDKey && propertyKey && dtObj) {
  950. for (let dItem of dtObj.data) {
  951. let doc = (dItem._doc === null || dItem._doc === undefined)?dItem:dItem._doc;
  952. let tmpRst = doc[baseKey];
  953. if (typeof tmpRst === "string" && tmpRst[0] === "@") {
  954. let refKey = tmpRst.slice(1);
  955. let hasGetRef = false;
  956. for (let orgDItem of orgDtObj) {
  957. let oDoc = (orgDItem._doc === null || orgDItem._doc === undefined)?orgDItem:orgDItem._doc;
  958. if (oDoc[refIDKey] === refKey) {
  959. rst.push(oDoc[propertyKey]);
  960. hasGetRef = true;
  961. break;
  962. }
  963. }
  964. if (!hasGetRef) {
  965. rst.push(tmpRst);
  966. }
  967. } else {
  968. rst.push(tmpRst);
  969. }
  970. }
  971. }
  972. return rst;
  973. }
  974. function ext_mainGetFee(feeKey, dtlFeeKey) {
  975. let rst = [];
  976. let parentObj = this;
  977. let dtObj = parentObj["myOwnRawDataObj"];
  978. if ((dtObj) && (feeKey)) {
  979. if (dtObj.hasOwnProperty("fees")) {
  980. for (let fee of dtObj["fees"]) {
  981. if (fee["fieldName"] === feeKey) {
  982. if (dtlFeeKey) {
  983. rst.push(fee[dtlFeeKey]);
  984. } else {
  985. rst.push(fee["unitFee"]);
  986. }
  987. break;
  988. }
  989. }
  990. } else if (dtObj.hasOwnProperty(feeKey)) {
  991. rst.push(dtObj[feeKey]);
  992. } else {
  993. //
  994. }
  995. }
  996. return rst;
  997. }
  998. function ext_getFee(feeKey, dtlFeeKey) {
  999. let rst = [], parentObj = this;
  1000. let dtObj = parentObj["myOwnRawDataObj"];
  1001. if (feeKey && dtObj) {
  1002. for (let dItem of dtObj.data) {
  1003. rst.push(pri_getFee(dItem, feeKey, dtlFeeKey));
  1004. }
  1005. }
  1006. for (let i = 0; i < rst.length; i++) {
  1007. rst[i] = parseFloat(rst[i]);
  1008. }
  1009. return rst;
  1010. }
  1011. function pri_getFee(dItem, feeKey, dtlFeeKey) {
  1012. let rst = 0;
  1013. let hasValue = false;
  1014. if (dItem["fees"]) {
  1015. for (let fee of dItem["fees"]) {
  1016. if (fee["fieldName"] === feeKey) {
  1017. if (dtlFeeKey) {
  1018. rst = fee[dtlFeeKey];
  1019. } else {
  1020. rst = fee["unitFee"];
  1021. }
  1022. hasValue = true;
  1023. break;
  1024. }
  1025. }
  1026. } else if (dItem[feeKey]) {
  1027. hasValue = true;
  1028. rst = dItem[feeKey];
  1029. } else {
  1030. hasValue = true;
  1031. rst = 0;
  1032. }
  1033. if (!hasValue) {
  1034. rst = 0;
  1035. }
  1036. return rst;
  1037. }
  1038. function ext_getCalcProperty(templateIDs, calcItemKey, calcItemKeyVal, calcItemRstKey){
  1039. let rst = [], parentObj = this; //this should be "calc_program" object
  1040. let dtObj = parentObj["myOwnRawDataObj"];
  1041. let optimizeObj = {};
  1042. let private_getProperty = function (cId) {
  1043. let calcTplObj = optimizeObj["calc_program_" + cId];
  1044. if (!calcTplObj) {
  1045. let templates = (dtObj.data._doc)?dtObj.data._doc.templates:dtObj.data.templates;
  1046. for (let tpl of templates) {
  1047. if (cId === tpl.ID) {
  1048. optimizeObj["calc_program_" + cId] = tpl;
  1049. calcTplObj = tpl;
  1050. break;
  1051. }
  1052. }
  1053. }
  1054. if (calcTplObj) {
  1055. for (let calcItem of calcTplObj.calcItems) {
  1056. if (calcItem[calcItemKey] === calcItemKeyVal) {
  1057. rst.push(calcItem[calcItemRstKey]);
  1058. break;
  1059. }
  1060. }
  1061. }
  1062. };
  1063. if (templateIDs instanceof Array) {
  1064. for (let tplId of templateIDs) {
  1065. private_getProperty(tplId);
  1066. }
  1067. } else {
  1068. private_getProperty(templateIDs);
  1069. }
  1070. optimizeObj = null;
  1071. return rst;
  1072. }
  1073. function ext_getFeeRate(fee_Ids){
  1074. let rst = [], parentObj = this; //this should be "feeRate" object
  1075. let dtObj = parentObj["myOwnRawDataObj"];
  1076. let optimizeObj = {};
  1077. let private_getFeeRate = function (fId) {
  1078. let feeRateItemObj = optimizeObj["fee_rates_" + fId];
  1079. if (!feeRateItemObj) {
  1080. let rates = (dtObj.data._doc)?dtObj.data._doc.rates:dtObj.data.rates;
  1081. for (let feeItem of rates) {
  1082. if (fId === feeItem.ID) {
  1083. optimizeObj["fee_rates_" + fId] = feeItem;
  1084. feeRateItemObj = feeItem;
  1085. break;
  1086. }
  1087. }
  1088. }
  1089. if (feeRateItemObj) {
  1090. rst.push(feeRateItemObj.rate);
  1091. } else {
  1092. rst.push(0);
  1093. }
  1094. };
  1095. if (fee_Ids instanceof Array) {
  1096. for (let fId of fee_Ids) {
  1097. private_getFeeRate(fId);
  1098. }
  1099. } else {
  1100. private_getFeeRate(fee_Ids);
  1101. }
  1102. optimizeObj = null;
  1103. return rst;
  1104. }
  1105. function ext_getArrayValues(itemKey) {
  1106. let rst = [], parentObj = this;
  1107. let dtObj = parentObj["myOwnRawDataObj"];
  1108. let keysArr = itemKey.split(".");
  1109. for (let dataItem of dtObj.data) {
  1110. let itemArr = [];
  1111. if (keysArr.length <= 2) {
  1112. if (dataItem[keysArr[0]] instanceof Array) {
  1113. if (keysArr.length === 2) {
  1114. for (let item of dataItem[keysArr[0]]) {
  1115. itemArr.push(item[keysArr[1]]);
  1116. }
  1117. } else {
  1118. itemArr = itemArr.concat(dataItem[keysArr[0]]);
  1119. }
  1120. } else {
  1121. if (keysArr.length === 2) {
  1122. let subProperty = dataItem[keysArr[0]][keysArr[1]];
  1123. if (subProperty instanceof Array) {
  1124. itemArr = itemArr.concat(subProperty);
  1125. } else {
  1126. itemArr.push(subProperty);
  1127. }
  1128. } else {
  1129. itemArr.push(dataItem[keysArr[0]]);
  1130. }
  1131. }
  1132. }
  1133. rst.push(itemArr);
  1134. }
  1135. return rst;
  1136. }
  1137. function ext_getArrayItemByKey(arrayKey, itemKey, itemKeyValue, itemRstKey){
  1138. let rst = [], parentObj = this;
  1139. let dtObj = parentObj["myOwnRawDataObj"];
  1140. let private_getItemValue = function (arr, dtlItKV) {
  1141. for (let item of arr) {
  1142. if (item[itemKey] === dtlItKV) {
  1143. if (itemRstKey) {
  1144. rst.push(item[itemRstKey]);
  1145. } else {
  1146. rst.push(item);
  1147. }
  1148. break;
  1149. }
  1150. }
  1151. };
  1152. let arr = dtObj[arrayKey];
  1153. if (arr && arr instanceof Array) {
  1154. if (itemKeyValue instanceof Array) {
  1155. for (let dtlItemKeyVal of itemKeyValue) {
  1156. private_getItemValue(arr, dtlItemKeyVal);
  1157. }
  1158. } else {
  1159. private_getItemValue(arr, itemKeyValue);
  1160. }
  1161. }
  1162. }
  1163. function ext_getBlank(dftVal) {
  1164. let rst = [], parentObj = this;
  1165. let dtObj = parentObj["myOwnRawDataObj"];
  1166. if (dtObj) {
  1167. for (let i = 0; i < dtObj.data.length; i++) {
  1168. if (dftVal !== null && dftVal !== undefined) {
  1169. rst.push(dftVal)
  1170. } else rst.push('');
  1171. }
  1172. }
  1173. return rst;
  1174. }
  1175. function ext_getPropertyByFlag(flagVal, rstKey, dftValIfEmpty) {
  1176. let rst = [], parentObj = this;
  1177. let dtObj = parentObj["myOwnRawDataObj"];
  1178. if (flagVal && rstKey && dtObj) {
  1179. let isArr = (flagVal instanceof Array);
  1180. for (let dItem of dtObj.data) {
  1181. let doc = (dItem._doc)?dItem._doc:dItem;
  1182. if (doc.hasOwnProperty("flags")) {
  1183. let bFlag = false;
  1184. for (let flagItem of doc.flags) {
  1185. if (isArr) {
  1186. bFlag = (flagVal.indexOf(flagItem.flag) >= 0);
  1187. } else {
  1188. if (flagItem.flag === flagVal) {
  1189. bFlag = true;
  1190. }
  1191. }
  1192. if (bFlag) break;
  1193. }
  1194. if (bFlag) {
  1195. let keys = rstKey.split(".");
  1196. if (keys[0] === "fees") {
  1197. rst.push(pri_getFee(doc, "common", keys[1]));
  1198. } else {
  1199. //其他,比如名称什么
  1200. }
  1201. break;
  1202. }
  1203. }
  1204. }
  1205. }
  1206. if (rst.length === 0 && dftValIfEmpty !== null) {
  1207. rst.push(dftValIfEmpty);
  1208. }
  1209. return rst;
  1210. }
  1211. function ext_getPropertyByForeignId(foreignIdVal, adHocIdKey, propKey, dftValIfNotFound) {
  1212. let rst = [], parentObj = this;
  1213. let IdKey = (adHocIdKey)?adHocIdKey:"ID";
  1214. let dtObj = parentObj["myOwnRawDataObj"];
  1215. let splitPKey = propKey.split(".");
  1216. if (foreignIdVal !== null && foreignIdVal !== undefined) {
  1217. let isFound = false;
  1218. if (foreignIdVal instanceof Array) {
  1219. for (let idVal of foreignIdVal) {
  1220. isFound = false;
  1221. let dataArr = dtObj.data;
  1222. if (dtObj.moduleName === "projectGLJ") dataArr = dtObj.data.gljList;
  1223. for (let i = 0; i < dataArr.length; i++) {
  1224. let item = (dataArr[i]._doc)?dataArr[i]._doc:dataArr[i];
  1225. if (item[IdKey] === idVal) {
  1226. if (splitPKey.length > 1) {
  1227. let rstP = null;
  1228. for (let i = 0; i < splitPKey.length; i++) {
  1229. if (i === 0) {
  1230. rstP = item[splitPKey[i]];
  1231. } else {
  1232. if (splitPKey[i].indexOf("[") === 0 && splitPKey[i].indexOf("]") === (splitPKey[i].length - 1)) {
  1233. //考虑数组情况^_^!!!
  1234. } else {
  1235. //
  1236. }
  1237. rstP = rstP[splitPKey[i]];
  1238. }
  1239. }
  1240. rst.push(rstP);
  1241. } else {
  1242. rst.push(item[propKey]);
  1243. }
  1244. isFound = true;
  1245. break;
  1246. }
  1247. }
  1248. if (!isFound) {
  1249. rst.push(dftValIfNotFound);
  1250. }
  1251. }
  1252. } else {
  1253. for (let item of dtObj.data) {
  1254. if (item[IdKey] === foreignIdVal) {
  1255. rst.push(item[propKey]);
  1256. isFound = true;
  1257. break;
  1258. }
  1259. }
  1260. if (!isFound) {
  1261. rst.push(dftValIfNotFound);
  1262. }
  1263. }
  1264. }
  1265. return rst;
  1266. }
  1267. export default Rpt_Data_Extractor;