qimall/addons/Agent/common/models/AgentSupplierOrder.php

<?php

namespace addons\Agent\common\models;

use addons\Course\common\models\AddonsCourseOrders;
use addons\Store\common\models\StoreCashierOrder;
use addons\Store\common\models\StoreOrder;
use addons\Store\common\models\StoreOrderDetail;
use common\components\export\CsvTool;
use common\enums\DownloadEnum;
use common\enums\RedisKeyEnum;
use common\enums\StatusEnum;
use common\models\base\BaseActiveRecord;
use common\models\common\CapitalLog;
use common\models\common\Download;
use common\models\order\Order;
use common\models\order\OrderDetail;
use common\models\user\User;

/**
 * This is the model class for table "qimall_addons_agent_supplier_order".
 *
 * @property int $id
 * @property int $mall_id
 * @property int $buy_user_id 买家id
 * @property int $buy_level 买家身份
 * @property int $seller_user_id 卖家id
 * @property int $seller_level 卖家身份
 * @property string $order_no 会员订单号
 * @property string $supplier_order_no 供应商订单号
 * @property int $goods_nums 商品数量
 * @property int $stock_nums 库存加减
 * @property float $payment_amount 货款金额
 * @property float $profit 利润
 * @property int $pay_time 订单支付时间
 * @property int $created_at 添加时间戳
 * @property int $updated_at 更新时间戳
 */
class AgentSupplierOrder extends BaseActiveRecord
{
    /**
     * 生成旧数据的缓存key
     */
    const OLD_DATA_GENERATE_ = 'agent_supplier_order_old_data_generate';

    /**
     * {@inheritdoc}
     */
    public static function tableName()
    {
        return '{{%addons_agent_supplier_order}}';
    }

