Hardware.php
3.3 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
<?php
/***
* 千寻数据采集
*/
namespace app\api\controller\reservoir;
use app\common\controller\Api;
use app\common\helper\HttpHelper;
use think\Request;
use think\Db;
use qx\Qx;
use addons\alisms\controller\Index;
/**
* Class Equipment
* @package app\api\controller\reservoir
*/
class Hardware extends Api
{
protected $model = '';
protected $noNeedLogin = ['*'];
protected $noNeedRight = '*';
protected $url = "http://116.53.40.20:9090/api";
/**
* 板桥河获取水质接口
* @return void
*/
public function getwaterquality()
{
$url = "/blade-system/apidata/queryWaterQuality";
$newtime = time();
$endTime = date("Y-m-d H:i:s", $newtime);
$beginTime = $newtime - 18000;
$beginTime = date("Y-m-d H:i:s", $beginTime);
//$detection=Db::name("detection")->where('type',2)->select(); 板桥河只有一个水质监测站返回数据
$param = ["beginTime" => $beginTime, "code" => "sz0001", "endTime" => $endTime];
$res = HttpHelper::get($this->url . $url, $param);
$res = json_decode($res, true);
foreach ($res['data'] as $k => $v) {
$res['data'][$k]['create_time'] = $newtime;
unset($res['data'][$k]['id']);
$ress = Db::name("querywaterquality")->insert($res['data'][$k]);
}
print_r("插入水质信息完成");
}
/**
* 板桥河获取水位接口
* @return void
*/
public function getwaterlevel()
{
//blade-system/apidata/queryStage
$url = "/blade-system/apidata/queryStage";
$newtime = time();
$endTime = date("Y-m-d H:i:s", $newtime);
$beginTime = $newtime - 3600;
$beginTime = date("Y-m-d H:i:s", $beginTime);
$detection = Db::name("detection")->where('type', 1)->select(); //板桥河只有一个水质监测站返回数据
foreach ($detection as $k => $v) {
$param = ["beginTime" => $beginTime, "code" => $detection[$k]['code'], "endTime" => $endTime];
$res = HttpHelper::get($this->url . $url, $param);
if ($res) {
$res = json_decode($res, true);
$res['data'][$k]['create_time'] = $newtime;
unset($res['data'][$k]['id']);
$waterleveldata = [
'water_level' => $res['data'][$k]['rz']+1844.42,
'reservoir_id' => 40,
'createtime' => time(),
'reporttime' => time(),
'number' => 1
];
$waterlevel = Db::name("reservoir_rain_water_level")->insert($waterleveldata);
$res = Db::name("querystage")->insert($res['data'][$k]);
}
}
print_r("插入水位信息完成");
}
/**
* 测站列表
* @return void
*/
public function stationList()
{
$url = "/blade-system/apidata/stationList";
$res = HttpHelper::get($this->url . $url);
print_r($res);
return;
}
public function water_intaking_list(){
$url="http://wateronline.yn-kuwata.com/Ajax.ashx?userid=40186&token=MGJhNTc4MTA0NzRkNDRjMmE1MmNlMDZh&action=list&app=Station&type=count";
$res=HttpHelper::get($url);
$res=json_decode($res,true);
$this->success("获取水位成功", $res['rows']);
}
}