周大胖子 发表于 2020-8-5 17:27:02

关于 如何同步主系统内部的可售商标问题

========================================= 关于 如何同步主系统内部的可售商标问题

        明确: 直接从数据库走,跳过token 环节;
               
        问题1:我有两个数据库,a,b   里面有部分表内容相同, 使用者甲 发起模糊请求 ,我可以分别获取a 和 b 内的数据,可 我该如何做到均衡 ?[比方说,第一页显示20条数据 ]
       
                老莫同学的点子:
               
                        1. 查就查呗,先查本地数据库,判断够不够,不够当页条数的,去拿主系统的;
                       
                                1.1 问题来了:主系统也是按照请求算的,那主系统也会有个对应的请求范围[第几页] ;
                                       
                                                比方说:第4页没有,我取了主系统前20条 ,第五页也没有,我怎么知道我该去 21-40条?
                               
       

        方法1:
       
                每次查的时候。连调 权客云数据 [数据可以实时更新]
               
               
       
        方法2:
       
                阶段性,将主系统可售商标信息复制一份到本地,每次更新时,删除原本的,再复制新的,效率太差,但是操作容易


                排除方法2 :
       
       
       
        方法1的 请求逻辑:
       *请求逻辑:
   *      a : 本系统数据库 ;
   *      b : 权客云数据库 ;
   *
   *      1. 带入请求条件,分别请求 a , b 内的符合条件的总数 aNum, bNum ;
   *      2. 页数,请求条数 为 必填值,如果不填 有默认值 page = 1 , limit= 20 ;
   *      3. page*limit = nowNum ; [为当前值]
   *      4. 判断 if( nowNum <= aNum){
   *                     ------如果请求数小于或等于a的总数----
   *                      [只取本地内的数据]   
   *            } else if(nowNum>aNum ){
   *                      ------如果请求数大于a的总数----
   *                     
   *                      if( nowNum+limit < aNum ){
   *                           -----且如果 处于ab之间,------
   *                           [则请求a 并且请求b,然后组装 ]
   *                      }else{
   *                           ----直接请求b------
   *                           
   *                              从多少条起步,拿去limit的 长度这样则不需要算页数;               
   *         
   *
   *                      }
   *            };
   *       5. 返回值有limit, 有page有 count , 有data [两者拼凑]   


最后的逻辑代码:
/**
   *请求逻辑:
   *      a : 本系统数据库 ;
   *      b : 权客云数据库 ;
   *
   *      1. 带入请求条件,分别请求 a , b 内的符合条件的总数 aNum, bNum ;
   *      2. 页数,请求条数 为 必填值,如果不填 有默认值 page = 1 , limit= 20 ;
   *      3. page*limit = nowNum ; [为当前值]
   *      4. 判断 if( nowNum <= aNum){
   *                     ------如果请求数小于或等于a的总数----
   *                      [只取本地内的数据]
   *            } else if(nowNum>aNum ){
   *                      ------如果请求数大于a的总数----
   *
   *                      if( nowNum < aNum+limit){
   *                           -----且如果 处于ab之间,------
   *                           [则请求a 并且请求b,然后组装 ]
   *                      }else{
   *                           ----直接请求b------
   *
   *                              从多少条起步,拿去limit的 长度这样则不需要算页数;
   *
   *
   *                      }
   *            };
   *       5. 返回值有limit, 有page有 count , 有data [两者拼凑]
   *
   *
   *
   *
   *      端口请求: http://www.newadmin.com/getsell?page=3&limit=15
   *      参  数: page   limit [有默认值]
   *
   *
   */
    public function getsell(Request $request)
    {

      // 提取页码和条数 没有则使用默认值
      $page = (int) $request->input('page');
      if (empty($request->input('page'))) {
            $page = 1;
      }

      $limit = (int) $request->input('limit');
      if (empty($request->input('limit'))) {
            $limit = 20;
      }

      // 整合请求条件a
      $aMap = function ($query) use ($request) {
            $query->where('id', '>', 0);
      };
      // 整合请求条件b
      $bMap = function ($query) use ($request) {
            
            // $query->where('id', '>=', 50);
            $query->where('t2.priceStatus', '=', 2);
      };
      // 整合b的最终转换
      $bChangeArr = [
            DB::raw('"3" as addtype'),
            "t1.id",
            "t1.tmNameText",
            "t1.tmIRNumberText as tmNumberText",
            "t1.tmClassText as ctype",
            "t1.dateApplication as registerDate",
            "t1.tmRightEndDate as specialEndDate",
            "t2.priceStatus"
            ];

      // 获取 ab 的总数
      $aNum =CmsSellTrademark::where($aMap)->count();
      $bNum =DB::connection('mysql_quancloud')
                  ->table('trademark_detail as t1')
                  ->join('trademark_currency as t2', 't2.id', '=', 't1.businessId')
                  ->where($bMap)
                  ->count();

      // 判断当前总条数
      $nowNum = $page*$limit ;

      $resData = array();
         
      if ($nowNum <= $aNum) {
            //------如果请求数小于或等于a的总数---- // return '只取本地内的数据';

            // 初始数据
            $surplus =$limit*($page-1);

            //分页 会自动判断 参数中的page 值 这里只需要条数就可以
            $resData =CmsSellTrademark::where($aMap)->offset($surplus)->limit($limit)->get();
      } elseif ($nowNum>$aNum) {
            //    ------如果请求数大于a的总数----
                  
            if ($nowNum < $aNum +$limit) {
                // 初始数据
                $surplus =$limit*($page-1);
                        
                //    -----且如果 处于ab之间,------// return '则请求a 并且请求b,然后组装';
                $aResData =CmsSellTrademark::where($aMap)->offset($surplus)->limit($limit)->get()->toArray();

                // 看一下剩余多少条
                $otherSurplus = $limit - count($aResData);

                $bResData = DB::connection('mysql_quancloud')
                                        ->table('trademark_detail as t1')
                                        ->join('trademark_currency as t2', 't2.id', '=', 't1.businessId')
                                        ->select($bChangeArr)
                                        ->where($bMap)
                                        ->offset(0)
                                        ->limit($otherSurplus)
                                        ->get()
                                        ->toArray();

                $resData = array_merge($aResData, $bResData);
            } else {
                // ----直接请求b------// 从多少条起步,拿去limit的 长度这样则不需要算页数 ,"t2.priceRange"priceRange为售价范围 ,priceStatus=2为售价开关   1未关 //return '直接请求b';
                $surplus = $limit*$page - $aNum;

                $resData = DB::connection('mysql_quancloud')
                                        ->table('trademark_detail as t1')
                                        ->join('trademark_currency as t2', 't2.id', '=', 't1.businessId')
                                        ->select($bChangeArr)
                                        ->where($bMap)
                                        ->offset($surplus)
                                        ->limit($limit)
                                        ->get();
            }
      };

      return [
            'code' => 0,
            'message' => '请求成功',
            'count' => $aNum + $bNum,
            'page' => $page ,
            'limit' =>$limit,
            'data' => $resData
      ];
    }




页: [1]
查看完整版本: 关于 如何同步主系统内部的可售商标问题