|
|
@@ -11,6 +11,7 @@ import com.izouma.wenlvju.exception.BusinessException;
|
|
|
import com.izouma.wenlvju.repo.UserRepo;
|
|
|
import com.izouma.wenlvju.repo.performance.ArrangeJudgeRepo;
|
|
|
import com.izouma.wenlvju.repo.performance.ArrangeRepo;
|
|
|
+import com.izouma.wenlvju.service.sms.NjwlSmsService;
|
|
|
import com.izouma.wenlvju.utils.JpaUtils;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import org.springframework.data.domain.Page;
|
|
|
@@ -19,6 +20,8 @@ import org.springframework.stereotype.Service;
|
|
|
import java.time.LocalDate;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
+import java.util.Set;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
@Service
|
|
|
@AllArgsConstructor
|
|
|
@@ -27,6 +30,7 @@ public class ArrangeJudgeService {
|
|
|
private ArrangeJudgeRepo arrangeJudgeRepo;
|
|
|
private ArrangeRepo arrangeRepo;
|
|
|
private UserRepo userRepo;
|
|
|
+ private NjwlSmsService njwlSmsService;
|
|
|
|
|
|
public Page<ArrangeJudge> all(PageQuery pageQuery) {
|
|
|
return arrangeJudgeRepo.findAll(JpaUtils.toSpecification(pageQuery, ArrangeJudge.class), JpaUtils.toPageRequest(pageQuery));
|
|
|
@@ -73,4 +77,14 @@ public class ArrangeJudgeService {
|
|
|
if (CollUtil.isNotEmpty(arrangeIds))
|
|
|
arrangeJudgeRepo.cancelJudge(arrangeIds);
|
|
|
}
|
|
|
+
|
|
|
+ public void notify(List<Long> arranges) {
|
|
|
+ List<ArrangeJudge> arrangeJudges = arrangeJudgeRepo.findAllByArrangeIdIn(arranges);
|
|
|
+ Set<Long> judges = arrangeJudges.stream().map(ArrangeJudge::getExpertId).collect(Collectors.toSet());
|
|
|
+ String phones = userRepo.findAllByIdInAndDelFalse(judges)
|
|
|
+ .stream()
|
|
|
+ .map(User::getPhone)
|
|
|
+ .collect(Collectors.joining(","));
|
|
|
+ njwlSmsService.sendSms(phones,"已分配您评审节目,链接为http://yskj.njlyw.cn:8081/h5/login");
|
|
|
+ }
|
|
|
}
|