xyzshop/test/TestExportOrder.php

<?php


use PHPUnit\Framework\TestCase;
use statistics\stat_refill;

define('APP_ID', 'test');
define('BASE_ROOT_PATH', str_replace('/test', '', dirname(__FILE__)));

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_CORE_PATH . '/lrlz.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_HELPER_PATH . '/PHPExcel/PHPExcel.php');

class TestExportOrder extends TestCase
{
    public static function setUpBeforeClass() : void
    {
        Base::run_util();
    }

    public function testXingzhiyu()
    {
        $end_time = strtotime("2021-06-15");
        $this->exoprt(1093,null,$end_time);
    }

    public function exoprt($mchid,$start_time = null,$end_time = null)
    {
        $cond['mchid'] = $mchid;
        $cond['vr_order.order_state'] = 40;
        if(!is_null($start_time) && !is_null($end_time)) {
            $cond["refill_order.notify_time&refill_order.notify_time"] = ['_multi' => true, ['egt', $start_time], ['lt', $end_time]];
        }
        elseif(!is_null($start_time)) {
            $cond["refill_order.notify_time"] = ['egt', $start_time];
        }
        elseif(!is_null($end_time)) {
            $cond["refill_order.notify_time"] = ['lt', $end_time];
        }

        $path = BASE_DATA_PATH . "/log/{$mchid}.csv";
        $fp = fopen($path, 'w');
        fputcsv($fp,['序号','商户订单号','卡号','面额','流水号',"下单时间","回调时间"]);

        $count = 1000;
        $i = 0;

        $index = 0;
        while (true)
        {
            $start = $i * $count;
            $items = Model('')->table('refill_order,vr_order')
                ->field('mch_order,refill_order.card_no,refill_amount,mch_amount,official_sn,from_unixtime(order_time) as sorder_time,from_unixtime(notify_time) as snotify_time')
                ->join('inner')
                ->on('refill_order.order_id=vr_order.order_id')
                ->where($cond)
                ->limit("{$start},{$count}")
                ->select();

            if(empty($items)) {
                break;
            }
            $i++;

            foreach ($items as $item)
            {
                $index++;
                $data = [$index,$item['mch_order'],$item['card_no'],$item['refill_amount'],$item['mch_amount'],$item['official_sn'],$item['sorder_time'],$item['snotify_time']];
                fputcsv($fp,$data);
            }
        }

        fclose($fp);
    }

    public function testRefillTask()
    {
        $model_refill_task = Model('refill_task');

        $task = $model_refill_task->UnDispose();
        if (empty($task)) return false;

        $task_id = $task['task_id'];
        switch ($task['task_type']) {
            case 'order_export' :
                $result = $this->TaskOrderExport($task,$model_refill_task);
                break;
            default:
                $result = '任务类型匹配失败';
                break;
        }
        Log::record("refill task result：{$result}, task_id：{$task_id}");
        return true;
    }

    private function TaskOrderExport($task,$model_refill_task)
    {
        $task_id = $task['task_id'];
        $task_params = unserialize($task['task_params']);
        if (empty($task_params)) {
            Log::record("refill task condition unserialize err, task_id：{$task_id}");
            return false;
        }

        $model_refill_task->Dispose($task_id);
        [$state, $task_result] = $this->order_export($task_params, $task_id);
        if ($state) {
            $model_refill_task->DisposeFinish($task_id, $task_result);
        } else {
            $model_refill_task->DisposeErr($task_id, $task_result);
        }
        return $state;
    }

    /**
     * @throws PHPExcel_Exception
     */
    private function order_export($condition, $task_id)
    {
        $orders = Model('refill_order')->getAllOrders($condition);
        if (empty($orders)) {
            return [false, '统计数据为空'];
        }

        $merchants = [];
        $column_values = ['商户号', '商户名称', '商户订单号','平台单号', '面额', '充值卡号', '充值卡类型', '下单日期', '完成日期', '官方流水号', '订单状态', '扣款金额（下游）', '上游名称','上游订单号', '折扣金额（上游）'];
        $data_keys = ['mchid', 'mch_name', 'mch_order', 'order_sn', 'refill_amount', 'card_no', 'card_type_text', 'order_time_text', 'notify_time_text', 'official_sn', 'order_state_text', 'mch_amount', 'channel_name', 'ch_trade_no', 'channel_amount'];
        $merchant_list = Model('')->table('merchant')->limit(1000)->order('company_name asc')->select();
        foreach ($merchant_list as $value) {
            $merchants[$value['mchid']] = $value;
        }
        $column_key = 'A';
        for($index=0;$index<count($column_values);$index++){
            $column_keys[] = $column_key;
            $column_key++;
        }

        $objPHPExcel = new PHPExcel();
        $objPHPExcel->setActiveSheetIndex(0);
        $objPHPExcel->getDefaultStyle()->getFont()->setName('Arial')->setSize(10);
        foreach ($column_keys as $key => $column_key) {
            $objPHPExcel->getActiveSheet()->getColumnDimension($column_key)->setWidth(25);
            $cell_value = $column_key . 1;
            $objPHPExcel->getActiveSheet()->setCellValue($cell_value, $column_values[$key]);
        }

        $card_type_texts = [mtopcard\PetroChinaCard => '中石油', mtopcard\SinopecCard => '中石化', mtopcard\ChinaMobileCard => '中国移动', mtopcard\ChinaUnicomCard => '中国联通', mtopcard\ChinaTelecomCard => '中国电信'];
        foreach ($orders as $k => $order) {
            if(!empty($merchants)) {
                $order['mch_name'] = $merchants[$order['mchid']]['company_name'];
            }
            $order['card_type_text'] = $card_type_texts[$order['card_type']];
            $order['order_time_text'] = $order['order_time'] ? date('Y-m-d H:i:s', $order['order_time']) : '';
            $order['notify_time_text'] = $order['notify_time'] ? date('Y-m-d H:i:s', $order['notify_time']) : '';
            $order['order_state_text'] = orderState($order);
            foreach ($column_keys as $key => $column_key) {
                $field = $column_key . ($k + 2);
                $objPHPExcel->getActiveSheet()->setCellValueExplicit($field, $order[$data_keys[$key]]);
            }
        }
        try {
            $path = BASE_ROOT_PATH . "/data/upload/task/";
            if (!is_dir($path)) {
                mkdir($path, 0755);
            }
            $filename = date('YmdHis', time()) . "-任务导出-任务ID:{$task_id}.xlsx";

            $file_path = $path . $filename;
            $objWriter = PHPExcel_IOFactory::createWriter($objPHPExcel, 'Excel2007');

            $objWriter->save($file_path);
            return [true, $filename];
        } catch (Exception $e) {
            return [false, $e->getMessage()];
        }
    }

    public function testStrSer()
    {
        $str = 'a:3:{s:11:"is_transfer";b:1;s:11:"card_states";a:2:{i:0;i:0;i:1;i:5;}s:10:"card_types";a:1:{i:0;i:4;}}';
        $arr = unserialize($str);

        $j = 'A';
        for($index=0;$index<10;$index++){
            $j++;
        }

        $a1 = [1];
        $a = array_merge([0],$a1,[2]);
    }
}


//docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestExportOrder::testXingzhiyu)( .*)?$/" --test-suffix TestExportOrder.php /var/www/html/test