package com.yeshi.location.app.service.impl.location;
|
|
import com.yeshi.location.app.dao.location.LocationTravelDao;
|
import com.yeshi.location.app.dao.location.LocationTravelDao.DaoQuery;
|
import com.yeshi.location.app.entity.location.LocationTravel;
|
import com.yeshi.location.app.entity.location.UserLatestLocation;
|
import com.yeshi.location.app.service.inter.location.LocationTravelService;
|
import com.yeshi.location.app.service.inter.location.UserLatestLocationService;
|
import com.yeshi.location.app.service.query.location.LocationTravelQuery;
|
import com.yeshi.location.app.utils.GeoUtils;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Service;
|
import org.yeshi.utils.bean.BeanUtil;
|
|
import javax.annotation.Resource;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
public class LocationTravelServiceImpl implements LocationTravelService {
|
|
@Resource
|
private LocationTravelDao locationTravelDao;
|
|
@Resource
|
private UserLatestLocationService userLatestLocationService;
|
|
@Override
|
public List<LocationTravel> list(LocationTravelQuery locationTravelQuery, int page, int pageSize) {
|
DaoQuery daoQuery = new DaoQuery();
|
try {
|
BeanUtil.copyProperties(locationTravelQuery, daoQuery);
|
} catch (IllegalAccessException e) {
|
e.printStackTrace();
|
}
|
daoQuery.start = (page - 1) * pageSize;
|
daoQuery.count = pageSize;
|
daoQuery.sortList = Arrays.asList(new Sort.Order[]{Sort.Order.desc("createTime")});
|
return locationTravelDao.list(daoQuery);
|
}
|
|
@Override
|
public long count(LocationTravelQuery locationTravelQuery) {
|
DaoQuery daoQuery = new DaoQuery();
|
try {
|
BeanUtil.copyProperties(locationTravelQuery, daoQuery);
|
} catch (IllegalAccessException e) {
|
e.printStackTrace();
|
}
|
return locationTravelDao.count(daoQuery);
|
}
|
|
@Override
|
public LocationTravel get(String id) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("_id").is(id));
|
return locationTravelDao.findOne(query);
|
}
|
|
@Override
|
public void add(LocationTravel locationTravel) throws Exception {
|
|
if (locationTravel == null || locationTravel.getUid() == null || locationTravel.getLocation() == null || locationTravel.getLocation().getLatitude() == null || locationTravel.getLocation().getLongitude() == null) {
|
throw new Exception("信息不完整");
|
}
|
|
if (locationTravel.getCreateTime() == null) {
|
locationTravel.setCreateTime(new Date());
|
}
|
|
if (locationTravel.getId() == null) {
|
locationTravel.setId(LocationTravel.createId(locationTravel.getUid(), locationTravel.getCreateTime()));
|
}
|
|
|
//获取最新的位置
|
DaoQuery daoQuery = new DaoQuery();
|
daoQuery.uid = locationTravel.getUid();
|
daoQuery.sortList = Arrays.asList(new Sort.Order[]{Sort.Order.desc("createTime")});
|
daoQuery.count = 1;
|
List<LocationTravel> travelList = locationTravelDao.list(daoQuery);
|
if (travelList != null && travelList.size() > 0) {
|
//判断距离
|
if (GeoUtils.getDistance(travelList.get(0).getLocation(), locationTravel.getLocation()) >= 10) {
|
//保存
|
locationTravelDao.save(locationTravel);
|
}
|
} else {
|
locationTravelDao.save(locationTravel);
|
}
|
|
UserLatestLocation latest = new UserLatestLocation();
|
latest.setLocation(locationTravel.getLocation());
|
latest.setUid(locationTravel.getUid());
|
userLatestLocationService.add(latest);
|
}
|
|
@Override
|
public void update(LocationTravel locationTravel) {
|
//更新
|
locationTravelDao.updateSelective(locationTravel);
|
}
|
|
@Override
|
public void delete(List<String> idList) {
|
for (String id : idList) {
|
locationTravelDao.delete(id);
|
}
|
}
|
|
@Override
|
public List<LocationTravel> getTravelList(Long uid, Date startTime, Date endTime, int page, int pageSize) {
|
|
DaoQuery daoQuery = new DaoQuery();
|
daoQuery.minCreateTime = startTime;
|
daoQuery.maxCreateTime = endTime;
|
daoQuery.uid = uid;
|
daoQuery.start = (page - 1) * pageSize;
|
daoQuery.count = pageSize;
|
List<LocationTravel> travelList = locationTravelDao.list(daoQuery);
|
return travelList;
|
}
|
|
@Override
|
public long countTravel(Long uid, Date startTime, Date endTime) {
|
DaoQuery daoQuery = new DaoQuery();
|
daoQuery.minCreateTime = startTime;
|
daoQuery.maxCreateTime = endTime;
|
daoQuery.uid = uid;
|
return locationTravelDao.count(daoQuery);
|
}
|
|
|
}
|
