Wechat.php 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
  1. <?php
  2. defined('BASEPATH') OR exit('No direct script access allowed');
  3. class Wechat extends Lyapi_Controller{
  4. // 注意:登录接口不能受基础控制器的登录校验,可以覆盖构造方法或单独处理
  5. public function __construct() {
  6. // 这里不执行登录校验,只加载缓存驱动
  7. parent::__construct(); // 暂时注释,或者使用一个新的不校验的基类
  8. // 简便做法:复制 Lyapi_Controller 的部分代码但不调用 _check_api_auth
  9. // $this->load->driver('cache'); // 加载缓存驱动
  10. $this->load->_model("Model_wechat","wechat");
  11. $this->load->_model("Model_user","user");
  12. $this->load->_model("Model_power","power");
  13. }
  14. public function bduser(){
  15. if($this->input->method(TRUE) != 'POST'){
  16. $this->_json_error('请求方式错误','500');
  17. }
  18. $json_str = $this->input->raw_input_stream;
  19. $data = json_decode($json_str,true);
  20. if(empty($data['code'])){
  21. $this->_json_error('参数错误','500');
  22. }
  23. $code = $data['code'];
  24. $r = $this->wechat->getopenid($code);
  25. if($r['code'] == -1){
  26. $this->_json_error('获取openid失败','500');
  27. }
  28. $user_info = $this->user->read($this->userinfo['userid']);
  29. if(empty($user_info['wxopenid'])){
  30. $wxopenid = [];
  31. }else{
  32. $wxopenid = json_decode($user_info['wxopenid'],true);
  33. }
  34. $openid = $r['data']['openid'];
  35. $wxopenid[] = $r['data']['openid'];
  36. $wxopenid = array_unique($wxopenid);
  37. $auth_token = $this->input->get_request_header('Auth-Token', TRUE);
  38. $this->cache->delete($auth_token);
  39. $this->db->where('id',$user_info['id'])->update('user',array('wxopenid' => json_encode($wxopenid)));
  40. $power = $this->power->read($user_info['power']);
  41. if(empty($power)){
  42. $this->_json_error('角色未设置','500');
  43. }
  44. if(empty($power['lyapiid'])){
  45. $this->_json_error('权限未设置','500');
  46. }
  47. $lyapiids = explode("|",trim($power['lyapiid'],"|"));
  48. $res = $this->power->_lyapi();
  49. $lyapi_list = $res['lyapi_list'];
  50. $all_arr = [];
  51. foreach($lyapi_list as $v){
  52. if(in_array($v['id'],$lyapiids)){
  53. $all_arr[] = $v['shortname'];
  54. }
  55. }
  56. $this->cache->save($openid, [
  57. 'userid'=>$user_info['id'],
  58. 'username'=>$user_info['userid'],
  59. 'mobile'=>'',
  60. 'token'=>$openid,
  61. 'power'=>$all_arr
  62. ], 7200);
  63. $this->_json_error('绑定成功','200',[
  64. 'username'=>$user_info['userid'],
  65. 'mobile'=>'',
  66. 'token'=>$openid,
  67. 'lypower'=>implode(',',$all_arr)
  68. ]);
  69. }
  70. public function wxlogin(){
  71. if($this->input->method(TRUE) != 'POST'){
  72. $this->_json_error('请求方式错误','500');
  73. }
  74. $json_str = $this->input->raw_input_stream;
  75. $data = json_decode($json_str,true);
  76. $auth_token = $this->input->get_request_header('Auth-Token', TRUE);
  77. if(!empty($auth_token)){
  78. $this->cache->delete($auth_token);
  79. }
  80. $code = $data['code'];
  81. $r = $this->wechat->getopenid($code);
  82. if($r['code'] == -1){
  83. $this->_json_error('获取openid失败','500');
  84. }
  85. $openid = $r['data']['openid'];
  86. $user_info_list = $this->user->find_all("wxopenid like '%{$openid}%'");
  87. if(empty($user_info_list)){
  88. $this->_json_error('微信未绑定erp账号','500');
  89. }
  90. $len = count($user_info_list);
  91. if($len > 1){
  92. $this->_json_error('微信绑定错误,请联系管理员','500');
  93. }
  94. $user_info = $user_info_list[0];
  95. $power = $this->power->read($user_info['power']);
  96. if(empty($power)){
  97. $this->_json_error('角色未设置','500');
  98. }
  99. if(empty($power['lyapiid'])){
  100. $this->_json_error('权限未设置','500');
  101. }
  102. $lyapiids = explode("|",trim($power['lyapiid'],"|"));
  103. $res = $this->power->_lyapi();
  104. $lyapi_list = $res['lyapi_list'];
  105. $all_arr = [];
  106. foreach($lyapi_list as $v){
  107. if(in_array($v['id'],$lyapiids)){
  108. $all_arr[] = $v['shortname'];
  109. }
  110. }
  111. $this->cache->save($openid, [
  112. 'userid'=>$user_info['id'],
  113. 'username'=>$user_info['userid'],
  114. 'mobile'=>'',
  115. 'token'=>$openid,
  116. 'power'=>$all_arr
  117. ], 7200);
  118. $this->_json_error('绑定成功','200',[
  119. 'username'=>$user_info['userid'],
  120. 'mobile'=>'',
  121. 'token'=>$openid,
  122. 'lypower'=>implode(',',$all_arr)
  123. ]);
  124. }
  125. }