views.py 文件源码

def post(self, request, *args, **kwargs):
        try:
            incoming_message = json.loads(self.request.body.decode('utf-8'))
            for entry in incoming_message['entry']:
                for message in entry['messaging']:
                    if 'message' in message:
                        text =  message['message']['text']
                        psid = message['sender']['id']
                        print(text, psid)
                        try:
                            user = User.objects.get(psid=psid)
                            if user.valid:
                                if user.profile_completed:
                                    analyseMessage.delay(psid, text)
                                else:#get user profile completed
                                    completeProfile.delay(psid, text)
                            else:
                                gotInactiveUser.delay(psid)
                        except Exception as e:
                            # print('\nnew user,, yaaayyye')
                            newUser.delay(psid)
        except Exception as e:
            # print(incoming_message)
            print("Exception: ", e)
        return HttpResponse()