Browse Source

初始化积分规则 方法调整为get 接口

dev_shibei_match
jianjun 4 years ago
parent
commit
367e1b2ead
  1. 2
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/InitPointRuleResultDTO.java
  2. 2
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/EpmetPointOpenFeignClient.java
  3. 5
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/fallback/EpmetPointOpenFeignClientFallback.java
  4. 13
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/BackDoorController.java
  5. 2
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/PointRuleService.java
  6. 19
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/PointRuleServiceImpl.java
  7. 2
      epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/service/impl/CustomerServiceImpl.java

2
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/InitPointRuleResultDTO.java

@ -42,4 +42,6 @@ public class InitPointRuleResultDTO implements Serializable {
* 已经初始化总数 * 已经初始化总数
*/ */
private Integer initedTotal; private Integer initedTotal;
private String InitedDetail;
} }

2
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/EpmetPointOpenFeignClient.java

@ -36,7 +36,7 @@ public interface EpmetPointOpenFeignClient {
* @author sun * @author sun
**/ **/
@PostMapping("/point/opback/initpointrule") @PostMapping("/point/opback/initpointrule")
Result<InitPointRuleResultDTO> initPointRule(); Result<InitPointRuleResultDTO> initPointRule(String customerId);
/** /**
* 获取小组积分 * 获取小组积分

5
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/fallback/EpmetPointOpenFeignClientFallback.java

@ -10,6 +10,7 @@ import com.epmet.dto.form.GroupPointFormDTO;
import com.epmet.dto.result.ResiPointDetailResultDTO; import com.epmet.dto.result.ResiPointDetailResultDTO;
import com.epmet.feign.EpmetPointOpenFeignClient; import com.epmet.feign.EpmetPointOpenFeignClient;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestParam;
/** /**
* @Description * @Description
@ -25,8 +26,8 @@ public class EpmetPointOpenFeignClientFallback implements EpmetPointOpenFeignCli
} }
@Override @Override
public Result<InitPointRuleResultDTO> initPointRule() { public Result<InitPointRuleResultDTO> initPointRule(@RequestParam String customerId) {
return ModuleUtils.feignConError(ServiceConstant.EPMET_POINT_SERVER, "initPointRule"); return ModuleUtils.feignConError(ServiceConstant.EPMET_POINT_SERVER, "initPointRule",customerId);
} }
/** /**

13
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/BackDoorController.java

@ -9,10 +9,7 @@ import com.epmet.dto.InitPointRuleResultDTO;
import com.epmet.dto.form.PointRuleFormDTO; import com.epmet.dto.form.PointRuleFormDTO;
import com.epmet.service.PointRuleService; import com.epmet.service.PointRuleService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List; import java.util.List;
@ -44,12 +41,12 @@ public class BackDoorController {
/** /**
* desc:批量添加规则 * desc:批量添加规则
* *
* @param list * @param customerId
* @return * @return
*/ */
@PostMapping(value = "initpointrule") @GetMapping(value = "initpointrule")
public Result<InitPointRuleResultDTO> initPointRule() { public Result<InitPointRuleResultDTO> initPointRule(@RequestParam(required = false) String customerId) {
InitPointRuleResultDTO resultDTO = pointRuleService.initPointRule(); InitPointRuleResultDTO resultDTO = pointRuleService.initPointRule(customerId);
return new Result<InitPointRuleResultDTO>().ok(resultDTO); return new Result<InitPointRuleResultDTO>().ok(resultDTO);
} }

2
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/PointRuleService.java

@ -69,7 +69,7 @@ public interface PointRuleService extends BaseService<PointRuleEntity> {
**/ **/
PointRuleEntity getByEventCodeAndCustomerId(String customerId,String eventCode); PointRuleEntity getByEventCodeAndCustomerId(String customerId,String eventCode);
InitPointRuleResultDTO initPointRule(); InitPointRuleResultDTO initPointRule(String customerId);
/** /**
* 获取小组积分规则 * 获取小组积分规则

19
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/PointRuleServiceImpl.java

@ -16,7 +16,6 @@
*/ */
package com.epmet.service.impl; package com.epmet.service.impl;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.epmet.common.enu.PointUnitEnum; import com.epmet.common.enu.PointUnitEnum;
@ -196,14 +195,23 @@ public class PointRuleServiceImpl extends BaseServiceImpl<PointRuleDao, PointRul
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public InitPointRuleResultDTO initPointRule() { public InitPointRuleResultDTO initPointRule(String customerId) {
//得到所有客户Id //得到所有客户Id
List<CustomerDTO> customerDTOList = null;
if (StringUtils.isBlank(customerId)){
Result<List<CustomerDTO>> customerListResult = operCrmOpenFeignClient.getAllCustomerList(); Result<List<CustomerDTO>> customerListResult = operCrmOpenFeignClient.getAllCustomerList();
log.info("initPointRule operCrmOpenFeignClient.getAllCustomerList result:{}",JSON.toJSONString(customerListResult)); log.info("initPointRule operCrmOpenFeignClient.getAllCustomerList result:{}",JSON.toJSONString(customerListResult));
if (!customerListResult.success() || CollectionUtils.isEmpty(customerListResult.getData())) { if (!customerListResult.success() || CollectionUtils.isEmpty(customerListResult.getData())) {
throw new RenException("获取所有客户列表失败"); throw new RenException("获取所有客户列表失败");
} }
List<CustomerDTO> customerDTOList = customerListResult.getData(); customerDTOList = customerListResult.getData();
}else{
customerDTOList = new ArrayList<>();
CustomerDTO customerDTO = new CustomerDTO();
customerDTO.setId(customerId);
customerDTOList.add(customerDTO);
}
//获取默认规则列表 //获取默认规则列表
List<PointRuleDefaultEntity> ruleDefaultEntities = pointRuleDefaultDao.selectList(null); List<PointRuleDefaultEntity> ruleDefaultEntities = pointRuleDefaultDao.selectList(null);
if (CollectionUtils.isEmpty(ruleDefaultEntities)) { if (CollectionUtils.isEmpty(ruleDefaultEntities)) {
@ -221,7 +229,7 @@ public class PointRuleServiceImpl extends BaseServiceImpl<PointRuleDao, PointRul
//key :: customerId || value :: 客户规则集合 //key :: customerId || value :: 客户规则集合
Map<String,List<PointRuleEntity>> customerRuleMap = Map<String,List<PointRuleEntity>> customerRuleMap =
customerRule.stream().collect(Collectors.groupingBy(PointRuleEntity :: getCustomerId)); customerRule.stream().collect(Collectors.groupingBy(PointRuleEntity :: getCustomerId));
customerRuleMap.forEach((customerId,ruleList) -> { customerRuleMap.forEach((cId,ruleList) -> {
if(null != ruleList){ if(null != ruleList){
List<String> event = new LinkedList<>(defaultEventCodeList); List<String> event = new LinkedList<>(defaultEventCodeList);
//取差集,event只剩下当前客户没有的积分规则 //取差集,event只剩下当前客户没有的积分规则
@ -234,7 +242,7 @@ public class PointRuleServiceImpl extends BaseServiceImpl<PointRuleDao, PointRul
entity.setCreatedTime(new Date()); entity.setCreatedTime(new Date());
entity.setUpdatedBy(""); entity.setUpdatedBy("");
entity.setUpdatedTime(new Date()); entity.setUpdatedTime(new Date());
entity.setCustomerId(customerId); entity.setCustomerId(cId);
insertList.add(entity); insertList.add(entity);
return entity; return entity;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
@ -281,6 +289,7 @@ public class PointRuleServiceImpl extends BaseServiceImpl<PointRuleDao, PointRul
InitPointRuleResultDTO result = new InitPointRuleResultDTO(); InitPointRuleResultDTO result = new InitPointRuleResultDTO();
result.setCustomerTotal(customerDTOList.size()); result.setCustomerTotal(customerDTOList.size());
result.setInitedTotal(insertList.size()); result.setInitedTotal(insertList.size());
result.setInitedDetail(JSON.toJSONString(insertList));
return result; return result;
} }

2
epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/service/impl/CustomerServiceImpl.java

@ -560,7 +560,7 @@ public class CustomerServiceImpl extends BaseServiceImpl<CustomerDao, CustomerEn
//2021.1.25 sun 新增初始化客户积分规则和评价指标权重 start //2021.1.25 sun 新增初始化客户积分规则和评价指标权重 start
//8.客户初始化已有的积分规则 //8.客户初始化已有的积分规则
Result<InitPointRuleResultDTO> resultPoint = epmetPointOpenFeignClient.initPointRule(); Result<InitPointRuleResultDTO> resultPoint = epmetPointOpenFeignClient.initPointRule(formDTO.getCustomerId());
if (!resultPoint.success()) { if (!resultPoint.success()) {
throw new RenException(resultPoint.getCode(), resultPoint.getInternalMsg()); throw new RenException(resultPoint.getCode(), resultPoint.getInternalMsg());
} }

Loading…
Cancel
Save