www.gusucode.com > 搜一次CMS电影程序 PHP 1.5源码程序 > include/timingcollect.php

    <?php
/*
'**************************************************************************************************
' 软件名称: 搜一次 Content Management System
' 版本编号: Version 5.X
' 官方网站: http://www.syccms.com
' 官方论坛:http://bbs.syccms.com
' 版权所有: 搜一次开发团队    无痕(QQ:512591)
' 法律顾问: 杭州市元茂律师事务所 严飞律师
' 郑重声明:
'    1、任何个人或组织不得在未经授权的情况下删除、修改、拷贝本软件及其他副本上一切关于版权的信息;
'    2、搜一次网络事业部保留此软件的法律追究权利
'**************************************************************************************************
*/
include "conn.php";
include "function.php";
include_once("timing_set.php");
@set_time_limit(0);
if(t_of==1) die();
$ServerUrl = SafeRequest("ServerUrl","get");
$action = SafeRequest("action","get");
$Page = SafeRequest("page","get");
$ClassID = SafeRequest("ClassID","get");
$VideoID=RequestBox("VideoID");
$pagenum = SafeRequest("pagenum","get");
$Mark=SafeRequest("Mark","get");
$types= SafeRequest("types","get");
$key= SafeRequest("key","get");
$Syc=SafeRequest("Syc","get");
if(!stristr($Mark,"_")){
	$Mark=$Mark."_";
	}
if(!IsNul($Page)){$Page=1;}
$action = SafeRequest("action","get");
if($action=="caiji" and $VideoID==""  and $ClassID==""){
		die("<script>alert('请选择要采集的数据!');history.back();</script>");
	}
switch($action){
	case 'caiji': 
		Caiji("normal");
		break;
	case 'today': 
		Caiji("today");
		break;
	case 'all': 
		Caiji("all");
		break;
	}	

//判断绑定
function checkbind2($bindid){
	global $db;
	$isbind=0;
	$sql="select * from s_class where S_SystemID=1";
	$result=$db->query($sql);
	if($result){
		while($row=$db->fetch_array($result)){
			if(stristr($row['S_TieID'],",".$bindid.",")){
				$isbind=$row['S_ID'];
				}
			}
		}
	return $isbind;
	}

