服务器发送的事件直到脚本完成才更新

我有一个更新数据库的小脚本。目前处理大约需要一分钟左右的时间，但随着数据库的增加，时间会增加。我想在脚本运行时向用户提供更新，以便他们知道脚本的状态以及它是否仍在运行。我实现了服务器端事件，当它工作时，在脚本完全完成之前，不会将任何更新发布到网站上。

我可以上传整个脚本文件，但这里是相关的部分。

首先，在脚本开始时，我检查脚本是否从命令行运行，如果不是，我会发送标题，如图所示：

$cli = (PHP_SAPI === 'cli') ? 1 : 0;
if(!$cli){
    header( 'Content-Type: text/event-stream' );
    header( 'Cache-Control: no-cache' );
}

这是我在调用时发送sse_message的函数

function sse_message( $type, $message, $progress=0 )
{
    $d = array("type" => $type, "msg" => $message , "progress" => $progress);
    $id = time();
    echo "id: $id" . PHP_EOL;
    echo "data: " . json_encode($d) . PHP_EOL;
    echo PHP_EOL;
    ob_flush();
    flush();
}

最后是我的监听器的javascript实现：

if( typeof(EventSource) !== "undefined" ){
    source = new EventSource( "../priv3/script/prowip_process.php" );
    source.addEventListener("message", function(e)
    {
        var result = JSON.parse(e.data);
        switch(result.type){
            case "update":
                if( result.msg != "" )
                    document.getElementById("prowip_status").value += "'n[INFO]: "+result.msg;
                document.getElementById("prowip_progress").value = result.progress;
                break;
            case "success":
                document.getElementById("prowip_status").value += "'n[COMPLETED]:"+result.msg;
                document.getElementById("prowip_progress").value = 100;
                document.getElementById("button_prowip_exit").disabled = false;
                source.close();
                break;
            case "error":
                document.getElementById("prowip_status").value += "'n[ERROR]: "+result.msg;
                document.getElementById("button_prowip_exit").disabled = false;
                source.close();
                break;      
        }
    }, false);
}
else{
    document.getElementById("prowip_status").value += "'n'n[ERROR]: Your browser does not support server-sent events.  Please upgrade your browser or use a different browser for this function.  Please note this script will not work with Internet Explorer."
    document.getElementById("button_prowip_exit").disabled = false;
}

同样，一切都很完美，只是在脚本过程中没有发生更新，然后当它完成所有消息和进度条时就会更新。

我已经在几个浏览器、计算机等中尝试过这种方法，但在整个脚本完成之前，不会对网页进行任何更新。

如有任何帮助或意见，我们将不胜感激。谢谢

2015年4月3日编辑，根据要求发布更多代码

这3个函数为CLI调用sse_message或仅echo。

function show_error( $cli, $message )
{
    if ($cli)
        echo $message."'n";
    else
        sse_message( "error", $message );
}
function show_message( $cli, $message, $progress )
{
    if ($cli)
        echo $message."[".$progress."%]'n";
    else
        sse_message( "update", $message, $progress );
}
function show_success( $cli, $message )
{
    if ($cli)
        echo $message."[100%]'n";
    else
        sse_message( "success", $message );
}

以下是主函数的剪辑，显示了这些函数的调用方式：

foreach ( $projects as $number => $project ) {
            $cn = strtok($number, "." );
            $pn = strtok(".");
            $wipover = $project['wip'] - $project['wip30'] - $project['wip60'] - $project['wip90'];
            $arover = $project['ar'] - $project['ar30'] - $project['ar60'] - $project['ar90'];
            $process_counter++;
            if( $process_counter >= $check ){
                $progress+=5;
                $check += intval ( $counter / 16 );
                show_message($cli,"",$progress);
            }
            if( ($project['empty']==1) and ($project['wip']==0) and ($project['ar']==0) ){
                //Do nothing...
            }
            else{
                $write_counter++;
                $update_query = "update projects set wip='{$project['wip']}', wip30='{$project['wip30']}', wip60='{$project['wip60']}', wip90='{$project['wip90']}', wipover='$wipover', ar='{$project['ar']}', ar30='{$project['ar30']}', ar60='{$project['ar60']}', ar90='{$project['ar90']}', arover='$arover' where client_num='$cn' and new_num='$pn'";
                if( ! $db->query( $update_query ) ){
                    show_error( $cli, "ERROR - update query: [$update_query] returned error: [".$db->error."]", $progress );
                }
            }
        }