SendMessageTrait.php
2.8 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
<?php
/**
+-----------------------------------------------------------------------------------------------------------------------
* 火警相关操作
+-----------------------------------------------------------------------------------------------------------------------
*
* PHP version 7
*
* @category App\Models\Traits
* @package App\Models\Traits
* @author Richer <yangzi1028@163.com>
* @date 2021年1月29日14:25:55
* @copyright 2020-2022 Richer (http://www.Richer.com/)
* @license http://www.Richer.com/ License
* @link http://www.Richer.com/
*/
namespace App\Models\Traits;
use App;
use App\Models\Warning;
use App\Models\WarningUser;
use App\Models\Lock\LockPassword;
use App\Sms\Sms;
use Illuminate\Support\Collection;
/**
* Trait WarningTrait
*
* @category App\Models\Traits
* @package App\Models\Traits
* @author Richer <yangzi1028@163.com>
* @date 2021年1月29日14:25:55
* @copyright 2020-2022 Richer (http://www.Richer.com/)
* @license http://www.Richer.com/ License
* @link http://www.Richer.com/
*/
trait SendMessageTrait
{
/**
* 发送消息
*
* @param $model
*/
public function sendSms($model)
{
$class = class_basename(get_class($model));
$method = "sendMessageFor" . $class;
if (method_exists($this, $method)) {
$this->{$method}($model);
}
}
/**
* 发送火警消息
*
* @param $model
*/
public function sendMessageForWarning($model)
{
$model->users()->chunkById(100, function ($toUsers) use ($model) {
$collect = new Collection();
foreach ($toUsers as $item) {
$collect->add($item->user);
}
$model->users = $collect;
$sms = app(Sms::class);
foreach ($toUsers as $value) {
$model->user = $value->user;
$result = $sms->pushNotification(Warning::OBJ_NAME, $model);
if ($result) {
$value->result = WarningUser::PROCESSED_SUCCESS;
$value->save();
} else {
$value->result = WarningUser::PROCESSED_FAIL;
$value->remark = $sms->getMessage();
$value->save();
}
}
});
}
/**
* 发送租客开锁密码
*
* @param $model
*/
public function sendMessageForLockPassword($model)
{
app(Sms::class)->pushNotification(LockPassword::OBJ_NAME, $model, 'tenant', 'tenant');
}
/**
* 发送租客开锁密码
*
* @param $model
*/
public function sendSmsForNeedCheckHouse($model)
{
app(Sms::class)->pushNotification(Ho::OBJ_NAME, $model, 'tenant', 'tenant');
}
}