connect('127.0.0.1', 6379);
$redis->auth("helloearth");
$hkey_arr = $redis->keys("*");
$hkeyArrVal = array_values($hkey_arr);
// 打印 $hkeyArrVal
foreach ($hkeyArrVal as $value)
{
if (strstr($value, "hlruser:"))
{
$hlruser[$userNum]=$value;
$userNum++;
}
}
//print_r($hlruser)
global $OMC_server;
$objConn = mysqli_connect($OMC_server[0]['host'],$OMC_server[0]['user'],$OMC_server[0]['password'], "OBJ_".$sysTypeNo);
$dbConn = mysqli_connect($OMC_server[0]['host'],$OMC_server[0]['user'],$OMC_server[0]['password'], "HLR_DB");
$sql="TRUNCATE HLR_DB.subscriberData";
mysqli_query($dbConn,$sql);
$tmpsql="TRUNCATE OBJ_330.tmpSubsData_0";
mysqli_query($objConn,$tmpsql);
// 初始化进度条
echo '';
echo '0%
';
set_time_limit(0);
ini_set('max_execution_time', 0);
for ($k = 0; $k < $userNum; $k++) {
$hlr_detail = $redis->hGetAll($hlruser[$k]);
$imsi = explode(":", $hlruser[$k])[1];
// 反转字节顺序
$reversedCamel = strrev($hlr_detail['camel']);
// 将反转后的字节序列转换为十六进制字符串
$hexValue = bin2hex($reversedCamel);
$nam = bin2hex($hlr_detail['nam']);
$usedFlag = bin2hex($hlr_detail['enable']);
$updateSql = "INSERT INTO HLR_DB.subscriberData (imsi, inter_msisdn, camel_flag, nam, used_flag) VALUES ('0$imsi', '$hlr_detail[msisdn]', '$hexValue', '$nam', '$usedFlag')";
mysqli_query($dbConn, $updateSql);
// 检查错误
$errStr = mysqli_error($dbConn);
if ($errStr != null) {
//echo "updateSql=$updateSql
";
// echo mysqli_error($dbConn);
}
$tmpUpdateSql = "INSERT INTO OBJ_330.tmpSubsData_0 (imsi, inter_msisdn, camel_flag, nam, used_flag) VALUES ('0$imsi', '$hlr_detail[msisdn]', '$hexValue', '$nam', '$usedFlag')";
mysqli_query($objConn, $tmpUpdateSql);
//echo "updateSql=$update1Sql
";
// 更新进度条
$progress = round(($k + 1) / $userNum * 100);
echo "";
flush(); // 刷新输出缓冲区
}
// 最后更新进度条到 100%
echo "";
usleep(100000); // 可选：添加延迟以便观察进度条变化
echo "";
$redis->close();
?>