Commit 23b3be26 authored by jim's avatar jim

notify

parent b4759f0e
...@@ -6,6 +6,7 @@ import com.edgec.browserbackend.browser.domain.*; ...@@ -6,6 +6,7 @@ import com.edgec.browserbackend.browser.domain.*;
import com.edgec.browserbackend.browser.dto.*; import com.edgec.browserbackend.browser.dto.*;
import com.edgec.browserbackend.browser.repository.IpResourceRepository; import com.edgec.browserbackend.browser.repository.IpResourceRepository;
import com.edgec.browserbackend.browser.service.IpAndShopService; import com.edgec.browserbackend.browser.service.IpAndShopService;
import com.edgec.browserbackend.common.commons.utils.NotifyUtils;
import com.edgec.browserbackend.common.utils.ThreadPoolUtils; import com.edgec.browserbackend.common.utils.ThreadPoolUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -185,13 +186,14 @@ public class BrowserTask { ...@@ -185,13 +186,14 @@ public class BrowserTask {
HttpMethod.GET, entity, IpInfoResultDto.class, "browser", ipResource.getAddr()); HttpMethod.GET, entity, IpInfoResultDto.class, "browser", ipResource.getAddr());
IpInfoResultDto ipInfoResultDto = result.getBody(); IpInfoResultDto ipInfoResultDto = result.getBody();
if (ipInfoResultDto != null && StringUtils.isBlank(ipInfoResultDto.getErrorCode())) { if (ipInfoResultDto != null && StringUtils.isBlank(ipInfoResultDto.getErrorCode())) {
if ( StringUtils.isNotEmpty(ipInfoResultDto.getStatus())) { if (StringUtils.isNotEmpty(ipInfoResultDto.getStatus())) {
ipResource.setStatus(0); ipResource.setStatus(0);
ipResourceRepository.save(ipResource); ipResourceRepository.save(ipResource);
} }
} }
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
NotifyUtils.sendMessage("浏览器后端又炸了,赶紧看啊", NotifyUtils.MsgType.WEBHOOK);
} finally { } finally {
long end = System.currentTimeMillis(); long end = System.currentTimeMillis();
log.debug("queryIpTask {} execution time is: " + (end - start) / 1000 + "s", ipResource.getId()); log.debug("queryIpTask {} execution time is: " + (end - start) / 1000 + "s", ipResource.getId());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment