Proorder.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ProcessWait;
  4. use think\App;
  5. use think\facade\Db;
  6. //消息(已读未读)
  7. class Proorder extends Base
  8. {
  9. public function __construct(App $app)
  10. {
  11. parent::__construct($app);
  12. }
  13. //已读列表
  14. public function list()
  15. {
  16. /**暂时屏蔽
  17. * $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']) :"1";
  18. * $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']) :"10";
  19. * $where =[['is_del',"=",0],['a.order_status',"=",2]];
  20. * $role=$this->checkRole();
  21. * if(!empty($role['write'])){
  22. * $where[]=["a.action_uid","in",$role['write']];
  23. * }
  24. * $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();
  25. * $total = ceil("$count/$size");
  26. * $page = $page>$total ? $total:$page;
  27. * $list = Db::name('process_order')->alias("a")->leftJoin("workflow b","a.order_type=b.order_type and a.order_code=b.order_code")
  28. * ->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")
  29. * ->where($where)->page($page,$size)->order("a.addtime desc")->select();
  30. * $data=[];
  31. * foreach ($list as $value){
  32. * $str = Db::name("process")->where(['process_type' => $value['order_type']])->field("process_name,status")->find();
  33. * $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();
  34. * $value['process_name']=$str['process_name'];
  35. * $value['order_name']=$var['order_name'];
  36. * $value['status_name'] = $var['status_name'];
  37. * $data[]=$value;
  38. * }
  39. * return app_show(0,"获取成功",['count'=>$count,'list'=>$data]);
  40. * **/
  41. {
  42. $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');
  43. $db = ProcessWait::alias("a")
  44. ->leftJoin("workflow b", "a.order_type=b.order_type and a.order_code=b.order_code")
  45. ->where(['is_del' => 0, 'a.status' => ProcessWait::$status_finish]);
  46. $db->where(function ($query) use ($param) {
  47. //所属角色
  48. $role = $this->checkRole();
  49. // if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
  50. $query->whereFindInSet('roleid', $role['roleid']);
  51. //本人id
  52. $user = GetUserInfo($param['token']);
  53. if (isset($user['data']['id'])) $query->whereOr('wait_id', $user['data']['id']);
  54. });
  55. if ($param['order_code'] != '') $db->whereLike("a.order_code", '%' . $param['order_code'] . '%');
  56. if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);
  57. $count = $db->count();
  58. $total = ceil($count / $param['size']);
  59. $page = $param['page'] > $total ? $total : $param['page'];
  60. $list = $db
  61. ->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")
  62. ->page($page, $param['size'])
  63. ->order("a.addtime desc")
  64. ->select()
  65. ->toArray();
  66. //所有流程名称
  67. $all_process = Db::name("process")
  68. ->whereIn('process_type', array_column($list, 'order_type'))
  69. ->column("process_name", 'process_type');
  70. $data = [];
  71. foreach ($list as $value) {
  72. $var = Db::name("action_process")
  73. ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
  74. ->field("status_name,order_process,order_name,roleid")
  75. ->find();
  76. $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
  77. $value['order_name'] = $var['order_name'];
  78. $value['status_name'] = $var['status_name'];
  79. $data[] = $value;
  80. }
  81. return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
  82. }
  83. }
  84. //待处理列表
  85. public function waitlist()
  86. {
  87. $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');
  88. $db = ProcessWait::alias("a")
  89. ->leftJoin('workflow b', 'a.order_type=b.order_type and a.order_code=b.order_code')
  90. ->leftJoin('process p', 'p.process_type=a.order_type AND p.is_del=0 AND p.status=1')
  91. ->where(['a.status' => ProcessWait::$status_wait]);
  92. $db->where(function ($query) use ($param) {
  93. //所属角色
  94. $role = $this->checkRole();
  95. // if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
  96. $query->whereFindInSet('roleid', $role['roleid']);
  97. //本人id
  98. $query->whereOr('wait_id', $this->uid);
  99. });
  100. if ($param['order_code'] != '') $db->whereLike('a.order_code', '%' . $param['order_code'] . '%');
  101. if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);
  102. $count = $db->count();
  103. $total = ceil($count / $param['size']);
  104. $page = $param['page'] > $total ? $total : $param['page'];
  105. $list = $db
  106. ->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")
  107. ->page($page, $param['size'])
  108. ->order("a.addtime desc")
  109. ->append(['handle_user_list'])
  110. ->withAttr('handle_user_list', function ($val, $da) {
  111. return [];
  112. })
  113. ->select()
  114. ->toArray();
  115. //所有流程名称
  116. $all_process = Db::name("process")
  117. ->whereIn('process_type', array_column($list, 'order_type'))
  118. ->column("process_name", 'process_type');
  119. $data = [];
  120. foreach ($list as $value) {
  121. $var = Db::name("action_process")
  122. ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
  123. ->field("status_name,order_process,order_name,roleid")
  124. ->find();
  125. $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
  126. $value['order_name'] = $var['order_name'];
  127. $value['status_name'] = $var['status_name'];
  128. //找到流程对应记录的所有人(创建人 or 申请人 or 采购员)
  129. $holder_id = 0;
  130. switch ($value['order_type']) {
  131. //1.采购单流程
  132. case 'CGD':
  133. $holder_id = Db::name('purchease_order')->where(['id' => $value['order_id'], 'is_del' => 0])->value('cgder_id', 0);
  134. break;
  135. //2.采购单入库流程
  136. case 'RKD':
  137. $holder_id = Db::name('purchease_in')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  138. break;
  139. //3.备货申请单流程
  140. case 'BHD':
  141. $holder_id = Db::name('purchease')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  142. break;
  143. //4.销售订单流程
  144. case 'XSQRD':
  145. $holder_id = Db::name('sale')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  146. break;
  147. //5.发货申请单流程
  148. case 'CKD':
  149. $holder_id = Db::name('order_out')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  150. break;
  151. //6.售后申请单流程
  152. case 'SHD':
  153. $holder_id = Db::name('order_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  154. break;
  155. //7.售后退货单流程
  156. case 'CKTHD':
  157. $holder_id = Db::name('order_back')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  158. break;
  159. //8.销售退货单流程
  160. case 'XSTHD':
  161. $holder_id = Db::name('sale_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  162. break;
  163. //9.采购工差单流程
  164. case 'CGGCD':
  165. $holder_id = Db::name('purchease_diff')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  166. break;
  167. //10.销售工差单流程
  168. case 'XSGCD':
  169. $holder_id = Db::name('sale_diff')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  170. break;
  171. //11.调拨单流程
  172. case 'DBD':
  173. $holder_id = Db::name('allot_stock')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  174. break;
  175. //12.盘点单流程
  176. case 'PDD':
  177. $holder_id = Db::name('good_check')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  178. break;
  179. //13.议价单流程
  180. case 'YJD':
  181. $holder_id = Db::name('bargain_order')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  182. break;
  183. //14.项目单流程
  184. case 'PRO':
  185. $holder_id = Db::name('project')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  186. break;
  187. //15.商品成本流程
  188. case 'SPCB':
  189. $holder_id = Db::name('good_basic')->where(['id' => 'order_id', 'is_del' => 0])->value('chargerid', 0);
  190. break;
  191. //16.商品上线流程
  192. case 'SPSX':
  193. $holder_id = Db::name('good')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  194. break;
  195. //17.活动流程
  196. case 'HD':
  197. $holder_id = Db::name('good_activity')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  198. break;
  199. //19.有赞商品上架流程
  200. case 'YZSX':
  201. $holder_id = Db::name('good_basic')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  202. break;
  203. //20.有赞订单审核流程
  204. // case 'YZQRD':
  205. // $holder_id = Db::name('')->where(['id' => 'order_id', 'is_del' => 0])->value('', 0);
  206. // break;
  207. //22.离职交接流程
  208. case 'LZJJ':
  209. $holder_id = Db::name('resign_info')->where(['id' => 'order_id', 'is_del' => 0])->value('hand_uid', 0);
  210. break;
  211. //23.采购单退货流程
  212. case 'CGTHD':
  213. $holder_id = Db::name('purchease_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
  214. break;
  215. //24.竞价单流程
  216. case 'ZXD':
  217. $holder_id = Db::name('consult_order')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  218. break;
  219. //25.商品下线流程
  220. case 'GOL':
  221. $holder_id = Db::name('good_offline_log')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
  222. break;
  223. }
  224. //根据记录的所有人判断哪些人能看到它的记录
  225. $uids_1 = $this->get_uids_by_group_share($holder_id, $value['api_url']);
  226. //根据角色筛选
  227. $uids_2 = Db::name('user_role')
  228. ->where([
  229. ['is_del', '=', 0],
  230. ['roleid', 'in', $value['roleid']],
  231. ['status', '=', 1],
  232. ['roleid', '<>', 1],//超级管理员不在这个范围内
  233. ])
  234. ->column('uid');
  235. $uids = array_intersect($uids_1['1'], $uids_2);
  236. $users = Db::name('depart_user')->where(['is_del' => 0, 'status' => 1])->whereIn('uid', $uids)->column('nickname');
  237. //当前操作人
  238. $value['handle_user_list'] = $value['wait_name'] ? array_merge($users, [$value['wait_name']]) : $users;
  239. $data[] = $value;
  240. }
  241. return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
  242. }
  243. public function all(){
  244. $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  245. if($token==""){
  246. return error_show(101,'token不能为空');
  247. }
  248. $effetc = VerifyTokens($token);
  249. if(!empty($effetc) && $effetc['code']!=0){
  250. return error_show($effetc['code'],$effetc['message']);
  251. }
  252. $where=[["is_del","=",0]];
  253. $process_name = isset($this->post['process_name']) && $this->post['process_name'] !==""? trim($this->post['process_name']) :"";
  254. if($process_name!=""){
  255. $where[]=["process_name","like","%$process_name%"];
  256. }
  257. $process_type = isset($this->post['process_type']) && $this->post['process_type'] !==""? trim($this->post['process_type']) :"";
  258. if($process_type!=""){
  259. $where[]=["process_type","like","%$process_type%"];
  260. }
  261. $list = Db::name('process')->where($where)->order("addtime desc")->select();
  262. return app_show(0,"获取成功",$list);
  263. }
  264. //我能被哪些人看到?
  265. private function get_uids_by_group_share(int $uid = 0, string $api_url = '')
  266. {
  267. //原始数据
  268. $data = [1 => [$uid], 2 => [$uid], 3 => []];
  269. //用户组
  270. $group = Db::name('data_group_userid')
  271. ->alias('a')
  272. ->leftJoin('data_group b', 'b.id=a.data_group_id')
  273. ->where([
  274. 'a.is_del' => 0,
  275. 'a.status' => 1,
  276. 'a.uid' => $uid,
  277. 'b.is_del' => 0,
  278. 'b.status' => 1,
  279. ])->order('a.data_group_id')
  280. ->column('b.type', 'a.data_group_id');
  281. $group_user = Db::name('data_group_userid')
  282. ->where([
  283. 'is_del' => 0,
  284. 'status' => 1,
  285. ])->whereIn('data_group_id', array_keys($group))
  286. ->field('id,data_group_id,uid')
  287. ->order('uid')
  288. ->cursor();
  289. foreach ($group_user as $g_u) {
  290. $data[$group[$g_u['data_group_id']]][] = $g_u['uid'];
  291. }
  292. //当前请求的接口地址
  293. if ($api_url == '') $api_url = app('http')->getName() . '/' . request()->pathinfo();
  294. $menu_id = Db::name('admin_menu')
  295. ->where(['is_del' => 0, 'menu_api' => $api_url])
  296. ->value('id', 0);
  297. if ($menu_id) {
  298. //共享规则
  299. $share = Db::name('data_share')
  300. ->field('id,type,uid,data_group_id')
  301. ->where([
  302. 'is_del' => 0,
  303. 'status' => 1,
  304. ])
  305. ->whereFindInSet('menu_ids', $menu_id)
  306. ->where(function ($query) use ($uid, $group) {
  307. return $query->where('source_uid', $uid)->whereOr('source_data_group_id', 'in', array_keys($group));
  308. })
  309. ->cursor();
  310. foreach ($share as $s) {
  311. $source_group_uid = Db::name('data_group_userid')
  312. ->where([
  313. 'is_del' => 0,
  314. 'status' => 1,
  315. 'data_group_id' => $s['data_group_id'],
  316. ])->order('uid')->column('uid');
  317. //$s['source_uid'] ? [$s['source_uid']] : [] 排除默认值0
  318. $data[$s['type']] = array_merge($data[$s['type']], $s['uid'] ? [$s['uid']] : [], $source_group_uid);
  319. }
  320. }
  321. unset($data[3]);
  322. $data[0] = array_merge($data[1], $data[2]);
  323. sort($data[0]);
  324. $data[0] = array_unique($data[0]);
  325. return $data;
  326. }
  327. }