From f57554f7da5e4d05b4b4bab99bf49ac9ca8c2038 Mon Sep 17 00:00:00 2001
From: jyy <935090232@qq.com>
Date: Fri, 15 Apr 2022 21:35:12 +0800
Subject: [PATCH] feat:商品资料导出新增时长字段

---
 zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysVipInfoServiceImpl.java |  190 ++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 144 insertions(+), 46 deletions(-)

diff --git a/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysVipInfoServiceImpl.java b/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysVipInfoServiceImpl.java
index 30e4893..0515e39 100644
--- a/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysVipInfoServiceImpl.java
+++ b/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysVipInfoServiceImpl.java
@@ -3,7 +3,10 @@
 import com.matrix.core.constance.MatrixConstance;
 import com.matrix.core.exception.GlobleException;
 import com.matrix.core.pojo.PaginationVO;
-import com.matrix.core.tools.*;
+import com.matrix.core.tools.DateUtil;
+import com.matrix.core.tools.EncrypUtil;
+import com.matrix.core.tools.StringUtils;
+import com.matrix.core.tools.WebUtil;
 import com.matrix.core.tools.excl.ExcelSheetPO;
 import com.matrix.core.tools.excl.ExcelUtil;
 import com.matrix.system.app.dto.AddVipDto;
@@ -11,9 +14,10 @@
 import com.matrix.system.app.dto.VipInfoListDto;
 import com.matrix.system.app.vo.VipInfoDetailVo;
 import com.matrix.system.app.vo.VipInfoListVo;
+import com.matrix.system.common.bean.BusParameterSettings;
 import com.matrix.system.common.bean.SysUsers;
+import com.matrix.system.common.dao.BusParameterSettingsDao;
 import com.matrix.system.common.tools.DataAuthUtil;
-import com.matrix.system.common.tools.PasswordUtil;
 import com.matrix.system.common.tools.ServiceUtil;
 import com.matrix.system.constance.Dictionary;
 import com.matrix.system.constance.TableMapping;
@@ -23,7 +27,11 @@
 import com.matrix.system.hive.plugin.util.CollectionUtils;
 import com.matrix.system.hive.pojo.VipInfoVo;
 import com.matrix.system.hive.service.SysVipInfoService;
+import com.matrix.system.score.constant.ScoreSettingConstant;
+import com.matrix.system.score.entity.ScoreVipDetail;
+import com.matrix.system.score.service.ScoreVipDetailService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -60,13 +68,28 @@
 	@Autowired
 	private SysVipLabelDao sysVipLabelDao;
 
+	@Value("${default.vip.photo.woman}")
+	String defaultWoman;
+
+	@Value("${default.vip.photo.man}")
+	String defaultMan;
+	@Autowired
+	BusParameterSettingsDao busParameterSettingsDao;
+
+	@Autowired
+	ScoreVipDetailService scoreVipDetailService;
+
+	@Autowired
+	private SysOrderDao sysOrderDao;
+
+
 	/**
 	 * 新增会员储值卡
 	 * @param vipId
 	 * @return
 	 */
 	@Override
-	public  int addVipDefaultCard(Long vipId){
+	public MoneyCardUse addVipDefaultCard(Long vipId){
 		MoneyCardUse defaultCardUse=new MoneyCardUse();
 		defaultCardUse.setVipId(vipId);
 		defaultCardUse.setCardName("储值卡");
@@ -75,17 +98,18 @@
 		defaultCardUse.setGiftMoney(0D);
 		defaultCardUse.setSource("-");
 		defaultCardUse.setStatus(Dictionary.MONEYCARD_STATUS_YX);
-		return  moneyCardUseDao.insert(defaultCardUse);
+		moneyCardUseDao.insert(defaultCardUse);
+		return  defaultCardUse;
 
 	}
 
 	@Override
 	public int add(SysVipInfo sysVipInfo) {
-		SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
+
 
 		if (sysVipInfo.getVipNo() != null && (!sysVipInfo.getVipNo().equals(""))) {
 			if (serviceUtil.addCheckRepeatTowColumn(TableMapping.SYS_VIP_INFO, "VIP_NO", sysVipInfo.getVipNo(),
-					"company_id",user.getCompanyId())) {
+					"company_id",sysVipInfo.getCompanyId())) {
 				throw new GlobleException("编号已存在!");
 			}
 		}
@@ -94,20 +118,26 @@
 				throw new GlobleException("请输入手机号!");
 			}
 			if (serviceUtil.addCheckRepeatTowColumn(TableMapping.SYS_VIP_INFO, "PHONE", sysVipInfo.getPhone(),
-					"company_id",user.getCompanyId() )) {
-				throw new GlobleException("手机已被注册!");
+					"company_id",sysVipInfo.getCompanyId() )) {
+				throw new GlobleException(sysVipInfo.getPhone()+"手机已被注册!");
 			}
 		}
