同步修改

2018-12-05 16:24:44 +08:00 · 2018-12-05 16:24:44 +08:00 · 169a6ac86b
commit 169a6ac86b
parent d1fac1f03c
10 changed files with 357 additions and 34 deletions
--- a/app/Domains/Real/Commands/Sync/ActivateSync.php
+++ b/app/Domains/Real/Commands/Sync/ActivateSync.php
@ -6,6 +6,7 @@ use Carbon\Carbon;
 use App\Models\Real\Card;
 use MongoDB\BSON\UTCDateTime;
 use Illuminate\Support\Facades\DB;
+use App\Domains\Real\Repositories\CardRepository;
 use App\Domains\Real\Repositories\PackageRepository;

 class ActivateSync extends Command
@ -14,6 +15,8 @@ class ActivateSync extends Command

    protected $description = '同步RD激活数据';

+    protected $chunks = 1000;
+
    public function handle()
    {
        $datetime = $this->getDateTime();
@ -31,7 +34,7 @@ class ActivateSync extends Command
        $total = 0;

        $this->line('拼装更新数据:'.count($res));
-        $chucks = array_chunk($res, 10000);
+        $chucks = array_chunk($res, $this->chunks);
        foreach ($chucks as $chuck) {
            echo '.';
            $cards = Card::select(['sim', 'package_id'])->whereIn('sim', array_pluck($chuck, 'cNo'))->get()->keyBy('sim')->toArray();
@ -62,9 +65,11 @@ class ActivateSync extends Command

        foreach (array_chunk($list, 3000) as $data) {
            echo '.';
-            Card::upsert($data, 'sim');
+            app(CardRepository::class)->updateActivateAt($data);
        }

+        app(CardRepository::class)->forgetCached();
+
        $this->line('更新数据成功');
    }
 }
--- a/app/Domains/Real/Commands/Sync/OrderBaseSync.php
+++ b/app/Domains/Real/Commands/Sync/OrderBaseSync.php
@ -23,7 +23,7 @@ class OrderBaseSync extends Command

    protected static $carrierOperators = [1, 0, 2];

