discuz 中实现从微信抓取消息并发帖

发帖"/>

discuz 中实现从微信抓取消息并发帖

这是我入职公司写的第一个程序，当时并没有太多的接触php，对php也不是很了解进过慢慢的学习完成的，虽然很low但我觉得很有意义！

<?php $_G['wx_g'] = array('init' => array("wx_thread" => array("fid" => 36, "author" => "admin", "authorid" => "1", "lastposter" => "admin", "uid" => 1, "width" => 166, "usesig" => 1),"wx_content" => array("weixin_user" => "微信账号", "weixin_pass" => "微信密码"))
);wx_login();$messge_list = get_message_list();
//print_r( $messge_list );exit;foreach ($messge_list['item'][0]['multi_item'] as $key => $val){if(!DB::result_first("select count(wid) from test.jiaojing_weixintable where wid= {$val['file_id']}")){$val['title']=mb_convert_encoding($val['title'], 'GBK','UTF-8');$val['content'] = get_content($val['content_url']);$val['create_time'] = $messge_list['item'][0]['create_time'];//创建时间在外围数组中 转移到全局变量中//写入微信表$query = "INSERT INTO test.jiaojing_weixintable(wid,title,content,date_time)VALUES ({$val['file_id']},'{$val['title']}','{$val['content']}','{$val['create_time']}')";$count1=DB::query($query);if($count1){$filesize=0;$new_img_url=NULL;//$img_url =$val['cover'];//图片地址是https 无法 保存 转http//https to http$img_url=explode('https',$val['cover']);$img_url=$img_url[1];$img_url='http'.$img_url;$img_name = DISCUZ_ROOT . "data/attachment/forum/jiaojing_images/{$val['file_id']}.jpg";getImage($img_url, $img_name);$new_img_url = "jiaojing_images/{$val['file_id']}.jpg";$filesize=filesize($img_name);//更新表DB::query("UPDATE test.jiaojing_weixintable SET img_url='$new_img_url', img_size='".$filesize."' WHERE wid='{$val['file_id']}'");}//写入微信表/* ****************** *///写入论坛帖子DB::result_first("insert into pre_forum_post_tableid set pid=0" );$newpid=DB::insert_id();$pid=$newpid; //贴子的ID$fid=$_G['wx_g']['init']['wx_thread']['fid']; //贴子所在版块的版块ID$author="{$_G['wx_g']['init']['wx_thread']['author']}"; //贴子的发表者的会员名称$authorid=$_G['wx_g']['init']['wx_thread']['authorid'];//贴子的发表者的会员UID编号$subject="{$val['title']}";//贴子的标题$dateline=$val['create_time'];//发表贴子的日期时间(时间轴)$lastpost=$val['create_time']; //最后发表日期$lastposter="{$_G['wx_g']['init']['wx_thread']['lastposter']}"; //最后发表的会员名称$message="{$val['content']}";//贴子的内容$useip= $_SERVER["REMOTE_ADDR"]; //发表者的IP$uid=$_G['wx_g']['init']['wx_thread']['uid'];//使用搜索功能的会员的UID编号$usesig=$_G['wx_g']['init']['wx_thread']['usesig']; //是否显示个性签名 1 or 0$aid=$arr['aid'];//贴子里的附件ID$width=$_G['wx_g']['init']['wx_thread']['width'];//附件缩略图宽$attachment1 = 2; //是否为有附件的主题$filename="{$val['file_id']}.jpg";//$filename=explode('/',$new_img_url); //$filename="{$arr['filename']}";//$filesize=$filesize;$attachment=$new_img_url; //$attachment="{$arr['attachment']}";//添加贴子DB::query("insert into " . DB::table('forum_thread'). " (fid,author,authorid,subject,dateline,lastpost,lastposter) values($fid,'{$author}',$authorid,'{$subject}',$dateline,$lastpost,'{$lastposter}')");$tid=$insert_id = DB::insert_id()."";//返回 tid 贴子所在主题的主题IDDB::query("insert into " . DB::table('forum_newthread'). "(tid,fid,dateline)values($tid,$fid,$dateline)");DB::query("insert into " . DB::table('forum_post'). "(pid,tid,fid,first,author,authorid,subject,dateline,message,useip,usesig,htmlon) values($pid,$tid,$fid,1,'{$author}',$authorid,'{$subject}',$dateline,'{$message}','{$useip}',{$usesig},1)");//if($attachment1==2){ //2表示有附件的代码$tableid = dintval($tid{strlen($tid)-1});//附件信息存储表pre_forum_attachment0-9中的分布表//echo $tableid;//更新贴子加入附件//DB::query("update pre_forum_post set attachment={$attachment1} where tid={$tid}");DB::query("UPDATE " . DB::table('forum_thread'). " SET attachment = {$attachment1} WHERE tid = '".$tid."'");DB::query("UPDATE " . DB::table('forum_post'). " SET attachment = {$attachment1} WHERE pid = '".$pid."'");//附件//tableid > pre_forum_attachment0-9中的分布表DB::result_first("insert into " . DB::table('forum_attachment'). " (tid,pid,uid,tableid)values($tid,$pid,$uid,$tableid)");$aid=DB::insert_id();DB::query("UPDATE " . DB::table('forum_attachment') . "  SET tid = '".$tid."', pid = '".$pid."', uid = '".$uid."', tableid = '".$tableid."' WHERE aid = '$aid'");DB::query("INSERT INTO " . DB::table('forum_attachment_'.$tableid) . " ( aid, tid, pid, uid, dateline, filename, filesize, width, attachment, isimage ) VALUES ('$aid','".$tid."','".$pid."','".$uid."','".$dateline."','$filename','" . $filesize. "', '500' , '" . $attachment . "', 1)");//}C::t('forum_forum')->update($fid, array('lastpost' => $lastpost));C::t('forum_forum')->update_forum_counter($fid, 1, 1, 1);//写入论坛帖子}}function get_content($url){global $_G;$message = file_get_contents($url);preg_match('/<div class="text">(.*)<\/div>/', $message, $content);//内容$content=mb_convert_encoding($content[1], "GBK","UTF-8");//获取过滤出的 完整微信内容 转码$content = strip_tags($content);return $content;}function get_message_list(){global $_G;$cookie=$_G['wx_g']['cookie'];$url = "=0&count=10&t=media/appmsg_list&type=10&action=list&token=".$_G['wx_g']['token']."&lang=zh_CN";$ch = curl_init();curl_setopt($ch, CURLOPT_URL, $url);curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);curl_setopt($ch, CURLOPT_COOKIE, $cookie);curl_setopt($ch, CURLOPT_REFERER, "=0&count=10&t=media/appmsg_list&type=10&action=list&token=".$_G['wx_g']['token']."&lang=zh_CN");curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Windows NT 6.1; rv:18.0) Gecko/20100101 Firefox/18.0");curl_setopt($ch, CURLOPT_FOLLOWLOCATION,true);curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);curl_setopt($ch, CURLOPT_SSLVERSION, 3);$output2 = curl_exec($ch);curl_close($ch);//echo $output2;exit;$output1=explode('wx.cgiData = ',$output2);$output1=$output1[1];$output1=explode(',"file_cnt":',$output1);$output1=$output1[0];$output1.='}';$message_list=json_decode($output1,true);//$message_list=mb_convert_encoding($message_list, "GBK","UTF-8");//print_r($message_list);exit;return $message_list;}function wx_login(){global $_G;//echo $_G['wx_g']['init']['wx_content']['weixin_user'];exit;$username = $_G['wx_g']['init']['wx_content']['weixin_user'];$pwd = md5($_G['wx_g']['init']['wx_content']['weixin_pass']);$url = "=zh_CN";$post_data = "username=".$username."&pwd=".$pwd."&imgcode=&f=json";$cookie = "pgv_pvid=2067516646";$ch = curl_init();curl_setopt($ch, CURLOPT_URL, $url);curl_setopt($ch, CURLOPT_HEADER, 1);curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);curl_setopt($ch, CURLOPT_POST, 1);curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);curl_setopt($ch, CURLOPT_COOKIE, $cookie);curl_setopt($ch, CURLOPT_REFERER, "=wxm2-login&lang=zh_CN");curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Windows NT 6.1; rv:18.0) Gecko/20100101 Firefox/18.0");curl_setopt($ch, CURLOPT_FOLLOWLOCATION,true);curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);curl_setopt($ch, CURLOPT_SSLVERSION, 3);$output = curl_exec($ch);curl_close($ch);//echo $output;exit;list($header, $body) = explode("\r\n\r\n", $output);preg_match_all("/set\-cookie:([^\r\n]*)/i", $header, $matches);if(!empty($matches[1][2])){$cookie = $matches[1][0].$matches[1][1].$matches[1][2].$matches[1][3];}else{$cookie = $matches[1][0].$matches[1][1];}$cookie = str_replace(array('Path=/',' ; Secure; HttpOnly','=;'),array('','','='), $cookie);$cookie = 'pgv_pvid=6648492946;'.$cookie;$data = json_decode($body,true);$result = explode('token=',$data['redirect_url']);$token = $result[1];if(!$token) cpmsg($installlang['import_error_password'], "{$request_url}&step=import&pswerror=1", 'error');//写入到全局变量$_G['wx_g']['cookie'] = $cookie;$_G['wx_g']['token'] = $token;}//微信图片保存函数
function getImage($url,$filename=''){global $_G;$cookie=$_G['wx_g']['cookie'];if($url==''){return false;}//文件保存路径$ch=curl_init();//$timeout=120;$ch=curl_init();curl_setopt($ch,CURLOPT_URL,$url);curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);curl_setopt($ch, CURLOPT_COOKIE, $cookie);curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0 (Windows NT 6.1; rv:18.0) Gecko/20100101 Firefox/18.0");$img=curl_exec($ch);curl_close($ch);$size=strlen($img);//文件大小$fp2=@fopen($filename,'a');fwrite($fp2,$img);fclose($fp2);return $filename;
}