package com.yeshi.location.app.controller.client.api;
|
|
import com.google.gson.*;
|
import com.yeshi.location.app.entity.location.LocationTravel;
|
import com.yeshi.location.app.entity.location.LocationUsers;
|
import com.yeshi.location.app.entity.location.SimpleLocationInfo;
|
import com.yeshi.location.app.entity.location.UserLatestLocation;
|
import com.yeshi.location.app.entity.user.UserInfo;
|
import com.yeshi.location.app.service.inter.location.LocationTravelService;
|
import com.yeshi.location.app.service.inter.location.LocationUsersService;
|
import com.yeshi.location.app.service.inter.location.UserLatestLocationService;
|
import com.yeshi.location.app.service.inter.user.UserInfoService;
|
import com.yeshi.location.app.service.query.location.LocationTravelQuery;
|
import com.yeshi.location.app.utils.Constant;
|
import com.yeshi.location.app.utils.annotation.UserLogin;
|
import com.yeshi.location.app.vo.AcceptAdminData;
|
import com.yeshi.location.app.vo.AcceptData;
|
import com.yeshi.location.app.vo.user.SimpleUserInfo;
|
import net.sf.json.JSONObject;
|
import org.springframework.scheduling.support.SimpleTriggerContext;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.yeshi.utils.JsonUtil;
|
import org.yeshi.utils.StringUtil;
|
import org.yeshi.utils.TimeUtil;
|
|
import javax.annotation.Resource;
|
import java.lang.reflect.Type;
|
import java.util.*;
|
|
/**
|
* @author hxh
|
* @title: UserController
|
* @description: 位置接口
|
* @date 2021/11/16 17:37
|
*/
|
@Controller
|
@RequestMapping("api/v1/location")
|
public class LocationController {
|
|
@Resource
|
private LocationTravelService locationTravelService;
|
|
@Resource
|
private LocationUsersService locationUsersService;
|
|
@Resource
|
private UserLatestLocationService userLatestLocationService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
|
/**
|
* 上传位置
|
*
|
* @param acceptData
|
* @param uid
|
* @param locationInfo
|
* @return
|
*/
|
|
@UserLogin(uid = "#uid")
|
@RequestMapping("uploadLocation")
|
@ResponseBody
|
public String uploadLocation(AcceptData acceptData, Long uid, SimpleLocationInfo locationInfo) {
|
|
LocationTravel locationTravel = new LocationTravel();
|
locationTravel.setUid(uid);
|
locationTravel.setLocation(locationInfo);
|
try {
|
locationTravelService.add(locationTravel);
|
return JsonUtil.loadTrueResult("");
|
} catch (Exception e) {
|
return JsonUtil.loadFalseResult(e.getMessage());
|
}
|
}
|
|
|
/**
|
* 获取最新的位置信息
|
*
|
* @param acceptData
|
* @param uid
|
* @param targetUid
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("getLocation")
|
@ResponseBody
|
public String getLocation(AcceptData acceptData, Long uid, Long targetUid) {
|
|
if (targetUid == null) {
|
targetUid = uid;
|
}
|
|
if (!targetUid.equals(uid)) {
|
LocationUsers users = locationUsersService.selectByUidAndTargetUid(uid, targetUid);
|
if (users == null) {
|
return JsonUtil.loadFalseResult("对方不是您的定位对象");
|
} else if (users.getStatus() != LocationUsers.LocationInviteStatus.agree) {
|
return JsonUtil.loadFalseResult("定位对象尚未同意");
|
}
|
}
|
|
Gson gson = new GsonBuilder().excludeFieldsWithoutExposeAnnotation().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
|
|
@Override
|
public JsonElement serialize(Date date, Type type, JsonSerializationContext jsonSerializationContext) {
|
return date == null ? new JsonPrimitive("") : new JsonPrimitive(TimeUtil.getGernalTime(date.getTime(), "yyyy.MM.dd HH:mm:ss"));
|
}
|
}).create();
|
|
UserLatestLocation location = userLatestLocationService.get(targetUid);
|
if (location == null) {
|
return JsonUtil.loadFalseResult("尚未获取到对方的位置信息");
|
}
|
if (location.getUpdateTime() == null) {
|
location.setUpdateTime(location.getCreateTime());
|
}
|
|
LocationTravelQuery query = new LocationTravelQuery();
|
query.setUid(uid);
|
location.setLocationCount((int) locationTravelService.count(query));
|
return JsonUtil.loadTrueResult(gson.toJson(location));
|
}
|
|
|
/**
|
* 获取定位对象
|
*
|
* @param acceptData
|
* @param uid
|
* @param page
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("getLocationUsers")
|
@ResponseBody
|
public String getLocationUsers(AcceptData acceptData, Long uid, int page) {
|
|
List<LocationUsers> list = locationUsersService.listMyLocationUser(uid, null, null, page, Constant.PAGE_SIZE);
|
if (list != null) {
|
List<Long> uidList = new ArrayList<>();
|
for (LocationUsers u : list) {
|
uidList.add(u.getTargetUid());
|
}
|
|
List<UserInfo> userInfoList = userInfoService.list(uidList);
|
Map<Long, UserInfo> map = new HashMap<>();
|
for (UserInfo user : userInfoList) {
|
map.put(user.getId(), user);
|
}
|
|
for (LocationUsers users : list) {
|
if (map.get(users.getTargetUid()) != null) {
|
users.setUserInfo(SimpleUserInfo.create(map.get(users.getTargetUid())));
|
}
|
}
|
|
|
}
|
|
GsonBuilder gb = new GsonBuilder();
|
gb.excludeFieldsWithoutExposeAnnotation();
|
Gson gson = gb.create();
|
long count = locationUsersService.countMyLocationUser(uid, null);
|
JSONObject data = new JSONObject();
|
data.put("count", count);
|
data.put("list", gson.toJson(list));
|
return JsonUtil.loadTrueResult(data);
|
}
|
|
|
/**
|
* 添加定位对象
|
*
|
* @param acceptData
|
* @param uid
|
* @param phone
|
* @param name
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("addLocationUser")
|
@ResponseBody
|
public String addLocationUser(AcceptData acceptData, Long uid, String phone, String name, LocationUsers.LocationUserType type) {
|
|
UserInfo user = null;
|
if (StringUtil.isMobile(phone)) {
|
user = userInfoService.selectValidByPhone(acceptData.getSystem(), phone);
|
} else {
|
user = userInfoService.get(Long.parseLong(phone));
|
}
|
if (user == null) {
|
return JsonUtil.loadFalseResult("该电话号码/用户ID不存在，请先注册");
|
}
|
|
LocationUsers locationUsers = locationUsersService.selectByUidAndTargetUid(uid, user.getId());
|
if (locationUsers != null) {
|
|
if (locationUsers.getStatus() == LocationUsers.LocationInviteStatus.sentInvite) {
|
return JsonUtil.loadFalseResult("等待对方同意");
|
}
|
|
if (locationUsers.getStatus() == LocationUsers.LocationInviteStatus.reject) {
|
return JsonUtil.loadFalseResult("对方已拒绝");
|
}
|
|
if (locationUsers.getStatus() == LocationUsers.LocationInviteStatus.agree) {
|
return JsonUtil.loadFalseResult("对方已是你的定位对象");
|
}
|
|
}
|
|
locationUsers = new LocationUsers();
|
locationUsers.setUid(uid);
|
locationUsers.setTargetName(name);
|
locationUsers.setTargetUid(user.getId());
|
locationUsers.setTargetPhone(user.getPhone());
|
|
locationUsers.setUserType(type);
|
try {
|
locationUsersService.add(locationUsers);
|
} catch (Exception e) {
|
return JsonUtil.loadFalseResult(e.getMessage());
|
}
|
|
return JsonUtil.loadTrueResult("");
|
}
|
|
|
/**
|
* 删除定位对象
|
*
|
* @param acceptData
|
* @param uid
|
* @param id
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("deleteLocationUser")
|
@ResponseBody
|
public String deleteLocationUser(AcceptData acceptData, Long uid, String id) {
|
|
LocationUsers users = locationUsersService.get(id);
|
if (users == null) {
|
return JsonUtil.loadFalseResult("定位对象不存在");
|
}
|
|
if (users.getUid().longValue() != uid) {
|
return JsonUtil.loadFalseResult("定位对象不存在");
|
}
|
locationUsersService.delete(Arrays.asList(new String[]{id}));
|
return JsonUtil.loadTrueResult("");
|
}
|
|
|
@UserLogin(uid = "#uid")
|
@RequestMapping("updateLocationUser")
|
@ResponseBody
|
public String updateLocationUser(AcceptData acceptData, Long uid, String id, String phone, LocationUsers.LocationUserType type) {
|
|
LocationUsers users = locationUsersService.get(id);
|
if (users == null) {
|
return JsonUtil.loadFalseResult("定位对象不存在");
|
}
|
|
if (users.getUid().longValue() != uid) {
|
return JsonUtil.loadFalseResult("定位对象不存在");
|
}
|
LocationUsers update = new LocationUsers();
|
update.setId(id);
|
update.setUserType(type);
|
if (type != null) {
|
update.setTargetName(type.getName());
|
}
|
update.setTargetPhone(phone);
|
locationUsersService.update(update);
|
return JsonUtil.loadTrueResult("");
|
}
|
|
|
/**
|
* 同意定位邀请
|
*
|
* @param acceptData
|
* @param uid
|
* @param id
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("agreeInviteLocation")
|
@ResponseBody
|
public String agreeInviteLocation(AcceptData acceptData, Long uid, String id) {
|
LocationUsers locationUsers = locationUsersService.get(id);
|
if (locationUsers == null) {
|
return JsonUtil.loadFalseResult("邀请记录不存在");
|
}
|
|
if (!locationUsers.getTargetUid().equals(uid)) {
|
return JsonUtil.loadFalseResult("不属于您的邀请记录");
|
}
|
|
if (locationUsers.getStatus() != LocationUsers.LocationInviteStatus.sentInvite) {
|
return JsonUtil.loadFalseResult("邀请状态错误");
|
}
|
|
LocationUsers update = new LocationUsers();
|
update.setId(id);
|
update.setStatus(LocationUsers.LocationInviteStatus.agree);
|
update.setAccessTime(new Date());
|
locationUsersService.update(update);
|
return JsonUtil.loadTrueResult("");
|
|
}
|
|
/**
|
* 拒绝定位邀请
|
*
|
* @param acceptData
|
* @param uid
|
* @param id
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("rejectInviteLocation")
|
@ResponseBody
|
public String rejectInviteLocation(AcceptData acceptData, Long uid, String id) {
|
LocationUsers locationUsers = locationUsersService.get(id);
|
if (locationUsers == null) {
|
return JsonUtil.loadFalseResult("邀请记录不存在");
|
}
|
|
if (!locationUsers.getTargetUid().equals(uid)) {
|
return JsonUtil.loadFalseResult("不属于您的邀请记录");
|
}
|
|
if (locationUsers.getStatus() != LocationUsers.LocationInviteStatus.sentInvite) {
|
return JsonUtil.loadFalseResult("邀请状态错误");
|
}
|
|
LocationUsers update = new LocationUsers();
|
update.setId(id);
|
update.setStatus(LocationUsers.LocationInviteStatus.reject);
|
update.setRejectTime(new Date());
|
locationUsersService.update(update);
|
return JsonUtil.loadTrueResult("");
|
}
|
|
/**
|
* 获取需要处理的定位邀请
|
*
|
* @param acceptData
|
* @param uid
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("getInviteLocation")
|
@ResponseBody
|
public String getInviteLocation(AcceptData acceptData, Long uid) {
|
List<LocationUsers> list = locationUsersService.listMyLocationUser(null, uid, LocationUsers.LocationInviteStatus.sentInvite, 1, 1);
|
if (list == null || list.size() == 0) {
|
return JsonUtil.loadFalseResult("暂无记录");
|
}
|
return JsonUtil.loadTrueResult(JsonUtil.getApiCommonGson().toJson(list.get(0)));
|
}
|
|
/**
|
* 获取轨迹
|
*
|
* @param acceptData
|
* @param uid
|
* @param targetUid
|
* @return
|
*/
|
@UserLogin(uid = "#uid")
|
@RequestMapping("getTravel")
|
@ResponseBody
|
public String getTravel(AcceptData acceptData, Long uid, Long targetUid, Long startTime, Long endTime, int page) {
|
|
if (targetUid == null) {
|
targetUid = uid;
|
}
|
|
if (!targetUid.equals(uid)) {
|
LocationUsers locationUsers = locationUsersService.selectByUidAndTargetUid(uid, targetUid);
|
if (locationUsers == null || locationUsers.getStatus() != LocationUsers.LocationInviteStatus.agree) {
|
return JsonUtil.loadFalseResult("暂无对方定位权限");
|
}
|
}
|
|
//获取轨迹记录
|
List<LocationTravel> locationTravelList = locationTravelService.getTravelList(targetUid, startTime == null ? null : new Date(startTime), endTime == null ? null : new Date(endTime), page, 100);
|
List<UserLatestLocation> simpleLocationInfoList = new ArrayList<>();
|
if (locationTravelList != null) {
|
for (LocationTravel lt : locationTravelList) {
|
UserLatestLocation location = new UserLatestLocation();
|
location.setLocation(lt.getLocation());
|
location.setUpdateTime(lt.getCreateTime());
|
location.setUid(targetUid);
|
location.setLocationCount(1);
|
simpleLocationInfoList.add(location);
|
}
|
}
|
|
Gson gson = new GsonBuilder().excludeFieldsWithoutExposeAnnotation().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
|
|
@Override
|
public JsonElement serialize(Date date, Type type, JsonSerializationContext jsonSerializationContext) {
|
return date == null ? new JsonPrimitive("") : new JsonPrimitive(TimeUtil.getGernalTime(date.getTime(), "yyyy.MM.dd HH:mm"));
|
}
|
}).create();
|
|
long count = locationTravelService.countTravel(targetUid, startTime == null ? null : new Date(startTime), endTime == null ? null : new Date(endTime));
|
JSONObject data = new JSONObject();
|
data.put("list", gson.toJson(simpleLocationInfoList));
|
data.put("count", count);
|
|
return JsonUtil.loadTrueResult(data);
|
}
|
|
|
}
|
