This commit is contained in:
yiyan 2025-01-05 19:29:40 +08:00
parent 5438a82f8d
commit 8f1b4e8155
9 changed files with 30 additions and 5 deletions

View File

@ -87,7 +87,7 @@ public class UpdateUserAction {
@RequestMapping(value = "/bindDevice.do") @RequestMapping(value = "/bindDevice.do")
@ResponseBody @ResponseBody
public Object bindDevice(@RequestParam String deviceId,@RequestParam Integer userId,@RequestParam String phoneType){ public Object bindDevice(@RequestParam String deviceId,@RequestParam Integer userId,@RequestParam String phoneType){
AliyunDeviceInfo aliyunDeviceInfo = baseService.getAliyunDeviceInfo(deviceId); AliyunDeviceInfo aliyunDeviceInfo = baseService.getAliyunDeviceInfoByUserId(userId);
if (aliyunDeviceInfo == null) { if (aliyunDeviceInfo == null) {
aliyunDeviceInfo = new AliyunDeviceInfo(); aliyunDeviceInfo = new AliyunDeviceInfo();
aliyunDeviceInfo.setAliyunDeviceId(deviceId); aliyunDeviceInfo.setAliyunDeviceId(deviceId);

View File

@ -62,7 +62,7 @@ public class UsersAction {
* @return * @return
*/ */
@RequestMapping(value={"/v3/deregister.do","deregister.do"},method=RequestMethod.POST) @RequestMapping(value={"/v3/deregister.do","deregister.do"},method=RequestMethod.POST)
public JsonResult<?> deregister(Integer userId) { public JsonResult<?> deregister(String userId) {
return userService.deregister(userId); return userService.deregister(userId);
} }

View File

@ -9,6 +9,7 @@ import com.ifish.entity.AliyunDeviceInfo;
*/ */
public interface AliyunDeviceInfoService { public interface AliyunDeviceInfoService {
AliyunDeviceInfo getAliyunDeviceInfo(String deviceId); AliyunDeviceInfo getAliyunDeviceInfo(String deviceId);
AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId);
void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo); void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo);
} }

View File

@ -163,6 +163,13 @@ public interface BaseService {
*/ */
AliyunDeviceInfo getAliyunDeviceInfo(String deviceId); AliyunDeviceInfo getAliyunDeviceInfo(String deviceId);
/**
* 根据用户ID查询设备信息
* @param userId
* @return
*/
AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId);
/** /**
* 保存或修改阿里云推送设备信息 * 保存或修改阿里云推送设备信息
* @param aliyunDeviceInfo * @param aliyunDeviceInfo

View File

@ -87,7 +87,7 @@ public interface UserService {
*/ */
public JsonResult<?> register(RegisterParam registerParam); public JsonResult<?> register(RegisterParam registerParam);
JsonResult<?> deregister(Integer userId); JsonResult<?> deregister(String userId);
/** /**
* 修改用户信息 * 修改用户信息

View File

@ -3,10 +3,14 @@ package com.ifish.serviceImpl;
import com.ifish.dao.AliyunDeviceInfoDao; import com.ifish.dao.AliyunDeviceInfoDao;
import com.ifish.entity.AliyunDeviceInfo; import com.ifish.entity.AliyunDeviceInfo;
import com.ifish.service.AliyunDeviceInfoService; import com.ifish.service.AliyunDeviceInfoService;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Restrictions;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/** /**
* @author: yan.y * @author: yan.y
* @Description: * @Description:
@ -25,6 +29,13 @@ public class AliyunDeviceInfoServiceImpl implements AliyunDeviceInfoService {
return aliyunDeviceInfo; return aliyunDeviceInfo;
} }
@Override
public AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId) {
Criterion criterion = Restrictions.eq("userId", userId);
List<AliyunDeviceInfo> deviceInfos = aliyunDeviceInfoDao.findByProperty(criterion);
return deviceInfos.stream().findFirst().get();
}
@Override @Override
public void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) { public void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) {
this.aliyunDeviceInfoDao.saveOrUpdate(aliyunDeviceInfo); this.aliyunDeviceInfoDao.saveOrUpdate(aliyunDeviceInfo);

View File

@ -2050,6 +2050,11 @@ public class BaseServiceImpl implements BaseService {
return this.aliyunDeviceInfoService.getAliyunDeviceInfo(device); return this.aliyunDeviceInfoService.getAliyunDeviceInfo(device);
} }
@Override
public AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId) {
return this.aliyunDeviceInfoService.getAliyunDeviceInfoByUserId(userId);
}
@Override @Override
public Object saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) { public Object saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) {
this.aliyunDeviceInfoService.saveOrUpdateAliyunDeviceInfo(aliyunDeviceInfo); this.aliyunDeviceInfoService.saveOrUpdateAliyunDeviceInfo(aliyunDeviceInfo);

View File

@ -778,9 +778,9 @@ public class UserServiceImpl implements UserService {
} }
@Override @Override
public JsonResult<?> deregister(Integer userId) { public JsonResult<?> deregister(String userId) {
//用户信息 //用户信息
User user = userDao.get(userId); User user = userDao.get(Integer.parseInt(userId));
if(user==null){ if(user==null){
throw new IfishException(ResultEnum.error402); throw new IfishException(ResultEnum.error402);
} }

View File

@ -1,4 +1,5 @@
jdbc.driver=com.mysql.jdbc.Driver jdbc.driver=com.mysql.jdbc.Driver
#jdbc.url=jdbc\:mysql\://120.55.190.56\:3306/myfishdb?characterEncoding\=UTF-8
jdbc.url=jdbc\:mysql\://localhost\:3306/myfishdb?characterEncoding\=UTF-8 jdbc.url=jdbc\:mysql\://localhost\:3306/myfishdb?characterEncoding\=UTF-8
#jdbc.url=jdbc\:mysql\://139.196.24.156\:3306/myfishdb?characterEncoding\=UTF-8 #jdbc.url=jdbc\:mysql\://139.196.24.156\:3306/myfishdb?characterEncoding\=UTF-8
jdbc.username=ifish jdbc.username=ifish