推广

application/api_broker/controller/SpreadUser.php

+<?php
+namespace app\api_broker\controller;
+/**
+ * Created by PhpStorm.
+ * User: zhuwei
+ * Date: 2018-11-21
+ * Time: 10:43:58
+ */
+
+
+use app\api_broker\extend\Basic;
+use app\model\USpreadUser;
+use think\Request;
+
+class SpreadUser extends Basic
+{
+
+    protected $uSpreadUser;
+
+    public function __construct($request = null)
+    {
+        parent::__construct($request);
+        $this->uSpreadUser = new USpreadUser();
+
+    }
+
+    /**
+     * 推广手机号码记录
+     * User: 朱伟
+     * Date: 2018-11-21
+     * Time: 10:43:58
+     */
+    public function addSpreadUser(){
+        $params = $this->params;
+        $user_ip = $this->ip();
+
+
+        $params = array(
+            "type" => 1,
+            "phone"  => 18112347151,
+            "ip"  => $user_ip
+        );
+
+        if (!isset($params["phone"]) or !isset($params["ip"])) {
+            return $this->response("101", "请求参数错误");
+        }
+
+
+        //先判断是否已经存在数据
+        $field = 'phone,ip,create_time';
+
+
+        $where['ip']  = $params["ip"];
+        $where_or['phone']  = $params["phone"];
+
+        $res = $this->uSpreadUser->getSpreadUser($field,$where,$where_or);
+
+        if($res){//如果存在
+            dump($res);
+            if($res){
+
+            }else{
+
+            }
+            return $this->response("101", "30分钟内不允许重复提交");
+        }else{//不存在则新增数据
+            $insert["phone"] = $params['phone'];
+            $insert["ip"] = $params['ip'];
+            $insert["type"] = $params['type'];
+            $res = $this->uSpreadUser->saveSpreadUser($insert);//int(1)
+        }
+
+        if ($res) {
+            return $this->response("200", "成功");
+        } else {
+            return $this->response("101", "失败");
+        }
+
+    }
+
+
+
+    public function ip() {
+        //strcasecmp 比较两个字符，不区分大小写。返回0，>0，<0。
+        if(getenv('HTTP_CLIENT_IP') && strcasecmp(getenv('HTTP_CLIENT_IP'), 'unknown')) {
+            $ip = getenv('HTTP_CLIENT_IP');
+        } elseif(getenv('HTTP_X_FORWARDED_FOR') && strcasecmp(getenv('HTTP_X_FORWARDED_FOR'), 'unknown')) {
+            $ip = getenv('HTTP_X_FORWARDED_FOR');
+        } elseif(getenv('REMOTE_ADDR') && strcasecmp(getenv('REMOTE_ADDR'), 'unknown')) {
+            $ip = getenv('REMOTE_ADDR');
+        } elseif(isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], 'unknown')) {
+            $ip = $_SERVER['REMOTE_ADDR'];
+        }
+        $res =  preg_match ( '/[\d\.]{7,15}/', $ip, $matches ) ? $matches [0] : '';
+        return $res;
+        //dump(phpinfo());//所有PHP配置信息
+    }
+
+}
\ No newline at end of file

application/api_broker/extend/Basic.php

@@ -58,6 +58,7 @@ class Basic extends Controller
         'broker/getBusinessAll',
         "broker/getSiteListApp",
         "broker/addUserCallAgentV2",
+        "broker/addSpreadUser",
     );
 
     /**

application/model/USpreadUser.php

+<?php
+
+namespace app\model;
+
+use think\Db;
+use think\Model;
+
+class USpreadUser extends Model
+{
+    // 设置当前模型对应的完整数据表名称
+    protected $table = 'u_spread_user';
+
+    public function saveSpreadUser($data) {
+        $time = date("Y-m-d H:i:s", time());
+
+        $data['create_time'] = $time;
+        $data['update_time'] = $time;
+        return $this->insert($data);
+    }
+
+    /**
+     * 查询数据
+     * 朱伟 2018-11-21 10:41:44
+     */
+    public function getSpreadUser($field,$params,$where_or)
+    {
+        $result = Db::table($this->table)
+            ->field($field)
+            //->alias('a')
+            ->where($params)->whereOr($where_or)
+            ->select();
+        echo $this->getLastSql();
+        return $result;
+    }
+
+    /**
+     * 更新数据
+     * 朱伟 2018-11-21 10:41:44
+     */
+    public function updateSpreadUser($params)
+    {
+        $result = $this->update($params);
+        //dump($this->getLastSql());
+        return $result;
+
+    }
+
+
+}