记录 version

描述：

目录结构

  1. .
  2. ├── Controller
  3. ├── Install 
  4. ├── Libs 核心实现库
  5. ├── Records 记录实体类
  6. ├── Model 
  7. ├── Service 服务
  8. └── Uninstall

使用指南

1.创建你的记录实体类

在 Record/Records/ 目录下创建消息实体类，并继承 Record\Libs\Record 类

  2. <?php
  3. namespace Record\Records;
  5. use Record\Libs\Record;
  7. class TradeRecord extends Record {
  8.     public $table_name = 'RecordTrade';
  10.     public function __construct($to, $target_type, $target) {
  11.         $this->setTo($to);
  12.         $this->setTargetType($target_type);
  13.         $this->setTarget($target);
  14.     }
  15. }

2.添加记录

使用 Record\Service\RecordService::createRrcord($record) 添加消息

  2. <?php
  3. namespace Record\Controller;
  6. use Common\Controller\AdminBase;
  7. use Record\Records\TradeRecord;
  8. use Record\Service\RecordService;
  9. use Record\Service\TradeRecordService;
  11. class TestController extends AdminBase {
  12.     public function index() {
  13.         $recode = new TradeRecord('1', 'wxpay', '1232122');
  14.         $recode->setIncome(100);
  15.         $this->ajaxReturn(RecordService::createRrcord($recode));
  16. //        $this->ajaxReturn(TradeRecordService::createTradeRecord('1', 'wxpay', '1232122', 100, 50));
  17.     }
  18. }

3.进一步封装 service

  2. <?php
  3. namespace Record\Service;
  5. use Record\Libs\Record;
  6. use Record\Model\RecordModel;
  7. use System\Service\BaseService;
  9. class RecordService extends BaseService {
  10.     static function createRrcord(Record $record) {
  11.         //获取上一条合法的record id
  12.         $where['status'] = RecordModel::STATUS_VAILD;
  13.         $where['to'] = $record->getTo();
  14.         $where['to_type'] = $record->getToType();
  15.         $last_vaild_record = M($record->table_name)->where($where)->order('id desc')->find();
  16.         $last_vaild_balance = self::getBalance($record)['data']; //获取最近的余额信息
  18.         $data = [
  19.             'parent_id' => $last_vaild_record ? $last_vaild_record['id'] : 0,
  20.             'to' => $record->getTo(),
  21.             'to_type' => $record->getToType(),
  22.             'from' => $record->getFrom(),
  23.             'from_type' => $record->getFromType(),
  24.             'target' => $record->getTarget(),
  25.             'target_type' => $record->getTargetType(),
  26.             'income' => $record->getIncome(),
  27.             'pay' => $record->getPay(),
  28.             'balance' => ($last_vaild_balance + $record->getIncome() - $record->getPay()),//计算当前记录的余额
  29.             'detail' => $record->getDetail(),
  30.             'status' => $record->getStatus(),
  31.             'create_time' => time(),
  32.             'remark' => $record->getRemark()
  33.         ];
  34.         $result = M($record->table_name)->add($data);
  35.         if ($result) {
  36.             return self::createReturn(true, $result);
  37.         }
  39.         return self::createReturn(false, null, '操作失败');
  40.     }
  42.     static function getBalance(Record $record) {
  43.         $where = [
  44.             'to' => $record->getTo(),
  45.             'to_type' => $record->getToType(),
  46.             'status' => RecordModel::STATUS_VAILD
  47.         ];
  48.         $lists = M($record->table_name)->field('income,pay')->where($where)->select();
  49.         $total = 0;
  50.         for ($i = 0; $i < count($lists); $i++) {
  51.             $total = $total + $lists[$i]['income'] - +$lists[$i]['pay'];
  52.         }
  54.         return self::createReturn(true, $total, 'ok');
  55.     }
  56. }