|
|
@ -18,6 +18,7 @@ |
|
|
|
package com.epmet.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.epmet.common.enu.PointUnitEnum; |
|
|
|
import com.epmet.common.enu.SysResponseEnum; |
|
|
|
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; |
|
|
@ -25,6 +26,7 @@ import com.epmet.commons.tools.constant.Constant; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.constant.StrConstant; |
|
|
|
import com.epmet.commons.tools.enums.CommonOperateTypeEnum; |
|
|
|
import com.epmet.commons.tools.enums.EventEnum; |
|
|
|
import com.epmet.commons.tools.exception.ExceptionUtils; |
|
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
|
import com.epmet.commons.tools.security.dto.TokenDto; |
|
|
@ -41,10 +43,7 @@ import com.epmet.dto.form.CustomerFunctionListFormDTO; |
|
|
|
import com.epmet.dto.form.PointDetailFormDTO; |
|
|
|
import com.epmet.dto.form.PointRuleFormDTO; |
|
|
|
import com.epmet.dto.form.PointRuleListFormDTO; |
|
|
|
import com.epmet.dto.result.CustomerFunctionResultDTO; |
|
|
|
import com.epmet.dto.result.DefaultFunctionListResultDTO; |
|
|
|
import com.epmet.dto.result.PointDetailResultDTO; |
|
|
|
import com.epmet.dto.result.PointRuleResultDTO; |
|
|
|
import com.epmet.dto.result.*; |
|
|
|
import com.epmet.entity.PointRuleDefaultEntity; |
|
|
|
import com.epmet.entity.PointRuleEntity; |
|
|
|
import com.epmet.entity.RuleOperateLogEntity; |
|
|
@ -61,6 +60,7 @@ import org.springframework.util.CollectionUtils; |
|
|
|
|
|
|
|
import java.util.*; |
|
|
|
import java.util.concurrent.ExecutorService; |
|
|
|
import java.util.concurrent.atomic.AtomicInteger; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
/** |
|
|
@ -284,6 +284,36 @@ public class PointRuleServiceImpl extends BaseServiceImpl<PointRuleDao, PointRul |
|
|
|
return result; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 获取小组积分规则 |
|
|
|
* |
|
|
|
* @param customerId |
|
|
|
* @return com.epmet.dto.result.GroupPointRuleResultDTO |
|
|
|
* @author zhaoqifeng |
|
|
|
* @date 2021/4/22 15:20 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public GroupPointRuleResultDTO getGroupRule(String customerId) { |
|
|
|
GroupPointRuleResultDTO resultDTO = new GroupPointRuleResultDTO(); |
|
|
|
List<String> list = new ArrayList<>(); |
|
|
|
QueryWrapper<PointRuleEntity> wrapper = new QueryWrapper<>(); |
|
|
|
wrapper.eq("CUSTOMER_ID", customerId) |
|
|
|
.eq("DEL_FLAG", NumConstant.ZERO_STR); |
|
|
|
List<PointRuleEntity> ruleList = baseDao.selectList(wrapper); |
|
|
|
if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(ruleList)) { |
|
|
|
AtomicInteger index=new AtomicInteger(1); |
|
|
|
list = ruleList.stream().filter(i -> ("resi_group").equals(Objects.requireNonNull(EventEnum.getEnum(i.getEventCode())).getEventClass())).map(item -> { |
|
|
|
String rule = index.getAndIncrement() + "." + item.getRuleName() + "," + "" + item.getPoint() + "分"; |
|
|
|
if (NumConstant.ZERO != item.getUpLimit()) { |
|
|
|
rule = rule + "(每天最多得" + item.getUpLimit() + "分)"; |
|
|
|
} |
|
|
|
return rule; |
|
|
|
}).collect(Collectors.toList()); |
|
|
|
} |
|
|
|
resultDTO.setRules(list); |
|
|
|
return resultDTO; |
|
|
|
} |
|
|
|
|
|
|
|
private void insertOperateRecord(TokenDto tokenDTO, PointRuleEntity entityNew, PointRuleEntity entityDB, String opType) { |
|
|
|
RuleOperateLogEntity record = new RuleOperateLogEntity(); |
|
|
|
if (tokenDTO != null) { |
|
|
|