From 59c15454d89ab5e185c9e84954b3f0b893fbe0aa Mon Sep 17 00:00:00 2001 From: Anyon Date: Thu, 9 Feb 2017 05:15:48 -0500 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=BE=AE=E4=BF=A1SDKload?= =?UTF-8?q?=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- extend/.gitignore | 2 - extend/service/ExpressService.php | 97 +++++++++++++++++ extend/service/FansService.php | 175 ++++++++++++++++++++++++++++++ extend/service/PayService.php | 135 +++++++++++++++++++++++ extend/service/SmsService.php | 86 +++++++++++++++ 5 files changed, 493 insertions(+), 2 deletions(-) delete mode 100644 extend/.gitignore create mode 100644 extend/service/ExpressService.php create mode 100644 extend/service/FansService.php create mode 100644 extend/service/PayService.php create mode 100644 extend/service/SmsService.php diff --git a/extend/.gitignore b/extend/.gitignore deleted file mode 100644 index c96a04f00..000000000 --- a/extend/.gitignore +++ /dev/null @@ -1,2 +0,0 @@ -* -!.gitignore \ No newline at end of file diff --git a/extend/service/ExpressService.php b/extend/service/ExpressService.php new file mode 100644 index 000000000..cbe42af53 --- /dev/null +++ b/extend/service/ExpressService.php @@ -0,0 +1,97 @@ + + * @date 2016/11/28 17:13 + */ +class ExpressService { + + const APPID = '1232779'; + const APPKEY = 'ac45f461-8c1a-4518-87b1-bb8e835a2f9d'; + const APIURI = 'http://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx'; + + /** + * @brief 获取物流轨迹线路 + * @param $ShipperCode string 物流公司代号 + * @param $LogisticCode string 物流单号 + * @return string array 轨迹数据 + */ + public static function line($ShipperCode, $LogisticCode) { + $sendData = json_encode(array('ShipperCode' => $ShipperCode, 'LogisticCode' => $LogisticCode), JSON_UNESCAPED_UNICODE); + $data = array( + 'RequestData' => $sendData, + 'EBusinessID' => self::APPID, + 'RequestType' => '1002', + 'DataType' => 2, + 'DataSign' => base64_encode(md5($sendData . self::APPKEY)), + ); + $result = Http::post(self::APIURI, $data); + $resultJson = json_decode($result, true); + if (!$resultJson) { + die(var_export($result)); + } + return self::response($resultJson); + } + + /** + * 处理返回数据统一数据格式 + * @param $result 结果处理 + * @return array 通用的结果集 array('result' => 'success或者fail','data' => array( array('time' => '时间','info' => '地点'),......),'reason' => '失败原因') + */ + public static function response($result) { + $status = "fail"; + $data = array(); + $message = "此单号无跟踪记录"; + if (isset($result['Message'])) { + $message = $result['Message']; + } else if (isset($result['Reason'])) { + $message = $result['Reason']; + } + if (isset($result['Traces']) && $result['Traces']) { + foreach ($result['Traces'] as $key => $val) { + $data[$key]['time'] = $val['AcceptTime']; + $data[$key]['info'] = $val['AcceptStation']; + } + $status = "success"; + $message = '此订单号有' . count($data) . '条跟踪记录'; + } + + return array('result' => $status, 'data' => $data, 'message' => $message); + } + + /** + * CURL模拟提交数据 + * @param $url string 提交的url + * @param $data array 要发送的数据 + * @return mixed 返回的数据 + */ + private static function curl_post($url, $data) { + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $url); + curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); + curl_setopt($ch, CURLOPT_POST, 1); + curl_setopt($ch, CURLOPT_POSTFIELDS, self::_encode_data($data)); + return curl_exec($ch); + } + + /** + * 进行数据的string字符串编码 + * @param type $datas + * @return type + */ + private static function _encode_data($datas) { + $temps = array(); + foreach ($datas as $key => $value) { + $temps[] = sprintf('%s=%s', $key, $value); + } + return join('&', $temps); + } + +} diff --git a/extend/service/FansService.php b/extend/service/FansService.php new file mode 100644 index 000000000..f8d93bca0 --- /dev/null +++ b/extend/service/FansService.php @@ -0,0 +1,175 @@ + + * @date 2016/10/24 17:01 + */ +class FansService { + + /** + * 从微信服务器获取所有标签 + * @param $appid + * @return bool + */ + static public function syncTags($appid) { + $wechat = &load_wechat("User", $appid); + if (($result = $wechat->getTags()) !== FALSE) { + $tags = $result['tags']; + foreach ($tags as &$tag) { + $tag['appid'] = $appid; + } + Db::table('wechat_fans_tags')->where('appid', $appid)->delete(); + foreach (array_chunk($tags, 100) as $list) { + Db::table('wechat_fans_tags')->insertAll($list); + } + return true; + } + return true; + } + + /** + * 同步粉丝的标签 + * @param string $appid + * @param string $openid + * @return bool + */ + static public function syncFansTags($appid, $openid) { + $wechat = &load_wechat('User', $appid); + $tagsid = $wechat->getUserTags($openid); + if ($tagsid === false || !is_array($tagsid)) { + return false; + } + return Data::save('wechat_fans', ['appid' => $appid, 'openid' => $openid, 'tagid_list' => join(',', $tagsid)], 'openid', ['appid' => $appid]); + } + + /** + * 保存/更新粉丝信息 + * @param array $userInfo + * @param string $appid + * @return bool + */ + static public function set($userInfo, $appid = '') { + if (!empty($userInfo['subscribe_time'])) { + $userInfo['subscribe_at'] = date('Y-m-d H:i:s', $userInfo['subscribe_time']); + } + if (!empty($userInfo['tagid_list']) && is_array($userInfo['tagid_list'])) { + $userInfo['tagid_list'] = join(',', $userInfo['tagid_list']); + } + $userInfo['appid'] = $appid; + return Data::save('wechat_fans', $userInfo, 'openid'); + } + + /** + * 读取粉丝信息 + * @param string $openid + * @return array|false + */ + static public function get($openid) { + return Db::table('wechat_fans')->where('openid', $openid)->find(); + } + + /** + * 同步获取粉丝列表 + * @param string $appid + * @param string $next_openid + * @return bool + */ + static public function sync($appid, $next_openid = '') { + $wechat = &load_wechat('User', $appid); + $result = $wechat->getUserList($next_openid); + if ($result === FALSE || empty($result['data']['openid'])) { + Log::record("获取粉丝列表失败，{$wechat->errMsg} [{$wechat->errCode}]", Log::ERROR); + return FALSE; + } + foreach ($result['data']['openid'] as $openid) { + if (FALSE === ($userInfo = $wechat->getUserInfo($openid))) { + Log::record("获取用户[{$openid}]信息失败，$wechat->errMsg", Log::ERROR); + return FALSE; + } + if (FALSE === self::set($userInfo, $wechat->appid)) { + Log::record('更新粉丝信息更新失败！', Log::ERROR); + return FALSE; + } + if ($result['next_openid'] === $openid) { + unset($result['next_openid']); + } + } + return !empty($result['next_openid']) ? self::sync($appid, $result['next_openid']) : TRUE; + } + + /** + * 同步获取黑名单信息 + * @param string $appid + * @param string $next_openid + * @return bool + */ + static public function syncBlacklist($appid, $next_openid = '') { + $wechat = &load_wechat('User'); + $result = $wechat->getBacklist($next_openid); + + if ($result === FALSE || (empty($result['data']['openid']))) { + if (empty($result['total'])) { + return TRUE; + } + Log::record("获取粉丝黑名单列表失败，{$wechat->errMsg} [{$wechat->errCode}]", Log::ERROR); + return FALSE; + } + foreach ($result['data']['openid'] as $openid) { + if (FALSE === ($userInfo = $wechat->getUserInfo($openid))) { + Log::record("获取用户[{$openid}]信息失败，$wechat->errMsg", Log::ERROR); + return FALSE; + } + $userInfo['is_back'] = '1'; + if (FALSE === self::set($userInfo)) { + Log::record('更新粉丝信息更新失败！', Log::ERROR); + return FALSE; + } + if ($result['next_openid'] === $openid) { + unset($result['next_openid']); + } + } + return !empty($result['next_openid']) ? self::sync_blacklist($appid, $result['next_openid']) : TRUE; + } + + /** + * 读取七天的统计数据 + * @param string $appid + * @param int $day + * @return array + */ + static public function getTotal($appid, $day = 7) { + $result = Cache::get(($cachekey = "wechat_token_{$appid}")); + if (!empty($result)) { + return $result; + } + $extends = &load_wechat('Extends', $appid); + // 统计总数 + $data['cumulate'] = (array)$extends->getDatacube('user', 'cumulate', date('Y-m-d', strtotime("-{$day} day")), date('Y-m-d', strtotime('-1 day'))); + // 统计增量数 + $data['summary'] = (array)$extends->getDatacube('user', 'summary', date('Y-m-d', strtotime("-{$day} day")), date('Y-m-d', strtotime('-1 day'))); + // 统计消息数 + $data['upstreammsg'] = (array)$extends->getDatacube('upstreammsg', 'summary', date('Y-m-d', strtotime("-{$day} day")), date('Y-m-d', strtotime('-1 day'))); + $temp = array(); + for ($i = 1; $i <= $day; $i++) { + $temp[date('Y-m-d', strtotime("-{$i} day"))] = []; + } + foreach ($data as $vo) { + foreach ($vo as $v) { + isset($v['ref_date']) && ($temp[$v['ref_date']] = array_merge($temp[$v['ref_date']], $v)); + } + } + ksort($temp); + Cache::set($cachekey, $temp, 600); + return $temp; + } + +} diff --git a/extend/service/PayService.php b/extend/service/PayService.php new file mode 100644 index 000000000..cb97c0a31 --- /dev/null +++ b/extend/service/PayService.php @@ -0,0 +1,135 @@ + + * @date 2016/10/25 14:49 + */ +class PayService { + + /** + * 查询订单是否已经支付 + * @param string $order_no + * @return bool + */ + static public function isPay($order_no) { + return Db::table('wechat_pay_prepayid')->where('order_no', $order_no)->where('is_pay', '1')->count() > 0; + } + + /** + * 创建微信二维码支付(扫码支付模式二) + * @param WechatPay $pay 支付SDK + * @param string $order_no 系统订单号 + * @param int $fee 支付金额 + * @param string $title 订单标题 + * @param string $from 订单来源 + * @return bool + */ + static public function createQrc($pay, $order_no, $fee, $title, $from = 'wechat') { + $prepayid = self::_createPrepayid($pay, null, $order_no, $fee, $title, 'NATIVE', $from); + if ($prepayid === false) { + return false; + } + $filename = ROOT_PATH . "public/upload/{$pay->appid}/payqrc/" . join('/', str_split(md5($prepayid), 16)) . '.png'; + !is_dir(dirname($filename)) && mkdir(dirname($filename), 0755, true); + !file_exists($filename) && QRcode::png($prepayid, $filename, Constants::QR_ECLEVEL_L, 8); + ob_clean(); + header("Content-type: image/png"); + exit(readfile($filename)); + } + + /** + * 创建微信预支付码 + * @param WechatPay $pay 支付SDK + * @param string $openid 支付者Openid + * @param string $order_no 实际订单号 + * @param int $fee 实际订单支付费用 + * @param string $title 订单标题 + * @param string $trade_type 付款方式 + * @param string $from 订单来源 + * @return bool|string + */ + static protected function _createPrepayid($pay, $openid, $order_no, $fee, $title, $trade_type = 'JSAPI', $from = 'shop') { + $map = ['order_no' => $order_no, 'is_pay' => '1', 'expires_in' => time(), 'appid' => $pay->appid]; + $prepayinfo = Db::table('wechat_pay_prepayid')->where('appid=:appid and order_no=:order_no and (is_pay=:is_pay or expires_in>:expires_in)', $map)->find(); + if (empty($prepayinfo) || empty($prepayinfo['prepayid'])) { + $out_trade_no = Data::createSequence(18, 'WXPAY-OUTER-NO'); + $prepayid = $pay->getPrepayId($openid, $title, $out_trade_no, $fee, url("@push/wechat/notify/{$pay->appid}", '', true, true), $trade_type); + if (empty($prepayid)) { + Log::error("内部订单号{$order_no}生成预支付失败，{$pay->errMsg}"); + return false; + } + $data = [ + 'appid' => $pay->appid, // 对应公众号APPID + 'prepayid' => $prepayid, // 微信支付预支付码 + 'order_no' => $order_no, // 内部订单号 + 'out_trade_no' => $out_trade_no, // 微信商户订单号 + 'fee' => $fee, // 需要支付费用（单位为分） + 'trade_type' => $trade_type, // 发起支付类型 + 'expires_in' => time() + 5400, // 微信预支付码有效时间1.5小时（最长为2小时） + 'from' => $from // 订单来源 + ]; + if (Db::table('wechat_pay_prepayid')->insert($data) > 0) { + Log::notice("内部订单号{$order_no}生成预支付成功,{$prepayid}"); + return $prepayid; + } + } + return $prepayinfo['prepayid']; + } + + /** + * 创建微信JSAPI支付签名包 + * @param WechatPay $pay 支付SDK + * @param string $openid 微信用户openid + * @param string $order_no 系统订单号 + * @param int $fee 支付金额 + * @param string $title 订单标题 + * @return bool|array + */ + static public function createJs($pay, $openid, $order_no, $fee, $title) { + if (($prepayid = self::_createPrepayid($pay, $openid, $order_no, $fee, $title, 'JSAPI')) === false) { + return false; + } + return $pay->createMchPay($prepayid); + } + + /** + * 微信退款操作 + * @param WechatPay $pay 支付SDK + * @param string $order_no 系统订单号 + * @param int $fee 退款金额 + * @param string|null $refund_no 退款订单号 + * @return bool + */ + static public function refund($pay, $order_no, $fee = 0, $refund_no = NULL, $refund_account = '') { + $map = array('order_no' => $order_no, 'is_pay' => '1', 'appid' => $pay->appid); + $notify = Db::table('wechat_pay_prepayid')->where($map)->find(); + if (empty($notify)) { + Log::error("内部订单号{$order_no}验证退款失败"); + return false; + } + if (false !== $pay->refund($notify['out_trade_no'], $notify['transaction_id'], is_null($refund_no) ? "T{$order_no}" : $refund_no, $notify['fee'], empty($fee) ? $notify['fee'] : $fee, '', $refund_account)) { + $data = ['out_trade_no' => $notify['out_trade_no'], 'is_refund' => "1", 'refund_at' => date('Y-m-d H:i:s'), 'expires_in' => time() + 7000]; + if (Data::save('wechat_pay_prepayid', $data, 'out_trade_no')) { + return true; + } + Log::error("内部订单号{$order_no}退款成功，系统更新异常"); + return false; + } + Log::error("内部订单号{$order_no}退款失败，{$pay->errMsg}"); + return false; + } + + +} diff --git a/extend/service/SmsService.php b/extend/service/SmsService.php new file mode 100644 index 000000000..f4ebe7950 --- /dev/null +++ b/extend/service/SmsService.php @@ -0,0 +1,86 @@ + + * @date 2016/12/14 16:50 + */ +class SmsService extends BasicService { + + /** + * 给手机发送短信 + * @param string $phone 手机号码 + * @param string $content 短信内容 + * @param array $data 短信内容模板数据 + * @return bool + */ + static public function send($phone, $content, $data = []) { + $sms = new Sms(); + return $sms->render($content, $data)->send($phone); + } + + /** + * 给指定手机号码发送验证码 + * @param string $phone 手机号码 + * @param int $length 验证码长度 + * @param string $string 验证码可选字符 + * @param string $code + * @return array + */ + static public function verify($phone, $length = 4, $string = "0123456789", $code = '') { + $max = strlen($string) - 1; + for ($i = 0; $i < $length; $i++) { + $code .= $string[rand(0, $max)]; + } + $cache_key = "sms_verify_{$phone}"; + $cache = Cache::get($cache_key); + if ($cache && !empty($cache['time']) && $cache['time'] + 60 > time()) { + return self::_data('同一手机号码60秒内只能发送一条短信哦！', 'SMS_60S_ONLY_SEND_A_SMS'); + } + $result = self::send($phone, 'sms_tpl_register', ['code' => $code]); + if ($result) { + $cache = ['phone' => $phone, 'code' => $code, 'time' => time()]; + Cache::set($cache_key, $cache, 180); + return self::_data('验证码发送成功，请查看手机短信！', 'SUCCESS'); + } + return self::_data('验证码发送失败，请稍候再试！', 'ERROR'); + } + + /** + * 获取再次发送短信的等待时间 + * @param string $phone + * @return int + */ + static public function getVerifyWaitTime($phone) { + $cache_key = "sms_verify_{$phone}"; + $cache = Cache::get($cache_key); + if (empty($cache) || empty($cache['time']) || $cache['time'] + 60 < time()) { + return 0; + } + return time() - $cache['time'] - 60; + } + + /** + * 统一验证码验证 + * @param string $phone + * @param string $code + * @return array + */ + static public function checkVerify($phone, $code) { + $cache_key = "sms_verify_{$phone}"; + $cache = Cache::get($cache_key); + if (empty($cache) || empty($cache['code']) || $cache['code'] !== $code) { + return self::_data('验证码验证失败，请输入正确的验证码！', 'SMS_VERIFY_FAILD'); + } + Cache::rm($cache_key); + return self::_data('验证码验证成功！', 'SUCCESS'); + } + +}