zhongshen_project/addon/v3tov4/model/Upgrade.php

<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com

 * =========================================================
 */

namespace addon\v3tov4\model;

use app\model\BaseModel;
use think\facade\Db;

/**
 * V3版本升级
 */
class Upgrade extends BaseModel
{
    private $db = 'v3';

    private $task_class = [
        'goods' => [
            'name' => '商品',
            'class' => 'addon\v3tov4\model\Goods',
            'is_show' => 1,
            'introduction' => '迁移商品、商品分类、商品标签等数据',
            'desc' => <<<EOT
变动说明
1、商品标签（ns_goods_group）转移到商品分组（ns_goods_label），丢失图片
2、商品分类（ns_goods_category），废弃pc端模板、手机端模板设置、是否显示、关联商品类型ID，完善上下级关联字段
3、相册图片直接查询存表
4、丢失商品类型数据
5、丢失商品评价数据
6、丢失回收站数据
7、丢失阶梯优惠数据
8、丢失积分设置
9、丢失会员折扣
10、丢失分销设置
11、丢失卡券商品
12、丢失网盘以及下载商品
13、丢失商品品牌，已废弃
14、丢失商品规格
15、ns_goods表字段变动说明
    1、移除brand_id，品牌id
    2、category_id_1、category_id_2、category_id_3合并到category_id、category_json字段
    3、promotion_price转移到ns_goods_sku表中的discount_price字段
    4、移除point_exchange_type、point_exchange，积分兑换字段
    5、移除give_point字段，购买商品赠送积分
    6、移除shop_id字段，店铺id
    7、移除is_member_discount字段，参与会员折扣
    8、shipping_fee对应is_free_shipping字段，是否免邮
    9、shipping_fee_id对应shipping_template字段，指定运费模板id
    10、stock对应goods_stock字段，商品库存
    11、min_stock_alarm对应goods_stock_alarm字段，库存预警
    12、移除star字段，好评星级
    13、移除shares字段，分享数
    14、evaluates对应evaluate字段，评价数
    15、移除province_id、city_id，地区id字段
    16、picture对应goods_image字段，商品主图路径
    17、goods_content对应description字段，商品详情
    18、移除QRcode字段，商品二维码
    19、移除is_stock_visible字段，页面不显示库存
    20、移除is_hot字段，是否热销商品
    21、移除is_recommend字段，是否推荐
    22、移除is_new字段，是否新品
    23、移除is_pre_sale字段，是否预售
    24、移除is_bill字段，是否开具增值税发票
    25、移除img_id_array字段，商品图片序列
    26、移除sku_img_array字段，商品sku应用图片列表
    27、移除match_point、match_ratio字段，实物与描述相符（根据评价计算）、百分比
    28、移除real_sales字段，实际销量
    29、goods_weight转移到ns_goods_sku表中的weight字段，重量（单位g）
    30、goods_volume转移到ns_goods_sku表中的volume字段，体积（单位立方米）
    31、移除shipping_fee_type字段，计价方式1.重量2.体积3.计件
    32、移除extend_category_id、extend_category_id_1、extend_category_id_2、extend_category_id_3字段
    33、移除production_date字段，生产日期
    34、移除shelf_life字段，保质期
    35、移除pc_custom_template字段，pc端商品自定义模板
    36、移除wap_custom_template字段，wap端商品自定义模板
    37、goods_video_address对应video_url字段，视频
    38、移除max_use_point字段，积分抵现最大可用积分数
    39、移除is_open_presell字段，是否支持预售
    40、移除presell_time、presell_day字段，预售发货时间/天数
    41、移除presell_delivery_type字段，预售发货方式1
    42、移除presell_price字段，预售金额
    43、goods_unit对应unit字段，单位
    44、移除decimal_reservation_number字段，价格保留方式 0 去掉角和分，1去掉分，2 保留角和分
    45、移除integral_give_type字段，积分赠送类型 0固定值 1按比率
16、ns_goods_sku表字段变动说明
    1、promote_price对应discount_price字段，促销价格
    2、移除QRcode字段，商品二维码
    3、移除sku_img_array字段，sku图片序列
    4、移除extend_json字段，虚拟扩展
EOT
        ],
        'member' => [
            'name' => '会员',
            'class' => 'addon\v3tov4\model\Member',
            'is_show' => 1,
            'introduction' => '迁移会员、等级、标签、收货地址、商品收藏、足迹、账户流水等数据',
            'desc' => <<<EOT
变动说明
1、丢失会员账户数据
2、会员主表 数据表: sys_user -> ns_member
    1、member_id 由 v3 sys_user uid对应转入
    2、source_member 来源会员id 查询v3  nfx_shop_member_association
    3、fenxiao_id 分销商id  查询会员是否是分销商 是则为自身分销商id 否查询上级分销商
    4、username  由 v3 sys_user user_name 字段对应转入
    5、nickname  由 v3 sys_user nick_name 字段对应转入
    6、mobile  由 v3 sys_user user_tel 字段对应转入
    7、email  由 v3 sys_user user_email 字段对应转入
    8、password  由 v3 sys_user user_password 字段对应转入
    9、headimg  头像需从v3站点进行拉取
    10、member_level、member_level_name、member_label、member_label_name 这些字段需关联v3 ns_member 查询到 会员等级 会员标签 去这两表中查询
    11、wx_openid 公众号openid v3 sys_user wx_openid 字段对应转入
    12、weapp_openid 小程序openid  v3 sys_user wx_applet_openid 字段对应转入
    13、realname  由v3 sys_user real_name 字段对应转入
    14、sex 由v3 sys_user sex 字段对应转入
    15、location  由v3 sys_user location 字段对应转入
    16、birthday  由v3 sys_user birthday 字段对应转入
    17、reg_time 由v3 sys_user reg_time 字段对应转入
    18、point 积分 由v3  ns_member_account point 字段对应转入
    19、balance 储值余额 由v3  ns_member_account balance 字段对应转入
EOT
        ],
        'fenxiao' => [
            'name' => '分销',
            'class' => 'addon\v3tov4\model\Fenxiao',
            'introduction' => '迁移分销商、分销商等级等数据',
            'is_show' => 0,
            'desc' => <<<EOT
变动说明
1、分销商 数据表:nfx_promoter -> ns_fenxiao 
    1、fenxiao_id  由v3 nfx_promoter promoter_id 字段对应转入
    2、fenxiao_no 按v4分销商编号生成规则生成
    3、fenxiao_name 由v3 nfx_promoter promoter_shop_name 字段对应转入
    4、mobile 由v3 nfx_promoter balance 字段对应转入
    5、member_id 由v3 nfx_promoter uid 字段对应转入
    6、level_id 由v3 nfx_promoter promoter_level 字段对应转入
    7、level_name 查询对应分销商等级名称
    8、parent 由v3 nfx_promoter parent_promoter 字段对应转入
    9、grand_parent 查询上上级分销商id
    10、account 当前佣金 由v3 nfx_promoter （commossion_total - commission_cash） 总佣金 - 已提现佣金
    11、account_withdraw 已提现佣金 由v3 nfx_promoter commission_cash 字段对应转入
    12、create_time 由v3 nfx_promoter audit_time 字段对应转入
    13、total_commission 累计佣金 由v3 nfx_promoter commossion_total 字段对应转入
2、分销商申请  数据表:nfx_promoter -> ns_fenxiao_apply
    1、fenxiao_name 由v3 nfx_promoter promoter_shop_name 字段对应转入
    2、parent 由v3 nfx_promoter parent_promoter 字段对应转入
    3、member_id 由v3 nfx_promoter uid 字段对应转入
    4、mobile 查询会员相应数据
    5、nickname 查询会员相应数据
    6、headimg 查询会员相应数据
    7、level_id 由v3 nfx_promoter promoter_level 字段对应转入
    8、level_name 查询相应分销商等级名称
    9、create_time 由v3 nfx_promoter regidter_time 字段对应转入
3、分销等级数据表：nfx_promoter_level -> ns_fenxiao_level
    1、level_id 由v3 nfx_promoter_level level_id 字段对应转入
    2、level_name 由v3 nfx_promoter_level level_name 字段对应转入
    3、one_rate 由v3 nfx_promoter_level  level_0 字段对应转入
    4、two_rate 由v3 nfx_promoter_level level_1 字段对应转入
    5、three_rate 由v3 nfx_promoter_level level_2 字段对应转入
    6、create_time 由v3 nfx_promoter_level create_time 字段对应转入
4、分销商品 （规则不同不做迁移）
EOT
        ],
//        'order' => [
//            'name' => '订单',
//            'class' => 'addon\v3tov4\model\Goods'
//        ]
    ];

