WebSVN – php-qbpwcf – Diff – /trunk/usr/lib/qbpwcf/resource.php

 			$result["status"]="false";
 			#設置執行錯誤
 			$result["error"]=$checkArguments;
+			#寫入結果到 client
+			@fwrite($conf["socket"],json_encode($result));
+			#關閉跟 client 的連線
+			@fclose($conf["socket"]);
 			#回傳結果
 			return $result;
 			}#if end
 			$result["status"]="false";
 			#設置執行錯誤
 			$result["error"]=$checkArguments;
+			#寫入結果到 client
+			@fwrite($conf["socket"],json_encode($result));
+			#關閉跟 client 的連線
+			@fclose($conf["socket"]);
 			#回傳結果
 			return $result;
 			}#if end
 			$result["status"]="false";
 			#設置執行錯誤
 			$result["error"]=$checkArguments;
+			#寫入結果到 client
+			@fwrite($conf["socket"],json_encode($result));
+			#關閉跟 client 的連線
+			@fclose($conf["socket"]);
 			#回傳結果
 			return $result;
 			}#if end
 			$result["status"]="false";
 			#設置執行錯誤
 			$result["error"]=$checkArguments;
+			#寫入結果到 client
+			@fwrite($conf["socket"],json_encode($result));
+			#關閉跟 client 的連線
+			@fclose($conf["socket"]);
 			#回傳結果
 			return $result;
 			}#if end
 		#取得 request data 的參考
 		$rdata=&$conf["request"]["data"];
+		#debug
+		#var_dump(__LINE__,$rdata);
 		#判斷 action
 		switch($rdata["action"]){
 			#如果是要寫入
 			case "write":
 								$result["status"]="false";
 								#設置執行錯誤
 								$result["error"]=$uuid;
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								}#if end
 								}#if end
 							#新增資料並指定 id
 							$conf["info"]["resource"][$uuid]=$row;
-							#設置新增的資料
+							#設置要回給client的訊息
-							$result["content"]=array("id"=>$uuid,"info"=>$row);
+							$res=array("id"=>$uuid,"info"=>$row);
+							#debug
+							#var_dump(__LINE__,$res);
+							#寫入結果到 client
+							fwrite($conf["socket"],json_encode($res));
+							#關閉連線
+							fclose($conf["socket"]);
 							#設置執行正常
 							$result["status"]="true";
 							#回傳結果
 							unset($conf["threads::proc"]);
 							#如果執行異常
 							if($proc["status"]==="false"){
-								#設置跳過,不適用
+								#設置執行異常識別
-								$result["status"]="continue";
+								$result["status"]="false";
+								#設置執行錯誤
+								$result["error"]=$proc;
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								}#if end
 							unset($conf["threads::proc_update"]);
 							#如果執行異常
 							if($proc_update["status"]==="false"){
-								#設置跳過,不適用
+								#設置執行異常識別
-								$result["status"]="continue";
+								$result["status"]="false";
+								#設置執行錯誤
+								$result["error"]=$proc_update;
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								}#if end
 							#如果proc裡面的程式執行異常
 							if($proc_update["content"]["status"]==="false"){
-								#設置跳過,不適用
+								#設置執行異常識別
-								$result["status"]="continue";
+								$result["status"]="false";
+								#設置執行錯誤
+								$result["error"]=$proc_update;
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								}#if end
 							#取得要儲存的php變數
 							$value=$proc_update["content"][0];
 								$result["status"]="false";
 								#設置執行錯誤
 								$result["error"]=$uuid;
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								}#if end
 								$row["life"]=time()+$conf["info"]["defaultLifeTime"];
 								}#if end
 							#設置新增的資料
-							$result["content"]=array("id"=>$uuid,"info"=>$row);
+							$msg=array("id"=>$uuid,"info"=>$row);
+							#設置為 json 字串
+							$msg=json_encode($msg);
 							#設置執行正常
 							$result["status"]="true";
+							#寫入結果到 client
+							@fwrite($conf["socket"],$msg);
+							#關閉連線
+							@fclose($conf["socket"]);
 							#回傳結果
 							return $result;
 							#跳出 switch
 							break 2;
 							$result["error"][]="unsupported type:".$rdata["type"];
 							#設置執行異常
 							$result["status"]="false";
