From da42a95d466fc764224c47a1af65712459d4d242 Mon Sep 17 00:00:00 2001 From: lai <10633968+laiyujun1@user.noreply.gitee.com> Date: Fri, 10 Jan 2025 09:49:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0HLRredis=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wxc2_omc/account/priSubsMng/hlrGetAll.php | 88 +++++++++++++++++++ .../account/priSubsMng/subscriberListDown.php | 2 +- .../account/priSubsMng/subscriberListUp.php | 3 +- wxc2_omc/account/pubSubsMng/hlrGetAll.php | 88 +++++++++++++++++++ .../account/pubSubsMng/subscriberListUp.php | 10 ++- wxc2_omc/security/login/login.php | 2 +- 6 files changed, 187 insertions(+), 6 deletions(-) create mode 100644 wxc2_omc/account/priSubsMng/hlrGetAll.php create mode 100644 wxc2_omc/account/pubSubsMng/hlrGetAll.php diff --git a/wxc2_omc/account/priSubsMng/hlrGetAll.php b/wxc2_omc/account/priSubsMng/hlrGetAll.php new file mode 100644 index 0000000..bb31f92 --- /dev/null +++ b/wxc2_omc/account/priSubsMng/hlrGetAll.php @@ -0,0 +1,88 @@ +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 '
'; +echo '
'; +echo '
0%
'; + +for ($k = 0; $k < $userNum; $k++) { + $hlr_detail = $redis->hGetAll($hlruser[$k]); + $imsi = explode(":", $hlruser[$k])[1]; + $camel = bin2hex($hlr_detail['camel']); + $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 ('$imsi', '$hlr_detail[msisdn]', '$camel', '$nam', '$usedFlag')"; + mysqli_query($dbConn, $updateSql); + + // 检查错误 + $errStr = mysqli_error($dbConn); + if ($errStr != null) { + //echo "updateSql=$updateSql
"; + echo mysqli_error($dbConn); + } + + // 更新进度条 + $progress = round(($k + 1) / $userNum * 100); + echo ""; + flush(); // 刷新输出缓冲区 +} + +// 最后更新进度条到 100% +echo ""; +usleep(100000); // 可选：添加延迟以便观察进度条变化 +echo ""; + +?> diff --git a/wxc2_omc/account/priSubsMng/subscriberListDown.php b/wxc2_omc/account/priSubsMng/subscriberListDown.php index 80e4a24..f9f126e 100755 --- a/wxc2_omc/account/priSubsMng/subscriberListDown.php +++ b/wxc2_omc/account/priSubsMng/subscriberListDown.php @@ -264,7 +264,7 @@ $getSysIdResult=mysqli_query($pubConn,$getSysIdSql); // debug_log("/tmp/debug.txt",$getSysIdResult); echo mysqli_error($pubConn); //debug_log("/tmp/debug.txt",mysqli_num_rows($getSysIdResult)); -if(mysqli_num_rows($getSysIdResult) > 0){ +if(mysqli_num_rows($getSysIdResult) > 0 ||$sysTypeNo==330){ $getSysIdRows=mysqli_fetch_array($getSysIdResult); $sysNo = $getSysIdRows[sysNo]; diff --git a/wxc2_omc/account/priSubsMng/subscriberListUp.php b/wxc2_omc/account/priSubsMng/subscriberListUp.php index 5fe684b..81f504e 100755 --- a/wxc2_omc/account/priSubsMng/subscriberListUp.php +++ b/wxc2_omc/account/priSubsMng/subscriberListUp.php @@ -138,8 +138,9 @@ function checkSubmit(actionType,transValue){ //echo "baseURL = \"./subscriberConfig.php?sysTypeNo=$sysTypeNo&dataTypeNo=$dataTypeNo&\"; \n"; break; case '330': - echo "baseURL = \"./hlrSubsConf.php?sysTypeNo=$sysTypeNo&dataTypeNo=$dataTypeNo&\"; \n"; + //echo "baseURL = \"./hlrSubsConf.php?sysTypeNo=$sysTypeNo&dataTypeNo=$dataTypeNo&\"; \n"; //echo "baseURL = \"./subscriberConfig.php?sysTypeNo=$sysTypeNo&dataTypeNo=$dataTypeNo&\"; \n"; + echo "baseURL = \"./hlrGetAll.php?sysTypeNo=$sysTypeNo&dataTypeNo=$dataTypeNo&\"; \n"; break; case '340': echo "baseURL = \"./aucSubsConf.php?sysTypeNo=$sysTypeNo&dataTypeNo=$dataTypeNo&\"; \n"; diff --git a/wxc2_omc/account/pubSubsMng/hlrGetAll.php b/wxc2_omc/account/pubSubsMng/hlrGetAll.php new file mode 100644 index 0000000..7f15d96 --- /dev/null +++ b/wxc2_omc/account/pubSubsMng/hlrGetAll.php @@ -0,0 +1,88 @@ +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 '
'; +echo '
'; +echo '
0%
'; + +for ($k = 0; $k < $userNum; $k++) { + $hlr_detail = $redis->hGetAll($hlruser[$k]); + $imsi = explode(":", $hlruser[$k])[1]; + $camel = bin2hex($hlr_detail['camel']); + $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 ('$imsi', '$hlr_detail[msisdn]', '$camel', '$nam', '$usedFlag')"; + mysqli_query($dbConn, $updateSql); + + // 检查错误 + $errStr = mysqli_error($dbConn); + if ($errStr != null) { + //echo "updateSql=$updateSql
"; + echo mysqli_error($dbConn); + } + + // 更新进度条 + $progress = round(($k + 1) / $userNum * 100); + echo ""; + flush(); +} + +// 更新进度条到 100% +echo ""; +usleep(100000); +echo ""; + +?> diff --git a/wxc2_omc/account/pubSubsMng/subscriberListUp.php b/wxc2_omc/account/pubSubsMng/subscriberListUp.php index deaa043..317ee0c 100755 --- a/wxc2_omc/account/pubSubsMng/subscriberListUp.php +++ b/wxc2_omc/account/pubSubsMng/subscriberListUp.php @@ -19,6 +19,7 @@ NO.1 require("../../inc/header.inc"); $sysTypeNo=$_REQUEST['sysTypeNo']; $dataTypeNo=$_REQUEST['dataTypeNo']; +$userNum = 0; //$helpId="6.4.1"; ?> @@ -47,15 +48,18 @@ function checkSubmit(actionType,transValue){ echo "baseURL = \"../pubSubsImport/subscriberImportIndex.php?sysId=$sysId&dataTypeNo=$dataTypeNo&\"; \n"; else echo "baseURL = \"../pubSubsImport/subscriberImportIndex.php?sysId=$sysTypeNo"."_99_99&dataTypeNo=$dataTypeNo&\"; \n"; - ?> - break; - case 5: //get all + + case 5: //get all break; + default: alert("Unknown action!"); return(false); diff --git a/wxc2_omc/security/login/login.php b/wxc2_omc/security/login/login.php index b405488..a29094e 100755 --- a/wxc2_omc/security/login/login.php +++ b/wxc2_omc/security/login/login.php @@ -227,7 +227,7 @@ function selectChn(){ } ?> -R2501.1 +R2501.2