-    protected $chunks = 5000;
+    protected $chunks = 1000;

    public function handle()
    {
@ -31,6 +31,7 @@ class OrderBaseSync extends Command
        
        $cards = $this->getCards();

+        $this->chunks *
        $bar = $this->output->createProgressBar(count($cards));

        $card_details = $this->getCardDetails($cards);
@ -137,7 +138,7 @@ class OrderBaseSync extends Command

        foreach ($cardChunks as $cardChunk) {
            echo '.';
-            $res = DB::connection('mongo')->table('tblCard')->select(['cNo', 'bNo', 'sPCode', 'iccid', 'imsi', 'soDate', 'comId', 'oType', 'jBatchNo'])
+            $res = DB::connection('mongo')->table('tblCard')->select(['cNo', 'iccid', 'imsi', 'comId', 'oType'])
                ->where('isDel', '<>', 1)
                ->whereIn('cNo', array_pluck($cardChunk, 'sim'))->get()->toArray();
        
@ -257,7 +258,7 @@ class OrderBaseSync extends Command
                'updated_at' => date('Y-m-d H:i:s'),
            ];

-            $dataOrderCards[] = [
+            $dataOrderCards[$value['sim']] = [
                'sim' => $value['sim'],
                'order_id' => $value['order_id'],
                'counts' => 1,
--- a/app/Domains/Real/Commands/Sync/OrderCustomSync.php
+++ b/app/Domains/Real/Commands/Sync/OrderCustomSync.php
@ -7,6 +7,7 @@ use Carbon\Carbon;
 use App\Models\Real\Order;
 use MongoDB\BSON\UTCDateTime;
 use Illuminate\Support\Facades\DB;
+use App\Domains\Real\Services\CommonService;
 use App\Domains\Real\Repositories\OrderRepository;

 class OrderCustomSync extends Command
@ -15,7 +16,7 @@ class OrderCustomSync extends Command

    protected $description = '同步RD企业订单数据';

-    protected $chunks = 5000;
+    protected $chunks = 1000;

    public function handle()
    {
@ -38,7 +39,7 @@ class OrderCustomSync extends Command
            $dataOrders[$value['order_id']] = [
                'id' => $value['order_id'],
                'type' => $value['type'],
-                'company_id' => $order['company_id'],
+                'company_id' => CommonService::parseCompanyId($order['company_id']),
                'transaction_no' => $order['transaction_no'],
                'pay_channel' => $order['pay_channel'],
                'unit_price' => $order['unit_price'],
@ -49,14 +50,14 @@ class OrderCustomSync extends Command
                'updated_at' => date('Y-m-d H:i:s'),
            ];

-            $dataOrderCards[$value['type']][] = [
+            $dataOrderCards[$value['type']][$value['sim']] = [
                'sim' => $value['sim'],
                'order_id' => $value['order_id'],
                'counts' => $value['item_counts'],
                'unit_price' => $value['item_unit_price'],
            ];

-            $dataPackageCards[$value['type']][] = [
+            $dataPackageCards[$value['type']][$value['sim']] = [
                'package_id' => $value['package_id'],
                'sim' => $value['sim'],
            ];
--- a/app/Domains/Real/Commands/Sync/PackageSync.php
+++ b/app/Domains/Real/Commands/Sync/PackageSync.php
@ -35,13 +35,19 @@ class PackageSync extends Command
        $renewalPackages = $this->getRenewalPackages();

        foreach ($renewalPackages as &$item) {
-            $item['carrier_operator'] = $basePackages[$item['parent_id']]['carrier_operator'];
-            $item['flows'] = $basePackages[$item['parent_id']]['flows'];
-            $item['voices'] = $basePackages[$item['parent_id']]['voices'];
-            $item['messages'] = $basePackages[$item['parent_id']]['messages'];
-            $item['has_message_switch'] = $basePackages[$item['parent_id']]['has_message_switch'];
-            $item['has_lbs'] = $basePackages[$item['parent_id']]['has_lbs'];
-            $item['reset_months'] = $basePackages[$item['parent_id']]['reset_months'];
+            $basePackage = $basePackages[$item['parent_id']];
+
+            if (!$basePackage) {
+                throw new \App\Exceptions\InvalidArgumentException('续费包未找到对应基础套餐 #:'.$$item['id']);
+            }
+
+            $item['carrier_operator'] = $basePackage['carrier_operator'];
+            $item['flows'] = $basePackage['flows'];
+            $item['voices'] = $basePackage['voices'];
+            $item['messages'] = $basePackage['messages'];
+            $item['has_message_switch'] = $basePackage['has_message_switch'];
+            $item['has_lbs'] = $basePackage['has_lbs'];
+            $item['reset_months'] = $basePackage['reset_months'];
        }

        $flowPackages = $this->getFlowPackages();
@ -51,7 +57,7 @@ class PackageSync extends Command
        $packages = array_merge($basePackages, $renewalPackages, $flowPackages, $optionalPackages, $additionalPackages);

        Package::upsert($packages, 'id');
-        
+
        app(PackageRepository::class)->forgetCached();
    }

@ -73,11 +79,13 @@ class PackageSync extends Command
            'jxc_package.flow_cycle as reset_months',
            'jxc_package.package_cycle as service_months',
            'jxc_package.del as del',
-            'jxc_package.description as description',
            DB::raw("FROM_UNIXTIME(jxc_package.create_time, '%Y-%m-%d %H:%i:%s') as created_at"),
        ];

-        $packages = DB::connection('real')->table('jxc_package')->select($select)->where('type', 11)->get();
+        $packages = DB::connection('real')->table('jxc_package')->join('jxc_package_custom_relation', function ($join) {
+            $join->on('jxc_package_custom_relation.package_sn', '=', 'jxc_package.package_sn')
+            ->whereIn('jxc_package_custom_relation.custom_no', $this->companies);
+        })->select($select)->where('type', 11)->get();

        return $this->transform($packages);
    }
@ -95,10 +103,13 @@ class PackageSync extends Command
            'jxc_package_renewal.service_cycle as service_months',
            'jxc_package_renewal.create_time as created_at',
            'jxc_package_renewal.del',
-            'jxc_package_renewal.remark as description',
        ];

-        $packages = DB::connection('real')->table('jxc_package_renewal')->select($select)->get();
+        $packages = DB::connection('real')->table('jxc_package_renewal')->join('jxc_package_value_add_relation', function ($join) {
+            $join->on('jxc_package_value_add_relation.value_add_number', '=', 'jxc_package_renewal.bag_number')
+            ->whereIn('jxc_package_value_add_relation.custom_no', $this->companies)
+            ->where('jxc_package_value_add_relation.type', 1);
+        })->select($select)->get();

        return $this->transform($packages);
    }
@ -121,10 +132,13 @@ class PackageSync extends Command
            'jxc_package_flows.service_cycle as service_months',
            'jxc_package_flows.create_time as created_at',
            'jxc_package_flows.del',
-            'jxc_package_flows.remark as description',
        ];

