zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test_speaker 接口

This commit is contained in:
曹前明 2022-09-13 10:53:42 +08:00
parent a0f11e8af7
commit 33775bf669
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/develop/views.py
View File

@ -17,6 +17,7 @@ from apps.third.clients import dhClient
from apps.third.models import TDevice
from apps.utils.sms import send_sms
from apps.utils.speech import generate_voice
from apps.third.clients import spClient
from apps.utils.viewsets import CustomGenericViewSet
from apps.utils.wx import wxClient
@ -249,6 +250,12 @@ class TestViewSet(CustomGenericViewSet):
check_not_in_place(Opl.objects.get(id='1568880208688320512'))
return Response()
@action(methods=['post'], detail=False, serializer_class=Serializer)
def test_speaker(self, request, pk=None):
spClient.speak(path='/media/2022/09/11/349b3451-50b9-4501-aded-c85a76967920.mp3', sns=request.data['sns'],
v_num=2)
return Response()
@action(methods=['post'], detail=False, serializer_class=Serializer)
def send_wx_msg(self, request, pk=None):
"""微信模板消息发送测试

10
apps/third/views.py
View File

@ -91,11 +91,11 @@ class XxListener(stomp.ConnectionListener):
print('received a message "%s"' % frame.body)
# if settings.XX_ENABLED:
# c = stomp.Connection([(settings.XX_MQ_HOST, settings.XX_MQ_PORT)])
# c.set_listener('', XxListener())
# c.connect(settings.XX_USERNAME, settings.XX_LICENCE)
# c.subscribe(settings.XX_QUEUE, id='')
if settings.XX_ENABLED:
c = stomp.Connection([(settings.XX_MQ_HOST, settings.XX_MQ_PORT)])
c.set_listener('', XxListener())
c.connect(settings.XX_USERNAME, settings.XX_LICENCE)
c.subscribe(settings.XX_QUEUE, id='')
class XxCommonViewSet(CreateModelMixin, CustomGenericViewSet):