淘礼金兼容

admin

2021-05-19 a1be6075c6b1365a7abc66bf559d6058039248ab

 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);
         }
   }

}