统计平台-脚本系列1

发货统计（多进程，前后30天每天的日期）

最近正在做的统计平台是关于整个中型电商网站的各项数据统计与展示，目前用到的技术是ELK，以后会慢慢把整个平台架构都写进来，今天先写一个模块-发货统计。

• 首先，统计的基数，当前采用的是统计每天收订的订单数量，即已支付订单，不考虑取消和退换货的情况。
• 其次，统计的维度，以每天和订单商品id为唯一值 ，以部门，sku，品牌，品类，季节，库龄，价格，性别，模式（自营与联营），仓库等为维度，来统计当天的发货量，销售量，发货率，发货毛利额，毛利率，签收数量，发货与签收时长类型。
• 最后，脚本的启动,因为是以每天的收定数量为基数，因此在订单支付以后的每一天里，都会有发货信息与签收数据更新，所以需要每天更新前15天的数据，以下为启动代码：

$statistical_dates = array();
for($i=1;$i<15;$i++){
    $statistical_dates[$i] = date("Y-m-d",strtotime('-'.$i.'day'));
    //此处调用真正跑的脚本。。
}
//因为需要计算当天之前15天的每一天的日期，所以用了strtotime，突然想起来，客服预约的日期展示，从今天开始30天内可以预约的日期，也可以用相同的函数处理：
$week_array=array("日","一","二","三","四","五","六");
$days=array();
for($i=0;$i<30;$i++){
    $days[$i]['time']=date("m-d",strtotime('+'.$i.'day'));
    if ($i==0) {
        $days[$i]['week']= '今';
    }else{
        $days[$i]['week']= $week_array[date("w",strtotime('+'.$i.'day'))];
    }
    $num = 1; //此处获取一下当天可以预约的数量。。
    if (empty($num)) {
        $num = 2;
    }
    $days[$i]['num']=$num;
}

也可以采用PHP多进程来处理，同时跑很多天的数据，可以节省很多时间：
以下是官方文档的代码：

<?php

$pid = pcntl_fork();
//父进程和子进程都会执行下面代码
if ($pid == -1) {
    //错误处理：创建子进程失败时返回-1.
     die('could not fork');
} else if ($pid) {
     //父进程会得到子进程号，所以这里是父进程执行的逻辑
     pcntl_wait($status); //等待子进程中断，防止子进程成为僵尸进程。
} else {
     //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。
}

?>

拿来加在代码里以后发现还是启动了一个脚本，并没有同时启动很多个脚本，后来才发现

在else if那段父进程里，暂时不要wait，把父进程放到一个数组里，到循环完成以后，再释放，就可以同时启动多个脚本来恢复一段时间内每一天的数据了

<?php
$pids = array();
//循环要循环的数据
foreach ($codes_info as $code_info) {
    $pid = pcntl_fork();
    //父进程和子进程都会执行下面代码
    if($pid == -1) {
        //错误处理：创建子进程失败时返回-1.
        die('error','could not fork');
    }elseif($pid) {
        //父进程会得到子进程号，所以这里是父进程执行的逻辑 父进程挂起
        $pids[] = $pid;
    }else{
        pcntl_exec('/usr/bin/php',array('cron.php','方法','参数';//这里调用要执行的每一天的脚本
    }
}
foreach ($pids as $npid) {
    if($npid) {
        pcntl_waitpid($npid, $status);
    }
}
?>