Browse Source

短信发送

dev_shibei_match
zxc 5 years ago
parent
commit
1708336fa2
  1. 12
      epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SysSmsServiceImpl.java

12
epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SysSmsServiceImpl.java

@ -253,11 +253,13 @@ public class SysSmsServiceImpl extends BaseServiceImpl<SysSmsDao, SysSmsEntity>
} }
Map<Boolean, List<CrmParameterResultDTO>> groupBySwitch = parameterResult.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getSwitchStatus)); Map<Boolean, List<CrmParameterResultDTO>> groupBySwitch = parameterResult.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getSwitchStatus));
List<CrmParameterResultDTO> crmParameterTrue = groupBySwitch.get(true); List<CrmParameterResultDTO> crmParameterTrue = groupBySwitch.get(true);
Map<Boolean, List<CrmParameterResultDTO>> groupByStatus = crmParameterTrue.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getBalanceStatus)); if (!CollectionUtils.isEmpty(crmParameterTrue)){
List<CrmParameterResultDTO> crmParameterResultDTOS = groupByStatus.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(crmParameterResultDTOS)){
operCrmOpenFeignClient.updateParamInfo(crmParameterResultDTOS);
}
} }
} }

Loading…
Cancel
Save