send_smsModel.php 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139
  1. <?php
  2. //require_once 'include\vendor\autoload.php';
  3. //$path = __DIR__ . \DIRECTORY_SEPARATOR . '..' . \DIRECTORY_SEPARATOR . 'vendor' . \DIRECTORY_SEPARATOR . 'autoload.php';
  4. $path = __DIR__ . \DIRECTORY_SEPARATOR . '..' . \DIRECTORY_SEPARATOR . '..'. \DIRECTORY_SEPARATOR . 'include' . \DIRECTORY_SEPARATOR . 'vendor' . \DIRECTORY_SEPARATOR . 'autoload.php';
  5. if (file_exists($path)) {
  6. require_once $path;
  7. }
  8. //use Darabonba\OpenApi\OpenApiClient;
  9. //use Darabonba\OpenApi\Models\Config;
  10. //use Darabonba\OpenApi\Models\Params;
  11. //use AlibabaCloud\Tea\Utils\Utils\RuntimeOptions;
  12. //use Darabonba\OpenApi\Models\OpenApiRequest;
  13. use AlibabaCloud\SDK\Dysmsapi\V20170525\Dysmsapi;
  14. // use \Exception;
  15. use AlibabaCloud\Tea\Exception\TeaError;
  16. use AlibabaCloud\Tea\Utils\Utils;
  17. use Darabonba\OpenApi\Models\Config;
  18. use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\SendBatchSmsRequest;
  19. use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\SendSmsRequest;
  20. use AlibabaCloud\Tea\Utils\Utils\RuntimeOptions;
  21. // use AliyunClient;
  22. class send_smsClassModel extends Model
  23. {
  24. // 短信模板code
  25. private $templateCode = [
  26. "",
  27. "SMS_467590542", // 会议通知-个人 1
  28. "SMS_467610225", // 会议审批提醒-提醒领导审批 2
  29. "SMS_467510538", // 会议通知-部门 3
  30. "SMS_467595489", // 通知申请人 4
  31. ];
  32. private $sign = "智慧矿山";
  33. public function initModel()
  34. {
  35. }
  36. /**
  37. * 使用AK&SK初始化账号Client
  38. * @return Dysmsapi Client
  39. */
  40. public function createClient(){
  41. // 工程代码泄露可能会导致 AccessKey 泄露,并威胁账号下所有资源的安全性。以下代码示例仅供参考。
  42. // 建议使用更安全的 STS 方式,更多鉴权访问方式请参见:https://help.aliyun.com/document_detail/311677.html。
  43. $accessKeyId = getconfig('ALIBABA_CLOUD_ACCESS_KEY_ID');
  44. $accessKeySecret = getconfig('ALIBABA_CLOUD_ACCESS_KEY_SECRET');
  45. if (empty($accessKeyId) || empty($accessKeySecret)) {
  46. m("log")->addlog("短信错误", "请配置accessKeyId和accessKeySecret");
  47. return null;
  48. }
  49. $config = new Config([
  50. // 必填,请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
  51. "accessKeyId" => $accessKeyId,
  52. // 必填,请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
  53. "accessKeySecret" => $accessKeySecret
  54. ]);
  55. // Endpoint 请参考 https://api.aliyun.com/product/Dysmsapi
  56. $config->endpoint = "dysmsapi.aliyuncs.com";
  57. return new Dysmsapi($config);
  58. }
  59. public function sendBatchSms($phoneArr, $infoArr, $tplCode){
  60. if (empty($phoneArr)||empty($infoArr) || empty($tplCode)) {
  61. m("log")->addlog("短信错误", "参数错误");
  62. return;
  63. }
  64. $client = $this->createClient();
  65. // 签名
  66. for ($i = 0; $i < count($phoneArr); $i++) {
  67. $signArr[] = $this->sign;
  68. }
  69. $dSmsInfo = [
  70. "phoneNumberJson" => json_encode($phoneArr),
  71. "signNameJson" => json_encode($signArr),
  72. "templateCode" => $this->templateCode[$tplCode],
  73. "templateParamJson" => json_encode($infoArr)
  74. ];
  75. m('log')->addlog("短信配置", json_encode($dSmsInfo));
  76. $sendBatchSmsRequest = new SendBatchSmsRequest($dSmsInfo);
  77. $runtime = new RuntimeOptions([]);
  78. try {
  79. // 复制代码运行请自行打印 API 的返回值
  80. $res = $client->sendBatchSmsWithOptions($sendBatchSmsRequest, $runtime);
  81. if ($res->body->code != 'OK') {
  82. m("log")->addlog("短信报错", $res->body->message);
  83. } else {
  84. m("log")->addlog("短信发送", $res->body->message);
  85. }
  86. }
  87. catch (Exception $error) {
  88. m("log")->addlog("短信报错", "错误信息:".$error->message);
  89. }
  90. }
  91. /**
  92. * @param string[] $args
  93. * @return void
  94. */
  95. // public static function test($args){
  96. // $client = self::createClient();
  97. // $sendBatchSmsRequest = new SendBatchSmsRequest([
  98. // "phoneNumberJson" => "[\"15309501557\",\"17701056405\"]",
  99. // "signNameJson" => "[\"智慧矿山\", \"智慧矿山\"]",
  100. // "templateCode" => "SMS_465319645",
  101. // "templateParamJson" => json_encode([["name"=>"张先生","meetdate"=>"2024-04-08", "meetname"=>"周例会", "meetroom"=>"306会议室"], ["name"=>"安全管理部","meetdate"=>"2024-04-08", "meetname"=>"周例会", "meetroom"=>"306会议室"]])
  102. // ]);
  103. // $runtime = new RuntimeOptions([]);
  104. // try {
  105. // // 复制代码运行请自行打印 API 的返回值
  106. // $res = $client->sendBatchSmsWithOptions($sendBatchSmsRequest, $runtime);
  107. // if ($res->body->code != 'OK') {
  108. // m("log")->addlog("短信报错", $res->body->message);
  109. // } else {
  110. // m("log")->addlog("短信发送", $res->body->message);
  111. // }
  112. // }
  113. // catch (Exception $error) {
  114. // m("log")->addlog("短信报错", "错误信息:".$error->message);
  115. // }
  116. // }
  117. }