From 42411e4a26461229c6bca6e89ca55e98a80f5a4e Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 30 九月 2021 18:08:17 +0800 Subject: [PATCH] bug修改 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/AccountMessageServiceImpl.java | 170 +++++++++++++++++++++++++++----------------------------- 1 files changed, 83 insertions(+), 87 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/AccountMessageServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/AccountMessageServiceImpl.java index 564fbed..d4cfa85 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/AccountMessageServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/AccountMessageServiceImpl.java @@ -1,87 +1,83 @@ -package com.yeshi.fanli.service.impl.user; - -import java.util.List; - -import javax.annotation.Resource; - -import org.hibernate.HibernateException; -import org.hibernate.Session; -import org.springframework.orm.hibernate4.HibernateCallback; -import org.springframework.stereotype.Service; - -import com.yeshi.fanli.dao.mybatis.AccountMessageMapper; -import com.yeshi.fanli.dao.user.UserInfoDao; -import com.yeshi.fanli.entity.bus.user.AccountMessage; -import com.yeshi.fanli.entity.bus.user.UserInfo; -import com.yeshi.fanli.entity.system.SystemZnx; -import com.yeshi.fanli.service.inter.user.AccountMessageService; -import com.yeshi.fanli.service.inter.user.SystemZnxService; -import com.yeshi.fanli.util.Constant; - -@Service -public class AccountMessageServiceImpl implements AccountMessageService { - - @Resource - private AccountMessageMapper accountMessageMapper; - @Resource - private UserInfoDao userInfoDao; - - @Resource - private SystemZnxService systemZnxService; - - @Override - public List<AccountMessage> findAccountMessageList(long uid, int page) { - return accountMessageMapper.listByUidOrderByIdDesc(uid, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE); - } - - @Override - public int getCount(long uid) { - return (int) accountMessageMapper.countByUidAndOpen(uid, null); - - } - - @Override - public void open(long id) { - AccountMessage find = accountMessageMapper.selectByPrimaryKey(id); - if (find != null) { - AccountMessage update = new AccountMessage(); - update.setId(id); - update.setIsOpen(true); - accountMessageMapper.updateByPrimaryKeySelective(update); - } - } - - @Override - public int getCanOpenCount(long uid) { - return (int) accountMessageMapper.countByUidAndOpen(uid, false); - } - - @Override - public void save(AccountMessage accountMessage) { - if (accountMessage != null) - accountMessageMapper.insertSelective(accountMessage); - } - - @SuppressWarnings("unchecked") - @Override - public void syncSystemZnx(long uid) { - UserInfo userInfo = userInfoDao.find(UserInfo.class, uid); - if (userInfo == null) - return; - - List<SystemZnx> list = systemZnxService.listbyUidAndCreateTime(uid, userInfo.getCreatetime()); - - if (list != null) - for (SystemZnx systemZnx : list) { - AccountMessage accountMessage = new AccountMessage(); - accountMessage.setTitle(systemZnx.getTitle()); - accountMessage.setContent(systemZnx.getContent()); - accountMessage.setCreateTime(systemZnx.getCreateTime()); - accountMessage.setIsOpen(false); - accountMessage.setUserInfo(new UserInfo(uid)); - accountMessage.setSystemMsgId(systemZnx.getId()); - save(accountMessage); - } - } - -} +package com.yeshi.fanli.service.impl.user; + +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.stereotype.Service; + +import com.yeshi.fanli.dao.mybatis.AccountMessageMapper; +import com.yeshi.fanli.entity.bus.user.AccountMessage; +import com.yeshi.fanli.entity.bus.user.UserInfo; +import com.yeshi.fanli.entity.system.SystemZnx; +import com.yeshi.fanli.service.inter.user.AccountMessageService; +import com.yeshi.fanli.service.inter.user.SystemZnxService; +import com.yeshi.fanli.service.inter.user.UserInfoService; +import com.yeshi.fanli.util.Constant; + +@Service +public class AccountMessageServiceImpl implements AccountMessageService { + + @Resource + private AccountMessageMapper accountMessageMapper; + @Resource + private UserInfoService userInfoService; + + @Resource + private SystemZnxService systemZnxService; + + @Override + public List<AccountMessage> findAccountMessageList(long uid, int page) { + return accountMessageMapper.listByUidOrderByIdDesc(uid, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE); + } + + @Override + public int getCount(long uid) { + return (int) accountMessageMapper.countByUidAndOpen(uid, null); + + } + + @Override + public void open(long id) { + AccountMessage find = accountMessageMapper.selectByPrimaryKey(id); + if (find != null) { + AccountMessage update = new AccountMessage(); + update.setId(id); + update.setIsOpen(true); + accountMessageMapper.updateByPrimaryKeySelective(update); + } + } + + @Override + public int getCanOpenCount(long uid) { + return (int) accountMessageMapper.countByUidAndOpen(uid, false); + } + + @Override + public void save(AccountMessage accountMessage) { + if (accountMessage != null) + accountMessageMapper.insertSelective(accountMessage); + } + + @Override + public void syncSystemZnx(long uid) { + UserInfo userInfo = userInfoService.selectByPKey(uid); + if (userInfo == null) + return; + + List<SystemZnx> list = systemZnxService.listbyUidAndCreateTime(uid, userInfo.getCreatetime()); + + if (list != null) + for (SystemZnx systemZnx : list) { + AccountMessage accountMessage = new AccountMessage(); + accountMessage.setTitle(systemZnx.getTitle()); + accountMessage.setContent(systemZnx.getContent()); + accountMessage.setCreateTime(systemZnx.getCreateTime()); + accountMessage.setIsOpen(false); + accountMessage.setUserInfo(new UserInfo(uid)); + accountMessage.setSystemMsgId(systemZnx.getId()); + save(accountMessage); + } + } + +} -- Gitblit v1.8.0