## 数据库操作类
~~~
<?php
/**
* Created by gather
* Email: chenruiqiang@yd-x.com
* Phone: 16601180687
* Copyright:源动互通（北京）科技有限公司
* Create Time: 2018/6/6 13:55
*/
namespace test;
class DB{
private static $dbcon = false;
private $host;
private $port;
private $user;
private $pass;
private $db;
private $charset;
private $link;
public function __construct(){
$this->host = "127.0.0.1";
$this->port = "3306";
$this->user = "root";
$this->pass = "xyq07041103";
$this->db = "email";
$this->charset = "utf8";
$this->db_connect();
$this->db_usedb();
$this->db_charset();
}
//连接数据库
private function db_connect(){
//$host = '', $user = '', $password = '', $database = '', $port = '', $socket = ''
$this->link = mysqli_connect($this->host,$this->user,$this->pass,$this->db,$this->port);
if (!$this->link){
echo "数据库连接失败<br>";
echo "错误编码".mysqli_errno($this->link)."<br>";
echo "错误信息".mysqli_error($this->link)."<br>";
exit();
}
}
//设置字符集
public function db_charset(){
mysqli_query($this->link,"set names {$this->charset}");
}
//选择数据库
public function db_usedb(){
mysqli_query($this->link,"use {$this->db}");
}
//私有的克隆
private function __clone(){
// TODO: Implement __clone() method.
die("clone is not allowed");
}
//公用静态方法
public static function getInstance(){
if (self::$dbcon == false){
self::$dbcon = new self;
}
return self::$dbcon;
}
//执行sql语句的方法
public function query($sql){
$res = mysqli_query($this->link,$sql);
if(!$res){
echo "sql语句执行失败<br>";
echo "错误编码是".mysqli_errno($this->link)."<br>";
echo "错误信息是".mysqli_error($this->link)."<br>";
}
return $res;
}
//获得最后一条记录id
public function getInsertId(){
return mysqli_insert_id($this->link);
}
/**
* 查询莫个字段
* @param $sql
* @return string or int
*/
public function getOne($sql){
$query = $this->query($sql);
return mysqli_free_result($query);
}
//获取一行记录，return array 一维数组
public function getRow($sql,$type="assoc"){
$query = $this->query($sql);
if(!in_array($type,array("assoc",'array','row'))){
die("mysql_query error");
}
$funcname = "mysqli_fetch_".$type;
return $funcname($query);
}
//获取一条记录，前置条件通过资源获取一条记录
public function getFormSource($query,$type="assoc"){
if(!in_array($type,array("assoc","array","row"))){
die("mysqli_query error");
}
$funcname = "mysqli_fetch_".$type;
return $funcname($query);
}
//获取多条数据，二维数组
public function getAll($sql){
$query = $this->query($sql);
$list = array();
while ($r=$this->getFormSource($query)){
$list[] = $r;
}
return $list;
}
//选择所有
public function selectAll($table,$where,$fields='*',$order='',$skip=0,$limit=1000){
if (is_array($where)){
foreach ($where as $key => $val){
if(is_numeric($val)){
$condition = $key.'='.$val;
}else{
$condition = $key.'=\''.$val.'\'';
}
}
}else{
$condition = $where;
}
if (!empty($order)){
$order = " order by ".$order;
}
$sql = "select $fields from $table where $condition $order limit $skip,$limit";
$query = $this->query($sql);
$list = array();
while ($r=$this->getFormSource($query)){
$list[] = $r;
}
return $list;
}
public function insert($table,$data){
$key_str = "";
$v_str="";
foreach ($data as $key=>$v) {
$key_str .= $key.',';
$v_str .= "'$v'".',';
}
$key_str = trim($key_str,',');
$v_str = trim($v_str,',');
$sql = "insert into $table($key_str) values($v_str)";
$this->query($sql);
return $this->getInsertId();
}
public function deleteOne($table,$where){
if(is_array($where)){
foreach ($where as $key=>$val){
$condition = $key.'='.$val;
}
}else{
$condition = $where;
}
$sql = "delete from $table where $condition";
$this->query($sql);
return mysqli_affected_rows($this->link);
}
public function deleteAll($table,$where){
if(is_array($where)){
foreach ($where as $key=>$val){
if(is_array($val)) {
$condition = $key.' in('.implode(',',$val).')';
}else{
$condition = $key.'='.$val;
}
}
}else{
$condition = $where;
}
$sql = "delete from $table where $condition";
$this->query($sql);
return mysqli_affected_rows($this->link);
}
public function update($table,$data,$where,$limit=0){
$str = '';
foreach ($data as $key=>$v){
$str .= "$key='$v'".',';
}
$str = rtrim($str,',');
if (is_array($where)){
foreach ($where as $key=>$val){
if(is_array($val)) {
$condition = $key.' in('.implode(',',$val).')';
}else{
$condition = $key.'='.$val;
}
}
}else{
$condition = $where;
}
if (empty($limit)){
$limit = " limit ".$limit;
}else{
$limit = '';
}
$sql = "update $table set $str where $condition $limit";
// var_dump($sql);
$this->query($sql);
return mysqli_affected_rows($this->link);
}
}
~~~
## 数据表
~~~
CREATE TABLE `order_queue` (
`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
`order_id` int(11) NOT NULL,
`mobile` varchar(2) NOT NULL COMMENT '用户手机号',
`created_at` datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
`updated_at` datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
`status` tinyint(4) NOT NULL COMMENT '0未处理1已处理2处理中',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=19 DEFAULT CHARSET=utf8mb4
~~~
## 增加订单order.php文件
~~~
<?php
/**
* Created by gather
* Email: chenruiqiang@yd-x.com
* Phone: 16601180687
* Copyright:源动互通（北京）科技有限公司
* Create Time: 2018/6/6 18:55
*/
//这个文件主要是配送系统处理队列中的订单并进行标记的一个文件
require "DB.php";
use test\DB;
$db=DB::getInstance();
//1）先把要处理的记录更新为等待处理，
$waiting = array('status'=>0);
$data = array(
'status'=>2,
);
$res_lock = $db->update('order_queue',$data,$waiting,2);
//2)我们要选择出刚刚咱们更新的这些数据，然后进行配送系统的处理。
if ($res_lock){
//选择出要处理的订单内容，有配货系统处理
$res = $db->selectAll('order_queue',$data);
//有配货系统进行退货处理
//把订单更新已完成
$success = array(
'status'=>1,
'updated_at'=>date("Y-m-d H:i:s")
);
$res_last = $db->update('order_queue',$success,$data,2);
if ($res_last){
echo "Success:".$res_last;
}else{
echo "Fail:".$res_last;
}
}else{
echo "没有需要处理的数据";
}
//3)处理过的更新为已完成。
~~~
## 处理订单goods.php文件
~~~
<?php
/**
* Created by gather
* Email: chenruiqiang@yd-x.com
* Phone: 16601180687
* Copyright:源动互通（北京）科技有限公司
* Create Time: 2018/6/6 18:55
*/
//这个文件主要是配送系统处理队列中的订单并进行标记的一个文件
require "DB.php";
use test\DB;
$db=DB::getInstance();
//1）先把要处理的记录更新为等待处理，
$waiting = array('status'=>0);
$data = array(
'status'=>2,
);
$res_lock = $db->update('order_queue',$data,$waiting,2);
//2)我们要选择出刚刚咱们更新的这些数据，然后进行配送系统的处理。
if ($res_lock){
//选择出要处理的订单内容，有配货系统处理
$res = $db->selectAll('order_queue',$data);
//有配货系统进行退货处理
//把订单更新已完成
$success = array(
'status'=>1,
'updated_at'=>date("Y-m-d H:i:s")
);
$res_last = $db->update('order_queue',$success,$data,2);
if ($res_last){
echo "Success:".$res_last;
}else{
echo "Fail:".$res_last;
}
}else{
echo "没有需要处理的数据";
}
//3)处理过的更新为已完成。
~~~
## shell 文件 good.sh
~~~
#!/bin/bash
date "+%G-%m-%d %H:%M:%S"
cd /Applications/XAMPP/xamppfiles/htdocs/study/order_queue/
php goods.php
~~~
## 定时任务crontab 命令
crontab -e
`*/1 * * * * /Applications/XAMPP/xamppfiles/htdocs/study/order_queue/good.sh >> /Applications/XAMPP/xamppfiles/htdocs/study/order_queue/log.log 2>&1`
- 简介
- Cookie
- HTML5 LocalStorage
- session
- 当浏览器关闭后，Session就销毁了吗？
- mysql数据库保存session
- HTTP协议的由来
- fsockopen异步请求
- http防盗链
- Apache伪静态知识补充
- 大并发量解决方案
- 大型网站是怎样解决多用户高并发访问
- 网站高并发 大流量访问的处理及解决方法
- 并发数与在线客户数 注册用户数的关系
- 即时聊天程序
- 反向Ajax实现
- ob缓存作用
- 浅聊并发之战
- php扩展安装
- php安装redis扩展
- SQLMap自动化实施SQL注入共计
- 命名空间namespace
- 集群和分布式之【session共享】
- php Redis存储Session 【1】
- php Redis存储Session 【2】
- php mysql存储session【1】
- php缓存
- 文件缓存
- memcache和redis的比较
- 原生session与session in redis对比
- XSS攻击【1】
- XSS攻击【2】
- PHP消息队列
- php+mysql 模拟发送邮件队列
- php+mysql 模拟订单处理队列
- php+redis 模拟秒杀队列
- RabbitMQ 消息队列系统
- beanstalkd
- PHP构建即时通讯
- WebSocket协议
- workerman
- PHP变量的作用域
- PHP传值和传引用的区别
- PHP匿名函数
- PHP递归函数&应用
- PHP单例模式
- PHP性能优化
- RESTful
- 集群
- 增加pgsql扩展
- php.ini路径查找
- Swoole Compiler
- mysql 主从
- 主从
- mysql-proxy
- window docker环境