123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379 |
- <?php
- namespace app\admin\controller;
- use app\admin\model\ProcessWait;
- use think\App;
- use think\facade\Db;
- //消息(已读未读)
- class Proorder extends Base
- {
- public function __construct(App $app)
- {
- parent::__construct($app);
- }
- //已读列表
- public function list()
- {
- /**暂时屏蔽
- * $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']) :"1";
- * $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']) :"10";
- * $where =[['is_del',"=",0],['a.order_status',"=",2]];
- * $role=$this->checkRole();
- * if(!empty($role['write'])){
- * $where[]=["a.action_uid","in",$role['write']];
- * }
- * $count = Db::name('process_order')->alias("a")->leftJoin("workflow b","a.order_type=b.order_type and a.order_code=b.order_code")->where($where)->count();
- * $total = ceil("$count/$size");
- * $page = $page>$total ? $total:$page;
- * $list = Db::name('process_order')->alias("a")->leftJoin("workflow b","a.order_type=b.order_type and a.order_code=b.order_code")
- * ->field("b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.action_status,a.order_type,a.action_process,a.order_code,a.order_id,a.id")
- * ->where($where)->page($page,$size)->order("a.addtime desc")->select();
- * $data=[];
- * foreach ($list as $value){
- * $str = Db::name("process")->where(['process_type' => $value['order_type']])->field("process_name,status")->find();
- * $var = Db::name("action_process")->where(['order_type'=>$value['order_type'],'order_process'=>$value['action_status']])->field("status_name,order_process,order_name,roleid")->find();
- * $value['process_name']=$str['process_name'];
- * $value['order_name']=$var['order_name'];
- * $value['status_name'] = $var['status_name'];
- * $data[]=$value;
- * }
- * return app_show(0,"获取成功",['count'=>$count,'list'=>$data]);
- * **/
- {
- $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');
- $db = ProcessWait::alias("a")
- ->leftJoin("workflow b", "a.order_type=b.order_type and a.order_code=b.order_code")
- ->where(['is_del' => 0, 'a.status' => ProcessWait::$status_finish]);
- $db->where(function ($query) use ($param) {
- //所属角色
- $role = $this->checkRole();
- // if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
- $query->whereFindInSet('roleid', $role['roleid']);
- //本人id
- $user = GetUserInfo($param['token']);
- if (isset($user['data']['id'])) $query->whereOr('wait_id', $user['data']['id']);
- });
- if ($param['order_code'] != '') $db->whereLike("a.order_code", '%' . $param['order_code'] . '%');
- if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);
- $count = $db->count();
- $total = ceil($count / $param['size']);
- $page = $param['page'] > $total ? $total : $param['page'];
- $list = $db
- ->field("b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.order_type,a.order_process,a.order_code,a.order_id,a.id")
- ->page($page, $param['size'])
- ->order("a.addtime desc")
- ->select()
- ->toArray();
- //所有流程名称
- $all_process = Db::name("process")
- ->whereIn('process_type', array_column($list, 'order_type'))
- ->column("process_name", 'process_type');
- $data = [];
- foreach ($list as $value) {
- $var = Db::name("action_process")
- ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
- ->field("status_name,order_process,order_name,roleid")
- ->find();
- $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
- $value['order_name'] = $var['order_name'];
- $value['status_name'] = $var['status_name'];
- $data[] = $value;
- }
- return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
- }
- }
- //待处理列表
- public function waitlist()
- {
- $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');
- $db = ProcessWait::alias("a")
- ->leftJoin('workflow b', 'a.order_type=b.order_type and a.order_code=b.order_code')
- ->leftJoin('process p', 'p.process_type=a.order_type AND p.is_del=0 AND p.status=1')
- ->where(['a.status' => ProcessWait::$status_wait]);
- $db->where(function ($query) use ($param) {
- //所属角色
- $role = $this->checkRole();
- // if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
- $query->whereFindInSet('roleid', $role['roleid']);
- //本人id
- $query->whereOr('wait_id', $this->uid);
- });
- if ($param['order_code'] != '') $db->whereLike('a.order_code', '%' . $param['order_code'] . '%');
- if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);
- $count = $db->count();
- $total = ceil($count / $param['size']);
- $page = $param['page'] > $total ? $total : $param['page'];
- $list = $db
- ->field("a.id,b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.order_type,a.order_process,a.order_code,a.order_id,a.roleid,a.wait_name,p.api_url")
- ->page($page, $param['size'])
- ->order("a.addtime desc")
- ->append(['handle_user_list'])
- ->withAttr('handle_user_list', function ($val, $da) {
- return [];
- })
- ->select()
- ->toArray();
- //所有流程名称
- $all_process = Db::name("process")
- ->whereIn('process_type', array_column($list, 'order_type'))
- ->column("process_name", 'process_type');
- $data = [];
- foreach ($list as $value) {
- $var = Db::name("action_process")
- ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
- ->field("status_name,order_process,order_name,roleid")
- ->find();
- $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
- $value['order_name'] = $var['order_name'];
- $value['status_name'] = $var['status_name'];
- //找到流程对应记录的所有人(创建人 or 申请人 or 采购员)
- $holder_id = 0;
- switch ($value['order_type']) {
- //1.采购单流程
- case 'CGD':
- $holder_id = Db::name('purchease_order')->where(['id' => $value['order_id'], 'is_del' => 0])->value('cgder_id', 0);
- break;
- //2.采购单入库流程
- case 'RKD':
- $holder_id = Db::name('purchease_in')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
- break;
- //3.备货申请单流程
- case 'BHD':
- $holder_id = Db::name('purchease')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
- break;
- //4.销售订单流程
- case 'XSQRD':
- $holder_id = Db::name('sale')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //5.发货申请单流程
- case 'CKD':
- $holder_id = Db::name('order_out')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //6.售后申请单流程
- case 'SHD':
- $holder_id = Db::name('order_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //7.售后退货单流程
- case 'CKTHD':
- $holder_id = Db::name('order_back')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //8.销售退货单流程
- case 'XSTHD':
- $holder_id = Db::name('sale_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //9.采购工差单流程
- case 'CGGCD':
- $holder_id = Db::name('purchease_diff')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //10.销售工差单流程
- case 'XSGCD':
- $holder_id = Db::name('sale_diff')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //11.调拨单流程
- case 'DBD':
- $holder_id = Db::name('allot_stock')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //12.盘点单流程
- case 'PDD':
- $holder_id = Db::name('good_check')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //13.议价单流程
- case 'YJD':
- $holder_id = Db::name('bargain_order')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- //14.项目单流程
- case 'PRO':
- $holder_id = Db::name('project')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- //15.商品成本流程
- case 'SPCB':
- $holder_id = Db::name('good_basic')->where(['id' => 'order_id', 'is_del' => 0])->value('chargerid', 0);
- break;
- //16.商品上线流程
- case 'SPSX':
- $holder_id = Db::name('good')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- //17.活动流程
- case 'HD':
- $holder_id = Db::name('good_activity')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- //19.有赞商品上架流程
- case 'YZSX':
- $holder_id = Db::name('good_basic')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- //20.有赞订单审核流程
- // case 'YZQRD':
- // $holder_id = Db::name('')->where(['id' => 'order_id', 'is_del' => 0])->value('', 0);
- // break;
- //22.离职交接流程
- case 'LZJJ':
- $holder_id = Db::name('resign_info')->where(['id' => 'order_id', 'is_del' => 0])->value('hand_uid', 0);
- break;
- //23.采购单退货流程
- case 'CGTHD':
- $holder_id = Db::name('purchease_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
- break;
- //24.竞价单流程
- case 'ZXD':
- $holder_id = Db::name('consult_order')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- //25.商品下线流程
- case 'GOL':
- $holder_id = Db::name('good_offline_log')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
- break;
- }
- //根据记录的所有人判断哪些人能看到它的记录
- $uids_1 = $this->get_uids_by_group_share($holder_id, $value['api_url']);
- //根据角色筛选
- $uids_2 = Db::name('user_role')
- ->where([
- ['is_del', '=', 0],
- ['roleid', 'in', $value['roleid']],
- ['status', '=', 1],
- ['roleid', '<>', 1],//超级管理员不在这个范围内
- ])
- ->column('uid');
- $uids = array_intersect($uids_1['1'], $uids_2);
- $users = Db::name('depart_user')->where(['is_del' => 0, 'status' => 1])->whereIn('uid', $uids)->column('nickname');
- //当前操作人
- $value['handle_user_list'] = $value['wait_name'] ? array_merge($users, [$value['wait_name']]) : $users;
- $data[] = $value;
- }
- return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
- }
- public function all(){
- $token = isset($this->post['token']) ? trim($this->post['token']) : "";
- if($token==""){
- return error_show(101,'token不能为空');
- }
- $effetc = VerifyTokens($token);
- if(!empty($effetc) && $effetc['code']!=0){
- return error_show($effetc['code'],$effetc['message']);
- }
- $where=[["is_del","=",0]];
- $process_name = isset($this->post['process_name']) && $this->post['process_name'] !==""? trim($this->post['process_name']) :"";
- if($process_name!=""){
- $where[]=["process_name","like","%$process_name%"];
- }
- $process_type = isset($this->post['process_type']) && $this->post['process_type'] !==""? trim($this->post['process_type']) :"";
- if($process_type!=""){
- $where[]=["process_type","like","%$process_type%"];
- }
- $list = Db::name('process')->where($where)->order("addtime desc")->select();
- return app_show(0,"获取成功",$list);
- }
- //我能被哪些人看到?
- private function get_uids_by_group_share(int $uid = 0, string $api_url = '')
- {
- //原始数据
- $data = [1 => [$uid], 2 => [$uid], 3 => []];
- //用户组
- $group = Db::name('data_group_userid')
- ->alias('a')
- ->leftJoin('data_group b', 'b.id=a.data_group_id')
- ->where([
- 'a.is_del' => 0,
- 'a.status' => 1,
- 'a.uid' => $uid,
- 'b.is_del' => 0,
- 'b.status' => 1,
- ])->order('a.data_group_id')
- ->column('b.type', 'a.data_group_id');
- $group_user = Db::name('data_group_userid')
- ->where([
- 'is_del' => 0,
- 'status' => 1,
- ])->whereIn('data_group_id', array_keys($group))
- ->field('id,data_group_id,uid')
- ->order('uid')
- ->cursor();
- foreach ($group_user as $g_u) {
- $data[$group[$g_u['data_group_id']]][] = $g_u['uid'];
- }
- //当前请求的接口地址
- if ($api_url == '') $api_url = app('http')->getName() . '/' . request()->pathinfo();
- $menu_id = Db::name('admin_menu')
- ->where(['is_del' => 0, 'menu_api' => $api_url])
- ->value('id', 0);
- if ($menu_id) {
- //共享规则
- $share = Db::name('data_share')
- ->field('id,type,uid,data_group_id')
- ->where([
- 'is_del' => 0,
- 'status' => 1,
- ])
- ->whereFindInSet('menu_ids', $menu_id)
- ->where(function ($query) use ($uid, $group) {
- return $query->where('source_uid', $uid)->whereOr('source_data_group_id', 'in', array_keys($group));
- })
- ->cursor();
- foreach ($share as $s) {
- $source_group_uid = Db::name('data_group_userid')
- ->where([
- 'is_del' => 0,
- 'status' => 1,
- 'data_group_id' => $s['data_group_id'],
- ])->order('uid')->column('uid');
- //$s['source_uid'] ? [$s['source_uid']] : [] 排除默认值0
- $data[$s['type']] = array_merge($data[$s['type']], $s['uid'] ? [$s['uid']] : [], $source_group_uid);
- }
- }
- unset($data[3]);
- $data[0] = array_merge($data[1], $data[2]);
- sort($data[0]);
- $data[0] = array_unique($data[0]);
- return $data;
- }
- }
|