-
-
-		sysVipInfo.setShopId(user.getShopId());
-		sysVipInfo.setCompanyId(user.getCompanyId());
+		SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
+		if(user!=null){
+			sysVipInfo.setCompanyId(user.getCompanyId());
+		}
 		sysVipInfo.setCreateTime(new Date());
 		sysVipInfo.setPointAll(0);
 		sysVipInfo.setIsDeal(SysVipInfo.UNDEAL_VIP);
-		sysVipInfo.setZjm(StringUtils.toHanyuPinyin(sysVipInfo.getVipName())+","+StringUtils.toHeadWordHanyuPinyin(sysVipInfo.getVipName()));
+		if(StringUtils.isNotBlank(sysVipInfo.getVipName())){
+			sysVipInfo.setZjm(StringUtils.toHanyuPinyin(sysVipInfo.getVipName())+","+StringUtils.toHeadWordHanyuPinyin(sysVipInfo.getVipName()));
+		}
+		if(Dictionary.SEX_MAN.equals(sysVipInfo.getSex())){
+			sysVipInfo.setPhoto(defaultMan);
+		}else{
+			sysVipInfo.setPhoto(defaultWoman);
+		}
 		int i=sysVipInfoDao.insert(sysVipInfo);
-		modifyVipWithOtherInfo(sysVipInfo);
 		//创建用户默认储值卡
 		addVipDefaultCard(sysVipInfo.getId());
 		return i;
@@ -199,8 +229,7 @@
 
 	@Override
 	public List<SysVipInfo> findByVipNoOrTel(String key) {
-		SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
-		return sysVipInfoDao.selectByVipNoOrTel(key, users.getShopId());
+		return sysVipInfoDao.selectByVipNoOrTel(key);
 
 	}
 
@@ -242,31 +271,7 @@
 		}
 		
 		
-        //如果会员id不为空则表示是修改,删除原有的绑定关系,建立新的关系
-         if(vipInfo.getId()!=null && !vipInfo.getId().equals("")){
-	         MyBeatician query=new MyBeatician();
-	         query.setVipId(vipInfo.getId());
-	         List<MyBeatician> listDel= myBeaticianDao.selectByModel(query);
-	         if(listDel!=null && listDel.size()>0){
-	         List<Long> delIds=new ArrayList<>();
-		         for (int i = 0; i < listDel.size(); i++) {
-					delIds.add(listDel.get(i).getId());
-				 }
-	         myBeaticianDao.deleteByIds(delIds);
-             }
-         }
-         //添加客户的美疗师
- 		List<MyBeatician> list=vipInfo.getBeauticains();
- 		if(list!=null && list.size()>0){
- 			List<MyBeatician> saveList=new ArrayList<>();
- 			//此处由于前台传递过来list中的下标可能是不连续的。因此要过滤掉空的,即要过滤掉美疗师的id为空的数据
- 			for (MyBeatician temp:list) {
- 				if(temp.getBeauticainId()!=null && !temp.getBeauticainId().equals("")){
- 					saveList.add(temp);
- 				   }
- 				}
- 			myBeaticianDao.insertAll(saveList,vipInfo.getId());
-			}
+
  			
 	}
 	
@@ -281,8 +286,8 @@
 
 	@Override
 	public List<SysVipInfo> findUserByKey(String keyWord) {
-		SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
-		return sysVipInfoDao.selectUserByKey(keyWord, users.getShopId());
+		SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
+		return sysVipInfoDao.selectUserByKey(keyWord,user.getCompanyId());
 	}
 	
 
@@ -338,6 +343,11 @@
 		SysUsers users = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY);
 		sysVipInfo.setCompanyId(users.getCompanyId());
 		sysVipInfo.setShopId(users.getShopId());
+		if(sysVipInfo.getSex().equals(Dictionary.SEX_MAN)){
+			sysVipInfo.setPhoto(defaultMan);
+		}else{
+			sysVipInfo.setPhoto(defaultWoman);
+		}
 		int i=sysVipInfoDao.insert(sysVipInfo);
 		modifyVipWithOtherInfo(sysVipInfo);
 		return i;
@@ -396,7 +406,7 @@
 					SysVipInfo vipInfo = new SysVipInfo();
 					vipInfo.setVipNo(objects.get(0).toString());
 
-					SysVipInfo exist = sysVipInfoDao.selectByPhone(objects.get(3).toString());
+					SysVipInfo exist = sysVipInfoDao.selectByPhone(objects.get(3).toString(),sysUsers.getCompanyId());
 					if (exist != null) {
 						continue;
 					}
