@@ -7,7 +7,7 @@ import lombok.ToString; | |||||
import models.BaseMongoDbEntity; | import models.BaseMongoDbEntity; | ||||
/** | /** | ||||
* @program: IPProvinceEntity | |||||
* @program: IpProvinceEntity | |||||
* @description: 位置实体类 | * @description: 位置实体类 | ||||
* @author: linwl | * @author: linwl | ||||
* @create: 2020-07-11 15:33 | * @create: 2020-07-11 15:33 | ||||
@@ -15,7 +15,7 @@ import models.BaseMongoDbEntity; | |||||
@ToString | @ToString | ||||
@Getter | @Getter | ||||
@Setter | @Setter | ||||
public class IPProvinceEntity extends BaseMongoDbEntity { | |||||
public class IpProvinceEntity extends BaseMongoDbEntity { | |||||
/** Ip */ | /** Ip */ | ||||
private String ip; | private String ip; |
@@ -1,7 +1,7 @@ | |||||
package com.telpo.dipperposition.mapper; | package com.telpo.dipperposition.mapper; | ||||
import com.telpo.dipperposition.annotation.MongoSwitch; | import com.telpo.dipperposition.annotation.MongoSwitch; | ||||
import com.telpo.dipperposition.entity.mongo.IPProvinceEntity; | |||||
import com.telpo.dipperposition.entity.mongo.IpProvinceEntity; | |||||
import db.BaseMongoDbDao; | import db.BaseMongoDbDao; | ||||
import org.springframework.beans.factory.annotation.Autowired; | import org.springframework.beans.factory.annotation.Autowired; | ||||
import org.springframework.stereotype.Repository; | import org.springframework.stereotype.Repository; | ||||
@@ -15,51 +15,51 @@ import java.util.List; | |||||
* @create: 2020-07-20 11:12 | * @create: 2020-07-20 11:12 | ||||
*/ | */ | ||||
@Repository | @Repository | ||||
public class IpProvinceMapper extends BaseMongoDbDao<IPProvinceEntity> { | |||||
public class IpProvinceMapper extends BaseMongoDbDao<IpProvinceEntity> { | |||||
private static IpProvinceMapper ipProvinceMapper; | |||||
// private static IpProvinceMapper ipProvinceMapper; | |||||
/** | /** | ||||
* spring会自动从ioc容器当中根据IPProvinceMapper类型找到iPProvinceMapper, | * spring会自动从ioc容器当中根据IPProvinceMapper类型找到iPProvinceMapper, | ||||
* 当做参数传进来 | * 当做参数传进来 | ||||
* | * | ||||
*/ | */ | ||||
@Autowired | |||||
public void setIPProvinceMapper(IpProvinceMapper ipProvinceMapper) { | |||||
this.ipProvinceMapper = ipProvinceMapper; | |||||
} | |||||
// @Autowired | |||||
// public void setIPProvinceMapper(IpProvinceMapper ipProvinceMapper) { | |||||
// this.ipProvinceMapper = ipProvinceMapper; | |||||
// } | |||||
@Override | @Override | ||||
protected Class<IPProvinceEntity> getEntityClass() { | |||||
return IPProvinceEntity.class; | |||||
protected Class<IpProvinceEntity> getEntityClass() { | |||||
return IpProvinceEntity.class; | |||||
} | } | ||||
@MongoSwitch("common") | @MongoSwitch("common") | ||||
public void saveIp(IPProvinceEntity entity) { | |||||
public void saveIp(IpProvinceEntity entity) { | |||||
this.save(entity); | this.save(entity); | ||||
} | } | ||||
@MongoSwitch("common") | @MongoSwitch("common") | ||||
public void saveIp(IPProvinceEntity entity, String collectionName) { | |||||
public void saveIp(IpProvinceEntity entity, String collectionName) { | |||||
this.save(entity, collectionName); | this.save(entity, collectionName); | ||||
} | } | ||||
@MongoSwitch("common") | @MongoSwitch("common") | ||||
public void updateIpFirst(IPProvinceEntity srcObj, IPProvinceEntity targetObj) { | |||||
public void updateIpFirst(IpProvinceEntity srcObj, IpProvinceEntity targetObj) { | |||||
this.updateFirst(srcObj, targetObj); | this.updateFirst(srcObj, targetObj); | ||||
} | } | ||||
@Override | @Override | ||||
public List<IPProvinceEntity> getPage(IPProvinceEntity object, int start, int size) { | |||||
public List<IpProvinceEntity> getPage(IpProvinceEntity object, int start, int size) { | |||||
return super.getPage(object, start, size); | return super.getPage(object, start, size); | ||||
} | } | ||||
@MongoSwitch("common") | @MongoSwitch("common") | ||||
public List<IPProvinceEntity> queryIpList(IPProvinceEntity object) { | |||||
public List<IpProvinceEntity> queryIpList(IpProvinceEntity object) { | |||||
return this.queryList(object); | return this.queryList(object); | ||||
} | } | ||||
@MongoSwitch("common") | @MongoSwitch("common") | ||||
public List<IPProvinceEntity> queryIpList(IPProvinceEntity object, String collectionName) { | |||||
public List<IpProvinceEntity> queryIpList(IpProvinceEntity object, String collectionName) { | |||||
return this.queryList(object, collectionName); | return this.queryList(object, collectionName); | ||||
} | } | ||||
@@ -1,7 +1,6 @@ | |||||
package com.telpo.dipperposition.service; | package com.telpo.dipperposition.service; | ||||
import com.telpo.dipperposition.entity.mongo.IPProvinceEntity; | |||||
import com.telpo.dipperposition.vo.IPProvinceVo; | |||||
import com.telpo.dipperposition.entity.mongo.IpProvinceEntity; | |||||
import org.springframework.beans.factory.annotation.Autowired; | import org.springframework.beans.factory.annotation.Autowired; | ||||
/** | /** | ||||
@@ -20,7 +19,7 @@ public interface IpProvinceService { | |||||
* @param entity | * @param entity | ||||
* @return | * @return | ||||
*/ | */ | ||||
boolean saveIpProvince(IPProvinceEntity entity); | |||||
boolean saveIpProvince(IpProvinceEntity entity); | |||||
/** | /** | ||||
* 更新IP省份 | * 更新IP省份 | ||||
@@ -30,7 +29,7 @@ public interface IpProvinceService { | |||||
* @return | * @return | ||||
*/ | */ | ||||
boolean updateIPProvince( | boolean updateIPProvince( | ||||
IPProvinceEntity query, IPProvinceEntity update); | |||||
IpProvinceEntity query, IpProvinceEntity update); | |||||
/** | /** | ||||
* 根据ID移除IP省份记录 | * 根据ID移除IP省份记录 | ||||
@@ -44,5 +43,5 @@ public interface IpProvinceService { | |||||
* @param ipAddress | * @param ipAddress | ||||
* 获取IP省份 | * 获取IP省份 | ||||
*/ | */ | ||||
IPProvinceEntity getIpProvince(String ipAddress); | |||||
IpProvinceEntity getIpProvince(String ipAddress); | |||||
} | } |
@@ -2,7 +2,7 @@ package com.telpo.dipperposition.service.impl; | |||||
import com.alibaba.fastjson.JSONObject; | 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; | ||||
@@ -98,7 +98,7 @@ public class DipperAstPosAsyncTaskServiceImpl implements IDipperAstPosAsyncTaskS | |||||
// 关于IP与省份的关系保存到缓存中 | // 关于IP与省份的关系保存到缓存中 | ||||
// 使用时,先在缓存中获取匹配信息 | // 使用时,先在缓存中获取匹配信息 | ||||
// 用mongodb实现 | // 用mongodb实现 | ||||
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(); | ||||
@@ -127,7 +127,7 @@ 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 { | ||||
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); | ||||
@@ -1,6 +1,6 @@ | |||||
package com.telpo.dipperposition.service.impl; | 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; | ||||
@@ -33,14 +33,14 @@ public class IpProvinceServiceImpl implements IpProvinceService { | |||||
this.ipProvinceService = ipProvinceService; | this.ipProvinceService = ipProvinceService; | ||||
} | } | ||||
@Override | @Override | ||||
public boolean saveIpProvince(IPProvinceEntity entity) { | |||||
public boolean saveIpProvince(IpProvinceEntity entity) { | |||||
ipProvinceMapper.saveIp(entity); | ipProvinceMapper.saveIp(entity); | ||||
return true; | return true; | ||||
} | } | ||||
@Override | @Override | ||||
public boolean updateIPProvince( | public boolean updateIPProvince( | ||||
IPProvinceEntity query, IPProvinceEntity update) { | |||||
IpProvinceEntity query, IpProvinceEntity update) { | |||||
ipProvinceMapper.updateIpFirst(query, update); | ipProvinceMapper.updateIpFirst(query, update); | ||||
return true; | return true; | ||||
@@ -54,12 +54,12 @@ public class IpProvinceServiceImpl implements IpProvinceService { | |||||
} | } | ||||
@Override | @Override | ||||
public IPProvinceEntity getIpProvince(String ipAddress) { | |||||
public IpProvinceEntity getIpProvince(String ipAddress) { | |||||
try { | try { | ||||
IPProvinceEntity query = new IPProvinceEntity(); | |||||
IpProvinceEntity query = new IpProvinceEntity(); | |||||
query.setIp(ipAddress); | query.setIp(ipAddress); | ||||
List<IPProvinceEntity> pushRecords = ipProvinceMapper.queryIpList(query); | |||||
List<IpProvinceEntity> pushRecords = ipProvinceMapper.queryIpList(query); | |||||
if (ObjectUtils.isNotEmpty(pushRecords)) { | if (ObjectUtils.isNotEmpty(pushRecords)) { | ||||
return pushRecords.get(0); | return pushRecords.get(0); | ||||
} else { | } else { | ||||