diff --git a/src/main/java/com/ifish/action/UpdateUserAction.java b/src/main/java/com/ifish/action/UpdateUserAction.java index b4f386f..a3063a6 100644 --- a/src/main/java/com/ifish/action/UpdateUserAction.java +++ b/src/main/java/com/ifish/action/UpdateUserAction.java @@ -87,7 +87,7 @@ public class UpdateUserAction { @RequestMapping(value = "/bindDevice.do") @ResponseBody 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) { aliyunDeviceInfo = new AliyunDeviceInfo(); aliyunDeviceInfo.setAliyunDeviceId(deviceId); diff --git a/src/main/java/com/ifish/action/UsersAction.java b/src/main/java/com/ifish/action/UsersAction.java index 23ca1b4..d9b4edd 100644 --- a/src/main/java/com/ifish/action/UsersAction.java +++ b/src/main/java/com/ifish/action/UsersAction.java @@ -62,7 +62,7 @@ public class UsersAction { * @return */ @RequestMapping(value={"/v3/deregister.do","deregister.do"},method=RequestMethod.POST) - public JsonResult deregister(Integer userId) { + public JsonResult deregister(String userId) { return userService.deregister(userId); } diff --git a/src/main/java/com/ifish/service/AliyunDeviceInfoService.java b/src/main/java/com/ifish/service/AliyunDeviceInfoService.java index 174e3c2..4443bc9 100644 --- a/src/main/java/com/ifish/service/AliyunDeviceInfoService.java +++ b/src/main/java/com/ifish/service/AliyunDeviceInfoService.java @@ -9,6 +9,7 @@ import com.ifish.entity.AliyunDeviceInfo; */ public interface AliyunDeviceInfoService { AliyunDeviceInfo getAliyunDeviceInfo(String deviceId); + AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId); void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo); } diff --git a/src/main/java/com/ifish/service/BaseService.java b/src/main/java/com/ifish/service/BaseService.java index 1842d8b..9977795 100644 --- a/src/main/java/com/ifish/service/BaseService.java +++ b/src/main/java/com/ifish/service/BaseService.java @@ -163,6 +163,13 @@ public interface BaseService { */ AliyunDeviceInfo getAliyunDeviceInfo(String deviceId); + /** + * 根据用户ID查询设备信息 + * @param userId + * @return + */ + AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId); + /** * 保存或修改阿里云推送设备信息 * @param aliyunDeviceInfo diff --git a/src/main/java/com/ifish/service/UserService.java b/src/main/java/com/ifish/service/UserService.java index a12d234..b9d1278 100644 --- a/src/main/java/com/ifish/service/UserService.java +++ b/src/main/java/com/ifish/service/UserService.java @@ -87,7 +87,7 @@ public interface UserService { */ public JsonResult register(RegisterParam registerParam); - JsonResult deregister(Integer userId); + JsonResult deregister(String userId); /** * 修改用户信息 diff --git a/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java b/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java index afaae74..d49ac0f 100644 --- a/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java +++ b/src/main/java/com/ifish/serviceImpl/AliyunDeviceInfoServiceImpl.java @@ -3,10 +3,14 @@ package com.ifish.serviceImpl; import com.ifish.dao.AliyunDeviceInfoDao; import com.ifish.entity.AliyunDeviceInfo; 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.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.util.List; + /** * @author: yan.y * @Description: @@ -25,6 +29,13 @@ public class AliyunDeviceInfoServiceImpl implements AliyunDeviceInfoService { return aliyunDeviceInfo; } + @Override + public AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId) { + Criterion criterion = Restrictions.eq("userId", userId); + List deviceInfos = aliyunDeviceInfoDao.findByProperty(criterion); + return deviceInfos.stream().findFirst().get(); + } + @Override public void saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) { this.aliyunDeviceInfoDao.saveOrUpdate(aliyunDeviceInfo); diff --git a/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java b/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java index 16e493b..aaf00d4 100644 --- a/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java +++ b/src/main/java/com/ifish/serviceImpl/BaseServiceImpl.java @@ -2050,6 +2050,11 @@ public class BaseServiceImpl implements BaseService { return this.aliyunDeviceInfoService.getAliyunDeviceInfo(device); } + @Override + public AliyunDeviceInfo getAliyunDeviceInfoByUserId(Integer userId) { + return this.aliyunDeviceInfoService.getAliyunDeviceInfoByUserId(userId); + } + @Override public Object saveOrUpdateAliyunDeviceInfo(AliyunDeviceInfo aliyunDeviceInfo) { this.aliyunDeviceInfoService.saveOrUpdateAliyunDeviceInfo(aliyunDeviceInfo); diff --git a/src/main/java/com/ifish/serviceImpl/UserServiceImpl.java b/src/main/java/com/ifish/serviceImpl/UserServiceImpl.java index 04a087a..2abd55c 100644 --- a/src/main/java/com/ifish/serviceImpl/UserServiceImpl.java +++ b/src/main/java/com/ifish/serviceImpl/UserServiceImpl.java @@ -778,9 +778,9 @@ public class UserServiceImpl implements UserService { } @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){ throw new IfishException(ResultEnum.error402); } diff --git a/src/main/resources/jdbc.properties b/src/main/resources/jdbc.properties index a84edef..ba04334 100644 --- a/src/main/resources/jdbc.properties +++ b/src/main/resources/jdbc.properties @@ -1,4 +1,5 @@ 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\://139.196.24.156\:3306/myfishdb?characterEncoding\=UTF-8 jdbc.username=ifish