qimall/common/models/user/UserMemberLabel.php

<?php

namespace common\models\user;

use common\components\export\CsvTool;
use common\enums\DownloadEnum;
use common\enums\MemberLabelEnum;
use common\enums\StatusEnum;
use common\models\base\BaseActiveRecord;
use common\models\common\Download;
use yii\db\Exception;

/**
 * This is the model class for table "qimall_user_member_label".
 *
 * @property int $id
 * @property int $mall_id 商城ID
 * @property int $user_id 会员ID
 * @property int $cate_id1 价值标签id
 * @property int $cate_id2 会员等级标签id
 * @property int $cate_id3 渠道等级标签id
 * @property int $cate_id4 复购标签id
 * @property int $cate_id5 推广标签id
 * @property int $cate_id6 领导标签id
 * @property int $cate_id7 活跃标签id
 * @property int $cate_id8 收入标签id
 * @property int $cate_id9 分享标签id
 * @property int $cate_id10 退款标签id
 * @property int $cate_id11 会员年龄标签id
 * @property int|null $status 状态[-1:删除;0:禁用;1启用]
 * @property int $register_time
 * @property int $created_at
 * @property int $updated_at
 */
class UserMemberLabel extends BaseActiveRecord
{
    /**
     * {@inheritdoc}
     */
    public static function tableName()
    {
        return '{{%user_member_label}}';
    }

