YeweiwarnController.class.php 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. <?php
  2. namespace Home\Controller;
  3. use Think\Controller;
  4. use Think\Cache\Driver;
  5. class YeweiwarnController extends PushWarnController
  6. {
  7. /**
  8. * "evt" => "09",
  9. * "IMEI" => 设备编号,
  10. * "DateTime" => 时间,
  11. * "Interval" => 间隔时间,
  12. * "Status" => 状态,
  13. * "Battery" => 电量,
  14. * "Signal" => 信号,
  15. * "Unit" => 单位,
  16. * "Pressure" => 水压值,
  17. * "phone" => 电话,
  18. * "insert_id" => 插入表id
  19. * @return [type] [description]
  20. */
  21. public function message_water()
  22. {
  23. $Data = I();
  24. if (empty($Data['phone'])) {
  25. echo "is null";
  26. exit;
  27. }
  28. $insert_id = $Data['insert_id'];
  29. if (!empty($Data['IMEI'])) {
  30. $dataid = $Data['IMEI'];
  31. } else if (!empty($Data['IEMI'])) {
  32. $dataid = $Data['IEMI'];
  33. } else {
  34. exit;
  35. }
  36. //3小时以内相同设备报警未处理则不推送;
  37. $time = $Data['time'];
  38. $unique_number = $dataid;
  39. $redis = new \Redis();
  40. $result = $redis->connect('47.98.201.73', 6379);
  41. $pd = 1;
  42. if ($result == 1) {
  43. $res = $redis->get("$unique_number");
  44. if ($res == 1) {
  45. // echo "1----";
  46. $pd = 1;
  47. } else if (!empty($res)) {
  48. // echo "2----".floor((strtotime($Data['time'])-strtotime($res))%86400/3600);
  49. if (floor((strtotime($Data['time']) - strtotime($res)) / 3600) > 3) {
  50. // echo "2.1----";
  51. $pd = 1;
  52. } else {
  53. echo "2.2----";
  54. $pd = 0;
  55. }
  56. } else {
  57. // echo "3----";
  58. $pd = 1;
  59. }
  60. $res1 = $redis->get("$unique_number");
  61. var_dump($res);
  62. $redis->set("$unique_number", "$time");
  63. $redis->close();
  64. }
  65. switch ($Data['Status']) {
  66. case 'LL0':
  67. $status = '正常';
  68. break;
  69. case 'LL1':
  70. $status = '低水位';
  71. break;
  72. case 'LL2':
  73. $status = '高水位';
  74. break;
  75. case 'LL3':
  76. $status = '故障';
  77. break;
  78. case 'LL4':
  79. $status = '离线';
  80. break;
  81. case 'LL5':
  82. $status = '波动告警';
  83. break;
  84. default:
  85. $status = '其他' . $Data['Status'];
  86. break;
  87. }
  88. if (!empty($Data['evt_c'])) {
  89. $status = $Data['evt_c'];
  90. }
  91. $company = M()->query("select s.owner_name,s.unitinfo,s.company,c.owner_address,s.company from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='" . $dataid . "'");
  92. $union_sql = M()->query("select phone from sp_owner_phone WHERE owner_code='" . $company[0]['company'] . "' and statusbb=1");
  93. if (count($union_sql) == 0) {
  94. exit;
  95. }
  96. $openids = $this->array_column1($union_sql, "phone");
  97. if (empty($openids)) {
  98. echo 'open is null';
  99. exit;
  100. }
  101. $op = M()->query("SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)");
  102. $status11 = M()->query("SELECT statustime FROM sp_devices_status where deviceid='" . $dataid . "'");
  103. $access_token = GetAccess_Token1();
  104. $address = '警报地址:' . $company[0]['owner_address'] . $company[0]['unitinfo'];
  105. $deviceid = $dataid;
  106. $type = $status;
  107. if (empty($Data['time'])) {
  108. $time = $status11[0]['statustime'];
  109. } else {
  110. $time = $Data['time'];
  111. }
  112. $remark = '设备名称:' . $company[0]['owner_name'];
  113. $ljurl = "https://qhome.usky.cn/jdxf/wxapp2.php/Home/Fireinfo/index/type/2/id/" . $insert_id;
  114. print_r($op);
  115. if ($pd == 1) {
  116. foreach ($op as $o) {
  117. if (!empty($o['openid'])) {
  118. $res=$this->SendDeviceAlarm($access_token, $o['openid'], $address, $deviceid, $type, $time, $remark, $ljurl, $url = '');
  119. print_r($res);
  120. }
  121. }
  122. }
  123. }
  124. }