Proorder.php 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356
  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
  58. // ->field("ANY_VALUE(`a`.`id`) id,`a`.order_type,`a`.order_id,GROUP_CONCAT(`a`.`id` ORDER BY `a`.`id` DESC) ids")
  59. ->group('a.order_type,a.order_id')
  60. // ->order(['a.id'=>'desc'])
  61. // ->fetchSql()
  62. // ->withAttr('ids', function ($val) {
  63. // $temp = explode(',', $val);
  64. // return $temp[0];
  65. // })
  66. // ->page($page, $param['size'])
  67. ->count('a.id');
  68. $total = ceil($count / $param['size']);
  69. $page = $param['page'] > $total ? $total : $param['page'];
  70. //筛选符合条件的order_type,排除重复数据
  71. $order_types = $db
  72. ->field("ANY_VALUE(`a`.`id`) id,`a`.order_type,`a`.order_id,GROUP_CONCAT(`a`.`id` ORDER BY `a`.`id` DESC) ids")
  73. ->group('a.order_type,a.order_id')
  74. ->order(['id' => 'desc'])
  75. ->withAttr('ids', function ($val) {
  76. $temp = explode(',', $val);
  77. return $temp[0];
  78. })
  79. ->page($page, $param['size'])
  80. ->select()
  81. ->toArray();
  82. $list = ProcessWait::alias("a")
  83. ->field("b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.order_type,a.order_code,a.order_id,a.id,a.order_process_finally order_process")
  84. ->whereIn('a.id', array_column($order_types, 'ids'))
  85. ->leftJoin("workflow b", "a.order_type=b.order_type and a.order_code=b.order_code")
  86. // ->page($page, $param['size'])
  87. ->order("a.addtime desc")
  88. ->select()
  89. ->toArray();
  90. //所有流程名称
  91. $all_process = Db::name("process")
  92. ->whereIn('process_type', array_column($list, 'order_type'))
  93. ->column("process_name", 'process_type');
  94. $data = [];
  95. foreach ($list as $value) {
  96. $var = Db::name("action_process")
  97. ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
  98. // ->whereIn('order_process', [$value['order_process'], $value['order_process_finally']])
  99. ->field("status_name,order_process,order_name,roleid")
  100. // ->column('status_name,order_process,order_name,roleid', 'order_process');
  101. ->findOrEmpty();
  102. $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
  103. $value['order_name'] = $var['order_name'];
  104. $value['status_name'] = $var['status_name'];
  105. // $value['order_process_finally_status_name'] = $var[$value['order_process_finally']]['status_name'] ?? '';
  106. $data[] = $value;
  107. }
  108. return app_show(0, "获取成功", ['count' => $count, 'list' => $data]);
  109. }
  110. }
  111. //待处理列表
  112. public function waitlist()
  113. {
  114. $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');
  115. $db = ProcessWait::alias("a")
  116. ->leftJoin('workflow b', 'a.order_type=b.order_type and a.order_code=b.order_code')
  117. // ->leftJoin('process p', 'p.process_type=a.order_type AND p.is_del=0 AND p.status=1')
  118. ->where(['a.status' => ProcessWait::$status_wait]);
  119. // $db->where(function ($query) use ($param) {
  120. //所属角色
  121. $role = $this->checkRole();
  122. if ($role['roleid'] != 1) $db->whereFindInSet('handle_user_list', $this->uid);
  123. // if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
  124. // $query->whereFindInSet('roleid', $role['roleid']);
  125. //本人id
  126. // $query->whereOr('wait_id', $this->uid);
  127. // });
  128. if ($param['order_code'] != '') $db->whereLike('a.order_code', '%' . $param['order_code'] . '%');
  129. if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);
  130. $count = $db->count();
  131. $total = ceil($count / $param['size']);
  132. $page = $param['page'] > $total ? $total : $param['page'];
  133. $list = $db
  134. ->field("a.id,a.addtime,a.action_name,a.order_status,a.order_type,a.order_process,a.order_code,a.order_id,a.handle_user_list")
  135. ->page($page, $param['size'])
  136. ->order("a.addtime desc")
  137. // ->append(['handle_user_list'])
  138. // ->withAttr('handle_user_list', function ($val, $da) {
  139. // return [];
  140. // })
  141. ->select()
  142. ->toArray();
  143. //所有流程名称
  144. $all_process = Db::name("process")
  145. ->whereIn('process_type', array_column($list, 'order_type'))
  146. ->column("process_name", 'process_type');
  147. $data = [];
  148. foreach ($list as $value) {
  149. $var = Db::name("action_process")
  150. ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
  151. ->field("status_name,order_process,order_name,roleid")
  152. ->find();
  153. $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
  154. $value['order_name'] = $var['order_name'];
  155. $value['status_name'] = $var['status_name'];
  156. //找到流程对应记录的所有人(创建人 or 申请人 or 采购员)
  157. // $holder_id = 0;
  158. // switch ($value['order_type']) {
  159. // //1.采购单流程
  160. // case 'CGD':
  161. // $holder_id = Db::name('purchease_order')->where(['id' => $value['order_id'], 'is_del' => 0])->value('cgder_id', 0);
  162. // break;
  163. // //2.采购单入库流程
  164. // case 'RKD':
  165. // $holder_id = Db::name('purchease_in')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  166. // break;
  167. // //3.备货申请单流程
  168. // case 'BHD':
  169. // $holder_id = Db::name('purchease')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  170. // break;
  171. // //4.销售订单流程
  172. // case 'XSQRD':
  173. // $holder_id = Db::name('sale')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  174. // break;
  175. // //5.发货申请单流程
  176. // case 'CKD':
  177. // $holder_id = Db::name('order_out')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  178. // break;
  179. // //6.售后申请单流程
  180. // case 'SHD':
  181. // $holder_id = Db::name('order_return')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  182. // break;
  183. // //7.售后退货单流程
  184. // case 'CKTHD':
  185. // $holder_id = Db::name('order_back')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  186. // break;
  187. // //8.销售退货单流程
  188. // case 'XSTHD':
  189. // $holder_id = Db::name('sale_return')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  190. // break;
  191. // //9.采购工差单流程
  192. // case 'CGGCD':
  193. // $holder_id = Db::name('purchease_diff')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  194. // break;
  195. // //10.销售工差单流程
  196. // case 'XSGCD':
  197. // $holder_id = Db::name('sale_diff')
  198. // ->alias('a')
  199. // ->where(['a.id' => $value['order_id']])
  200. // ->leftJoin('sale s', 's.orderCode=a.orderCode')
  201. // ->value('s.apply_id', 0);
  202. // break;
  203. // //11.调拨单流程
  204. // case 'DBD':
  205. // $holder_id = Db::name('allot_stock')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  206. // break;
  207. // //12.盘点单流程
  208. // case 'PDD':
  209. // $holder_id = Db::name('good_check')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  210. // break;
  211. // //13.议价单流程
  212. // case 'YJD':
  213. // $holder_id = Db::name('bargain_order')->where(['id' => $value['order_id'], 'is_del' => 0])->value('createrid', 0);
  214. // break;
  215. // //14.项目单流程
  216. // case 'PRO':
  217. // $holder_id = Db::name('project')->where(['id' => $value['order_id'], 'is_del' => 0])->value('createrid', 0);
  218. // break;
  219. // //15.商品成本流程
  220. // case 'SPCB':
  221. // $holder_id = Db::name('good_basic')->where(['id' => $value['order_id'], 'is_del' => 0])->value('chargerid', 0);
  222. // break;
  223. // //16.商品上线流程
  224. // case 'SPSX':
  225. // $holder_id = Db::name('good_platform')
  226. // ->alias('a')
  227. // ->where(['a.id' => $value['order_id']])
  228. // ->leftJoin('good g', 'g.spuCode=a.spuCode')
  229. // ->value('g.createrid', 0);
  230. // break;
  231. // //17.活动流程
  232. // case 'HD':
  233. // $holder_id = Db::name('good_activity')->where(['id' => $value['order_id'], 'is_del' => 0])->value('createrid', 0);
  234. // break;
  235. // //19.有赞商品上架流程
  236. // case 'YZSX':
  237. // $holder_id = Db::name('platform_youzan')
  238. // ->alias('a')
  239. // ->where(['a.id' => $value['order_id']])
  240. // ->leftJoin('good g', 'g.spuCode=a.spuCode')
  241. // ->value('g.createrid', 0);
  242. // break;
  243. // //20.有赞订单审核流程
  244. //// case 'YZQRD':
  245. //// $holder_id = Db::name('')->where(['id' => $value['order_id'], 'is_del' => 0])->value('', 0);
  246. //// break;
  247. // //22.离职交接流程
  248. // case 'LZJJ':
  249. // $holder_id = Db::name('resign_info')->where(['id' => $value['order_id'], 'is_del' => 0])->value('hand_uid', 0);
  250. // break;
  251. // //23.采购单退货流程
  252. // case 'CGTHD':
  253. // $holder_id = Db::name('purchease_return')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
  254. // break;
  255. // //24.竞价单流程
  256. // case 'ZXD':
  257. // $holder_id = Db::name('consult_order')->where(['id' => $value['order_id'], 'is_del' => 0])->value('createrid', 0);
  258. // break;
  259. // //25.商品下线流程
  260. // case 'GOL':
  261. // $holder_id = Db::name('good_offline_log')->where(['id' => $value['order_id'], 'is_del' => 0])->value('createrid', 0);
  262. // break;
  263. // }
  264. //根据记录的所有人判断哪些人能看到它的记录
  265. // $uids_1 = $this->get_uids_by_group_share($holder_id, $value['api_url']);
  266. //根据角色筛选
  267. $uid = Db::name('user_role')
  268. ->field('uid')
  269. ->where([
  270. ['is_del', '=', 0],
  271. ['uid', 'in', $value['handle_user_list']],
  272. // ['roleid', '<>', 1],//超级管理员不在这个范围内
  273. ['status', '=', 1],
  274. ])
  275. ->buildSql();
  276. $value['handle_user_list'] = Db::name('depart_user')
  277. ->where(['is_del' => 0, 'status' => 1])
  278. ->where('uid IN ' . $uid)
  279. ->column('nickname');
  280. // $value['uid_1'] = $uids_1;
  281. // $value['uid_2'] = $uids_2;
  282. // $uids = array_intersect($uids_1, $uids_2);
  283. // $users = Db::name('depart_user')->where(['is_del' => 0, 'status' => 1])->whereIn('uid', $uids)->column('nickname');
  284. //当前操作人
  285. // $value['handle_user_list'] = $value['wait_name'] ? array_merge($users, [$value['wait_name']]) : $users;
  286. $data[] = $value;
  287. }
  288. return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
  289. }
  290. public function all()
  291. {
  292. $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  293. if ($token == "") {
  294. return error_show(101, 'token不能为空');
  295. }
  296. $effetc = VerifyTokens($token);
  297. if (!empty($effetc) && $effetc['code'] != 0) {
  298. return error_show($effetc['code'], $effetc['message']);
  299. }
  300. $where = [["is_del", "=", 0]];
  301. $process_name = isset($this->post['process_name']) && $this->post['process_name'] !== "" ? trim($this->post['process_name']) : "";
  302. if ($process_name != "") {
  303. $where[] = ["process_name", "like", "%$process_name%"];
  304. }
  305. $process_type = isset($this->post['process_type']) && $this->post['process_type'] !== "" ? trim($this->post['process_type']) : "";
  306. if ($process_type != "") {
  307. $where[] = ["process_type", "like", "%$process_type%"];
  308. }
  309. $list = Db::name('process')->where($where)->order("addtime desc")->select();
  310. return app_show(0, "获取成功", $list);
  311. }
  312. }