* Finish task #83942.

2023-02-07 10:17:09 +08:00
parent 42144fb719
commit ed7d5cc4dd
7 changed files with 157 additions and 32 deletions
@@ -971,6 +971,8 @@ class programplanModel extends model
                    {
                        $this->action->create('execution', $stageID, 'opened');
                    }
+
+                    $this->computeProgress($stageID, 'create');
                }
            }

@@ -1380,4 +1382,73 @@ class programplanModel extends model

        return $parentStage;
    }
+
+    /**
+     * Compute stage status.
+     *
+     * @param  int    $stage
+     * @param  strihg $action
+     * @access public
+     * @return void
+     */
+    public function computeProgress($stageID, $action = '')
+    {
+        $stage = $this->loadModel('execution')->getByID($stageID);
+        if(empty($stage) or empty($stage->path) or $stage->type != 'stage') return false;
+
+        $this->loadModel('execution');
+        $this->loadModel('action');
+        $action       = strtolower($action);
+        $parentIdList = explode(',', trim($stage->path, ','));
+        $parentIdList = array_reverse($parentIdList);
+        foreach($parentIdList as $id)
+        {
+            $parent = $this->execution->getByID($id);
+            if($parent->type != 'stage' or $id == $stageID) continue;
+
+            $statusCount = array();
+            $children    = $this->execution->getChildExecutions($parent->id);
+            foreach($children as $childID => $childExecution) $statusCount[$childExecution->status] = empty($statusCount[$childExecution->status]) ? 1 : $statusCount[$childExecution->status] ++;
+
+            if(isset($statusCount['wait']) and count($statusCount) == 1)
+            {
+                if($parent->status != 'wait')
+                {
+                    $parentStatus = 'wait';
+                    $parentAction = 'waitbychild';
+                }
+            }
+            elseif(isset($statusCount['suspended']) and count($statusCount) == 1)
+            {
+                if($parent->status != 'suspended')
+                {
+                    $parentStatus = 'suspended';
+                    $parentAction = 'suspendedbychild';
+                }
+            }
+            elseif(isset($statusCount['closed']) and count($statusCount) == 1)
+            {
+                if($parent->status != 'closed')
+                {
+                    $parentStatus = 'closed';
+                    $parentAction = 'closedbychild';
+                }
+            }
+            else
+            {
+                if($parent->status != 'doing')
+                {
+                    $parentStatus = 'doing';
+                    $parentAction = 'startbychild' . $action;
+                }
+            }
+
+            if(isset($parentStatus))
+            {
+                $this->dao->update(TABLE_EXECUTION)->set('status')->eq($parentStatus)->where('id')->eq($id)->exec();
+                $this->action->create('execution', $id, $parentAction, '', $parentAction);
+            }
+            unset($parentStatus, $parentAction);
+        }
+    }
 }