@@ -422,8 +432,9 @@
 
 	@Override
 	public List<VipInfoListVo> findVipAddressBook(VipInfoListDto vipInfoListDto) {
+		//todo 会员查询单独做控制
 		SysUsers sysUsers = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
-		if (!DataAuthUtil.hasAllShopAuth()) {
+		if (!DataAuthUtil.hasAllCustomerAuth()) {
 			vipInfoListDto.setShopId(sysUsers.getShopId());
 		}
 		QueryUtil.setQueryLimitCom(vipInfoListDto);
@@ -432,10 +443,13 @@
 
 	@Override
 	public com.matrix.system.app.vo.VipInfoVo findApiVipInfoById(Long id) {
-		return sysVipInfoDao.selectVipInfoById(id);
+		com.matrix.system.app.vo.VipInfoVo result = sysVipInfoDao.selectVipInfoById(id);
+		result.setArrears(sysOrderDao.selectArrearsByVipId(id));
+		return result;
 	}
 
 	@Override
+	@Transactional
 	public int apiAddVip(AddVipDto addVipDto) {
 		SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
 
@@ -484,15 +498,69 @@
 		vipInfo.setPointAll(0);
 		vipInfo.setIsDeal(SysVipInfo.UNDEAL_VIP);
 		vipInfo.setZjm(StringUtils.toHanyuPinyin(vipInfo.getVipName())+","+StringUtils.toHeadWordHanyuPinyin(vipInfo.getVipName()));
+		if(vipInfo.getSex().equals(Dictionary.SEX_MAN)){
+			vipInfo.setPhoto(defaultMan);
+		}else{
+			vipInfo.setPhoto(defaultWoman);
+		}
 		int i=sysVipInfoDao.insert(vipInfo);
 
 		if (CollectionUtils.isNotEmpty(addVipDto.getLabels())) {
 			batchInsertLabel(addVipDto.getLabels(), vipInfo.getId());
 		}
+		//添加推荐人积分
+		addReferrerVipScore(vipInfo);
 
 		//创建用户默认储值卡
 		addVipDefaultCard(vipInfo.getId());
 		return i;
+	}
+
+	/**
+	 * 添加推荐人积分
+	 * @param vipInfo
+	 */
+	public void addReferrerVipScore(SysVipInfo vipInfo) {
+		if(vipInfo.getRecommendId()!=null){
+			SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
+			BusParameterSettings referrerScoreSetting = busParameterSettingsDao.selectCompanyParamByCode(ScoreSettingConstant.REFERRALS_CONSUMPTION, user.getCompanyId());
+			//推荐注册老带新积分奖励
+			SysVipInfo referrerVip = sysVipInfoDao.selectById(vipInfo.getRecommendId());
+
+			if(StringUtils.isNotBlank(referrerScoreSetting.getParamValue())){
+
+				scoreVipDetailService.addScore(
+						referrerVip.getId(),
+						user.getSuId(),
+						vipInfo.getShopId(),
+						Integer.parseInt(referrerScoreSetting.getParamValue()),
+						vipInfo.getId(),
+						ScoreVipDetail.SCORE_VIP_TYPE_REFERRER,
+						"推荐会员"
+						);
+			}
+
+			//推荐注册二级带新积分奖励
+
+			if(referrerVip.getRecommendId()!=null){
+
+				SysVipInfo topVipInfo = sysVipInfoDao.selectById(referrerVip.getRecommendId());
+
+
+				if(StringUtils.isNotBlank(referrerScoreSetting.getParamValue1())){
+					scoreVipDetailService.addScore(
+							topVipInfo.getId(),
+							user.getSuId(),
+							vipInfo.getShopId(),
+							Integer.parseInt(referrerScoreSetting.getParamValue1()),
+							vipInfo.getId(),
+							ScoreVipDetail.SCORE_VIP_TYPE_REFERRER,
+							"间接推荐会员"
+					);
+				}
+			}
+
+		}
 	}
 
 	@Override
@@ -585,4 +653,34 @@
 		vipInfoDetailVo.setLabels(labels);
 		return vipInfoDetailVo;
 	}
+
+	@Override
+	public SysVipInfo findByOpenId(String openId) {
+		return sysVipInfoDao.findByOpenId(openId);
+	}
+
+	/**
+	 * 设置成为推广员
+	 * @param invitationId
+	 */
+	@Override
+	public int setToBeAnSalesman(Long userId,Long invitationId,long gradeId) {
+		SysVipInfo sysVipInfo=sysVipInfoDao.selectById(userId);
+		sysVipInfo.setIsSales(SysVipInfo.IS_SALES);
+		sysVipInfo.setRecommendId(invitationId);
+		sysVipInfo.setBindingParentTime(new Date());
+		sysVipInfo.setSalesmanGrade(gradeId);
+		return sysVipInfoDao.update(sysVipInfo);
+	}
+
+
+	@Override
+	public List<Map<String, Object>> findVipArrearsStatistics(SysVipInfo sysVipInfo, PaginationVO pageVo) {
+		return sysVipInfoDao.selectVipArrearsStatistics(sysVipInfo, pageVo);
+	}
+
+	@Override
+	public Integer findVipArrearsStatisticsTotal(SysVipInfo sysVipInfo) {
+		return sysVipInfoDao.selectVipArrearsStatisticsTotal(sysVipInfo);
+	}
 }
\ No newline at end of file

--
Gitblit v1.9.1