OaService.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946
  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. $oa_id = Oa::where('menu_id', $menu_id)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('del_time', 0)->value('id');
  448. $parent_ids = [$parent_id, 0];
  449. // var_dump($parent_ids);
  450. if ($sort > 2) {
  451. $sorts = $sort - 1;
  452. $oa_sub_ids = OaSub::where('sort', '<', $sorts)->where('del_time', 0)->wherein('parent_id', $parent_ids)->pluck('id')->toArray();
  453. // var_dump($oa_sub_ids);die;
  454. $parent_ids = array_merge($parent_ids, $oa_sub_ids);
  455. }
  456. $list = OaSub::where('oa_id', $oa_id)->where('del_time', 0)->where('sort', $sort)->wherein('parent_id', $parent_ids);
  457. $list = $list->select('*')->get()->toArray();
  458. if (empty($list)) return [[], '',$detail];
  459. $oa_sub_ids = [];
  460. $oa_sub_key = [];
  461. foreach ($list as $v) {
  462. $oa_sub_ids[] = $v['id'];
  463. $oa_sub_key[$v['id']] = $v;
  464. $rule_key_list[$v['id']] = [];
  465. }
  466. $rule_list = OaSubRule::wherein('oa_sub_id', $oa_sub_ids)->select('*')->get()->toArray();
  467. foreach ($rule_list as $v) {
  468. $rule_key_list[$v['oa_sub_id']][] = $v;
  469. }
  470. //规则开始判断
  471. $employee_ids = [];
  472. $oa_sub_id = 0;
  473. foreach ($rule_key_list as $k => $v) {
  474. $status = $this->formulaRule($v, $detail);
  475. if ($status) {
  476. if ($oa_sub_key[$k]['type'] == 2 && $oa_sub_key[$k]['sub_id'] > 0) {
  477. $employee_ids = EmployeeTeamPermission::where('team_id', $oa_sub_key[$k]['sub_id'])->pluck('employee_id')->toArray();
  478. } elseif ($oa_sub_key[$k]['sub_id'] == -1) {
  479. $employee_ids = OaSubEmployee::where('oa_sub_id', $oa_sub_key[$k]['id'])->pluck('employee_id')->toArray();
  480. } else {
  481. $employee_ids[] = [$oa_sub_key[$k]['sub_id']];
  482. }
  483. $oa_sub_id = $k;
  484. continue;
  485. }
  486. }
  487. return [$employee_ids, $oa_sub_id,$detail];
  488. }
  489. public function formulaRule($params, $detail)
  490. {
  491. $rule = '';
  492. // dd($params);
  493. if (empty($params)) return true;
  494. foreach ($params as $param) {
  495. if (!$param['key']) continue;
  496. if (!empty($param['right_formula'])) $rule .= ' ' . $param['right_formula'] . ' ';
  497. $rule .= '"' . $detail[$param['key']] . '"' . ' ' . $param['formula'] . ' ' . '"' . $param['value'] . '"';
  498. }
  499. // dd($rule);
  500. if (empty($rule)) return true;
  501. // var_dump($rule);
  502. if (eval("return $rule;")) {
  503. // var_dump($rule);die;
  504. return true;
  505. } else return false;
  506. }
  507. public function oaCheck($data, $user)
  508. {
  509. $user_id = $user['id'];
  510. // $user_id = '482';
  511. $id = $data['id'];
  512. $state = $data['state'];
  513. if ($state == 0) $state = 2;
  514. $remark = $data['remark'];
  515. $detail = OaOrderSub::from('oa_order_sub as s')
  516. ->leftJoin('oa_order_sub_employee as e', 'e.oa_order_sub_id', 's.id')
  517. ->where('e.employee_id', $user_id)->where('s.state', 0)
  518. ->where('s.id', $id)
  519. ->select('s.oa_order_id', 'sort', 'oa_sub_id', 's.id')->first();
  520. if (empty($detail)) return [false, '没有审核权限'];
  521. $detail = $detail->toArray();
  522. $oaOrder = OaOrder::where('id', $detail['oa_order_id'])->first();
  523. try {
  524. DB::beginTransaction();
  525. switch ($state) {
  526. case 1:
  527. $sort = $detail['sort'] + 1;
  528. list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($oaOrder->menu_id, ['order_number' => $oaOrder->order_no], $sort, $detail['oa_sub_id'],$user);
  529. // var_dump($employee_ids);
  530. // var_dump($oa_sub_id);die;
  531. if (empty($employee_ids)) {
  532. $oaOrder->state = 2;
  533. $oaOrder->save();
  534. //审核通过
  535. $tmp_data = [
  536. $order_detail['order_number'],
  537. SysMenu::where('id',$oaOrder->menu_id)->value('title'),
  538. '通过',
  539. Employee::where('id',$user_id)->value('emp_name'),
  540. date('Y-m-d H:i:s'),
  541. ];
  542. $this->sendWxMsg($order_detail['crt_id'],2,0,$oaOrder->menu_id,$tmp_data);
  543. $this->returnOa($oaOrder->order_no, 1, $oaOrder->opt_case);
  544. } else {
  545. $oaOrder->state = 1;
  546. $oaOrder->save();
  547. $oa_order_sub = new OaOrderSub();
  548. $oa_order_sub->oa_order_id = $oaOrder->id;
  549. $oa_order_sub->sort = $sort;
  550. $oa_order_sub->remark = '';
  551. $oa_order_sub->type = 1;
  552. $oa_order_sub->oa_sub_id = $oa_sub_id;
  553. $oa_order_sub->save();
  554. $oa_order_sub_id = $oa_order_sub->id;
  555. $insert = [];
  556. foreach ($employee_ids as $employee_id) {
  557. $insert[] = [
  558. 'oa_order_id' => $oaOrder->id,
  559. 'oa_order_sub_id' => $oa_order_sub_id,
  560. 'employee_id' => $employee_id,
  561. ];
  562. $tmp_data = [
  563. $order_detail['order_number'],
  564. $order_detail['crt_name'].'('.SysMenu::where('id',$oaOrder->menu_id)->value('title').')',
  565. Employee::where('id',$employee_id)->value('emp_name'),
  566. date('Y-m-d H:i:s'),
  567. ];
  568. $this->sendWxMsg($employee_id,1,0,$oaOrder->menu_id,$tmp_data);
  569. }
  570. OaOrderSubEmployee::insert($insert);
  571. }
  572. break;
  573. case 2:
  574. list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($oaOrder->menu_id, ['order_number' => $oaOrder->order_no], 1, $detail['oa_sub_id'],$user);
  575. $tmp_data = [
  576. $oaOrder['order_no'],
  577. '拒绝',
  578. $order_detail['crt_time'],
  579. $remark,
  580. ];
  581. if ($detail['sort'] == 1||true) {
  582. $oaOrder->state = 3;
  583. $oaOrder->save();
  584. $this->sendWxMsg($order_detail['crt_id'],3,2,$oaOrder->menu_id,$tmp_data);
  585. $this->returnOa($oaOrder->order_no, 2, $oaOrder->opt_case);
  586. }else{
  587. $id = OaOrderSub::where('sort', ($detail['sort'] - 1))->where('oa_order_id', $oaOrder->id)->value('id');
  588. $employee_ids = OaOrderSubEmployee::where('oa_order_sub_id',$id)->pluck('employee_id')->toArray();
  589. foreach ($employee_ids as $v){
  590. $this->sendWxMsg($v,3,2,$oaOrder->menu_id,$tmp_data);
  591. }
  592. }
  593. OaOrderSub::where('sort', ($detail['sort'] - 1))->where('oa_order_id', $oaOrder->id)->update([
  594. 'state' => 0,
  595. 'remark' => $remark,
  596. ]);
  597. break;
  598. }
  599. OaOrderSub::where('id', $id)->update([
  600. 'state' => $state,
  601. 'remark' => $remark,
  602. ]);
  603. $this->report($oaOrder, $detail['oa_sub_id'],$user_id);
  604. DB::commit();
  605. return [true, '操作成功!'];
  606. } catch (\Exception $e) {
  607. DB::rollBack();
  608. return [false, $e->getLine() . ':' . $e->getMessage()];
  609. }
  610. }
  611. public function report($oaOrder, $oa_sub_id,$user_id)
  612. {
  613. $oa_sub_report_employee = OaSubReportEmployee::where('oa_sub_id', $oa_sub_id)->select('*')->get()->toArray();
  614. if (!empty($oa_sub_report_employee)) {
  615. $list = [];
  616. $report = new OaReportOrder();
  617. $report->menu_id = $oaOrder->menu_id;
  618. $report->order_no = $oaOrder->order_no;
  619. $report->opt_case = $oaOrder->opt_case;
  620. $report->user_id = $user_id;
  621. $report->channel = $this->user['depart_top'][0]['depart_id'];
  622. $report->save();
  623. $tmp_data = [
  624. $oaOrder->order_no,
  625. SysMenu::where('id',$oaOrder->menu_id)->value('title'),
  626. '审核通过',
  627. Employee::where('id',$user_id)->value('emp_name'),
  628. date('Y-m-d H:i:s'),
  629. ];
  630. foreach ($oa_sub_report_employee as $v) {
  631. $list[] = [
  632. 'employee_id' => $v['employee_id'],
  633. 'oa_report_order_id' => $report->id,
  634. ];
  635. $this->sendWxMsg($v['employee_id'],2,0,$oaOrder->menu_id,$tmp_data);
  636. }
  637. OaReportOrderEmployee::insert($list);
  638. }
  639. }
  640. public function returnOa($order_no, $type, $opt_case)
  641. {
  642. $service = new CheckService();
  643. $service->createRecordAndInventory([
  644. 'order_number' => $order_no,
  645. 'type' => $type,
  646. 'opt_case' => $opt_case,
  647. 'user_data' => $this->user,
  648. ]);
  649. }
  650. public function oaGetData($menu_id, $request,$user='')
  651. {
  652. $api = SysMenu::where('id', $menu_id)->value('api');
  653. $param = SysMenu::where('id', $menu_id)->value('api_params');
  654. $param = json_decode($param,true);
  655. $param['state'] = null;
  656. $param['menu_id'] = $menu_id;
  657. $param['id'] = null;
  658. $request->merge($param);
  659. $path = $this->getMenu();
  660. $control = '\\' . $path[$api]["controller"];
  661. $act = $path[$api]["act"];
  662. $new = new $control();
  663. $detail = $new->$act($request);
  664. // if(!isset($detail['data']['data'][0])) $detail['data']['data'][0] = $detail['data'];
  665. return $detail['data']['data'][0];
  666. }
  667. public function getMenu()
  668. {
  669. $app = App();
  670. $routes = $app->routes->getRoutes();
  671. $path = [];
  672. foreach ($routes as $k => $value) {
  673. if (!isset($value->action['controller'])) continue;
  674. $act = explode('@', $value->action['controller']);
  675. if (!isset($act[1])) continue;
  676. $path[$value->uri]['act'] = $act[1];
  677. $path[$value->uri]['controller'] = $act[0];
  678. }
  679. return $path;
  680. }
  681. public function oaOrderList($data)
  682. {
  683. $order_no = $data['order_no'];
  684. $menu_id = $data['menu_id'];
  685. $oa = OaOrder::where('order_no', $order_no)->first();
  686. if (empty($oa)) return [false, '审核不存在'];
  687. $list = OaOrderSub::where('oa_order_id', $oa->id)->orderBy('sort', 'asc')->select('*')->get()->toArray();
  688. return [true, $list];
  689. }
  690. public function oaOrderState($data, $user)
  691. {
  692. $user_id = $user['id'];
  693. $order_no = $data['order_no'];
  694. $menu_id = $data['menu_id'];
  695. $detail = OaOrder::where('order_no', $order_no)->where('channel',$this->user['depart_top'][0]['depart_id'])->orderBy('id', 'desc')->where('menu_id', $menu_id)->first();
  696. if (empty($detail)) return [true, ['state' => 0]];
  697. if ($detail->state == 2) return [true, ['state' => 0]];
  698. $oa_detail = OaOrderSubEmployee::where('employee_id', $user_id)->where('oa_order_id', $detail->id)->pluck('oa_order_sub_id')->toArray();
  699. if (empty($oa_detail)) return [true, ['state' => 0]];
  700. $state = OaOrderSub::wherein('id', $oa_detail)->where('state', '<>', 2)->orderBy('sort', 'desc')->first();
  701. if (in_array($state->state, [0, 2])) return [true, ['state' => 1, 'id' => $state->id]];
  702. return [true, ['state' => 0]];
  703. }
  704. public function checkAllOver($data)
  705. {
  706. $order_no = $data['order_number'];
  707. $menu_id = $data['menu_id'];
  708. $op_case = $data['opt_case'];
  709. // $oaOrder = OaOrder::where('order_no',$order_no)->first();
  710. // $id = OaOrderSub::where('oa_order_id',$oaOrder->id)->orderBy('id','desc')->value('id');
  711. // OaOrderSub::where('id',$id)->update([
  712. // 'state' => 1
  713. // ]);
  714. // $oaOrder->state = 1;
  715. // $oaOrder->save();
  716. $this->returnOa($order_no, 3, $op_case);
  717. return [true, '弃审成功'];
  718. }
  719. public function oaCheckMove($data, $user_id)
  720. {
  721. $id = $data['id'];
  722. $employee_id = $data['employee_id'];
  723. if (empty($employee_id)) return [false, '用户不存在'];
  724. $oaOrderSub = OaOrderSub::where('id', $id)->first();
  725. OaOrderSubEmployee::where('oa_order_sub_id', $oaOrderSub->id)->delete();
  726. $add = [
  727. 'oa_order_id' => $oaOrderSub->oa_order_id,
  728. 'oa_order_sub_id' => $oaOrderSub->id,
  729. 'employee_id' => $employee_id
  730. ];
  731. $oaOrder = OaOrder::where('id', $oaOrderSub->oa_order_id)->first();
  732. OaOrderSubEmployee::insert($add);
  733. Construction::where('order_number', $oaOrder->order_no)->update([
  734. 'is_transfer' => 1
  735. ]);
  736. // $this->returnOa($order_no,3,$op_case);
  737. return [true, '转签成功'];
  738. }
  739. public function oaSubUserDetail($data)
  740. {
  741. $order_no = $data['order_no'];
  742. $first = OaOrder::where('order_no', $order_no)->first();
  743. if (empty($first)) return [true, []];
  744. $oa_order_id = $first->id;
  745. $oa_order_sub_id = OaOrderSub::where('oa_order_id', $oa_order_id)->orderBy('sort', 'desc')->value('id');
  746. $employee_list = Employee::pluck('emp_name', 'id')->toArray();
  747. $oa_order_sub_employee_ids = OaOrderSubEmployee::where('oa_order_sub_id', $oa_order_sub_id)->pluck('employee_id')->toArray();
  748. $list = [];
  749. foreach ($oa_order_sub_employee_ids as $v) {
  750. $list[] = $employee_list[$v];
  751. }
  752. return [true, $list];
  753. }
  754. public function oaGetTeamDetail($data)
  755. {
  756. $order_no = $data['order_no'];
  757. $oa_order_id = OaOrder::where('order_no', $order_no)->pluck('id')->toArray();
  758. if (empty($oa_order_id)) return [true, []];
  759. // $oa_order_id = $first->id;
  760. $list = OaOrderSub::wherein('oa_order_id', $oa_order_id)->select('*')->orderBy('id', 'asc')->get()->toArray();
  761. $subEmployeeList = OaOrderSubEmployee::wherein('oa_order_id', $oa_order_id)->select('*')->get()->toArray();
  762. $emp_id_key_list = [];
  763. $employee_key_list = Employee::pluck('emp_name', 'id')->toArray();
  764. foreach ($subEmployeeList as $v) {
  765. $emp_id_key_list[$v['oa_order_sub_id']][] = [
  766. 'id' => $v['employee_id'],
  767. 'emp_name' => $employee_key_list[$v['employee_id']] ?? '',
  768. ];
  769. }
  770. $return = [];
  771. foreach ($list as $v) {
  772. $return[] = [
  773. 'sort' => $v['sort'],
  774. 'team' => $emp_id_key_list[$v['id']],
  775. 'remark' => $v['remark'] ?? '',
  776. 'state' => $v['state'],
  777. ];
  778. }
  779. // $this->returnOa($order_no,3,$op_case);
  780. return [true, $return];
  781. }
  782. public function oaSubRemark($data)
  783. {
  784. $order_no = $data['order_no'];
  785. $first = OaOrder::where('del_time', 0)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('order_no', $order_no)->orderBy('id', 'desc')->first();
  786. if (empty($first)) return [true, []];
  787. $oa_order_id = $first->id;
  788. $remark = OaOrderSub::where('oa_order_id', $oa_order_id)->orderBy('sort', 'desc')->value('remark');
  789. // $this->returnOa($order_no,3,$op_case);
  790. return [true, $remark];
  791. }
  792. public function reportList($data, $user)
  793. {
  794. $id = $user['id'];
  795. $list = OaReportOrder::from('oa_report_order_employee as e')
  796. ->leftJoin('oa_report_order as o','o.id','e.oa_report_order_id')
  797. ->leftJoin('oa_order as oo','oo.order_no','o.order_no')
  798. ->leftJoin('employee as ee','ee.id','o.user_id')
  799. ->where('e.employee_id',$id)
  800. ->where('o.channel',$this->user['depart_top'][0]['depart_id'])
  801. ->groupBy('oo.id')->orderBy('oo.id','desc')
  802. ->select('oo.*','o.id as sid','o.check','o.user_id','ee.emp_name');
  803. $list = $this->limit($list,'',$data);
  804. return [true,$list];
  805. }
  806. public function reportCheck($data){
  807. $id = $data['sid'];
  808. OaReportOrder::wherein('id',$id)->where('channel',$this->user['depart_top'][0]['depart_id'])->update([
  809. 'check' => 1
  810. ]);
  811. return [true,''];
  812. }
  813. public function reportCount($data,$user){
  814. $id = $user['id'];
  815. $list = OaReportOrder::from('oa_report_order_employee as e')
  816. ->leftJoin('oa_report_order as o','o.id','e.oa_report_order_id')
  817. ->leftJoin('oa_order as oo','oo.order_no','o.order_no')
  818. ->where('e.employee_id',$id)
  819. ->where('o.check',0)
  820. ->groupBy('oo.id')->orderBy('oo.id','desc')
  821. ->select('oo.*','o.id as sid','o.check')->get()->toArray();
  822. return [true,['total'=>count($list),'list'=>$list]];
  823. }
  824. public function reportTime($data){
  825. return [true,['time'=>'20小时10分钟']];
  826. }
  827. public function sendWxMsg($user_id,$type,$state,$menu_id,$order_data){
  828. $service = new WxSendMessageService();
  829. 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);
  830. list($status, $msg) = $service->wx_sendMsg($user_id,$type,$state,$menu_id,$order_data);
  831. file_put_contents('msg_result.txt',date('Y-m-d H:i:s') . "结果:" . $msg . PHP_EOL,8);
  832. }
  833. }