interval cycleImgView send email

controller/AsImg.py

@@ -21,6 +21,7 @@ from object.ResponseObject import ResponseObject
 from object.TokenObject import TokenObject
 from service.CommonService import CommonService
 from object.SesClassObject import SesClassObject
+from object.RedisObject import RedisObject
 
 
 class addView(TemplateView):
@@ -177,6 +178,12 @@ class cycleImgView(TemplateView):
             sys_dict[i['key']] = i['val']
         asimgEmail = sys_dict['asimgEmail']
         asinterval = sys_dict['asinterval']
+        redisObj = RedisObject()
+        redis_asinterval = redisObj.get_data(key='asinterval')
+        if redis_asinterval:
+            return response.json(0, '时候未到呢')
+        else:
+            redisObj.set_data(key='asinterval', val=1, expire=int(asinterval))
         # 校验出的asin码列表
         err_asin_list = []
         for a in as_qs:
@@ -191,10 +198,11 @@ class cycleImgView(TemplateView):
                 else:
                     err_asin_list.append(a['asin'])
         # 发送邮件
-        from var_dump import var_dump
-        var_dump(err_asin_list)
+        # from var_dump import var_dump
+        # var_dump(err_asin_list)
         if len(err_asin_list) > 0:
             sesObj = SesClassObject()
             sesObj.send_email(send_address_list=[asimgEmail], subject='发现亚马逊产品图片丢失', body=','.join(err_asin_list))
+            return response.json(0, {'send_count': len(err_asin_list)})
 
         return response.json(0)

controller/SysSet.py

@@ -20,7 +20,7 @@ from django.views.generic import TemplateView
 from model.models import SysSetModel
 from object.ResponseObject import ResponseObject
 from object.TokenObject import TokenObject
-from service.CommonService import CommonService
+from object.RedisObject import RedisObject
 
 
 class queryView(TemplateView):
@@ -76,12 +76,17 @@ class updateView(TemplateView):
             return response.json(0)
         nowTime = int(time.time())
         tko = TokenObject(token)
+        redisObj = RedisObject()
         if tko.code == 0:
             for i in update_data:
                 sys_qs = SysSetModel.objects.filter(key=i['key'])
                 if sys_qs.exists():
+                    if i['key'] == 'asinterval':
+                        redisObj.set_data(key='asinterval', val=1, expire=int(i['val']))
                     sys_qs.update(val=i['val'], updTime=nowTime)
                 else:
+                    if i['key'] == 'asinterval':
+                        redisObj.set_data(key='asinterval', val=1, expire=int(i['val']))
                     create_dict = {
                         'addTime': nowTime,
                         'updTime': nowTime,