停机短信提示

application/api/controller/Index.php

@@ -2,6 +2,7 @@
 
 namespace app\api\controller;
 
+use app\admin\controller\Sample;
 use think\Log;
 use app\common\controller\Api;
 
@@ -22,6 +23,36 @@ class Index extends Api
         $this->success('请求成功');
     }
 
+    /**
+     * 定时任务
+     * 查询是否超时,发送短信
+     */
+    public function is_send()
+    {
+        $bool = db()->name('jtbh_log')->where('finish_time','<',date('Y/m/d H:i:s'))->select();
+        if($bool){
+            $sample = new Sample();
+            foreach ($bool as $k=>$v){
+                if($v['status']==1 && $v['is_send']==0 && $v['phone']){
+
+                    $name1 = $v['company'];
+                    $name2 = $v['name'];
+                    $name = $v['company'].$v['name'];
+
+                    $arr = explode(',',$v['phone']);
+                    foreach ($arr as $phone){
+                        //发送短息
+                        $mobile = $phone;
+                        $sample->send_verify($mobile,$name1,$name2,0,0.5,'SMS_255300044');
+                    }
+
+                    //修改信息
+                    db()->name('jtbh_log')->where('machine_no',$v['machine_no'])->update(['is_send'=>1]);
+                }
+            }
+        }
+    }
+
 
     /**
      * vocs
@@ -34,9 +65,24 @@ class Index extends Api
         $time = date('Y/m/d H:i:s');
         $rows = $req;
         $lx = explode(',',$req[0]);
+
         if(count($lx)>1){
             $res['company'] = $lx[1];
             $res['machine_no'] = $lx[2];
+
+            //查询数据库是否存在该机台
+            $bool = db()->name('jtbh_log')->where('machine_no',$lx[2])->find();
+            if($bool){
+                //存在,修改时间
+                db()->name('jtbh_log')->where('machine_no',$lx[2])->update(['is_send'=>0, 'finish_time'=>date('Y/m/d H:i:s',time()+1500)]);
+            }else{
+                //不存在,添加记录
+                $data['machine_no'] = $lx[2];
+                $data['company'] = $lx[1];
+                $data['finish_time'] = date('Y/m/d H:i:s',time()+1500);
+
+                db()->name('jtbh_log')->insert($data);
+            }
         }
         if($lx[0]=='C'){
             //查询匹配主表数据