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 |  155 ++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 115 insertions(+), 40 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 922b7d9..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,7 +14,9 @@
 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.ServiceUtil;
 import com.matrix.system.constance.Dictionary;
@@ -22,6 +27,9 @@
 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;
@@ -65,7 +73,14 @@
 
 	@Value("${default.vip.photo.man}")
 	String defaultMan;
+	@Autowired
+	BusParameterSettingsDao busParameterSettingsDao;
 
+	@Autowired
+	ScoreVipDetailService scoreVipDetailService;
+
+	@Autowired
+	private SysOrderDao sysOrderDao;
 
 
 	/**
@@ -90,11 +105,11 @@
 
 	@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("编号已存在!");
 			}
 		}
@@ -103,25 +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(sysVipInfo.getSex().equals(Dictionary.SEX_MAN)){
+		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;
@@ -255,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());
-			}
+
  			
 	}
 	
@@ -414,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;
 					}
@@ -440,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);
@@ -450,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);
 
@@ -512,10 +508,59 @@
 		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
@@ -608,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