Notification.php 15 KB

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