OaService.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicRollFilm;
  4. use App\Model\Construction;
  5. use App\Model\Depart;
  6. use App\Model\Employee;
  7. use App\Model\EmployeeDepartPermission;
  8. use App\Model\EmployeeTeamPermission;
  9. use App\Model\Oa;
  10. use App\Model\OaOrder;
  11. use App\Model\OaOrderSub;
  12. use App\Model\OaOrderSubEmployee;
  13. use App\Model\OaReportOrder;
  14. use App\Model\OaReportOrderEmployee;
  15. use App\Model\OaSub;
  16. use App\Model\OaSubEmployee;
  17. use App\Model\OaSubReportEmployee;
  18. use App\Model\OaSubRule;
  19. use App\Model\RollFilm;
  20. use App\Model\RollFilmCombine;
  21. use App\Model\RollFilmCompany;
  22. use App\Model\SysMenu;
  23. use App\Model\Team;
  24. use App\Service\Weixin\WxSendMessageService;
  25. use App\Service\Wx\WxService;
  26. use Illuminate\Support\Facades\App;
  27. use Illuminate\Support\Facades\DB;
  28. use Illuminate\Support\Facades\Log;
  29. use Illuminate\Http\Request;
  30. use Illuminate\Support\Facades\Route;
  31. /**
  32. * bom相关
  33. * @package App\Models
  34. */
  35. class OaService extends Service
  36. {
  37. public $user;
  38. public function __construct($user = '')
  39. {
  40. parent::__construct();
  41. $this->user = $user;
  42. }
  43. public function oaList($data,$user)
  44. {
  45. $list = Oa::from('oa as o')
  46. ->leftjoin('sys_menu as s', 's.id', 'o.menu_id')
  47. ->select('o.id', 'o.menu_id', 'o.crt_time', 's.title','o.channel')
  48. ->where('o.del_time', 0);
  49. if(! empty($data['top_depart_id'])) {
  50. $list->where('o.channel', $data['top_depart_id']);
  51. }else{
  52. if(! $user['is_all_depart']){
  53. $top_depart_id = $user['depart_top'][0]['depart_id'] ?? 0;
  54. $list->where('o.channel', $top_depart_id);
  55. }
  56. }
  57. $list = $this->limit($list, '', $data);
  58. $list = $this->fillData($list);
  59. return [true, $list];
  60. }
  61. public function fillData($data) {
  62. if (empty($data['data'])) return $data;
  63. $depart = Depart::whereIn('id',array_column($data['data'],'channel'))
  64. ->pluck('title','id')
  65. ->toArray();
  66. foreach ($data['data'] as $key => $value){
  67. $data['data'][$key]['top_depart_title'] = $depart[$value['channel']] ?? '';
  68. }
  69. return $data;
  70. }
  71. public function oaDetail($data)
  72. {
  73. $id = $data['id'];
  74. $oa = Oa::where('id', $id)->first();
  75. $list = OaSub::where('oa_id', $id)->where('del_time', 0)->get()->toArray();
  76. $oa_sub_ids = [];
  77. foreach ($list as $v) {
  78. $oa_sub_ids[] = $v['id'];
  79. }
  80. $oaRule = OaSubRule::wherein('oa_sub_id', $oa_sub_ids)->get()->toArray();
  81. $oaEmployee = OaSubEmployee::wherein('oa_sub_id', $oa_sub_ids)->get()->toArray();
  82. $oaReportEmployee = OaSubReportEmployee::wherein('oa_sub_id', $oa_sub_ids)->get()->toArray();
  83. $oaRuleKey = [];
  84. $oaEmployeeKey = [];
  85. $oaReportEmployeeKey = [];
  86. foreach ($oaRule as $v) {
  87. $oaRuleKey[$v['oa_sub_id']][] = [
  88. 'value' => $v['value'],
  89. 'key' => $v['key'],
  90. 'opera' => $v['formula'] == '==' ? '==' : $v['formula'],
  91. ];
  92. }
  93. $employee_key_list = Employee::pluck('emp_name', 'id')->toArray();
  94. foreach ($oaEmployee as $v) {
  95. $oaEmployeeKey[$v['oa_sub_id']][] = [
  96. 'id' => $v['employee_id'],
  97. 'emp_name' => $employee_key_list[$v['employee_id']],
  98. ];
  99. }
  100. foreach ($oaReportEmployee as $v) {
  101. $oaReportEmployeeKey[$v['oa_sub_id']][] = [
  102. 'id' => $v['employee_id'],
  103. 'emp_name' => $employee_key_list[$v['employee_id']],
  104. ];
  105. }
  106. $return = [];
  107. foreach ($list as $v) {
  108. $return[$v['sort']][] = [
  109. 'emp_id' => $oaEmployeeKey[$v['id']],
  110. 'copy_id' => $oaReportEmployeeKey[$v['id']] ?? [],
  111. 'is_copy' => isset($oaReportEmployeeKey[$v['id']]) && !empty($oaReportEmployeeKey[$v['id']]),
  112. 'index' => $v['h5_key'],
  113. 'set' => isset($oaRuleKey[$v['id']]) ? $oaRuleKey[$v['id']] : [],
  114. ];
  115. }
  116. $detail = [];
  117. foreach ($return as $k => $v) {
  118. $children = [];
  119. foreach ($v as $vv) {
  120. $children[] = [
  121. 'set' => $vv['set'],
  122. 'emp_id' => $vv['emp_id'],
  123. 'copy_id' => $vv['copy_id'],
  124. 'is_copy' => $vv['is_copy'],
  125. 'index' => $vv['index'],
  126. ];
  127. }
  128. $detail[] = ['children' => $children];
  129. }
  130. return [true, ['data' => $detail, 'menu_id' => $oa->menu_id, 'title' => $oa->title]];
  131. }
  132. public function oaUserDetail($data)
  133. {
  134. $detail = [
  135. 'detail' => [
  136. [
  137. 'key' => 'area',
  138. 'value' => '南区',
  139. 'formula' => 'dengyu',
  140. ], [
  141. 'key' => 'num',
  142. 'value' => '40',
  143. 'formula' => 'dayu',
  144. ], [
  145. 'key' => 'brand',
  146. 'value' => 'A,B,C',
  147. 'formula' => 'baohan',
  148. ],
  149. ],
  150. 'click' => [
  151. 'area',
  152. 'num',
  153. 'brand',
  154. ],
  155. 'string' => '(area 并且 num) 或者 num'
  156. ];
  157. return [true, $detail];
  158. }
  159. public function oaParam($data)
  160. {
  161. $detail = [
  162. [
  163. 'key' => 'area',
  164. 'value' => '地区',
  165. ], [
  166. 'key' => 'num',
  167. 'value' => '数量',
  168. ], [
  169. 'key' => 'brand',
  170. 'value' => '品牌',
  171. ],
  172. ];
  173. return [true, $detail];
  174. }
  175. public function oaFormula($data)
  176. {
  177. $detail = [
  178. [
  179. 'key' => 'dengyu',
  180. 'value' => '等于',
  181. ], [
  182. 'key' => 'dayu',
  183. 'value' => '大于',
  184. ], [
  185. 'key' => 'baohan',
  186. 'value' => '包含',
  187. ],
  188. ];
  189. return [true, $detail];
  190. }
  191. public function oaAdd($data)
  192. {
  193. $oa = new Oa();
  194. try {
  195. DB::beginTransaction();
  196. $oa->menu_id = $data['menu_id'];
  197. $oa->type = $data['type'];
  198. $oa->title = $data['title'] ?? '';
  199. $oa->channel = $this->user['depart_top'][0]['depart_id'];
  200. $oa->save();
  201. $id = $oa->id;
  202. $insert = [];
  203. foreach ($data['detail'] as $v) {
  204. foreach ($v['employee_list'] as $vv) {
  205. $insert[] = [
  206. 'oa_id' => $id,
  207. 'remark' => $v['remark'],
  208. 'employee_id' => $vv['employee_id'],
  209. 'sort' => $v['sort'],
  210. 'type' => $v['type'],
  211. 'crt_time' => time(),
  212. 'upd_time' => time(),
  213. 'area_id' => $vv['area_id'],
  214. ];
  215. }
  216. }
  217. OaSub::insert($insert);
  218. DB::commit();
  219. } catch (\Exception $e) {
  220. DB::rollBack();
  221. return [false, $e->getLine() . ':' . $e->getMessage()];
  222. }
  223. return [true, '保存成功!'];
  224. }
  225. public function oaEdit($data, $user)
  226. {
  227. $first = Oa::where('del_time', 0)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('menu_id', $data['menu_id']);
  228. if (isset($data['id'])) $first = $first->where('id', '<>', $data['id']);
  229. if (isset($data['type'])) $first = $first->where('type', $data['type']);
  230. $first = $first->first();
  231. if ($first) return [false, '该菜单oa已存在!'];
  232. try {
  233. DB::beginTransaction();
  234. if (isset($data['id'])) $oa = Oa::where('id', $data['id'])->first();
  235. else $oa = new Oa();
  236. $oa->menu_id = $data['menu_id'];
  237. $oa->crt_employee_id = $user['id'];
  238. $oa->type = $data['type'] ?? 0;
  239. $oa->title = $data['title'] ?? '';
  240. $oa->channel = $this->user['depart_top'][0]['depart_id'];
  241. $oa->save();
  242. $id = $oa->id;
  243. $insert = [];
  244. $oa_sub_id = OaSub::where('oa_id', $id)->where('del_time',0)->pluck('id')->toArray();
  245. OaSub::where('oa_id', $id)->update([
  246. 'del_time' => time()
  247. ]);
  248. //处理前端数据
  249. $this->dealOaData($data, $id, $oa_sub_id);
  250. DB::commit();
  251. } catch (\Exception $e) {
  252. DB::rollBack();
  253. return [false, $e->getLine() . $e->getMessage()];
  254. }
  255. return [true, '更新成功'];
  256. }
  257. public function dealOaData($data, $id, $oa_sub_id)
  258. {
  259. $data = $data['approval'];
  260. $detail = [];
  261. $sort = 0;
  262. foreach ($data as $v) {
  263. $sort++;
  264. foreach ($v['children'] as $vv) {
  265. $detail[] = [
  266. 'h5_key' => $vv['index'],
  267. 'emp_id' => $vv['emp_id'],
  268. 'copy_id' => $vv['copy_id'] ?? [],
  269. 'set' => $vv['set'],
  270. 'sort' => $sort,
  271. ];
  272. }
  273. }
  274. $oa_subs = [];
  275. foreach ($detail as $v) {
  276. $oa_subs[] = [
  277. 'crt_time' => time(),
  278. 'upd_time' => time(),
  279. 'sort' => $v['sort'],
  280. 'sub_id' => -1,
  281. 'remark' => '',
  282. 'oa_id' => $id,
  283. 'type' => 1,
  284. 'parent_id' => 0,
  285. 'h5_key' => $v['h5_key'],
  286. ];
  287. }
  288. OaSub::insert($oa_subs);
  289. $oa_sub = OaSub::where('oa_id', $id)->get()->toArray();
  290. $list_key = [];
  291. foreach ($oa_sub as $v) {
  292. $list_key[$v['h5_key']] = $v;
  293. }
  294. foreach ($list_key as $k => $v) {
  295. if ($v['sort'] == 1) continue;
  296. $len = strlen($k);
  297. foreach ($list_key as $kk => $vv) {
  298. if (strlen($kk) == ($len - 2) && substr($k, 0, $len - 2) == $kk) {
  299. $list_key[$k]['parent_id'] = $vv['id'];
  300. }
  301. }
  302. }
  303. $employee_list = [];
  304. $set_list = [];
  305. $report_list = [];
  306. foreach ($detail as $v) {
  307. if (isset($v['copy_id'])) {
  308. foreach ($v['copy_id'] as $vv) {
  309. $report_list[] = [
  310. 'employee_id' => $vv,
  311. 'oa_sub_id' => $list_key[$v['h5_key']]['id'],
  312. ];
  313. }
  314. }
  315. foreach ($v['emp_id'] as $vv) {
  316. $employee_list[] = [
  317. 'employee_id' => $vv,
  318. 'oa_sub_id' => $list_key[$v['h5_key']]['id'],
  319. ];
  320. }
  321. $n = 1;
  322. foreach ($v['set'] as $vv) {
  323. if ($vv['opera'] == '=') $v['opera'] = '==';
  324. if ($n > 1) $right_formula = '&&';
  325. else $right_formula = '';
  326. $set_list[] = [
  327. 'oa_sub_id' => $list_key[$v['h5_key']]['id'],
  328. 'key' => $vv['key'],
  329. 'value' => $vv['value'],
  330. 'sort' => $n,
  331. 'formula' => $vv['opera'],
  332. 'right_formula' => $right_formula,
  333. ];
  334. $n++;
  335. }
  336. }
  337. OaSubRule::wherein('oa_sub_id', $oa_sub_id)->delete();
  338. OaSubEmployee::wherein('oa_sub_id', $oa_sub_id)->delete();
  339. OaSubRule::insert($set_list);
  340. OaSubEmployee::insert($employee_list);
  341. if (!empty($report_list)) OaSubReportEmployee::insert($report_list);
  342. foreach ($list_key as $v) {
  343. if ($v['parent_id'] > 0) OaSub::where('id', $v['id'])->update([
  344. 'parent_id' => $v['parent_id']
  345. ]);
  346. }
  347. }
  348. public function oaDel($data)
  349. {
  350. $id = $data['id'];
  351. Oa::where('id', $id)->update([
  352. 'del_time' => time(),
  353. ]);
  354. OaSub::where('oa_id', $id)->update([
  355. 'del_time' => time(),
  356. ]);
  357. return [true, '删除成功'];
  358. }
  359. public function oaSubType($data)
  360. {
  361. $service = new CheckService();
  362. $list = $service->map;
  363. $return = [];
  364. foreach ($list as $k => $v) {
  365. $return[] = [
  366. 'id' => $k,
  367. 'title' => $v,
  368. ];
  369. }
  370. return [true, $return];
  371. }
  372. public function createOaOrder($data)
  373. {
  374. // $crt_id = request()->userData->id;
  375. Log::channel('request')->info('request', ['param' => $data]);
  376. if (!isset($data['order_number'])) $data['order_number'] = $data['order_no'];
  377. $orderObject = $data['order_number'];
  378. $menu_id = $data['menu_id'];
  379. $order_no = $data['order_number'];
  380. $type = isset($data['opt_case']) ? $data['opt_case'] : 0;
  381. // $this->returnOa($order_no,1,$type);
  382. // return [200,''];
  383. //特殊的审批
  384. $list = Oa::from('oa as o')
  385. ->leftJoin('oa_sub as os', 'os.oa_id', 'o.id')
  386. ->select('os.sort', 'os.type', 'os.sub_id')
  387. ->where('o.del_time', 0)
  388. ->where('o.sub_type', 2)
  389. ->where('os.del_time', 0)
  390. ->where('o.menu_id', $menu_id);
  391. if (!empty($type)) $list = $list->where('os.sort', 1);
  392. $list = $list->orderBy('os.sort')->get()->toArray();
  393. if(empty($list)){
  394. $list = Oa::from('oa as o')
  395. ->leftJoin('oa_sub as os', 'os.oa_id', 'o.id')
  396. ->select('os.sort', 'os.type', 'os.sub_id')
  397. ->where('o.del_time', 0)
  398. ->where('os.del_time', 0)
  399. ->where('o.channel', $this->user['depart_top'][0]['depart_id'])
  400. ->where('o.menu_id', $menu_id);
  401. if (!empty($type)) $list = $list->where('os.sort', 1);
  402. $list = $list->orderBy('os.sort')->get()->toArray();
  403. }
  404. if (empty($list)) {
  405. $this->returnOa($order_no, 1, $type);
  406. return [200, ''];
  407. }
  408. try {
  409. DB::beginTransaction();
  410. list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($menu_id, ['order_number' => $orderObject], 1,0,$this->user);
  411. if (empty($employee_ids)) {
  412. $this->returnOa($order_no, 1, $type);
  413. DB::commit();
  414. return [true, '审核成功'];
  415. }
  416. $order = new OaOrder();
  417. $order->menu_id = $menu_id;
  418. $order->order_no = $order_no;
  419. $order->opt_case = $type;
  420. $order->channel = $this->user['depart_top'][0]['depart_id'];
  421. $order->save();
  422. $id = $order->id;
  423. $oa_order_sub = new OaOrderSub();
  424. $oa_order_sub->oa_order_id = $id;
  425. $oa_order_sub->sort = 1;
  426. $oa_order_sub->remark = '';
  427. $oa_order_sub->type = 1;
  428. $oa_order_sub->oa_sub_id = $oa_sub_id;
  429. $oa_order_sub->save();
  430. $oa_order_sub_id = $oa_order_sub->id;
  431. $insert = [];
  432. //处理数据发送通知消息
  433. foreach ($employee_ids as $employee_id) {
  434. $insert[] = [
  435. 'oa_order_id' => $id,
  436. 'oa_order_sub_id' => $oa_order_sub_id,
  437. 'employee_id' => $employee_id,
  438. ];
  439. $tmp_data = [
  440. $orderObject,
  441. $order_detail['crt_name'].'('.SysMenu::where('id',$menu_id)->value('title').')',
  442. Employee::where('id',$employee_id)->value('emp_name'),
  443. date('Y-m-d H:i:s'),
  444. ];
  445. $this->sendWxMsg($employee_id,1,0,$menu_id,$tmp_data);
  446. }
  447. OaOrderSubEmployee::insert($insert);
  448. DB::commit();
  449. return [true, '']; //success
  450. } catch (\Exception $e) {
  451. DB::rollBack();
  452. $this->returnOa($order_no, 2, $type);
  453. return [false, $e->getLine() . ':' . $e->getMessage()];
  454. }
  455. }
  456. public function oaCommon($menu_id, $param, $sort = 1, $parent_id = 0,$user='')
  457. {
  458. $request = request();
  459. foreach ($param as $k => $v) {
  460. $request->$k = $v;
  461. }
  462. $all = $request->all();
  463. if (!isset($all['order_number'])) $request->merge($param);
  464. // $request->merge($param);
  465. $detail = $this->oaGetData($menu_id, $request,$user);
  466. //特殊的审批
  467. $oa_id = Oa::where('menu_id',$menu_id)->where('del_time', 0)->where('sub_type',2)->value('id');
  468. if(empty($oa_id)) $oa_id = Oa::where('menu_id', $menu_id)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('del_time', 0)->value('id');
  469. $parent_ids = [$parent_id, 0];
  470. // var_dump($parent_ids);
  471. if ($sort > 2) {
  472. $sorts = $sort - 1;
  473. $oa_sub_ids = OaSub::where('sort', '<', $sorts)->where('del_time', 0)->wherein('parent_id', $parent_ids)->pluck('id')->toArray();
  474. // var_dump($oa_sub_ids);die;
  475. $parent_ids = array_merge($parent_ids, $oa_sub_ids);
  476. }
  477. $list = OaSub::where('oa_id', $oa_id)->where('del_time', 0)->where('sort', $sort)->wherein('parent_id', $parent_ids);
  478. $list = $list->select('*')->get()->toArray();
  479. if (empty($list)) return [[], '',$detail];
  480. $oa_sub_ids = [];
  481. $oa_sub_key = [];
  482. foreach ($list as $v) {
  483. $oa_sub_ids[] = $v['id'];
  484. $oa_sub_key[$v['id']] = $v;
  485. $rule_key_list[$v['id']] = [];
  486. }
  487. $rule_list = OaSubRule::wherein('oa_sub_id', $oa_sub_ids)->select('*')->get()->toArray();
  488. foreach ($rule_list as $v) {
  489. $rule_key_list[$v['oa_sub_id']][] = $v;
  490. }
  491. //规则开始判断
  492. $employee_ids = [];
  493. $oa_sub_id = 0;
  494. foreach ($rule_key_list as $k => $v) {
  495. $status = $this->formulaRule($v, $detail);
  496. if ($status) {
  497. if ($oa_sub_key[$k]['type'] == 2 && $oa_sub_key[$k]['sub_id'] > 0) {
  498. $employee_ids = EmployeeTeamPermission::where('team_id', $oa_sub_key[$k]['sub_id'])->pluck('employee_id')->toArray();
  499. } elseif ($oa_sub_key[$k]['sub_id'] == -1) {
  500. $employee_ids = OaSubEmployee::where('oa_sub_id', $oa_sub_key[$k]['id'])->pluck('employee_id')->toArray();
  501. } else {
  502. $employee_ids[] = [$oa_sub_key[$k]['sub_id']];
  503. }
  504. $oa_sub_id = $k;
  505. continue;
  506. }
  507. }
  508. return [$employee_ids, $oa_sub_id,$detail];
  509. }
  510. public function formulaRule($params, $detail)
  511. {
  512. $rule = '';
  513. // dd($params);
  514. if (empty($params)) return true;
  515. foreach ($params as $param) {
  516. if (!$param['key']) continue;
  517. if (!empty($param['right_formula'])) $rule .= ' ' . $param['right_formula'] . ' ';
  518. $rule .= '"' . $detail[$param['key']] . '"' . ' ' . $param['formula'] . ' ' . '"' . $param['value'] . '"';
  519. }
  520. // dd($rule);
  521. if (empty($rule)) return true;
  522. // var_dump($rule);
  523. if (eval("return $rule;")) {
  524. // var_dump($rule);die;
  525. return true;
  526. } else return false;
  527. }
  528. public function oaCheck($data, $user)
  529. {
  530. $user_id = $user['id'];
  531. // $user_id = '482';
  532. $id = $data['id'];
  533. $state = $data['state'];
  534. if ($state == 0) $state = 2;
  535. $remark = $data['remark'];
  536. $detail = OaOrderSub::from('oa_order_sub as s')
  537. ->leftJoin('oa_order_sub_employee as e', 'e.oa_order_sub_id', 's.id')
  538. ->where('e.employee_id', $user_id)->where('s.state', 0)
  539. ->where('s.id', $id)
  540. ->select('s.oa_order_id', 'sort', 'oa_sub_id', 's.id')->first();
  541. if (empty($detail)) return [false, '没有审核权限'];
  542. $detail = $detail->toArray();
  543. $oaOrder = OaOrder::where('id', $detail['oa_order_id'])->first();
  544. try {
  545. DB::beginTransaction();
  546. switch ($state) {
  547. case 1:
  548. $sort = $detail['sort'] + 1;
  549. list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($oaOrder->menu_id, ['order_number' => $oaOrder->order_no], $sort, $detail['oa_sub_id'],$user);
  550. // var_dump($employee_ids);
  551. // var_dump($oa_sub_id);die;
  552. if (empty($employee_ids)) {
  553. $oaOrder->state = 2;
  554. $oaOrder->save();
  555. //审核通过
  556. $tmp_data = [
  557. $order_detail['order_number'],
  558. SysMenu::where('id',$oaOrder->menu_id)->value('title'),
  559. '通过',
  560. Employee::where('id',$user_id)->value('emp_name'),
  561. date('Y-m-d H:i:s'),
  562. ];
  563. $this->sendWxMsg($order_detail['crt_id'],2,0,$oaOrder->menu_id,$tmp_data);
  564. $this->returnOa($oaOrder->order_no, 1, $oaOrder->opt_case);
  565. } else {
  566. $oaOrder->state = 1;
  567. $oaOrder->save();
  568. $oa_order_sub = new OaOrderSub();
  569. $oa_order_sub->oa_order_id = $oaOrder->id;
  570. $oa_order_sub->sort = $sort;
  571. $oa_order_sub->remark = '';
  572. $oa_order_sub->type = 1;
  573. $oa_order_sub->oa_sub_id = $oa_sub_id;
  574. $oa_order_sub->save();
  575. $oa_order_sub_id = $oa_order_sub->id;
  576. $insert = [];
  577. foreach ($employee_ids as $employee_id) {
  578. $insert[] = [
  579. 'oa_order_id' => $oaOrder->id,
  580. 'oa_order_sub_id' => $oa_order_sub_id,
  581. 'employee_id' => $employee_id,
  582. ];
  583. $tmp_data = [
  584. $order_detail['order_number'],
  585. $order_detail['crt_name'].'('.SysMenu::where('id',$oaOrder->menu_id)->value('title').')',
  586. Employee::where('id',$employee_id)->value('emp_name'),
  587. date('Y-m-d H:i:s'),
  588. ];
  589. $this->sendWxMsg($employee_id,1,0,$oaOrder->menu_id,$tmp_data);
  590. }
  591. OaOrderSubEmployee::insert($insert);
  592. }
  593. break;
  594. case 2:
  595. list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($oaOrder->menu_id, ['order_number' => $oaOrder->order_no], 1, $detail['oa_sub_id'],$user);
  596. $tmp_data = [
  597. $oaOrder['order_no'],
  598. '拒绝',
  599. $order_detail['crt_time'],
  600. $remark,
  601. ];
  602. if ($detail['sort'] == 1||true) {
  603. $oaOrder->state = 3;
  604. $oaOrder->save();
  605. $this->sendWxMsg($order_detail['crt_id'],3,2,$oaOrder->menu_id,$tmp_data);
  606. $this->returnOa($oaOrder->order_no, 2, $oaOrder->opt_case);
  607. }else{
  608. $id = OaOrderSub::where('sort', ($detail['sort'] - 1))->where('oa_order_id', $oaOrder->id)->value('id');
  609. $employee_ids = OaOrderSubEmployee::where('oa_order_sub_id',$id)->pluck('employee_id')->toArray();
  610. foreach ($employee_ids as $v){
  611. $this->sendWxMsg($v,3,2,$oaOrder->menu_id,$tmp_data);
  612. }
  613. }
  614. OaOrderSub::where('sort', ($detail['sort'] - 1))->where('oa_order_id', $oaOrder->id)->update([
  615. 'state' => 0,
  616. 'remark' => $remark,
  617. ]);
  618. break;
  619. }
  620. OaOrderSub::where('id', $id)->update([
  621. 'state' => $state,
  622. 'remark' => $remark,
  623. ]);
  624. $this->report($oaOrder, $detail['oa_sub_id'],$user_id);
  625. DB::commit();
  626. return [true, '操作成功!'];
  627. } catch (\Exception $e) {
  628. DB::rollBack();
  629. return [false, $e->getLine() . ':' . $e->getMessage()];
  630. }
  631. }
  632. public function report($oaOrder, $oa_sub_id,$user_id)
  633. {
  634. $oa_sub_report_employee = OaSubReportEmployee::where('oa_sub_id', $oa_sub_id)->select('*')->get()->toArray();
  635. if (!empty($oa_sub_report_employee)) {
  636. $list = [];
  637. $report = new OaReportOrder();
  638. $report->menu_id = $oaOrder->menu_id;
  639. $report->order_no = $oaOrder->order_no;
  640. $report->opt_case = $oaOrder->opt_case;
  641. $report->user_id = $user_id;
  642. $report->channel = $this->user['depart_top'][0]['depart_id'];
  643. $report->save();
  644. $tmp_data = [
  645. $oaOrder->order_no,
  646. SysMenu::where('id',$oaOrder->menu_id)->value('title'),
  647. '审核通过',
  648. Employee::where('id',$user_id)->value('emp_name'),
  649. date('Y-m-d H:i:s'),
  650. ];
  651. foreach ($oa_sub_report_employee as $v) {
  652. $list[] = [
  653. 'employee_id' => $v['employee_id'],
  654. 'oa_report_order_id' => $report->id,
  655. ];
  656. $this->sendWxMsg($v['employee_id'],2,0,$oaOrder->menu_id,$tmp_data);
  657. }
  658. OaReportOrderEmployee::insert($list);
  659. }
  660. }
  661. public function returnOa($order_no, $type, $opt_case)
  662. {
  663. $service = new CheckService();
  664. list($bool, $msg) = $service->createRecordAndInventory([
  665. 'order_number' => $order_no,
  666. 'type' => $type,
  667. 'opt_case' => $opt_case,
  668. 'user_data' => $this->user,
  669. ]);
  670. return [$bool, $msg];
  671. }
  672. public function oaGetData($menu_id, $request,$user='')
  673. {
  674. $api = SysMenu::where('id', $menu_id)->value('api');
  675. $param = SysMenu::where('id', $menu_id)->value('api_params');
  676. $param = json_decode($param,true);
  677. $param['state'] = null;
  678. $param['menu_id'] = $menu_id;
  679. $param['id'] = null;
  680. $request->merge($param);
  681. $path = $this->getMenu();
  682. $control = '\\' . $path[$api]["controller"];
  683. $act = $path[$api]["act"];
  684. $new = new $control();
  685. $detail = $new->$act($request);
  686. // if(!isset($detail['data']['data'][0])) $detail['data']['data'][0] = $detail['data'];
  687. return $detail['data']['data'][0];
  688. }
  689. public function getMenu()
  690. {
  691. $app = App();
  692. $routes = $app->routes->getRoutes();
  693. $path = [];
  694. foreach ($routes as $k => $value) {
  695. if (!isset($value->action['controller'])) continue;
  696. $act = explode('@', $value->action['controller']);
  697. if (!isset($act[1])) continue;
  698. $path[$value->uri]['act'] = $act[1];
  699. $path[$value->uri]['controller'] = $act[0];
  700. }
  701. return $path;
  702. }
  703. public function oaOrderList($data)
  704. {
  705. $order_no = $data['order_no'];
  706. $menu_id = $data['menu_id'];
  707. $oa = OaOrder::where('order_no', $order_no)->first();
  708. if (empty($oa)) return [false, '审核不存在'];
  709. $list = OaOrderSub::where('oa_order_id', $oa->id)->orderBy('sort', 'asc')->select('*')->get()->toArray();
  710. return [true, $list];
  711. }
  712. public function oaOrderState($data, $user)
  713. {
  714. $user_id = $user['id'];
  715. $order_no = $data['order_no'];
  716. $menu_id = $data['menu_id'];
  717. //特殊的审批
  718. $oa_id = Oa::where('menu_id',$menu_id)->where('del_time', 0)->where('sub_type',2)->exists();
  719. if($oa_id){
  720. $detail = OaOrder::where('order_no', $order_no)
  721. ->orderBy('id', 'desc')
  722. ->where('menu_id', $menu_id)
  723. ->first();
  724. }else{
  725. $detail = OaOrder::where('order_no', $order_no)
  726. ->where('channel',$this->user['depart_top'][0]['depart_id'])
  727. ->orderBy('id', 'desc')
  728. ->where('menu_id', $menu_id)
  729. ->first();
  730. }
  731. if (empty($detail)) return [true, ['state' => 0]];
  732. if ($detail->state == 2) return [true, ['state' => 0]];
  733. $oa_detail = OaOrderSubEmployee::where('employee_id', $user_id)->where('oa_order_id', $detail->id)->pluck('oa_order_sub_id')->toArray();
  734. if (empty($oa_detail)) return [true, ['state' => 0]];
  735. $state = OaOrderSub::wherein('id', $oa_detail)->where('state', '<>', 2)->orderBy('sort', 'desc')->first();
  736. if (in_array($state->state, [0, 2])) return [true, ['state' => 1, 'id' => $state->id]];
  737. return [true, ['state' => 0]];
  738. }
  739. public function checkAllOver($data)
  740. {
  741. $order_no = $data['order_number'];
  742. $menu_id = $data['menu_id'];
  743. $op_case = $data['opt_case'];
  744. // $oaOrder = OaOrder::where('order_no',$order_no)->first();
  745. // $id = OaOrderSub::where('oa_order_id',$oaOrder->id)->orderBy('id','desc')->value('id');
  746. // OaOrderSub::where('id',$id)->update([
  747. // 'state' => 1
  748. // ]);
  749. // $oaOrder->state = 1;
  750. // $oaOrder->save();
  751. $this->returnOa($order_no, 3, $op_case);
  752. return [true, '弃审成功'];
  753. }
  754. public function oaCheckMove($data, $user_id)
  755. {
  756. $id = $data['id'];
  757. $employee_id = $data['employee_id'];
  758. if (empty($employee_id)) return [false, '用户不存在'];
  759. $oaOrderSub = OaOrderSub::where('id', $id)->first();
  760. OaOrderSubEmployee::where('oa_order_sub_id', $oaOrderSub->id)->delete();
  761. $add = [
  762. 'oa_order_id' => $oaOrderSub->oa_order_id,
  763. 'oa_order_sub_id' => $oaOrderSub->id,
  764. 'employee_id' => $employee_id
  765. ];
  766. $oaOrder = OaOrder::where('id', $oaOrderSub->oa_order_id)->first();
  767. OaOrderSubEmployee::insert($add);
  768. Construction::where('order_number', $oaOrder->order_no)->update([
  769. 'is_transfer' => 1
  770. ]);
  771. // $this->returnOa($order_no,3,$op_case);
  772. return [true, '转签成功'];
  773. }
  774. public function oaSubUserDetail($data)
  775. {
  776. $order_no = $data['order_no'];
  777. $first = OaOrder::where('order_no', $order_no)->first();
  778. if (empty($first)) return [true, []];
  779. $oa_order_id = $first->id;
  780. $oa_order_sub_id = OaOrderSub::where('oa_order_id', $oa_order_id)->orderBy('sort', 'desc')->value('id');
  781. $employee_list = Employee::pluck('emp_name', 'id')->toArray();
  782. $oa_order_sub_employee_ids = OaOrderSubEmployee::where('oa_order_sub_id', $oa_order_sub_id)->pluck('employee_id')->toArray();
  783. $list = [];
  784. foreach ($oa_order_sub_employee_ids as $v) {
  785. $list[] = $employee_list[$v];
  786. }
  787. return [true, $list];
  788. }
  789. public function oaGetTeamDetail($data)
  790. {
  791. $order_no = $data['order_no'];
  792. $oa_order_id = OaOrder::where('order_no', $order_no)->pluck('id')->toArray();
  793. if (empty($oa_order_id)) return [true, []];
  794. // $oa_order_id = $first->id;
  795. $list = OaOrderSub::wherein('oa_order_id', $oa_order_id)->select('*')->orderBy('id', 'asc')->get()->toArray();
  796. $subEmployeeList = OaOrderSubEmployee::wherein('oa_order_id', $oa_order_id)->select('*')->get()->toArray();
  797. $emp_id_key_list = [];
  798. $employee_key_list = Employee::pluck('emp_name', 'id')->toArray();
  799. foreach ($subEmployeeList as $v) {
  800. $emp_id_key_list[$v['oa_order_sub_id']][] = [
  801. 'id' => $v['employee_id'],
  802. 'emp_name' => $employee_key_list[$v['employee_id']] ?? '',
  803. ];
  804. }
  805. $return = [];
  806. foreach ($list as $v) {
  807. $return[] = [
  808. 'sort' => $v['sort'],
  809. 'team' => $emp_id_key_list[$v['id']],
  810. 'remark' => $v['remark'] ?? '',
  811. 'state' => $v['state'],
  812. ];
  813. }
  814. // $this->returnOa($order_no,3,$op_case);
  815. return [true, $return];
  816. }
  817. public function oaSubRemark($data)
  818. {
  819. $order_no = $data['order_no'];
  820. $first = OaOrder::where('del_time', 0)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('order_no', $order_no)->orderBy('id', 'desc')->first();
  821. if (empty($first)) return [true, []];
  822. $oa_order_id = $first->id;
  823. $remark = OaOrderSub::where('oa_order_id', $oa_order_id)->orderBy('sort', 'desc')->value('remark');
  824. // $this->returnOa($order_no,3,$op_case);
  825. return [true, $remark];
  826. }
  827. public function reportList($data, $user)
  828. {
  829. $id = $user['id'];
  830. $list = OaReportOrder::from('oa_report_order_employee as e')
  831. ->leftJoin('oa_report_order as o','o.id','e.oa_report_order_id')
  832. ->leftJoin('oa_order as oo','oo.order_no','o.order_no')
  833. ->leftJoin('employee as ee','ee.id','o.user_id')
  834. ->where('e.employee_id',$id)
  835. ->where('o.channel',$this->user['depart_top'][0]['depart_id'])
  836. ->groupBy('oo.id')->orderBy('oo.id','desc')
  837. ->select('oo.*','o.id as sid','o.check','o.user_id','ee.emp_name');
  838. $list = $this->limit($list,'',$data);
  839. return [true,$list];
  840. }
  841. public function reportCheck($data){
  842. $id = $data['sid'];
  843. OaReportOrder::wherein('id',$id)->where('channel',$this->user['depart_top'][0]['depart_id'])->update([
  844. 'check' => 1
  845. ]);
  846. return [true,''];
  847. }
  848. public function reportCount($data,$user){
  849. $id = $user['id'];
  850. $list = OaReportOrder::from('oa_report_order_employee as e')
  851. ->leftJoin('oa_report_order as o','o.id','e.oa_report_order_id')
  852. ->leftJoin('oa_order as oo','oo.order_no','o.order_no')
  853. ->where('e.employee_id',$id)
  854. ->where('o.check',0)
  855. ->groupBy('oo.id')->orderBy('oo.id','desc')
  856. ->select('oo.*','o.id as sid','o.check')->get()->toArray();
  857. return [true,['total'=>count($list),'list'=>$list]];
  858. }
  859. public function reportTime($data){
  860. return [true,['time'=>'20小时10分钟']];
  861. }
  862. public function sendWxMsg($user_id,$type,$state,$menu_id,$order_data){
  863. $service = new WxSendMessageService();
  864. file_put_contents('msg_result.txt',date('Y-m-d H:i:s') . "入参:" . json_encode([$user_id,$type,$state,$menu_id,$order_data]). PHP_EOL,8);
  865. list($status, $msg) = $service->wx_sendMsg($user_id,$type,$state,$menu_id,$order_data);
  866. file_put_contents('msg_result.txt',date('Y-m-d H:i:s') . "结果:" . $msg . PHP_EOL,8);
  867. }
  868. public function getConstructionOaOrderState($order_no, $user, $menu_id)
  869. {
  870. $user_id = $user['id'];
  871. $return = [];
  872. foreach ($order_no as $value){
  873. $return[$value] = ['oa_state' => 0];
  874. }
  875. $detail = OaOrder::whereIn('order_no', $order_no)
  876. ->where('channel',$user['depart_top'][0]['depart_id'])
  877. ->where('menu_id', $menu_id)
  878. ->where('del_time', 0)
  879. ->orderBy('id', 'desc')
  880. ->get()->toArray();
  881. if (empty($detail)) $return;
  882. $final_detail = $oa_order = $oa_order2 = $map = [];
  883. foreach ($detail as $value){
  884. if(! isset($final_detail[$value['order_no']])){
  885. $map[$value['id']] = $value['order_no'];
  886. if($value['state'] == 2) {
  887. $oa_order[] = $value['id'];
  888. }else{
  889. $oa_order2[] = $value['id'];
  890. }
  891. $final_detail[$value['order_no']] = $value['id'];
  892. }
  893. }
  894. if (count($oa_order) == count($final_detail)) return $return;
  895. $oa_detail = OaOrderSubEmployee::where('employee_id', $user_id)
  896. ->whereIn('oa_order_id', $oa_order2)
  897. ->pluck('oa_order_sub_id','oa_order_id')
  898. ->toArray();
  899. if(empty($oa_detail)) return $return;
  900. $oa_detail_map = array_flip($oa_detail);
  901. $oa_detail_value = array_values($oa_detail);
  902. $state = OaOrderSub::whereIn('id', $oa_detail_value)
  903. ->where('state', '<>', 2)
  904. ->orderBy('sort', 'desc')
  905. ->get()->toArray();
  906. foreach ($state as $value){
  907. $oa_order_id_tmp = $oa_detail_map[$value['id']];
  908. $order_no_tmp = $map[$oa_order_id_tmp];
  909. if (in_array($value['state'], [0, 2])) {
  910. $return[$order_no_tmp] = ['oa_state' => 1, 'oa_id' => $value['id']];
  911. }else{
  912. $return[$order_no_tmp] = ['oa_state' => 0];
  913. }
  914. }
  915. return $return;
  916. }
  917. public function getOaTeamDetailList($order_no)
  918. {
  919. if(empty($order_no)) return [];
  920. $orderNoGroups = OaOrder::whereIn('order_no', $order_no)
  921. ->get()
  922. ->groupBy('order_no');
  923. $maxIds = $orderNoGroups->map(function ($group) {
  924. return $group->max('id');
  925. });
  926. $map = $maxIds->toArray();
  927. if(empty($map)) return [];
  928. $map2 = array_flip($map);
  929. $oa_order_id = array_values($map);
  930. $list = OaOrderSub::whereIn('oa_order_id', $oa_order_id)
  931. ->where('state',0)
  932. ->select('id','state','oa_order_id')
  933. ->orderBy('id', 'asc')
  934. ->get()->toArray();
  935. $subEmployeeList = OaOrderSubEmployee::whereIn('oa_order_id', $oa_order_id)
  936. ->select('*')
  937. ->get()->toArray();
  938. $emp_id_key_list = [];
  939. $employee_key_list = Employee::whereIn('id',array_unique(array_column($subEmployeeList,'employee_id')))
  940. ->pluck('emp_name', 'id')
  941. ->toArray();
  942. foreach ($subEmployeeList as $v) {
  943. $emp_id_key_list[$v['oa_order_sub_id']][] = [
  944. 'id' => $v['employee_id'],
  945. 'emp_name' => $employee_key_list[$v['employee_id']] ?? '',
  946. ];
  947. }
  948. $return = [];
  949. foreach ($list as $v) {
  950. $order_no_tmp = $map2[$v['oa_order_id']] ?? "";
  951. if($v['state'] == 0 && ! isset($return[$order_no_tmp])){
  952. $emp_tmp = $emp_id_key_list[$v['id']] ?? [];
  953. $emp_tmp_str = implode('|',array_column($emp_tmp,'emp_name'));
  954. $return[$order_no_tmp] = $emp_tmp_str;
  955. // $return[$order_no_tmp][] = [
  956. // 'oa_order_id' => $v['oa_order_id'],
  957. // 'sort' => $v['sort'],
  958. // 'team' => $emp_id_key_list[$v['id']],
  959. // 'state' => $v['state'],
  960. // ];
  961. }
  962. }
  963. return $return;
  964. }
  965. }