function  Caiji($mode){
		global $db;
		global $jsoncls;
		$ServerUrl = SafeRequest("ServerUrl","get");
		$action = SafeRequest("action","get");
		$Page = SafeRequest("page","get");
		$ClassID = SafeRequest("ClassID","get");
		$VideoID=RequestBox("VideoID");
		$pagenum = SafeRequest("pagenum","get");
		$Mark=SafeRequest("Mark","get");
		$Syc=SafeRequest("Syc","get");
		$types= SafeRequest("types","get");
		$key= SafeRequest("key","get");
		
		if(!IsNul($Page)){$Page='1';}
		$url=$ServerUrl."?action=caiji&Syc=".$Syc."&Mark=".$Mark."&Page=".$Page."&ClassID=".$ClassID."&VideoID=".$VideoID."&mode=".$mode;
		for($iii=0;$iii<4;$iii++){
			$vc=file_get_contents($url);
			if($vc) break;
			}
		
		if(!IsNul($vc)){
			$vc=geturl($url);
			}
		$Vdata=explode("##syc##",$vc);
		if($mode=="today") $pagenum=$Vdata[2]; 
		
		$Vdata[6]=ReplaceStr($Vdata[6],'\\','\');
		$Vdata[6]=ReplaceStr($Vdata[6],"	","");
		$Vdata[6]=ReplaceStr($Vdata[6],"","");
		$Vdata[6]=ReplaceStr($Vdata[6],"","");
		$Vdata[6]=ReplaceStr($Vdata[6],"","");
		$Vdata[6]=ReplaceStr($Vdata[6],chr(10).chr(13),"");
		preg_match_all('/"S_ConTent":"(.*?)"/',$Vdata[6],$Arr);		
		for($i=0;$i<count($Arr[1]);$i++){
			$Vdata[6]=ReplaceStr($Vdata[6],$Arr[1][$i],$Arr[1][$i]."&nbsp;&nbsp;");
			}
		preg_match_all('/"S_Author":"(.*?)"/',$Vdata[6],$Arr2);
		for($i=0;$i<count($Arr2[1]);$i++){
			$Vdata[6]=ReplaceStr($Vdata[6],$Arr2[1][$i],$Arr2[1][$i]." ");
			}	
		$Vdatas=convert_encoding($Vdata[6],"UTF-8","GBK");
		if( function_exists("json_decode") ){
			$json=json_decode($Vdatas,true);
			}
		for($i=0;$i<count($json);$i++){			
			$S_Name=convert_encoding($json[$i]["S_Name"],"GBK","UTF-8");
			$S_Keywords=convert_encoding($json[$i]["S_Keywords"],"GBK","UTF-8");
			$S_Remark=convert_encoding($json[$i]["S_Remark"],"GBK","UTF-8");
			$S_ClassID=convert_encoding($json[$i]["S_ClassID"],"GBK","UTF-8");
			//判断绑定的分类
			$isbind="0";
			$sqlstr="select * from s_class where S_SystemID=1";
			$res=$db->query($sqlstr);
			if($res){
				while($row=$db->fetch_array($res)){
					if(stristr($row['S_TieID'],",".$S_ClassID.",")){
						$isbind=$row['S_ID'];
						}
					}
			}
			$S_ClassID=$isbind;
			$S_Author=convert_encoding($json[$i]["S_Author"],"GBK","UTF-8");
			$S_Direct=convert_encoding($json[$i]["S_Direct"],"GBK","UTF-8");
			$S_IsEnd=convert_encoding($json[$i]["S_IsEnd"],"GBK","UTF-8");
			$S_Source=convert_encoding($json[$i]["S_Source"],"GBK","UTF-8");
			$S_Content=convert_encoding($json[$i]["S_ConTent"],"GBK","UTF-8");
			$S_VData=convert_encoding($json[$i]["S_VData"],"GBK","UTF-8");
			$S_Year=convert_encoding($json[$i]["S_Year"],"GBK","UTF-8");
			$S_Area=convert_encoding($json[$i]["S_Area"],"GBK","UTF-8");
			$S_Language=convert_encoding($json[$i]["S_Language"],"GBK","UTF-8");
			$S_Pic=convert_encoding($json[$i]["S_Pic"],"GBK","UTF-8");
			$S_AddTime=date('Y-m-d H:i:s');
			if($S_IsEnd==""){$S_IsEnd=0;}
			if($S_Area==""){$S_Area="未知";}
			if($S_Language==""){$S_Language="未知";}
			if($S_Year==""){$S_Year="未知";}
			//开始处理数据
			if(!IsNul($S_Source) or !IsNul($S_VData)){
			 echo "&nbsp;&nbsp;<font color=red>".$S_Name."&nbsp;".$S_Remark."</font>&nbsp;&nbsp;数据不完整,不进行入库处理!<br/>";
				}
			else{
				//判断数据是否相同
				$sql2="select * from s_video where S_Name='".$S_Name."'";
				
				$result2=$db->query($sql2);
				$nums=$db->num_rows($result2);
				if($nums!='0'){
					if($result2){
						while ($row3=$db->fetch_array($result2)){
							if($row3['S_Source']==$S_Source and $row3['S_VData']==$S_VData){
								echo "&nbsp;&nbsp;<font color=red>".$S_Name." &nbsp;".$S_Remark."</font>&nbsp;&nbsp;数据相同,暂无不需要更新<br/>";
								}
							 else{
								 //判断追加还是更新数据
								  if(stristr($row3['S_Source'],$S_Source)){
									  $Temp_Source=explode('$$',$row3['S_Source']);
									  $Temp_VData=explode('$$$',$row3['S_VData']);
									  for($j=0;$j<count($Temp_Source);$j++){
										  if($Temp_Source[$j]==$S_Source){
											  $Temp_VData[$j]=$S_VData;
											  }
										  }
									  $R_VData=join("$$$",$Temp_VData);
									  $S_Source=$row3['S_Source'];
									  $S_VData=$R_VData;
									  }
								  else{
									  $S_Source=$row3['S_Source'].'$$'.$S_Source;
									  $S_VData=$row3['S_VData'].'$$$'.$S_VData;
									  }								 
								 //执行入库处理
								 $sql="update s_video set S_Name='".$S_Name."',S_Remark='".$S_Remark."',S_ClassID=".$S_ClassID.",S_Author='".$S_Author."',S_Content='".$S_Content."',S_IsEnd=".$S_IsEnd.",S_Source='".$S_Source."',S_Vdata='".$S_VData."',S_Year='".$S_Year."',S_Area='".$S_Area."',S_Language='".$S_Language."',S_Direct='".$S_Direct."',S_Keywords='".$S_Keywords."',S_AddTime='".$S_AddTime."' where S_ID=".$row3['S_ID']."";

								 if($db->query($sql)){
									 echo "&nbsp;&nbsp;<font color=red>".$S_Name."&nbsp;".$S_Remark."</font>&nbsp;&nbsp;数据有变动,数据已更新完成!<br>";
									 }
								 }	
							}
						}
					
					}
				else{
					$sql="Insert s_video (S_Name,S_Keywords,S_Remark,S_Pic,S_ClassID,S_Author,S_Content,S_Direct,S_IsEnd,S_Source,S_VData,S_Year,S_Area,S_Language,S_AddTime) values ('".$S_Name."','".$S_Keywords."','".$S_Remark."','".$S_Pic."',".$S_ClassID.",'".$S_Author."','".$S_Content."','".$S_Direct."',".$S_IsEnd.",'".$S_Source."','".$S_VData."','".$S_Year."','".$S_Area."','".$S_Language."','".$S_AddTime."')";

					if($db->query($sql)){
						echo "<font color=red>&nbsp;&nbsp;".$S_Name."</font>数据库中没有记录,已采集完成!<br/>";
						}
					}	
				//end
			}	
		}
		$Page=$Page+1;
		if($Page>$pagenum){
			unset($Vdata);
			echo("</br>&nbsp;&nbsp;<b>恭喜您,全部采集完成啦。。。。。</b><script>alert('恭喜你,全部采集OK了!');window.location='?ServerUrl=".$ServerUrl."&page=".($Page-1)."&ClassID=".$ClassID."&VideoID=".$VideoID."&iPageSize=10&Syc=".$Syc."&Mark=".$Mark."'</script>");
			}
		else{
			unset($Vdata);
			echo("</br>&nbsp;&nbsp;<b><img src='../images/loading2.gif'>&nbsp;第".($Page-1)."页采集完毕,暂停3秒继续。。。。。</b><script>setTimeout('updatenext();',3000);function updatenext(){location.href='?ServerUrl=".$ServerUrl."&page=".$Page."&ClassID=".$ClassID."&VideoID=".$VideoID."&iPageSize=10&action=".$action."&pagenum=".$pagenum."&Syc=".$Syc."&Mark=".$Mark."';}</script>");

			}	

	}
?>