# 模型逻辑层之实战代码
这节 其实没有什么好说的 当你把每个复杂的逻辑处理过程封装到逻辑层中,你前段的控制器代码就会优雅简洁很多
>[warning] 不要纠结你给你的逻辑处理代码起的名称 和存放位置
* 代码一
~~~
/**
* 创建项目预算书
* User: Mikkle
* Q Q:776329498
* @param $data
* @param $id
* @param $project_id
* @return array
*/
public function buildBudgetBook($data,$id,$project_id){
try{
$this->startTrans();
//修改审核记录
if(!$this->data($data)->isUpdate(true,['guid'=>$id])->save()){
throw new Exception("审核信息失败");
}
if($project_id!=$this->where(['guid'=>$id])->value("project_id")){
throw new Exception("项目ID获取出错!");
}
//审核结果 1审核通过
$m=isset($data['examine_status']) ? $data['examine_status'] : 0 ;
if($m==1){
$model_book_number= new BudgetBookNumber();
Db::table("mk_budget_default_book_number")->where(["project_id"=>$project_id,"status"=>1])->update(["status"=>2]);
$model_book_number->save(["project_id"=>$project_id]);
$book_number_id = $model_book_number->id;
if(!is_numeric($book_number_id)){
throw new Exception("获取预算书ID失败");
}
//预算书编号
$book_number = $book_number_id+100000;
$model_book_number->save(["book_number"=>$book_number],["id"=>$book_number_id]);
$list_default_book = Db::table("mk_budget_default_book")->where(["project_id"=>$project_id,"status"=>1])->select();
if(count($list_default_book)!=1){
throw new Exception("项目书数量不是唯一");
}
$list_default_book=$list_default_book[0];
unset($list_default_book["id"]);
$list_default_book["book_number"]=$book_number;
if(!isset(DefaultBookCopy::create($list_default_book)["id"])){
throw new Exception("出错了");
}
//插入装修项目信息
$list_default_project = Db::table("mk_budget_default_project")->where(["project_id"=>$project_id,"status"=>1])->select();
$append=["book_number"=>$book_number];
$unset=["id"];
//重整数组 追加 book_number 删除 id
$list_default_project=$this->changeArrayColumnData($list_default_project,$append,$unset);
$insert_count= count($list_default_project);
$model_project =new DefaultProjectCopy();
//超过100条 分批插入
if ($insert_count>0 && $insert_count<100){
$model_project->insertAll($list_default_project);
}elseif($insert_count>100){
$insert_batch= ceil($insert_count/100);
for( $i=0 ;$i<$insert_batch;$i++ ){
$model_project->insertAll(array_slice($list_default_project, $i*100,100));
}
}
//插入装修费率信息
$list_default_rate = Db::table("mk_budget_default_rate")->where(["project_id"=>$project_id,"status"=>1])->select();
$append=["book_number"=>$book_number];
$unset=["id"];
//重整数组 追加 book_number 删除 id
$list_default_rate=$this->changeArrayColumnData($list_default_rate,$append,$unset);
$model_rate =new DefaultRateCopy();
$model_rate->insertAll($list_default_rate) ;
}
$this->commit();
return self::showReturnCodeWithOutData(1001);
}catch (Exception $e){
$this->rollback();
return self::showReturnCodeWithOutData(1008,$e->getMessage());
}
}
~~~
* 实战代码二
以前写的代码 其实他更像是控制器的逻辑层
我现在也看着头大
~~~
/**
* 订单排产
* User: Mikkle
* Q Q:776329498
* @param string $batch_no
*/
public function createFactoryProductBomByBatchNo($batch_no='20170303-16575510'){
@ob_end_clean();
@ob_implicit_flush(0);
try{
if (!$batch_no){
throw new \Exception("生产批号[{$batch_no}]数据不存在");
}
$model = new FactoryBatch();
$batch_info=$model -> where(['batch_no'=>$batch_no])->find();
if($batch_info['batch_status']!= 1){
throw new \Exception("生产批号[{$batch_no}]排产状态异常,请确认是否已经安排排产");
}
$this->flush_str("生产批号[{$batch_no}]排产状态验证通过!");
$this->batch_no=$batch_no;
$order_list = $model -> table('my_factory_orders_batch_access') -> where(['batch_no'=>$batch_no,'factory_state'=>0,'status'=>1]) -> column('order_no');
if($batch_info['order_num']!== count($order_list)){
throw new \Exception("生产批号[{$batch_no}]订单数量和流水线数量不符 请联系系统管理员Mikkle");
}
$this->flush_str("生产批号[{$batch_no}]订单数量和流水线数量验证相符!");
$this->flush_str("生产批号[{$batch_no}]共有订单{$batch_info['order_num']}份");
$model->startTrans();
$this->flush_str("生产批号[{$batch_no}]验证通过,进入BOM单分解流程开始!");
$count_package=[];
$count_product=[];
foreach ($order_list as $item=>$order) {
$no = $item +1;
$order_info = $model ->table('my_orders')->where(['order_no' => $order,'status' => 1,'is_pay' => 1,'factory_batch'=>$batch_no,'factory_state'=>1])->find();
if (!$order_info) {
throw new \Exception("订单[{$order}]状态异常或不存在,请核对订单号再排产");
}
$this->flush_str("<-------------------拆解订单第{$no}个[{$order}]数据开始------------------->");
$this->flush_str("已经验证订单[{$order}]状态正常");
$save_data=$this->splitOrder($order);
if (!$save_data) {
throw new \Exception("订单[{$order}]BOM单分解数据不存在,请联系管理员.");
}
$count_package = $this->guidCountAdd($count_package,$this->count_package);
$count_product = $this->guidCountAdd($count_product,$this->count_product);
$data_num = count($save_data);
$this->flush_str("拆解订单第{$no}个[{$order}]数据,共计[$data_num]份BOM数据");
foreach($save_data as $key=>$value){
$num=$key+1;
$this->flush_str("拆解订单[{$order}]数据第[$num]份BOM数据,{$value['product_bom_name']}");
}
if($model->table('my_factory_orders_bom_access')->insertAll($save_data)==0){
throw new \Exception("写入订单[{$order}]Bom单信息数据失败!");
};
$this->flush_str("写入订单[{$order}]Bom单信息数据成功!");
$this->flush_str("<-------------------拆解订单第{$no}个[{$order}]数据结束------------------->");
}
$save_count_data=array_merge($this->buildCountDataArray($count_package,'Package'), $this->buildCountDataArray($count_product,'Product'));
if($model->table('my_factory_batch_plan')->insertAll($save_count_data)==0){
throw new \Exception("写入生产批次[{$batch_no}]商品统计数据失败!");
};
$this->flush_str("写入生产批次[{$batch_no}]商品统计数据成功!");
$this->flush_str("生产批号[{$batch_no}]全部BOM单分解成功!");
//更新订单表信息
if (!$model->table('my_orders')->where(['factory_batch' => $batch_no])->update([ 'factory_state' => 2])) {
throw new \Exception("更新[$batch_no]订单表数据失败");
}
$this->flush_str("更新[$batch_no]订单表数据成功.");
//更新订单表信息
if($batch_info->where('batch_no',$batch_no)->update(['batch_status'=>2])==0){
throw new \Exception("生产批号[{$batch_no}]排产状态修改失败!");
};
$this->flush_str("生产批号[{$batch_no}]状态修改成功!");
$model->commit();
$this->flush_str("生产批号[{$batch_no}]BOM单分解成功!");
$this->flush_str("<a onclick='history.go(-1)'>返回上一页</a>");
} catch (\Exception $e) {
// / dump($e);
$model->rollback();
$this->batch_no = Null;
$str = "出错了,[{$e->getMessage()}],系统关联操作被取消!";
$this->flush_str($str);
}
}
public function batchNoFactoryProductBomRollback($batch_no){
@ob_end_clean();
@ob_implicit_flush(0);
$model_order = new Orders();
try {
if (!$batch_no) {
throw new \Exception('要回滚的生产批号不存在');
}
$batch_info=$model_order->table('my_factory_batch')->where(['batch_no'=>$batch_no,'status'=>1])->find();
if (!$batch_info) {
throw new \Exception("要回滚的生产批号[{$batch_no}]数据不存在");
}
if ($batch_info['batch_status']!=2) {
throw new \Exception("该生产批号[{$batch_no}]状态已经改变,不允许回滚.");
}
$order_num=$model_order->where(['is_pay' => 1, 'status' => 1, 'factory_batch' => $batch_no])->count('id');
if ($batch_info['order_num']!=$order_num) {
throw new \Exception("该生产批号[{$batch_no}]要回滚的数量异常,请联系Mikkle.");
}
$this->flush_str("生产批号{$batch_no}回滚的订单号数量[{$order_num}]条,验证正确!!");
$model_order->startTrans();
$this->flush_str("生产批号{$batch_no}回滚验证已经通过,开始执行生成批号撤销!");
//更新订单表信息
if (!$model_order->update([ 'factory_state' => 1], ['factory_batch' => $batch_no,'is_pay' => 1, 'status' => 1,])) {
throw new \Exception("回滚生成批次[$batch_no]数据失败");
}
$this->flush_str("生产批号{$batch_no}相关订单数据回滚成功!");
//回滚生产BOM表
if (!$model_order->table('my_factory_orders_bom_access')->where(['batch_no'=>$batch_no,'status' => 1])->update(['status'=>0,'factory_desc'=>'该生产批号已经撤销'])) {
throw new \Exception("回滚生产批次[$batch_no]BOM数据失败");
}
$this->flush_str("回滚生产批次[$batch_no]流水数据成功!");
//回滚生产统计数据
if (!$model_order->table('my_factory_batch_plan')->where(['batch_no'=>$batch_no,'status' => 1])->update(['status'=>0,'factory_desc'=>'该生产批号已经撤销'])) {
throw new \Exception("回滚生产批次[$batch_no]统计数据失败");
}
$this->flush_str("回滚生产批次[$batch_no]统计数据成功!");
//回滚生产批号状态
if (!$model_order->table('my_factory_batch')->where(['batch_no'=>$batch_no])->update(['batch_status'=>1,])) {
throw new \Exception("回滚生产批号[{$batch_no}]数据失败");
}
$this->flush_str("回滚生产表批号[{$batch_no}]数据成功");
$model_order->commit();
$this->flush_str("回滚操作成功");
} catch (\Exception $e) {
$model_order->rollback();
$str = "出错了,[{$e->getMessage()}],系统关联操作被取消!";
$this->flush_str($str);
}
}
~~~
- 序言及更新日志
- 前言一 开发PHP必备的环境(你可以不看)
- LinUX系统ThinkPHP5链接MsSQL数据库的pdo_dblib扩展
- centos7.2挂载硬盘攻略
- Centos系统Redis安装及Redis的PHP扩展安装
- Centos系统增加Swap(系统交换区)的方法
- 前言二 开发PHP软件配置和介绍(你依然可以不看)
- 数据库SQL文件
- 本地Git(版本控制)的搭建
- GIT远程仓库的克隆和推送
- Git常用命令
- PHP面向对象思想实战经验领悟
- PHP面向对象实战----命名空间
- PHP面向对象实战----继承
- 基类实战--底层方法封装
- 基类实战--构造函数实战
- 基类实战--析构函数的使用
- TP5实战开发前篇---控制器(controller)
- 控制器中Request类的使用
- 控制器中基类的使用
- TP5实战开发前篇---模型篇(model)
- TP5实战开发前篇---验证器篇(Validate)
- TP5实战课程入门篇---花拳绣腿
- 模块以及类的文件的建立
- Api开发------单条信息显示
- Api开发---单条信息复杂关联显示
- Api开发---查询信息缓存Cache的应用
- TP5实战技巧---开发思路 引路造桥
- TP5实战技巧---整合基类 化繁为简
- TP5实战课程入门篇---数据操作
- Api开发---数据的添加和修改
- API开发---快速开发API通用接口
- TP5专用微信sdk使用教程
- THINKPHP5微信SDK更新记录及升级指导
- TP5专用SDK 微信参数配置方法
- 微信公众号推送接口对接教程
- 微信推送接口对接示例含扫描登录微信端部分
- TP5专用微信支付SDK使用简介
- TP5专用支付宝支付SDK使用说明
- 使用NW将开发的网站打包成桌面应用
- TP5高阶实战课程 进阶篇概述
- 进阶篇一 实战开发之习惯及要求
- 进阶篇二 实战开发之控制器
- 控制器基类之控制器基类使用方法
- 控制器基类之控制器基类常用方法分享
- 控制器基类之构造函数的使用方法
- 进阶篇三 实战开发之权限控制
- TP5实战源码 --- 全局用户信息验证类Auth
- TP5实战源码 --- 微信Auth实战开发源码
- 进阶篇四 实战开发之模型
- 模型基类之模型基类的用途
- 模型基类之常用数据处理方法
- 模型逻辑层之实战代码(含事务)
- 模型实战开发之模型常用方法
- 模型实战源码 --- 乐观锁的应用
- 模型实战技巧---Model事件功能的使用
- 模型事件实战应用---数据库操作日志
- 进阶篇五 实战开发之缓存(Cache)
- TP5实战源码---应用缓存获取城市信息
- TP5实战源码---应用缓存获取分类详情
- 进阶篇六 TP5类库的封装和使用
- DataEdit快捷操作类库
- ShowCode快捷使用类库
- 阿里大于 短信API接口 TP5专用类库
- DatabaseUpgrade数据库对比及更新类库
- AuthWeb权限类使用说明
- 进阶篇七 服务层的应用
- 服务层源码示例
- 服务层基类源码
- 进阶篇八 应用层Redis数据处理基类
- Redis服务层基类源码
- 进阶篇九 使用Redis类库处理一般的抢购(秒杀)活动示例
- 进阶篇十 某大型项目应用本Redis类源码示例(含事务 乐观锁)
- 进阶篇十一 逻辑层的应用
- 逻辑层基类源码
- 进阶篇 服务层代码示例
- 高阶实战课程 进阶篇持续新增中
- 高阶篇一 TP5命令行之守护任务源码
- TP5实战源码 --- 命令行
- TP5实战源码 --- 通过shell建立PHP守护程序
- 高阶篇二 使用Redis队列发送微信模版消息
- 高阶篇二 之 Worker队列基类源码
- 高阶篇三 TP5实战之Redis缓存应用
- Redis实战源码之Hash专用类库源码
- Redis实战源码之Model类结合
- Redis实战源码之模型Hash基类源码
- Redis实战源码之Hash查询使用技巧
- Redis实战源码之 shell脚本中redis赋值和取值
- 高阶篇四 Swoole的实战应用
- swoole基类代码
- Swoole扩展WebsocketServer专用类
- 基于Swoole的多Room聊天室的程序
- Swoole守护服务shell源码
- 高阶篇五 命令行异步多进程队列类的应用
- tp_worker类源码
- WorkerBase
- WorkerCommand
- WorkerRedis
- Redis类
- CycleWorkBase
- WorkerHookBase异步钩子
- 队列日志SQL
- 高阶篇六 定时执行队列类库以及使用方法
- 定时队列类库源码
- 高阶篇七 异步执行循环队列类库以及使用教程
- CycleWorkBase源码
- 高阶实战课程 进阶篇持续新增中
- Extend便捷类库源码库
- 阿里相关类库
- SendSms--验证码API接口文件
- 权限相关类库目录
- AuthWeb 权限验证类库
- Redis便捷操作类库(20171224更新)
- Redis
- Tools工具类库集
- Curl类库
- DataEdit
- Rand类库
- ShowCode类库
- Upload类库
- 附件集合
- 附件一:微信支付 实战开发源码
- 微信支付类库源代码
- Common_util_pub.php
- DownloadBill_pub.php
- JsApi_pub.php
- NativeCall_pub.php
- NativeLink_pub.php
- OrderQuery_pub.php
- Refund_pub.php
- RefundQuery_pub.php
- SDKRuntimeException.php
- ShortUrl_pub.php
- UnifiedOrder_pub.php
- Wxpay_client_pub.php
- Wxpay_server_pub.php
- WxPayConf_pub.php
- 微信支付回调页面源码
- 附件二 顺丰快递BSP接口实战开发源码
- 顺丰快递BSP接口实战开发源码
- 顺丰BSP基类
- 顺丰BSP基础代码
- 顺丰BSP下单接口
- 顺丰BSP查单接口
- 顺丰BSP确认/取消接口
- 附件三 APP注册登陆接口源码(含融云平台接口)
- 附件四 TP5订单Model(含事务 获取器 修改器等方法)
- 附录五 RSA加密解密
- Rsa文件源码
- 附件六 阿里大于短信接口
- 附件七 AES加解密类
- AES加解密类源码
- 附件八 TP5路由设置源码
- 附件九 TP5 Excel导入导出下载便捷类库
- Excel类库TP5源码
- 附件十 TP5便捷操作Redis类库源码
- TP5源码 Redis操作便捷类库
- 附件十一 TP5源码 上传文件入库类源码
- 上传类Upload源码
- Upload类上传配置文件
- 存储图像文件的数据库SQL文件
- 存储文件的数据库SQL文件
- 附件十二 TP5 图片处理增强类 支持缩略图在线显示
- 附件十三 微信推送消息接口类库源码
- 附件十三 微信推送消息接口类库源码 之 基类
- 附件十四 存储微信昵称的处理方法