月份：2020年9月

tp5：
insertGetId方法新增数据并返回主键值使用getLastInsID方法：

Db::name(‘user’)->insert($data);

 $userId = Db::name(‘user’)->getLastInsID();

// 使用insertGetId方法

Db::name(‘user’)->insertGetId($data);

if(isQQBrowser() == ‘QQ’){
echo “QQ内置浏览器”;
}elseif(isQQBrowser() == ‘QQBrowser’){
echo “QQ浏览器”;
}else{
echo “其他浏览器”;
}

function isQQBrowser(){
if(strpos($_SERVER[‘HTTP_USER_AGENT’], ‘QQ’) !== false){
if(strpos($_SERVER[‘HTTP_USER_AGENT’], ‘SQ‘) !== false){
return “QQ”; //QQ内置浏览器
}else{
return “QQBrowser”; //QQ浏览器
}
}
return false;
}

ThinkPHP是国内流行的PHP开发框架之一，对于数据批量更新的问题在Think PHP5的官方文档有说明，但是我估计很多小伙伴看过文档之后可能会存在一点懵逼。因为官方文档讲述数据批量更新采用的是saveAll()的方法。以下是官方文档部分。

ThinkPHP5数据批量更新的问题

文档连接地址：https://www.kancloud.cn/manual/thinkphp5/135189

文档本身没有任何问题，假如我们有一个数据库表表名为“tp_user",其中"tp_"为表前缀。那么我们可以把包含主键的数组通过文档的方法直接批量更新到数据库中。

然而假如有一种情况就是我们的表名没有这么设计，或者我们在一个model中要更新一个特定的数据表的话，那么这个方法就不能直接使用了。否则就会报错。

今天之所以发现这个问题，是因为我在写项目中直接用Db的链式操作update()数组的时候出现了“没有更新数据”的错误后排查时发现的。

发现这一问题后我也百度了一下网上有没有网友遇到同类的问题，其中有部分网友的解决方案是重新封装一个updateAll()的方法。重新封装确实是一种最直接的解决问题的方法。同样的我也弄了个DataService来批量的修改数据，不过既然用了TP框架，我觉得还是最好用官方的方法比较好。经过半个小时研究TP的源代码，找到了最终的解决方法。

这里是think PHP5的方法，估计3.2不太适合。解决方法如下：

我们在任何位置如果想批量对任何一个数据库表执行批量更新的操作，只需要如下两行代码就可以了。

$this->name("数据表名");
$res = $this->saveAll($data);
至于更新最终结果，我们拿$res去判断就可以了。

以上内容就是波波今天遇到的问题及解决方法，希望可以帮助有同样需求的小伙伴。同样的下面是对单条数据更新返回值判断的补充。

我不知道有没有小伙伴写代码类似“$res = Db::name()->where($where)->update($data);”进行单条数据更新的，如果更新的数据和原始数据一样，就是没有改变的前提下，其实$res返回值判断很容易执行到false的逻辑中去。

解决方法：用“===”进行判断。示例如下：

if($res !== false) {
    echo 'success';
}else{
    echo 'false';
}
好了，这篇日记就写这些吧，其实项目中出现问题并不可怕，一步一步排查分析其实所有的问题都很容易解决。

<?php
namespace app\index\controller;
use app\index\model\Staff;

class Index {

  public function index(){

    //创建模型对象
    $model = new Staff;
    
    //创建自定义数据
    $data[] = ['id' => 1010,'name'=>'宋门庆'];
    $data[] = ['id' => 1011,'name'=>'马金莲'];

    //批量更新,自动识别更新和写入
    $result = $model -> saveAll($data,true);

    //反馈执行信息
    echo $result ? '更新成功!<br />' : '更新失败~~<br />' ;

    //查看更新后的信息
    echo '更新后的记录信息:<br />';

    //遍历数据对象数组
    foreach ($result as $list){
      dump($list -> getData());
    }    
  }
}

批量更新

<?php
namespace app\index\controller;
use app\index\model\Staff;

class Index {

