qimall/addons/CloudStock/common/services/CloudStockDispenseOrderService.php

<?php

namespace addons\CloudStock\common\services;

use addons\CloudStock\common\enums\CloudStockEnum;
use addons\CloudStock\common\models\CloudStockDeductionDetail;
use addons\CloudStock\common\models\CloudStockDispenseOrder;
use common\components\export\CsvTool;
use common\enums\DownloadEnum;
use common\enums\StatusEnum;
use common\models\common\CapitalLog;
use common\models\common\Download;
use common\models\goods\Goods;
use common\models\user\User;

class CloudStockDispenseOrderService extends BaseService
{
    public function index($params)
    {

        $params['where'] = $this->getQueryWhere($params);
        $params['order'] = 'id desc';
        $params['with'] = ['user', 'child', 'goods'];
        $pageData = CloudStockDispenseOrder::listPage($params, false);
        if (!empty($pageData['list'])) {
            foreach ($pageData['list'] as &$item) {
                $item['order'] = [
                    'order_no' => $item['order_no'],
                    'id' => $item['id'],
                ];
                $item['type_text'] = $item['type'] == 1 ? '上级配货' : '平台充值';
                if (!isset($item['user'])) {
                    $item['user'] = [
                        'id' => 0,
                        'nickname' => '平台',
                        'avatar_url' => '',
                    ];
                }
                $item['from_user'][] = $item['child'];
                unset($item['child']);
            }
        }
        $pageData['export_list'] = $this->getExportFields();
        return $pageData;
    }

    public function getQueryWhere($params)
    {
        $where = [
            ['mall_id' => $this->mall_id],
            ['status' => [StatusEnum::ENABLED, StatusEnum::DISABLED]],
        ];
        if (isset($params['keyword']) && $params['keyword'] !== '') {
            if (!empty($params['keyword'])) {
                $keyword = trim($params['keyword']);
                $user_id_arr = User::find()->where(['or',
                    ['id' => $keyword],
                    ['like', 'nickname', $keyword]])
                    ->select('id')->column();
                $where[] = ['user_id' => $user_id_arr];
            } else {
                $where[] = ['user_id' => 0];
            }
        }
        if (!empty($params['goods_name'])) {
            $goods_name = trim($params['goods_name']);
            $goods_ids = Goods::find()->where(['and',
                ['mall_id' => $this->mall_id],
                ['like', 'goods_name', $goods_name]])
                ->select('id')->column();
            $where[] = ['goods_id' => $goods_ids];
        }
        if (!empty($params['start'])) {
            $where[] = ['>=', 'created_at', strtotime($params['start'])];
        }
        if (!empty($params['end'])) {
            $where[] = ['<=', 'created_at', strtotime($params['end'])];
        }
        if (!empty($params['type'])) {
            $where[] = ['type' => $params['type']];
        }
        if (!empty($params['order_no'])) {
            $where[] = ['like', 'order_no', trim($params['order_no'])];
        }
        return $where;
    }

    public function getDeductionUserList($pageData, &$deduction_user_id_arr)
    {
        $fill_order_id_arr = [];
        foreach ($pageData['list'] as $item) {
            $item['rand_fee'] = $item['paymentTrade']['rand_fee'] ?? 0;
            foreach ($item['fillOrder'] as $val) {
                $fill_order_id_arr[] = $val['id'];
            }
        }
        $deduction_list = CloudStockDeductionDetail::lists([
                'where' => [
                    ['order_id' => $fill_order_id_arr],
                    ['order_type' => CloudStockEnum::STOCK_ORDER_TYPE_REPLENISH]
                ],
                'select' => 'user_id,order_id',
            ]
        );
        $deduction_user_ids = array_column($deduction_list, 'user_id');
        foreach ($deduction_list as $val) {
            $deduction_user_id_arr[$val['order_id']][] = $val['user_id'];
        }
        $deduction_user_list = User::lists([
                'where' => [
                    ['id' => $deduction_user_ids]
                ],
                'index' => 'id',
                'select' => 'id,nickname,mobile,avatar_url',
            ]
        );
        $deduction_user_list[0] = ['id' => 0,
            'nickname' => '平台',
            'mobile' => '',
            'avatar_url' => '',
        ];
        return $deduction_user_list;

    }


