Notification.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335
  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. $item->sendOfficialInfo();
  129. }
  130. public function sendOfficialInfo()
  131. {
  132. $content = $this->getNameContent();
  133. $user = User::find($this['user_id']);
  134. $official_app = app('wechat.official_account.default');
  135. if($content && isset($content['official']) && $user && $user['official_open_id']) {
  136. $info = $content['official'];
  137. $official_app->template_message->send([
  138. 'touser' => $user['official_open_id'],
  139. 'template_id' => $info['template_id'],
  140. 'miniprogram' => [
  141. 'appid' => env('WECHAT_MINI_PROGRAM_APPID'),
  142. 'pagepath' => $info['page'],
  143. ],
  144. 'data' => $info['data'],
  145. ]);
  146. }
  147. }
  148. public function getNameContent()
  149. {
  150. $order = Order::find($this['order_id']);
  151. $status_name = $order ? $order->getStatusName() : '';
  152. $source = ($order->project ? $order->project->name : '') . '-' . ($order->workPoint ? $order->workPoint->name : '') . '-' . ($order->user ? $order->user->name : '');
  153. if($this['type'] == 1) {
  154. $detail = OrderDevice::where('order_id', $order->id)->count() . '个设备,¥' . ($order->money / 100);
  155. $type = '设备租赁订单';
  156. if($this['status'] == 1) {
  157. return [
  158. 'name' => '租赁审批成功通知',
  159. 'content' => '你的设备租赁申请已通过,请确认相关信息:',
  160. 'official' => [
  161. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  162. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  163. 'data' => [
  164. 'first' => '您有一个订单已通过审核,请注意查看!',
  165. 'keyword1' => $this['created_at'],
  166. 'keyword2' => $type,
  167. 'keyword3' => $status_name,
  168. 'keyword4' => $source,
  169. 'keyword5' => $detail,
  170. 'remark' => '点击进入小程序查看详情。',
  171. ]
  172. ]
  173. ];
  174. } else if($this['status'] == 2) {
  175. return [
  176. 'name' => '租赁审批待处理通知',
  177. 'content' => '你有一条设备租赁申请待审批,请确认相关信息:',
  178. 'official' => [
  179. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  180. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  181. 'data' => [
  182. 'first' => '您有一条待审核的订单,请注意查看!',
  183. 'keyword1' => $this['created_at'],
  184. 'keyword2' => $type,
  185. 'keyword3' => $status_name,
  186. 'keyword4' => $source,
  187. 'keyword5' => $detail,
  188. 'remark' => '点击进入小程序查看详情,请及时处理。',
  189. ]
  190. ]
  191. ];
  192. } else if($this['status'] == 3) {
  193. return [
  194. 'name' => '租赁审批驳回通知',
  195. 'content' => '你有一条设备租赁申请被驳回,请确认相关信息:',
  196. 'official' => [
  197. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  198. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  199. 'data' => [
  200. 'first' => '您有一个订单已被驳回,请注意查看!',
  201. 'keyword1' => $this['created_at'],
  202. 'keyword2' => $type,
  203. 'keyword3' => $status_name,
  204. 'keyword4' => $source,
  205. 'keyword5' => $detail,
  206. 'remark' => '点击进入小程序查看详情,请及时处理。',
  207. ]
  208. ]
  209. ];
  210. } else if($this['status'] == 4) {
  211. return [
  212. 'name' => '租赁时间到期通知',
  213. 'content' => '你有一条设备租赁已到期消息,请确认相关信息:'
  214. ];
  215. } else if($this['status'] == 5) {
  216. return [
  217. 'name' => '租赁完成通知',
  218. 'content' => '你有一条设备租赁已完成消息,请确认相关信息:',
  219. 'official' => [
  220. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  221. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  222. 'data' => [
  223. 'first' => '有一个订单已完成,请注意查看!',
  224. 'keyword1' => $this['created_at'],
  225. 'keyword2' => $type,
  226. 'keyword3' => $status_name,
  227. 'keyword4' => $source,
  228. 'keyword5' => $detail,
  229. 'remark' => '点击进入小程序查看详情。',
  230. ]
  231. ]
  232. ];
  233. }
  234. } else {
  235. $detail = OrderDevice::where('order_id', $order->id)->count() . '个设备';
  236. $type = '设备调用订单';
  237. if($this['status'] == 1) {
  238. return [
  239. 'name' => '调用审批成功通知',
  240. 'content' => '你的设备调用申请已通过,请确认相关信息:',
  241. 'official' => [
  242. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  243. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  244. 'data' => [
  245. 'first' => '您有一个订单已通过审核,请注意查看!',
  246. 'keyword1' => $this['created_at'],
  247. 'keyword2' => $type,
  248. 'keyword3' => $status_name,
  249. 'keyword4' => $source,
  250. 'keyword5' => $detail,
  251. 'remark' => '点击进入小程序查看详情。',
  252. ]
  253. ]
  254. ];
  255. } else if($this['status'] == 2) {
  256. return [
  257. 'name' => '调用审批待处理通知',
  258. 'content' => '你有一条设备调用申请待审批,请确认相关信息:',
  259. 'official' => [
  260. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  261. 'page' => '/pages/create-order-inner/index?id=' . $order->project_id . '&order_id=' . $order->id . '&type=edit',
  262. 'data' => [
  263. 'first' => '您有一条待审核的订单,请注意查看!',
  264. 'keyword1' => $this['created_at'],
  265. 'keyword2' => $type,
  266. 'keyword3' => $status_name,
  267. 'keyword4' => $source,
  268. 'keyword5' => $detail,
  269. 'remark' => '点击进入小程序查看详情,请及时处理。',
  270. ]
  271. ]
  272. ];
  273. } else if($this['status'] == 3) {
  274. return [
  275. 'name' => '调用审批驳回通知',
  276. 'content' => '你有一条设备调用申请被驳回,请确认相关信息:',
  277. 'official' => [
  278. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  279. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  280. 'data' => [
  281. 'first' => '您有一个订单已被驳回,请注意查看!',
  282. 'keyword1' => $this['created_at'],
  283. 'keyword2' => $type,
  284. 'keyword3' => $status_name,
  285. 'keyword4' => $source,
  286. 'keyword5' => $detail,
  287. 'remark' => '点击进入小程序查看详情,请及时处理。',
  288. ]
  289. ]
  290. ];
  291. } else if($this['status'] == 4) {
  292. return [
  293. 'name' => '调用时间到期通知',
  294. 'content' => '你有一条设备调用已到期消息,请确认相关信息:'
  295. ];
  296. } else if($this['status'] == 5) {
  297. return [
  298. 'name' => '调用完成通知',
  299. 'content' => '你有一条设备调用已完成消息,请确认相关信息:',
  300. 'official' => [
  301. 'template_id' => 'dlRsvUWqeziBvGbdT89b69slvZll6gZVRCotIXCwwjM',
  302. 'page' => 'pages/order-detail/index?id=' . $this['order_id'],
  303. 'data' => [
  304. 'first' => '有一个订单已完成,请注意查看!',
  305. 'keyword1' => $this['created_at'],
  306. 'keyword2' => $type,
  307. 'keyword3' => $status_name,
  308. 'keyword4' => $source,
  309. 'keyword5' => $detail,
  310. 'remark' => '点击进入小程序查看详情。',
  311. ]
  312. ]
  313. ];
  314. } else if($this['status'] == 6) {
  315. return [
  316. 'name' => '调用退回通知',
  317. 'content' => '你有一条设备调用已归还消息,请确认相关信息:'
  318. ];
  319. } else if($this['status'] == 7) {
  320. return [
  321. 'name' => '调用修改通知',
  322. 'content' => '你有一条设备调用被修改消息,请确认相关信息:'
  323. ];
  324. }
  325. }
  326. return ['name' => '', 'content' => ''];
  327. }
  328. }