Patrolv2.php
5.9 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
<?php
namespace app\api\controller\xunjian;
//允许所有的跨域请求
header('Access-Control-Allow-Origin: *');
header("Access-Control-Allow-Headers: *");
header('Access-Control-Allow-Methods: POST,GET,OPTIONS');
header('Access-Control-Allow-Credentials: true');
header('Access-Control-Max-Age: 86400');
use app\api\controller\tencentim\Openim;
use app\common\controller\Api;
use fast\Tree;
use think\Db;
use think\exception\PDOException;
/**
* 巡检人员
*/
class Patrolv2 extends Api
{
protected $noNeedLogin = ['*'];
protected $noNeedRight = ['*'];
public function _initialize()
{
parent::_initialize();
}
/**
* 3. 查询水库管理员（巡检员）
*/
public function getStaffList()
{
$reservoir_id = $this->request->param("reservoir_id", "");//水库id
$except_id = $this->request->param("except_id","");//排除某个员工id
$where = [];
$where2 = [];
if (!empty($reservoir_id)) {
$where = ["a.reservoir_id" => $reservoir_id];
}
if(!empty($except_id)){
$where2["a.id"] = ["neq",$except_id];
}
$list = Db::name("inspection_staff")->alias("a")
->join("user u", "u.id=a.user_id", "LEFT")
->join("inspection_depart p", "p.id=a.depart_id", "LEFT")
->field("a.id,a.staff_code,a.staff_name,a.mobile,a.is_screen_mng,u.clientid,p.depart_name")
->where($where)
->where($where2)
->order("a.id desc")
->select();
$back_data = [];
if (!empty($list)) {
$count =count($list);
$addnum = 500;//因为即时通讯人员状态每次限制查500人；所以得分开查
for($i=0;$i<$count;$i=$i+$addnum){
if($count-$i>0){
$j=$i-1>0?$i:0;
$data = array_slice($list,$j,$addnum);
//$mobile_list = array_column($data,"mobile");
foreach ($data as $k=>$v){
$mobile_list[$k]="gjs_".$data[$k]['mobile'];
}
$openim_api = new Openim();
$r = $openim_api->query_online_status(["To_Account"=>$mobile_list]);
if($r['state']==true){
$back_data=$back_data+$r['data'];
}
}
}
//追加在线状态
foreach ($list as $lk=>$lv){
if("gjs_".$list[$lk]["mobile"]==$back_data["gjs_".$list[$lk]['mobile']]['To_Account']){
$list[$lk]["online_status"] =$back_data["gjs_".$list[$lk]['mobile']]['Status'];
$list[$lk]["online_status_cn"] =$back_data["gjs_".$list[$lk]['mobile']]['StatusCn'];
$list[$lk]["mobile"] = "gjs_".$list[$lk]["mobile"];
} else{
$list[$lk]["online_status"] ="Offline";
$list[$lk]["online_status_cn"] ="下班";
$list[$lk]["mobile"] = "gjs_".$list[$lk]["mobile"];
}
}
}
$this->success("巡检人员数据获取成功", $list);
}
/**
* 3.1 查询所有管理员在线人数（巡检员）
*/
public function allStaffList()
{
$list = Db::name("inspection_staff")->alias("a")
->join("user u", "u.id=a.user_id", "LEFT")
->join("inspection_depart p", "p.id=a.depart_id", "LEFT")
->field("a.id,a.staff_code,a.staff_name,a.mobile,a.is_screen_mng,u.clientid,p.depart_name")
->order("a.id desc")
->select();
$back_data = [];
if (!empty($list)) {
$count = count($list);
$addnum = 500;//因为即时通讯人员状态每次限制查500人；所以得分开查
for ($i = 0; $i < $count; $i = $i + $addnum) {
if ($count - $i > 0) {
$j = $i - 1 > 0 ? $i : 0;
$data = array_slice($list, $j, $addnum);
$mobile_list = array_column($data, "mobile");
$openim_api = new Openim();
$r = $openim_api->query_online_status(["To_Account" => $mobile_list]);
if ($r['state'] == true) {
$back_data = $back_data + $r['data'];
}
}
}
$isoffline = 0;//不在线人数
$isOnline = 0;//在线人数
foreach ($list as $lk => $lv) {
//追加在线状态
$list[$lk]["online_status"] = $back_data[$lv['mobile']]['Status'] ? $back_data[$lv['mobile']]['Status'] : "Offline";
$list[$lk]["online_status_cn"] = $back_data[$lv['mobile']]['StatusCn'] ? $back_data[$lv['mobile']]['StatusCn'] : "下班";
if ($back_data[$lv['mobile']]['Status'] == "PushOnline") {
$isoffline += 1;
} elseif ($back_data[$lv['mobile']]['Status'] == "Online") {
$isOnline += 1;
} else {
$isoffline += 1;
}
}
}
$activation="0%";
if($isOnline){
$activation=bcmul(bcdiv($isOnline, count($back_data), 4), 100, 2) . "%";
}
$dataline = [
'isoffline' => $isoffline,
'isOnline' => $isOnline,
'allstaff' => count($back_data),
'activation' =>$activation
];
$this->success("app数据获取成功", $dataline);
}
/**
* 获取腾讯云某个App管理员帐号的签名
* @throws \Exception
*/
// public function userSig()
// {
// Vendor("tencent.TLSSigAPIv2");
// $api = new \TLSSigAPIv2(1400645108, '249c08eef888876a00cd6fc9d6e10fa2a767802b959129494ce86f4db1ef106c');
// $sig = $api->genUserSig('hcanxyz', 86400 * 365 * 5);//有效期5年
// echo $sig . "\n";
//
// }
}