|
|
@ -253,11 +253,13 @@ public class SysSmsServiceImpl extends BaseServiceImpl<SysSmsDao, SysSmsEntity> |
|
|
|
} |
|
|
|
Map<Boolean, List<CrmParameterResultDTO>> groupBySwitch = parameterResult.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getSwitchStatus)); |
|
|
|
List<CrmParameterResultDTO> crmParameterTrue = groupBySwitch.get(true); |
|
|
|
Map<Boolean, List<CrmParameterResultDTO>> groupByStatus = crmParameterTrue.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getBalanceStatus)); |
|
|
|
List<CrmParameterResultDTO> crmParameterResultDTOS = groupByStatus.get(true); |
|
|
|
// 把参数开关打开的,已发送短信的客户更新余额
|
|
|
|
if (!CollectionUtils.isEmpty(crmParameterResultDTOS)){ |
|
|
|
operCrmOpenFeignClient.updateParamInfo(crmParameterResultDTOS); |
|
|
|
if (!CollectionUtils.isEmpty(crmParameterTrue)){ |
|
|
|
Map<Boolean, List<CrmParameterResultDTO>> groupByStatus = crmParameterTrue.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getBalanceStatus)); |
|
|
|
List<CrmParameterResultDTO> crmParameterResultDTOS = groupByStatus.get(true); |
|
|
|
// 把参数开关打开的,已发送短信的客户更新余额
|
|
|
|
if (!CollectionUtils.isEmpty(crmParameterResultDTOS)){ |
|
|
|
operCrmOpenFeignClient.updateParamInfo(crmParameterResultDTOS); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|