update

src/common/models.py

@@ -611,7 +611,7 @@ class APPVersion(models.Model):
     """                                                                            
     name = models.CharField(u"词条名称", max_length=255, blank=True,null=True)  
     version = models.CharField(u"词条名称", max_length=255, blank=True,null=True)  
-    anroid_url = models.CharField(u"安装包地址", max_length=255, blank=True,null=True)  
+    android_url = models.CharField(u"安装包地址", max_length=255, blank=True,null=True)  
     ios_url = models.CharField(u"安装包地址", max_length=255, blank=True,null=True)  
     force = models.SmallIntegerField(u"0/待发布,1/已发布",default=0)
                                                                                    

src/utils/aliyun_sms.py

@@ -49,6 +49,6 @@ if __name__ == "__main__":
     phone = "15982456282"
     #phone = "13883187629"
     code = "1234"
-    #send_verify_code(phone,code)
-    send_signup_success(phone,u"肖")
+    send_verify_code(phone,code)
+    #send_signup_success(phone,u"肖")
 

src/weixin/control_auth.py

@@ -176,7 +176,6 @@ def get_wxauth_info_v3(request):
     unionid = qdata.get("unionid")
     phone = qdata.get("phone")
     phcode = qdata.get("phcode")
-    orgcode = ccc.cache.get(phone)
 
     user = None
     if openid:

src/weixin/controls.py

@@ -2869,3 +2869,67 @@ def get_baike_detail(**kwargs):
 def get_app_version(request):
     rst = cm.APPVersion.objects.all().order_by("-id").values().first()
     return rst
+
+
+def reply_wanzhu_consult(**kwargs):
+    """
+    """
+    pid = kwargs.get("pid")
+    content = kwargs.get("reply_content")
+    user_id = kwargs.get("user_id")
+    action = kwargs.get("action")
+    if action == "send":
+        user = cm.UserInfo.objects.filter(id=user_id).first()
+        user_name = user.username
+        user_avatar = user.avatar
+
+        obj,flag = cm.Consult.objects.get_or_create(
+            user_id = user_id, 
+        )
+        obj.user_name = user_name
+        obj.user_avatar = user_avatar
+        #obj.reply_content = content
+        obj.view_status = 1
+        obj.reply_status = 0
+        obj.ctime = datetime.datetime.now()
+        obj.save()
+
+        wanzhu_obj = cm.WanzhuConsult.objects.create(
+            user_id = user_id, 
+            user_name = user_name, 
+            user_avatar = user_avatar
+        )
+
+        wanzhu_obj_1 = cm.WanzhuConsult.objects.create(
+            reply_content = content,
+            user_id = 0,
+            player_id = 0,
+            reply_user_id = user_id,
+            pid = wanzhu_obj.id
+        )
+        cm.Consult.objects.filter(user_id=user_id).update(reply_status=1,reply_content=content,ctime=datetime.datetime.now())
+
+
+    else:
+        cm.WanzhuConsult.objects.create(
+            pid = pid, 
+            reply_content = content,
+            user_id = 0,
+            player_id = 0,
+            reply_user_id = user_id
+        )
+        cm.Consult.objects.filter(user_id=user_id).update(reply_status=1,reply_content=content,ctime=datetime.datetime.now())
+    #发送消息提醒
+    if cm.UserInfo.objects.filter(id=user_id).exists():
+        user = cm.UserInfo.objects.filter(id=user_id).first()
+        openid = user.openid
+        username = user.username
+        try:
+            send_consult_reply_message(openid,username)
+        except Exception as e:
+            print(e)
+        #发送app推送消息
+        title = u"顽主杯"
+        body = u"你收到一条顽主的消息"
+        params = {"type":"message","id":str(user_id)}
+        aliyunpush.push_notice_by_userid(user_id,title,body,params)

src/weixin/urls_backstage.py

@@ -87,6 +87,7 @@ urlpatterns = [
     url(r'^v3/baike/detail$', views.BaikeDetailView.as_view()),
     url(r'^v3/authinfo$', views.V3AuthinfoView.as_view()),
     url(r'^v3/app/version$', views.V3APPVersionView.as_view()),
+    url(r'^v3/consult/reply$', views.WanzhuConsultReplyView.as_view()),
 
 ]
 

src/weixin/views.py

@@ -1325,3 +1325,23 @@ class V3APPVersionView(cv.BaseView):
         except Exception as e:
             cv.tracefail()
             return cv.to_fail(e)
+
+
+class WanzhuConsultReplyView(cv.AuthView):
+    def post(self, request):
+        """#顽主咨询回复(平台管理后台)
+        @id:1
+        """
+        qdata = request.json
+        need_params = ["reply_content","user_id"]
+        mse = ccf.check_params(*need_params,**qdata)
+        if mse:
+            raise ce.TipException(mse)
+        try:
+            need_params.extend(["pid","action"])
+            vals = ccf.get_need_params(*need_params,**qdata)
+            rst = ctl.reply_wanzhu_consult(**vals)
+            return cv.to_suc(rst)
+        except Exception as e:
+            cv.tracefail()
+            return cv.to_fail(e)