From cf45a1856195bea8e7c9c377d6c708b18b3d3137 Mon Sep 17 00:00:00 2001
From: linwl <304115325@qq.com>
Date: Wed, 20 Jan 2021 20:23:22 +0800
Subject: [PATCH] =?UTF-8?q?mongodb=E8=AE=BF=E9=97=AE=E6=96=B9=E5=BC=8F?=
 =?UTF-8?q?=E5=8F=98=E6=9B=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                                   | 6 ------
 .../service/impl/DipperAstPosAsyncTaskServiceImpl.java    | 8 +++++---
 2 files changed, 5 insertions(+), 9 deletions(-)

diff --git a/pom.xml b/pom.xml
index 56a6dc9..12008e3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -138,12 +138,6 @@
             <version>2.0</version>
         </dependency>
 
-        <dependency>
-            <groupId>com.mongodb</groupId>
-            <artifactId>mongo</artifactId>
-            <version>1.0</version>
-        </dependency>
-
     </dependencies>
 
     <dependencyManagement>
diff --git a/src/main/java/com/telpo/dipperposition/service/impl/DipperAstPosAsyncTaskServiceImpl.java b/src/main/java/com/telpo/dipperposition/service/impl/DipperAstPosAsyncTaskServiceImpl.java
index 3384ab6..d1ea3a1 100644
--- a/src/main/java/com/telpo/dipperposition/service/impl/DipperAstPosAsyncTaskServiceImpl.java
+++ b/src/main/java/com/telpo/dipperposition/service/impl/DipperAstPosAsyncTaskServiceImpl.java
@@ -25,6 +25,7 @@ import java.io.UnsupportedEncodingException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 
 /**
  * @program: DipperAstPosAsyncTaskServiceImpl
@@ -78,7 +79,7 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
                         log.debug("IP省份获取错误，结果为FAIL");
                         return null;
                     }
-                    log.debug("IP省份获取错误，结果为：" + result);
+                    //log.debug("IP省份获取错误，结果为：" + result);
                     JSONObject provinceJson = JSONObject.parseObject(result);
                     String province = (String)provinceJson.get("province");
                     if (ObjectUtils.isEmpty(province)) {
@@ -99,16 +100,17 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
 
     // 将IP对应的省会保存到mongoDB
     public void createIPProvince(String ipAddress, String province) {
-        log.debug("异步创建推送失败任务记录!");
+        log.debug("创建IP省份记录!");
         try {
             IpProvinceEntity ipProvinceEntity = ipProvinceService.getIpProvince(ipAddress);
             if (ipProvinceEntity == null) {
+                ipProvinceEntity = new IpProvinceEntity();
                 ipProvinceEntity.setIp(ipAddress);
                 ipProvinceEntity.setProvince(province);
                 ipProvinceService.saveIpProvince(ipProvinceEntity);
             }
         } catch (Exception e) {
-            log.error("创建推送失败记录异常:", e);
+            log.error("创建IP省份记录异常:", e);
         }
     }