Bladeren bron

修改到docker外运行环境

tags/v1.0.0^2
林万龙 4 jaren geleden
bovenliggende
commit
37ac3fad43
3 gewijzigde bestanden met toevoegingen van 10 en 25 verwijderingen
  1. +1
    -1
      src/main/java/com/telpo/dipperposition/service/IpProvinceService.java
  2. +5
    -20
      src/main/java/com/telpo/dipperposition/service/impl/DipperAstPosAsyncTaskServiceImpl.java
  3. +4
    -4
      src/main/java/com/telpo/dipperposition/service/impl/IpProvinceServiceImpl.java

src/main/java/com/telpo/dipperposition/service/IPProvinceService.java → src/main/java/com/telpo/dipperposition/service/IpProvinceService.java Bestand weergeven

@@ -9,7 +9,7 @@ import com.telpo.dipperposition.vo.IPProvinceVo;
* @author: king * @author: king
* @create: 2020-07-20 11:09 * @create: 2020-07-20 11:09
*/ */
public interface IPProvinceService {
public interface IpProvinceService {


/** /**
* 保存IP省份 * 保存IP省份

+ 5
- 20
src/main/java/com/telpo/dipperposition/service/impl/DipperAstPosAsyncTaskServiceImpl.java Bestand weergeven

@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSONObject;
import com.telpo.dipperposition.common.*; import com.telpo.dipperposition.common.*;
import com.telpo.dipperposition.entity.mongo.IPProvinceEntity; import com.telpo.dipperposition.entity.mongo.IPProvinceEntity;
import com.telpo.dipperposition.service.IDipperAstPosAsyncTaskService; import com.telpo.dipperposition.service.IDipperAstPosAsyncTaskService;
import com.telpo.dipperposition.service.IPProvinceService;
import com.telpo.dipperposition.service.IpProvinceService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -33,7 +33,7 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
@Autowired @Autowired
private OkHttpUtil okHttpUtil; private OkHttpUtil okHttpUtil;
@Autowired @Autowired
private IPProvinceService iPProvinceService;
private IpProvinceService ipProvinceService;


private static IDipperAstPosAsyncTaskService dipperAstPosAsyncTaskService; private static IDipperAstPosAsyncTaskService dipperAstPosAsyncTaskService;
/** /**
@@ -87,9 +87,6 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
} else { } else {
centerProvinceName = centerAddressSetArray[3]; centerProvinceName = centerAddressSetArray[3];
centerProvinceLonAndAlt = centerAddressSetArray[1]+","+centerAddressSetArray[2]; centerProvinceLonAndAlt = centerAddressSetArray[1]+","+centerAddressSetArray[2];
if (redisUtil == null) {
redisUtil = new RedisUtil();
}
redisUtil.set(centerProvinceName, centerProvinceLonAndAlt, 0); redisUtil.set(centerProvinceName, centerProvinceLonAndAlt, 0);
} }
} }
@@ -101,18 +98,12 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
// 关于IP与省份的关系保存到缓存中 // 关于IP与省份的关系保存到缓存中
// 使用时,先在缓存中获取匹配信息 // 使用时,先在缓存中获取匹配信息
// 用mongodb实现 // 用mongodb实现
if(iPProvinceService == null) {
iPProvinceService = new IpProvinceServiceImpl();
}
IPProvinceEntity ipProvinceEntity = iPProvinceService.getIpProvince(ipAddress);
IPProvinceEntity ipProvinceEntity = ipProvinceService.getIpProvince(ipAddress);
if (ipProvinceEntity == null) { if (ipProvinceEntity == null) {
// 匹配不到,再请求高德IP定位服务。 // 匹配不到,再请求高德IP定位服务。
JSONObject userObj = new JSONObject(); JSONObject userObj = new JSONObject();
userObj.put("ip", ipAddress); userObj.put("ip", ipAddress);
userObj.put("key", ipPositionRequestKey); userObj.put("key", ipPositionRequestKey);
if (okHttpUtil == null) {
okHttpUtil = new OkHttpUtil();
}
JSONObject json = okHttpUtil.postRequestWithJson(ipPositionRequestPath, null, userObj); JSONObject json = okHttpUtil.postRequestWithJson(ipPositionRequestPath, null, userObj);
if (ObjectUtils.isNotEmpty(json)) { if (ObjectUtils.isNotEmpty(json)) {
String province = (String) json.get("province"); String province = (String) json.get("province");
@@ -136,15 +127,12 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
public void createIPProvince(String ipAddress, String province) { public void createIPProvince(String ipAddress, String province) {
log.debug("异步创建推送失败任务记录!"); log.debug("异步创建推送失败任务记录!");
try { try {
if(iPProvinceService == null) {
iPProvinceService = new IpProvinceServiceImpl();
}
IPProvinceEntity ipProvinceEntity = iPProvinceService.getIpProvince(ipAddress);
IPProvinceEntity ipProvinceEntity = ipProvinceService.getIpProvince(ipAddress);
if (ipProvinceEntity == null) { if (ipProvinceEntity == null) {
//DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); //DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
ipProvinceEntity.setIp(ipAddress); ipProvinceEntity.setIp(ipAddress);
ipProvinceEntity.setProvince(province); ipProvinceEntity.setProvince(province);
iPProvinceService.saveIpProvince(ipProvinceEntity);
ipProvinceService.saveIpProvince(ipProvinceEntity);
// } else { // } else {
// //
// ipProvinceEntity.setProvince(province); // ipProvinceEntity.setProvince(province);
@@ -182,9 +170,6 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS
} }


String lonAndAlt; String lonAndAlt;
if (redisUtil == null) {
redisUtil = new RedisUtil();
}
if (redisUtil.hasKey(centerAddress)) { if (redisUtil.hasKey(centerAddress)) {
// 获取省会城市定位信息 // 获取省会城市定位信息
lonAndAlt= (String) redisUtil.get(centerAddress); lonAndAlt= (String) redisUtil.get(centerAddress);


+ 4
- 4
src/main/java/com/telpo/dipperposition/service/impl/IpProvinceServiceImpl.java Bestand weergeven

@@ -2,7 +2,7 @@ package com.telpo.dipperposition.service.impl;


import com.telpo.dipperposition.entity.mongo.IPProvinceEntity; import com.telpo.dipperposition.entity.mongo.IPProvinceEntity;
import com.telpo.dipperposition.mapper.IpProvinceMapper; import com.telpo.dipperposition.mapper.IpProvinceMapper;
import com.telpo.dipperposition.service.IPProvinceService;
import com.telpo.dipperposition.service.IpProvinceService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -18,18 +18,18 @@ import java.util.List;
*/ */
@Slf4j @Slf4j
@Service @Service
public class IpProvinceServiceImpl implements IPProvinceService {
public class IpProvinceServiceImpl implements IpProvinceService {


@Autowired @Autowired
private IpProvinceMapper ipProvinceMapper; private IpProvinceMapper ipProvinceMapper;


private static IPProvinceService ipProvinceService;
private static IpProvinceService ipProvinceService;
/** /**
* spring会自动从ioc容器当中根据IPProvinceService类型找到ipProvinceService,当做参数传进来 * spring会自动从ioc容器当中根据IPProvinceService类型找到ipProvinceService,当做参数传进来
* *
*/ */
@Autowired @Autowired
public void setIPProvinceService(IPProvinceService ipProvinceService) {
public void setIPProvinceService(IpProvinceService ipProvinceService) {
this.ipProvinceService = ipProvinceService; this.ipProvinceService = ipProvinceService;
} }
@Override @Override


Laden…
Annuleren
Opslaan