StatTreeController.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791
  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('label')->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" => false,
  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" => false,
  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, $allInputs = [])
  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 override available - replace with that
  339. if(@$allInputs['st__' . $clauseArg->arg_text]) {
  340. $value = $allInputs['st__' . $clauseArg->arg_text];
  341. }
  342. if(!is_null($value)) {
  343. $clauseText = str_replace(
  344. ':' . $clauseArg->arg_text, // search for :xxx
  345. "'" . $value . "'::" . $clauseArg->field_type, // replace with '$value'::$field_type
  346. $clauseText);
  347. }
  348. }
  349. //dump($clauseText);
  350. /*$isValid = $this->cleanupClause($clauseText);
  351. if ($isValid) {*/
  352. array_push($clauses, $clauseText);
  353. //}
  354. }
  355. // if stat tree bound to a pro, apply pro_scope_clause
  356. if(!$proUid) {
  357. if($statTreeLine->statTree->pro && $statTreeLine->statTree->pro_scope_clause) {
  358. $clauses[] = str_replace('@PRO_ID', $statTreeLine->statTree->pro->id, $statTreeLine->statTree->pro_scope_clause);
  359. }
  360. }
  361. else {
  362. $mvPro = Pro::where('uid', $proUid)->first();
  363. if($statTreeLine->statTree->pro_scope_clause) {
  364. $clauses[] = str_replace('@PRO_ID', $mvPro->id, $statTreeLine->statTree->pro_scope_clause);
  365. }
  366. }
  367. $query = 'SELECT COUNT(*) FROM '.$model.' WHERE '. implode(" AND ", $clauses);
  368. try {
  369. //dump($query);
  370. $result = DB::select($query);
  371. }
  372. catch (\Exception $ex) {
  373. $result = 'error';
  374. }
  375. return $result;
  376. }
  377. private function applyStatTreeLineQueryClausesGroupByPros(StatTreeLine $statTreeLine, $proUids)
  378. {
  379. $model = $statTreeLine->statTree->model;
  380. $clauses = [];
  381. foreach ($statTreeLine->lineClauses as $lineClause) {
  382. $clauseText = $lineClause->clause->clause_text;
  383. // apply arg values
  384. foreach ($lineClause->clause->clauseArgs as $clauseArg) {
  385. $value = null;
  386. foreach ($lineClause->lineClauseArgs as $lineClauseArg) {
  387. if($lineClauseArg->clause_arg_id === $clauseArg->id) {
  388. $value = $lineClauseArg->value;
  389. }
  390. }
  391. if(!is_null($value)) {
  392. $clauseText = str_replace(
  393. ':' . $clauseArg->arg_text, // search for :xxx
  394. "'" . $value . "'::" . $clauseArg->field_type, // replace with '$value'::$field_type
  395. $clauseText);
  396. }
  397. }
  398. //dump($clauseText);
  399. /*$isValid = $this->cleanupClause($clauseText);
  400. if ($isValid) {*/
  401. array_push($clauses, $clauseText);
  402. //}
  403. }
  404. // if stat tree bound to a pro, apply pro_scope_clause
  405. /*if(!$proUid) {
  406. if($statTreeLine->statTree->pro && $statTreeLine->statTree->pro_scope_clause) {
  407. $clauses[] = str_replace('@PRO_ID', $statTreeLine->statTree->pro->id, $statTreeLine->statTree->pro_scope_clause);
  408. }
  409. }
  410. else {
  411. $mvPro = Pro::where('uid', $proUid)->first();
  412. if($statTreeLine->statTree->pro_scope_clause) {
  413. $clauses[] = str_replace('@PRO_ID', $mvPro->id, $statTreeLine->statTree->pro_scope_clause);
  414. }
  415. $query = 'SELECT COUNT(*) FROM '.$model.' WHERE '. implode(" AND ", $clauses);
  416. }*/
  417. $proUids = explode(",", $proUids);
  418. $proUids = array_map(function($_x) {
  419. return "'{$_x}'";
  420. }, $proUids);
  421. $clauses[] = "_j_pro.uid IN (" . implode(",", $proUids) . ")";
  422. $proJoinClause = 'JOIN pro _j_pro on ' . str_replace('@PRO_ID', '_j_pro.id', $statTreeLine->statTree->pro_scope_clause);
  423. $query = "SELECT COUNT(*), _j_pro.uid as _v_pro_uid FROM {$model} {$proJoinClause} WHERE " . implode(" AND ", $clauses) . " GROUP BY _j_pro.uid";
  424. try {
  425. //dump($query);
  426. $result = DB::select($query);
  427. }
  428. catch (\Exception $ex) {
  429. $result = 'error';
  430. }
  431. return $result;
  432. }
  433. public function linesJSON(Request $request, StatTree $statTree) {
  434. // refresh counts
  435. $lines = $statTree->lines;
  436. foreach ($lines as $line) {
  437. $query = $this->applyStatTreeLineQueryClauses($line, $request->input('proUid'), $request->input());
  438. if ($query && $query !== 'error') {
  439. $line->last_refresh_count = $query[0]->count;
  440. }
  441. else {
  442. $line->last_refresh_count = -1;
  443. }
  444. $line->save();
  445. }
  446. $nodes = [];
  447. foreach ($statTree->rootLines as $rootLine) {
  448. $nodes[] = $this->lineObject($rootLine);
  449. }
  450. return json_encode($nodes);
  451. }
  452. public function getCountsForPro(Request $request) {
  453. $statTreeUid = $request->get('uid');
  454. if (!$statTreeUid) return $this->fail('No specified stat tree!');
  455. $statTree = StatTree::where('uid', $statTreeUid)->first();
  456. $lines = $statTree->lines;
  457. $result = [];
  458. foreach ($lines as $line) {
  459. $query = $this->applyStatTreeLineQueryClauses($line, $request->input('proUid'));
  460. if ($query && $query !== 'error') {
  461. $result[$line->uid] = $query[0]->count;
  462. }
  463. else {
  464. $result[$line->uid] = -1;
  465. }
  466. }
  467. return json_encode($result);
  468. }
  469. public function getCountsForPros(Request $request) {
  470. $statTreeUid = $request->get('uid');
  471. if (!$statTreeUid) return $this->fail('No specified stat tree!');
  472. $statTree = StatTree::where('uid', $statTreeUid)->first();
  473. $lines = $statTree->lines;
  474. $result = [];
  475. foreach ($lines as $line) {
  476. $query = $this->applyStatTreeLineQueryClausesGroupByPros($line, $request->input('proUids'));
  477. if ($query && $query !== 'error') {
  478. $result[$line->uid] = $query;
  479. }
  480. else {
  481. $result[$line->uid] = -1;
  482. }
  483. }
  484. return json_encode($result);
  485. }
  486. private function lineObject(StatTreeLine $line) {
  487. // columns
  488. $columns = [];
  489. foreach ($line->reportColumns as $column) {
  490. $columns[] = [
  491. "label" => $column->label,
  492. "display_key" => $column->display_key,
  493. "type" => $column->field_type
  494. ];
  495. }
  496. // clause
  497. $lineClause = $line->displayLineClause();
  498. $args = [];
  499. $argsLabel = [];
  500. foreach($lineClause->lineClauseArgs as $stlcArg) {
  501. if($stlcArg->clauseArg) {
  502. $args[] = [
  503. "arg_text" => $stlcArg->clauseArg->arg_text,
  504. "field_type" => $stlcArg->clauseArg->field_type,
  505. "value" => $stlcArg->value,
  506. "access_level" => $stlcArg->access_level
  507. ];
  508. $argsLabel[] = $stlcArg->clauseArg->arg_text . ': ' . $stlcArg->value;
  509. }
  510. }
  511. $clause = [
  512. "clause_id" => $lineClause->clause_id,
  513. "clause_label" => $lineClause->clause_label,
  514. "position_index" => $lineClause->position_index,
  515. "args" => $args
  516. ];
  517. $children = [];
  518. foreach ($line->children as $child) {
  519. $children[] = $this->lineObject($child);
  520. }
  521. return [
  522. "text" => '<span class="stat-tree-anchor">' .
  523. '<span class="text-secondary text-sm">' . ($line->tree_order_position_index + 1) . '.</span> ' .
  524. $line->displayLabel() . '</span>' .
  525. (count($argsLabel) ? '<span class="arg-label text-info text-sm ml-2">[' . implode(', ', $argsLabel) . ']</span>' : '') .
  526. '<span class="ml-2 text-secondary line-count-label">(' .
  527. (is_null($line->last_refresh_count) ? '…' :
  528. ($line->last_refresh_count === -1 ?
  529. '<span class="text-danger text-sm font-weight-bold"><i class="fa fa-exclamation-triangle"></i> Query error / missing arg values</span>' :
  530. $line->last_refresh_count)) .
  531. ')</span>',
  532. "state" => [
  533. "opened" => true,
  534. "disabled" => false,
  535. "selected" => false,
  536. ],
  537. "children" => $children,
  538. "data" => [
  539. "type" => "stat_tree_line",
  540. "id" => $line->id,
  541. "uid" => $line->uid,
  542. "displayLabel" => $line->displayLabel(),
  543. "extendedLabel" => $line->displayLabel() . (count($argsLabel) ? ' [' . implode(', ', $argsLabel) . ']' : ''),
  544. "lastRefreshCount" => $line->last_refresh_count,
  545. "treeOrderPositionIndex" => $line->tree_order_position_index,
  546. "columns" => $columns,
  547. "clause" => $clause,
  548. "goalPercent" => (is_null($line->goal_percent) ? -1 : $line->goal_percent),
  549. "goalCondition" => (is_null($line->goal_condition) ? '' : $line->goal_condition)
  550. ],
  551. "a_attr" => [
  552. "title" => $line->displayLineClause()->clause->clause_text
  553. ]
  554. ];
  555. }
  556. public function replaceAllLinesJSON(Request $request) {
  557. $statTree = StatTree::where('uid', $request->get('uid'))->first();
  558. if(!$statTree) return $this->fail("Stat tree does not exist!");
  559. $lines = json_decode($request->get('data'));
  560. DB::beginTransaction();
  561. // cleanup junk
  562. DB::statement("DELETE FROM stat_tree_line WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  563. DB::statement("DELETE FROM stat_tree_line_clause WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  564. DB::statement("DELETE FROM stat_tree_line_clause_arg WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  565. DB::statement("DELETE FROM stat_tree_line_clause_arg_value WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  566. DB::statement("DELETE FROM stat_tree_line_report_column WHERE stat_tree_id = :stat_tree_id", ['stat_tree_id' => $statTree->id]);
  567. // process
  568. for ($i=0; $i<count($lines); $i++) {
  569. $result = $this->saveStatTreeLine($lines[$i], $i, null, $statTree);
  570. if($result !== TRUE) {
  571. DB::rollBack();
  572. return $result;
  573. }
  574. }
  575. DB::commit();
  576. return $this->pass();
  577. }
  578. private function saveStatTreeLine($line, $position, $parentLine, $statTree) {
  579. // saved tree line
  580. $nextId = DB::select("select nextval('stat_tree_line_id_seq')");
  581. $statTreeLine = new StatTreeLine;
  582. $statTreeLine->id = $nextId[0]->nextval;
  583. $statTreeLine->uid = Uuid::uuid4();
  584. $statTreeLine->stat_tree_id = $statTree->id;
  585. $statTreeLine->tree_order_position_index = $position;
  586. $statTreeLine->last_refresh_count = null;
  587. $statTreeLine->tsv_text_for_report_columns = null;
  588. $statTreeLine->goal_condition = (!@$line->goalCondition ? null : $line->goalCondition);
  589. $statTreeLine->goal_percent = (!@$line->goalPercent || $line->goalPercent === -1 ? null : $line->goalPercent);
  590. $statTreeLine->parent_stat_tree_line_id = $parentLine ? $parentLine->id : null;
  591. $statTreeLine->save();
  592. // -- clauses -- START
  593. // copy parent line clauses
  594. $maxParentClausePositionIndex = 0;
  595. if($parentLine && count($parentLine->lineClauses)) {
  596. foreach ($parentLine->lineClauses as $parentLineClause) {
  597. $nextId = DB::select("select nextval('stat_tree_line_clause_id_seq')");
  598. $statTreeLineClause = new StatTreeLineClause();
  599. $statTreeLineClause->id = $nextId[0]->nextval;
  600. $statTreeLineClause->uid = Uuid::uuid4();
  601. $statTreeLineClause->stat_tree_line_id = $statTreeLine->id; // this stat tree line
  602. $statTreeLineClause->clause_id = $parentLineClause->clause_id;
  603. $statTreeLineClause->clause_label = $parentLineClause->clause_label;
  604. $statTreeLineClause->position_index = $parentLineClause->position_index;
  605. if($statTreeLineClause->position_index > $maxParentClausePositionIndex) {
  606. $maxParentClausePositionIndex = $statTreeLineClause->position_index;
  607. }
  608. $statTreeLineClause->stat_tree_id = $statTree->id;
  609. $statTreeLineClause->save();
  610. // copy clause args for parent line clauses
  611. foreach ($parentLineClause->lineClauseArgs as $parentLineClauseArg) {
  612. $statTreeLineClauseArg = new StatTreeLineClauseArg();
  613. $nextId = DB::select("select nextval('stat_tree_line_clause_arg_id_seq')");
  614. $statTreeLineClauseArg->id = $nextId[0]->nextval;
  615. $statTreeLineClauseArg->stat_tree_line_clause_id = $statTreeLineClause->id; // this line cause
  616. $statTreeLineClauseArg->clause_arg_id = $parentLineClauseArg->clause_arg_id;
  617. $statTreeLineClauseArg->value = $parentLineClauseArg->value;
  618. $statTreeLineClauseArg->access_level = $parentLineClauseArg->access_level;
  619. $statTreeLineClauseArg->stat_tree_id = $statTree->id;
  620. $statTreeLineClauseArg->save();
  621. }
  622. }
  623. }
  624. // create own line clause (from clause.clause_label)
  625. $clause = Clause::where('label', $line->clause->clause_label)->where('model', 'ilike', $statTree->model)->first();
  626. if(!$clause) {
  627. return $this->fail('No clause record found for ' . $line->clause->clause_label);
  628. }
  629. $nextId = DB::select("select nextval('stat_tree_line_clause_id_seq')");
  630. $statTreeLineClause = new StatTreeLineClause();
  631. $statTreeLineClause->id = $nextId[0]->nextval;
  632. $statTreeLineClause->uid = Uuid::uuid4();
  633. $statTreeLineClause->stat_tree_line_id = $statTreeLine->id; // this stat tree line
  634. $statTreeLineClause->clause_id = $clause->id;
  635. $statTreeLineClause->clause_label = $line->clause->clause_label;
  636. $statTreeLineClause->position_index = $maxParentClausePositionIndex + 1;
  637. $statTreeLineClause->stat_tree_id = $statTree->id;
  638. $statTreeLineClause->save();
  639. // create args for own line clause
  640. foreach ($clause->clauseArgs as $clauseArg) {
  641. $statTreeLineClauseArg = new StatTreeLineClauseArg();
  642. $nextId = DB::select("select nextval('stat_tree_line_clause_arg_id_seq')");
  643. $statTreeLineClauseArg->id = $nextId[0]->nextval;
  644. $statTreeLineClauseArg->stat_tree_line_clause_id = $statTreeLineClause->id;
  645. $statTreeLineClauseArg->clause_arg_id = $clauseArg->id;
  646. $statTreeLineClauseArg->value = null;
  647. $statTreeLineClauseArg->access_level = 'ADMIN';
  648. for ($j=0; $j<count($line->clause->args); $j++) { // find the arg matching text and type from line->args and use that
  649. if($line->clause->args[$j]->arg_text === $clauseArg->arg_text &&
  650. $line->clause->args[$j]->field_type === $clauseArg->field_type) {
  651. $statTreeLineClauseArg->value = $line->clause->args[$j]->value;
  652. $statTreeLineClauseArg->access_level = $line->clause->args[$j]->access_level;
  653. break;
  654. }
  655. }
  656. $statTreeLineClauseArg->stat_tree_id = $statTree->id;
  657. $statTreeLineClauseArg->save();
  658. }
  659. // -- clauses -- END
  660. // columns
  661. for ($i=0; $i<count($line->columns); $i++) {
  662. $column = new StatTreeLineReportColumn();
  663. $nextId = DB::select("select nextval('stat_tree_line_report_column_id_seq')");
  664. $column->id = $nextId[0]->nextval;
  665. $column->uid = Uuid::uuid4();
  666. $column->stat_tree_line_id = $statTreeLine->id;
  667. $column->label = $line->columns[$i]->label;
  668. $column->display_key = $line->columns[$i]->display_key;
  669. $column->field_type = $line->columns[$i]->type;
  670. $column->position_index = $i;
  671. $column->stat_tree_id = $statTree->id;
  672. $column->save();
  673. }
  674. // child lines
  675. for ($i=0; $i<count($line->children); $i++) {
  676. $result = $this->saveStatTreeLine($line->children[$i], $i, $statTreeLine, $statTree);
  677. if($result !== TRUE) {
  678. DB::rollBack();
  679. return $result;
  680. }
  681. }
  682. return TRUE;
  683. }
  684. public function refreshTreeCountQueries(Request $request)
  685. {
  686. $statTreeID = $request->get('statTreeID');
  687. if (!$statTreeID) return $this->fail('No specified stat tree!');
  688. $statTree = StatTree::where('id', $statTreeID)->first();
  689. if (!$statTree) return $this->fail('Invalid stat tree!');
  690. $lines = $statTree->lines;
  691. foreach ($lines as $line) {
  692. $query = $this->applyStatTreeLineQueryClauses($line);
  693. if ($query && $query !== 'error') {
  694. $line->last_refresh_count = $query[0]->count;
  695. }
  696. else {
  697. $line->last_refresh_count = -1;
  698. }
  699. $line->save();
  700. }
  701. return $this->pass();
  702. }
  703. }