-        $packages = DB::connection('real')->table('jxc_package_flows')->select($select)->get();
+        $packages = DB::connection('real')->table('jxc_package_flows')->join('jxc_package_value_add_relation', function ($join) {
+            $join->on('jxc_package_value_add_relation.value_add_number', '=', 'jxc_package_flows.bag_number')
+            ->whereIn('jxc_package_value_add_relation.custom_no', $this->companies)
+            ->where('jxc_package_value_add_relation.type', 2);
+        })->select($select)->get();

        return $this->transform($packages);
    }
@ -147,10 +161,13 @@ class PackageSync extends Command
            'jxc_package_optional.service_cycle as service_months',
            'jxc_package_optional.create_time as created_at',
            'jxc_package_optional.del',
-            'jxc_package_optional.remark as description',
        ];

-        $packages = DB::connection('real')->table('jxc_package_optional')->select($select)->get();
+        $packages = DB::connection('real')->table('jxc_package_optional')->join('jxc_package_value_add_relation', function ($join) {
+            $join->on('jxc_package_value_add_relation.value_add_number', '=', 'jxc_package_optional.bag_number')
+            ->whereIn('jxc_package_value_add_relation.custom_no', $this->companies)
+            ->where('jxc_package_value_add_relation.type', 3);
+        })->select($select)->get();

        return $this->transform($packages);
    }
@ -171,10 +188,13 @@ class PackageSync extends Command
            'jxc_package_addoptional.service_cycle as service_months',
            'jxc_package_addoptional.create_time as created_at',
            'jxc_package_addoptional.del',
-            'jxc_package_addoptional.package_remark as description',
        ];

-        $packages = DB::connection('real')->table('jxc_package_addoptional')->select($select)->where('jxc_package_addoptional.tid', 1)->get();
+        $packages = DB::connection('real')->table('jxc_package_addoptional')->join('jxc_package_value_add_relation', function ($join) {
+            $join->on('jxc_package_value_add_relation.value_add_number', '=', 'jxc_package_addoptional.bag_number')
+            ->whereIn('jxc_package_value_add_relation.custom_no', $this->companies)
+            ->where('jxc_package_value_add_relation.type', 4);
+        })->select($select)->where('jxc_package_addoptional.tid', 1)->get();

        return $this->transform($packages);
    }
--- a/app/Domains/Real/Repositories/CardRepository.php
+++ b/app/Domains/Real/Repositories/CardRepository.php
@ -4,6 +4,7 @@ namespace App\Domains\Real\Repositories;

 use App\Core\Repository;
 use App\Models\Real\Card as Model;
+use Illuminate\Support\Facades\DB;

 class CardRepository extends Repository
 {
@ -60,4 +61,23 @@ class CardRepository extends Repository

        return $this;
    }
+
+
+    /**
+     * 批量更新激活时间
+     *
+     * @return void
+     */
+    public function updateActivateAt(array $data)
+    {
+        $connection = $this->model->getConnection();
+
+        $arr = array_map(function ($value) {
+            return sprintf("('%s', '%s')", $value['sim'], $value['activate_at']);
+        }, $data);
+
+        $sql = 'UPDATE real_cards SET activate_at = list.activate_at::timestamp FROM (VALUES ' . implode(',', $arr) . ') AS list(sim, activate_at) WHERE real_cards.sim = list.sim AND real_cards.activate_at IS NULL';
+
+        return $connection->update($sql);
+    }
 }
--- a/database/migrations/2018_11_27_175137_create_base_tables.php
+++ b/database/migrations/2018_11_27_175137_create_base_tables.php
@ -32,7 +32,10 @@ class CreateBaseTables extends Migration
        foreach (app(Dicts::class)->get('tables') as $prefix => $type) {
            Schema::create("{$prefix}_companies", function (Blueprint $table) {
                $table->increments('id')->comment('企业编号');
-                $table->string('name', 32)->comment('企业名称');
+                $table->string('name', 32)->default('')->comment('企业名称');
+                $table->string('phone', 20)->default('')->comment('手机号');
+                $table->string('username', 32)->default('')->comment('登录名');
+                $table->string('password', 32)->default('')->comment('密码');
                $table->timestamps();
                $table->softDeletes();
            });
@ -79,12 +82,12 @@ class CreateBaseTables extends Migration
                $table->string('price', 20)->comment('单价');
                $table->tinyInteger('carrier_operator')->unsigned()->default(255)->comment('运营商(0:联通 1:移动 2:电信)');
                $table->timestamp('activate_at')->nullable()->comment('激活时间');
+                $table->timestamp('virtual_activate_at')->nullable()->comment('虚拟激活时间');
                $table->timestamps();
    
                $table->primary('sim');
                $table->index('imsi');
                $table->index('iccid');
-                $table->index('activate_at');
            });
    
            db_alter("{$prefix}_cards", "{$type}卡基础信息表");
