From 0e2fe60253126f69675777a3501071c5176a4739 Mon Sep 17 00:00:00 2001 From: doudou201703 <84085676+doudou201703@users.noreply.github.com> Date: Mon, 10 Aug 2026 22:07:46 +0800 Subject: [PATCH] six_004 --- django_app/业务订单接口.py | 10 +---- django_celery/测试接口.py | 32 -------------- sixGuoDjango/urls.py | 43 +++++++------------ .../小程序用户头像昵称手机号接口.py | 10 ++--- wechat_接口/小程序用户接口/小程序订阅消息.py | 15 +++---- 5 files changed, 28 insertions(+), 82 deletions(-) delete mode 100644 django_celery/测试接口.py diff --git a/django_app/业务订单接口.py b/django_app/业务订单接口.py index 32f1109..e208641 100644 --- a/django_app/业务订单接口.py +++ b/django_app/业务订单接口.py @@ -111,16 +111,11 @@ class 业务订单接口ViewSets(ViewSet): wechat_pay_data = sixWechatPay六果泡泡支付(pay_methon方法="POST", pay_请求体=body, pay_uri=url_pay).getpay_jsapi发起支付() order订单对象 = order订单.objects.create(order支付商家侧订单号=out_trade_no商家侧的订单号, order购物车商品总价=order购物车商品总价, order购物车商品数据=order购物车商品数据, - order购物车商品数量=order购物车商品数量, - order支付数据=body, order支付状态="支付中", - order订单类型=order订单类型, - order用户配送地址=order用户配送地址, - order分享者unionid=share订单分享者ID, - order支付者openid=self_mini_openid, + order购物车商品数量=order购物车商品数量, order支付数据=body, order支付状态="支付中", order订单类型=order订单类型, + order用户配送地址=order用户配送地址, order分享者unionid=share订单分享者ID, order支付者openid=self_mini_openid, order支付者unionid=self_mini_unionid, ) httpResData = BaseResponse(resData=ResData(listData=[""], dictData=wechat_pay_data), ).model_dump() - # httpResData = BaseResponse(resData=ResData(listData=[""], dictData={}), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) @sync_lock_接口线程锁(lock=lock_接口线程锁) # 锁住这个接口所有并发请求, @@ -128,7 +123,6 @@ class 业务订单接口ViewSets(ViewSet): def jsapi支付回调测试接口(self, request: Request) -> Response: """ 微信支付成功后的回调接口 """ wechat_data支付回调数据 = sixWechatPay六果泡泡支付(pay_uri="", pay_请求体={}, pay_methon方法="POST", ).callBack回调解密(headers=request.headers, response_body=request.data) - print("支付的回调数据", wechat_data支付回调数据) out_trade_no商家侧支付订单号 = pydash.get(obj=wechat_data支付回调数据, path="out_trade_no") # 商家侧的订单号 trade_state_desc = pydash.get(obj=wechat_data支付回调数据, path="trade_state_desc") # 支付回调的支付状态 transaction_id = pydash.get(obj=wechat_data支付回调数据, path="transaction_id") diff --git a/django_celery/测试接口.py b/django_celery/测试接口.py deleted file mode 100644 index 66a87d3..0000000 --- a/django_celery/测试接口.py +++ /dev/null @@ -1,32 +0,0 @@ -from django.core.handlers.wsgi import WSGIRequest -from rest_framework import status -from rest_framework.decorators import action -from rest_framework.request import Request -from rest_framework.response import Response -from rest_framework.routers import DefaultRouter -from rest_framework.viewsets import ViewSet - -from django_celery.xiao_queue队列.tasks import taskMessages -from sixGuoDjango import BaseResponse, ResData - - - - - -class Celery测试接口ViewSets( ViewSet ): - - - @action( detail=False, methods=[ "get", "post", "put", "delete" ], url_path="test" ) - def 测试路由接口( self, request: WSGIRequest | Request ): - """""" - taskMessages.delay( token="alkdsfjal;d" ) - taskMessages.apply_async( kwargs={ 'token': 'your_token' }, ) - httpResData = BaseResponse( resData=ResData( listData=[ "" ], dictData={ "demo": "xiaozizi" } ), ).model_dump( ) - return Response( data=httpResData, status=status.HTTP_200_OK ) - - - - - -Celery测试接口ViewSetsRouter = DefaultRouter( ) -Celery测试接口ViewSetsRouter.register( prefix="", viewset=Celery测试接口ViewSets, basename="" ) diff --git a/sixGuoDjango/urls.py b/sixGuoDjango/urls.py index b86a7ee..7957696 100644 --- a/sixGuoDjango/urls.py +++ b/sixGuoDjango/urls.py @@ -1,18 +1,18 @@ """ -URL configuration for sixGuoDjango project. - -The `urlpatterns` list routes URLs to views. For more information please see: - https://docs.djangoproject.com/en/6.0/topics/http/urls/ -Examples: -Function views - 1. Add an import: from my_app import views - 2. Add a URL to urlpatterns: path('', views.home, name='home') -Class-based views - 1. Add an import: from other_app.views import Home - 2. Add a URL to urlpatterns: path('', Home.as_view(), name='home') -Including another URLconf - 1. Import the include() function: from django.urls import include, path - 2. Add a URL to urlpatterns: path('blog/', include('blog.urls')) + URL configuration for sixGuoDjango project. + + The `urlpatterns` list routes URLs to views. For more information please see: + https://docs.djangoproject.com/en/6.0/topics/http/urls/ + Examples: + Function views + 1. Add an import: from my_app import views + 2. Add a URL to urlpatterns: path('', views.home, name='home') + Class-based views + 1. Add an import: from other_app.views import Home + 2. Add a URL to urlpatterns: path('', Home.as_view(), name='home') + Including another URLconf + 1. Import the include() function: from django.urls import include, path + 2. Add a URL to urlpatterns: path('blog/', include('blog.urls')) """ from django.contrib import admin from django.urls import include, path @@ -20,7 +20,6 @@ from django.views.generic import TemplateView from django_app.views import DemoXiaoViewSetsDemoRouter from django_app.业务订单接口 import 业务订单接口ViewSetsViewSetsRouter -from django_celery.测试接口 import Celery测试接口ViewSetsRouter from django_routes.企业微信管理端接口列表 import 企业微信管理端接口列表Router from django_routes.小程序前端页面分享接口列表 import 小程序前端分享页面Router from django_routes.小程序服务端接口管理列表 import 小程序服务端管理接口列表ViewSetsRouter @@ -29,12 +28,9 @@ from django_routes.服务号接口列表 import 服务号接口列表Router from django_routes.桌面端接口列表 import 桌面端企业微信接口ViewSets列表Router from django_web_微信开放平台应用用户登陆.网页端验证文件接口 import 网页端验证文件接口ViewSets from django_wechat_服务号.服务号接收微信code网页授权 import 服务号网页授权接口ViewSets -# from django_定时器.幸运拼团业务模型接口 import 拼团业务接口ViewSetsRouter from wechat_接口.商品订单模拟接口.商品数据接口 import 商品接口ViewSetsRouter from wechat_接口.商品订单模拟接口.订单管理接口 import 订单管理接口ViewSetsRouter -from wechat_接口.小程序用户接口.小程序用户头像昵称手机号接口 import 小程序用户头像昵称接口ViewSetsRouter from wechat_接口.小程序用户接口.小程序用户登陆接口 import 六果科技小程序用户登陆Router -from wechat_接口.小程序用户接口.小程序订阅消息 import miniMsg订阅消息Router from wechat_接口.微信支付接口.代金券相关接口 import 代金券接口ViewSetsRouter from wechat_接口.微信支付接口.商家转账 import six商家转账ViewSetsRouter from wechat_接口.微信支付接口.微信支付测试接口 import 微信支付ViewSetsRouter @@ -51,7 +47,7 @@ urlpatterns = [ path(route="six/", view=include(arg=业务订单接口ViewSetsViewSetsRouter.urls)), path(route="", view=htmlViewSets.as_view({"get": "home"})), # 项目首页 # path( route="lucky/", view=include( arg=拼团业务接口ViewSetsRouter.urls ) ), # 幸运拼团的业务demo接口 - path('robots.txt', TemplateView.as_view(template_name="robots.txt", content_type='text/plain')), + path("robots.txt", TemplateView.as_view(template_name="robots.txt", content_type='text/plain')), # path( 'favicon.ico', TemplateView.as_view( template_name="favicon.ico", content_type='image/x-icon' ) ), # 积分测试接口 path("admin/", admin.site.urls), @@ -66,13 +62,6 @@ urlpatterns = [ # 微信支付测试接口 path(route="demopay/", view=include(arg=微信支付ViewSetsRouter.urls, )), path(route="demopay/", view=include(arg=six商家转账ViewSetsRouter.urls)), - # celery测试接口 - path(route="celery/", view=include(arg=Celery测试接口ViewSetsRouter.urls)), - # 小程序用户头像和昵称接口 - path(route="user/", view=include(arg=小程序用户头像昵称接口ViewSetsRouter.urls)), - path(route="submsg/", view=include(arg=miniMsg订阅消息Router.urls)), - # 企业微信相关的业务逻辑接口 - # 用户角色权限接口 path(route="mini_msg/", view=sixmini.as_view({"get": "api_get", "post": "api_post"})), # 本接口授权,是小程序配置项中, 消息推送的配置 path(route="ryo32y0UxI.txt", view=sixmini.as_view({"get": "web_view_auth"})), # 本接口是对小程序页面中使用web时的域名授权 @@ -99,6 +88,6 @@ urlpatterns = [ # 用户管理后台所有的接口 path(route="web/", view=include(arg=桌面端企业微信接口ViewSets列表Router.urls)), path(route="wechat/", view=include(arg=服务号接口列表Router.urls)), - # 这是验验网站使用 微信登陆的 验证文件接口 + # 这是验验网站使用 微信登陆的 验证文件 接口 path(route="0p7rS8xxjR.txt/", view=网页端验证文件接口ViewSets.as_view({"get": "网页端验证文件接口"})), ] diff --git a/wechat_接口/小程序用户接口/小程序用户头像昵称手机号接口.py b/wechat_接口/小程序用户接口/小程序用户头像昵称手机号接口.py index 1a3ff3b..92af304 100644 --- a/wechat_接口/小程序用户接口/小程序用户头像昵称手机号接口.py +++ b/wechat_接口/小程序用户接口/小程序用户头像昵称手机号接口.py @@ -25,7 +25,7 @@ class 小程序用户头像昵称接口ViewSets(ViewSet): print(self_user_unionid) httpResData = BaseResponse(resData=ResData(listData=[""], dictData={"demo": "xiaozizi"}), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) - + @action(detail=False, methods=["post"], url_path="nickName") def 更新用户昵称(self, request: Request): """""" @@ -35,7 +35,7 @@ class 小程序用户头像昵称接口ViewSets(ViewSet): print("获取到的用户昵称", nickName) httpResData = BaseResponse(resData=ResData(listData=[""], dictData={"demo": "xiaozizi"}), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) - + @action(detail=False, methods=["post"], url_path="getPhoneNumber") def 获取用户手机号码(self, request: Request): """""" @@ -51,7 +51,7 @@ class 小程序用户头像昵称接口ViewSets(ViewSet): print(phoneNumber) httpResData = BaseResponse(resData=ResData(listData=[""], dictData={"phoneNumber": phoneNumber}), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) - + @action(detail=False, methods=["post"], url_path="search") def 查询用户头像和昵称(self, request: Request): """""" @@ -62,7 +62,3 @@ class 小程序用户头像昵称接口ViewSets(ViewSet): print(self_mini_unionid) httpResData = BaseResponse(resData=ResData(listData=[""], dictData=resData), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) - - -小程序用户头像昵称接口ViewSetsRouter = DefaultRouter() -小程序用户头像昵称接口ViewSetsRouter.register(prefix="", viewset=小程序用户头像昵称接口ViewSets, basename="") diff --git a/wechat_接口/小程序用户接口/小程序订阅消息.py b/wechat_接口/小程序用户接口/小程序订阅消息.py index b81ff7f..75c5b35 100644 --- a/wechat_接口/小程序用户接口/小程序订阅消息.py +++ b/wechat_接口/小程序用户接口/小程序订阅消息.py @@ -19,7 +19,7 @@ from wechat_数据库.雪花算法.雪花算法工具 import generator class miniMsg订阅消息(ViewSet): """miniMsg订阅消息工具""" - + @action(detail=False, methods=["post"], url_path="查询服务卡片状态") def 查询服务卡片状态(self, request: WSGIRequest | Request): """ @@ -37,7 +37,7 @@ class miniMsg订阅消息(ViewSet): result_data = post(url=uri, params={"access_token": mini_token}, json=post_data) print(result_data.json()) return Response() - + @action(detail=False, methods=["post"], url_path="gettemplate") def 获取消息列表(self, request: WSGIRequest | Request): """""" @@ -55,7 +55,7 @@ class miniMsg订阅消息(ViewSet): print(orjson.loads(result_data.content.decode(encoding="utf-8"))) httpResData = BaseResponse(resData=ResData(listData=[""], dictData={"demo": "xiaozizi"}), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) - + @action(detail=False, methods=["post"], url_path="sendmsg") def 发送模板消息(self, request: WSGIRequest | Request): """ @@ -86,13 +86,13 @@ class miniMsg订阅消息(ViewSet): result_data = post(url=uri, params={"access_token": mini_token}, json=post_data) print(result_data.json(), "订阅消息发送成功了啦") return Response(data={"msg": "订阅消息"}) - + @action(detail=False, methods=["post"], url_path="add_messages") def 计数订阅成功的次数(self, request: Request): """""" self_mini_openid = request.data.get("self_mini_openid", None) self_mini_unionid = request.data.get("self_mini_unionid", None) - + sub对象, sub对象是否存在 = miniSub订阅消息模板.objects.update_or_create(sub订阅用户ID=self_mini_openid, sub订阅模板ID="RvGf7wyALX4djhBgeIp6jqlfAKNzd_weXRFEd1P54fk", ) @@ -101,6 +101,5 @@ class miniMsg订阅消息(ViewSet): httpResData = BaseResponse(resData=ResData(listData=[""], dictData={"demo": "xiaozizi"}), ).model_dump() return Response(data=httpResData, status=status.HTTP_200_OK) - -miniMsg订阅消息Router = DefaultRouter() -miniMsg订阅消息Router.register(prefix="", viewset=miniMsg订阅消息, basename="") +# miniMsg订阅消息Router = DefaultRouter() +# miniMsg订阅消息Router.register(prefix="", viewset=miniMsg订阅消息, basename="")