  public function index(){

  $dataBefore = Staff::where('name','like','%云%')->select();

  if (!empty($dataBefore)){

      //查看一下更新前的数据对象中的原始数据
      echo '1. 查看一下更新前的数据对象中的原始数据<br />';
      foreach ($dataBefore as $before){
         dump($before->getData());
      }

      //更新数据对象中的原始数据
      foreach ($dataBefore as $list){
         $list -> setAttr('salary','6000');
         $data[] = $list -> getData();
      }

      //用数据对象中的原始数据更新表中对应字段信息
      $dataAfter = (new Staff()) -> saveAll($data);

      if (!empty($dataAfter)){
					echo '更新成功!<br />';
          //查看更新完成后返回的数据对象
          echo '2. 查看一下更新后的数据对象中的原始数据<br />';
          foreach ($dataAfter as $after){
            dump($after->getData());
          }
        }else{
          echo '更新失败!';
        }
  } else {
    echo '没有满足条件的记录!';
  }     
 }
}

输出

1. 查看一下更新前的数据对象中的原始数据
array(6) {
  ["id"] => int(1009)
  ["name"] => string(9) "楚云飞"
  ["sex"] => int(1)
  ["salary"] => float(8100)
  ["dept"] => string(9) "开发部"
  ["hiredate"] => string(10) "2017-01-01"
}
array(6) {
  ["id"] => int(1010)
  ["name"] => string(9) "李云龙"
  ["sex"] => int(1)
  ["salary"] => float(2000)
  ["dept"] => string(9) "开发部"
  ["hiredate"] => string(10) "2017-02-01"
}
更新成功!
2. 查看一下更新后的数据对象中的原始数据
array(6) {
  ["id"] => int(1009)
  ["name"] => string(9) "楚云飞"
  ["sex"] => int(1)
  ["salary"] => string(4) "6000"
  ["dept"] => string(9) "开发部"
  ["hiredate"] => string(10) "2017-01-01"
}
array(6) {
  ["id"] => int(1010)
  ["name"] => string(9) "李云龙"
  ["sex"] => int(1)
  ["salary"] => string(4) "6000"
  ["dept"] => string(9) "开发部"
  ["hiredate"] => string(10) "2017-02-01"
}

1. ceil — 进一取整函数
函数详解
float ceil ( float value )
返回不小于 value 的下一个整数，value 如果有小数部分则进一位。ceil() 返回的类型仍然是 float，因为 float 值的范围通常比 integer 要大。
示例：

ceil(4.33)  52. floor — 舍去取整函数

函数详解
float floor ( float value )
返回不大于 value 的下一个整数，将 value 的小数部分舍去取整。floor() 返回的类型仍然是 float，因为 float 值的范围通常比 integer 要大。
示例：

echo floor(9.99) 93. round — 四舍五入取整函数

函数详解
float round ( float val [, int precision] )
返回将 val 根据指定精度 precision（十进制小数点后数字的数目）进行四舍五入的结果。precision 也可以是负数或零（默认值）。
例子 1. round() 例子

round(3.4); 3

round(3.5); 4因为我们的取整函数返回的数据类型都是float类型，一般我们可用intval函数，将数据类型强制转化为整数类型。

示例：
intval—将数据强制转化成整数型态
例子intval()

intval(4.3) 4

intval(4.7) 4 好了，我们来尝试下将除法结果分为整数和余数部分吧。

举例：7/3
整数部分：intval(floor(7/3))
余数部分：7%3

TP3.2框架的路由匹配和规则处理：

包括：静态路由，动态路由，多参数路由、正则路由

<?php
return array(
    //'配置项'=>'配置值'
    
    /* 
     * 路由开启和匹配。首先开启路由匹配，然后根据相应的路由规则进行匹配
     * 1、静态路由
     * 2、动态路由
     * 3、动静态结合路由
     * 4、正则路由 
     */
    'URL_ROUTER_ON'   => true, //开启路由
    'URL_ROUTE_RULES' => array( //定义路由规则
        //路由规则          //指向url匹配地址
        'News/top' => 'news/index?type=top',     //静态路由(死的)，指向Admin/news/index?type=top
        'News/:id\d$'    => 'News/read',          //动态路由，指向Admin/News/read?id=:id    //$后面再加参数是无效的
        'News/:name'    => 'News/read',          //动态路由，指向Admin/News/read?name=:name,注意这里的name参数一定要和控制器接受的name参数一致
        'News/:year\d/:month\d'  => 'News/archive',
        '/^News\/(\d{4})\/(\d{2})$/' => 'News/archive?year=:1&month=:2',//正则路由，指向Admin/News/archive?year=:1&month=:2
    ),
);