+							#寫入結果到 client
+							@fwrite($conf["socket"],json_encode($result["content"]));
+							#關閉連線
+							@fclose($conf["socket"]);
 							#回傳結果
 							return $result;
 						}#switch end
 												unset($conf["threads::proc"]);
 												#如果執行異常
 												if($proc["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤
+													$result["error"]=$proc;
-													#回傳結果
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result));
-													return $result;
+													#關閉連線
+													@fclose($conf["socket"]);
 													}#if end
 												#函式說明:
 												#更新透過proc執行的多程序資訊.
 												unset($conf["threads::proc_update"]);
 												#如果執行異常
 												if($proc_update["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤
+													$result["error"]=$proc_update;
-													#回傳結果
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result));
-													return $result;
+													#關閉連線
+													@fclose($conf["socket"]);
 													}#if end
 												#如果proc裡面的程式執行異常
 												if($proc_update["content"]["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤
+													$result["error"]=$proc_update;
-													#回傳結果
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result));
-													return $result;
+													#關閉連線
+													@fclose($conf["socket"]);
 													}#if end
 												#取得要儲存的php變數
 												$value=$proc_update["content"][0];
 												$result["error"][]="unsupported type:".$rdata["type"];
 												#設置執行異常
 												$result["status"]="false";
+												#寫入結果到 client
+												@fwrite($conf["socket"],json_encode($result));
+												#關閉連線
+												@fclose($conf["socket"]);
 												#回傳結果
 												return $result;
 											}#switch end
 										#設置結果
-										$result["content"]=array("id"=>$idInM,"value"=>$conf["info"]["resource"][$valInM]);
+										$msg=array("id"=>$idInM,"value"=>$conf["info"]["resource"][$valInM]);
+										#轉換成json字串
+										$msg=json_encode($msg);
 										#設置執行正常
 										$result["status"]="true";
+										#寫入結果到 client
+										@fwrite($conf["socket"],$msg);
+										#關閉連線
+										@fclose($conf["socket"]);
 										#回傳結果
 										return $result;
 										}#if end
 									}#foreach end
 								#執行到這邊代表沒有符合條件的記錄
+								#設置預設要回的訊息為空陣列
+								$msg=array();
-								#設置結果為null
+								#轉換成json字串
-								$result["content"]=null;
+								$msg=json_encode($msg);
 								#設置執行正常
 								$result["status"]="true";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($msg));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								#跳出 switch
 												unset($conf["threads::proc"]);
 												#如果執行異常
 												if($proc["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤
+													$result["error"]=$proc;
-													#回傳結果
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result));
-													return $result;
+													#關閉連線
+													@fclose($conf["socket"]);
 													}#if end
 												#函式說明:
 												#更新透過proc執行的多程序資訊.
 												unset($conf["threads::proc_update"]);
 												#如果執行異常
 												if($proc_update["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤
+													$result["error"]=$proc_update;
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result));
+													#關閉連線
+													@fclose($conf["socket"]);
 													#回傳結果
 													return $result;
 													}#if end
 												#如果proc裡面的程式執行異常
 												if($proc_update["content"]["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤
+													$result["error"]=$proc_update;
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result));
+													#關閉連線
+													@fclose($conf["socket"]);
 													#回傳結果
 													return $result;
 													}#if end
 												$result["error"][]="unsupported type:".$rdata["type"];
 												#設置執行異常
 												$result["status"]="false";
+												#寫入結果到 client
+												@fwrite($conf["socket"],json_encode($result));
+												#關閉連線
+												@fclose($conf["socket"]);
 												#回傳結果
 												return $result;
 											}#switch end
 									}#foreach end
 								#執行到這邊代表沒有符合條件的記錄
-								#設置結果為null
+								#設置結果為空陣列
+								$msg=array();
+								#變成json字串
-								$result["content"]=null;
+								$msg=json_encode($msg);
 								#設置執行正常
 								$result["status"]="true";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($msg));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								#跳出 switch
 												if($currentType==="proc"){
 													#pid
 													#$valInM["proc_get_status"]["pid"];
-													#關閉程序
+													#關閉既有程序
 													proc_close($valInM["process"]);
 													}#if end
 												#取得要運行的程式與參數
 												unset($conf["threads::proc"]);
 												#如果執行異常
 												if($proc["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置錯誤訊息
+													$result["error"]=$proc;
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+													#關閉連線
+													@fclose($conf["socket"]);
 													#回傳結果
 													return $result;
 													}#if end
 												unset($conf["threads::proc_update"]);
 												#如果執行異常
 												if($proc_update["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置異常錯誤
+													$result["error"]=$proc_update;
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+													#關閉連線
+													@fclose($conf["socket"]);
 													#回傳結果
 													return $result;
 													}#if end
 												#如果proc裡面的程式執行異常
 												if($proc_update["content"][0]["status"]==="false"){
-													#設置跳過,不適用
+													#設置異常
-													$result["status"]="continue";
+													$result["status"]="false";
+													#設置異常錯誤
+													$result["error"]=$proc_update;
+													#寫入結果到 client
+													@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+													#關閉連線
+													@fclose($conf["socket"]);
 													#回傳結果
 													return $result;
 													}#if end
 												$result["error"][]="unsupported type:".$rdata["type"];
 												#設置執行異常
 												$result["status"]="false";
+												#寫入結果到 client
+												@fwrite($conf["socket"],json_encode($result));
+												#關閉連線
+												@fclose($conf["socket"]);
 												#回傳結果
 												return $result;
 											}#switch end
 										}#if end
 									}#foreach end
