Notification.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384
  1. <?php
  2. namespace App\Models;
  3. use Carbon\Carbon;
  4. class Notification extends BaseModel
  5. {
  6. public static function send($order_id, $overdue = false)
  7. {
  8. $order = Order::find($order_id);
  9. if(!$order) return false;
  10. if($order['is_draft'] == 1) return false;
  11. $checked_id = Option::get('orders', 'status', 'checked');
  12. $reject_id = Option::get('orders', 'status', 'reject');
  13. $pass_id = Option::get('orders', 'status', 'pass');
  14. $back_id = Option::get('orders', 'status', 'back');
  15. $last_role = ProjectRole::find($order['last_project_role_id']);
  16. $role = ProjectRole::find($order['project_role_id']);
  17. $status = 1;
  18. $user_ids = [];
  19. $project_role_ids = ProjectRole::where('level', $order['level'])->pluck('id');
  20. if($overdue) {
  21. // 调用时间到期
  22. $role = ProjectRole::getFirstRole($order);
  23. $project_role_ids = [$role['id']];
  24. } else if($order['status'] == $pass_id) {
  25. // 租赁完成,调用完成
  26. if($order['type'] == 1) {
  27. // 租赁完成
  28. $project_role_ids = ProjectRole::whereIn('key', ['manager'])->pluck('id');
  29. } else if($order['is_change' == 2]) {
  30. // 调用完成且未修改
  31. $project_role_ids = ProjectRole::whereIn('key', ['admin'])->pluck('id');
  32. } else {
  33. // 调用完成且修改
  34. $project_role_ids = ProjectRole::whereIn('key', ['admin'])->pluck('id');
  35. }
  36. } else if($order['status'] == $back_id) {
  37. $project_role_ids = ProjectRole::whereIn('key', ['admin'])->pluck('id');
  38. }
  39. if($overdue) {
  40. $project_role_ids = ProjectRole::whereIn('key', ['machine', 'admin'])->pluck('id');
  41. }
  42. if(count($project_role_ids) > 0) {
  43. $user_ids = ProjectUser::where([
  44. ['project_id', $order['project_id']]
  45. ])->whereIn('project_role_id', $project_role_ids)->pluck('user_id');
  46. }
  47. // 外部租赁
  48. if($order['type'] == 1) {
  49. // 审批成功
  50. if($order['status'] == $checked_id && $last_role && $last_role['key'] == 'manager') {
  51. $status = 1;
  52. } else if($role && in_array($role['key'], ['machine', 'assist', 'manager'])) {
  53. // 审批待处理
  54. $status = 2;
  55. } else if($order['status'] == $reject_id) {
  56. // 审批被驳回
  57. $status = 3;
  58. } else if($order['status'] == $pass_id) {
  59. // 租赁已完成
  60. $status = 5;
  61. }
  62. } else {
  63. // 调用
  64. // 调用成功
  65. if($order['status'] == $checked_id && $role && $last_role && in_array($last_role['key'], ['admin', 'sub'])) {
  66. $status = $order['is_change'] == 1 ? 7 : 1;
  67. } else if($order['status'] == $reject_id) {
  68. // 调用被驳回
  69. $status = 3;
  70. } else if($order['status'] == $pass_id) {
  71. // 调用已完成,主动退回
  72. $status = 6;
  73. } else if($order['status'] == $back_id) {
  74. // 调用已归还
  75. $status = 6;
  76. } else if($order['is_change'] == 1) {
  77. // 调用修改通知
  78. $status = 7;
  79. } else if($role && in_array($role['key'], ['assist', 'manager', 'sub', 'admin'])) {
  80. // 调用待处理
  81. $status = 2;
  82. }
  83. }
  84. // 调用时间到期,发送调用完成通知 status = 5
  85. if($overdue) {
  86. $status = 5;
  87. }
  88. foreach($user_ids as $user_id) {
  89. $data = [
  90. 'user_id' => $user_id,
  91. 'order_id' => $order['id'],
  92. 'status' => $status,
  93. 'type' => $order['type'],
  94. 'is_read' => 2
  95. ];
  96. self::createAndSend($data);
  97. }
  98. return true;
  99. }
  100. /**
  101. * 租赁时间到期 status = 4
  102. * @param $id
  103. * @return bool
  104. */
  105. public static function sendOverdue($id)
  106. {
  107. $order = self::find($id);
  108. if(!$order) return false;
  109. $role = $order->type == 1 ? $role = ProjectRole::getByKey('work') : ProjectRole::getByKey('machine');
  110. $user_ids = ProjectUser::where([
  111. ['project_id', $order['project_id']],
  112. ['project_role_id', $role['id']]
  113. ])->pluck('user_id');
  114. foreach($user_ids as $user_id) {
  115. $data = [
  116. 'user_id' => $user_id,
  117. 'order_id' => $order['id'],
  118. 'status' => 4,
  119. 'type' => $order['type'],
  120. 'is_read' => 2
  121. ];
  122. self::createAndSend($data);
  123. }
  124. return false;
  125. }
  126. public static function createAndSend($data)
  127. {
  128. $item = Notification::create($data);
  129. $item->sendOfficialInfo();
  130. }
  131. public function sendOfficialInfo()
  132. {
  133. $content = $this->getNameContent();
  134. $user = User::find($this['user_id']);
  135. $official_app = app('wechat.official_account.default');
  136. if($content && isset($content['official']) && $user && $user['official_open_id']) {
  137. $info = $content['official'];
  138. $official_app->template_message->send([
  139. 'touser' => $user['official_open_id'],
  140. 'template_id' => $info['template_id'],
  141. 'miniprogram' => [
  142. 'appid' => env('WECHAT_MINI_PROGRAM_APPID'),
  143. 'pagepath' => $info['page'],
  144. ],
  145. 'data' => $info['data'],
  146. ]);
  147. }
  148. }
  149. public function getNameContent()
  150. {
  151. $order = Order::find($this['order_id']);
  152. $status_name = $order ? $order->getStatusName() : '';
  153. $source = ($order->project ? $order->project->name : '') . '-' . ($order->workPoint ? $order->workPoint->name : '') . '-' . ($order->user ? $order->user->name : '');
  154. $tomorrow = Carbon::tomorrow();
  155. $days = OrderDevice::where([
  156. 'order_id' => $order->id,
  157. 'end_date' => $tomorrow
  158. ])->first() ? 1 : 3;
  159. if($this['type'] == 1) {
  160. $detail = OrderDevice::where('order_id', $order->id)->count() . '个设备,¥' . ($order->money / 100);
  161. $type = '设备租赁订单';
  162. if($this['status'] == 1) {
  163. return [
  164. 'name' => '租赁审批成功通知',
  165. 'content' => '你的设备租赁申请已通过,请确认相关信息:',
  166. 'official' => [
  167. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  168. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  169. 'data' => [
  170. 'first' => '您有一个订单已通过审核,请注意查看!',
  171. 'keyword1' => $this['created_at'],
  172. 'keyword2' => $type,
  173. 'keyword3' => $status_name,
  174. 'keyword4' => $source,
  175. 'keyword5' => $detail,
  176. 'remark' => '点击进入小程序查看详情。',
  177. ]
  178. ]
  179. ];
  180. } else if($this['status'] == 2) {
  181. return [
  182. 'name' => '租赁审批待处理通知',
  183. 'content' => '你有一条设备租赁申请待审批,请确认相关信息:',
  184. 'official' => [
  185. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  186. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  187. 'data' => [
  188. 'first' => '您有一条待审核的订单,请注意查看!',
  189. 'keyword1' => $this['created_at'],
  190. 'keyword2' => $type,
  191. 'keyword3' => $status_name,
  192. 'keyword4' => $source,
  193. 'keyword5' => $detail,
  194. 'remark' => '点击进入小程序查看详情,请及时处理。',
  195. ]
  196. ]
  197. ];
  198. } else if($this['status'] == 3) {
  199. return [
  200. 'name' => '租赁审批驳回通知',
  201. 'content' => '你有一条设备租赁申请被驳回,请确认相关信息:',
  202. 'official' => [
  203. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  204. 'page' => '/pages/create-order/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  205. 'data' => [
  206. 'first' => '您有一个订单已被驳回,请注意查看!',
  207. 'keyword1' => $this['created_at'],
  208. 'keyword2' => $type,
  209. 'keyword3' => $status_name,
  210. 'keyword4' => $source,
  211. 'keyword5' => $detail,
  212. 'remark' => '点击进入小程序查看详情,请及时处理。',
  213. ]
  214. ]
  215. ];
  216. } else if($this['status'] == 4) {
  217. return [
  218. 'name' => '租赁时间到期通知',
  219. 'content' => '你有一条设备租赁已到期消息,请确认相关信息:',
  220. 'official' => [
  221. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  222. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  223. 'data' => [
  224. 'first' => '您有一个设备租赁订单即将到期,请注意查看',
  225. 'keyword1' => $this['created_at'],
  226. 'keyword2' => $type,
  227. 'keyword3' => $status_name,
  228. 'keyword4' => $source,
  229. 'keyword5' => $detail,
  230. 'remark' => '你租赁的设备将于' . $days . '天后到期,请进入小程序查看
  231. ',
  232. ]
  233. ]
  234. ];
  235. } else if($this['status'] == 5) {
  236. return [
  237. 'name' => '租赁完成通知',
  238. 'content' => '你有一条设备租赁已完成消息,请确认相关信息:',
  239. 'official' => [
  240. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  241. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  242. 'data' => [
  243. 'first' => '有一个订单已完成,请注意查看!',
  244. 'keyword1' => $this['created_at'],
  245. 'keyword2' => $type,
  246. 'keyword3' => $status_name,
  247. 'keyword4' => $source,
  248. 'keyword5' => $detail,
  249. 'remark' => '点击进入小程序查看详情。',
  250. ]
  251. ]
  252. ];
  253. }
  254. } else {
  255. $detail = OrderDevice::where('order_id', $order->id)->count() . '个设备';
  256. $type = '设备调用订单';
  257. if($this['status'] == 1) {
  258. return [
  259. 'name' => '调用审批成功通知',
  260. 'content' => '你的设备调用申请已通过,请确认相关信息:',
  261. 'official' => [
  262. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  263. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  264. 'data' => [
  265. 'first' => '您有一个订单已通过审核,请注意查看!',
  266. 'keyword1' => $this['created_at'],
  267. 'keyword2' => $type,
  268. 'keyword3' => $status_name,
  269. 'keyword4' => $source,
  270. 'keyword5' => $detail,
  271. 'remark' => '点击进入小程序查看详情。',
  272. ]
  273. ]
  274. ];
  275. } else if($this['status'] == 2) {
  276. return [
  277. 'name' => '调用审批待处理通知',
  278. 'content' => '你有一条设备调用申请待审批,请确认相关信息:',
  279. 'official' => [
  280. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  281. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  282. 'data' => [
  283. 'first' => '您有一条待审核的订单,请注意查看!',
  284. 'keyword1' => $this['created_at'],
  285. 'keyword2' => $type,
  286. 'keyword3' => $status_name,
  287. 'keyword4' => $source,
  288. 'keyword5' => $detail,
  289. 'remark' => '点击进入小程序查看详情,请及时处理。',
  290. ]
  291. ]
  292. ];
  293. } else if($this['status'] == 3) {
  294. return [
  295. 'name' => '调用审批驳回通知',
  296. 'content' => '你有一条设备调用申请被驳回,请确认相关信息:',
  297. 'official' => [
  298. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  299. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  300. 'data' => [
  301. 'first' => '您有一个订单已被驳回,请注意查看!',
  302. 'keyword1' => $this['created_at'],
  303. 'keyword2' => $type,
  304. 'keyword3' => $status_name,
  305. 'keyword4' => $source,
  306. 'keyword5' => $detail,
  307. 'remark' => '点击进入小程序查看详情,请及时处理。',
  308. ]
  309. ]
  310. ];
  311. } else if($this['status'] == 4) {
  312. return [
  313. 'name' => '调用时间到期通知',
  314. 'content' => '你有一条设备调用已到期消息,请确认相关信息:',
  315. 'official' => [
  316. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  317. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  318. 'data' => [
  319. 'first' => '您有一个设备租赁订单即将到期,请注意查看',
  320. 'keyword1' => $this['created_at'],
  321. 'keyword2' => $type,
  322. 'keyword3' => $status_name,
  323. 'keyword4' => $source,
  324. 'keyword5' => $detail,
  325. 'remark' => '你租赁的设备将于' . $days . '天后到期,请进入小程序查看
  326. ',
  327. ]
  328. ]
  329. ];
  330. } else if($this['status'] == 5) {
  331. return [
  332. 'name' => '调用完成通知',
  333. 'content' => '你有一条设备调用已完成消息,请确认相关信息:',
  334. 'official' => [
  335. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  336. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  337. 'data' => [
  338. 'first' => '有一个订单已完成,请注意查看!',
  339. 'keyword1' => $this['created_at'],
  340. 'keyword2' => $type,
  341. 'keyword3' => $status_name,
  342. 'keyword4' => $source,
  343. 'keyword5' => $detail,
  344. 'remark' => '点击进入小程序查看详情。',
  345. ]
  346. ]
  347. ];
  348. } else if($this['status'] == 6) {
  349. return [
  350. 'name' => '调用退回通知',
  351. 'content' => '你有一条设备调用已归还消息,请确认相关信息:',
  352. 'official' => [
  353. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  354. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  355. 'data' => [
  356. 'first' => '有一个设备调用订单已完成,请注意查看',
  357. 'keyword1' => $this['created_at'],
  358. 'keyword2' => $type,
  359. 'keyword3' => $status_name,
  360. 'keyword4' => $source,
  361. 'keyword5' => $detail,
  362. 'remark' => '请进入小程序查看详情',
  363. ]
  364. ]
  365. ];
  366. } else if($this['status'] == 7) {
  367. return [
  368. 'name' => '调用修改通知',
  369. 'content' => '你有一条设备调用被修改消息,请确认相关信息:'
  370. ];
  371. }
  372. }
  373. return ['name' => '', 'content' => ''];
  374. }
  375. }