rpt_construct_data_util.js 51 KB

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