package com.yeshi.fanli.service.impl.msg;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dao.mybatis.msg.MsgOtherDetailMapper;
|
import com.yeshi.fanli.entity.bus.msg.MsgExtra;
|
import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail;
|
import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum;
|
import com.yeshi.fanli.exception.msg.MsgOtherDetailException;
|
import com.yeshi.fanli.service.inter.msg.MsgExtraService;
|
import com.yeshi.fanli.service.inter.msg.MsgOtherDetailService;
|
import com.yeshi.fanli.service.inter.msg.UserMsgReadStateService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
|
@Service
|
public class MsgOtherDetailServiceImpl implements MsgOtherDetailService {
|
|
@Resource
|
private MsgOtherDetailMapper msgOtherDetailMapper;
|
|
@Resource
|
private UserMsgReadStateService userMsgReadStateService;
|
|
@Resource
|
private MsgExtraService msgExtraService;
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void addMsgOtherDetail(MsgOtherDetail detail) throws MsgOtherDetailException {
|
if (detail == null || detail.getUser() == null || StringUtil.isNullOrEmpty(detail.getExtraInfo())) {
|
throw new MsgOtherDetailException(1, "消息内容不全");
|
}
|
|
msgOtherDetailMapper.insertSelective(detail);
|
msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_OTHER);
|
userMsgReadStateService.addOtherMsgUnReadCount(detail.getUser().getId(), 1);
|
}
|
|
@Override
|
public void updateMsgOtherDetail(MsgOtherDetail detail) throws MsgOtherDetailException {
|
if (detail.getType() == MsgTypeOtherTypeEnum.couponMianDan
|
|| detail.getType() == MsgTypeOtherTypeEnum.couponReward
|
|| detail.getType() == MsgTypeOtherTypeEnum.couponWelfareMianDan) {
|
if (detail.getId() == null)
|
throw new MsgOtherDetailException(2, "主键为空");
|
if (detail.getCoupnContent() == null)
|
throw new MsgOtherDetailException(1, "内容为空");
|
detail.setContent(new Gson().toJson(detail.getCoupnContent()));
|
if(detail.getUpdateTime()==null)
|
detail.setUpdateTime(new Date());
|
msgOtherDetailMapper.updateByPrimaryKeySelective(detail);
|
}
|
}
|
|
@Override
|
public List<MsgOtherDetail> listMsgOtherDetail(Long uid, int page) {
|
return msgOtherDetailMapper.listByUid(uid, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE);
|
}
|
|
@Override
|
public long countMsgOtherDetail(Long uid) {
|
return msgOtherDetailMapper.countByUid(uid);
|
}
|
|
@Override
|
public void readMsgByUid(Long uid) {
|
msgOtherDetailMapper.setMsgReadByUid(uid);
|
}
|
|
@Override
|
public MsgOtherDetail selectByPrimaryKey(Long id) {
|
return msgOtherDetailMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public void deleteByPrimaryKey(Long id) {
|
msgOtherDetailMapper.deleteByPrimaryKey(id);
|
msgExtraService.deleteByPidAndType(id, MsgExtra.MSG_TYPE_OTHER);
|
}
|
}
|
