基于Java的全优学堂培训机构管理系统设计源码

package cn.xluobo.business.tool.impt.listener; import cn.xluobo.business.sc.base.domain.req.ReqSchoolSelect; import cn.xluobo.business.sc.base.domain.resp.RespSchoolSelect; import cn.xluobo.business.sc.base.repo.model.ScSchool; import cn.xluobo.business.sc.base.service.IScSchoolService; import cn.xluobo.business.sc.course.domain.export.ExpCourse; import cn.xluobo.business.sc.course.domain.req.ReqCourseClaSelect; import cn.xluobo.business.sc.course.domain.req.ReqSearchScCourse; import cn.xluobo.business.sc.course.domain.resp.RespCourseClaSelectInfo; import cn.xluobo.business.sc.course.enums.ChargeDateUnitEnum; import cn.xluobo.business.sc.course.enums.CourseChargeTypeEnum; import cn.xluobo.business.sc.course.repo.mapper.ScCourseClaMapper; import cn.xluobo.business.sc.course.repo.mapper.ScCourseMapper; import cn.xluobo.business.sc.course.repo.model.ScCourseCharge; import cn.xluobo.business.sc.course.service.IScCourseChargeService; import cn.xluobo.business.sc.log.enums.LogTypeEnum; import cn.xluobo.business.sc.log.repo.model.ScStudentCourseLog; import cn.xluobo.business.sc.log.service.IScStudentCourseLogService; import cn.xluobo.business.sc.order.enums.OrderStatusEnum; import cn.xluobo.business.sc.order.repo.model.ScOrder; import cn.xluobo.business.sc.order.repo.model.ScOrderAccount; import cn.xluobo.business.sc.order.repo.model.ScOrderDetail; import cn.xluobo.business.sc.order.service.IScOrderAccountService; import cn.xluobo.business.sc.order.service.IScOrderDetailService; import cn.xluobo.business.sc.order.service.IScOrderService; import cn.xluobo.business.sc.student.repo.model.ScStudent; import cn.xluobo.business.sc.student.repo.model.ScStudentContact; import cn.xluobo.business.sc.student.repo.model.ScStudentCourse; import cn.xluobo.business.sc.student.repo.model.ScStudentCourseOrder; import cn.xluobo.business.sc.student.service.IScStudentContactService; import cn.xluobo.business.sc.student.service.IScStudentCourseOrderService; import cn.xluobo.business.sc.student.service.IScStudentCourseService; import cn.xluobo.business.sc.student.service.IScStudentService; import cn.xluobo.business.sys.admin.domain.resp.RespTreeSelect; import cn.xluobo.business.sys.admin.repo.model.SysDictData; import cn.xluobo.business.sys.admin.service.BusinessSysDeptService; import cn.xluobo.business.sys.admin.service.BusinessSysDictDataService; import cn.xluobo.business.sys.receipt.repo.model.SysReceiptAccount; import cn.xluobo.business.sys.receipt.service.ISysReceiptAccountService; import cn.xluobo.business.sys.staff.repo.model.SysStaff; import cn.xluobo.business.sys.staff.service.ISysStaffService; import cn.xluobo.business.tool.impt.domain.ImportStudentOrder; import cn.xluobo.config.exception.BusinessException; import cn.xluobo.config.login.LoginUser; import cn.xluobo.core.api.APIBaseResponse; import cn.xluobo.core.page.RespPage; import cn.xluobo.core.utils.DateUtil; import cn.xluobo.utils.ContextUtils; import com.alibaba.excel.context.AnalysisContext; import com.alibaba.excel.event.AnalysisEventListener; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.google.common.collect.Maps; import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.assertj.core.util.Lists; import org.joda.time.DateTime; import org.joda.time.Period; import org.joda.time.PeriodType; import java.math.BigDecimal; import java.util.Date; import java.util.List; import java.util.Map; /** * @author ：zhangbaoyu * @date ：Created in 2020/10/12 17:12 */ @Slf4j @Data public class ImportStudentOrderListener extends AnalysisEventListener<ImportStudentOrder> { private IScStudentService studentService; private IScOrderService orderService; private IScOrderDetailService orderDetailService; private IScSchoolService schoolService; private IScStudentContactService studentContactService; private IScStudentCourseService studentCourseService; private IScStudentCourseOrderService courseOrderService; private IScOrderAccountService orderAccountService; private BusinessSysDictDataService dictDataService; private BusinessSysDeptService deptService; private ScCourseMapper courseMapper; private ScCourseClaMapper claMapper; private ISysReceiptAccountService receiptAccountService; private ISysStaffService staffService; private IScCourseChargeService courseChargeService; private IScStudentCourseLogService scStudentCourseLogService; /** * 是否需要保存 */ private Boolean needSave; // key=value value=contactRelationId private Map<String, String> contactRelationMap = Maps.newHashMap(); // key=value value=sexId private Map<String, String> sexMap = Maps.newHashMap(); // key=schoolName value=schoolId private Map<String, Long> schoolMap = Maps.newHashMap(); // key=detailTagName value=detailTagId private Map<String, String> orderDetailTagMap = Maps.newHashMap(); // key=deptName value=deptId private Map<String, String> campusMap = Maps.newHashMap(); // key=courseChargeName value=chargeId private Map<String, Long> courseChargeMap = Maps.newHashMap(); private Map<String, RespCourseClaSelectInfo> claMap = Maps.newHashMap(); // key=courseId value=value private Map<Long, String> courseMap = Maps.newHashMap(); // key=name value=receiptAccountId private Map<String, Long> receiptAccountMap = Maps.newHashMap(); // key=staffName value=staffId private Map<String, Long> staffMap = Maps.newHashMap(); private Map<Long, ScCourseCharge> chargeCacheMap = Maps.newHashMap(); // key=studentName value=studentId private Map<String, Long> studentMap = Maps.newHashMap(); private boolean hadMoreStudent; // 登录用户id private String loginUserId = ""; private LoginUser loginUser; // 导入id private Long importId; // 需保存的successRecordList private List<ImportStudentOrder> successRecordList = Lists.newArrayList(); // 校验失败的列表 private List<ImportStudentOrder> failRecordList = Lists.newArrayList(); /** * 最多读取多少行 */ int maxRecord = 200; /** * 当前已读取 */ int hadReadRecord = 0; public ImportStudentOrderListener() { studentService = ContextUtils.getBean(IScStudentService.class); orderService = ContextUtils.getBean(IScOrderService.class); orderDetailService = ContextUtils.getBean(IScOrderDetailService.class); schoolService = ContextUtils.getBean(IScSchoolService.class); studentContactService = ContextUtils.getBean(IScStudentContactService.class); studentCourseService = ContextUtils.getBean(IScStudentCourseService.class); courseOrderService = ContextUtils.getBean(IScStudentCourseOrderService.class); orderAccountService = ContextUtils.getBean(IScOrderAccountService.class); dictDataService = ContextUtils.getBean(BusinessSysDictDataService.class); deptService = ContextUtils.getBean(BusinessSysDeptService.class); courseMapper = ContextUtils.getBean(ScCourseMapper.class); claMapper = ContextUtils.getBean(ScCourseClaMapper.class); receiptAccountService = ContextUtils.getBean(ISysReceiptAccountService.class); staffService = ContextUtils.getBean(ISysStaffService.class); courseChargeService = ContextUtils.getBean(IScCourseChargeService.class); scStudentCourseLogService = ContextUtils.getBean(IScStudentCourseLogService.class); this.initCacheMap(); } @Override public void invoke(ImportStudentOrder data, AnalysisContext context) { APIBaseResponse checkParam = checkParam(data); if (!checkParam.isSuccess()) { data.setFailMsg(checkParam.getRespMsg()); failRecordList.add(data); return; } successRecordList.add(data); } @Override public void doAfterAllAnalysed(Analy