// +---------------------------------------------------------------------- namespace App\Services; use App\Models\StoresModel; use App\Models\StoresRecordsModel; /** * 商品出入库管理-服务类 * @author wesmiler * @since 2020/11/11 * Class StoreRecordsService * @package App\Services */ class StoreRecordsService extends BaseService { protected $storeModel = null; /** * 构造函数 * @author wesmiler * @since 2020/11/11 * StoreRecordsService constructor. */ public function __construct() { $this->model = new StoresRecordsModel(); $this->storeModel = new StoresModel(); } /** * 获取列表 * @return array * @since 2020/11/11 * @author wesmiler */ public function getList() { $params = request()->all(); $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE; $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE; $dataList = $this->model::from('store_records as sr') ->leftJoin('stores as s', 's.id', '=', 'sr.store_id') ->where(function ($query) use ($params) { $query->where('sr.mark', 1); $type = isset($params['type']) ? intval($params['type']) : 0; if ($type > 0) { $query->where('sr.cate_id', $type); } $status = isset($params['status']) ? $params['status'] : 0; if ($status > 0) { $query->where('sr.status', $status); } else { $query->whereIn('sr.status', [1, 2]); } }) ->where(function ($query) use ($params) { $keyword = isset($params['keyword']) ? trim($params['keyword']) : ''; if (!empty($keyword)) { $query->where('s.title', 'like', "%{$keyword}%") ->orWhere('s.source','like',"%{$keyword}%"); } }) ->select(['sr.id', 'sr.store_id', 's.title as goods_name','sr.stock', 'sr.type', 'sr.description', 'sr.create_time', 'sr.update_time']) ->orderBy('sr.update_time', 'desc') ->paginate($pageSize); $dataList = $dataList ? $dataList->toArray() : []; if ($dataList) { foreach ($dataList['data'] as &$item) { $item['create_time'] = $item['create_time'] ? datetime($item['create_time'],'Y-m-d H:i:s') : ''; } unset($item); } return [ 'code' => 0, 'success'=> true, 'msg' => '操作成功', 'count' => isset($dataList['total']) ? $dataList['total'] : 0, 'data' => isset($dataList['data']) ? $dataList['data'] : 0, ]; } /** * 添加或编辑 * @return array * @since 2020/11/11 * @author wesmiler */ public function edit() { $data = request()->all(); $data['update_time'] = time(); $storeId = isset($data['store_id'])? $data['store_id'] : 0; $type = isset($data['type'])? $data['type'] : 0; $stock = isset($data['stock'])? $data['stock'] : 0; if(!in_array($type, [1,2])){ return message('出入库类型错误', false); } if(empty($storeId)){ return message('操作商品参数错误', false); } if($stock<=0){ return message('出入库数量错误', false); } $storeInfo = $this->storeModel->where(['id'=> $storeId,'status'=> 1])->first(); if(!$storeInfo){ return message('操作商品不存在或状态不可操作', false); } // 出库 if($storeInfo->stock < $stock && $type == 2){ return message('出库数量超出商品库存', false); } if($type==1){ $res = $this->storeModel::where(['id'=> $storeId])->increment('stock', $stock); }else{ $res = $this->storeModel::where(['id'=> $storeId])->decrement('stock', $stock); } $data = [ 'store_id'=> $storeId, 'type'=> $type, 'stock'=> $stock, 'description'=> isset($data['description'])? $data['description'] : '', 'create_time'=> time(), 'update_time'=> time(), 'status'=> 1, ]; if($res && $this->model->insert($data)){ return message(); }else{ return message(MESSAGE_FAILED, false); } } }