source/model/push.ctrl.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php
define("WEIXIN_MB_MSG_OPEN",1);
class pushControl extends skymvc{
	
	public function __construct(){
		parent::__construct();
		require "extends/pushtpl.class.php";		
	}
	
	public function onDefault(){
		$key="push_plan";
		if(1==1 || !$res=cache()->get($key)){
			$this->onPlan();
			cache()->set($key,1,10);
		}
	}
	
	
	public function sendGeTui($plan,$app){
		
		$title=urlencode("商家推送");
		$content=urlencode($plan['content']);
		$json=curl_get_contents("http://".DOMAIN."/api/getui/demo.php?appid=".$app['appid']."&mtype=".$app['typeid']."&cid=".$app['clientid']."&token=".$app['token']."&title=".$title."&content=".$content."");
		$data=json_decode($json,true);
		if($data['result']){
			if($data['result']=='ok'){
				//如果推送成功 则删除推送计划
				M("apppush_plan")->delete("id=".$plan['id']);
			}else{
				//更新状态
				M("apppush_plan")->update(array(
					"status"=>2
				),"id=".$plan['id']);
			}
		}
	}
	
	
	public function SendWeiXin($plan,$app){
		if(empty($plan['content'])) return false;
		$wx=M("weixin")->selectRow(array("where"=>"","order"=>"id DESC"));
		$data=get_weixin_access_token();
		$token=$data['access_token'];
		$data=array(
			"touser"=>$app['openid'],
			"msgtype"=>"text",
			"text"=>array(
				"content"=>$plan['content']
			)
		);
		
		$json=curl_post("https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=".$token,zh_json_encode($data));
		
		$data=json_decode($json,true);
		 
		if(isset($data['errcode']) && $data['errcode']==0){
			M("apppush_plan")->delete("id=".$plan['id']);
		}else{
			M("apppush_plan")->update(array(
					"dateline"=>time(),