sb

app/service/partner.js

@@ -98,27 +98,30 @@ class PartnerService extends Service {
   // orderId/userId/status
   async notify(order) {
     const { ctx, service } = this;
-    const { orderId, notifyUrl, userId, notice } = order;
-    const dbRes = await service.order.getOneByOrderId({ orderId, notice: 1 });
-    if (!dbRes && notifyUrl && notice !== '1') {
-      const ret = await ctx.curl(notifyUrl, {
-        charset: 'utf-8',
-        timeout: [30000, 30000],
-        contentType: 'json',
-        method: 'POST',
-        data: {
-          order_id: orderId,
-          user_id: userId,
-          status: 'success',
-        },
-      }
-      );
-      ctx.logger.info(`【Partner】 notice ${notifyUrl}`, 'orderId:', orderId, 'result:', ret.status, JSON.stringify(ret.data));
-      if (ret.status === 200) {
-        await order.update({ notice: '1' });
+    try {
+      const { orderId, notifyUrl, userId, notice } = order;
+      const dbRes = await service.order.getOneByOrderId({ orderId, notice: 1 });
+      if (!dbRes && notifyUrl && notice !== '1') {
+        const ret = await ctx.curl(notifyUrl, {
+          charset: 'utf-8',
+          timeout: [30000, 30000],
+          contentType: 'json',
+          method: 'POST',
+          data: {
+            order_id: orderId,
+            user_id: userId,
+            status: 'success',
+          },
+        }
+        );
+        ctx.logger.info(`【Partner】 notice ${notifyUrl}`, 'orderId:', orderId, 'result:', ret.status, JSON.stringify(ret.data));
+        if (ret.status === 200) {
+          await order.update({ notice: '1' });
+        }
       }
+    } catch (err) {
+      ctx.logger.warn('【Partner】 notice error', JSON.stringify(order), JSON.stringify(err));
     }
-    return;
   }
 }