StatTreeController.php 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Models\Pro;
  4. use App\Models\StatTreeLineClauseArg;
  5. use App\Models\StatTreeLineReportColumn;
  6. use Illuminate\Http\Request;
  7. use Illuminate\Support\Facades\Validator;
  8. use App\Models\Clause;
  9. use App\Models\StatTree;
  10. use App\Models\StatTreeLine;
  11. use App\Models\StatTreeLineClause;
  12. use Carbon\Carbon;
  13. use Illuminate\Support\Facades\DB;
  14. use Ramsey\Uuid\Uuid;
  15. class StatTreeController extends Controller
  16. {
  17. public function list()
  18. {
  19. $statTrees = StatTree::orderByRaw('is_template DESC NULLS LAST')->orderBy('name')->get();
  20. return view('app.stat-tree.stat-trees.list', compact('statTrees'));
  21. }
  22. public function createPage()
  23. {
  24. return view('app.stat-tree.stat-trees.create');
  25. }
  26. public function dashboard(StatTree $statTree)
  27. {
  28. return view('app.stat-tree.stat-trees.sub.dashboard', compact('statTree'));
  29. }
  30. public function dashboard2(StatTree $statTree)
  31. {
  32. return view('app.stat-tree.stat-trees.sub.dashboard2', compact('statTree'));
  33. }
  34. public function create(Request $request)
  35. {
  36. $validatedData = Validator::make($request->all(), [
  37. 'name' => 'required|string|unique:stat_tree',
  38. 'model' => 'required|string',
  39. 'slug' => 'required|string|unique:stat_tree'
  40. ]);
  41. if ($validatedData->fails()) return $this->fail($validatedData->errors()->first());
  42. [
  43. 'name' => $name,
  44. 'model' => $model,
  45. 'slug' => $slug
  46. ] = $request->all();
  47. $nextId = DB::select("select nextval('stat_tree_id_seq')");
  48. $statTree = new StatTree;
  49. $statTree->id = $nextId[0]->nextval;
  50. $statTree->uid = Uuid::uuid4();
  51. $statTree->name = $name;
  52. $statTree->model = $model;
  53. $statTree->slug = $slug;
  54. $statTree->is_template = (bool)$request->input('isTemplate');
  55. if($request->input('proUid')) {
  56. $pro = Pro::where('uid', $request->input('proUid'))->first();
  57. if($pro) {
  58. $statTree->pro_id = $pro->id;
  59. }
  60. }
  61. $statTree->pro_scope_clause = $request->input('proScopeClause');
  62. $statTree->save();
  63. return $this->pass($statTree->uid);
  64. }
  65. public function updateBasic(Request $request) {
  66. $statTree = StatTree::where('uid', $request->input('uid'))->first();
  67. if(!$statTree) return $this->fail('Stat tree not found!');
  68. $statTree->name = $request->input('name');
  69. $statTree->model = $request->input('model');
  70. $statTree->slug = $request->input('slug');
  71. $statTree->is_template = (bool)$request->input('isTemplate');
  72. $statTree->pro_id = NULL;
  73. if($request->input('proUid')) {
  74. $pro = Pro::where('uid', $request->input('proUid'))->first();
  75. if($pro) {
  76. $statTree->pro_id = $pro->id;
  77. }
  78. }
  79. $statTree->pro_scope_clause = $request->input('proScopeClause');
  80. $statTree->save();
  81. return $this->pass();
  82. }
  83. public function remove(Request $request) {
  84. $statTree = StatTree::where('uid', $request->input('uid'))->first();
  85. if(!$statTree) return $this->pass();
  86. DB::statement("DELETE FROM stat_tree_line WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  87. DB::statement("DELETE FROM stat_tree_line_clause WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  88. DB::statement("DELETE FROM stat_tree_line_clause_arg WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  89. DB::statement("DELETE FROM stat_tree_line_clause_arg_value WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  90. DB::statement("DELETE FROM stat_tree_line_report_column WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  91. DB::statement("DELETE FROM stat_tree WHERE id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  92. return $this->pass();
  93. }
  94. public function instantiate(Request $request, StatTree $statTree) {
  95. if(!$statTree->is_template) {
  96. return $this->fail("State tree is not a template!");
  97. }
  98. $pro = Pro::where('uid', $request->input('proUid'))->first();
  99. if(!$pro) {
  100. return $this->fail("Pro not found!");
  101. }
  102. $instance = $statTree->instantiateForPro($pro);
  103. return $this->pass($instance->uid);
  104. }
  105. public function clone(Request $request, StatTree $statTree) {
  106. $instance = $statTree->clone($request->input('name'));
  107. return $this->pass($instance->uid);
  108. }
  109. private function traverseLines($_lines, &$result) {
  110. foreach ($_lines as $line) {
  111. $result[] = $line;
  112. if(count($line->children)) {
  113. $this->traverseLines($line->children, $result);
  114. }
  115. }
  116. }
  117. public function edit(Request $request, StatTree $statTree) {
  118. $linesFlat = [];
  119. if($request->input('multi-pro')) {
  120. $this->traverseLines($statTree->rootLines, $linesFlat);
  121. }
  122. return view('app.stat-tree.stat-trees.sub.edit', compact('statTree', 'linesFlat'));
  123. }
  124. public function replaceAllLines(Request $request){
  125. $parents = [];
  126. $columns = '';
  127. $statTreeID = (int) $request->get('statTreeID');
  128. $data = $request->get('data');
  129. $rows = json_decode($data, true);
  130. $statTree = StatTree::where('id', $statTreeID)->first();
  131. $model = $statTree->model;
  132. DB::beginTransaction();
  133. // cleanup junk
  134. DB::statement("DELETE FROM stat_tree_line WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  135. DB::statement("DELETE FROM stat_tree_line_clause WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  136. DB::statement("DELETE FROM stat_tree_line_clause_arg WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  137. DB::statement("DELETE FROM stat_tree_line_clause_arg_value WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  138. DB::statement("DELETE FROM stat_tree_line_report_column WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  139. for($x = 0; $x < count($rows); $x++){
  140. $row = $rows[$x];
  141. $nextStatLineId = DB::select("select nextval('stat_tree_line_id_seq')");
  142. $statTreeLine = new StatTreeLine;
  143. $statTreeLine->id = $nextStatLineId[0]->nextval;
  144. $statTreeLine->uid = Uuid::uuid4();
  145. $statTreeLine->stat_tree_id = $statTree->id;
  146. $statTreeLine->tree_order_position_index = $x;
  147. $statTreeLine->last_refresh_count = null;
  148. $statTreeLine->tsv_text_for_report_columns = null;
  149. $statTreeLine->save();
  150. $allClauses = [];
  151. for($i = 0; $i < count($row); $i++){
  152. $cell = $row[$i];
  153. if(!$cell || empty($cell)) continue;
  154. $parts = explode('==>', $cell);
  155. $cell = $parts[0];
  156. $columns = count($parts) > 1 ? $parts[1] : '';
  157. $clause = Clause::where('label', $cell)->where('model', 'ilike', $model)->first();
  158. if(!$clause){
  159. DB::rollBack();
  160. return $this->fail('No clause record found for ' . $cell);
  161. }
  162. $nextStatLineClauseId = DB::select("select nextval('stat_tree_line_clause_id_seq')");
  163. $statTreeLineClause = new StatTreeLineClause;
  164. $statTreeLineClause->id = $nextStatLineClauseId[0]->nextval;
  165. $statTreeLineClause->uid = Uuid::uuid4();
  166. $statTreeLineClause->stat_tree_line_id = $statTreeLine->id;
  167. $statTreeLineClause->clause_id = $clause->id;
  168. $statTreeLineClause->clause_label = $cell;
  169. $statTreeLineClause->position_index = $i;
  170. $statTreeLineClause->detail_json = json_encode(['model' => $model]);
  171. $statTreeLineClause->stat_tree_id = $statTree->id;
  172. $statTreeLineClause->save();
  173. // check if the clause has any clauseArgs, if yes, create stat-tree-line-clause-arg and value records for them
  174. if(count($clause->clauseArgs)) {
  175. foreach ($clause->clauseArgs as $clauseArg) {
  176. $statTreeLineClauseArg = new StatTreeLineClauseArg();
  177. $nextId = DB::select("select nextval('stat_tree_line_clause_arg_id_seq')");
  178. $statTreeLineClauseArg->id = $nextId[0]->nextval;
  179. $statTreeLineClauseArg->stat_tree_line_clause_id = $statTreeLineClause->id;
  180. $statTreeLineClauseArg->clause_arg_id = $clauseArg->id;
  181. $statTreeLineClauseArg->access_level = 'ADMIN';
  182. $statTreeLineClauseArg->stat_tree_id = $statTree->id;
  183. $statTreeLineClauseArg->value = null;
  184. // TODO: need to copy clause arg values from parent node for all except last clause
  185. $statTreeLineClauseArg->save();
  186. }
  187. }
  188. $allClauses[] = $cell;
  189. // fill report columns (if last clause)
  190. if($i === count($row) - 1 && !!$columns) {
  191. $columns = explode(",", $columns);
  192. for ($j = 0; $j < count($columns); $j++) {
  193. $parts = explode("|", $columns[$j]);
  194. $column = new StatTreeLineReportColumn();
  195. $nextId = DB::select("select nextval('stat_tree_line_report_column_id_seq')");
  196. $column->id = $nextId[0]->nextval;
  197. $column->uid = Uuid::uuid4();
  198. $column->stat_tree_line_id = $statTreeLine->id;
  199. $column->label = $parts[1];
  200. $column->display_key = $parts[0];
  201. $positionIndex = DB::select("select max(position_index) from stat_tree_line_report_column where stat_tree_line_id = {$column->stat_tree_line_id}");
  202. $column->position_index = is_numeric($positionIndex[0]->max) ? $positionIndex[0]->max + 1 : 1;
  203. $column->stat_tree_id = $statTree->id;
  204. $column->save();
  205. }
  206. }
  207. }
  208. $parents[implode("|", $allClauses)] = $statTreeLine;
  209. // if child, find and set parent
  210. $nonEmpty = [];
  211. for($i = 0; $i < count($row); $i++){
  212. if($row[$i] && !empty($row[$i])) $nonEmpty[] = $row[$i];
  213. }
  214. if(count($nonEmpty) > 1) {
  215. $parentClauses = [];
  216. for($i = 0; $i < count($nonEmpty) - 1; $i++){
  217. $cell = $nonEmpty[$i];
  218. $parts = explode('==>', $cell);
  219. $cell = $parts[0];
  220. $columns = count($parts) > 1 ? $parts[1] : '';
  221. $clause = Clause::where('label', $cell)->where('model', 'ilike', $model)->first();
  222. if(!$clause){
  223. DB::rollBack();
  224. return $this->fail('No clause record found for ' . $cell);
  225. }
  226. $parentClauses[] = $clause->label;
  227. }
  228. $parentClauses = implode("|", $parentClauses);
  229. if(@$parents[$parentClauses]) {
  230. $statTreeLine->parent_stat_tree_line_id = $parents[$parentClauses]->id;
  231. $statTreeLine->save();
  232. }
  233. }
  234. }
  235. DB::commit();
  236. return $this->pass();
  237. }
  238. public function clausesJSON(Request $request, StatTree $statTree) {
  239. $clauses = Clause::where('model', $statTree->model)->orderBy('position_index')->get();
  240. $nodes = [];
  241. foreach ($clauses as $clause) {
  242. $children = [];
  243. // clause text child
  244. $children[] = [
  245. "text" => $clause->clause_text,
  246. "icon" => "fa fa-laptop-code text-primary text-sm",
  247. "state" => [
  248. "opened" => false,
  249. "disabled" => false,
  250. "selected" => false,
  251. ],
  252. "li_attr" => [
  253. "type" => "clause_text"
  254. ],
  255. "a_attr" => [
  256. "title" => $clause->clause_text,
  257. ],
  258. "data" => [
  259. "type" => "clause_text"
  260. ]
  261. ];
  262. // clause arg children
  263. $argsSystem = [];
  264. foreach ($clause->clauseArgs as $clauseArg) {
  265. $children[] = [
  266. "text" => $clauseArg->arg_text . '<span class="text-secondary text-sm ml-2">' . $clauseArg->field_type . '</span>',
  267. "icon" => "fa fa-cubes text-info",
  268. "state" => [
  269. "opened" => true,
  270. "disabled" => false,
  271. "selected" => false,
  272. ],
  273. "data" => [
  274. "type" => "clause_arg",
  275. "id" => $clauseArg->id,
  276. "uid" => $clauseArg->uid,
  277. "argText" => $clauseArg->arg_text,
  278. "fieldType" => $clauseArg->field_type,
  279. "clauseId" => $clause->id
  280. ]
  281. ];
  282. $argsSystem[] = [
  283. "arg_text" => $clauseArg->arg_text,
  284. "field_type" => $clauseArg->field_type,
  285. "value" => null,
  286. "access_level" => null
  287. ];
  288. }
  289. $nodes[] = [
  290. "text" => $clause->label,
  291. "state" => [
  292. "opened" => true,
  293. "disabled" => false,
  294. "selected" => false,
  295. ],
  296. "children" => $children,
  297. "data" => [
  298. "type" => "clause",
  299. "id" => $clause->id,
  300. "uid" => $clause->uid,
  301. "model" => $clause->model,
  302. "question" => $clause->question,
  303. "answer" => $clause->answer,
  304. "label" => $clause->label,
  305. "clauseText" => $clause->clause_text,
  306. "clauseId" => $clause->id,
  307. "args" => $argsSystem
  308. ],
  309. "a_attr" => [
  310. "title" => $clause->clause_text,
  311. ],
  312. ];
  313. }
  314. return json_encode($nodes);
  315. }
  316. private function cleanupClause($clauseText)
  317. {
  318. //Dont include empty clauses, i.e ()
  319. preg_match('#\((.*?)\)#', $clauseText, $match);
  320. $content = @$match[1];
  321. if (!$content || empty($content)) return null;
  322. return $content;
  323. }
  324. private function applyStatTreeLineQueryClauses(StatTreeLine $statTreeLine, $proUid = false)
  325. {
  326. $model = $statTreeLine->statTree->model;
  327. $clauses = [];
  328. foreach ($statTreeLine->lineClauses as $lineClause) {
  329. $clauseText = $lineClause->clause->clause_text;
  330. // apply arg values
  331. foreach ($lineClause->clause->clauseArgs as $clauseArg) {
  332. $value = null;
  333. foreach ($lineClause->lineClauseArgs as $lineClauseArg) {
  334. if($lineClauseArg->clause_arg_id === $clauseArg->id) {
  335. $value = $lineClauseArg->value;
  336. }
  337. }
  338. if(!is_null($value)) {
  339. $clauseText = str_replace(
  340. ':' . $clauseArg->arg_text, // search for :xxx
  341. "'" . $value . "'::" . $clauseArg->field_type, // replace with '$value'::$field_type
  342. $clauseText);
  343. }
  344. }
  345. //dump($clauseText);
  346. /*$isValid = $this->cleanupClause($clauseText);
  347. if ($isValid) {*/
  348. array_push($clauses, $clauseText);
  349. //}
  350. }
  351. // if stat tree bound to a pro, apply pro_scope_clause
  352. if(!$proUid) {
  353. if($statTreeLine->statTree->pro && $statTreeLine->statTree->pro_scope_clause) {
  354. $clauses[] = str_replace('@PRO_ID', $statTreeLine->statTree->pro->id, $statTreeLine->statTree->pro_scope_clause);
  355. }
  356. }
  357. else {
  358. $mvPro = Pro::where('uid', $proUid)->first();
  359. if($statTreeLine->statTree->pro_scope_clause) {
  360. $clauses[] = str_replace('@PRO_ID', $mvPro->id, $statTreeLine->statTree->pro_scope_clause);
  361. }
  362. }
  363. $query = 'SELECT COUNT(*) FROM '.$model.' WHERE '. implode(" AND ", $clauses);
  364. try {
  365. //dump($query);
  366. $result = DB::select($query);
  367. }
  368. catch (\Exception $ex) {
  369. $result = 'error';
  370. }
  371. return $result;
  372. }
  373. private function applyStatTreeLineQueryClausesGroupByPros(StatTreeLine $statTreeLine, $proUids)
  374. {
  375. $model = $statTreeLine->statTree->model;
  376. $clauses = [];
  377. foreach ($statTreeLine->lineClauses as $lineClause) {
  378. $clauseText = $lineClause->clause->clause_text;
  379. // apply arg values
  380. foreach ($lineClause->clause->clauseArgs as $clauseArg) {
  381. $value = null;
  382. foreach ($lineClause->lineClauseArgs as $lineClauseArg) {
  383. if($lineClauseArg->clause_arg_id === $clauseArg->id) {
  384. $value = $lineClauseArg->value;
  385. }
  386. }
  387. if(!is_null($value)) {
  388. $clauseText = str_replace(
  389. ':' . $clauseArg->arg_text, // search for :xxx
  390. "'" . $value . "'::" . $clauseArg->field_type, // replace with '$value'::$field_type
  391. $clauseText);
  392. }
  393. }
  394. //dump($clauseText);
  395. /*$isValid = $this->cleanupClause($clauseText);
  396. if ($isValid) {*/
  397. array_push($clauses, $clauseText);
  398. //}
  399. }
  400. // if stat tree bound to a pro, apply pro_scope_clause
  401. /*if(!$proUid) {
  402. if($statTreeLine->statTree->pro && $statTreeLine->statTree->pro_scope_clause) {
  403. $clauses[] = str_replace('@PRO_ID', $statTreeLine->statTree->pro->id, $statTreeLine->statTree->pro_scope_clause);
  404. }
  405. }
  406. else {
  407. $mvPro = Pro::where('uid', $proUid)->first();
  408. if($statTreeLine->statTree->pro_scope_clause) {
  409. $clauses[] = str_replace('@PRO_ID', $mvPro->id, $statTreeLine->statTree->pro_scope_clause);
  410. }
  411. $query = 'SELECT COUNT(*) FROM '.$model.' WHERE '. implode(" AND ", $clauses);
  412. }*/
  413. $proUids = explode(",", $proUids);
  414. $proUids = array_map(function($_x) {
  415. return "'{$_x}'";
  416. }, $proUids);
  417. $clauses[] = "_j_pro.uid IN (" . implode(",", $proUids) . ")";
  418. $proJoinClause = 'JOIN pro _j_pro on ' . str_replace('@PRO_ID', '_j_pro.id', $statTreeLine->statTree->pro_scope_clause);
  419. $query = "SELECT COUNT(*), _j_pro.uid as _v_pro_uid FROM {$model} {$proJoinClause} WHERE " . implode(" AND ", $clauses) . " GROUP BY _j_pro.uid";
  420. try {
  421. //dump($query);
  422. $result = DB::select($query);
  423. }
  424. catch (\Exception $ex) {
  425. $result = 'error';
  426. }
  427. return $result;
  428. }
  429. public function linesJSON(Request $request, StatTree $statTree) {
  430. // refresh counts
  431. $lines = $statTree->lines;
  432. foreach ($lines as $line) {
  433. $query = $this->applyStatTreeLineQueryClauses($line, $request->input('proUid'));
  434. if ($query && $query !== 'error') {
  435. $line->last_refresh_count = $query[0]->count;
  436. }
  437. else {
  438. $line->last_refresh_count = -1;
  439. }
  440. $line->save();
  441. }
  442. $nodes = [];
  443. foreach ($statTree->rootLines as $rootLine) {
  444. $nodes[] = $this->lineObject($rootLine);
  445. }
  446. return json_encode($nodes);
  447. }
  448. public function getCountsForPro(Request $request) {
  449. $statTreeUid = $request->get('uid');
  450. if (!$statTreeUid) return $this->fail('No specified stat tree!');
  451. $statTree = StatTree::where('uid', $statTreeUid)->first();
  452. $lines = $statTree->lines;
  453. $result = [];
  454. foreach ($lines as $line) {
  455. $query = $this->applyStatTreeLineQueryClauses($line, $request->input('proUid'));
  456. if ($query && $query !== 'error') {
  457. $result[$line->uid] = $query[0]->count;
  458. }
  459. else {
  460. $result[$line->uid] = -1;
  461. }
  462. }
  463. return json_encode($result);
  464. }
  465. public function getCountsForPros(Request $request) {
  466. $statTreeUid = $request->get('uid');
  467. if (!$statTreeUid) return $this->fail('No specified stat tree!');
  468. $statTree = StatTree::where('uid', $statTreeUid)->first();
  469. $lines = $statTree->lines;
  470. $result = [];
  471. foreach ($lines as $line) {
  472. $query = $this->applyStatTreeLineQueryClausesGroupByPros($line, $request->input('proUids'));
  473. if ($query && $query !== 'error') {
  474. $result[$line->uid] = $query;
  475. }
  476. else {
  477. $result[$line->uid] = -1;
  478. }
  479. }
  480. return json_encode($result);
  481. }
  482. private function lineObject(StatTreeLine $line) {
  483. // columns
  484. $columns = [];
  485. foreach ($line->reportColumns as $column) {
  486. $columns[] = [
  487. "label" => $column->label,
  488. "display_key" => $column->display_key,
  489. "type" => $column->field_type
  490. ];
  491. }
  492. // clause
  493. $lineClause = $line->displayLineClause();
  494. $args = [];
  495. $argsLabel = [];
  496. foreach($lineClause->lineClauseArgs as $stlcArg) {
  497. if($stlcArg->clauseArg) {
  498. $args[] = [
  499. "arg_text" => $stlcArg->clauseArg->arg_text,
  500. "field_type" => $stlcArg->clauseArg->field_type,
  501. "value" => $stlcArg->value,
  502. "access_level" => $stlcArg->access_level
  503. ];
  504. $argsLabel[] = $stlcArg->clauseArg->arg_text . ': ' . $stlcArg->value;
  505. }
  506. }
  507. $clause = [
  508. "clause_id" => $lineClause->clause_id,
  509. "clause_label" => $lineClause->clause_label,
  510. "position_index" => $lineClause->position_index,
  511. "args" => $args
  512. ];
  513. $children = [];
  514. foreach ($line->children as $child) {
  515. $children[] = $this->lineObject($child);
  516. }
  517. return [
  518. "text" => '<span class="stat-tree-anchor">' . $line->displayLabel() . '</span>' .
  519. (count($argsLabel) ? '<span class="text-info text-sm ml-2">[' . implode(', ', $argsLabel) . ']</span>' : '') .
  520. '<span class="ml-2 text-secondary line-count-label">(' .
  521. (is_null($line->last_refresh_count) ? '…' :
  522. ($line->last_refresh_count === -1 ?
  523. '<span class="text-danger text-sm font-weight-bold"><i class="fa fa-exclamation-triangle"></i> Query error / missing arg values</span>' :
  524. $line->last_refresh_count)) .
  525. ')</span>',
  526. "state" => [
  527. "opened" => true,
  528. "disabled" => false,
  529. "selected" => false,
  530. ],
  531. "children" => $children,
  532. "data" => [
  533. "type" => "stat_tree_line",
  534. "id" => $line->id,
  535. "uid" => $line->uid,
  536. "displayLabel" => $line->displayLabel(),
  537. "extendedLabel" => $line->displayLabel() . (count($argsLabel) ? ' [' . implode(', ', $argsLabel) . ']' : ''),
  538. "lastRefreshCount" => $line->last_refresh_count,
  539. "treeOrderPositionIndex" => $line->tree_order_position_index,
  540. "columns" => $columns,
  541. "clause" => $clause
  542. ],
  543. "a_attr" => [
  544. "title" => $line->displayLineClause()->clause->clause_text
  545. ]
  546. ];
  547. }
  548. public function replaceAllLinesJSON(Request $request) {
  549. $statTree = StatTree::where('uid', $request->get('uid'))->first();
  550. if(!$statTree) return $this->fail("Stat tree does not exist!");
  551. $lines = json_decode($request->get('data'));
  552. DB::beginTransaction();
  553. // cleanup junk
  554. DB::statement("DELETE FROM stat_tree_line WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  555. DB::statement("DELETE FROM stat_tree_line_clause WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  556. DB::statement("DELETE FROM stat_tree_line_clause_arg WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  557. DB::statement("DELETE FROM stat_tree_line_clause_arg_value WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  558. DB::statement("DELETE FROM stat_tree_line_report_column WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  559. // process
  560. for ($i=0; $i<count($lines); $i++) {
  561. $result = $this->saveStatTreeLine($lines[$i], $i, null, $statTree);
  562. if($result !== TRUE) {
  563. DB::rollBack();
  564. return $result;
  565. }
  566. }
  567. DB::commit();
  568. return $this->pass();
  569. }
  570. private function saveStatTreeLine($line, $position, $parentLine, $statTree) {
  571. // saved tree line
  572. $nextId = DB::select("select nextval('stat_tree_line_id_seq')");
  573. $statTreeLine = new StatTreeLine;
  574. $statTreeLine->id = $nextId[0]->nextval;
  575. $statTreeLine->uid = Uuid::uuid4();
  576. $statTreeLine->stat_tree_id = $statTree->id;
  577. $statTreeLine->tree_order_position_index = $position;
  578. $statTreeLine->last_refresh_count = null;
  579. $statTreeLine->tsv_text_for_report_columns = null;
  580. $statTreeLine->parent_stat_tree_line_id = $parentLine ? $parentLine->id : null;
  581. $statTreeLine->save();
  582. // -- clauses -- START
  583. // copy parent line clauses
  584. $maxParentClausePositionIndex = 0;
  585. if($parentLine && count($parentLine->lineClauses)) {
  586. foreach ($parentLine->lineClauses as $parentLineClause) {
  587. $nextId = DB::select("select nextval('stat_tree_line_clause_id_seq')");
  588. $statTreeLineClause = new StatTreeLineClause();
  589. $statTreeLineClause->id = $nextId[0]->nextval;
  590. $statTreeLineClause->uid = Uuid::uuid4();
  591. $statTreeLineClause->stat_tree_line_id = $statTreeLine->id; // this stat tree line
  592. $statTreeLineClause->clause_id = $parentLineClause->clause_id;
  593. $statTreeLineClause->clause_label = $parentLineClause->clause_label;
  594. $statTreeLineClause->position_index = $parentLineClause->position_index;
  595. if($statTreeLineClause->position_index > $maxParentClausePositionIndex) {
  596. $maxParentClausePositionIndex = $statTreeLineClause->position_index;
  597. }
  598. $statTreeLineClause->stat_tree_id = $statTree->id;
  599. $statTreeLineClause->save();
  600. // copy clause args for parent line clauses
  601. foreach ($parentLineClause->lineClauseArgs as $parentLineClauseArg) {
  602. $statTreeLineClauseArg = new StatTreeLineClauseArg();
  603. $nextId = DB::select("select nextval('stat_tree_line_clause_arg_id_seq')");
  604. $statTreeLineClauseArg->id = $nextId[0]->nextval;
  605. $statTreeLineClauseArg->stat_tree_line_clause_id = $statTreeLineClause->id; // this line cause
  606. $statTreeLineClauseArg->clause_arg_id = $parentLineClauseArg->clause_arg_id;
  607. $statTreeLineClauseArg->value = $parentLineClauseArg->value;
  608. $statTreeLineClauseArg->access_level = $parentLineClauseArg->access_level;
  609. $statTreeLineClauseArg->stat_tree_id = $statTree->id;
  610. $statTreeLineClauseArg->save();
  611. }
  612. }
  613. }
  614. // create own line clause (from clause.clause_label)
  615. $clause = Clause::where('label', $line->clause->clause_label)->where('model', 'ilike', $statTree->model)->first();
  616. if(!$clause) {
  617. return $this->fail('No clause record found for ' . $line->clause->clause_label);
  618. }
  619. $nextId = DB::select("select nextval('stat_tree_line_clause_id_seq')");
  620. $statTreeLineClause = new StatTreeLineClause();
  621. $statTreeLineClause->id = $nextId[0]->nextval;
  622. $statTreeLineClause->uid = Uuid::uuid4();
  623. $statTreeLineClause->stat_tree_line_id = $statTreeLine->id; // this stat tree line
  624. $statTreeLineClause->clause_id = $clause->id;
  625. $statTreeLineClause->clause_label = $line->clause->clause_label;
  626. $statTreeLineClause->position_index = $maxParentClausePositionIndex + 1;
  627. $statTreeLineClause->stat_tree_id = $statTree->id;
  628. $statTreeLineClause->save();
  629. // create args for own line clause
  630. foreach ($clause->clauseArgs as $clauseArg) {
  631. $statTreeLineClauseArg = new StatTreeLineClauseArg();
  632. $nextId = DB::select("select nextval('stat_tree_line_clause_arg_id_seq')");
  633. $statTreeLineClauseArg->id = $nextId[0]->nextval;
  634. $statTreeLineClauseArg->stat_tree_line_clause_id = $statTreeLineClause->id;
  635. $statTreeLineClauseArg->clause_arg_id = $clauseArg->id;
  636. $statTreeLineClauseArg->value = null;
  637. $statTreeLineClauseArg->access_level = 'ADMIN';
  638. for ($j=0; $j<count($line->clause->args); $j++) { // find the arg matching text and type from line->args and use that
  639. if($line->clause->args[$j]->arg_text === $clauseArg->arg_text &&
  640. $line->clause->args[$j]->field_type === $clauseArg->field_type) {
  641. $statTreeLineClauseArg->value = $line->clause->args[$j]->value;
  642. $statTreeLineClauseArg->access_level = $line->clause->args[$j]->access_level;
  643. break;
  644. }
  645. }
  646. $statTreeLineClauseArg->stat_tree_id = $statTree->id;
  647. $statTreeLineClauseArg->save();
  648. }
  649. // -- clauses -- END
  650. // columns
  651. for ($i=0; $i<count($line->columns); $i++) {
  652. $column = new StatTreeLineReportColumn();
  653. $nextId = DB::select("select nextval('stat_tree_line_report_column_id_seq')");
  654. $column->id = $nextId[0]->nextval;
  655. $column->uid = Uuid::uuid4();
  656. $column->stat_tree_line_id = $statTreeLine->id;
  657. $column->label = $line->columns[$i]->label;
  658. $column->display_key = $line->columns[$i]->display_key;
  659. $column->field_type = $line->columns[$i]->type;
  660. $column->position_index = $i;
  661. $column->stat_tree_id = $statTree->id;
  662. $column->save();
  663. }
  664. // child lines
  665. for ($i=0; $i<count($line->children); $i++) {
  666. $result = $this->saveStatTreeLine($line->children[$i], $i, $statTreeLine, $statTree);
  667. if($result !== TRUE) {
  668. DB::rollBack();
  669. return $result;
  670. }
  671. }
  672. return TRUE;
  673. }
  674. public function refreshTreeCountQueries(Request $request)
  675. {
  676. $statTreeID = $request->get('statTreeID');
  677. if (!$statTreeID) return $this->fail('No specified stat tree!');
  678. $statTree = StatTree::where('id', $statTreeID)->first();
  679. if (!$statTree) return $this->fail('Invalid stat tree!');
  680. $lines = $statTree->lines;
  681. foreach ($lines as $line) {
  682. $query = $this->applyStatTreeLineQueryClauses($line);
  683. if ($query && $query !== 'error') {
  684. $line->last_refresh_count = $query[0]->count;
  685. }
  686. else {
  687. $line->last_refresh_count = -1;
  688. }
  689. $line->save();
  690. }
  691. return $this->pass();
  692. }
  693. }