limit

app/service/cache.js

@@ -4,7 +4,7 @@
  * @Author: jd
  * @Date: 2019-02-25 18:59:53
  * @LastEditors  : jd
- * @LastEditTime : 2019-12-21 14:12:18
+ * @LastEditTime : 2019-12-21 14:46:55
  */
 'use strict';
 
@@ -39,7 +39,21 @@ class CacheService extends Service {
     });
     if (order && order.status !== 'success') {
       if (order.appKey === '9FBBA75BBFC24401AA6A76AEFC277346' && value.status === 'login') {
-        ctx.logger.info(`ipLimit ADD ${ctx.request.ip} value:`);
+        const ip = ctx.request.ip.split(',');
+        const iplimit = await app.redis.get(ip);
+        if (!iplimit) {
+          await app.redis.set(ip, JSON.stringify({ count: 1 }), 'EX', 24 * 3600);
+          ctx.logger.info(`ipLimit set ${ip[0]} value:`, 1);
+        } else {
+          const { count } = JSON.parse(iplimit);
+          await app.redis.set(ip, JSON.stringify({ count: count + 1 }), 'EX', 24 * 3600);
+          ctx.logger.info(`ipLimit ADD ${ip[0]} value:`, count + 1);
+          if (count + 1 > 30) {
+            ctx.logger.info(`ipLimit ${ip[0]} MAX30LIMIT 提交任务失败`);
+            ctx.throw(400, { message: '提交任务失败' });
+            return;
+          }
+        }
       }
       await order.update({ ...value });
     } else {