    /**
     * {@inheritdoc}
     */
    public function rules()
    {
        return [
            [['mall_id', 'buy_user_id', 'buy_level', 'seller_user_id', 'seller_level', 'goods_nums', 'stock_nums', 'pay_time', 'created_at', 'updated_at', 'status'], 'integer'],
            [['payment_amount', 'profit'], 'number'],
            [['order_no', 'supplier_order_no'], 'string', 'max' => 100],
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function attributeLabels()
    {
        return [
            'id' => 'ID',
            'mall_id' => 'Mall ID',
            'buy_user_id' => '买家id',
            'buy_level' => '买家身份',
            'seller_user_id' => '卖家id',
            'seller_level' => '卖家身份',
            'order_no' => '会员订单号',
            'supplier_order_no' => '供应商订单号',
            'goods_nums' => '商品数量',
            'stock_nums' => '库存加减',
            'payment_amount' => '货款金额',
            'profit' => '利润',
            'pay_time' => '订单支付时间',
            'created_at' => '添加时间戳',
            'updated_at' => '更新时间戳',
        ];
    }

    /**
     * 可供导出供应商订单的字段
     * @Author：hua
     * @Date：2024-02-22 18:02
     * @Copyright：copyright（c）2024 广东七件事集团
     * @return string[]
     */
    public static function exportFieldsList()
    {
        return [
            'buy_user_id' => '买家id',
            'buy_nickname' => '买家昵称',
            'buy_level' => '买家身份',
            'seller_user_id' => '卖家id',
            'seller_nickname' => '卖家昵称',
            'seller_level' => '卖家身份',
            'order_no' => '会员订单号',
            'supplier_order_no' => '供应商订单号',
            'goods_nums' => '商品数量',
            'stock_nums' => '库存加减',
            'order_status' => '发货状态',
            'payment_amount' => '货款金额',
            'profit' => '利润',
            'pay_time' => '订单时间',
        ];
    }

    public function getBuyUser()
    {
        return $this->hasOne(User::class, ['id' => 'buy_user_id']);
    }

    public function getSellerUser()
    {
        return $this->hasOne(User::class, ['id' => 'seller_user_id']);
    }

    /**
     * 设置单条数据
     * @Author：hua
     * @Date：2024-02-23 15:09
     * @Copyright：copyright（c）2024 广东七件事集团
     * @param $params
     * @return self|bool
     */
    public static function setData($params, bool $returnBool = true)
    {
        $model = AgentSupplierOrder::find()->where(['seller_user_id' => $params['seller_user_id'], 'order_no' => $params['order_no'], 'status' => StatusEnum::ENABLED])->one();
        if (empty($model)) {
            $model = new AgentSupplierOrder();
            $model->mall_id = $params['mall_id'];
            $model->buy_user_id = $params['buy_user_id'];
            $model->buy_level = $params['buy_level'];
            $model->seller_user_id = $params['seller_user_id'];
            $model->seller_level = $params['seller_level'];
            $model->order_no = $params['order_no'];
            $model->supplier_order_no = Order::generateOrderNo('G');
            $model->pay_time = $params['pay_time'];
        }
        $model->payment_amount += $params['payment_amount'];
        $model->profit += $params['money'];
        $model->goods_nums += $params['goods_nums'];
        $model->stock_nums += $params['stock_nums'];

        $res = $model->save();
        if ($returnBool) {
            return $res;
        }
        return $model;
    }

    /**
     * 添加分佣记录数据
     * @Author：hua
     * @Date：2024-02-23 09:54
     * @Copyright：copyright（c）2024 广东七件事集团
     * @param $params
     * @return void
     */
    public static function insertData($params)
    {
        $insert_wallet = $params['insert_wallet'];
        $order_no = $params['order_no'];
        $agent_list = $params['agent_list'];
        $order = Order::findOne(['order_no' => $order_no]);
        $supplierCommissionInsertData = [];
        foreach ($insert_wallet as $key => $item) {
            $params['money'] = $item['money'];
            $params['mall_id'] = $item['mall_id'];
            $params['seller_user_id'] = $item['user_id'];
            $params['seller_level'] = $agent_list[$item['user_id']]['level'] ?? 0;
            $params['supplier_order_no'] = Order::generateOrderNo('G');
            $params['pay_time'] = $order['pay_time'];
            $params['stock_nums'] = $params['goods_nums'];
            $saveModel = self::setData($params, false);

            // 写入供应商佣金
            foreach ($saveModel as $field => $value) {
                $supplierCommissionInsertData[$key][$field] = $value;
            }
            $supplierCommissionInsertData[$key]['seller_level'] = $agent_list[$item['user_id']]['level'] ?? $params['seller_level'];
            $supplierCommissionInsertData[$key]['payment_amount'] = $params['payment_amount'];
            $supplierCommissionInsertData[$key]['profit'] = $item['money'];
            $supplierCommissionInsertData[$key]['goods_nums'] = $params['goods_nums'];
            $supplierCommissionInsertData[$key]['stock_nums'] = $params['stock_nums'];
            $supplierCommissionInsertData[$key]['capital_type'] = $item['capital_type'];
            $supplierCommissionInsertData[$key]['source_table'] = $item['source_table'];
            $supplierCommissionInsertData[$key]['source_table_id'] = $item['source_table_id'];
        }

        AgentSupplierCommission::insertData($supplierCommissionInsertData);
    }

    /**
     * 旧数据生成
     * @Author：hua
     * @Date：2024-02-23 15:44
     * @Copyright：copyright（c）2024 广东七件事集团
     * @param $params
     * @return bool|void
     */
    public static function oldDataGenerate($params)
    {
        $mall_id = $params['mall_id'];
        $cache_key = RedisKeyEnum::suffix(self::OLD_DATA_GENERATE_, $mall_id);
        $cache = \Yii::$app->cache;
        $cache_data = $cache->get($cache_key);
        if (!empty($cache_data)) return true;
        $wallet_type = 'commission';
        $i = 1;
        $page_size = 1000;
        while (true) {
            CapitalLog::$capitalType = $wallet_type;
            $list = CapitalLog::find()->where(['mall_id' => $mall_id, 'from_type' => 'Agent'])
                ->offset(($i - 1) * $page_size)->limit($page_size)->all();
            if (empty($list)) break;
            self::saveData($list);
            $i++;
        }

        $i = 1;
        $page_size = 1000;
        $wallet_type = 'commission_frozen';
        while (true) {
            CapitalLog::$capitalType = $wallet_type;
            $list = CapitalLog::find()->where(['mall_id' => $mall_id, 'from_type' => 'Agent', 'status' => StatusEnum::DISABLED])
                ->offset(($i - 1) * $page_size)->limit($page_size)->all();
            if (empty($list)) break;
            self::saveData($list);
            $i++;
        }
        $cache->set($cache_key, 1);

    }

    /**
     * 保存列表数据
     * @Author：hua
     * @Date：2024-02-23 15:08
     * @Copyright：copyright（c）2024 广东七件事集团
     * @param $list
     * @return void
     */
    public static function saveData($list)
    {
        foreach ($list as $item) {
            list($payment_amount, $goods_nums, $buy_user_id, $buy_user_level, $seller_level, $order_no, $pay_time) = self::formatData($item);
            if (empty($order_no)) continue;
            $params['mall_id'] = $item['mall_id'];
            $params['buy_user_id'] = $buy_user_id;
            $params['buy_level'] = $buy_user_level;
            $params['seller_user_id'] = $item['user_id'];
            $params['seller_level'] = $seller_level;
            $params['order_no'] = $order_no;
            $params['supplier_order_no'] = Order::generateOrderNo('G');
            $params['pay_time'] = $pay_time;
            $params['payment_amount'] = $payment_amount;
            $params['money'] = $item['change_num'];
            $params['goods_nums'] = $goods_nums;
            $params['stock_nums'] = $goods_nums;
            self::setData($params);
        }
    }

    /**
     * 格式化数据
     * @Author：hua
     * @Date：2024-02-23 15:07
     * @Copyright：copyright（c）2024 广东七件事集团
     * @param $item
     * @return array
     */
    public static function formatData($item)
    {
        $payment_amount = 0;
        $goods_nums = 0;
        $buy_user_id = 0;
        $buy_user_level = 0;
        $seller_level = 0;
        $order_no = '';
        $pay_time = '';
        switch ($item['source_table']) {
            case 'order_detail':
                $order_detail = OrderDetail::findOne(['id' => $item['source_table_id']]);
                if ($order_detail) {
                    $order = Order::findOne(['id' => $order_detail['order_id']]);
                    if ($order) {
                        $order_no = $order['order_no'];
                        $pay_time = $order['pay_time'];
                        $buy_user_id = $order['user_id'];
                    }
                    $goods_nums = $order_detail['num'];
                    $payment_amount = $order_detail['goods_price'];
                }
                break;
            case 'store_cashier_order':
                $store_cashier_order = StoreCashierOrder::findOne(['id' => $item['source_table_id']]);
                if ($store_cashier_order) {
                    $order_no = $store_cashier_order['order_no'];
                    $pay_time = $store_cashier_order['pay_time'];
                    $buy_user_id = $store_cashier_order['user_id'];
                    $payment_amount = $store_cashier_order['pay_money'];

                }
                $goods_nums = 1;
                break;
            case 'store_order_detail':
                $store_order_detail = StoreOrderDetail::findOne(['id' => $item['source_table_id']]);
                if ($store_order_detail) {
                    $store_order = StoreOrder::findOne(['id' => $store_order_detail['order_id']]);
                    if ($store_order) {
                        $order_no = $store_order['order_no'];
                        $pay_time = $store_order['pay_time'];
                        $buy_user_id = $store_order['user_id'];
                    }
                    $payment_amount = $store_order_detail['goods_price'];
                }
                $goods_nums = $store_order_detail['num'];
                break;
            case '{{%addons_agent_team_achievement}}':
                break;
            case '{{%addons_course_orders}}':
                $course_order = AddonsCourseOrders::findOne(['id' => $item['source_table_id']]);
                if ($course_order) {
                    $order_no = $course_order['order_no'];
                    $pay_time = $course_order['pay_time'];
                    $buy_user_id = $course_order['user_id'];
                    $goods_nums = 1;
                    $payment_amount = $course_order['pay_money'];

                }
                break;
            case '{{%order}}':
                $order = Order::findOne(['id' => $item['source_table_id']]);
                if ($order) {
                    $num = OrderDetail::find()->where(['order_id' => $order['id']])->sum('num');
                    $goods_price = OrderDetail::find()->where(['order_id' => $order['id']])->sum('goods_price');
                    if (!empty($num)) $goods_nums = $num;
                    if (!empty($goods_price)) $payment_amount = $goods_price;
                    $order_no = $order['order_no'];
                    $pay_time = $order['pay_time'];
                    $buy_user_id = $order['user_id'];
                }
                break;
        }
        $agent_arr = Agent::find()->where(['mall_id' => $item['mall_id'], 'user_id' => [$buy_user_id, $item['user_id']], 'status' => StatusEnum::ENABLED])
            ->indexBy('user_id')->all();

        if (isset($agent_arr[$buy_user_id])) $buy_user_level = $agent_arr[$buy_user_id]['level'];
        if (isset($agent_arr[$item['user_id']])) $seller_level = $agent_arr[$item['user_id']]['level'];
        return [$payment_amount, $goods_nums, $buy_user_id, $buy_user_level, $seller_level, $order_no, $pay_time];

    }

    /**
     * 导出供应商订单
     * @Author：hua
     * @Date：2024-02-22 18:27
     * @Copyright：copyright（c）2024 广东七件事集团
     * @param  $data
     * @return bool|void
     */
    public static function exportHandle($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;
                $fields = $params['fields'];
                $fields_arr = self::exportFieldsList();
                $have_select_field_arr = [];
                foreach ($fields as $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;

                $model = self::find();
                $model->where(['mall_id' => $params['mall_id']]);
                //拼接查询条件
                if (!empty($params['order_no'])) $model->andWhere(['=', 'order_no', $params['order_no']]);
                if (!empty($params['keyword'])) {
                    $condition['where'] = [[
                        'or',
                        ['=', 'id', $params['keyword']],
                        ['like', 'username', $params['keyword']],
                        ['like', 'nickname', $params['keyword']],
                        ['like', 'mobile', $params['keyword']]
                    ]];
                    $user_list = User::lists($condition);
                    $user_id_arr = array_column($user_list, 'id');
                    $model->andWhere(['in', 'buy_user_id', $user_id_arr]);
                }
                if (!empty($params['seller_keyword'])) {
                    $condition['where'] = [[
                        'or',
                        ['=', 'id', $params['seller_keyword']],
                        ['like', 'username', $params['seller_keyword']],
                        ['like', 'nickname', $params['seller_keyword']],
                        ['like', 'mobile', $params['seller_keyword']]
                    ]];
                    $user_list = User::lists($condition);
                    $user_id_arr = array_column($user_list, 'id');
                    $model->andWhere(['in', 'seller_user_id', $user_id_arr]);
                }
                $model->with(['buyUser', 'sellerUser']);

                //遍历组装数据
                $args = [];
                $args['where'] = [['mall_id' => $params['mall_id']], ['<>', 'status', StatusEnum::DELETE]];
                $args['select'] = 'id,level,name';
                $args['index'] = 'level';
                $level_list = AgentLevel::lists($args, true);
                $order_status_arr = [
                    '0' => "待付款",
                    '1' => "待发货",
                    '2' => "已发货",
                    '3' => "已收货",
                    '4' => "已完成",
                    '-4' => "已关闭",
                    '-2' => "退款中",
                    '-1' => "售后申请"
                ];
                foreach ($model->batch() as $list) {
                    $order_no_arr = array_column($list, 'order_no');
                    $order_arr = Order::lists(['where' => [['order_no' => $order_no_arr]], 'index' => 'order_no', 'select' => 'order_no,order_status']);
                    $csv->data = array_map(function ($agent) use ($fields, $level_list, $order_arr, $order_status_arr) {
                        $row = [];
                        //遍历所选字段
                        foreach ($fields as $field) {
                            if (in_array($field, ['pay_time'])) {
                                $row[] = !empty($agent[$field]) ? date('Y-m-d H:i:s', $agent[$field]) : '';
                            } elseif (in_array($field, ['buy_nickname'])) {
                                $row[] = !empty($agent['buyUser']['nickname']) ? $agent['buyUser']['nickname'] : '';
                            } elseif (in_array($field, ['seller_nickname'])) {
                                $row[] = !empty($agent['sellerUser']['nickname']) ? $agent['sellerUser']['nickname'] : '';
                            } elseif (in_array($field, ['buy_level'])) {
                                if (isset($level_list[$agent['buy_level']])) {
                                    $row[] = $level_list[$agent['buy_level']]['name'];
                                } else {
                                    $row[] = '普通会员';
                                }
                            } elseif (in_array($field, ['seller_level'])) {
                                if (isset($level_list[$agent['seller_level']])) {
                                    $row[] = $level_list[$agent['seller_level']]['name'];
                                } else {
                                    $row[] = '普通会员';
                                }
                            } elseif (in_array($field, ['order_status'])) {
                                if (isset($order_arr[$agent['order_no']]) && isset($order_status_arr[$order_arr[$agent['order_no']]['order_status']])) {
                                    $row[] = $order_status_arr[$order_arr[$agent['order_no']]['order_status']];
                                } else {
                                    $row[] = '';
                                }
                            } elseif (in_array($field, ['stock_nums'])) {
                                if ($agent['buy_level'] == 0) {
                                    $row[] = '/';
                                } else {
                                    $row[] = !empty($agent[$field]) ? $agent[$field] : '';
                                }
                            } else {
                                $row[] = !empty($agent[$field]) ? $agent[$field] : '';
                            }
                        }
                        return $row;
                    }, $list);
                    $csv->export();
                }
                $csv->updateDown($download, $params['mall_id']);
                return true;
            } catch (\Exception $e) {
                $download->status = 3;
                $res = $download->save();
                self::setStaticError($e->getMessage());
                return false;
            }
        }
    }


}