需求： 访问这个目录的时候，http://xx.com/p-412313要重定向到（暂且这么叫）http://xx.com/Home/Blog/index/id/412313

就是看着好看

我的应用目录是Application。模块是Home

第一步：知道哪个文件怎么处理的路由
路由处理在think/Route.class.php

// 动态路由处理        $routes =   C('URL_ROUTE_RULES');        // var_dump($routes);         if(!empty($routes)) {            // dump($routes);            //array(1) {                // ["/^p-(\d+)$/"] => string(16) "Blog/index?id=:1"            //}            // echo "rount.class.php\n";            foreach ($routes as $rule=>$route){                if(is_numeric($rule)){                    // 支持 array('rule','adddress',...) 定义路由                    $rule   =   array_shift($route);                }     ...代码多，仅标识位置

第二步：在项目模块的配置文件下，设置配置文件 如下（因为tp是逐级加载配置文件，惯例配置->应用配置->模式配

置->调试配置->状态配置->模块配置->扩展配置->动态配置，这里属于模块配置

<?phpreturn array(      'MODULE_ALLOW_LIST' => array('Home','Admin','Common'),     'DEFAULT_MODULE'       =>    'Home',  // 默认模块     'DEFAULT_CONTROLLER'    =>  'Index', // 默认控制器名称     'DEFAULT_ACTION'        =>  'index', // 默认操作名称         //    路由规则    'URL_ROUTER_ON' => TRUE,    'URL_ROUTE_RULES' => array(        '/^c-(\d+)$/' => 'Index/content?id=:1'    ),	 'URL_ROUTER_ON '=>true,     'URL_MODEL'          => '1',      'URL_ROUTE_RULES'=>array(          '/^p-(\d+)$/' => 'Home/Blog/index?id=:1',//意思是访问x.com/p-34 会访问的是x.com/Blog/index/id/34          ),);

第三部：
如果你没有设置默认的模块 ，会出现找不到p-34这个模块的错误。
那么需要在index.php中设置
define(‘BIND_MODULE’,’Home’);

这样就可以了。

说明：如果没有第三步。默认打开是正常的就是这样。

但是

所以我们操作第三步，就可以实现如下效果了：

一、php模拟实现多线程的三种方法

1、linux下的php多线程

下面所讲的东西是源自php的pcntl_fork函数.因为这个函数依赖操作系统fork的实现,所以本文所讲的东西只适用于linux/unix。那么先看看这个函数的用法吧.php手册上是这么说的:

<?php
$pid = pcntl_fork();
if ($pid == -1) {
         die('could not fork');
} else if ($pid) {
         // we are the parent
         pcntl_wait($status); //Protect against Zombie children
} else {
         // we are the child
}
?>

通过pcntl_fork创建一个子进程,如果返回值是-1的话,那么说明子进程创建失败.创建成功的进程id会返回给父进程,0返回给子进程.不好理解吧，所以应该这样写：

<?php
$pid = pcntl_fork();
if($pid == -1){
         //创建失败咱就退出呗,没啥好说的
         die('could not fork');
}
else{
        if($pid){
                //从这里开始写的代码是父进程的,因为写的是系统程序,记得退出的时候给个返回值
                exit(0);
        }
        else{
                //从这里开始写的代码都是在新的进程里执行的,同样正常退出的话,最好也给一个返回值
                exit(0);
        }
}
?>

这样一改好理解多了,如果你父进程希望知道子进程正常退出的话,可以加上前面的pcntl_wait。

2.通过stream_socket_client 方式

function sendStream() { 
    $english_format_number = number_format($number, 4, '.', ''); 
  
    echo $english_format_number;  
    exit(); 
    $timeout = 10; 
    $result = array(); 
    $sockets = array(); 
    $convenient_read_block = 8192; 
    $host = "test.local.com"; 
    $sql = "select waybill_id,order_id from xm_waybill where status>40 order by update_time desc limit 1 ";  
    $data = Yii::app()->db->createCommand($sql)->queryAll(); 
    $id = 0; 
  
    foreach ($data as $k => $v) { 
      if ($k % 2 == 0) { 
        $send_data[$k]['body'] = NoticeOrder::getSendData($v['waybill_id']); 
  
      } else { 
        $send_data[$k]['body'] = array($v['order_id'] => array('extra' => 16));  
      }  
      $data = json_encode($send_data[$k]['body']); 
      $s = stream_socket_client($host . ":80", $errno, $errstr, $timeout, STREAM_CLIENT_ASYNC_CONNECT | STREAM_CLIENT_CONNECT); 
      if ($s) {  
        $sockets[$id++] = $s; 
        $http_message = "GET /php/test.php?data=" . $data . " HTTP/1.0\r\nHost:" . $host . "\r\n\r\n";  
        fwrite($s, $http_message); 
      } else {  
        echo "Stream " . $id . " failed to open correctly."; 
      }  
    } 
  
    while (count($sockets)) { 
  
      $read = $sockets; 
  
      stream_select($read, $w = null, $e = null, $timeout); 
       if (count($read)) {  
        /* stream_select generally shuffles $read, so we need to 
         compute from which socket(s) we're reading. */
        foreach ($read as $r) { 
  
          $id = array_search($r, $sockets); 
          $data = fread($r, $convenient_read_block); 
          if (strlen($data) == 0) { 
            echo "Stream " . $id . " closes at " . date('h:i:s') . ".<br>  "; 
            fclose($r); 
             unset($sockets[$id]); 
          } else { 
            $result[$id] = $data; 
          } 
        } 
      } else {  
        /* A time-out means that *all* streams have failed 
         to receive a response. */
        echo "Time-out!\n"; 
        break; 
      }  
    }  
    print_r($result); 
  
  }

3、通过多进程代替多线程

function daemon($func_name,$args,$number){ 
  while(true){ 
    $pid=pcntl_fork(); 
    if($pid==-1){ 
      echo "fork process fail"; 
      exit(); 
    }elseif($pid){//创建的子进程 
  
      static $num=0; 
      $num++; 
      if($num>=$number){ 
        //当进程数量达到一定数量时候，就对子进程进行回收。 
        pcntl_wait($status); 
  
        $num--; 
      }  
    }else{ //为0 则代表是子进程创建的，则直接进入工作状态 
  
      if(function_exists($func_name)){ 
        while (true) { 
          $ppid=posix_getpid(); 
          var_dump($ppid); 
          call_user_func_array($func_name,$args); 
          sleep(2); 
        } 
      }else{ 
        echo "function is not exists"; 
      } 
      exit();   
    } 
  } 
}  
function worker($args){  
  //do something 
  
}  
daemon('worker',array(1),2); 

二、真正实现php多线程的方法

php真正的多线程实现方式，通过安装php的扩展 pthread 可以做到。

点此下载 但是这个下载的是 版本3 也就是php 7 才能用的，我们需要使的是 版本2 

然后刷新的页面如下，拖到最底部：

下一页找到版本2的

下载下来，这个v2 才是php5才可以使用的

下载下来，安装：

或者，您直接这样下载：

cd /tools  
   wget https://github.com/krakjoe/pthreads/archive/v2.0.10.zip  
   unzip   v2.0.10.zip  
   cd pthreads-2.0.10  
   /usr/local/php/bin/phpize  
   ./configure --with-php-config=/usr/local/php/bin/php-config    
   make  
   make install

注意：您的php 在编译的时候需要开启 –enable-maintainer-zts

./configure --prefix=/usr/local/php --disable-fileinfo   --enable-fpm --with-config-file-path=/etc --with-config-file-scan-dir=/etc/php.d --with-openssl --with-zlib --with-curl --enable-ftp --with-gd --with-xmlrpc  --with-jpeg-dir --with-png-dir --with-freetype-dir --enable-gd-native-ttf --enable-mbstring --with-mcrypt=/usr/local/libmcrypt --enable-zip --with-mysql=/usr/local/mysql --without-pear --enable-maintainer-zts 

vim /etc/php.ini 
添加
extension=pthreads.so

重启php  
/etc/init.d/php-fpm restart