jpc_flow_tab.js 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680
  1. let JV = require('./jpc_value_define');
  2. let JE = require('./jpc_rte');
  3. let JpcFieldHelper = require('./helper/jpc_helper_field');
  4. let JpcBandHelper = require('./helper/jpc_helper_band');
  5. let JpcBand = require('./jpc_band');
  6. let JpcFlowTabHelper = require('./helper/jpc_helper_flow_tab');
  7. let JpcCommonHelper = require('./helper/jpc_helper_common');
  8. let JpcDiscreteHelper = require('./helper/jpc_helper_discrete');
  9. let JpcTextHelper = require('./helper/jpc_helper_text');
  10. let JpcCommonOutputHelper = require('./helper/jpc_helper_common_output');
  11. let JpcAreaHelper = require('./helper/jpc_helper_area');
  12. let PDFKit = require('pdfkit');
  13. let JpcFlowTabSrv = function(){};
  14. //let grpPageInfo = {"segGrpRecStartIdx": 0, "insertedGrpRecAmt": 0, "preAddPageGrpInfo": null};
  15. JpcFlowTabSrv.prototype.createNew = function(){
  16. function private_addPageValue(ValuedIdxLst, sortedSequence, grpSequenceInfo, startRecIdx, maxRecPerPage,page_seg_map, segIdx, pageIdx, grpPageInfo, isFollow) {
  17. let vIdx = [], preAmt = 0, insertedGrpAmt = 0, grp_lines = 0;
  18. if (grpSequenceInfo && grpPageInfo) {
  19. //grpPageInfo[JV.PROP_INSERTED_GRP_REC] = 0;
  20. if (grpPageInfo[JV.PROP_PRE_ADD_GRP_REC_INFO].length > 0) {
  21. for (let grpLineIdx of grpPageInfo[JV.PROP_PRE_ADD_GRP_REC_INFO]) {
  22. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_GROUP, grpPageInfo[JV.PROP_SEG_GRP_IDX], grpLineIdx]);
  23. }
  24. grpPageInfo[JV.PROP_SEG_GRP_IDX]++;
  25. }
  26. preAmt = grpPageInfo[JV.PROP_PRE_ADD_GRP_REC_INFO].length;
  27. grpPageInfo[JV.PROP_PRE_ADD_GRP_REC_INFO] = [];
  28. grp_lines = grpPageInfo[JV.PROP_GRP_LINES];
  29. }
  30. for (let vi = 0; (vi + insertedGrpAmt * grp_lines) < maxRecPerPage - preAmt; vi++) {
  31. if (grpSequenceInfo && grpPageInfo) {
  32. if ((startRecIdx + vi) === grpSequenceInfo[grpPageInfo[JV.PROP_SEG_GRP_IDX]]) {
  33. //表示这里要插入grouping信息啦!
  34. //1. 首先push正常的记录
  35. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_NORMAL, sortedSequence[startRecIdx + vi]]);
  36. //2. 然后就要push grouping记录了
  37. let hasFullGrp = true;
  38. for (let i = 0; i < grp_lines; i++) {
  39. if ( ((vi + insertedGrpAmt * grp_lines) + i + 1) >= (maxRecPerPage - preAmt)) {
  40. for (let j = i; j < grp_lines; j++) {
  41. grpPageInfo[JV.PROP_PRE_ADD_GRP_REC_INFO].push(j);
  42. }
  43. //准备要跳出去了
  44. hasFullGrp = false;
  45. break;
  46. } else {
  47. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_GROUP, grpPageInfo[JV.PROP_SEG_GRP_IDX], i]);
  48. }
  49. }
  50. //3. 进位下一个group信息所在位置
  51. if (hasFullGrp) {
  52. grpPageInfo[JV.PROP_INSERTED_GRP_REC]++;
  53. insertedGrpAmt++;
  54. grpPageInfo[JV.PROP_SEG_GRP_IDX]++;
  55. } else {
  56. break;
  57. }
  58. } else {
  59. if (sortedSequence.length > startRecIdx + vi) {
  60. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_NORMAL, sortedSequence[startRecIdx + vi]]);
  61. } else {
  62. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_NORMAL, JV.BLANK_VALUE_INDEX]);
  63. }
  64. }
  65. } else {
  66. if (sortedSequence.length > startRecIdx + vi) {
  67. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_NORMAL, sortedSequence[startRecIdx + vi]]);
  68. } else {
  69. vIdx.push([(isFollow)?JV.TYPE_FOLLOW_MODE:-1, JV.DISPLAY_VAL_TYPE_NORMAL, JV.BLANK_VALUE_INDEX]);
  70. }
  71. }
  72. }
  73. page_seg_map.push([pageIdx, segIdx]);
  74. ValuedIdxLst.push(vIdx);
  75. }
  76. let JpcFlowTabResult = {};
  77. JpcFlowTabResult.initialize = function(isEx) {
  78. let me = this;
  79. me.isEx = isEx;
  80. me.paging_option = JV.PAGING_OPTION_NORMAL;
  81. me.segments = [];
  82. me.dispValueIdxLst = [];
  83. me.page_seg_map = [];
  84. me.disp_fields_idx = [];
  85. me.seg_sum_fields_idx = [];
  86. me.seg_sum_tab_fields = [];
  87. me.page_sum_fields_idx = [];
  88. me.page_sum_tab_fields = [];
  89. me.auto_height_fields_idx = [];//那些被标记为判断自动行高的指标集合
  90. me.group_fields = [];
  91. me.group_sum_fields = [];
  92. me.group_sum_values = null;
  93. me.group_node_info = null; //记录在哪个seg及到哪条记录后有group sum信息
  94. me.group_lines_amt = 0; //每group一次占用多少行,计算page信息会用到
  95. me.pageStatusLst = [];
  96. me.groupSumValLst = [];
  97. me.segSumValLst = [];
  98. me.pageSumValLst = [];
  99. me.multiCols = 1;
  100. me.pagesAmt = 0;
  101. };
  102. JpcFlowTabResult.sorting = function(rptTpl, dataObj, dataSeq) {
  103. let me = this;
  104. let FLOW_NODE_STR = me.isEx?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  105. JpcFieldHelper.findAndPutDataFieldIdx(rptTpl, rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_SEG_SUM][JV.PROP_SUM_FIELDS], me.seg_sum_tab_fields, me.seg_sum_fields_idx, me.isEx);
  106. JpcFieldHelper.findAndPutDataFieldIdx(rptTpl, rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_PAGE_SUM][JV.PROP_SUM_FIELDS], me.page_sum_tab_fields, me.page_sum_fields_idx, me.isEx);
  107. JpcFieldHelper.findAndPutDataFieldIdx(rptTpl, rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_FIELDS], me.group_fields, null, me.isEx);
  108. JpcFieldHelper.findAndPutDataFieldIdx(rptTpl, rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_GROUP][JV.PROP_SUM_FIELDS], me.group_sum_fields, null, me.isEx);
  109. JpcFieldHelper.findAutoHeightFieldIdx(rptTpl, rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_CONTENT][JV.PROP_FLOW_FIELDS], me.auto_height_fields_idx, me.isEx);
  110. for (let si = 0; si < dataSeq.length; si++) {
  111. me.segments.push(dataSeq[si].slice(0));
  112. }
  113. //pre-sum the data(for seg sum display)
  114. let data_details = me.isEx?dataObj[JV.DATA_DETAIL_DATA_EX]:dataObj[JV.DATA_DETAIL_DATA],
  115. data_fields = [];
  116. for (let i = 0; i < me.seg_sum_fields_idx.length; i++) {
  117. let data_field = data_details[me.seg_sum_fields_idx[i]];
  118. data_fields.push(data_field);
  119. }
  120. for (let i = 0; i < me.segments.length; i++) { //seg level
  121. if (me.segments[i].length > 0) {
  122. let rowGrandTotal = [];
  123. for (let di = 0; di < data_fields.length; di++) {
  124. rowGrandTotal.push(0.0);
  125. for (let j = 0; j < me.segments[i].length; j++) {
  126. //3. start to sum
  127. rowGrandTotal[di] = rowGrandTotal[di] + 1.0 * JpcFieldHelper.getValue(data_fields[di], me.segments[i][j]);
  128. }
  129. }
  130. me.segSumValLst.push(rowGrandTotal);
  131. }
  132. }
  133. };
  134. JpcFlowTabResult.sumUpGrp = function ($CURRENT_RPT, dataObj, segIdx, preGrpIdx, nexGrpIdx) {
  135. let me = this, segDataIdx = me.segments[segIdx];
  136. for (let j = 0; j < me.group_sum_fields.length; j++) {
  137. let sum_field = JE.F(me.group_sum_fields[j][JV.PROP_FIELD_ID], $CURRENT_RPT);
  138. if (sum_field) {
  139. let data_field = null;
  140. if (sum_field[JV.PROP_AD_HOC_DATA]) {
  141. data_field = sum_field[JV.PROP_AD_HOC_DATA]
  142. } else {
  143. data_field = dataObj[sum_field.DataNodeName][sum_field.DataSeq];
  144. }
  145. let sumV = 0;
  146. for (let si = preGrpIdx; si <= nexGrpIdx; si++) {
  147. sumV += JpcFieldHelper.getValue(data_field, segDataIdx[si]);
  148. }
  149. // me.group_sum_values[segIdx][j].push(sumV);
  150. me.group_sum_values[segIdx][me.group_sum_fields[j][JV.PROP_SUM_KEY]].push(sumV);
  151. }
  152. }
  153. me.group_node_info[segIdx].push(nexGrpIdx);
  154. };
  155. JpcFlowTabResult.setupGroupingData = function (rptTpl, dataObj, $CURRENT_RPT) {
  156. let me = this;
  157. if (me.group_fields.length > 0 && me.group_sum_fields.length > 0) {
  158. me.group_sum_values = [];
  159. me.group_node_info = [];
  160. let CURRENT_FLOW_INFO = (me.isEx)?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  161. me.group_lines_amt = rptTpl[CURRENT_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES].length;
  162. //
  163. let preGrpIdx = 0, nexGrpIdx = 0;
  164. for (let segIdx = 0; segIdx < me.segments.length; segIdx++) {
  165. let segDataIdx = me.segments[segIdx];
  166. // me.group_sum_values.push([]);
  167. me.group_sum_values.push({});
  168. me.group_node_info.push([]);
  169. for (let j = 0; j < me.group_sum_fields.length; j++) {
  170. // me.group_sum_values[segIdx].push([]);
  171. me.group_sum_values[segIdx][me.group_sum_fields[j][JV.PROP_SUM_KEY]] = [];
  172. // me.group_node_info[segIdx].push([]);
  173. }
  174. for (let di = 0; di < segDataIdx.length; di++) {
  175. let hasDiff = false;
  176. if (di > 1) {
  177. for (let i = 0; i < me.group_fields.length; i++) {
  178. let grp_field = JE.F(me.group_fields[i][JV.PROP_FIELD_ID], $CURRENT_RPT);
  179. if (grp_field) {
  180. let data_field = null;
  181. if (grp_field[JV.PROP_AD_HOC_DATA]) {
  182. data_field = grp_field[JV.PROP_AD_HOC_DATA]
  183. } else {
  184. data_field = dataObj[grp_field.DataNodeName][grp_field.DataSeq];
  185. }
  186. let v1 = JpcFieldHelper.getValue(data_field, segDataIdx[di]), v2 = JpcFieldHelper.getValue(data_field, segDataIdx[di - 1]);
  187. if (v1 !== v2) {
  188. hasDiff = true;
  189. break;
  190. }
  191. }
  192. }
  193. }
  194. if (hasDiff) {
  195. //then sum up the fields
  196. me.sumUpGrp($CURRENT_RPT, dataObj, segIdx, preGrpIdx, nexGrpIdx);
  197. nexGrpIdx = di;
  198. preGrpIdx = di;
  199. if (di === segDataIdx.length - 1) {
  200. me.sumUpGrp($CURRENT_RPT, dataObj, segIdx, preGrpIdx, nexGrpIdx);
  201. }
  202. } else if (di === segDataIdx.length - 1) {
  203. me.sumUpGrp($CURRENT_RPT, dataObj, segIdx, preGrpIdx, di);
  204. } else {
  205. nexGrpIdx = di;
  206. }
  207. }
  208. }
  209. }
  210. };
  211. JpcFlowTabResult.setupAutoHeightData = function(rptTpl, dataObj, $CURRENT_RPT) {
  212. //自动行高功能,需要考虑以下情况:
  213. //1. 每一Segment的需要增加行的数量
  214. //2. 边界条件(跨页处理)
  215. let me = this;
  216. let CURRENT_FLOW_INFO = (me.isEx)?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  217. //rptTpl[CURRENT_FLOW_INFO][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES].length;
  218. };
  219. JpcFlowTabResult.preSetupPages = function (rptTpl, dataObj, defProperties, option, $CURRENT_RPT, followTabEx) {
  220. //换一种思路来整理流水式数据
  221. let me = this, rst = 1, counterRowRec = 0, counterRowRecEx = 0, maxRowRec = 1, pageIdx = 0, currentRecAmt = 0;
  222. me.setupGroupingData(rptTpl, dataObj, $CURRENT_RPT);
  223. if (followTabEx) {
  224. followTabEx.setupGroupingData(rptTpl, dataObj, $CURRENT_RPT);
  225. }
  226. me.paging_option = option||JV.PAGING_OPTION_NORMAL;
  227. let CURRENT_FLOW_INFO = (me.isEx)?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  228. JpcFieldHelper.findAndPutDataFieldIdx(rptTpl, rptTpl[CURRENT_FLOW_INFO][JV.NODE_FLOW_CONTENT][JV.PROP_FLOW_FIELDS], null, me.disp_fields_idx, me.isEx);
  229. if (me.paging_option === JV.PAGING_OPTION_INFINITY) {
  230. rst = me.segments.length;
  231. let pageStatus = [true, true, false, true, true, true, false, false];
  232. for (let segIdx = 0; segIdx < me.segments.length; segIdx++) {
  233. if (segIdx === me.segments.length - 1) {
  234. pageStatus[JV.STATUS_REPORT_END] = true;
  235. }
  236. if (segIdx > 0) {
  237. pageStatus[JV.STATUS_REPORT_START] = false;
  238. }
  239. me.pageStatusLst.push(pageStatus.slice(0));
  240. pageIdx++;
  241. let grpSeqInfo = (me.group_node_info)?me.group_node_info[segIdx]:null;
  242. private_addPageValue(me.dispValueIdxLst, me.segments[segIdx], grpSeqInfo, 0, me.segments[segIdx].length, me.page_seg_map, segIdx, pageIdx, null, false);
  243. }
  244. //目前不支持flowTabEx
  245. } else {
  246. let bands = JpcBand.createNew(rptTpl, defProperties);
  247. let pageStatus = [true, true, false, true, false, false, false, false];
  248. if (me.isEx) {
  249. pageStatus[JV.STATUS_REPORT_START] = false;
  250. }
  251. if (rptTpl[CURRENT_FLOW_INFO][JV.PROP_MULTI_COLUMN]) {
  252. me.multiCols = 1 * rptTpl[CURRENT_FLOW_INFO][JV.PROP_MULTI_COLUMN];
  253. }
  254. let grpPageInfo = {};
  255. function private_resetBandArea() {
  256. JpcBandHelper.setBandArea(bands, rptTpl, pageStatus, !me.isEx, me.isEx);
  257. maxRowRec = JpcFlowTabHelper.getMaxRowsPerPage(bands, rptTpl, me.isEx);
  258. }
  259. function private_addPage(segIdx, grpSeqInfo, isFollow, isMix, mixSplitPoint) {
  260. private_resetBandArea();
  261. me.pageStatusLst.push(pageStatus.slice(0));
  262. currentRecAmt += maxRowRec;
  263. pageIdx++;
  264. if (isMix) {
  265. //先处理上半部分
  266. private_addPageValue(me.dispValueIdxLst, me.segments[segIdx], grpSeqInfo, counterRowRec, mixSplitPoint,me.page_seg_map, segIdx, pageIdx, grpPageInfo, false);
  267. for (let dv of me.dispValueIdxLst[me.dispValueIdxLst.length - 1]) {
  268. if (dv[1] === JV.DISPLAY_VAL_TYPE_NORMAL) counterRowRec++;
  269. }
  270. //再处理下半部分
  271. private_addPageValue(me.dispValueIdxLst, followTabEx.segments[segIdx], null, counterRowRecEx, maxRowRec - mixSplitPoint, me.page_seg_map, segIdx, pageIdx, null, true);
  272. for (let dv of me.dispValueIdxLst[me.dispValueIdxLst.length - 1]) {
  273. if (dv[1] === JV.DISPLAY_VAL_TYPE_NORMAL) counterRowRecEx++;
  274. }
  275. //合并到一页中
  276. me.page_seg_map.splice(me.page_seg_map.length - 1, 1);
  277. let vl = me.dispValueIdxLst[me.dispValueIdxLst.length - 2];
  278. for (let item of me.dispValueIdxLst[me.dispValueIdxLst.length - 1]) {
  279. vl.push(item);
  280. }
  281. me.dispValueIdxLst.splice(me.dispValueIdxLst.length - 1, 1);
  282. } else if (isFollow) {
  283. private_addPageValue(me.dispValueIdxLst, followTabEx.segments[segIdx], null, counterRowRecEx, maxRowRec, me.page_seg_map, segIdx, pageIdx, null, true);
  284. for (let dv of me.dispValueIdxLst[me.dispValueIdxLst.length - 1]) {
  285. if (dv[1] === JV.DISPLAY_VAL_TYPE_NORMAL) counterRowRecEx++;
  286. }
  287. } else {
  288. private_addPageValue(me.dispValueIdxLst, me.segments[segIdx], grpSeqInfo, counterRowRec, maxRowRec,me.page_seg_map, segIdx, pageIdx, grpPageInfo, false);
  289. for (let dv of me.dispValueIdxLst[me.dispValueIdxLst.length - 1]) {
  290. if (dv[1] === JV.DISPLAY_VAL_TYPE_NORMAL) counterRowRec++;
  291. }
  292. }
  293. }
  294. for (let segIdx = 0; segIdx < me.segments.length; segIdx++) {
  295. let grpSeqInfo = (me.group_node_info)?me.group_node_info[segIdx]:null;
  296. let grpRecAmt = (grpSeqInfo)?(grpSeqInfo.length*me.group_lines_amt):0;
  297. let grpRecAmtEx = 0;
  298. if (followTabEx && followTabEx.group_node_info) {
  299. grpRecAmtEx = followTabEx.group_node_info.length * followTabEx.group_lines_amt;
  300. }
  301. grpPageInfo[JV.PROP_SEG_GRP_IDX] = 0;
  302. grpPageInfo[JV.PROP_INSERTED_GRP_REC] = 0;
  303. grpPageInfo[JV.PROP_PRE_ADD_GRP_REC_INFO] = [];
  304. grpPageInfo[JV.PROP_GRP_LINES] = me.group_lines_amt;
  305. pageStatus[JV.STATUS_SEGMENT_START] = true;
  306. private_resetBandArea();
  307. let threshold = 0;
  308. currentRecAmt = 0;
  309. counterRowRec = 0;
  310. counterRowRecEx = 0;
  311. let ttlSegRecAmtNormal = me.segments[segIdx].length + grpRecAmt; //正常的segment下的数据长度累计(含grouping data)
  312. let ttlSegRecAmt = (followTabEx)?(me.segments[segIdx].length + grpRecAmt + followTabEx.segments[segIdx].length + grpRecAmtEx):(me.segments[segIdx].length + grpRecAmt); //所有的segment下的数据长度累计(包括ex部分)
  313. while (true) {
  314. if (currentRecAmt > 0) pageStatus[JV.STATUS_SEGMENT_START] = false;
  315. if (pageIdx > 0) pageStatus[JV.STATUS_REPORT_START] = false;
  316. //开始判断各种scenarios
  317. if (ttlSegRecAmtNormal < ttlSegRecAmt) {
  318. //有流水拓展,并且是follow mode
  319. if (currentRecAmt + maxRowRec > ttlSegRecAmtNormal) {
  320. if (currentRecAmt >= ttlSegRecAmtNormal) {
  321. //纯 followTabEx 数据
  322. if (currentRecAmt + maxRowRec >= ttlSegRecAmt) {
  323. pageStatus[JV.STATUS_SEGMENT_END] = true;
  324. private_resetBandArea();
  325. let hasAdHocRow = !JpcFlowTabHelper.chkSegEnd(bands, rptTpl, ttlSegRecAmt, currentRecAmt, maxRowRec, me.isEx);
  326. if (hasAdHocRow) {
  327. //add page info(pre segment end)
  328. pageStatus[JV.STATUS_SEGMENT_END] = false;
  329. private_addPage(segIdx, null, true, false, -1);
  330. }
  331. //add page info
  332. pageStatus[JV.STATUS_SEGMENT_END] = true;
  333. private_addPage(segIdx, null, true, false, -1);
  334. } else {
  335. private_addPage(segIdx, null, true, false, -1);
  336. }
  337. } else {
  338. //混合数据
  339. if (currentRecAmt + maxRowRec >= ttlSegRecAmt) {
  340. pageStatus[JV.STATUS_SEGMENT_END] = true;
  341. private_resetBandArea();
  342. let hasAdHocRow = !JpcFlowTabHelper.chkSegEnd(bands, rptTpl, ttlSegRecAmt, currentRecAmt, maxRowRec, me.isEx);
  343. if (hasAdHocRow) {
  344. //add page info(pre segment end)
  345. pageStatus[JV.STATUS_SEGMENT_END] = false;
  346. private_addPage(segIdx, grpSeqInfo, false, true, ttlSegRecAmtNormal);
  347. }
  348. //add page info
  349. pageStatus[JV.STATUS_SEGMENT_END] = true;
  350. if (currentRecAmt >= ttlSegRecAmtNormal) {
  351. //纯 followTabEx 数据啦
  352. private_addPage(segIdx, null, true, false, -1);
  353. } else {
  354. private_addPage(segIdx, grpSeqInfo, false, true, ttlSegRecAmtNormal);
  355. }
  356. } else {
  357. private_addPage(segIdx, grpSeqInfo, false, true, ttlSegRecAmtNormal);
  358. }
  359. }
  360. } else {
  361. //纯followTab数据
  362. private_addPage(segIdx, grpSeqInfo, false, false, -1);
  363. }
  364. } else {
  365. //普通流水数据情况
  366. if (currentRecAmt + maxRowRec >= ttlSegRecAmt) {
  367. pageStatus[JV.STATUS_SEGMENT_END] = true;
  368. pageStatus[JV.STATUS_REPORT_END] = true;
  369. private_resetBandArea();
  370. let hasAdHocRow = !JpcFlowTabHelper.chkSegEnd(bands, rptTpl, ttlSegRecAmt, currentRecAmt, maxRowRec, me.isEx);
  371. if (hasAdHocRow) {
  372. //add page info(pre segment end)
  373. pageStatus[JV.STATUS_SEGMENT_END] = false;
  374. pageStatus[JV.STATUS_REPORT_END] = false;
  375. private_addPage(segIdx, grpSeqInfo, false, false, -1);
  376. }
  377. //add page info
  378. pageStatus[JV.STATUS_SEGMENT_END] = true;
  379. pageStatus[JV.STATUS_REPORT_END] = true;
  380. private_addPage(segIdx, grpSeqInfo, false, false, -1);
  381. } else {
  382. private_addPage(segIdx, grpSeqInfo, false, false, -1);
  383. }
  384. }
  385. //检测是否可退出
  386. if ((currentRecAmt >= ttlSegRecAmt) && (pageIdx % me.multiCols === 0)) {
  387. //备注:这里必须得考虑多栏的情况,否则会造成pageStatus出界的问题
  388. break;
  389. }
  390. //控制阈值,超过阈值则强制退出,防止死循环
  391. threshold++;
  392. if (threshold > 1000) {
  393. console.log("Hey! There may be a dead loop here!!!");
  394. break;
  395. }
  396. }
  397. }
  398. // console.log(me.dispValueIdxLst);
  399. rst = Math.ceil(pageIdx / me.multiCols);
  400. }
  401. me.pagesAmt = rst;
  402. return rst;
  403. };
  404. JpcFlowTabResult.outputAsSimpleJSONPage = function (rptTpl, dataObj, page, bands, controls, adHocMergePos, $CURRENT_RPT) {
  405. let me = this, rst = [], tabRstLst = [];
  406. let FLOW_NODE_STR = me.isEx?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  407. let unitFactor = JpcCommonHelper.getUnitFactor(rptTpl);
  408. if (me.paging_option === JV.PAGING_OPTION_INFINITY) {
  409. let segIdx = page - 1;
  410. //1 calculate the band position
  411. JpcBandHelper.setBandArea(bands, rptTpl, me.pageStatusLst[page - 1], !me.isEx, me.isEx);
  412. //2. then reset the band height
  413. let tab = rptTpl[JV.NODE_FLOW_INFO][JV.NODE_FLOW_CONTENT];
  414. let flowContentBand = bands[tab[JV.PROP_BAND_NAME]];
  415. let actH = JpcFlowTabHelper.getActualContentAreaHeight(bands, rptTpl, me.segments, page, me.isEx);
  416. let offsetY = actH - (flowContentBand.Bottom - flowContentBand.Top);
  417. JpcBandHelper.resetBandPos(rptTpl[JV.NODE_BAND_COLLECTION], bands, flowContentBand, 0, offsetY);
  418. // 2.1 Content-Tab
  419. tabRstLst.push(me.outputContent(rptTpl, dataObj, page, bands, unitFactor, controls, 0, $CURRENT_RPT));
  420. // 2.2 Column tab
  421. tabRstLst.push(me.outputColumn(rptTpl, dataObj, page, segIdx, bands, unitFactor, controls, 0));
  422. // 2.3 Sum Seg
  423. tabRstLst.push(me.outputSegSum(rptTpl, dataObj, page, segIdx, bands, unitFactor, controls));
  424. // 2.4 Sum Page
  425. tabRstLst.push(me.outputPageSum(rptTpl, dataObj, page, segIdx, bands, unitFactor, controls));
  426. // 2.5 Group
  427. // 2.6 Discrete
  428. tabRstLst.push(JpcDiscreteHelper.outputDiscreteInfo(rptTpl[FLOW_NODE_STR][JV.NODE_DISCRETE_INFO], bands, dataObj, unitFactor, me.pageStatusLst[page - 1], segIdx, 1, 0, $CURRENT_RPT));
  429. //3. reset merge band position
  430. if (bands[JV.BAND_PROP_MERGE_BAND] && adHocMergePos) {
  431. let mergedBand = bands[JV.BAND_PROP_MERGE_BAND];
  432. let arr = [];
  433. arr.push(parseInt(mergedBand[JV.PROP_LEFT].toFixed(0)));
  434. adHocMergePos[JV.PROP_LEFT] = arr;
  435. arr = [];
  436. arr.push(parseInt(mergedBand[JV.PROP_RIGHT].toFixed(0)));
  437. adHocMergePos[JV.PROP_RIGHT] = arr;
  438. arr = [];
  439. arr.push(parseInt(mergedBand[JV.PROP_TOP].toFixed(0)));
  440. adHocMergePos[JV.PROP_TOP] = arr;
  441. arr = [];
  442. arr.push(parseInt((mergedBand[JV.PROP_BOTTOM]).toFixed(0)));
  443. adHocMergePos[JV.PROP_BOTTOM] = arr;
  444. }
  445. } else {
  446. let segIdx = JpcCommonHelper.getSegIdxByPageIdx(page, me.page_seg_map);
  447. //1 calculate the band position
  448. JpcBandHelper.setBandArea(bands, rptTpl, me.pageStatusLst[page - 1], !me.isEx, me.isEx);
  449. //2. start to output detail-part
  450. for (let pi = 0; pi < me.multiCols; pi++) {
  451. let actualPage = (page - 1) * me.multiCols + pi + 1;
  452. // 2.1 Content-Tab
  453. tabRstLst.push(me.outputContent(rptTpl, dataObj, actualPage, bands, unitFactor, controls, pi, $CURRENT_RPT));
  454. // 2.2 Column tab
  455. tabRstLst.push(me.outputColumn(rptTpl, dataObj, actualPage, segIdx, bands, unitFactor, controls, pi));
  456. // 2.3 Sum Seg
  457. tabRstLst.push(me.outputSegSum(rptTpl, dataObj, actualPage, segIdx, bands, unitFactor, controls));
  458. // 2.4 Sum Page
  459. tabRstLst.push(me.outputPageSum(rptTpl, dataObj, actualPage, segIdx, bands, unitFactor, controls));
  460. // 2.5 Group
  461. // 2.6 Discrete
  462. if (pi === 0) {
  463. tabRstLst.push(JpcDiscreteHelper.outputDiscreteInfo(rptTpl[FLOW_NODE_STR][JV.NODE_DISCRETE_INFO], bands, dataObj, unitFactor, me.pageStatusLst[actualPage - 1], segIdx, 1, pi, $CURRENT_RPT));
  464. }
  465. }
  466. }
  467. for (let i = 0; i < tabRstLst.length; i++) {
  468. rst = rst.concat(tabRstLst[i]);
  469. tabRstLst[i] = null;
  470. }
  471. return rst;
  472. };
  473. JpcFlowTabResult.outputContent = function(rptTpl, dataObj, page, bands, unitFactor, controls, multiColIdx, $CURRENT_RPT) {
  474. let me = this, rst = [];
  475. let FLOW_NODE_STR = me.isEx?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  476. let tab = rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_CONTENT];
  477. let tabEx = (rptTpl[JV.NODE_FLOW_INFO_EX])?rptTpl[JV.NODE_FLOW_INFO_EX][JV.NODE_FLOW_CONTENT]:null;
  478. let band = bands[tab[JV.PROP_BAND_NAME]];
  479. if (band) {
  480. let pageStatus = me.pageStatusLst[page - 1];
  481. if (pageStatus[band[JV.BAND_PROP_DISPLAY_TYPE]]) {
  482. let tab_fields = tab[JV.PROP_FLOW_FIELDS];
  483. let tab_fields_ex = tabEx?tabEx[JV.PROP_FLOW_FIELDS]:null;
  484. let data_details = me.isEx?dataObj[JV.DATA_DETAIL_DATA_EX]:dataObj[JV.DATA_DETAIL_DATA];
  485. let data_details_ex = $CURRENT_RPT.isFollowMode?dataObj[JV.DATA_DETAIL_DATA_EX]:null;
  486. let contentValuesIdx = me.dispValueIdxLst[page - 1];
  487. let page_sum_data_fields = [];
  488. for (let i = 0; i < me.page_sum_fields_idx.length; i++) {
  489. let data_field = data_details[me.page_sum_fields_idx[i]];
  490. page_sum_data_fields.push(data_field);
  491. }
  492. let rowGrandTotal = [];
  493. for (let di = 0; di < page_sum_data_fields.length; di++) {
  494. rowGrandTotal.push(0.0);
  495. }
  496. //normal content
  497. for (let rowIdx = 0; rowIdx < contentValuesIdx.length; rowIdx++) {
  498. for (let i = 0; i < tab_fields.length; i++) {
  499. let tab_field = tab_fields[i];
  500. let data_field = null;
  501. if (me.disp_fields_idx[i] !== JV.BLANK_FIELD_INDEX) {
  502. data_field = data_details[me.disp_fields_idx[i]];
  503. } else {
  504. data_field = JE.F(tab_field[JV.PROP_FIELD_ID], $CURRENT_RPT);
  505. if (data_field) {
  506. data_field = data_field[JV.PROP_AD_HOC_DATA];
  507. }
  508. }
  509. if (!(tab_field[JV.PROP_HIDDEN])) {
  510. // rst.push(me.outputTabField(band, tab_field, data_field, contentValuesIdx[rowIdx], -1, contentValuesIdx.length, rowIdx, 1, 0, unitFactor, true, controls, multiColIdx));
  511. //测试中
  512. if (contentValuesIdx[rowIdx][0] !== JV.TYPE_FOLLOW_MODE && contentValuesIdx[rowIdx][1] === JV.DISPLAY_VAL_TYPE_NORMAL) {
  513. rst.push(me.outputTabField(band, tab_field, data_field, contentValuesIdx[rowIdx][2], -1, contentValuesIdx.length, rowIdx, 1, 0, unitFactor, true, controls, multiColIdx));
  514. }
  515. }
  516. }
  517. if (contentValuesIdx[rowIdx][0] === JV.TYPE_FOLLOW_MODE) {
  518. for (let i = 0; i < tab_fields_ex.length; i++) {
  519. let tab_field = tab_fields_ex[i];
  520. let data_field = null;
  521. if (me.disp_fields_idx[i] !== JV.BLANK_FIELD_INDEX) {
  522. data_field = data_details_ex[me.disp_fields_idx[i]];
  523. } else {
  524. data_field = JE.F(tab_field[JV.PROP_FIELD_ID], $CURRENT_RPT);
  525. if (data_field) {
  526. data_field = data_field[JV.PROP_AD_HOC_DATA];
  527. }
  528. }
  529. if (!(tab_field[JV.PROP_HIDDEN])) {
  530. if (contentValuesIdx[rowIdx][0] === JV.TYPE_FOLLOW_MODE && contentValuesIdx[rowIdx][1] === JV.DISPLAY_VAL_TYPE_NORMAL) {
  531. rst.push(me.outputTabField(band, tab_field, data_field, contentValuesIdx[rowIdx][2], -1, contentValuesIdx.length, rowIdx, 1, 0, unitFactor, true, controls, multiColIdx));
  532. }
  533. }
  534. }
  535. }
  536. //page sum content
  537. for (let di = 0; di < page_sum_data_fields.length; di++) {
  538. rowGrandTotal[di] = rowGrandTotal[di] + 1.0 * JpcFieldHelper.getValue(page_sum_data_fields[di], contentValuesIdx[rowIdx][2]);
  539. }
  540. }
  541. me.pageSumValLst.push(rowGrandTotal);
  542. //grouping content
  543. for (let rowIdx = 0; rowIdx < contentValuesIdx.length; rowIdx++) {
  544. if (contentValuesIdx[rowIdx][1] === JV.DISPLAY_VAL_TYPE_GROUP) {
  545. for (let grpIdx = 0; grpIdx < rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES].length; grpIdx++) {
  546. if (contentValuesIdx[rowIdx][3] === grpIdx) {
  547. let grp_line = rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_GROUP][JV.PROP_GROUP_LINES][grpIdx];
  548. let lineRst = me.outputTabGrpLine(band, grp_line, page, contentValuesIdx[rowIdx], contentValuesIdx.length, rowIdx, 1, 0, unitFactor, true, controls, multiColIdx)
  549. rst = rst.concat(lineRst);
  550. }
  551. }
  552. }
  553. }
  554. }
  555. }
  556. return rst;
  557. };
  558. JpcFlowTabResult.outputColumn = function (rptTpl, dataObj, page, segIdx, bands, unitFactor, controls, multiColIdx) {
  559. let me = this, rst = [];
  560. let FLOW_NODE_STR = me.isEx?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  561. let tab = rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_COLUMN];
  562. let band = bands[tab[JV.PROP_BAND_NAME]];
  563. if (band) {
  564. let pageStatus = me.pageStatusLst[page - 1];
  565. if (pageStatus[band[JV.BAND_PROP_DISPLAY_TYPE]]) {
  566. if (tab[JV.PROP_TEXT]) {
  567. rst.push(JpcTextHelper.outputText(tab[JV.PROP_TEXT], band, unitFactor, 1, 0, 1, 0, me.multiCols, multiColIdx));
  568. }
  569. if (tab[JV.PROP_TEXTS]) {
  570. for (let j = 0; j < tab[JV.PROP_TEXTS].length; j++) {
  571. rst.push(JpcTextHelper.outputText(tab[JV.PROP_TEXTS][j], band, unitFactor, 1, 0, 1, 0, me.multiCols, multiColIdx));
  572. }
  573. }
  574. if (tab[JV.NODE_DISCRETE_INFO]) {
  575. rst = rst.concat(JpcDiscreteHelper.outputDiscreteInfo(tab[JV.NODE_DISCRETE_INFO], bands, dataObj, unitFactor, me.pageStatusLst[page - 1], segIdx, me.multiCols, multiColIdx));
  576. }
  577. }
  578. }
  579. return rst;
  580. };
  581. JpcFlowTabResult.outputSegSum = function (rptTpl, dataObj, page, segIdx, bands, unitFactor, controls) {
  582. let me = this, rst = [];
  583. let FLOW_NODE_STR = me.isEx?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  584. let tab = rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_SEG_SUM];
  585. let band = bands[tab[JV.PROP_BAND_NAME]];
  586. if (band) {
  587. let pageStatus = me.pageStatusLst[page - 1];
  588. if (pageStatus[band[JV.BAND_PROP_DISPLAY_TYPE]]) {
  589. let tab_fields = me.seg_sum_tab_fields;
  590. for (let i = 0; i < tab_fields.length; i++) {
  591. let cellItem = JpcCommonOutputHelper.createCommonOutput(tab_fields[i], me.segSumValLst[segIdx][i], controls);
  592. cellItem[JV.PROP_AREA] = JpcAreaHelper.outputArea(tab_fields[i][JV.PROP_AREA], band, unitFactor, 1, 0, 1, 0, me.multiCols, 0, true, false);
  593. rst.push(cellItem);
  594. }
  595. if (tab[JV.PROP_TEXT]) {
  596. rst.push(JpcTextHelper.outputText(tab[JV.PROP_TEXT], band, unitFactor, 1, 0, 1, 0, me.multiCols, 0));
  597. }
  598. if (tab[JV.PROP_TEXTS]) {
  599. for (let j = 0; j < tab[JV.PROP_TEXTS].length; j++) {
  600. rst.push(JpcTextHelper.outputText(tab[JV.PROP_TEXTS][j], band, unitFactor, 1, 0, 1, 0, me.multiCols, 0));
  601. }
  602. }
  603. if (tab[JV.NODE_DISCRETE_INFO]) {
  604. rst = rst.concat(JpcDiscreteHelper.outputDiscreteInfo(tab[JV.NODE_DISCRETE_INFO], bands, dataObj, unitFactor, me.pageStatusLst[page - 1], segIdx, me.multiCols, 0));
  605. }
  606. }
  607. }
  608. return rst;
  609. };
  610. JpcFlowTabResult.outputPageSum = function (rptTpl, dataObj, page, segIdx, bands, unitFactor, controls) {
  611. let me = this, rst = [];
  612. let FLOW_NODE_STR = me.isEx?JV.NODE_FLOW_INFO_EX:JV.NODE_FLOW_INFO;
  613. let tab = rptTpl[FLOW_NODE_STR][JV.NODE_FLOW_PAGE_SUM];
  614. let band = bands[tab[JV.PROP_BAND_NAME]];
  615. if (band) {
  616. let pageStatus = me.pageStatusLst[page - 1];
  617. if (pageStatus[band[JV.BAND_PROP_DISPLAY_TYPE]]) {
  618. let tab_fields = me.page_sum_tab_fields;
  619. for (let i = 0; i < tab_fields.length; i++) {
  620. let cellItem = JpcCommonOutputHelper.createCommonOutput(tab_fields[i], me.pageSumValLst[page - 1], controls);
  621. cellItem[JV.PROP_AREA] = JpcAreaHelper.outputArea(tab_fields[i][JV.PROP_AREA], band, unitFactor, 1, 0, 1, 0, me.multiCols, 0, true, false);
  622. rst.push(cellItem);
  623. }
  624. if (tab[JV.PROP_TEXT]) {
  625. rst.push(JpcTextHelper.outputText(tab[JV.PROP_TEXT], band, unitFactor, 1, 0, 1, 0, me.multiCols, 0));
  626. }
  627. if (tab[JV.PROP_TEXTS]) {
  628. for (let j = 0; j < tab[JV.PROP_TEXTS].length; j++) {
  629. rst.push(JpcTextHelper.outputText(tab[JV.PROP_TEXTS][j], band, unitFactor, 1, 0, 1, 0, me.multiCols, 0));
  630. }
  631. }
  632. if (tab[JV.NODE_DISCRETE_INFO]) {
  633. rst = rst.concat(JpcDiscreteHelper.outputDiscreteInfo(tab[JV.NODE_DISCRETE_INFO], bands, dataObj, unitFactor, me.pageStatusLst[page - 1], segIdx, me.multiCols, 0));
  634. }
  635. }
  636. }
  637. return rst;
  638. };
  639. JpcFlowTabResult.outputTabField = function (band, tab_field, data_field, valueIdx, serialIdx, rows, rowIdx, cols, colIdx, unitFactor, isRow, controls, multiColIdx) {
  640. let me = this,
  641. rst = JpcCommonOutputHelper.createCommonOutput(tab_field, JpcFieldHelper.getValue(data_field, valueIdx), controls);
  642. rst[JV.PROP_AREA] = JpcAreaHelper.outputArea(tab_field[JV.PROP_AREA], band, unitFactor, rows, rowIdx, cols, colIdx, me.multiCols, multiColIdx, true, false);
  643. return rst;
  644. };
  645. JpcFlowTabResult.outputTabGrpLine = function (band, grp_line, page, grpValueIdx, rows, rowIdx, cols, colIdx, unitFactor, isRow, controls, multiColIdx) {
  646. let me = this, rst = [];
  647. if (grp_line[JV.PROP_GROUP_SUM_KEYS]) {
  648. let segIdx = JpcCommonHelper.getSegIdxByPageIdx(page, me.page_seg_map);
  649. let curSegGrpSum = me.group_sum_values[segIdx];
  650. for (let sumFieldNode of grp_line[JV.PROP_GROUP_SUM_KEYS]) {
  651. let value = curSegGrpSum[sumFieldNode[JV.PROP_SUM_KEY]][grpValueIdx[2]];
  652. let sumFldRst = JpcTextHelper.outputDirectValue(sumFieldNode, value, band, unitFactor, rows, rowIdx, cols, colIdx, me.multiCols, multiColIdx)
  653. rst.push(sumFldRst);
  654. }
  655. }
  656. if (grp_line[JV.PROP_TEXTS]) {
  657. for (let txt of grp_line[JV.PROP_TEXTS]) {
  658. rst.push(JpcTextHelper.outputText(txt, band, unitFactor, rows, rowIdx, cols, colIdx, me.multiCols, multiColIdx));
  659. }
  660. }
  661. if (grp_line[JV.PROP_DISCRETE_FIELDS]) {
  662. //暂时不支持
  663. }
  664. if (grp_line[JV.PROP_PARAMS]) {
  665. //暂时不支持
  666. }
  667. // console.log(rst);
  668. return rst;
  669. };
  670. return JpcFlowTabResult;
  671. };
  672. module.exports = new JpcFlowTabSrv();