Python models 模块，Item() 实例源码

def new_item(category):
    if request.method == 'GET':
        return render('newitem.html', category=category)
    elif request.method == 'POST':
        name = request.form['name']
        highlight = request.form['highlight']
        url = request.form['url']
        if valid_item(name, url, highlight):
            user_id = login_session['user_id']
            item = Item(name=name, highlight=highlight, url=url, user_id=user_id, category_id=category.id)
            session.add(item)
            session.commit()
            flash("Newed item %s!" % item.name)
            return redirect(url_for('show_item', category_id=category.id, item_id=item.id))
        else:
            error = "Complete info please!"
            return render('newitem.html', category=category, name=name, highlight=highlight, url=url,
                          error=error)

def fetch(self):
        logging.debug("Fetching google calendar data")
        self.build_service('calendar', 'v3')
        timeMin = self.date_dt.isoformat() + 'Z'
        timeMax = self.next_date_dt.isoformat() + 'Z'
        results = self.service.events().list(calendarId='primary',
                                             maxResults=self.limit,
                                             timeMin=timeMin,
                                             timeMax=timeMax).execute()
        if results:
            items = [
                Item(
                    svc=SERVICE.GCAL,
                    title=r.get('summary'),
                    details=r.get('description'),
                    id=r.get('id'),
                    type=SERVICE.EVENT).json() for r in results.get(
                    'items',
                    [])]
            return items
        return []

def _handle_gmail_message(self, request_id, response, exception):
        if exception is not None:
            logging.error(str(exception))
        else:
            if response:
                headers = response.get('payload').get('headers')
                subject = _from = _to = _date = None
                for h in headers:
                    if h.get('name') == 'Subject':
                        subject = h.get('value')
                    if h.get('name') == 'From':
                        _from = h.get('value')
                    if h.get('name') == 'To':
                        _to = h.get('value')
                    if h.get('name') == 'Date':
                        _date = h.get('value')
                if subject and _from:
                    self.items.append(
                        Item(
                            svc=SERVICE.GMAIL,
                            title=subject,
                            subhead=_from,
                            id=response.get('id'),
                            type=SERVICE.EMAIL).json())

def item_detail(request, item_code):
    from forms import ItemForm
    item = get_object_or_404(Item, code=item_code)
    if request.method=="POST":
        item_form = ItemForm(instance=item, data=request.POST)
        if item_form.is_valid():
            item = item_form.save()
            return redirect(item)
    else:
        item_form = ItemForm(instance=item)

    payload={
                'item':item,
                'item_form':item_form,
                'l_m_storage_active':"active",
             }
    return _render('warehouse/item/detail.html', payload, request)

def item_json(category, item):
    return jsonify(Item=item.serialize)

def fetch(self):
        self.build_service('tasks', 'v1')
        timeMin = self.date_dt.isoformat() + 'Z'
        timeMax = self.next_date_dt.isoformat() + 'Z'
        gt_settings = self.user.get_svc_settings('g_tasks')
        tasklist = gt_settings.get('taskList', {}).get("value")
        if tasklist:
            results = self.service.tasks().list(
                tasklist=tasklist,
                maxResults=self.limit,
                completedMin=timeMin,
                completedMax=timeMax).execute()
            if results:
                logging.debug(results)
                items = [
                    Item(
                        svc=SERVICE.GTASKS,
                        title=r.get('title'),
                        id=r.get('id'),
                        type=SERVICE.TASK).json() for r in results.get(
                        'items',
                        [])]
                return items
        else:
            raise ServiceError("No tasklist configured")
        return []

def fetch(self):
        BATCH_MESSAGES = True
        before_gdate = datetime.strftime(self.next_date_dt, "%Y/%m/%d")
        after_gdate = datetime.strftime(self.date_dt, "%Y/%m/%d")
        self.build_service('gmail', 'v1')
        query = 'before:%s after:%s' % (before_gdate, after_gdate)
        logging.debug(query)
        if BATCH_MESSAGES:
            # Fetch message IDs
            results = self.service.users().messages().list(
                userId='me', maxResults=self.limit, q=query).execute()
            if results:
                ids = [r.get('id') for r in results.get('messages', [])]
                if ids:
                    batch = self.service.new_batch_http_request(
                        callback=self._handle_gmail_message)
                    for id in ids:
                        batch.add(
                            self.service.users().messages().get(
                                id=id, userId="me"), request_id=id)
                    # Blocks, populates self.items
                    batch.execute(http=self.http_auth)
        else:
            # Only threads show snippets in Gmail API?
            results = self.service.users().threads().list(
                userId='me', maxResults=self.limit, fields='threads', q=query).execute()
            if results:
                self.items = [
                    Item(
                        svc=SERVICE.GMAIL,
                        title=r.get('snippet'),
                        id=r.get('id'),
                        type=SERVICE.EMAIL).json() for r in results.get(
                        'threads',
                        [])]
        return self.items

def fetch(self):
        self.build_service('drive', 'v3')
        timeMin = self.date_dt.isoformat()
        timeMax = self.next_date_dt.isoformat()
        query = "(viewedByMeTime > '%s' and viewedByMeTime < '%s') OR (createdTime > '%s' and createdTime < '%s' and '%s' in owners)" % (
            timeMin, timeMax, timeMin, timeMax, self.user.email)
        items = []
        results = self.service.files().list(
            orderBy='modifiedTime',
            pageSize=self.limit,
            spaces='drive,photos',
            fields='files(createdTime,description,id,kind,viewedByMeTime,modifiedTime,name,spaces,webViewLink,thumbnailLink),kind',
            q=query).execute()
        for f in results.get('files', []):
            spaces = f.get('spaces')
            is_image = 'photos' in spaces
            type = SERVICE.DOCUMENT if not is_image else SERVICE.PHOTO
            webViewLink = f.get('webViewLink')
            thumbnailLink = f.get('thumbnailLink')
            item = Item(svc=SERVICE.GDRIVE,
                        title=f.get('name'),
                        id=f.get('id'),
                        image=thumbnailLink,
                        details=f.get('description'),
                        type=type)
            if is_image:
                logging.debug(f)
            items.append(item.json())
        return items

def item_list(request):
    item_list = Item.objects.all()
    return _render('warehouse/item/list.html', {
            'item_list':item_list,
            'l_m_storage_active':"active",
        }, request)