In Yii 2.0, the console command line, add the implementation of the parameters
1, CMCConsoleUser/ActionSync, existing implementation, reference:https://www.shuijingwanwq.com/2020/03/02/3964/, now need to add parameters: tenant ID
2. The parameter will be passed to the action method corresponding to the requested subcommand. Set the default value of the parameter $groupid to null
public function actionSync($groupId = null)
3. Determine whether the $groupId is empty, if it is not empty, and it does not exist in $HttpCMCAPiGroupIds, it successfully exits
/* 判断 $groupId 是否为空，如果不为空，且在 $httpCmcApiGroupIds 中不存在，则成功退出 */
if (!empty($groupId) && !in_array($groupId, $httpCmcApiGroupIds)) {
return ExitCode::OK;
}
4. Based on the chronological arrangement of the last synchronization, assign the value to: $sortcmCapiGroupIds, the array before and after printing the sorting
// 基于上次同步时间顺序排列，赋值给：$sortCmcApiGroupIds
$sortCmcApiGroupIds = $cmcApiGroupIds;
print_r($sortCmcApiGroupIds);
ArrayHelper::multisort($sortCmcApiGroupIds, 'cmc_console_user_last_synced_at', SORT_ASC);
print_r($sortCmcApiGroupIds);
exit;
PS E:\wwwroot\pcs-api> ./yii cmc-console-user/sync
Array
(
[0] => Array
(
[group_id] => c10e87f39873512a16727e17f57456a5
[cmc_console_user_last_synced_at] => 1590649259
)
[1] => Array
(
[group_id] => 015ce30b116ce86058fa6ab4fea4ac63
[cmc_console_user_last_synced_at] => 0
)
[2] => Array
(
[group_id] => 4fd58ceba1fbc537b5402302702131eb
[cmc_console_user_last_synced_at] => 0
)
[3] => Array
(
[group_id] => f53df1a8d46108afc8ae9eeb3f0e1f0e
[cmc_console_user_last_synced_at] => 0
)
[4] => Array
(
[group_id] => e774bfcf8fc4cfe2ce57ac875a266e94
[cmc_console_user_last_synced_at] => 0
)
[5] => Array
(
[group_id] => b28312e46044da2682e540d1fb838c67
[cmc_console_user_last_synced_at] => 0
)
)
Array
(
[0] => Array
(
[group_id] => 015ce30b116ce86058fa6ab4fea4ac63
[cmc_console_user_last_synced_at] => 0
)
[1] => Array
(
[group_id] => 4fd58ceba1fbc537b5402302702131eb
[cmc_console_user_last_synced_at] => 0
)
[2] => Array
(
[group_id] => f53df1a8d46108afc8ae9eeb3f0e1f0e
[cmc_console_user_last_synced_at] => 0
)
[3] => Array
(
[group_id] => e774bfcf8fc4cfe2ce57ac875a266e94
[cmc_console_user_last_synced_at] => 0
)
[4] => Array
(
[group_id] => b28312e46044da2682e540d1fb838c67
[cmc_console_user_last_synced_at] => 0
)
[5] => Array
(
[group_id] => c10e87f39873512a16727e17f57456a5
[cmc_console_user_last_synced_at] => 1590649259
)
)
5. Now it is necessary to synchronize the users under this tenant based on the value of the parameter $groupId, that is, the tenant needs to be ranked first. to meet the needs. Destroy the $groupId in the $sortcmcapiGroupIds first, and then insert it to the beginning. Print the array before and after sorting. in line with expectations. as shown in Figure 1
Figure 1
// 基于上次同步时间顺序排列，赋值给：$sortCmcApiGroupIds
$sortCmcApiGroupIds = $cmcApiGroupIds;
print_r($sortCmcApiGroupIds);
ArrayHelper::multisort($sortCmcApiGroupIds, 'cmc_console_user_last_synced_at', SORT_ASC);
print_r($sortCmcApiGroupIds);
/* 判断 $groupId 是否为空，如果不为空 */
if (!empty($groupId)) {
// 销毁 $sortCmcApiGroupIds 中的 $groupId
foreach ($sortCmcApiGroupIds as $sortCmcApiGroupIdKey => $sortCmcApiGroupId) {
if ($sortCmcApiGroupId['group_id'] == $groupId) {
unset($sortCmcApiGroupIds[$sortCmcApiGroupIdKey]);
break;
}
}
print_r($sortCmcApiGroupIds);
// 将 $groupId 插入至 $sortCmcApiGroupIds 的开头
array_unshift($sortCmcApiGroupIds, [
'group_id' => $groupId,
'cmc_console_user_last_synced_at' => 0, //上次同步时间
]);
}
print_r($sortCmcApiGroupIds);
exit;
PS E:\wwwroot\pcs-api> ./yii cmc-console-user/sync b28312e46044da2682e540d1fb838c67
Array
(
[0] => Array
(
[group_id] => c10e87f39873512a16727e17f57456a5
[cmc_console_user_last_synced_at] => 1590649259
)
[1] => Array
(
[group_id] => 015ce30b116ce86058fa6ab4fea4ac63
[cmc_console_user_last_synced_at] => 0
)
[2] => Array
(
[group_id] => 4fd58ceba1fbc537b5402302702131eb
[cmc_console_user_last_synced_at] => 0
)
[3] => Array
(
[group_id] => f53df1a8d46108afc8ae9eeb3f0e1f0e
[cmc_console_user_last_synced_at] => 0
)
[4] => Array
(
[group_id] => e774bfcf8fc4cfe2ce57ac875a266e94
[cmc_console_user_last_synced_at] => 0
)
[5] => Array
(
[group_id] => b28312e46044da2682e540d1fb838c67
[cmc_console_user_last_synced_at] => 0
)
)
Array
(
[0] => Array
(
[group_id] => 015ce30b116ce86058fa6ab4fea4ac63
[cmc_console_user_last_synced_at] => 0
)
[1] => Array
(
[group_id] => 4fd58ceba1fbc537b5402302702131eb
[cmc_console_user_last_synced_at] => 0
)
[2] => Array
(
[group_id] => f53df1a8d46108afc8ae9eeb3f0e1f0e
[cmc_console_user_last_synced_at] => 0
)
[3] => Array
(
[group_id] => e774bfcf8fc4cfe2ce57ac875a266e94
[cmc_console_user_last_synced_at] => 0
)
[4] => Array
(
[group_id] => b28312e46044da2682e540d1fb838c67
[cmc_console_user_last_synced_at] => 0
)
[5] => Array
(
[group_id] => c10e87f39873512a16727e17f57456a5
[cmc_console_user_last_synced_at] => 1590649259
)
)
Array
(
[0] => Array
(
[group_id] => 015ce30b116ce86058fa6ab4fea4ac63
[cmc_console_user_last_synced_at] => 0
)
[1] => Array
(
[group_id] => 4fd58ceba1fbc537b5402302702131eb
[cmc_console_user_last_synced_at] => 0
)
[2] => Array
(
[group_id] => f53df1a8d46108afc8ae9eeb3f0e1f0e
[cmc_console_user_last_synced_at] => 0
)
[3] => Array
(
[group_id] => e774bfcf8fc4cfe2ce57ac875a266e94
[cmc_console_user_last_synced_at] => 0
)
[5] => Array
(
[group_id] => c10e87f39873512a16727e17f57456a5
[cmc_console_user_last_synced_at] => 1590649259
)
)
Array
(
[0] => Array
(
[group_id] => b28312e46044da2682e540d1fb838c67
[cmc_console_user_last_synced_at] => 0
)
[1] => Array
(
[group_id] => 015ce30b116ce86058fa6ab4fea4ac63
[cmc_console_user_last_synced_at] => 0
)
[2] => Array
(
[group_id] => 4fd58ceba1fbc537b5402302702131eb
[cmc_console_user_last_synced_at] => 0
)
[3] => Array
(
[group_id] => f53df1a8d46108afc8ae9eeb3f0e1f0e
[cmc_console_user_last_synced_at] => 0
)
[4] => Array
(
[group_id] => e774bfcf8fc4cfe2ce57ac875a266e94
[cmc_console_user_last_synced_at] => 0
)
[5] => Array
(
[group_id] => c10e87f39873512a16727e17f57456a5
[cmc_console_user_last_synced_at] => 1590649259
)
)
6. The final code implementation
// 设置同步标识的缓存键
$redisCache = Yii::$app->redisCache;
// HTTP 请求，获取开通有效服务的租户ID列表
$httpCmcApiGroupIds = CmcApiGroupService::httpGetGroupIds();
/* 判断 $httpCmcApiGroupIds 是否为空，如果为空，则成功退出 */
if (empty($httpCmcApiGroupIds)) {
// 延缓执行 60 * 60 秒
// sleep(Yii::$app->params['cmcConsoleUser']['isEmptyYesSleepTime']);
return ExitCode::OK;
}
/* 判断 $groupId 是否为空，如果不为空，且在 $httpCmcApiGroupIds 中不存在，则成功退出 */
if (!empty($groupId) && !in_array($groupId, $httpCmcApiGroupIds)) {
return ExitCode::OK;
}
// 设置租户ID列表的缓存键
$redisCacheGroupIdsKey = 'cmc_api_group_ids';
// 从缓存中取回租户ID列表
$redisCacheGroupIdsData = $redisCache[$redisCacheGroupIdsKey];
// 是否设置租户ID列表的缓存，默认：否
$isSetRedisCacheGroupIds = false;
if ($redisCacheGroupIdsData === false) {
$cmcApiGroupIds = [];
foreach ($httpCmcApiGroupIds as $httpCmcApiGroupId) {
$cmcApiGroupIds[] = [
'group_id' => $httpCmcApiGroupId,
'cmc_console_user_last_synced_at' => 0, //上次同步时间
];
}
// 是否设置租户ID列表的缓存：是
$isSetRedisCacheGroupIds = true;
} else {
// 获取 group_id 值列表
$redisCacheGroupIds = ArrayHelper::getColumn($redisCacheGroupIdsData, 'group_id');
$cmcApiGroupIds = $redisCacheGroupIdsData;
/* 删除出现在 $cmcApiGroupIds 中但是未出现在 $httpCmcApiGroupIds 中的租户 */
foreach ($cmcApiGroupIds as $cmcApiGroupIdKey => $cmcApiGroupId) {
if (!in_array($cmcApiGroupId['group_id'], $httpCmcApiGroupIds)) {
unset($cmcApiGroupIds[$cmcApiGroupIdKey]);
// 是否设置租户ID列表的缓存：是
$isSetRedisCacheGroupIds = true;
}
}
foreach ($httpCmcApiGroupIds as $httpCmcApiGroupId) {
if (!in_array($httpCmcApiGroupId, $redisCacheGroupIds)) {
$cmcApiGroupIds[] = [
'group_id' => $httpCmcApiGroupId,
'cmc_console_user_last_synced_at' => 0, //上次同步时间
];
// 是否设置租户ID列表的缓存：是
$isSetRedisCacheGroupIds = true;
}
}
}
// 判断是否设置租户ID列表的缓存
if ($isSetRedisCacheGroupIds) {
// 将 $cmcApiGroupIds 存放到缓存供下次使用，将数据在缓存中永久保留
$redisCache->set($redisCacheGroupIdsKey, $cmcApiGroupIds);
}
// 基于上次同步时间顺序排列，赋值给：$sortCmcApiGroupIds
$sortCmcApiGroupIds = $cmcApiGroupIds;
ArrayHelper::multisort($sortCmcApiGroupIds, 'cmc_console_user_last_synced_at', SORT_ASC);
/* 判断 $groupId 是否为空，如果不为空 */
if (!empty($groupId)) {
// 销毁 $sortCmcApiGroupIds 中的 $groupId
foreach ($sortCmcApiGroupIds as $sortCmcApiGroupIdKey => $sortCmcApiGroupId) {
if ($sortCmcApiGroupId['group_id'] == $groupId) {
unset($sortCmcApiGroupIds[$sortCmcApiGroupIdKey]);
break;
}
}
// 将 $groupId 插入至 $sortCmcApiGroupIds 的开头
array_unshift($sortCmcApiGroupIds, [
'group_id' => $groupId,
'cmc_console_user_last_synced_at' => 0, //上次同步时间
]);
}