    /**
     * {@inheritdoc}
     */
    public function rules()
    {
        return [
            [['mall_id', 'user_id', 'cate_id1', 'cate_id2', 'cate_id3', 'cate_id4', 'cate_id5', 'cate_id6', 'cate_id7', 'cate_id8', 'cate_id9', 'cate_id10', 'cate_id11', 'status', 'register_time', 'created_at', 'updated_at'], 'integer'],
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function attributeLabels()
    {
        return [
            'id' => 'ID',
            'mall_id' => '商城ID',
            'user_id' => '会员ID',
            'cate_id1' => '价值标签id',
            'cate_id2' => '会员等级标签id',
            'cate_id3' => '渠道等级标签id',
            'cate_id4' => '复购标签id',
            'cate_id5' => '推广标签id',
            'cate_id6' => '领导标签id',
            'cate_id7' => '活跃标签id',
            'cate_id8' => '收入标签id',
            'cate_id9' => '分享标签id',
            'cate_id10' => '退款标签id',
            'cate_id11' => '会员年龄标签id',
            'status' => '状态[-1:删除;0:禁用;1启用]',
            'register_time' => 'Register Time',
            'created_at' => 'Created At',
            'updated_at' => 'Updated At',
        ];
    }

    public static function setData(array $params)
    {
        try {
            //过滤重复标签

            $model = self::findOne(['user_id' => $params['user_id'], 'mall_id' => $params['mall_id'], 'status' => StatusEnum::ENABLED]);
            if (empty($model)) {
                $model = new self();
                $model->loadDefaultValues();
            }
            if (!$model->load($params, '') || !$model->save()) {
                throw new \Exception($model->getErrorMessage());
            }
            var_dump($model->user_id);
            return $model;
        } catch (\Exception $e) {
            self::setStaticError($e->getMessage());
            return false;
        }
    }

    public static function fieldsList()
    {
        return [
            'user_id' => '会员id',
            'nickname' => '昵称',
            'mobile' => '手机号',
            'label' => '标签',
            'register_time' => '注册时间',
        ];
    }

    public static function exportHandle(array $data)
    {
        date_default_timezone_set('PRC');
        $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;
                $mall_id = $params['mall_id'];
                $showType = $params['showType'];
                $fields_arr = self::fieldsList();
                $have_select_field_arr = [];
                foreach ($fields_arr as $value) {
                    $have_select_field_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;

                $query = UserMemberLabel::find()->where(['mall_id' => $mall_id])->andWhere(['status' => [StatusEnum::DISABLED, StatusEnum::ENABLED]]);
                if (!empty($params['start'])) {
                    $temp = ['>=', 'register_time', strtotime($params['start'])];
                    $query->andWhere($temp);
                }
                if (!empty($params['end'])) {
                    $temp = ['<=', 'register_time', strtotime($params['end'])];
                    $query->andWhere($temp);
                }
                if (!empty($params['nickname'])) {
                    $userList = User::lists([
                        'where' => [
                            ['mall_id' => $mall_id],
                            ['like', 'nickname', $params['nickname']],
                            ['status' => [StatusEnum::DISABLED, StatusEnum::ENABLED]]
                        ],
                        'select' => 'id',
                    ]);
                    $userIds = array_column($userList, 'id');
                    $temp = ['user_id' => $userIds];
                    $query->andWhere($temp);
                }
                if (!empty($params['user_id'])) {
                    $temp = ['=', 'user_id', $params['user_id']];
                    $query->andWhere($temp);
                }
                if (!empty($params['memberLabelIds']) && !empty($params['cate_id'])) {
                    $cate_id = str_replace('key', '', $params['cate_id']);
                    $temp = ['cate_id' . $cate_id => $params['memberLabelIds']];
                    $query->andWhere($temp);
                }
                if (!empty($params['memberLabelIds'])) {
                    $cateIdArr = [];
                    foreach ($params['memberLabelIds'] as $val) {
                        $temp_arr = explode('_', $val);
                        $cateIdArr[$temp_arr[0]][] = $temp_arr[1];
                    }
                    foreach ($cateIdArr as $cate_id => $memberLabelIds) {
                        $temp = ['cate_id' . $cate_id => $memberLabelIds];
                        $query->andWhere($temp);
                    }
                }

                $i = 1;
                $page_size = 20000;
                $data_list = [];
                $cate_map = MemberLabelEnum::getMap();
                $mapContent = MemberLabelEnum::getMapContent();
                $mapIds = array_keys($cate_map);
                $member_label_list = MemberLabel::lists(['where' => [['status' => [StatusEnum::DISABLED, StatusEnum::ENABLED]]], 'index' => 'id']);
                $users = $query
                    ->offset(($i - 1) * $page_size)->groupBy('user_id')->limit($page_size)->asArray()->all();

                empty($csv->header) && $csv->header = array_keys($users[0]);
                $userIds = array_column($users, 'user_id');
                $userArr = User::lists(['where' => [['id' => $userIds]], 'index' => 'id', 'select' => 'id,nickname,mobile']);
                foreach ($users as $user) {
                    $row = [];
                    $nickname = '';
                    $mobile = '';
                    if (isset($userArr[$user['user_id']])) {
                        $nickname = $userArr[$user['user_id']]['nickname'];
                        $mobile = $userArr[$user['user_id']]['mobile'];
                    }
                    $userMemberLabelList = [];
                    $label_str = '';
                    foreach ($mapIds as $cate_id) {
                        $temp_cate_id = $user['cate_id' . $cate_id];
                        if (isset($member_label_list[$temp_cate_id])) {
                            if ($showType == 1) {
                                $label_str .= $member_label_list[$temp_cate_id]['name'] . ',';
                            } else {
                                $content = $mapContent[$cate_id];
                                if (!is_array($member_label_list[$temp_cate_id]['condition'])) {
                                    $member_label_list[$temp_cate_id]['condition'] = json_decode($member_label_list[$temp_cate_id]['condition'], true);
                                }
                                if (empty($member_label_list[$temp_cate_id]['condition']['num'])) $member_label_list[$temp_cate_id]['condition']['num'] = '';
                                $content = str_replace('{data}', $member_label_list[$temp_cate_id]['condition']['num'], $content);
                                $label_str .= $content . ',';
                            }
                        }
                    }
                    $label_str = trim($label_str, ',');
                    $item['userMemberLabelList'] = $userMemberLabelList;
                    foreach ($fields_arr as $field => $name) {
                        switch ($field) {
                            case 'nickname':
                                $row[] = $nickname;
                                break;
                            case 'mobile':
                                $row[] = $mobile;
                                break;
                            case 'label':
                                $row[] = $label_str;
                                break;
                            case 'register_time':
                                $row[] = !empty($user['register_time']) ? date('Y-m-d H:i:s', $user['register_time']) : '';
                                break;
                            default:
                                if ((isset($user[$field]))) $row[] = $user[$field] ?? '';
                        }
                    }
                    $data_list[] = $row;
                }

                $csv->data = $data_list;
                $csv->export();

                $url = $csv->upload($params['mall_id'], $csv->relative_filename);

                $download->status = 2;
                $download->url = $url;
                $download->num = $csv->line_num;
                $download->size = $csv->file_size;
                $res = $download->save();

                return true;
            } catch (Exception $e) {
                $download->status = 3;
                dd($e->getMessage());
                self::setStaticError($e->getMessage());
                return false;
            }
        }
    }


}