    private $page_size = 10;

    /**
     * 获取数据迁移项
     * @return array
     */
    public function getTaskClass()
    {
        return $this->task_class;
    }

    /**
     * 获取分页
     * @return int
     */
    public function getPageSize()
    {
        return $this->page_size;
    }

    /**
     * 获取分页列表
     * @param $table
     * @param $where
     * @param $page
     * @param $page_size
     * @param $ailas
     * @param $join
     */
    final protected function getPageList($table, $where = [], $field = '*', $page = 1, $page_size = 10, $alias = '', $join = null)
    {
        $table = Db::connect($this->db)->table($table);
        if (!empty($join)) {
            $table = $this->parseJoin($table, $join);
        }
        $list = $table->alias($alias)->where($where)->field($field)->limit($page_size)->page($page)->select()->toArray();
        return $list;
    }

    /**
     * 获取列表
     * @param $table
     * @param array $where
     * @param string $field
     * @param string $alias
     * @param null $join
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    final protected function getList($table, $where = [], $field = '*', $order = "", $alias = '', $join = null)
    {
        $table = Db::connect($this->db)->table($table);
        if (!empty($join)) {
            $table = $this->parseJoin($table, $join);
        }
        $list = $table->alias($alias)->where($where)->order($order)->field($field)->select()->toArray();
        return $list;
    }

    /**
     * 查询单条数据
     * @param $table
     * @param array $where
     * @param string $field
     * @param string $alias
     * @param null $join
     * @return mixed
     */
    final protected function getInfo($table, $where = [], $field = '*', $alias = 'a', $join = null)
    {
        $table = Db::connect($this->db)->table($table);
        if (!empty($join)) {
            $table = $this->parseJoin($table, $join);
        }
        $info = $table->alias($alias)->where($where)->field($field)->find();
        return $info;
    }

