mirror of https://github.com/jumpserver/jumpserver
59 lines
2.3 KiB
Python
59 lines
2.3 KiB
Python
|
from rest_framework.views import Response
|
||
|
|
from rest_framework.generics import GenericAPIView
|
||
|
|
from rest_framework.exceptions import APIException
|
||
|
|
from rest_framework import status
|
||
|
|
from django.utils.translation import gettext_lazy as _
|
||
|
|
|
||
|
|
from common.message.backends.sms import SMS_MESSAGE
|
||
|
|
from common.message.backends.sms.alibaba import AlibabaSMS
|
||
|
|
from settings.models import Setting
|
||
|
|
from common.permissions import IsSuperUser
|
||
|
|
from common.exceptions import JMSException
|
||
|
|
|
||
|
|
from .. import serializers
|
||
|
|
|
||
|
|
|
||
|
|
class AlibabaSMSTestingAPI(GenericAPIView):
|
||
|
|
permission_classes = (IsSuperUser,)
|
||
|
|
serializer_class = serializers.AlibabaSMSSettingSerializer
|
||
|
|
|
||
|
|
def post(self, request):
|
||
|
|
serializer = self.serializer_class(data=request.data)
|
||
|
|
serializer.is_valid(raise_exception=True)
|
||
|
|
|
||
|
|
alibaba_access_key_id = serializer.validated_data['ALIBABA_ACCESS_KEY_ID']
|
||
|
|
alibaba_access_key_secret = serializer.validated_data.get('ALIBABA_ACCESS_KEY_SECRET')
|
||
|
|
alibaba_sms_sign_and_tmpl = serializer.validated_data['ALIBABA_SMS_SIGN_AND_TEMPLATES']
|
||
|
|
test_phone = serializer.validated_data.get('SMS_TEST_PHONE')
|
||
|
|
|
||
|
|
if not test_phone:
|
||
|
|
raise JMSException(code='test_phone_required', detail=_('test_phone is required'))
|
||
|
|
|
||
|
|
if not alibaba_access_key_secret:
|
||
|
|
secret = Setting.objects.filter(name='ALIBABA_ACCESS_KEY_SECRET').first()
|
||
|
|
if secret:
|
||
|
|
alibaba_access_key_secret = secret.cleaned_value
|
||
|
|
|
||
|
|
alibaba_access_key_secret = alibaba_access_key_secret or ''
|
||
|
|
|
||
|
|
try:
|
||
|
|
client = AlibabaSMS(
|
||
|
|
access_key_id=alibaba_access_key_id,
|
||
|
|
access_key_secret=alibaba_access_key_secret
|
||
|
|
)
|
||
|
|
sign, tmpl = SMS_MESSAGE.VERIFICATION_CODE.get_sign_and_tmpl(alibaba_sms_sign_and_tmpl)
|
||
|
|
|
||
|
|
client.send_sms(
|
||
|
|
phone_numbers=[test_phone],
|
||
|
|
sign_name=sign,
|
||
|
|
template_code=tmpl,
|
||
|
|
template_param={'code': 'test'}
|
||
|
|
)
|
||
|
|
return Response(status=status.HTTP_200_OK, data={'msg': _('Test success')})
|
||
|
|
except APIException as e:
|
||
|
|
try:
|
||
|
|
error = e.detail['errmsg']
|
||
|
|
except:
|
||
|
|
error = e.detail
|
||
|
|
return Response(status=status.HTTP_400_BAD_REQUEST, data={'error': error})
|