Wechat.php 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  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. 'is_wxbd'=>1,
  68. 'lypower'=>implode(',',$all_arr)
  69. ]);
  70. }
  71. public function wxlogin(){
  72. if($this->input->method(TRUE) != 'POST'){
  73. $this->_json_error('请求方式错误','500');
  74. }
  75. $json_str = $this->input->raw_input_stream;
  76. $data = json_decode($json_str,true);
  77. $auth_token = $this->input->get_request_header('Auth-Token', TRUE);
  78. if(!empty($auth_token)){
  79. $this->cache->delete($auth_token);
  80. }
  81. $code = $data['code'];
  82. $r = $this->wechat->getopenid($code);
  83. if($r['code'] == -1){
  84. $this->_json_error('获取openid失败','500');
  85. }
  86. $openid = $r['data']['openid'];
  87. $user_info_list = $this->user->find_all("wxopenid like '%{$openid}%'");
  88. if(empty($user_info_list)){
  89. $this->_json_error('微信未绑定erp账号','500');
  90. }
  91. $len = count($user_info_list);
  92. if($len > 1){
  93. $this->_json_error('微信绑定错误,请联系管理员','500');
  94. }
  95. $user_info = $user_info_list[0];
  96. $wxopenid = json_decode($user_info['wxopenid'],true);
  97. if(!in_array($openid,$wxopenid)){
  98. $this->_json_error('微信未绑定','500');
  99. }
  100. $power = $this->power->read($user_info['power']);
  101. if(empty($power)){
  102. $this->_json_error('角色未设置','500');
  103. }
  104. if(empty($power['lyapiid'])){
  105. $this->_json_error('权限未设置','500');
  106. }
  107. $lyapiids = explode("|",trim($power['lyapiid'],"|"));
  108. $res = $this->power->_lyapi();
  109. $lyapi_list = $res['lyapi_list'];
  110. $all_arr = [];
  111. foreach($lyapi_list as $v){
  112. if(in_array($v['id'],$lyapiids)){
  113. $all_arr[] = $v['shortname'];
  114. }
  115. }
  116. $this->cache->save($openid, [
  117. 'userid'=>$user_info['id'],
  118. 'username'=>$user_info['userid'],
  119. 'mobile'=>'',
  120. 'token'=>$openid,
  121. 'power'=>$all_arr
  122. ], 7200);
  123. $this->_json_error('绑定成功','200',[
  124. 'username'=>$user_info['userid'],
  125. 'mobile'=>'',
  126. 'token'=>$openid,
  127. 'is_wxbd'=>1,
  128. 'lypower'=>implode(',',$all_arr)
  129. ]);
  130. }
  131. }