OaService.php 34 KB

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