fixed TaskManager procedure added reinstall action

SE/se-lib/Route/UrlAction/TaskManager.php

@@ -41,19 +41,36 @@ class Route_UrlAction_TaskManager extends RouteBase {// TODO: UrlActionBase @see
 	}
 
 	public function reinstallAction() {
+		try {
+			$dropTableSql = "DROP TABLE `_SYNC_TASK_PERCENT`";
+			DBG::nicePrint($dropTableSql, '$dropTableSql');
+			DB::getPDO()->query($dropTableSql);
+		} catch (Exception $e) {
+			// SQLSTATE[42000]: Syntax error or access violation: 1305 PROCEDURE SES_USERS2.PROBLEMS__SYNC_PERCENT does not exist
+		}
+
 		$createTableSql = file_get_contents(__FILE__ . '.create__SYNC_TASK_PERCENT.sql');
 		DBG::nicePrint($createTableSql, '$createTableSql');
-		$dropProcedureSql = "DROP PROCEDURE `PROBLEMS__SYNC_PERCENT`";
-		DBG::nicePrint($dropProcedureSql, '$dropProcedureSql');
+		DB::getPDO()->query($createTableSql);
+
+		try {
+			$dropProcedureSql = "DROP PROCEDURE `PROBLEMS__SYNC_PERCENT`";
+			DBG::nicePrint($dropProcedureSql, '$dropProcedureSql');
+			DB::getPDO()->query($dropProcedureSql);
+		} catch (Exception $e) {
+			// SQLSTATE[42000]: Syntax error or access violation: 1305 PROCEDURE SES_USERS2.PROBLEMS__SYNC_PERCENT does not exist
+		}
+
 		$createProcedureSql = file_get_contents(__FILE__ . '.problems_sync_percent.sql');
 		DBG::nicePrint($createProcedureSql, '$createProcedureSql');
+		DB::getPDO()->query($createProcedureSql);
 	}
 
 	public function defaultAction() {
 		UI::gora();
 		UI::menu();
 		try {
-			// DB::getPDO()->query("CALL `PROBLEMS__SYNC_PERCENT`();");// TODO: BUG zamula
+			DB::getPDO()->query("CALL `PROBLEMS__SYNC_PERCENT`();");// TODO: BUG zamula
 			$id = 0;
 			$type = "";
 			if (!empty(V::get('ID_PROBLEM', 0, $_REQUEST, 'int'))) {

SE/se-lib/Route/UrlAction/TaskManager.php.create__SYNC_TASK_PERCENT.sql

@@ -1,10 +1,12 @@
 CREATE TABLE IF NOT EXISTS `_SYNC_TASK_PERCENT` (
   `ID_TASK` int(11) NOT NULL,
+  `ID_PARENT_TASK` int(11) NOT NULL DEFAULT 0,
   `A_PROBLEM_COMPLETE_PERCENT` varchar(6) NOT NULL DEFAULT '',
   `L_APPOITMENT_PERIOD` varchar(30) NOT NULL DEFAULT '',
   `A_SYNCHRONIZED` int(1) NOT NULL DEFAULT '0',
   `A_LAST_SYNC` varchar(20) DEFAULT '',
   `SYNC_SORT_PRIO` int(11) NOT NULL DEFAULT '0',
   `CHILDS_COUNT` int(11) NOT NULL DEFAULT '0',
-  `CHILDS_DONE_COUNT` int(11) NOT NULL DEFAULT '0'
+  `CHILDS_DONE_COUNT` int(11) NOT NULL DEFAULT '0',
+  UNIQUE KEY `ID_TASK` (`ID_TASK`)
 ) ENGINE=MyISAM DEFAULT CHARSET=latin2;

SE/se-lib/Route/UrlAction/TaskManager.php.problems_sync_percent.sql

@@ -1,83 +1,163 @@
 CREATE DEFINER=`root`@`localhost` PROCEDURE `PROBLEMS__SYNC_PERCENT`()
-BEGIN
+`proc_label`:BEGIN
 
-INSERT IGNORE INTO _SYNC_TASK_PERCENT (`ID_TASK`) SELECT `ID` FROM PROBLEMS;
+SET @updatedCnt = 1;
+
+INSERT IGNORE INTO _SYNC_TASK_PERCENT (`ID_TASK`, `ID_PARENT_TASK`) SELECT `ID`, `PARENT_ID` FROM PROBLEMS;
+
+-- update `_SYNC_TASK_PERCENT` set `A_LAST_SYNC` = NOW(); -- TODO test recurse up - RMME
+-- update `_SYNC_TASK_PERCENT` set `A_SYNCHRONIZED` = 1; -- TODO test recurse up - RMME
+-- update `_SYNC_TASK_PERCENT` set `A_SYNCHRONIZED` = 0 WHERE `ID_TASK`=1050; -- TODO test recurse up - RMME
 
 UPDATE `_SYNC_TASK_PERCENT` p, `PROBLEMS` t
 	SET p.`A_PROBLEM_COMPLETE_PERCENT` = REPLACE(t.`A_PROBLEM_COMPLETE_PERCENT`, "%", "")
 		, p.`L_APPOITMENT_PERIOD` = t.`L_APPOITMENT_PERIOD`
+		, p.`ID_PARENT_TASK` = t.`PARENT_ID`
 	WHERE p.`ID_TASK` = t.`ID`
 ;
 
+SET @updatedCnt = ROW_COUNT(); SELECT CONCAT("UPDATE 1 : updated ", @updatedCnt); -- DBG
+
 UPDATE `_SYNC_TASK_PERCENT` t
 	LEFT JOIN `PROBLEMS` p ON t.`ID_TASK` = p.`ID`
 	SET t.A_SYNCHRONIZED = 0
 	WHERE t.`A_LAST_SYNC` < p.`A_RECORD_CREATE_DATE` OR t.`A_LAST_SYNC` < p.`A_RECORD_UPDATE_DATE`
 ;
 
-SELECT @c:=COUNT(*) FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0;
+SET @updatedCnt = ROW_COUNT(); SELECT CONCAT("UPDATE 2 : updated ", @updatedCnt); -- DBG
+
+-- SELECT @c:=COUNT(*) FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0;
+-- SET @i = 0;
+-- WHILE @i < @c DO
+-- 	PREPARE stmt FROM "SELECT `ID_TASK` into @parent_id FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0 LIMIT ?,1";
+-- 	EXECUTE stmt USING @i;
+-- 	DEALLOCATE PREPARE stmt;
+-- 	select @parent_id;
+-- 	WHILE @parent_id <> 0 DO
+-- 		SELECT @parent_id := `PARENT_ID` FROM `PROBLEMS` WHERE `ID` = @parent_id;
+-- 		UPDATE `_SYNC_TASK_PERCENT` SET `A_SYNCHRONIZED` = 0 WHERE `ID_TASK` = @parent_id;
+-- 	END WHILE;
+-- 	SET @i = @i +1;
+-- END WHILE;
+
+-- set A_SYNCHRONIZED = 0 going up by recurse
 SET @i = 0;
-WHILE @i < @c DO
-	PREPARE stmt FROM "SELECT `ID_TASK` into @parent_id FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0 LIMIT ?,1";
-	EXECUTE stmt USING @i;
-	DEALLOCATE PREPARE stmt;
-	select @parent_id;
-	WHILE @parent_id <> 0 DO
-		SELECT @parent_id := `PARENT_ID` FROM `PROBLEMS` WHERE `ID` = @parent_id;
-		UPDATE `_SYNC_TASK_PERCENT` SET `A_SYNCHRONIZED` = 0 WHERE `ID_TASK` = @parent_id;
-	END WHILE;
-	SET @i = @i +1;
+SET @loopLomit = 100;
+SET @updatedCnt = 1;
+WHILE @i < @loopLomit and @updatedCnt > 0 DO
+	update `_SYNC_TASK_PERCENT` p
+		join `_SYNC_TASK_PERCENT` pp on(pp.`ID_TASK`=p.`ID_PARENT_TASK`)
+		set p.`A_SYNCHRONIZED`=0
+		where pp.`A_SYNCHRONIZED`!=0
+	;
+	SET @updatedCnt = ROW_COUNT();
+	SELECT CONCAT("LOOP 2 (", @i, "): updated ", @updatedCnt); -- DBG
+	SET @i = @i + 1;
 END WHILE;
 
-UPDATE `_SYNC_TASK_PERCENT` SET SYNC_SORT_PRIO = 0;
-SELECT @c:=COUNT(*) FROM `_SYNC_TASK_PERCENT` p1
-	LEFT JOIN `PROBLEMS` t1 ON p1.`ID_TASK` = t1.`PARENT_ID`
-	WHERE p1.`A_SYNCHRONIZED` = 0 AND  t1.`ID` IS NULL
-;
+-- UPDATE `_SYNC_TASK_PERCENT` SET `SYNC_SORT_PRIO` = 0;
+-- SELECT @c:=COUNT(*) FROM `_SYNC_TASK_PERCENT` p1
+-- 	LEFT JOIN `PROBLEMS` t1 ON p1.`ID_TASK` = t1.`PARENT_ID`
+-- 	WHERE p1.`A_SYNCHRONIZED` = 0 AND  t1.`ID` IS NULL
+-- ;
+-- SET @i = 0;
+-- WHILE @i < @c DO
+-- 	SET @sort_prio = 1000;
+-- 	SELECT @i;
+-- 	PREPARE stmt FROM "SELECT p1.`ID_TASK` into @parent_id FROM `_SYNC_TASK_PERCENT` p1
+-- 		LEFT JOIN `PROBLEMS` t1 ON p1.`ID_TASK` = t1.`PARENT_ID`
+-- 		WHERE p1.`A_SYNCHRONIZED` = 0 AND  t1.`ID` IS NULL LIMIT ?, 1"
+-- 	;
+-- 	EXECUTE stmt USING @i;
+-- 	DEALLOCATE PREPARE stmt;
+-- 	select @parent_id;
+-- 	UPDATE `_SYNC_TASK_PERCENT` SET `SYNC_SORT_PRIO` = @sort_prio WHERE `ID_TASK` = @parent_id;
+-- 	WHILE @parent_id <> 0 DO
+-- 		SET @sort_prio = @sort_prio - 1;
+-- 		SELECT @parent_id := `PARENT_ID` FROM `PROBLEMS` WHERE `ID` = @parent_id;
+-- 		UPDATE `_SYNC_TASK_PERCENT` SET `SYNC_SORT_PRIO` = @sort_prio WHERE `ID_TASK` = @parent_id;
+-- 	END WHILE;
+-- 	SET @i = @i + 1;
+-- END WHILE;
 
+-- set SYNC_SORT_PRIO - start from value 1000 for leaf and go up recurse and lover value
+-- select p.`ID_TASK`, p.`ID_PARENT_TASK`
+-- 		, IF((select count(1) as cnt from `_SYNC_TASK_PERCENT` sp where sp.`ID_PARENT_TASK` = p.`ID_TASK`) > 0, 0, 1000) as sort_prio
+-- 	from `_SYNC_TASK_PERCENT` p
+-- ;
+-- select p.`ID_TASK`, p.`ID_PARENT_TASK`
+-- 		, IF((select count(1) as cnt from `PROBLEMS` sp where sp.`PARENT_ID` = p.`ID_TASK`) > 0, 0, 1000) as sort_prio
+-- 	from `_SYNC_TASK_PERCENT` p
+-- ;
+-- set 1000 when is leaf - has no children
 SET @i = 0;
-WHILE @i < @c DO
-	SET @sort_prio = 1000;
-	SELECT @i;
-	PREPARE stmt FROM "SELECT p1.`ID_TASK` into @parent_id FROM `_SYNC_TASK_PERCENT` p1
-		LEFT JOIN `PROBLEMS` t1 ON p1.`ID_TASK` = t1.`PARENT_ID`
-		WHERE p1.`A_SYNCHRONIZED` = 0 AND  t1.`ID` IS NULL LIMIT ?, 1"
+SET @loopLomit = 100;
+SET @updatedCnt = 1;
+SET @sortPrio = 100;
+UPDATE `_SYNC_TASK_PERCENT` p
+	SET p.`SYNC_SORT_PRIO` = IF((select count(1) as cnt from `PROBLEMS` sp where sp.`PARENT_ID` = p.`ID_TASK`) > 0, 0, @sortPrio)
+;
+WHILE @i < @loopLomit and @updatedCnt > 0 DO
+	update `_SYNC_TASK_PERCENT` p
+		join `_SYNC_TASK_PERCENT` pp on(pp.`ID_TASK`=p.`ID_PARENT_TASK`)
+		set pp.`SYNC_SORT_PRIO` = IF(@sortPrio > pp.`SYNC_SORT_PRIO` and pp.`SYNC_SORT_PRIO` > 0, pp.`SYNC_SORT_PRIO` - 1, @sortPrio - 1)
+		where p.`SYNC_SORT_PRIO` = @sortPrio
 	;
-	EXECUTE stmt USING @i;
-	DEALLOCATE PREPARE stmt;
-	select @parent_id;
-	UPDATE `_SYNC_TASK_PERCENT` SET `SYNC_SORT_PRIO` = @sort_prio WHERE `ID_TASK` = @parent_id;
-	WHILE @parent_id <> 0 DO
-		SET @sort_prio = @sort_prio - 1;
-		SELECT @parent_id := `PARENT_ID` FROM `PROBLEMS` WHERE `ID` = @parent_id;
-		UPDATE `_SYNC_TASK_PERCENT` SET `SYNC_SORT_PRIO` = @sort_prio WHERE `ID_TASK` = @parent_id;
-	END WHILE;
+	SET @updatedCnt = ROW_COUNT();
 	SET @i = @i + 1;
+	SET @sortPrio = @sortPrio - 1;
+	SELECT CONCAT("LOOP 2 (", @i, "): updated ", @updatedCnt); -- DBG
 END WHILE;
 
+
 SELECT @c:=COUNT(*) FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0;
 SET @i = 0;
+SET @id = 0;
+SET @childs = 0;
+SELECT CONCAT("LOOP 3 @i(", @i, ") @c(", @c, ")"); -- DBG
 WHILE @i < @c DO
-	SELECT `ID_TASK` into @id FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0 ORDER BY `SYNC_SORT_PRIO` DESC LIMIT 0,1;
 	SET @i = @i + 1;
-	SELECT @childs:=COUNT(*) FROM `_SYNC_TASK_PERCENT` p1
-		LEFT JOIN `PROBLEMS` t1 ON p1.`ID_TASK` = t1.`PARENT_ID`
-		WHERE p1.`A_SYNCHRONIZED` = 0 AND t1.`PARENT_ID` = @id
+	SELECT CONCAT("LOOP 3 ..."); -- DBG
+	SELECT `ID_TASK` into @id FROM `_SYNC_TASK_PERCENT` WHERE `A_SYNCHRONIZED` = 0 ORDER BY `SYNC_SORT_PRIO` DESC, `ID_TASK` DESC LIMIT 0,1;
+	SELECT CONCAT("LOOP 3 (", @i, "): id ", @id); -- DBG
+	SELECT COUNT(*) into @childs FROM `_SYNC_TASK_PERCENT` p
+		WHERE p.`ID_PARENT_TASK` = @id
+		-- AND p.`A_SYNCHRONIZED` = 0
 	;
+	SELECT CONCAT("LOOP 3 (", @i, "): id (",@id,") childs(",@childs,")"); -- DBG
 	IF @childs = 0 THEN
-		UPDATE `_SYNC_TASK_PERCENT` SET A_SYNCHRONIZED = 1, A_LAST_SYNC = NOW(), `CHILDS_COUNT` = @childs WHERE `ID_TASK` = @id;
+		SELECT CONCAT("LOOP 3 (", @i, "): LIF0"); -- DBG
+		UPDATE `_SYNC_TASK_PERCENT` SET `A_SYNCHRONIZED` = 1, `A_LAST_SYNC` = NOW(), `CHILDS_COUNT` = @childs WHERE `ID_TASK` = @id;
+		SELECT CONCAT("LOOP 3 (", @i, "): LIF1"); -- DBG
 	ELSE
+		SELECT CONCAT("LOOP 3 (", @i, "): LE0"); -- DBG
+
 		SELECT @avg:=AVG(p2.`A_PROBLEM_COMPLETE_PERCENT`), @amount:=SUM(p2.`L_APPOITMENT_PERIOD`) FROM `_SYNC_TASK_PERCENT` p1
 			LEFT JOIN `PROBLEMS` t1 ON p1.`ID_TASK` = t1.`PARENT_ID`
 			LEFT JOIN `_SYNC_TASK_PERCENT` p2 ON p2.`ID_TASK` = t1.`ID`
 			WHERE p1.`A_SYNCHRONIZED` = 0 AND t1.`PARENT_ID` = @id
 		;
+
+		SELECT CONCAT("LOOP 3 (", @i, "): LE1"); -- DBG
+
 		SET @avg = ROUND(@avg);
-		UPDATE `_SYNC_TASK_PERCENT` SET A_SYNCHRONIZED = 1, A_PROBLEM_COMPLETE_PERCENT = @avg,L_APPOITMENT_PERIOD = @amount, A_LAST_SYNC = NOW(), `CHILDS_COUNT` = @childs WHERE `ID_TASK` = @id;
+		UPDATE `_SYNC_TASK_PERCENT`
+			SET `A_SYNCHRONIZED` = 1
+				, `A_PROBLEM_COMPLETE_PERCENT` = @avg
+				, `L_APPOITMENT_PERIOD` = @amount
+				, `A_LAST_SYNC` = NOW()
+				, `CHILDS_COUNT` = @childs
+			WHERE `ID_TASK` = @id
+		;
+
+		SELECT CONCAT("LOOP 3 (", @i, "): LE2"); -- DBG
+
 		SET @avg = ROUND(@avg/10)*10;
-		UPDATE `PROBLEMS` SET `A_PROBLEM_COMPLETE_PERCENT` = CONCAT(@avg, "%"),L_APPOITMENT_PERIOD = @amount, A_RECORD_UPDATE_DATE = NOW() WHERE `ID` = @id;
+		-- TODO UPDATE `PROBLEMS` SET `A_PROBLEM_COMPLETE_PERCENT` = CONCAT(@avg, "%"), `L_APPOITMENT_PERIOD` = @amount, `A_RECORD_UPDATE_DATE` = NOW() WHERE `ID` = @id;
 	END IF;
+
 	SELECT "TEST";
+
 	SELECT @childsdone:=COUNT(*) FROM `_SYNC_TASK_PERCENT` p
 		LEFT JOIN `PROBLEMS` t ON t.`ID` = p.`ID_TASK`
 		WHERE p.`A_PROBLEM_COMPLETE_PERCENT` = 100 AND t.`PARENT_ID` = @id