package com.hx.phip.tool.club;
|
|
import com.hx.common.service.CommonService;
|
import com.hx.exception.TipsException;
|
import com.hx.mybatisTool.SqlSentence;
|
import com.hx.phiappt.common.OrderItemConstants;
|
import com.hx.phiappt.common.OrderTotalConstants;
|
import com.hx.phiappt.constants.enums.GroupTypeEnum;
|
import com.hx.phiappt.constants.enums.ProjectRelationTypeEnum;
|
import com.hx.phiappt.dao.mapper.ProjectTypeRelationMapper;
|
import com.hx.phiappt.model.cardItem.CardEquity;
|
import com.hx.phiappt.model.cardItem.CardItemInfo;
|
import com.hx.phiappt.model.market.system.MarketSystem;
|
import com.hx.phiappt.model.market.system.MarketSystemProject;
|
import com.hx.phiappt.model.order.OrderItem;
|
import com.hx.phiappt.model.order.OrderItemSon;
|
import com.hx.phiappt.model.order.OrdersTotal;
|
import com.hx.phiappt.model.project.ProjectTypeRelation;
|
import com.hx.phiappt.model.user.club.UserClubMember;
|
import com.hx.phip.dao.mapper.*;
|
import com.hx.util.DateUtil;
|
|
import java.util.*;
|
|
/**用户俱乐部会员
|
* @author CJH
|
*/
|
public class UserCluebMemberTool {
|
|
/**订单下单结账校验是否符合会员条件*/
|
public static void orderChekMember(String orderId,Integer marketType, CommonService commonService){
|
|
OrdersTotal ordersTotal = commonService.selectOneByKey(OrdersTotalMapper.class,orderId);
|
if(ordersTotal == null){
|
throw new TipsException("订单标识错误！");
|
}
|
//充值单跳过
|
if(OrderTotalConstants.TYPE_RECHARGE.equals(ordersTotal.getType())){
|
return;
|
}
|
//未支付跳过
|
if(ordersTotal.getPayStatus() != OrderTotalConstants.PAY_STATUS_SUC){
|
return;
|
}
|
|
//查询活动配置
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> values = new HashMap<>();
|
|
values.put("type",marketType);
|
sqlSentence.sqlSentence("SELECT * FROM market_system WHERE isDel = 0 AND isUp = 1 AND type = #{m.type}",values);
|
MarketSystem marketSystem = commonService.selectOneByKey(MarketSystemMapper.class,sqlSentence);
|
if(marketSystem == null){
|
return;
|
}
|
|
//---判断是否在活动时间内
|
if(marketSystem.getStartTime() != null){
|
if(ordersTotal.getPayTime().getTime() < marketSystem.getStartTime().getTime()){
|
return;
|
}
|
}
|
if(marketSystem.getEndTime() != null){
|
if(ordersTotal.getPayTime().getTime() > marketSystem.getEndTime().getTime()){
|
return;
|
}
|
}
|
|
//----获取指定的项目配置
|
values.clear();
|
values.put("marketSystemId",marketSystem.getId());
|
sqlSentence.sqlSentence("SELECT type,typeCode,typeId FROM market_system_project WHERE isDel = 0 AND marketSystemId = #{m.marketSystemId}",values);
|
List<MarketSystemProject> marketSystemProjectList = commonService.selectList(MarketSystemProjectMapper.class,sqlSentence);
|
|
//指定活动项目编号匹配存储
|
Set<String> skuNoSet = new HashSet<>();
|
StringBuilder itemNameSql = new StringBuilder();
|
for(MarketSystemProject marketSystemProject:marketSystemProjectList){
|
if(marketSystemProject.getType() == MarketSystemProject.TYPE_PROJECT_MAPPER){
|
if(itemNameSql.length() > 0){
|
itemNameSql.append(",");
|
}
|
itemNameSql.append("'").append(marketSystemProject.getTypeCode()).append("'");
|
}else{
|
skuNoSet.add(marketSystemProject.getTypeCode());
|
}
|
}
|
if(itemNameSql.length() > 0){
|
values.clear();
|
values.put("moduleType", ProjectRelationTypeEnum.MODULE_TYPE_ZS_PROJECT.getCode());
|
values.put("itemNameList",itemNameSql.toString());
|
sqlSentence.sqlSentence("SELECT skuNo FROM project_type_relation WHERE isDel = 0 AND moduleType = 7 AND itemName IN(${m.itemNameList})",values);
|
List<ProjectTypeRelation> projectTypeRelationList = commonService.selectList(ProjectTypeRelationMapper.class,sqlSentence);
|
for(ProjectTypeRelation projectTypeRelation:projectTypeRelationList){
|
skuNoSet.add(projectTypeRelation.getSkuNo());
|
}
|
}
|
|
//---获取购买的子单
|
values.clear();
|
values.put("orderId",ordersTotal.getId());
|
sqlSentence.sqlSentence("SELECT id,type,commonId,goodsNo,goodsName,usedTotal,hasReNum FROM order_item WHERE isDel = 0 AND orderId = #{m.orderId}",values);
|
List<OrderItem> orderItemList = commonService.selectList(OrderItemMapper.class,sqlSentence);
|
|
//已经算了疗程数的项目编号
|
Set<String> mateSkuNoSet = new HashSet<>();
|
//总疗程数，所有的项目疗程数总和
|
int cureNum = 0;
|
|
//存储卡项所有的子项，k值：权益标识
|
Map<String,List<CardItemInfo>> cardItemInfoMapList;
|
List<OrderItemSon> orderItemSonList;
|
List<CardEquity> cardEquityList;
|
List<CardItemInfo> cardItemInfoList;
|
int cureItemMax;
|
int cureItemNum;
|
int deductionSurp;
|
int deductionNum;
|
for(OrderItem orderItem:orderItemList){
|
if(OrderItemConstants.TYPE_PROJECT.equals(orderItem.getType())){
|
//项目，没有包含
|
if(skuNoSet.contains(orderItem.getGoodsNo())){
|
//疗程次数叠加，退款的也需要减去
|
cureNum = cureNum+orderItem.getUsedTotal()-orderItem.getHasReNum();
|
}
|
}else if(OrderItemConstants.TYPE_PROMOTION.equals(orderItem.getType())){
|
//促销
|
orderItemSonList = getOrderItemSonList(orderItem.getId(),OrderItemConstants.TYPE_PROJECT,commonService);
|
for(OrderItemSon orderItemSon:orderItemSonList){
|
if(skuNoSet.contains(orderItemSon.getGoodsNo())){
|
//疗程次数叠加，退款的也需要减去
|
cureNum = cureNum+orderItem.getUsedTotal()-orderItem.getHasReNum();
|
}
|
}
|
}else if(OrderItemConstants.TYPE_CARD.equals(orderItem.getType())){
|
//卡项，注意，不是卡包
|
//TODO 退款没有减去
|
cardEquityList = getCardEquityList(orderItem.getCommonId(),commonService);
|
cardItemInfoMapList = getCardItemInfoList(orderItem.getCommonId(),commonService);
|
for(CardEquity cardEquity:cardEquityList){
|
cardItemInfoList = cardItemInfoMapList.get(cardEquity.getId());
|
if(cardItemInfoList==null || cardItemInfoList.size()==0){
|
continue;
|
}
|
//判断权益类型
|
if(cardEquity.getEquityType().equals(CardEquity.EQUITY_TYPE_PROJECT)){
|
for(CardItemInfo cardItemInfo:cardItemInfoList){
|
//固定项目类型
|
if(cardItemInfo.getUserNum() != null){
|
cureNum = cureNum+cardItemInfo.getUserNum()*cardItemInfo.getMaxNum()*orderItem.getBuyNum();
|
}
|
}
|
}else if(cardEquity.getEquityType().equals(CardEquity.EQUITY_TYPE_TIME_CARD)){
|
//TODO 这里还没有做完
|
//只存储最大的一个疗程数
|
cureItemMax = 0;
|
//剩余抵扣次数
|
deductionSurp = cardEquity.getValue();
|
//次卡
|
for(CardItemInfo cardItemInfo:cardItemInfoList){
|
|
if(cardItemInfo.getUserNum() != null){
|
deductionNum = cardEquity.getValue()/cardItemInfo.getEveryDrawNum();
|
cureItemNum = cardItemInfo.getUserNum()*deductionNum*orderItem.getBuyNum();
|
if(cureItemNum>cureItemMax){
|
cureItemMax = cureItemMax;
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
//判断是否符合规则
|
if(cureNum >= marketSystem.getCureNum()){
|
//生成俱乐部会员
|
createClubMember(UserClubMember.TYPE_REGENERATION,ordersTotal,marketSystem,commonService);
|
}
|
|
}
|
|
/**获取二级子订单*/
|
public static List<OrderItemSon> getOrderItemSonList(String orderItemId,String goodsType,CommonService commonService){
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> values = new HashMap<>();
|
|
values.put("orderItemId",orderItemId);
|
values.put("goodsType",goodsType);
|
sqlSentence.sqlSentence("SELECT id,type,goodsId,goodsNo,goodsName,usedTotal,hasReNum FROM order_item_source WHERE isDel = 0 AND orderItemId = #{m.orderItemId} AND type = #{m.type}",values);
|
return commonService.selectList(OrderItemSonMapper.class,sqlSentence);
|
}
|
|
/**获取所有的权益*/
|
public static List<CardEquity> getCardEquityList(String cardItemId, CommonService commonService){
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> values = new HashMap<>();
|
|
values.put("cardItemId",cardItemId);
|
sqlSentence.sqlSentence("SELECT cii.id,cii.equityType,cii.value,cii.shareMoney" +
|
" FROM card_equity cii WHERE cii.isDel = 0 AND cii.cardItemId = #{m.cardItemId}",values);
|
|
return commonService.selectList(CardEquityMapper.class,sqlSentence);
|
}
|
|
/**获取卡项所有的项目*/
|
public static Map<String,List<CardItemInfo>> getCardItemInfoList(String cardItemId, CommonService commonService){
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> values = new HashMap<>();
|
|
values.put("cardItemId",cardItemId);
|
sqlSentence.sqlSentence("SELECT cii.id,cii.cardEquityId,cii.commonCode,cii.commonId,cii.commonName,cii.commonType,cii.maxNum,cii.everyDrawNum,p.treatmentItemsNum AS userNum" +
|
" LEFT JOIN project p ON p.id = cii.commonId AND p.isExecutable = 1" +
|
" FROM card_item_info cii WHERE cii.isDel = 0 AND cii.cardItemId = #{m.cardItemId} AND cii.commonType IN('project')",values);
|
List<CardItemInfo> cardItemInfoList = commonService.selectList(CardItemInfoMapper.class,sqlSentence);
|
|
Map<String,List<CardItemInfo>> cardItemInfoMapList = new HashMap<>();
|
List<CardItemInfo> cardItemInfoList1;
|
for(CardItemInfo cardItemInfo:cardItemInfoList){
|
cardItemInfoList1 = cardItemInfoMapList.computeIfAbsent(cardItemInfo.getCardEquityId(),k->new ArrayList<>());
|
cardItemInfoList1.add(cardItemInfo);
|
}
|
|
return cardItemInfoMapList;
|
}
|
|
/**订单生成再生俱乐部会员*/
|
public static void createClubMember(Integer type,OrdersTotal ordersTotal,MarketSystem marketSystem,CommonService commonService){
|
|
Integer durationType = UserClubMember.DURATION_TYPE_PARAGRAPH;
|
Date startTime = null;
|
Date endTime = null;
|
if(marketSystem.getDurationType() == MarketSystem.DURATION_TYPE_ALL){
|
durationType = UserClubMember.DURATION_TYPE_ALL;
|
}else if(marketSystem.getDurationType() == MarketSystem.DURATION_TYPE_PARAGRAPH){
|
startTime = marketSystem.getDurationStart();
|
endTime = marketSystem.getDurationEnd();
|
}else{
|
startTime = ordersTotal.getPayTime();
|
endTime = startTime;
|
if(marketSystem.getDurationYear() != null){
|
endTime = DateUtil.addYear(endTime,marketSystem.getDurationYear());
|
}
|
if(marketSystem.getDurationMonth() != null){
|
endTime = DateUtil.addMonth(endTime,marketSystem.getDurationMonth());
|
}
|
if(marketSystem.getDurationDay() != null){
|
endTime = DateUtil.addDay(endTime,marketSystem.getDurationDay());
|
}
|
//时间精确到当天最后一秒
|
endTime = DateUtil.dayToEndDateNoMillisecond(endTime);
|
}
|
insertClubMember(type,durationType,startTime,endTime,UserClubMember.SOURCE_TYPE_ORDER,ordersTotal.getId(),marketSystem.getId(),ordersTotal.getUserId(),commonService);
|
}
|
|
/**保存俱乐部会员*/
|
public static void insertClubMember(Integer type,Integer durationType,Date startTime,Date endTime,Integer sourceType,String sourceId,String sourceOtherId
|
,String userId,CommonService commonService){
|
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> values = new HashMap<>();
|
|
//有绑定的全部进行取消
|
values.put("type",type);
|
values.put("status",UserClubMember.STATUS_NORMAL);
|
values.put("userId",userId);
|
sqlSentence.sqlUpdate(" isDel = 2 WHERE isDel = 0 AND type = #{m.type} AND status = #{m.status} AND userId = #{m.userId}",values);
|
commonService.updateWhere(UserClubMemberMapper.class,sqlSentence);
|
|
UserClubMember userClubMember = new UserClubMember();
|
userClubMember.setType(type);
|
userClubMember.setStatus(UserClubMember.STATUS_NORMAL);
|
userClubMember.setDurationType(durationType);
|
userClubMember.setStartTime(startTime);
|
userClubMember.setEndTime(endTime);
|
userClubMember.setSourceType(sourceType);
|
userClubMember.setSourceId(sourceId);
|
userClubMember.setSourceOtherId(sourceOtherId);
|
userClubMember.setUserId(userId);
|
commonService.insert(UserClubMemberMapper.class,userClubMember);
|
}
|
|
|
|
}
|
