<?php
/*
 * @copyright   QiaoQiaoShiDai Internet Technology(Shanghai)Co.,Ltd
 * @license     https://www.oaooa.com/licenses/
 * 
 * @link        https://www.oaooa.com
 * @author      zyx(zyx@oaooa.com)
 */


if(!defined('IN_OAOOA')) {
	exit('Access Denied');
}

class dzz_notification {


	public static function notification_add($touid, $type, $note, $notevars = array(), $category = 0,$langfolder='') {
		global $_G;

		if(!($tospace = getuserbyuid($touid))) {
			return false;
		}

		$notestring = lang($note, $notevars,'',$langfolder);
		$notestring_wx = lang($note.'_wx', $notevars,'',$langfolder);
		$redirect=lang( $note.'_redirecturl', $notevars,'',$langfolder);


		$title=lang($note.'_title',$notevars,'',$langfolder);
		$oldnote = array();
		//if($notevars['from_id'] && $notevars['from_idtype']) {
			$oldnote = C::t('notification')->fetch_by_fromid_uid_type($notevars['from_id'], $notevars['from_idtype'], $touid,$type);
		//}

		if(empty($oldnote['from_num'])) $oldnote['from_num'] = 0;
		$notevars['from_num'] = (isset($notevars['from_num'])&& $notevars['from_num']) ? $notevars['from_num'] : 1;
		$setarr = array(
			'uid' => $touid,
			'type' => $type,
			'new' => 1,
			'wx_new' =>1,
			'wx_note'=>$notestring_wx,
			'redirecturl'=>$redirect,
			'title'=>$title,
			'authorid' => $_G['uid'],
			'author' => $_G['username'],
			'note' => $notestring,
			'dateline' => $_G['timestamp'],
			'from_id' => $notevars['from_id'],
			'from_idtype' => $notevars['from_idtype'],
			'from_num' => ($oldnote['from_num']+$notevars['from_num']),
			'category'=>$category
		);
		/*if($category==1) {
			$setarr['authorid'] = 0;
			$setarr['author'] = '';
		}*/
		if($oldnote['id']) {
			$setarr['id']=$oldnote['id'];
			C::t('notification')->update($oldnote['id'], $setarr);
		} else {
			$oldnote['new'] = 0;
			$setarr['id']=C::t('notification')->insert($setarr, true);
		}
		$noteid=$setarr['id'];
		Hook::listen('online_notification', $noteid);
		//self::wx_notification($setarr);
		//$banType = array('task');
		if(empty($oldnote['new'])) {
			C::t('user')->increase($touid, array('newprompt' => 1));
			
			/*require_once libfile('function/mail');
			$mail_subject = lang('notification', 'mail_to_user');
			sendmail_touser($touid, $mail_subject, $notestring,  $type);*/
		}
	}
	
	public function wx_sendMsg($data){
		if(!getglobal('setting/CorpID') || !getglobal('setting/CorpSecret')) return false;
		$user=C::t('user')->fetch($data['uid']);
		if(!$user['wechat_userid'] || $user['wechat_status']!=1){ 
			C::t('notification')->update($data['id'],array('wx_new'=>$data['wx_new']+1));
			return false;
		}
		$agentid=0;
		if($data['from_idtype']=='app' && $data['from_id'] && ($wxapp=C::t('wx_app')->fetch($data['from_id']))){
			if($wxapp['agentid'] && $wxapp['status']<1) $agentid=$wxapp['agentid'];
		}
		$appsecret=getglobal('setting/CorpSecret');
		if(isset($wxapp['secret']) && $wxapp['secret']){
			$appsecret=$wxapp['secret'];
		}
		$wx=new qyWechat(array('appid'=>getglobal('setting/CorpID'),'appsecret'=>$appsecret));
		$msg=array(
			   	  "touser" =>$user['wechat_userid'], //"dzz-".$data['uid'],
				  //"toparty" => "1",
				  "safe"=>0,			//是否为保密消息，对于news无效
				  "agentid" => $agentid,	//应用id
				  "msgtype" => "news",  //根据信息类型，选择下面对应的信息结构体
				  "news" => array(			//不支持保密
							  "articles" => array(    //articles  图文消息，一个图文消息支持1到10个图文
								  array(
									  "title" => $data['title'],             //标题
									  "description" => getstr($data['wx_note'],0,0,0,0,-1), //描述
									  "url" => $wx->getOauthRedirect(getglobal('siteurl').'index.php?mod=system&op=wxredirect&url='.dzzencode($data['redirecturl'])) //点击后跳转的链接。可根据url里面带的code参数校验员工的真实身份。
									 // "picurl" => "http://cs.286.com.cn/data/attachment/appimg/201409/15/161401bmtrmxlmjtlfllkr.png", //图文消息的图片链接,支持JPG、PNG格式，较好的效果为大图640320，小图8080。如不填，在客户端不显示图片
								  )
							  )
							)
		 		);
		if($ret=$wx->sendMessage($msg)){
			C::t('notification')->update($data['id'],array('wx_new'=>0));
			return true;
		}else{
			C::t('notification')->update($data['id'],array('wx_new'=>$data['wx_new']+1));
			$message='wx_notification：errCode:'.$wx->errCode.';errMsg:'.$wx->errMsg;
			runlog('wxlog',$message);
			return false;
		}
	}
	
	 
	public function update_newprompt($uid, $type) {
		global $_G;
		if($_G['member']['newprompt_num']) {
			$tmpprompt = $_G['member']['newprompt_num'];
			$num = 0;
			$updateprompt = 0;
			if(!empty($tmpprompt[$type])) {
				unset($tmpprompt[$type]);
				$updateprompt = true;
			}
			foreach($tmpprompt as $key => $val) {
				$num += $val;
			}
			if($num) {
				if($updateprompt) {
					C::t('user')->update($uid, array('newprompt'=>$num));
				}
			} else {
				C::t('user')->update($_G['uid'], array('newprompt'=>0));
			}
		}
	}
}

?>