1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
# coding=utf-8
from __future__ import absolute_import
import requests
import os
import ffmpy
import hashlib
import time
from six.moves import xrange
from celery import shared_task
from django.conf import settings
from gm_types.mimas import IMAGE_TYPE
from gm_upload.utils.image_utils import Picture
from gm_upload import upload_file
from talos.models.tractate import TractateImages
from talos.rpc import logging_exception
from qa.models.answer import AnswerImage, QuestionImage
from qa.cache import ViewRecord
def view_increase_amount(model_name, id_value, count, reverse=False):
for _ in xrange(count):
view_increase(model_name, id_value, reverse)
@shared_task
def view_increase(model_name, id_value, reverse=False):
"""
:param model_name:
:param id_value:
:param reverse: 相反的，做减法
:return:
"""
view = ViewRecord(model_name)
if reverse:
view[id_value] = int(view[id_value] or '1') - 1
else:
view[id_value] = int(view[id_value] or '0') + 1
return view[id_value]
@shared_task
def gif_create_webp(conent_id, content_type):
"""把GIF转成webp格式的图"""
if not conent_id or not content_type:
return
if content_type == "answer":
img_items = AnswerImage.objects.filter(image_type=IMAGE_TYPE.GIF, answer_id=conent_id)
elif content_type == "question":
img_items = QuestionImage.objects.filter(image_type=IMAGE_TYPE.GIF, question_id=conent_id)
elif content_type == "tractate":
img_items = TractateImages.objects.filter(image_type=IMAGE_TYPE.GIF, tractate_id=conent_id)
else:
return
if not img_items:
return
for img_item in img_items:
hash_key = hashlib.md5(str(time.time()).encode("utf8")).hexdigest()
input_path = os.path.join(settings.GIF_CONVERT_PATH, "{}twp.gif".format(hash_key))
output_path = os.path.join(settings.GIF_CONVERT_PATH, '{}twp.webp'.format(hash_key))
img_url = Picture.get_no_watermark_path(img_item.image_url)
res = requests.get(img_url)
# 文件存储到本地
with open(input_path, 'wb') as f:
f.write(res.content)
# 使用底层 FFmpeg 库进行转码
ff = ffmpy.FFmpeg(
inputs={input_path: None},
outputs={output_path: settings.GIF_FF_WEBP}
)
ff.run()
# 上传webP图片
img_item.image_webp = upload_file(output_path)
img_item.save()
if os.path.exists(input_path):
os.remove(input_path)
if os.path.exists(output_path):
os.remove(output_path)