正式服配置

app/service/cache.js

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

app/service/task.js

@@ -4,7 +4,7 @@
  * @Author: jd
  * @Date: 2019-02-25 18:59:53
  * @LastEditors  : jd
- * @LastEditTime : 2019-12-24 14:24:06
+ * @LastEditTime : 2019-12-24 14:27:20
  */
 'use strict';
 
@@ -100,19 +100,19 @@ class TaskService extends Service {
   async iplimit() {
     const { ctx, app, ipLimitNum } = this;
     const ip = ctx.request.ip.split(',');
-    // if (ip[0] !== '101.71.242.179' && ip[0] !== '122.224.130.226') {
-    const iplimit = await app.redis.get(ip[0]);
-    if (iplimit) {
-      const { count } = JSON.parse(iplimit);
-      await app.redis.set(ip[0], JSON.stringify({ count }), 'EX', 15 * 3600);
-      ctx.logger.info(`ipLimit ADD ${ip[0]} value:`, count);
-      if (count + 1 > ipLimitNum) {
-        ctx.logger.info(`ipLimit ${ip[0]} MAXLIMIT 创建任务失败`);
-        ctx.throw(400, { message: '创建任务失败' });
-        return;
+    if (ip[0] !== '101.71.242.179' && ip[0] !== '122.224.130.226') {
+      const iplimit = await app.redis.get(ip[0]);
+      if (iplimit) {
+        const { count } = JSON.parse(iplimit);
+        await app.redis.set(ip[0], JSON.stringify({ count }), 'EX', 15 * 3600);
+        ctx.logger.info(`ipLimit ADD ${ip[0]} value:`, count);
+        if (count + 1 > ipLimitNum) {
+          ctx.logger.info(`ipLimit ${ip[0]} MAXLIMIT 创建任务失败`);
+          ctx.throw(400, { message: '创建任务失败' });
+          return;
+        }
       }
     }
-    // }
   }
 
 }

config/config.prod.js

@@ -90,7 +90,7 @@ module.exports = () => {
     taskPrefix: 'URANUS.HF.TASK',
   };
 
-  config.ipLimitNum = 3;
+  config.ipLimitNum = 21;
 
   config.sequelize = {
     datasources: [{