package com.stylefeng.guns.modular.system.service.impl;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.modular.system.dao.CompanyCityMapper;
|
import com.stylefeng.guns.modular.system.dao.CompanyMapper;
|
import com.stylefeng.guns.modular.system.model.City;
|
import com.stylefeng.guns.modular.system.model.Company;
|
import com.stylefeng.guns.modular.system.model.CompanyCity;
|
import com.stylefeng.guns.modular.system.service.ICityService;
|
import com.stylefeng.guns.modular.system.service.ICompanyCityService;
|
import com.stylefeng.guns.modular.system.util.GDMapGeocodingUtil;
|
import com.stylefeng.guns.modular.system.util.GoogleMap.AddressComponentsVo;
|
import com.stylefeng.guns.modular.system.util.GoogleMap.GoogleMapUtil;
|
import com.stylefeng.guns.modular.system.util.GoogleMap.ReverseGeocodeVo;
|
import com.stylefeng.guns.modular.system.util.RedisUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
|
@Service
|
public class CompanyCityServiceImpl extends ServiceImpl<CompanyCityMapper, CompanyCity> implements ICompanyCityService {
|
|
@Resource
|
private CompanyMapper companyMapper;
|
|
@Autowired
|
private ICityService cityService;
|
|
@Resource
|
private RedisUtil redisUtil;
|
|
|
|
|
@Override
|
public Company query1(Integer uid, String lon, String lat) throws Exception {
|
String tripId = redisUtil.getValue("trip" + uid);
|
ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(Double.valueOf(lat), Double.valueOf(lon), tripId);
|
if(null == reverseGeocode){
|
return null;
|
}
|
AddressComponentsVo[] addressComponentsVos = reverseGeocode.getAddressComponentsVos();
|
String[] citys = new String[addressComponentsVos.length];
|
for (int i = 0; i < addressComponentsVos.length; i++) {
|
citys[i] = addressComponentsVos[i].getLongName();
|
}
|
Company query = this.query(citys);
|
return query;
|
}
|
|
|
|
|
@Override
|
public Company query(String[] city) throws Exception {
|
List<City> cities = cityService.selectList(new EntityWrapper<City>().in("chineseName", Arrays.asList(city)).or()
|
.in("englishName", Arrays.asList(city)).or().in("frenchName", Arrays.asList(city)));
|
List<Integer> collect = cities.stream().map(City::getId).collect(Collectors.toList());
|
if(collect.size() == 0){
|
return null;
|
}
|
return companyMapper.query(collect);
|
}
|
}
|