@ -95,7 +98,7 @@ class CreateBaseTables extends Migration
                $table->string('id', 32)->comment('订单编号');
                $table->tinyInteger('type')->unsigned()->default(255)->comment('订单类型（0:基础套餐 1:套餐续费 2：续费包 3:加油包 4:可选包 5:附加包）');
                $table->integer('company_id')->unsigned()->default(0)->comment("{$type}企业编号");
-                $table->string('transaction_no', 20)->comment('交易流水号');
+                $table->string('transaction_no', 64)->comment('交易流水号');
                $table->tinyInteger('pay_channel')->unsigned()->default(0)->comment('支付方式(0:银行转账 1:账户余额 2:微信支付 3:支付宝 4:天猫续费)');
                $table->integer('unit_price')->unsigned()->default(0)->comment('单价');
                $table->integer('counts')->unsigned()->default(0)->comment('数量');
--- a/database/migrations/2018_11_27_175146_create_order_tables.php
+++ b/database/migrations/2018_11_27_175146_create_order_tables.php
@ -39,6 +39,8 @@ class CreateOrderTables extends Migration
                    $table->integer('counts')->unsigned()->default(1)->comment('数量');
                    $table->integer('unit_price')->unsigned()->default(0)->comment('单价');
                    $table->primary(['order_id', 'sim']);
+                    
+                    $table->unique('sim');
                });
    
                db_alter($table_name, $table_comment);
--- a/database/migrations/2018_11_27_175152_create_package_tables.php
+++ b/database/migrations/2018_11_27_175152_create_package_tables.php
@ -27,6 +27,8 @@ class CreatePackageTables extends Migration
                $table->string('package_id', 20)->comment('套餐编号');
                $table->string('sim', 20)->comment('sim卡号');
                $table->primary(['package_id', 'sim']);
+
+                $table->unique('sim');
            });

            db_alter($table_name, $table_comment);
