package com.yeshi.fanli.service.impl.money.msg;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
|
import com.yeshi.fanli.dao.mybatis.msg.MsgMoneyDetailMapper;
|
import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail;
|
import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail.MsgTypeMoneyTypeEnum;
|
import com.yeshi.fanli.exception.msg.MsgMoneyDetailException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.money.msg.MsgMoneyDetailService;
|
import com.yeshi.fanli.service.inter.msg.UserMsgReadStateService;
|
import com.yeshi.fanli.util.Constant;
|
|
@Service
|
public class MsgMoneyDetailServiceImpl implements MsgMoneyDetailService {
|
|
@Resource
|
private MsgMoneyDetailMapper msgMoneyDetailMapper;
|
|
@Resource
|
private UserMsgReadStateService userMsgReadStateService;
|
|
@Override
|
public void addMsgMoneyDetail(MsgMoneyDetail detail) throws MsgMoneyDetailException {
|
if (detail == null)
|
throw new MsgMoneyDetailException(1, "消息为空");
|
if (detail.getMsgType() == MsgTypeMoneyTypeEnum.extract) {
|
if (detail.getExtract() == null || detail.getUser() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
MsgMoneyDetail msg = msgMoneyDetailMapper.selectBySourceIdAndMsgType(detail.getExtract().getId(),
|
MsgTypeMoneyTypeEnum.extract);
|
if (msg == null) {
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else {
|
MsgMoneyDetail update = new MsgMoneyDetail();
|
update.setId(msg.getId());
|
update.setUpdateTime(new Date());
|
update.setRead(false);
|
update.setStateDesc(detail.getStateDesc());
|
msgMoneyDetailMapper.updateByPrimaryKeySelective(update);
|
}
|
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.extractValid) {
|
if (detail.getAlipayAccountValid() == null || detail.getUser() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
MsgMoneyDetail msg = msgMoneyDetailMapper.selectBySourceIdAndMsgType(detail.getAlipayAccountValid().getId(),
|
MsgTypeMoneyTypeEnum.extractValid);
|
if (msg == null) {
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else {
|
MsgMoneyDetail update = new MsgMoneyDetail();
|
update.setId(msg.getId());
|
update.setUpdateTime(new Date());
|
update.setRead(false);
|
update.setStateDesc(detail.getStateDesc());
|
msgMoneyDetailMapper.updateByPrimaryKeySelective(update);
|
}
|
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.fanli) {
|
if (detail.getMoney() == null || detail.getGoodsCount() == null || detail.getOrderId() == null
|
|| detail.getBalance() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.invite
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.share) {
|
if (detail.getMoney() == null || detail.getGoodsCount() == null || detail.getOrderCount() == null
|
|| detail.getBalance() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.fanliWeiQuan
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.inviteWeiQuan
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.shareWeiQuan) {
|
if (detail.getMoney() == null || detail.getOrderId() == null || detail.getBalance() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.orderReward) {
|
if (detail.getMoney() == null || detail.getOrderId() == null || detail.getBalance() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.systemEqualize) {
|
if (detail.getMoney() == null || detail.getOrderId() == null || detail.getBalance() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.extractAutoWX) {
|
if (detail.getMoney() == null || detail.getUser() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
|
MsgMoneyDetail msg = msgMoneyDetailMapper.selectBySourceIdAndMsgType(detail.getExtract().getId(),
|
MsgTypeMoneyTypeEnum.extractAutoWX);
|
if (msg == null) {
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
} else {
|
MsgMoneyDetail update = new MsgMoneyDetail();
|
update.setId(msg.getId());
|
update.setUpdateTime(new Date());
|
update.setRead(false);
|
update.setStateDesc(detail.getStateDesc());
|
msgMoneyDetailMapper.updateByPrimaryKeySelective(update);
|
}
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackGiveOff
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackReceiveOff
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackGiveBack
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackExchangePass
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackExchangeReject
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackNewUserReward
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackInviteSucceed
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackFirstSharedOrder
|
|| detail.getMsgType() == MsgTypeMoneyTypeEnum.redPackMonthSharedOrder) {
|
if (detail.getUser() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
|
System.out.println("1-insertSelective执行数据。。。。。。。。。。" + detail.getId());
|
LogHelper.test("1-insertSelective执行数据。。。。。。。。。。" + detail.getId());
|
} else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.subSidy) {
|
if (detail.getMoney() == null || detail.getUser() == null)
|
throw new MsgMoneyDetailException(2, "消息信息不全");
|
detail.setCreateTime(new Date());
|
detail.setUpdateTime(new Date());
|
detail.setRead(false);
|
msgMoneyDetailMapper.insertSelective(detail);
|
}
|
|
userMsgReadStateService.addMoneyMsgUnReadCount(detail.getUser().getId(), 1);
|
System.out.println("1-insertSelective执行数据完成。。。。。。。。。。");
|
LogHelper.test("2-insertSelective执行数据。。。。。。。。。。" + detail.getId());
|
}
|
|
@Override
|
public List<MsgMoneyDetail> listMsgMoneyDetail(Long uid, int page) {
|
return msgMoneyDetailMapper.listByUid(uid, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE);
|
}
|
|
@Override
|
public long countMsgMoneyDetail(Long uid) {
|
return msgMoneyDetailMapper.countByUid(uid);
|
}
|
|
@Override
|
public void readMsgByUid(Long uid) {
|
msgMoneyDetailMapper.setMsgReadByUid(uid);
|
}
|
|
}
|
