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

周大胖子 · 发表于 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
];
}

复制代码

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

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