123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300 |
- <?php
- namespace addons\qingdongams\controller;
- use addons\qingdongams\model\Parts as PartsModel;
- use addons\qingdongams\model\Message;
- use addons\qingdongams\model\PartsStock;
- use addons\qingdongams\model\PartsStockReload;
- use think\Db;
- use think\Exception;
- /**
- * 零件管理
- */
- class Parts extends StaffApi
- {
- protected $noNeedLogin = [];
- protected $noNeedRight = [];
- //获取零件列表
- public function getList()
- {
- $limit = input("limit/d", 10);
- $params = $this->request->post();
- $where = [];
- $stock='';
- $order = 'id desc';
- if (isset($params['name']) && $params['name']) {//产品名称
- $where['name'] = ['like', "%{$params['name']}%"];
- }
- if(isset($params['type']) && $params['type'] == 1){
- $stock='stock <= warning_stock';
- }
- $list = PartsModel::where($where)->with([
- 'createStaff',
- ])->where($stock)->order($order)->paginate($limit);
- $this->success('请求成功', $list);
- }
- //获取selelct列表
- public function getSelectList()
- {
- $name = input('name');
- $product_id = input('product_id');
- $where = [];
- if ($name) {
- $where['name'] = ['like', "%{$name}%"];
- }
- $whereProduct = [];
- if ($product_id) {//产品
- $product_id=intval($product_id);
- $whereProduct[] = ['exp', Db::raw('FIND_IN_SET(' . $product_id . ',product_id)')];
- }
- $list = PartsModel::where($where)
- ->where($whereProduct)
- ->with(['createStaff'])
- ->field('id,name,stock,num,img,unit,price,status')->select();
- $this->success('请求成功', $list);
- }
- //添加零件
- public function addParts()
- {
- $params = $this->request->post();
- if (PartsModel::where(['name' => $params['name']])->find()) {
- $this->error('零件名称已存在');
- }
- try {
- $result = PartsModel::createParts($params);
- Db::commit();
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- if ($result) {
- $this->success('新增零件成功');
- }
- }
- //修改零件
- public function editParts()
- {
- $id = input('id');
- $params = $this->request->post();
- $row = PartsModel::where(['id' => $id])->find();
- if (empty($row)) {
- $this->error('修改零件信息不存在');
- }
- $params['product_id']=implode(',',$params['product_id']);
- // 表单验证
- if (($result = $this->qingdongamsValidate($params,get_class(), 'edit')) !== true) {
- $this->error($result);
- }
- Db::startTrans();
- try {
- $result = PartsModel::updateParts($params);
- Db::commit();
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- $this->success('修改零件信息成功');
- }
- //获取零件详情
- public function getPartsDetail()
- {
- $id = input('id');
- $parts = PartsModel::where(['id' => $id])->with(['createStaff'])->find();
- if (empty($parts)) {
- $this->error('零件信息不存在');
- }
- if (!empty($parts['product_id'])) {
- $product_ids = explode(',', $parts['product_id']);
- $names = \addons\qingdongams\model\Product::where(['id' => ['in', $product_ids]])->column('name');
- $parts['product_name'] = implode(',', $names);
- }
- $parts['stocks'] = PartsStock::where(['parts_id' => $id])->with(['createStaff'])->select();
- Message::setRead(Message::PARTS_TYPE,$id,$this->auth->id);
- $this->success('请求成功', $parts);
- }
- //获取库存记录
- public function getStockRecord()
- {
- $parts_id = input('parts_id');
- $type = input('type');
- if (empty($parts_id)) {
- $this->error('库存不存在');
- }
- $where = ['parts_id' => $parts_id];
- if ($type) {
- $where['type'] = $type;
- }
- $stocks = PartsStock::where($where)->with(['parts', 'createStaff'])->select();
- $this->success('请求成功', $stocks);
- }
- //添加库存
- public function addStocks()
- {
- $params = $this->request->post();
- // 表单验证
- if (($result = $this->validate($params, 'addons\qingdongams\validate\PartsStockReload.create')) !== true) {
- $this->error($result);
- }
- Db::startTrans();
- try {
- $parts = [];
- foreach ($params['parts'] as $part) {
- $parts[] = ['id' => $part['id'], 'number' => $part['number']];
- }
- $params['parts'] = json_encode($params['parts']);
- PartsStockReload::addRecord($params);
- Db::commit();
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- $this->success('提交成功');
- }
- //首页-库存审批记录
- public function examineStockRecord()
- {
- $limit = input('limit', 10);
- $type = input('type');//1 出库 入库
- $check_status = input('check_status'); //审核状态 1审核中、2审核通过、3审核未通过
- $where = [];
- if ($type) {
- $where['type'] = $type;
- }
- $whereFlow = [];
- $where = [];
- if ($check_status) {
- //0待审核、1审核中、2审核通过、3审核未通过、4撤销
- if ($check_status == 1) {
- $where['check_status'] = ['in', [0, 1]];
- } elseif ($check_status == 2) {
- $where['check_status'] = 2;
- } elseif ($check_status == 3) {
- $where['check_status'] = ['in', [3, 4]];
- }
- }
- $select = PartsStockReload::where($where)->with(['createStaff'])->paginate($limit);
- $this->success('请求成功', $select);
- }
- //我的库存记录
- public function myStockRecord()
- {
- $limit = input('limit', 10);
- $times = input('times');
- $type = input('type');//
- $check_status = input('check_status');//审核状态 1审核中、2审核通过、3审核未通过
- $check_type = input('check_type', 1);
- $where = [];
- $whereFlow = [];
- if ($type) {
- $where['type'] = $type;
- }
- if ($check_type == 1) {//我发起的
- $where['create_staff_id'] = $this->auth->id;
- } elseif ($check_type == 2) {//我审批的
- $whereFlow[] = ['exp', Db::raw('FIND_IN_SET(' . $this->auth->id . ',flow_staff_ids)')];
- }
- if ($check_status) {
- //0待审核、1审核中、2审核通过、3审核未通过、4撤销
- if ($check_status == 1) {
- $where['check_status'] = ['in', [0, 1]];
- } elseif ($check_status == 2) {
- $where['check_status'] = 2;
- } elseif ($check_status == 3) {
- $where['check_status'] = ['in', [3, 4]];
- }
- }
- // $where['create_staff_id'] = $this->auth->id;
- if ($times) {//创建时间
- $times = explode(',', $times);
- $where['createtime'] = ['between', [$times[0], $times[1]]];
- }
- $select = PartsStockReload::where($where)->where($whereFlow)->order('id desc')->with(['createStaff'])->paginate($limit);
- $this->success('请求成功', $select);
- }
- //获取我的 已申请和待我审核
- public function getReloadNumber()
- {
- $check_type = input('check_type', 1);
- $where = [
- 'check_status' => ['in', [0, 1]],];
- $whereFlow = [];
- if ($check_type == 1) {//我发起的
- $where['create_staff_id'] = $this->auth->id;
- } elseif ($check_type == 2) {//我审批的
- $whereFlow[] = ['exp', Db::raw('FIND_IN_SET(' . $this->auth->id . ',flow_staff_ids)')];
- }
- $ruku = PartsStockReload::where([
- 'type' => 1,
- ])->where($where)->where($whereFlow)->count();
- $chuku = PartsStockReload::where([
- 'type' => 2,
- ])->where($where)->where($whereFlow)->count();
- $this->success('请求成功', ['ruku' => $ruku, 'chuku' => $chuku]);
- }
- //获取零件审批详情
- public function getPartsReloadDetail(){
- $id=input('id');
- $detail = PartsStockReload::where([
- 'id' => $id,
- ])->with(['createStaff'])->find();
- $detail['is_examine'] = 0;
- $detail['is_operation'] = 0;
- if(in_array($detail['check_status'],[0,1]) && in_array($this->auth->id,explode(',',$detail['flow_staff_ids']))){
- $detail['is_examine'] = 1;
- $detail['is_operation'] = 1;
- }
- if($detail['create_staff_id'] == $this->auth->id){
- //是否可以操作
- $detail['is_operation']=1;
- }
- Message::setRead(Message::PARTS_TYPE,$id,$this->auth->id);
- $this->success('请求成功', $detail);
- }
- //获取零件编号
- public function getPartsNumber()
- {
- $this->success('请求成功', ['number' => 'KQ' . date('Ymdhis') . rand(1000, 9999)]);
- }
- }
|