123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- <?php
- namespace app\jobs\notice;
- use app\services\message\SystemMessageServices;
- use crmeb\basic\BaseJobs;
- use crmeb\traits\QueueTrait;
- use think\facade\Log;
- class SystemMsgJob extends BaseJobs
- {
- use QueueTrait;
-
- public function doJob($uid, $noticeInfo, $data, $type = 1)
- {
- if (!$uid || !$noticeInfo) {
- return true;
- }
- try {
- $title = $noticeInfo['system_title'];
- $str = $noticeInfo['system_text'];
- foreach ($data as $key => $item) {
- $str = str_replace('{' . $key . '}', $item, $str);
- $title = str_replace('{' . $key . '}', $item, $title);
- }
- $sdata = [];
- $sdata['mark'] = $noticeInfo['mark'];
- $sdata['uid'] = $uid;
- $sdata['content'] = $str;
- $sdata['title'] = $title;
- $sdata['type'] = $type;
- $sdata['add_time'] = time();
-
- $systemMessageServices = app()->make(SystemMessageServices::class);
- $systemMessageServices->save($sdata);
- } catch (\Throwable $e) {
- Log::error('发送站内信失败,原因:' . $e->getMessage());
- }
- return true;
- }
- }
|