12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- <?php
- namespace app\jobs\notice;
- use crmeb\basic\BaseJobs;
- use crmeb\services\HttpService;
- use crmeb\traits\QueueTrait;
- use think\facade\Log;
- class EnterpriseWechatJob extends BaseJobs
- {
- use QueueTrait;
-
- public function doJob($data, $url, $ent_wechat_text)
- {
- try {
- $str = $ent_wechat_text;
- foreach ($data as $key => $item) {
- $str = str_replace('{' . $key . '}', $item, $str);
- }
- $s = explode('\n', $str);
- $d = '';
- foreach ($s as $item) {
- $d .= $item . "\n>";
- }
- $d = substr($d, 0, strlen($d) - 2);
- $datas = [
- 'msgtype' => 'markdown',
- 'markdown' => ['content' => $d]
- ];
- HttpService::postRequest($url, json_encode($datas));
- return true;
- } catch (\Throwable $e) {
- Log::error('发送企业群消息失败,失败原因:' . $e->getMessage());
- }
- }
- }
|