毕业设计：基于PHP开源商城系统，基于swoole、easyswoole框架开发.zip

<?php /** * * Copyright FaShop * License http://www.fashop.cn * link http://www.fashop.cn * Created by FaShop. * User: hanwenbo * Date: 2017/11/26 * Time: 下午9:01 * */ namespace App\HttpController\Admin; use App\Utils\Code; use App\Logic\Wechat\Factory as WechatFactory; use EasySwoole\Core\Utility\File; /** * 微信管理 * Class Wechat * @package App\HttpController\Admin * @property \App\Logic\Wechat\Factory $wechat */ class Wechat extends Admin { protected $wechat; protected function _initialize() { $this->wechat = new WechatFactory(); } /** * 获得token * @method GET * @param bool $refresh * @author 韩文博 */ public function getToken() { if( isset( $this->get['refresh'] ) ){ $token = $this->wechat->accessToken->getToken(); } else{ $token = $this->wechat->accessToken->getToken( true ); } return $this->send( Code::success, $token ); } /** * 读取（查询）已设置菜单 * @method GET * @author 邓凯 */ public function menuList() { $list = $this->wechat->menu->list(); return $this->send( Code::success, $list ); } /** * 获取当前菜单 * @method GET * @author 邓凯 */ public function menuCurrent() { $list = $this->wechat->menu->current(); return $this->send( Code::success, $list ); } /** * 创建自定义菜单 * @method POST * @param array $buttons * @author 邓凯 */ public function menuCreate() { if( $this->validate( $this->post, 'Admin/Wechat/Menu.create' ) !== true ){ return $this->send( Code::param_error, [], $this->getValidate()->getError() ); } else{ $result = $this->wechat->menu->create( $this->post['buttons'] ); return $this->send( Code::success, $result ); } } /** * 删除菜单 * @method POST * @param int $menu_id * 有两种删除方式，一种是全部删除，另外一种是根据菜单 ID 来删除(删除个性化菜单时用，ID 从查询接口获取) * @author 韩文博 */ public function menuDelete() { if( isset( $this->post['menu_id'] ) ){ $this->wechat->menu->delete( $this->post['id'] ); } else{ $this->wechat->menu->delete(); } return $this->send( Code::success ); } /** * 消息群发用户筛选 * @method POST * @param string $condition_type 1全部粉丝 2按条件筛选 3手动选择粉丝 * @param int $sex 性别，默认全部，1男2女，3保密 * @param array $province 地区 * @param array $cost_average_price * @param array $cost_times * @param array $resent_cost_time * @param array $resent_visit_time * @param array $register_time * @param array user_tag * @author 韩文博 */ public function broadcastUserSearch() { if( $this->validate( $this->post, 'Admin/Wechat/Broadcast.userSearch' ) !== true ){ $this->send( Code::param_error, [], $this->getValidate()->getError() ); } else{ $db = \ezswoole\Db::name( 'User' ); $db->alias( 'user' ); $db->join( "wechat_user wechat_user", 'wechat_user.openid = user.wechat_openid', 'LEFT' ); $db->join( "user_temp user_temp", 'user.id = user_temp.user_id', 'LEFT' ); if( $this->post['condition_type'] == 1 ){ } elseif( $this->post['condition_type'] == 2 ){ if( isset( $this->post['sex'] ) ){ if( $this->post['sex'] == 3 ){ $db->where( ['wechat_user.sex' => ['notin', [1, 2]]] ); } else{ $db->where( ['wechat_user.sex' => ['in', $this->post['sex']]] ); } } if( isset( $this->post['area'] ) ){ $db->where( ['wechat_user.province' => ['in', $this->post['province']]] ); } if( isset( $this->post['user_tag'] ) ){ $user_tag = $this->post['user_tag']; $db->where( function( $query ) use ( $user_tag ){ foreach( $user_tag as $tagId ){ $query->whereOr( ['wechat_user.tagid_list' => ['like', '%'.$tagId.'%']] ); } } ); } if( isset( $this->post['cost_average_price'] ) ){ $cost_average_price = $this->post['cost_average_price']; $db->where( function( $query ) use ( $cost_average_price ){ foreach( $cost_average_price as $fromTo ){ $query->whereOr( ['user_temp.cost_average_price' => ['between', $fromTo]] ); } } ); } if( isset( $this->post['cost_times'] ) ){ $cost_times = $this->post['cost_times']; $db->where( function( $query ) use ( $cost_times ){ foreach( $cost_times as $fromTo ){ $query->whereOr( ['user_temp.cost_times' => ['between', $fromTo]] ); } } ); } if( isset( $this->post['resent_cost_time'] ) ){ $resent_cost_time = $this->post['resent_cost_time']; $db->where( function( $query ) use ( $resent_cost_time ){ foreach( $resent_cost_time as $fromTo ){ $query->whereOr( ['user_temp.resent_cost_time' => ['between', $fromTo]] ); } } ); } if( isset( $this->post['resent_visit_time'] ) ){ $resent_visit_time = $this->post['resent_visit_time']; $db->where( function( $query ) use ( $resent_visit_time ){ foreach( $resent_visit_time as $fromTo ){ $query->whereOr( ['user_temp.resent_visit_time' => ['between', $fromTo]] ); } } ); } if( isset( $this->post['register_time'] ) ){ $register_time = $this->post['register_time']; $db->where( function( $query ) use ( $register_time ){ foreach( $register_time as $fromTo ){ $query->whereOr( ['user_temp.register_time' => ['between', $fromTo]] ); } } ); } } $db->where( ["user.wechat_openid" => ['not null']] ); $total_number = $db->count( 'DISTINCT wechat_user.openid' ); $this->send( Code::success, ['total_number' => $total_number] ); } } /** * 群发当日可发送状态检查 * @method GET * @param string $condition_type 1全部粉丝 2按条件筛选 3手动选择粉丝 * @param int $send_time * @author 韩文博 */ public function broadcastSurplus() { if( $this->validate( $this->get, 'Admin/Wechat/Broadcast.surplus' ) !== true ){ $this->send( Code::param_error, [], $this->getValidate()->getError() ); } else{ $conf = model( 'Wechat' )->getWechatInfo( ['id' => 1], 'app_key,app_secret,level' ); if( $conf['app_key'] && $conf['app_secret'] && in_array( $conf['level'], [1, 2, 3, 4] ) ){ $model = model( 'WechatBroadcast' ); // 每月4次 $send_time = $this->get['send_time']; if( in_array( $conf['level'], [2, 4] ) ){ $beginThismonth = mktime( 0, 0, 0, date( 'm', $send_time ), 1, date( 'Y', $send_time ) ); $endThismonth = mktime( 23, 59, 59, date( 'm', $send_time ), date( 't', $send_time ), date( 'Y', $send_time ) ); $condition['send_time'] = ['between', [$beginThismonth, $endThismonth]]; $total_number = $model->where( $condition )->count(); $can_send_state = $total_number >= 4 ? 0 : 1; } else{ $beginToday = strtotime( date( 'Y-m-d ', $send_time )."00:00:00" ); $endToday = strtotime( date( 'Y-m-d ', $send_time )."23:59:59" );; $condition['send_time'] = ['between', [$beginToday, $endToday]]; $total_number = $model->where( $condition )->count(); $can_send_state = $total_number > 0 ? 0 : 1; } $this->send( Code::success, [ 'send_number' => $total_number, 'can_send_state' => $can_send_state, ] ); } else{ $this->send( Code::error, [], '请先配置微信众号秘钥及公类型' ); } } } /** * 群发创建 * @method POST * @param string $condition_type 1全部粉丝 2按条件筛选 3手动选择粉丝 * @param array $condition * @param int $send_time * @param array $send_content * @author 韩文博 */ public function broadcastCreate() { if( $this->validate( $this->post, 'Admin/Wechat/Broadcast.create' ) !== true ){ $this->send( Code::param_error, [], $this->getValidate()->getError() ); } else{ $conf = model( 'Wechat' )->getWechatInfo( ['id' => 1], 'app_key,app_secret,level' ); if( $conf['app_key'] &