-								#執行到這邊代表沒有符合條件的記錄
+								#執行到這邊代表沒有符合條件的記錄,可供寫入/更新.
-								#設置結果為null
+								#設置結果為空陣列
+								$msg=array();
+								#變成json字串
-								$result["content"]=null;
+								$msg=json_encode($msg);
 								#設置執行正常
 								$result["status"]="true";
+								#寫入結果到 client
+								@fwrite($conf["socket"],$msg);
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								#跳出 switch
 								break;
 								$result["error"][]="unsupported column:".$key;
 								#設置執行異常
 								$result["status"]="false";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result));
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 							}#switch end
 				break;
 			#如果是 read
 			case "read":
+				#debug
+				#var_dump(__LINE__,$rdata);
 				#如果是空的,亦即沒有條件,代表要取得全部.
 				if(empty($rdata["condition"])){
+					#初始化要回的訊息
+					$msg=array();
 					#針對每筆記錄
 					foreach($conf["info"]["resource"] as $idInM => $valInM){
 						#設置要取得的內容
-						$result["content"][]=array("id"=>$idInM,"value"=>$valInM);
+						$msg[]=array("id"=>$idInM,"value"=>$valInM);
 						}#foreach end
+					#設置成json字串
+					$msg=json_encode($msg);
 					#設置執行正常
 					$result["status"]="true";
+					#寫入結果到 client
+					$fwrite=@fwrite($conf["socket"],$msg);
+					#debug
+					var_dump(__LINE__,$fwrite,$msg);
+					#關閉連線
+					@fclose($conf["socket"]);
 					#回傳結果
 					return $result;
 					}#if end
 										#設置結果
 										$result["content"][]=array("id"=>$idInM,"value"=>$valInM);
 										#設置執行正常
 										$result["status"]="true";
+										#寫入結果到 client
+										@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+										#關閉連線
+										@fclose($conf["socket"]);
 										#回傳結果
 										return $result;
 										}#if end
 								#設置結果為null
 								$result["content"]=null;
 								#設置執行正常
 								$result["status"]="true";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								#跳出 switch
 										$result["content"]=array("id"=>$idInM,"value"=>$valInM);
 										#設置執行結果
 										$result["status"]="true";
+										#寫入結果到 client
+										@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+										#關閉連線
+										@fclose($conf["socket"]);
 										#回傳結果
 										return $result;
 										}#if end
 								#設置結果為null
 								$result["content"]=null;
 								#設置執行正常
 								$result["status"]="true";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								#跳出 switch
 										$result["content"]=array("id"=>$idInM,"value"=>$valInM);
 										#設置執行結果
 										$result["status"]="true";
+										#寫入結果到 client
+										@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+										#關閉連線
+										@fclose($conf["socket"]);
 										#回傳結果
 										return $result;
 										}#if end
 								#設置結果為null
 								$result["content"]=null;
 								#設置執行正常
 								$result["status"]="true";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 								#跳出 switch
 								$result["error"][]="unsupported column:".$key;
 								#設置執行異常
 								$result["status"]="false";
+								#寫入結果到 client
+								@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+								#關閉連線
+								@fclose($conf["socket"]);
 								#回傳結果
 								return $result;
 							}#switch end
 				$result["error"][]="unsupported action:".$conf["request"]["action"];
 				#設置執行異常
 				$result["status"]="false";
+				#寫入結果到 client
+				@fwrite($conf["socket"],json_encode($result).PHP_EOL);
+				#關閉連線
+				@fclose($conf["socket"]);
 				#回傳結果
 				return $result;
 			}#switch end
 	#$conf["condition"]=array();
 	#參考資料:
 	#無.
 	#備註:
 	#僅能在命令列環境下運行.
-	#若於proc中運行,則不會因為無法存取socket而報錯並結束執行.
 	*/
 	public static function client(&$conf){
 		#初始化要回傳的結果
 		$result=array();

Subversion Repositories php-qbpwcf

(root)/trunk/usr/lib/qbpwcf/resource.php – Rev 383 → 396