    /**
     * sql查询
     * @param $sql
     * @return mixed
     */
    final protected function query($sql)
    {
        $res = Db::connect($this->db)->query($sql);
        return $res;
    }

    /**
     * 查询数量
     * @param $table
     * @param array $where
     * @param string $field
     */
    final protected function getCount($table, $where = [], $field = '*')
    {
        $table = Db::connect($this->db)->table($table);
        $count = $table->where($where)->count($field);
        return $count;
    }

    /**
     * join分析
     * @access protected
     * @param array $join
     * @param array $options 查询条件
     * @return string
     */
    final protected function parseJoin($db_obj, $join)
    {
        foreach ($join as $item) {
            list($table, $on, $type) = $item;
            $type = strtolower($type);
            switch ( $type ) {
                case "left":
                    $db_obj = $db_obj->leftJoin($table, $on);
                    break;
                case "inner":
                    $db_obj = $db_obj->join($table, $on);
                    break;
                case "right":
                    $db_obj = $db_obj->rightjoin($table, $on);
                    break;
                case "full":
                    $db_obj = $db_obj->fulljoin($table, $on);
                    break;
                default:
                    break;
            }
        }
        return $db_obj;
    }

    /**
     * 获取数据同步任务列表
     */
    public function getSyncTask($class)
    {
        $task_class = [];
        $class_array = explode(',', $class);
        foreach ($class_array as $item) {
            if (isset($this->task_class[ $item ])) {
                array_push($task_class, $this->task_class[ $item ][ 'class' ]);
                if ($item == 'member') {
                    array_push($task_class, $this->task_class[ 'fenxiao' ][ 'class' ]);
                }
            }
        }
        try {
            $methods = $this->getTaskMethod($task_class);
            $task = [];
            foreach ($methods as $method => $class_name) {
                $class = new $class_name();
                $count = $class->$method();
                if ($count > 0) {
                    for ($i = 0; $i < ceil(( $count / $this->page_size )); $i++) {
                        array_push($task, [
                            'class' => $class_name,
                            'method' => str_replace('Count', 'List', $method),
                            'page' => $i + 1,
                            'page_size' => $this->page_size
                        ]);
                    }
                }
            }
            return $task;
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 执行任务
     */
    public function run($task)
    {
        try {

            [ 'class' => $class_name, 'method' => $method, 'page' => $page, 'page_size' => $page_size ] = $task;
            $class = new $class_name();
            $res = $class->$method($page, $page_size);
            return $res;
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 获取类中的方法
     * @param $class_array
     * @return array
     * @throws \ReflectionException
     */
    private function getTaskMethod($class_array)
    {
        $method_array = [];
        foreach ($class_array as $class_name) {
            $class = new \ReflectionClass($class_name);
            $methods = $class->getMethods();
            foreach ($methods as $method) {
                if (strpos($method->name, 'Count') !== false && $method->name != 'getCount') {
                    $method_array[ $method->name ] = $method->class;
                }
            }
        }
        return $method_array;
    }
}