|
@@ -486,7 +486,7 @@ public class MusicGroupServiceImpl extends BaseServiceImpl<String, MusicGroup> i
|
|
Boolean freeFlag = calender.getCurrentTotalAmount().compareTo(BigDecimal.ZERO) == 0;
|
|
Boolean freeFlag = calender.getCurrentTotalAmount().compareTo(BigDecimal.ZERO) == 0;
|
|
List<String> phones = importDtos.stream().map(e -> e.getPhone()).collect(Collectors.toList());
|
|
List<String> phones = importDtos.stream().map(e -> e.getPhone()).collect(Collectors.toList());
|
|
List<BasicUserDto> userList = teacherDao.queryUserByPhones(phones);
|
|
List<BasicUserDto> userList = teacherDao.queryUserByPhones(phones);
|
|
- List<String> existPhones = studentDao.queryExistStuByPhone(phones);
|
|
|
|
|
|
+// List<String> existPhones = studentDao.queryExistStuByPhone(phones);
|
|
Map<String, BasicUserDto> userDtoMap = userList.stream().collect(Collectors.groupingBy(e -> e.getPhone(), Collectors.collectingAndThen(Collectors.toList(), v -> v.get(0))));
|
|
Map<String, BasicUserDto> userDtoMap = userList.stream().collect(Collectors.groupingBy(e -> e.getPhone(), Collectors.collectingAndThen(Collectors.toList(), v -> v.get(0))));
|
|
Organization organization = organizationDao.get(calender.getOrganId());
|
|
Organization organization = organizationDao.get(calender.getOrganId());
|
|
//检查用户是否已入团或在其他机构已注册
|
|
//检查用户是否已入团或在其他机构已注册
|
|
@@ -522,6 +522,7 @@ public class MusicGroupServiceImpl extends BaseServiceImpl<String, MusicGroup> i
|
|
student = studentDao.get(userId);
|
|
student = studentDao.get(userId);
|
|
if(Objects.isNull(student)){
|
|
if(Objects.isNull(student)){
|
|
student = new Student(userId, subjectMap.get(si.getSubjectName()) + "");
|
|
student = new Student(userId, subjectMap.get(si.getSubjectName()) + "");
|
|
|
|
+ student.setCurrentClass(si.getCurrentClass());
|
|
student.setCurrentGradeNum(SixPlusGradeEnum.get(si.getGrade()).getCode());
|
|
student.setCurrentGradeNum(SixPlusGradeEnum.get(si.getGrade()).getCode());
|
|
studentDao.insert(student);
|
|
studentDao.insert(student);
|
|
// 添加用户现金账户
|
|
// 添加用户现金账户
|
|
@@ -2571,8 +2572,6 @@ public class MusicGroupServiceImpl extends BaseServiceImpl<String, MusicGroup> i
|
|
//加一的原因是为了和positionId同步,枚举是从0开始
|
|
//加一的原因是为了和positionId同步,枚举是从0开始
|
|
musicGroupQuit.setCurrentApproveRole(ORGAN_MANAGER.ordinal() + 1 + "");
|
|
musicGroupQuit.setCurrentApproveRole(ORGAN_MANAGER.ordinal() + 1 + "");
|
|
}
|
|
}
|
|
- musicGroupQuitDao.update(musicGroupQuit);
|
|
|
|
-
|
|
|
|
if (status == ApprovalStatus.APPROVED) {
|
|
if (status == ApprovalStatus.APPROVED) {
|
|
|
|
|
|
List<Integer> classGroupIdList = classGroupStudentMapperDao.queryClassGroupIdList(musicGroupId, userId, GroupType.MUSIC);
|
|
List<Integer> classGroupIdList = classGroupStudentMapperDao.queryClassGroupIdList(musicGroupId, userId, GroupType.MUSIC);
|
|
@@ -2764,27 +2763,39 @@ public class MusicGroupServiceImpl extends BaseServiceImpl<String, MusicGroup> i
|
|
sysUserCashAccountLog.setReturnFeeType(ReturnFeeEnum.MUSIC);
|
|
sysUserCashAccountLog.setReturnFeeType(ReturnFeeEnum.MUSIC);
|
|
sysUserCashAccountLog.setComment("退出乐团");
|
|
sysUserCashAccountLog.setComment("退出乐团");
|
|
sysUserCashAccountLogDao.insert(sysUserCashAccountLog);
|
|
sysUserCashAccountLogDao.insert(sysUserCashAccountLog);
|
|
- // 增加交易流水
|
|
|
|
-// sysUserCashAccountDetailService.addCashAccountDetail(userId, amount, SysUserCashAccountDetailService.MUSIC_GROUP + musicGroupId, "",
|
|
|
|
-// PlatformCashAccountDetailTypeEnum.REFUNDS, null, SUCCESS, "退出乐团", null);
|
|
|
|
}
|
|
}
|
|
- }
|
|
|
|
|
|
+ // 推送退团消息
|
|
|
|
+ IPage<SchoolStaffWrapper.SchoolStaff> page = schoolStaffService.selectPage(new Page<>(1, -1),
|
|
|
|
+ SchoolStaffWrapper.SchoolStaffQuery.builder().schoolId(musicGroup.getCooperationOrganId().longValue()).build());
|
|
|
|
+ List<SchoolStaffWrapper.SchoolStaff> records = page.getRecords();
|
|
|
|
+ if (CollectionUtils.isNotEmpty(records)) {
|
|
|
|
|
|
- // 推送退团消息
|
|
|
|
- IPage<SchoolStaffWrapper.SchoolStaff> page = schoolStaffService.selectPage(new Page<>(1, -1),
|
|
|
|
- SchoolStaffWrapper.SchoolStaffQuery.builder().schoolId(musicGroup.getCooperationOrganId().longValue()).build());
|
|
|
|
- List<SchoolStaffWrapper.SchoolStaff> records = page.getRecords();
|
|
|
|
- if (CollectionUtils.isNotEmpty(records)) {
|
|
|
|
|
|
+ SysUser sysUser = sysUserFeignService.queryUserById(userId);
|
|
|
|
|
|
- SysUser sysUser = sysUserFeignService.queryUserById(userId);
|
|
|
|
|
|
+ Map<Integer, String> userMap = new HashMap<>();
|
|
|
|
+ records.forEach(o -> userMap.put(o.getUserId().intValue(), o.getUserId().toString()));
|
|
|
|
|
|
- Map<Integer, String> userMap = new HashMap<>();
|
|
|
|
- records.forEach(o -> userMap.put(o.getUserId().intValue(), o.getUserId().toString()));
|
|
|
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_STUDENT_QUIT_GROUP,
|
|
|
|
+ userMap, null, 0, null,
|
|
|
|
+ "SCHOOL",musicGroup.getName(),sysUser.getUsername());
|
|
|
|
+ }
|
|
|
|
+ }else {
|
|
|
|
+ IPage<SchoolStaffWrapper.SchoolStaff> page = schoolStaffService.selectPage(new Page<>(1, -1),
|
|
|
|
+ SchoolStaffWrapper.SchoolStaffQuery.builder().schoolId(musicGroup.getCooperationOrganId().longValue()).build());
|
|
|
|
+ List<SchoolStaffWrapper.SchoolStaff> records = page.getRecords();
|
|
|
|
+ if (CollectionUtils.isNotEmpty(records)) {
|
|
|
|
|
|
- sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_STUDENT_QUIT_GROUP,
|
|
|
|
- userMap, null, 0, null,
|
|
|
|
- "SCHOOL",musicGroup.getName(),sysUser.getUsername());
|
|
|
|
- }
|
|
|
|
|
|
+ SysUser sysUser = sysUserFeignService.queryUserById(userId);
|
|
|
|
+
|
|
|
|
+ Map<Integer, String> userMap = new HashMap<>();
|
|
|
|
+ records.forEach(o -> userMap.put(o.getUserId().intValue(), o.getUserId().toString()));
|
|
|
|
+
|
|
|
|
+ sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, MessageTypeEnum.JIGUANG_STUDENT_QUIT_GROUP_DENIED,
|
|
|
|
+ userMap, null, 0, null,
|
|
|
|
+ "SCHOOL",musicGroup.getName(),sysUser.getUsername(),musicGroupQuit.getReason());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ musicGroupQuitDao.update(musicGroupQuit);
|
|
return true;
|
|
return true;
|
|
}
|
|
}
|
|
|
|
|