From 23f7b250c00597ad89282075460a4c27dffe1ada Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 19 一月 2019 17:39:06 +0800
Subject: [PATCH] Merge branch 'dev-msg'

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/msg/MsgInviteDetailServiceImpl.java |   72 ++++++++++++++++++++++++++++++++++++
 1 files changed, 72 insertions(+), 0 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/MsgInviteDetailServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/MsgInviteDetailServiceImpl.java
new file mode 100644
index 0000000..0b823a8
--- /dev/null
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/msg/MsgInviteDetailServiceImpl.java
@@ -0,0 +1,72 @@
+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 com.yeshi.fanli.dao.mybatis.msg.MsgInviteDetailMapper;
+import com.yeshi.fanli.entity.bus.msg.MsgInviteDetail;
+import com.yeshi.fanli.entity.bus.user.ThreeSale;
+import com.yeshi.fanli.exception.msg.MsgInviteDetailException;
+import com.yeshi.fanli.service.inter.msg.MsgInviteDetailService;
+import com.yeshi.fanli.util.Constant;
+
+@Service
+public class MsgInviteDetailServiceImpl implements MsgInviteDetailService {
+
+	@Resource
+	private MsgInviteDetailMapper msgInviteDetailMapper;
+
+	@Override
+	public void addMsgInviteDetail(MsgInviteDetail detail) throws MsgInviteDetailException {
+		if (detail == null)
+			throw new MsgInviteDetailException(1, "娑堟伅涓虹┖");
+
+		if (detail.getInviteUser() == null || detail.getMsgType() == null || detail.getUser() == null
+				|| detail.getDesc() == null)
+			throw new MsgInviteDetailException(2, "娑堟伅鍐呭涓嶅畬鏁�");
+
+		// 鏌ヨ鏄惁宸插瓨鍦ㄨ閭�璇稩D
+		MsgInviteDetail oldDetail = msgInviteDetailMapper.selectByThreeSaleId(detail.getInviteUser().getId());
+		if (oldDetail == null) {
+			detail.setCreateTime(new Date());
+			detail.setUpdateTime(new Date());
+			detail.setRead(false);
+			msgInviteDetailMapper.insertSelective(detail);
+		} else {
+			MsgInviteDetail update = new MsgInviteDetail();
+			update.setId(oldDetail.getId());
+			if (!detail.getInviteUser().getState()) {
+				if (detail.getInviteUser().getExpire() == ThreeSale.EXPIRE_NORMAL) {
+					update.setDesc("鎭枩浣狅紝鏈夋柊闃熷憳鍔犲叆浣犵殑闃熷垪锛岃嫢瀵规柟60澶╁唴鏈縺娲诲皢浼氫笌浣犺劚绂婚個璇峰叧绯�");
+				} else {
+					update.setDesc("鎶辨瓑锛岃闃熷憳鍥�60澶╁唴鏈縺娲伙紝宸茶劚绂讳簡浣犵殑闃熷垪锛屽彲浠ヨ瘯鐫�閲嶆柊閭�璇�");
+				}
+			} else {
+				update.setDesc("鎭枩浣狅紝鎴愬姛閭�璇蜂竴涓槦鍛�");
+			}
+			update.setUpdateTime(new Date());
+			update.setRead(false);
+			msgInviteDetailMapper.updateByPrimaryKeySelective(update);
+		}
+	}
+
+	@Override
+	public List<MsgInviteDetail> listMsgInviteDetail(Long uid, int page) {
+		return msgInviteDetailMapper.listByUid(uid, (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE);
+	}
+
+	@Override
+	public long countMsgInviteDetail(Long uid) {
+		return msgInviteDetailMapper.countByUid(uid);
+	}
+
+	@Override
+	public void readMsgByUid(Long uid) {
+		msgInviteDetailMapper.setMsgReadByUid(uid);
+	}
+
+}

--
Gitblit v1.8.0