--- a/postgres.sql
+++ b/postgres.sql
@ -0,0 +1,273 @@
+CREATE SERVER IF NOT EXISTS "mysql_real" FOREIGN DATA WRAPPER "mysql_fdw" OPTIONS ( host 'rm-bp13y52rav2jc6952o.mysql.rds.aliyuncs.com', port '3306');
+CREATE USER MAPPING IF NOT EXISTS FOR "root" SERVER "mysql_real" OPTIONS (username 'fdw_readonly', password 'Fxft123456');
+
+-- ----------------------------
+-- Table structure for jxc_custom
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_custom" (
+  "custom_no" varchar(20) COLLATE "pg_catalog"."default" NOT NULL,
+  "name" varchar(20) COLLATE "pg_catalog"."default" NOT NULL,
+  "status" int2 NOT NULL,
+  "del" int2 NOT NULL,
+  "create_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL,
+  "update_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_custom');
+
+-- ----------------------------
+-- Table structure for jxc_custom_order
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_custom_order" (
+  "sn" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "custom_no" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "pay_no" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "transaction_no" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "sim_count" int4 NOT NULL,
+  "amount_money" float8 NOT NULL,
+  "paytype" varchar(20) COLLATE "pg_catalog"."default" NOT NULL,
+  "status" int2 NOT NULL,
+  "pay_time" varchar(19) NOT NULL,
+  "create_date" varchar(10) COLLATE "pg_catalog"."default" NOT NULL,
+  "create_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL,
+  "update_time" varchar(19) NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_custom_order');
+
+-- ----------------------------
+-- Table structure for jxc_custom_order_item
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_custom_order_item" (
+  "sn" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "sim" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "goods_no" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "goods_name" varchar(100) COLLATE "pg_catalog"."default" NOT NULL,
+  "goods_type" int2 NOT NULL,
+  "unit_price" float8 NOT NULL,
+  "amount_price" float8 NOT NULL,
+  "quantity" int4 NOT NULL,
+  "custom_no" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "create_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_custom_order_item');
+
+-- ----------------------------
+-- Table structure for jxc_order
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_order" (
+  "o_number" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_card_use" varchar(10) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_customer_number" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_customer_relation_id" int4 NOT NULL,
+  "o_customer_name" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_p_number" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_p_name" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_price" float8 NOT NULL,
+  "o_hastest" int2 NOT NULL,
+  "o_has_empty" int2 NOT NULL,
+  "o_testing_period_type" int2 NOT NULL,
+  "o_test_time" int4 NOT NULL,
+  "o_testing_period_start" date NOT NULL,
+  "o_testing_period_end" date NOT NULL,
+  "o_test_flows_type" varchar(10) COLLATE "pg_catalog"."default",
+  "o_test_flows" varchar(20) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_test_msg" int4 NOT NULL,
+  "o_silent_period_type" int2,
+  "o_silent_time" int4 NOT NULL,
+  "o_silent_period_start" date NOT NULL,
+  "o_silent_period_end" date NOT NULL,
+  "o_renewal_price" float8 NOT NULL,
+  "o_number_type" int2 NOT NULL,
+  "o_card_counts" int4 NOT NULL,
+  "o_amount" float8 NOT NULL,
+  "o_create_date" date NOT NULL,
+  "o_remark" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_status" varchar(10) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_delivery_man" int4 NOT NULL,
+  "o_delivery_time" varchar(19) NOT NULL,
+  "o_is_del" int2 NOT NULL,
+  "o_create_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_update_time" varchar(19) NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_order');
+
+-- ----------------------------
+-- Table structure for jxc_order_single_row
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_order_single_row" (
+  "s_id" int4 NOT NULL,
+  "s_number" varchar(20) COLLATE "pg_catalog"."default" NOT NULL,
+  "o_number" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "s_card_counts" int4 NOT NULL,
+  "s_status" int2 NOT NULL,
+  "s_remark" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
+  "s_create_time" varchar(10) COLLATE "pg_catalog"."default" NOT NULL,
+  "s_update_time" varchar(19) NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_order_single_row');
+
+-- ----------------------------
+-- Table structure for jxc_order_single_row_item
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_order_single_row_item" (
+  "i_id" int4 NOT NULL,
+  "s_number" varchar(20) COLLATE "pg_catalog"."default" NOT NULL,
+  "s_out_number" int4 NOT NULL,
+  "s_batch_number" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "s_section_number" text COLLATE "pg_catalog"."default" NOT NULL,
+  "s_sim_start" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "s_is_serial" int2 NOT NULL,
+  "i_status" int2 NOT NULL,
+  "i_remark" varchar(255) COLLATE "pg_catalog"."default" NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_order_single_row_item');
+
+-- ----------------------------
+-- Table structure for jxc_package
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package" (
+  "package_sn" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "name" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "type" int2 NOT NULL,
+  "carrieroperator" varchar(2) COLLATE "pg_catalog"."default" NOT NULL,
+  "price" varchar(10) COLLATE "pg_catalog"."default" NOT NULL,
+  "guide_price" varchar(10) COLLATE "pg_catalog"."default",
+  "flows" varchar(255) COLLATE "pg_catalog"."default",
+  "voices" int4,
+  "short_msg" int4,
+  "short_msg_on" int2,
+  "lbs" int2,
+  "flow_cycle" int4,
+  "package_cycle" int4,
+  "status" int2 NOT NULL,
+  "del" int2 NOT NULL,
+  "create_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL,
+  "update_time" varchar(11) COLLATE "pg_catalog"."default" NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package');
+
+-- ----------------------------
+-- Table structure for jxc_package_addoptional
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package_addoptional" (
+  "bag_number" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "name" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "type_content" varchar(50) COLLATE "pg_catalog"."default",
+  "content_count" varchar(100) COLLATE "pg_catalog"."default",
+  "content_unit" varchar(20) COLLATE "pg_catalog"."default",
+  "service_cycle" int4,
+  "reset_cycle" int4,
+  "guide_price" numeric,
+  "effect_immediate" int2,
+  "package_remark" varchar(100) COLLATE "pg_catalog"."default",
+  "status" "real"."status_t",
+  "del" "real"."del_t",
+  "create_time" varchar(19),
+  "update_time" varchar(19)
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package_addoptional');
+
+-- ----------------------------
+-- Table structure for jxc_package_custom_relation
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package_custom_relation" (
+  "custom_no" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "package_sn" varchar(30) COLLATE "pg_catalog"."default" NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package_custom_relation');
+
+-- ----------------------------
+-- Table structure for jxc_package_flows
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package_flows" (
+  "bag_number" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "name" varchar(100) COLLATE "pg_catalog"."default" NOT NULL,
+  "carrieroperator" char(2) COLLATE "pg_catalog"."default",
+  "flows" int4,
+  "short_msg" int4,
+  "voices" int4,
+  "lbs" int2,
+  "flows_cycle" int4,
+  "service_cycle" int4 NOT NULL,
+  "price" numeric NOT NULL,
+  "guide_price" numeric,
+  "effect_immediate" int2,
+  "operator" int4 NOT NULL,
+  "status" "real"."status_t" NOT NULL,
+  "del" "real"."del_t" NOT NULL,
+  "create_time" varchar(19) NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package_flows');
+
+-- ----------------------------
+-- Table structure for jxc_package_optional
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package_optional" (
+  "bag_number" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "name" varchar(100) COLLATE "pg_catalog"."default" NOT NULL,
+  "carrieroperator" char(2) COLLATE "pg_catalog"."default",
+  "flows" int4,
+  "short_msg" int4,
+  "voices" int4,
+  "lbs" int2,
+  "flows_cycle" int4,
+  "service_cycle" int4 NOT NULL,
+  "price" numeric NOT NULL,
+  "guide_price" numeric,
+  "effect_immediate" int2,
+  "base_service_cycle_extend" int2,
+  "remark" text COLLATE "pg_catalog"."default",
+  "status" "real"."status_t" NOT NULL,
+  "del" "real"."del_t" NOT NULL,
+  "create_time" varchar(19) NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package_optional');
+
+-- ----------------------------
+-- Table structure for jxc_package_renewal
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package_renewal" (
+  "bag_number" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "package_sn" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "name" varchar(100) COLLATE "pg_catalog"."default" NOT NULL,
+  "service_cycle" int4 NOT NULL,
+  "price" numeric NOT NULL,
+  "guide_price" numeric,
+  "effect_immediate" int2,
+  "remark" text COLLATE "pg_catalog"."default",
+  "status" "real"."status_t" NOT NULL,
+  "del" "real"."del_t" NOT NULL,
+  "create_time" varchar(19) NOT NULL
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package_renewal');
+
+-- ----------------------------
+-- Table structure for jxc_package_value_add_relation
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_package_value_add_relation" (
+  "id" int4 NOT NULL,
+  "type" int2 NOT NULL,
+  "custom_no" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "package_sn" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "package_name" varchar(100) COLLATE "pg_catalog"."default",
+  "value_add_id" int4 NOT NULL,
+  "value_add_number" varchar(30) COLLATE "pg_catalog"."default" NOT NULL,
+  "value_add_name" varchar(100) COLLATE "pg_catalog"."default",
+  "wx_package_show" int2,
+  "del" "real"."del_t",
+  "create_time" varchar(19)
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_package_value_add_relation');
+
+-- ----------------------------
+-- Table structure for jxc_user
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_user" (
+  "id" int4 NOT NULL,
+  "username" varchar(64) COLLATE "pg_catalog"."default" NOT NULL,
+  "nickname" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "last_login_time" int4,
+  "last_login_ip" varchar(40) COLLATE "pg_catalog"."default",
+  "email" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
+  "phone" varchar(20) COLLATE "pg_catalog"."default",
+  "parent_user" int4,
+  "role_tag" varchar(10) COLLATE "pg_catalog"."default",
+  "status" int2,
+  "del" int2 NOT NULL,
+  "create_time" int4,
+  "update_time" int4
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_user');
+
+-- ----------------------------
+-- Table structure for jxc_user_custom_relation
+-- ----------------------------
+CREATE FOREIGN TABLE IF NOT EXISTS "real"."jxc_user_custom_relation" (
+  "uid" int4,
+  "custom_no" varchar(20) COLLATE "pg_catalog"."default"
+) SERVER "mysql_real" OPTIONS ("dbname" 'ckb_jxc', "table_name" 'jxc_user_custom_relation');
--- a/public/index.php
+++ b/public/index.php
@ -1,9 +1,5 @@
 <?php

-phpinfo();
-
-exit();
-
 /*
 |--------------------------------------------------------------------------
 | Create The Application