    public static function exportOrder($params)
    {
        (new CloudStockDispenseOrderService(['mall_id' => $params['mall_id']]))->export($params);

    }

    public function getExportFields()
    {
        $fields = [
            'user_id' => '代理商id',
            'nickname' => '代理商昵称',
            'order_no' => '订单编号',
            'goods_id' => '商品id',
            'goods_name' => '商品名称',
            'num' => '商品数量',
            'money' => '配货商品金额',
            'child_id' => '配货下级id',
            'child_nickname' => '配货下级昵称',
            'type_text' => '配货类型',
            'created_at' => '订单创建时间',
        ];
        return $fields;
    }

    public function export(array $data)
    {
        $download_id = $data['download_id'] ?? 0;
        $download = Download::findOne(['id' => $download_id]);
        if ($download) {
            try {
                $params = json_decode($download->params, true);
                $filename = $download->name;
                $type = $download->type;
                $params['where'] = $this->getQueryWhere($params);
                $params['where'] = $this->getQueryWhere($params);
                $params['order'] = 'id desc';
                $params['with'] = ['user', 'child', 'goods'];
                $list = CloudStockDispenseOrder::lists($params, true);
                $fields = $params['fields'];
                $fields_arr = $this->getExportFields();
                $have_select_field_arr = [];
                foreach ($fields as $value) {
                    if (isset($fields_arr[$value])) $have_select_field_arr[] = $fields_arr[$value];
                }
                $csv = new CsvTool();
                $csv->filename = $filename;
                $csv->file_dirname = DownloadEnum::getTypeStorageDirMap($type);
                $csv->export_mode = CsvTool::EXPORT_MODE_ASYNC;
                $csv->header = $have_select_field_arr;
                $rows = [];
                foreach ($list as $item) {
                    $row = [];
                    foreach ($fields as $field) {
                        switch (true) {
                            case ($field == 'nickname'):
                                $row[] = $item['user'][$field] ?? '平台';
                                break;
                            case ($field == 'goods_name'):
                                $row[] = $item['goods']['goods_name'] ?? '';
                                break;
                            case ($field == 'child_nickname'):
                                $row[] = $item['child']['nickname'] ?? '';
                                break;
                            case ($field == 'type_text'):
                                $row[] = $item['type'] == 1 ? '上级配货' : '平台充值';
                                break;
                            case ($field == 'created_at'):
                                $row[] = !empty($item[$field]) ? date('Y-m-d H:i:s', $item[$field]) : '';
                                break;
                            default:
                                $row[] = $item[$field] ?? '';
                                break;

                        }
                    }
                    $rows[] = $row;
                }
                $csv->data = $rows;
                $csv->export();
                $csv->updateDown($download, $params['mall_id']);
            } catch (\Exception $e) {
                $download->status = 3;
                $res = $download->save();
                var_dump($e->getMessage() . $e->getFile() . $e->getLine());
                self::setStaticError($e->getMessage());
                return $e->getMessage();
            }
        }
    }

    public function commissionList($params)
    {
        $wallet_type = 'commission';
        $condition = [
            'where' => [
                ['mall_id' => $this->mall_id],
                ['source_table' => CloudStockDispenseOrder::tableName()],
                ['source_table_id' => $params['order_id']]
            ],
        ];
        CapitalLog::$capitalType = "{$wallet_type}";
        $list = CapitalLog::getList($condition, 0);
        CapitalLog::$capitalType = "{$wallet_type}_frozen";
        $condition['where'][] = ['status' => 0];
        $frozen_list = CapitalLog::getList($condition, 1);
        if (!empty($frozen_list)) $list = array_merge($list, $frozen_list);
        return ['list' => $list];
    }

}