hlm_pl_mall/app/crontab/controller/Month.php

<?php

namespace app\crontab\controller;
use think\facade\Db;
/**
 * ============================================================================
 * 
 * ============================================================================
 * 
 * ----------------------------------------------------------------------------
 * 
 * ============================================================================
 * 定时器
 */
class Month extends BaseCron {

    /**
     * 默认方法
     */
    public function index(){
        //生成平台月账单统计
        $this->_create_orderstatis();
    }

    private function _create_orderstatis(){
        $max_time=strtotime(date('Y-m-01 0:0:0', TIMESTAMP))-1;//上个月最后一天
        
        $os_month=Db::name('orderstatis')->order('os_month desc')->value('os_month');
        if($os_month){
            //有生成过平台账单则查看最新的账单时间到上个月期间是否有结算单
            $start_time= strtotime($os_month.'01 0:0:0 + 1 month');

        }else{
            //没生成过平台账单则生成最旧的结算单时间到上个月期间的平台账单
            $ob_createdate=Db::name('orderbill')->order('ob_startdate asc')->value('ob_startdate');
            if($ob_createdate){
                $start_time= strtotime(date('Y-m-01 0:0:0',$ob_createdate));
            }
        }
        
        
        if(isset($start_time)){
            for($i=1;$i<=100;$i++){
                $end_time=strtotime(date('Y-m-01 0:0:0', $start_time)." +1 month")-1;
                if($end_time>$max_time){
                    break;
                }
                $orderbill_sum=Db::name('orderbill')->where('ob_enddate','between',[$start_time,$end_time])->field('SUM(ob_order_totals) AS os_order_totals,SUM(ob_shipping_totals) AS os_shipping_totals,SUM(ob_order_return_totals) AS os_order_returntotals,SUM(ob_commis_totals) AS os_commis_totals,SUM(ob_commis_return_totals) AS os_commis_returntotals,SUM(ob_store_cost_totals) AS os_store_costtotals,SUM(ob_vr_order_totals) AS os_vr_order_totals,SUM(ob_vr_commis_totals) AS os_vr_commis_totals,SUM(ob_vr_inviter_totals) AS os_vr_inviter_totals,SUM(ob_result_totals) AS os_result_totals,SUM(ob_inviter_totals) AS os_inviter_totals,SUM(ob_vr_order_return_totals) AS os_vr_order_return_totals,SUM(ob_vr_commis_return_totals) AS os_vr_commis_return_totals')->find();
                if($orderbill_sum){
                    Db::name('orderstatis')->insert(array(
                        'os_month'=>date('Ym',$start_time),
                        'os_createdate'=>TIMESTAMP,
                        'os_order_totals'=>floatval($orderbill_sum['os_order_totals']),
                        'os_shipping_totals'=>floatval($orderbill_sum['os_shipping_totals']),
                        'os_order_returntotals'=>floatval($orderbill_sum['os_order_returntotals']),
                        'os_commis_totals'=>floatval($orderbill_sum['os_commis_totals']),
                        'os_commis_returntotals'=>floatval($orderbill_sum['os_commis_returntotals']),
                        'os_store_costtotals'=>floatval($orderbill_sum['os_store_costtotals']),
                        'os_vr_order_totals'=>floatval($orderbill_sum['os_vr_order_totals']),
                        'os_vr_commis_totals'=>floatval($orderbill_sum['os_vr_commis_totals']),
                        'os_vr_inviter_totals'=>floatval($orderbill_sum['os_vr_inviter_totals']),
                        'os_result_totals'=>floatval($orderbill_sum['os_result_totals']),
                        'os_inviter_totals'=>floatval($orderbill_sum['os_inviter_totals']),
                        'os_vr_order_return_totals'=>floatval($orderbill_sum['os_vr_order_return_totals']),
                        'os_vr_commis_return_totals'=>floatval($orderbill_sum['os_vr_commis_return_totals']),
                    ));
                }else{
                    Db::name('orderstatis')->insert(array('os_month'=>date('Ym',$start_time),'os_createdate'=>TIMESTAMP));
                }
                $start_time=$end_time+1;
            }
            if($end_time<$max_time){
                $this->redirect('month/index');
            }
        }
    }
    
}