|  |  | 
 |  |  | import com.alibaba.fastjson.JSONObject; | 
 |  |  | import com.doumee.biz.system.SystemDictDataBiz; | 
 |  |  | import com.doumee.core.constants.ResponseStatus; | 
 |  |  | import com.doumee.core.dingTalk.DingTalk; | 
 |  |  | import com.doumee.core.exception.BusinessException; | 
 |  |  | import com.doumee.core.haikang.model.HKConstants; | 
 |  |  | import com.doumee.core.haikang.model.param.BaseResponse; | 
 |  |  | import com.doumee.core.haikang.model.param.request.ParkReservationAddRequest; | 
 |  |  | import com.doumee.core.haikang.model.param.respose.ParkReservationAddResponse; | 
 |  |  | import com.doumee.core.haikang.service.HKService; | 
 |  |  | import com.doumee.core.model.PageData; | 
 |  |  | import com.doumee.core.model.PageWrap; | 
 |  |  | import com.doumee.service.business.third.model.PageData; | 
 |  |  | import com.doumee.service.business.third.model.PageWrap; | 
 |  |  | import com.doumee.core.utils.Constants; | 
 |  |  | import com.doumee.core.utils.DateUtil; | 
 |  |  | import com.doumee.core.utils.SmsConstants; | 
 |  |  | import com.doumee.core.utils.Utils; | 
 |  |  | import com.doumee.core.wx.wxPlat.WxPlatConstants; | 
 |  |  | import com.doumee.core.wx.wxPlat.WxPlatNotice; | 
 |  |  | import com.doumee.dao.business.*; | 
 |  |  | import com.doumee.dao.business.dao.CompanyMapper; | 
 |  |  | import com.doumee.dao.business.dao.MemberMapper; | 
 |  |  | import com.doumee.dao.business.dao.SmsConfigMapper; | 
 |  |  | import com.doumee.dao.business.dao.SmsEmailMapper; | 
 |  |  | import com.doumee.dao.business.dto.ApproveDTO; | 
 |  |  | import com.doumee.dao.business.join.ApproveJoinMapper; | 
 |  |  | 
 |  |  | import com.doumee.dao.business.join.VisitsJoinMapper; | 
 |  |  | import com.doumee.dao.business.model.*; | 
 |  |  | import com.doumee.dao.business.vo.ApproveDataVO; | 
 |  |  | import com.doumee.dao.business.model.Member; | 
 |  |  | import com.doumee.dao.system.SystemUserMapper; | 
 |  |  | import com.doumee.dao.system.dto.NoticesDTO; | 
 |  |  | import com.doumee.dao.system.join.NoticesJoinMapper; | 
 |  |  | import com.doumee.dao.system.model.Notices; | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private SystemDictDataBiz systemDictDataBiz; | 
 |  |  |     @Autowired | 
 |  |  |     private WxNoticeConfigMapper wxNoticeConfigMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private ApproveTemplMapper approveTemplMapper; | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private CarUseBookMapper carUseBookMapper; | 
 |  |  |      | 
 |  |  |     @Autowired | 
 |  |  |     private SystemUserMapper systemUserMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private CarDriverMapper carDriverMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private VisitsMapper visitsMapper; | 
 |  |  |     private DdNoticeConfigMapper ddNoticeConfigMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private VisitsJoinMapper visitsJoinMapper; | 
 |  |  |     private VisitsJoinMapper visitsMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private CarUseBookJoinMapper carUseBookJoinMapper; | 
 |  |  | 
 |  |  |     private PlatformReasonMapper platformReasonMapper; | 
 |  |  |     @Autowired | 
 |  |  |     private PlatformGroupMapper platformGroupMapper; | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private ParksMapper parksMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private ParkBookMapper parkBookMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private VisitParkMapper visitParkMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private SmsConfigMapper smsConfigMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private SmsEmailMapper smsEmailMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private EmayService emayService; | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private DingTalk dingTalk; | 
 |  |  |     @Override | 
 |  |  |     public Integer create(Approve approve) { | 
 |  |  |         approveMapper.insert(approve); | 
 |  |  |         return approve.getId(); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void deleteById(Integer id) { | 
 |  |  |         approveMapper.deleteById(id); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void delete(Approve approve) { | 
 |  |  |         UpdateWrapper<Approve> deleteWrapper = new UpdateWrapper<>(approve); | 
 |  |  |         approveMapper.delete(deleteWrapper); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void deleteByIdInBatch(List<Integer> ids) { | 
 |  |  |         if (CollectionUtils.isEmpty(ids)) { | 
 |  |  | 
 |  |  |                                 Constants.equalsInteger(i.getUserId(),memberId) | 
 |  |  |                                 &&Constants.equalsInteger(i.getStatus(),Constants.ZERO) | 
 |  |  |                                 &&Constants.equalsInteger(i.getSendacopy(),Constants.ZERO) | 
 |  |  |                                         &&StringUtils.equals(i.getParam2(),"0") | 
 |  |  |                         ).count() | 
 |  |  |                 ); | 
 |  |  |                 //已处理数据 | 
 |  |  | 
 |  |  |                         noticesJoinMapper.selectCount(new QueryWrapper<Notices>().lambda().eq(Notices::getParam3,memberId)) | 
 |  |  |                 ); | 
 |  |  |                 //抄送我的数据 | 
 |  |  |                  internalHomeVO.setNoticeCopyNum( | 
 |  |  |                 internalHomeVO.setNoticeCopyNum( | 
 |  |  |                         noticesList.stream().filter(i->Constants.equalsInteger(i.getUserId(),memberId) | 
 |  |  |                                 &&Constants.equalsInteger(i.getSendacopy(),Constants.ONE) | 
 |  |  |                                 &&Constants.equalsInteger(i.getReaded(),Constants.ZERO) | 
 |  |  | 
 |  |  |                     noticesList.stream().filter(i->Constants.equalsInteger(i.getUserId(),noticesDTO.getMemberId()) | 
 |  |  |                             &&Constants.equalsInteger(i.getStatus(),Constants.ZERO) | 
 |  |  |                             &&Constants.equalsInteger(i.getSendacopy(),Constants.ZERO) | 
 |  |  |                             &&StringUtils.equals(i.getParam2(),"0") | 
 |  |  |                     ).count() | 
 |  |  |             ); | 
 |  |  |             internalHomeVO.setNoticeDealNum( | 
 |  |  | 
 |  |  |      * @param tempType 模板类型  0非施工人员访客申请 1施工人员访客申请 2访客报备 3公车市内用车 4公车室外用车 5市公司物流车预约 | 
 |  |  |      * @param businessId 业务主键 根据 tempType | 
 |  |  |      * @param createMemberId 提交流程人员 | 
 |  |  |      * @param applyMember 申请人对象(如果为空,默认为提交人) | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     @Transactional(rollbackFor = {Exception.class,BusinessException.class}) | 
 |  |  |     public void createApproveFlow(Integer tempType,Integer businessId,Integer createMemberId){ | 
 |  |  |     public void createApproveFlow(Integer tempType,Integer businessId,Integer createMemberId,Member applyMember){ | 
 |  |  |         //查询处理模板 | 
 |  |  |         ApproveTempl approveTempl = approveTemplMapper.selectOne(new QueryWrapper<ApproveTempl>().lambda() | 
 |  |  |                 .eq(ApproveTempl::getType,tempType) | 
 |  |  | 
 |  |  |         } | 
 |  |  |         List<ApproveParam> approveCopyList = approveParamAllList.stream().filter(i->i.getType().equals(Constants.ONE)).collect(Collectors.toList()); | 
 |  |  |  | 
 |  |  |         Member createMember = memberMapper.selectById(createMemberId); | 
 |  |  |         Member createMember =    memberMapper.selectById(createMemberId); | 
 |  |  |         if(Objects.isNull(createMember)|| Objects.isNull(createMember.getCompanyId())){ | 
 |  |  |             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"申请人组织信息异常"); | 
 |  |  |         } | 
 |  |  |         List<Approve> approveList = new ArrayList<>(); | 
 |  |  |  | 
 |  |  |         this.organizeApproveData(approveTempl,approveParamList,createMember,businessId,approveList); | 
 |  |  |  | 
 |  |  |         this.organizeApproveData(approveTempl,approveParamList,createMember,applyMember,businessId,approveList); | 
 |  |  |         if(CollectionUtils.isEmpty(approveList)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批流配置错误"); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         //处理抄送数据 | 
 |  |  |         if(CollectionUtils.isNotEmpty(approveCopyList)){ | 
 |  |  |             this.organizeApproveCopyData(approveTempl,approveCopyList,businessId,approveList); | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     @Transactional(rollbackFor = {Exception.class,BusinessException.class}) | 
 |  |  |     public void createApproveForPlatfrom(Integer tempId,Integer businessId,Integer createMemberId){ | 
 |  |  |     public void createApproveForPlatfrom(Integer tempId,Integer businessId,Integer createMemberId ){ | 
 |  |  |         //查询处理模板 | 
 |  |  |         ApproveTempl approveTempl = approveTemplMapper.selectById(tempId); | 
 |  |  |         if(Objects.isNull(approveTempl)){ | 
 |  |  | 
 |  |  |         } | 
 |  |  |         List<Approve> approveList = new ArrayList<>(); | 
 |  |  |  | 
 |  |  |         this.organizeApproveData(approveTempl,approveParamList,createMember,businessId,approveList); | 
 |  |  |         this.organizeApproveData(approveTempl,approveParamList,createMember,null,businessId,approveList); | 
 |  |  |  | 
 |  |  |         if(CollectionUtils.isEmpty(approveList)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批流配置错误"); | 
 |  |  | 
 |  |  |      * @param businessId | 
 |  |  |      * @param approveList | 
 |  |  |      */ | 
 |  |  |     public void organizeApproveData(ApproveTempl approveTempl,List<ApproveParam> approveParamList,Member createMember,Integer businessId,List<Approve> approveList){ | 
 |  |  |     public void organizeApproveData(ApproveTempl approveTempl,List<ApproveParam> approveParamList,Member createMember,Member applyMember,Integer businessId,List<Approve> approveList){ | 
 |  |  |  | 
 |  |  |         if(applyMember ==null){ | 
 |  |  |             applyMember = createMember; | 
 |  |  |         } | 
 |  |  |         //创建默认人信息 | 
 |  |  |         Approve createUserApprove = new Approve(); | 
 |  |  |         createUserApprove.setRemark("发起申请"); | 
 |  |  |         createUserApprove.setCreateDate(new Date()); | 
 |  |  |         createUserApprove.setIsdeleted(Constants.ZERO); | 
 |  |  |         createUserApprove.setTemplatId(approveTempl.getId()); | 
 |  |  |         createUserApprove.setChekorId(createMember.getId()); | 
 |  |  |         createUserApprove.setChekorId(applyMember.getId()); | 
 |  |  |         createUserApprove.setCheckDate(createUserApprove.getCreateDate()); | 
 |  |  |         createUserApprove.setStatus(Constants.approveStatus.pass); | 
 |  |  |         createUserApprove.setTitle("发起申请"); | 
 |  |  | 
 |  |  |         approveList.add(createUserApprove); | 
 |  |  |  | 
 |  |  |         //查询所有待处理人 | 
 |  |  |  | 
 |  |  | //        String token = systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(); | 
 |  |  |         //审批业务数据 | 
 |  |  |         for (int i = 0; i < approveParamList.size(); i++) { | 
 |  |  |             ApproveParam approveParam = approveParamList.get(i); | 
 |  |  |             List<Integer> ids = this.getApproveUserIds(approveParam,createMember); | 
 |  |  |             List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda().in(Member::getId,ids)); | 
 |  |  |             List<Member> memberList = memberMapper.selectJoinList(Member.class, | 
 |  |  |                     new MPJLambdaWrapper<Member>() | 
 |  |  |                             .selectAll(Member.class) | 
 |  |  |                             .selectAs(SystemUser::getOpenid,Member::getSystemOpenid) | 
 |  |  |                             .leftJoin(SystemUser.class,SystemUser::getMemberId,Member::getId) | 
 |  |  |                             .in(Member::getId,ids) | 
 |  |  |             ); | 
 |  |  |             List<String> memberNameList =memberList.stream().map(m->m.getName()).collect(Collectors.toList()); | 
 |  |  |             String memberNames = String.join(",",memberNameList); | 
 |  |  |             Integer noticeType = Constants.approveTypeToNoticeType(approveTempl.getType()); | 
 |  |  | 
 |  |  |                         title = this.createNoticesData(noticeType,businessId,title,jsonMap); | 
 |  |  |                     } | 
 |  |  |                     if(j==0){ | 
 |  |  |                         //默认生成一条 申请人的数据 标记删除状态用于处理到 任务中心(我发起)使用 | 
 |  |  |                         Notices notices = new Notices(); | 
 |  |  |                         notices.setCreateDate(new Date()); | 
 |  |  |                         notices.setIsdeleted(Constants.ONE); | 
 |  |  |                         notices.setObjId(businessId); | 
 |  |  |                         notices.setObjType(noticeType); | 
 |  |  |                         notices.setType(noticeType); | 
 |  |  |                         notices.setTitle(title); | 
 |  |  |                         notices.setParam1(JSONObject.toJSONString(jsonMap)); | 
 |  |  |                         notices.setStatus(Constants.ZERO); | 
 |  |  |                         notices.setReaded(Constants.ZERO); | 
 |  |  |                         notices.setSendacopy(Constants.ZERO); | 
 |  |  |                         notices.setParam2("0"); | 
 |  |  |                         notices.setParam3(createMember.getId().toString()); | 
 |  |  |                         notices.setInfo("处理中"); | 
 |  |  |                         noticesJoinMapper.insert(notices); | 
 |  |  |                         //访客人员不生成此记录 | 
 |  |  |                        if(!(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit)&&Constants.equalsInteger(applyMember.getType(),Constants.ONE))){ | 
 |  |  |                             //默认生成一条 申请人的数据 标记删除状态用于处理到 任务中心(我发起)使用 | 
 |  |  |                             Notices notices = new Notices(); | 
 |  |  |                             notices.setCreateDate(new Date()); | 
 |  |  |                             notices.setIsdeleted(Constants.ONE); | 
 |  |  |                             notices.setObjId(businessId); | 
 |  |  |                             notices.setObjType(noticeType); | 
 |  |  |                             notices.setType(noticeType); | 
 |  |  |                             notices.setTitle(title); | 
 |  |  |                             notices.setParam1(JSONObject.toJSONString(jsonMap)); | 
 |  |  |                             notices.setStatus(Constants.ZERO); | 
 |  |  |                             notices.setReaded(Constants.ZERO); | 
 |  |  |                             notices.setSendacopy(Constants.ZERO); | 
 |  |  |                             notices.setParam2("0"); | 
 |  |  |                             notices.setParam3(createMember.getId().toString()); | 
 |  |  |                             notices.setInfo("处理中"); | 
 |  |  |                             noticesJoinMapper.insert(notices); | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                     if(CollectionUtils.isEmpty(memberList)){ | 
 |  |  |                         throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到审批人信息"); | 
 |  |  | 
 |  |  |                 approve.setType(Constants.ZERO); | 
 |  |  |                 approveList.add(approve); | 
 |  |  |  | 
 |  |  |                 WxPlatNotice wxPlatNotice = new WxPlatNotice(); | 
 |  |  |                 if(Constants.equalsInteger(approve.getStatus(),Constants.ONE) && StringUtils.isNotBlank(member.getPhone())){ | 
 |  |  |                     //发送短信通知 | 
 |  |  |                     if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.reason)){ | 
 |  |  | 
 |  |  |                                 SmsConstants.platformBookContent.platformBookWaitAudit, | 
 |  |  |                                 null,Arrays.asList(member.getPhone().split(",")) | 
 |  |  |                         ); | 
 |  |  |                         //公众号通知 | 
 |  |  |                         if(StringUtils.isNotBlank(member.getSystemOpenid())){ | 
 |  |  |                             wxPlatNotice.sendPlatformBookTemplateNotice(systemDictDataBiz, | 
 |  |  |                                     wxNoticeConfigMapper, | 
 |  |  |                                     platformBooksMapper.selectById(businessId), | 
 |  |  |                                     WxPlatConstants.platformBookContent.platformBookWaitAudit,  | 
 |  |  |                                     Arrays.asList(member.getSystemOpenid().split(",")), | 
 |  |  |                                     Constants.ONE); | 
 |  |  |                         } | 
 |  |  |                     }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit)){ | 
 |  |  |                         //访客申请 | 
 |  |  |                         //短信通知 | 
 |  |  |                         SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, | 
 |  |  |                                 emayService,smsEmailMapper,smsConfigMapper,visitsMapper,businessId, | 
 |  |  |                                 SmsConstants.visitContent.visitNotice, | 
 |  |  |                                 null,Arrays.asList(member.getPhone().split(",")) | 
 |  |  |                         ); | 
 |  |  |                         //公众号通知 | 
 |  |  |                         if(StringUtils.isNotBlank(member.getSystemOpenid())){ | 
 |  |  |                             wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz, | 
 |  |  |                                     wxNoticeConfigMapper,visitsMapper.selectById(businessId), WxPlatConstants.visitContent.visitWaitAudit, | 
 |  |  |                                     Arrays.asList(member.getSystemOpenid().split(",")) | 
 |  |  |                             ); | 
 |  |  |                         } | 
 |  |  |                          | 
 |  |  |                     }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)){ | 
 |  |  |                         //访客报备 | 
 |  |  |                         SmsEmailServiceImpl.sendVisitReportSms(systemDictDataBiz, | 
 |  |  | 
 |  |  |                                 SmsConstants.visitReportingContent.visitReportingNotice, | 
 |  |  |                                 null,Arrays.asList(member.getPhone().split(",")) | 
 |  |  |                         ); | 
 |  |  |                         //公众号通知 | 
 |  |  |                         if(StringUtils.isNotBlank(member.getSystemOpenid())){ | 
 |  |  |                             wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz, | 
 |  |  |                                     wxNoticeConfigMapper,visitsMapper.selectById(businessId), WxPlatConstants.visitReportContent.visitReportWaitAudit, | 
 |  |  |                                     Arrays.asList(member.getSystemOpenid().split(",")) | 
 |  |  |                             ); | 
 |  |  |                         } | 
 |  |  |                     }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.useCar)){ | 
 |  |  |                         //用车申请 | 
 |  |  |                         SmsEmailServiceImpl.sendCarUseSms(systemDictDataBiz, | 
 |  |  | 
 |  |  |                                 SmsConstants.carUseBookContent.carUseBookWaitAudit, | 
 |  |  |                                 null,Arrays.asList(member.getPhone().split(",")) | 
 |  |  |                         ); | 
 |  |  |                         //公众号通知 | 
 |  |  |                         if(StringUtils.isNotBlank(member.getSystemOpenid())){ | 
 |  |  |                             CarUseBook carUseBook = carUseBookMapper.selectById(businessId); | 
 |  |  |                             if(Objects.nonNull(carUseBook)){ | 
 |  |  |                                 SystemUser systemUser = systemUserMapper.selectById(carUseBook.getCreator()); | 
 |  |  |                                 if(Objects.nonNull(systemUser)){ | 
 |  |  |                                     carUseBook.setMemberName(systemUser.getRealname()); | 
 |  |  |                                     wxPlatNotice.sendCarUseBookTemplateNotice(systemDictDataBiz, | 
 |  |  |                                             wxNoticeConfigMapper, | 
 |  |  |                                             carUseBookMapper.selectById(businessId), | 
 |  |  |                                             WxPlatConstants.carUseBookContent.carUseBookWaitAudit, | 
 |  |  |                                             Arrays.asList(member.getSystemOpenid().split(",")), | 
 |  |  |                                             Constants.ONE); | 
 |  |  |                                 } | 
 |  |  |                             } | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                 }  | 
 |  |  |             } | 
 |  |  |             if(Constants.equalsInteger(i,Constants.ZERO) && CollectionUtils.isNotEmpty(memberList)){ | 
 |  |  |                 //生成第一批钉钉审批通知信息 | 
 |  |  |                 List<String> erpId = memberList.stream().filter(m->StringUtils.isNotBlank(m.getErpId())).map(m->m.getErpId()).collect(Collectors.toList()); | 
 |  |  |                 if(CollectionUtils.isNotEmpty(erpId)){ | 
 |  |  |                     if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.useCar)){ | 
 |  |  |                         CarUseBook carUseBook = carUseBookMapper.selectJoinOne(CarUseBook.class, | 
 |  |  |                                 new MPJLambdaWrapper<CarUseBook>() | 
 |  |  |                                         .selectAll(CarUseBook.class) | 
 |  |  |                                         .selectAs(Member::getName,CarUseBook::getMemberName) | 
 |  |  |                                         .leftJoin(Member.class,Member::getId,CarUseBook::getMemberId) | 
 |  |  |                                         .eq(CarUseBook::getId,businessId) | 
 |  |  |                                         .last(" limit 1 ") | 
 |  |  |                         ); | 
 |  |  |                         if(Objects.nonNull(carUseBook)){ | 
 |  |  |                             if(CollectionUtils.isNotEmpty(erpId)){ | 
 |  |  |                                 String ddTalkId = dingTalk.toDoNotice(StringUtils.isNotBlank(carUseBook.getMemberName())?(carUseBook.getMemberName()+"提交的公务用车申请"):"公务车用车申请", | 
 |  |  |                                         erpId , | 
 |  |  |                                         ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda() | 
 |  |  |                                                 .eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO) | 
 |  |  |                                                 .eq(DdNoticeConfig::getObjType,9))>Constants.ZERO? | 
 |  |  |                                         dingTalk.getToDoCarUseBookFiledInfo(carUseBook):null,"pages/staff/vehicle/sendACarDetail?id="+carUseBook.getId()); | 
 |  |  |                                 carUseBookMapper.update(new UpdateWrapper<CarUseBook>().lambda() | 
 |  |  |                                         .set(CarUseBook::getDdBelongToUnionId,erpId.get(Constants.ZERO)) | 
 |  |  |                                         .set(CarUseBook::getDdToDoId,ddTalkId).eq(CarUseBook::getId,carUseBook.getId())); | 
 |  |  |                             } | 
 |  |  |                         } | 
 |  |  |                     }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit) || Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)) { | 
 |  |  |                         Visits visits = visitsMapper.selectById(businessId); | 
 |  |  |                         if (Objects.nonNull(visits)) { | 
 |  |  |                             //TODO 缺少域名前缀内容 | 
 |  |  |                             String ddTalkId = dingTalk.toDoNotice(visits.getName() + (Constants.equalsInteger(visits.getType(),Constants.TWO)?"的访客报备":"的访客申请"), | 
 |  |  |                                     erpId, | 
 |  |  |                                     ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda() | 
 |  |  |                                             .eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO) | 
 |  |  |                                             .eq(DdNoticeConfig::getObjType,Constants.equalsInteger(visits.getType(),Constants.TWO)?5:1))>Constants.ZERO? | 
 |  |  |                                     dingTalk.getToDoVisitFiledInfo(visits):null, | 
 |  |  |                                     "pages/appointmentDetails/appointmentDetails?id=" + visits.getId()); | 
 |  |  |                             visitsMapper.update(new UpdateWrapper<Visits>().lambda() | 
 |  |  |                                             .set(Visits::getDdBelongToUnionId,erpId.get(Constants.ZERO)) | 
 |  |  |                                     .set(Visits::getDdToDoId, ddTalkId).eq(Visits::getId, visits.getId())); | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  | 
 |  |  |         if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit) | 
 |  |  |                 || Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)){ | 
 |  |  |             //访客记录与访客报备 | 
 |  |  |             Visits visits = visitsJoinMapper.selectJoinOne(Visits.class, | 
 |  |  |             Visits visits = visitsMapper.selectJoinOne(Visits.class, | 
 |  |  |                     new MPJLambdaWrapper<Visits>().selectAll(Visits.class) | 
 |  |  |                             .selectAs(Member::getName,Visits::getReceptMemberName) | 
 |  |  |                             .selectAs(Company::getName,Visits::getReceptMemberDepartment) | 
 |  |  | 
 |  |  |             if(Objects.isNull(platformBooks)){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到业务数据信息"); | 
 |  |  |             } | 
 |  |  |             title = "[物流车入园预约]申请人-" + platformBooks.getDriverName(); | 
 |  |  |             jsonMap.put("inType", "入库类型:"+(Constants.equalsInteger(platformBooks.getInType(),Constants.ZERO)?"整托盘":"件烟")); | 
 |  |  |             jsonMap.put("totalNum", "总运输量:"+platformBooks.getTotalNum()+"万支"); | 
 |  |  |             jsonMap.put("arriveDate", "到场时间:" + DateUtil.DateToStr(platformBooks.getArriveDate() , "yyyy-MM-dd HH:mm")); | 
 |  |  |             jsonMap.put("carNum", "车牌照:"+platformBooks.getCarCodeFront()); | 
 |  |  |             title = ApproveServiceImpl.creatPlatformBookNotice(platformBooks,jsonMap); | 
 |  |  | //            title = "[物流车入园预约]申请人-" + platformBooks.getDriverName(); | 
 |  |  | //            jsonMap.put("inType", "入库类型:"+(Constants.equalsInteger(platformBooks.getInType(),Constants.ZERO)?"整托盘":"件烟")); | 
 |  |  | //            jsonMap.put("totalNum", "总运输量:"+platformBooks.getTotalNum()+"万支"); | 
 |  |  | //            jsonMap.put("arriveDate", "到场时间:" + DateUtil.DateToStr(platformBooks.getArriveDate() , "yyyy-MM-dd HH:mm")); | 
 |  |  | //            jsonMap.put("carNum", "车牌照:"+platformBooks.getCarCodeFront()); | 
 |  |  |         } | 
 |  |  |         return title; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public static String creatPlatformBookNotice(PlatformBooks platformBooks,Map<String,Object> jsonMap){ | 
 |  |  |         jsonMap.put("inType", "作业类型:"+(Constants.equalsInteger(platformBooks.getInType(),Constants.ZERO)?"整托盘":"件烟")); | 
 |  |  |         jsonMap.put("totalNum", "总运输量:"+platformBooks.getTotalNum()+"万支"); | 
 |  |  |         jsonMap.put("arriveDate", "到场时间:" + DateUtil.DateToStr(platformBooks.getArriveDate() , "yyyy-MM-dd HH:mm")); | 
 |  |  |         jsonMap.put("carNum", "车牌照:"+platformBooks.getCarCodeFront()); | 
 |  |  |         return  "[物流车入园预约]申请人-" + platformBooks.getDriverName() ; | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | 
 |  |  |      * @param objLevel  查询级别 | 
 |  |  |      */ | 
 |  |  |     public Company getAuditCompanyHead(Integer companyId, Integer objLevel){ | 
 |  |  |         if(Objects.isNull(objLevel)||Objects.isNull(companyId)){ | 
 |  |  |             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"审批流配置异常,请联系管理员"); | 
 |  |  |         } | 
 |  |  |         Company auditCompany =  companyMapper.selectById(companyId); | 
 |  |  |         Integer queryLevel = Constants.ONE; | 
 |  |  |         while(queryLevel<objLevel){ | 
 |  |  | 
 |  |  |     @Override | 
 |  |  |     @Transactional(rollbackFor = {Exception.class,BusinessException.class}) | 
 |  |  |     public void approved(ApproveDTO approveDTO){ | 
 |  |  |         WxPlatNotice wxPlatNotice = new WxPlatNotice(); | 
 |  |  |         if(Objects.isNull(approveDTO) | 
 |  |  |         || Objects.isNull(approveDTO.getObjId()) | 
 |  |  |                 || Objects.isNull(approveDTO.getObjType()) | 
 |  |  | 
 |  |  |                 || Objects.isNull(approveDTO.getLoginUserInfo())){ | 
 |  |  |             throw new BusinessException(ResponseStatus.BAD_REQUEST); | 
 |  |  |         } | 
 |  |  |         if(approveDTO.getStatus().equals(Constants.THREE)&&StringUtils.isBlank(approveDTO.getCheckInfo())){ | 
 |  |  |             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请输入拒绝说明"); | 
 |  |  |         if(!(Constants.equalsInteger(approveDTO.getObjType(),Constants.THREE)||Constants.equalsInteger(approveDTO.getObjType(),Constants.FOUR))){ | 
 |  |  |             if(approveDTO.getStatus().equals(Constants.THREE)&&StringUtils.isBlank(approveDTO.getCheckInfo())){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请输入拒绝说明"); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         Approve approve = approveMapper.selectOne(new QueryWrapper<Approve>() | 
 |  |  |                 .lambda() | 
 |  |  | 
 |  |  |         approveMapper.updateById(approve); | 
 |  |  |         //是否处理 业务数据 | 
 |  |  |         Boolean dealBusinessBean = false; | 
 |  |  |         Boolean dealDDToDo = false; | 
 |  |  |         //审批驳回情况 | 
 |  |  |         if(approveDTO.getStatus().equals(Constants.THREE)){ | 
 |  |  |             dealBusinessBean = true; | 
 |  |  | 
 |  |  |                         .set(Notices::getInfo,"已拒绝") | 
 |  |  |                         .eq(Notices::getObjId,notices.getObjId()) | 
 |  |  |                         .eq(Notices::getObjType,notices.getObjType()) | 
 |  |  |                         .eq(Notices::getReaded,Constants.ZERO) | 
 |  |  | //                        .eq(Notices::getReaded,Constants.ZERO) | 
 |  |  |                         .ne(Notices::getId,notices.getId()) | 
 |  |  |                 ); | 
 |  |  |             } | 
 |  |  | 
 |  |  |                             .in(Approve::getId,approveList.stream().map(m->m.getId()).collect(Collectors.toList()))); | 
 |  |  |                 } | 
 |  |  |                 /**开启下一级别的数据为待审核**/ | 
 |  |  |  | 
 |  |  |                 List<Approve> waitAuditList = approveJoinMapper.selectJoinList(Approve.class, | 
 |  |  |                         new MPJLambdaWrapper<Approve>() | 
 |  |  |                                 .selectAll(Approve.class) | 
 |  |  |                                 .selectAs(Member::getPhone,Approve::getMemberPhone) | 
 |  |  |                                 .selectAs(SystemUser::getOpenid,Approve::getSystemOpenid) | 
 |  |  |                                 .leftJoin(Member.class,Member::getId,Approve::getChekorId) | 
 |  |  |                                 .leftJoin(SystemUser.class,SystemUser::getMemberId,Member::getId) | 
 |  |  |                                 .eq(Approve::getStatus,Constants.approveStatus.wait) | 
 |  |  |                                 .eq(Approve::getObjId,approve.getObjId()) | 
 |  |  |                                 .eq(Approve::getObjType,approve.getObjType()) | 
 |  |  | 
 |  |  |                         .eq(Approve::getObjType,approve.getObjType()) | 
 |  |  |                         .eq(Approve::getLevel,(approve.getLevel()+1)) | 
 |  |  |                 ); | 
 |  |  |  | 
 |  |  |                 //发送短信通知  下级审批人 | 
 |  |  |                 List<String> memberPhone = waitAuditList.stream().filter(i->StringUtils.isNotBlank(i.getMemberPhone())).map(i->i.getMemberPhone()).collect(Collectors.toList()); | 
 |  |  |                 //物流车预约 | 
 |  |  |                 if(approveDTO.getObjType().equals(Constants.approveObjectType.reason)){ | 
 |  |  |                     SmsEmailServiceImpl.sendPlatformBookSms(systemDictDataBiz, | 
 |  |  |                             emayService,smsEmailMapper,smsConfigMapper,platformBooksMapper,approveDTO.getObjId(), | 
 |  |  |                             SmsConstants.platformBookContent.platformBookWaitAudit, | 
 |  |  |                             approveDTO.getCheckInfo(),memberPhone | 
 |  |  |                     ); | 
 |  |  |                 } | 
 |  |  |                 List<String> openIdList =waitAuditList.stream().filter(i->StringUtils.isNotBlank(i.getSystemOpenid())).map(i->i.getSystemOpenid()).collect(Collectors.toList()); | 
 |  |  |  | 
 |  |  |                 else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar) | 
 |  |  |                 || approveDTO.getObjType().equals(Constants.approveObjectType.unCityUseCar)){ | 
 |  |  |                     SmsEmailServiceImpl.sendCarUseSms(systemDictDataBiz, | 
 |  |  |                             emayService,smsEmailMapper,smsConfigMapper,carUseBookMapper,approveDTO.getObjId(), | 
 |  |  |                             SmsConstants.hiddenDangerContent.hiddenDangerDealUser, | 
 |  |  |                             approveDTO.getCheckInfo(),memberPhone); | 
 |  |  |                 } | 
 |  |  |                 this.sendNextLvSms(approve,approveDTO,memberPhone,openIdList); | 
 |  |  |  | 
 |  |  |                 //访客申请/报备 | 
 |  |  |                 if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit) | 
 |  |  |                         ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit) | 
 |  |  |                         ||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)) { | 
 |  |  |                     Visits visits = visitsMapper.selectById(approve.getObjId()); | 
 |  |  |                     if(Objects.nonNull(visits)){ | 
 |  |  |                         if(Constants.equalsInteger(visits.getStatus(),Constants.ZERO)){ | 
 |  |  |                              visitsMapper.update(null,new UpdateWrapper<Visits>().lambda().set(Visits::getStatus,Constants.ONE).eq(Visits::getId,visits.getId())); | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( | 
 |  |  |                         Constants.approveObjectType.unCityUseCar)){ | 
 |  |  |                     this.updDriver(approveDTO,approve,false); | 
 |  |  |                 } | 
 |  |  | //                if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( | 
 |  |  | //                        Constants.approveObjectType.unCityUseCar)){ | 
 |  |  | //                    this.updDriver(approveDTO,approve,false); | 
 |  |  | //                } | 
 |  |  |             }else if(approve.getApproveType().equals(Constants.ONE)){ | 
 |  |  |                 //会签 且终审 | 
 |  |  |                 if(!Constants.equalsInteger(approveList.size(),Constants.ZERO)&&Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)){ | 
 |  |  |                     //标记钉钉通知自己已处理 | 
 |  |  |                     dealDDToDo = true; | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 //无他人审批的情况 则修改数据状态 | 
 |  |  |                 if(Constants.equalsInteger(approveList.size(),Constants.ZERO)&&Constants.equalsInteger(approve.getIsEndCheck(),Constants.ONE)){ | 
 |  |  |                     dealBusinessBean = true; | 
 |  |  |                 }else{ | 
 |  |  |                     if(Constants.equalsInteger(approveList.size(),Constants.ZERO)&&Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)){ | 
 |  |  |                         /**开启下一级别的数据为待审核**/ | 
 |  |  |                         List<Approve> waitAuditList = approveJoinMapper.selectJoinList(Approve.class, | 
 |  |  |                                 new MPJLambdaWrapper<Approve>() | 
 |  |  |                                         .selectAll(Approve.class) | 
 |  |  |                                         .selectAs(Member::getPhone,Approve::getMemberPhone) | 
 |  |  |                                         .selectAs(SystemUser::getOpenid,Approve::getSystemOpenid) | 
 |  |  |                                         .leftJoin(Member.class,Member::getId,Approve::getChekorId) | 
 |  |  |                                         .leftJoin(SystemUser.class,SystemUser::getMemberId,Member::getId) | 
 |  |  |                                         .eq(Approve::getStatus,Constants.approveStatus.wait) | 
 |  |  |                                         .eq(Approve::getObjId,approve.getObjId()) | 
 |  |  |                                         .eq(Approve::getObjType,approve.getObjType()) | 
 |  |  |                                         .eq(Approve::getLevel,(approve.getLevel()+1))); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |                         approveJoinMapper.update(null,new UpdateWrapper<Approve>() | 
 |  |  |                                 .lambda() | 
 |  |  |                                 .set(Approve::getStatus,Constants.approveStatus.auditIng) | 
 |  |  | 
 |  |  |                                 .eq(Approve::getObjType,approve.getObjType()) | 
 |  |  |                                 .eq(Approve::getLevel,(approve.getLevel()+1)) | 
 |  |  |                         ); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |                         //发送短信通知  下级审批人 | 
 |  |  |                         List<String> memberPhone = waitAuditList.stream().filter(i->StringUtils.isNotBlank(i.getMemberPhone())).map(i->i.getMemberPhone()).collect(Collectors.toList()); | 
 |  |  |                         List<String> openIdList =waitAuditList.stream().filter(i->StringUtils.isNotBlank(i.getSystemOpenid())).map(i->i.getSystemOpenid()).collect(Collectors.toList()); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |                         this.sendNextLvSms(approve,approveDTO,memberPhone,openIdList); | 
 |  |  |  | 
 |  |  |                     } | 
 |  |  |                     if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( | 
 |  |  |                             Constants.approveObjectType.unCityUseCar)){ | 
 |  |  |                         this.updDriver(approveDTO,approve,false); | 
 |  |  |                     } | 
 |  |  | //                    if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( | 
 |  |  | //                            Constants.approveObjectType.unCityUseCar)){ | 
 |  |  | //                        this.updDriver(approveDTO,approve,false); | 
 |  |  | //                    } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             this.passNextNotices(dealBusinessBean,notices,approve,approveList,approveCopyList,approveDTO); | 
 |  |  |             this.passNextNotices(dealBusinessBean,notices,approve,approveList,approveCopyList,approveDTO,dealDDToDo); | 
 |  |  |         } | 
 |  |  |         //处理业务数据 | 
 |  |  |         if(dealBusinessBean){ | 
 |  |  | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     public void sendNextLvSms(Approve approve ,ApproveDTO approveDTO , List<String> memberPhone ,List<String> openIdList){ | 
 |  |  |         WxPlatNotice wxPlatNotice = new WxPlatNotice(); | 
 |  |  |         //物流车预约 | 
 |  |  |         List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda() | 
 |  |  |                 .in(Member::getPhone,memberPhone) | 
 |  |  |                 .eq(Member::getIsdeleted,Constants.ZERO) | 
 |  |  |                 .eq(Member::getStatus,Constants.ZERO) | 
 |  |  |                 .isNotNull(Member::getErpId) | 
 |  |  |          ); | 
 |  |  |         if(approveDTO.getObjType().equals(Constants.approveObjectType.reason)){ | 
 |  |  |             SmsEmailServiceImpl.sendPlatformBookSms(systemDictDataBiz, | 
 |  |  |                     emayService,smsEmailMapper,smsConfigMapper,platformBooksMapper,approveDTO.getObjId(), | 
 |  |  |                     SmsConstants.platformBookContent.platformBookWaitAudit, | 
 |  |  |                     approveDTO.getCheckInfo(),memberPhone | 
 |  |  |             ); | 
 |  |  |             //公众号通知 | 
 |  |  |             if(CollectionUtils.isNotEmpty(openIdList)){ | 
 |  |  |                 wxPlatNotice.sendPlatformBookTemplateNotice(systemDictDataBiz, | 
 |  |  |                         wxNoticeConfigMapper, | 
 |  |  |                         platformBooksMapper.selectById(approveDTO.getObjId()), | 
 |  |  |                         WxPlatConstants.platformBookContent.platformBookWaitAudit, | 
 |  |  |                         openIdList, | 
 |  |  |                         Constants.ONE); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |         } else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar) | 
 |  |  |                 || approveDTO.getObjType().equals(Constants.approveObjectType.unCityUseCar)){ | 
 |  |  |  | 
 |  |  |             this.updDriver(approveDTO,approve,false); | 
 |  |  |  | 
 |  |  |             SmsEmailServiceImpl.sendCarUseSms(systemDictDataBiz, | 
 |  |  |                     emayService,smsEmailMapper,smsConfigMapper,carUseBookMapper,approveDTO.getObjId(), | 
 |  |  |                     SmsConstants.carUseBookContent.carUseBookWaitAudit, | 
 |  |  |                     approveDTO.getCheckInfo(),memberPhone); | 
 |  |  |             //发送公众号通知 | 
 |  |  |             CarUseBook carUseBook = carUseBookMapper.selectJoinOne(CarUseBook.class, | 
 |  |  |                     new MPJLambdaWrapper<CarUseBook>() | 
 |  |  |                             .selectAll(CarUseBook.class) | 
 |  |  |                             .selectAs(Member::getName,CarUseBook::getMemberName) | 
 |  |  |                             .leftJoin(Member.class,Member::getId,CarUseBook::getMemberId) | 
 |  |  |                             .eq(CarUseBook::getId,approve.getObjId()) | 
 |  |  |                             .last(" limit 1 ") | 
 |  |  |             ); | 
 |  |  |             if(CollectionUtils.isNotEmpty(openIdList)&&Objects.nonNull(carUseBook)){  | 
 |  |  |                     SystemUser systemUser = systemUserMapper.selectById(carUseBook.getCreator()); | 
 |  |  |                     if(Objects.nonNull(systemUser)){ | 
 |  |  |                         carUseBook.setMemberName(systemUser.getRealname()); | 
 |  |  |                         //发送微信公众号通知 | 
 |  |  |                         wxPlatNotice.sendCarUseBookTemplateNotice(systemDictDataBiz, | 
 |  |  |                                 wxNoticeConfigMapper,carUseBook, | 
 |  |  |                                 WxPlatConstants.carUseBookContent.carUseBookWaitAudit,  | 
 |  |  |                                 openIdList,1); | 
 |  |  |                     }  | 
 |  |  |             } | 
 |  |  |             //发送钉钉待办 公务车申请 | 
 |  |  |             if(Objects.nonNull(carUseBook)&&Objects.nonNull(memberList)){ | 
 |  |  |                 //标记当前审批人已完成 | 
 |  |  |                 dingTalk.updToDoNoticeInfoStatus(carUseBook.getDdBelongToUnionId(),carUseBook.getDdToDoId()); | 
 |  |  |                 //TODO 缺少域名前缀内容 | 
 |  |  |                 String ddTalkId = dingTalk.toDoNotice(StringUtils.isNotBlank(carUseBook.getMemberName())?(carUseBook.getMemberName()+"提交的公务用车申请"):"公务车用车申请", | 
 |  |  |                         memberList.stream().map(i->i.getErpId()).collect(Collectors.toList()) , | 
 |  |  |                         ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda() | 
 |  |  |                                 .eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO) | 
 |  |  |                                 .eq(DdNoticeConfig::getObjType,9))>Constants.ZERO? | 
 |  |  |                         dingTalk.getToDoCarUseBookFiledInfo(carUseBook):null,"pages/staff/vehicle/sendACarDetail?id="+carUseBook.getId()); | 
 |  |  |                 carUseBookMapper.update(new UpdateWrapper<CarUseBook>().lambda() | 
 |  |  |                         .set(CarUseBook::getDdToDoId,ddTalkId).eq(CarUseBook::getId,carUseBook.getId())); | 
 |  |  |             }  | 
 |  |  |         }else | 
 |  |  |             //访客申请/报备 | 
 |  |  |             if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit) | 
 |  |  |                     ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit) | 
 |  |  |                     ||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)) { | 
 |  |  |                 Visits visits = visitsMapper.selectById(approve.getObjId()); | 
 |  |  |                 if(Objects.nonNull(visits)){ | 
 |  |  |                     if(Constants.equalsInteger(visits.getStatus(),Constants.ZERO)){ | 
 |  |  |                         visitsMapper.update(null,new UpdateWrapper<Visits>().lambda().set(Visits::getStatus,Constants.ONE).eq(Visits::getId,visits.getId())); | 
 |  |  |                     } | 
 |  |  |                     SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, | 
 |  |  |                             emayService,smsEmailMapper,smsConfigMapper,visitsMapper,approveDTO.getObjId(), | 
 |  |  |                             approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)? | 
 |  |  |                                     SmsConstants.visitReportingContent.visitReportingNotice:SmsConstants.visitContent.visitNotice, | 
 |  |  |                             null,memberPhone | 
 |  |  |                     ); | 
 |  |  |                     //公众号通知 | 
 |  |  |                     if(CollectionUtils.isNotEmpty(openIdList)){ | 
 |  |  |                         wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz, | 
 |  |  |                                 wxNoticeConfigMapper,visitsMapper.selectById(approveDTO.getObjId()), | 
 |  |  |                                 approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)?WxPlatConstants.visitReportContent.visitReportWaitAudit:WxPlatConstants.visitContent.visitWaitAudit, | 
 |  |  |                                 openIdList | 
 |  |  |                         ); | 
 |  |  |                     } | 
 |  |  |                     if(Objects.nonNull(visits)&&Objects.nonNull(memberList)){ | 
 |  |  |                         //标记当前审批人已完成 | 
 |  |  |                         dingTalk.updToDoNoticeInfoStatus(visits.getDdBelongToUnionId(),visits.getDdToDoId()); | 
 |  |  |                         //TODO 缺少域名前缀内容 | 
 |  |  |                         String ddTalkId = dingTalk.toDoNotice(visits.getName()+"的访客申请", | 
 |  |  |                                 memberList.stream().map(i->i.getErpId()).collect(Collectors.toList()) , | 
 |  |  |                                 dingTalk.getToDoVisitFiledInfo(visits),"pages/appointmentDetails/appointmentDetails?id="+visits.getId()); | 
 |  |  |                         visitsMapper.update(new UpdateWrapper<Visits>().lambda() | 
 |  |  |                                 .set(Visits::getDdToDoId,ddTalkId).eq(Visits::getId,visits.getId())); | 
 |  |  |                     } | 
 |  |  |  | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 处理待办信息 | 
 |  |  |      * @param dealBusinessBean  是否需要进行更新业务数据状态 | 
 |  |  |      * @param approve  审批记录 | 
 |  |  |      * @param approveList  同级待审批数据 | 
 |  |  |      * @param dealDDToDo  是否处理 当前审批信息人的钉钉的工作通知 | 
 |  |  |      * | 
 |  |  |      */ | 
 |  |  |     public void passNextNotices(Boolean dealBusinessBean,Notices notices,Approve approve,List<Approve> approveList,List<Approve> copyList,ApproveDTO approveDTO){ | 
 |  |  |     public void passNextNotices(Boolean dealBusinessBean,Notices notices,Approve approve,List<Approve> approveList,List<Approve> copyList,ApproveDTO approveDTO,Boolean dealDDToDo){ | 
 |  |  |         //未开启下一级时,操作后的待审批人 | 
 |  |  |         String memberNames =notices.getParam5() | 
 |  |  |                 .replaceAll(","+notices.getRemark(),"") | 
 |  |  |                 .replaceAll(notices.getRemark()+",","") | 
 |  |  |                 .replaceAll(notices.getRemark(),""); | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         //1、修改自己的数据记录 | 
 |  |  |         noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() | 
 |  |  | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         if(dealDDToDo){ | 
 |  |  |             if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit) | 
 |  |  |                     ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit) | 
 |  |  |                     ||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)) { | 
 |  |  |                 Member member = memberMapper.selectById(approve.getChekorId()); | 
 |  |  |                 // 访客 三类业务数据 | 
 |  |  |                 Visits visits = visitsMapper.selectById(approveDTO.getObjId()); | 
 |  |  |                 if(Objects.nonNull(member)&&Objects.nonNull(member.getErpId()) | 
 |  |  |                         &&Objects.nonNull(visits)&&Objects.nonNull(visits.getDdToDoId())&&Objects.nonNull(visits.getDdBelongToUnionId())){ | 
 |  |  |                     dingTalk.updUserToDoNoticeInfoStatus(visits.getDdBelongToUnionId(),visits.getDdToDoId(),member.getErpId()); | 
 |  |  |                 } | 
 |  |  |             }else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( | 
 |  |  |                     Constants.approveObjectType.unCityUseCar)){ | 
 |  |  |                 Member member = memberMapper.selectById(approve.getChekorId()); | 
 |  |  |                 CarUseBook carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId()); | 
 |  |  |                 if(Objects.nonNull(member)&&Objects.nonNull(member.getErpId()) | 
 |  |  |                         &&Objects.nonNull(carUseBook)&&Objects.nonNull(carUseBook.getDdToDoId())&&Objects.nonNull(carUseBook.getDdBelongToUnionId())){ | 
 |  |  |                     dingTalk.updUserToDoNoticeInfoStatus(carUseBook.getDdBelongToUnionId(),carUseBook.getDdToDoId(),member.getErpId()); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     public void dealBusinessData(ApproveDTO approveDTO,Approve approve){ | 
 |  |  |         WxPlatNotice wxPlatNotice = new WxPlatNotice(); | 
 |  |  |         Visits visits = new Visits(); | 
 |  |  |         CarUseBook carUseBook = new CarUseBook(); | 
 |  |  |         if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit) | 
 |  |  |                 ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit) | 
 |  |  |                 ||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)){ | 
 |  |  |             // 访客 三类业务数据 | 
 |  |  |             Visits visits = visitsMapper.selectById(approveDTO.getObjId()); | 
 |  |  |             visits = visitsMapper.selectById(approveDTO.getObjId()); | 
 |  |  |             if(Objects.isNull(visits)){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到申请记录"); | 
 |  |  |             } | 
 |  |  | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             //访客报备 | 
 |  |  |             String objCode = ""; | 
 |  |  |             if(approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)){ | 
 |  |  |                 //发送短信通知 | 
 |  |  |                 SmsEmailServiceImpl.sendVisitReportSms(systemDictDataBiz, | 
 |  |  | 
 |  |  |                                 SmsConstants.visitReportingContent.visitReportingAuditFail, | 
 |  |  |                         approveDTO.getCheckInfo(),null | 
 |  |  |                 ); | 
 |  |  |                 objCode =  Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? | 
 |  |  |                         WxPlatConstants.visitReportContent.visitReportAuditSuccess:WxPlatConstants.visitReportContent.visitReportAuditFail; | 
 |  |  |  | 
 |  |  |             }else{ //访客申请 | 
 |  |  |                 //发送短信通知 | 
 |  |  |                 SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, | 
 |  |  | 
 |  |  |                                 SmsConstants.visitContent.visitAuditFail, | 
 |  |  |                         approveDTO.getCheckInfo(),null | 
 |  |  |                 ); | 
 |  |  |                 if(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)){ | 
 |  |  |                     SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, | 
 |  |  |                             emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), | 
 |  |  |                                     SmsConstants.visitContent.visitAuditSuccessToVisiter, | 
 |  |  |                             approveDTO.getCheckInfo(),null | 
 |  |  |                     ); | 
 |  |  |                 } | 
 |  |  |                 objCode =  Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? WxPlatConstants.visitContent.visitAuditSuccess: | 
 |  |  |                         WxPlatConstants.visitContent.visitAuditFail; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             visitsMapper.updateById(visits); | 
 |  |  |             //发送微信公众号 | 
 |  |  |             if(StringUtils.isNotBlank(objCode)){ | 
 |  |  |                 if(Objects.nonNull(visits) && StringUtils.isNotBlank(visits.getOpenid())){ | 
 |  |  |                     wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz, | 
 |  |  |                             wxNoticeConfigMapper,visits, objCode, | 
 |  |  |                             Arrays.asList(visits.getOpenid().split(",")) | 
 |  |  |                     ); | 
 |  |  |                 } | 
 |  |  |                 //钉钉通知 访客被访人或报备提交人 | 
 |  |  |                 Member beVisitMember = memberMapper.selectById(Constants.equalsInteger(visits.getType(),Constants.TWO)?visits.getMemberId():visits.getReceptMemberId()); | 
 |  |  |                 if(Objects.nonNull(beVisitMember)&&StringUtils.isNotBlank(beVisitMember.getDdId())){ | 
 |  |  |                     dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()), | 
 |  |  |                             beVisitMember.getDdId(), | 
 |  |  |                             ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda() | 
 |  |  |                                     .eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO) | 
 |  |  |                                     .eq(DdNoticeConfig::getObjType, Constants.equalsInteger(visits.getType(),Constants.TWO)?(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?6:7):(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?2:3)))>Constants.ZERO? | 
 |  |  |                             dingTalk.getVisitNoticeMsg(visits,visits.getName()+"的"+(Constants.equalsInteger(visits.getType(),Constants.TWO)?"访客报备":"访客申请")+","+ | 
 |  |  |                                     (Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? "已审批通过":"已审批驳回")):null | 
 |  |  |                     ); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             if(StringUtils.isNotBlank(visits.getDdBelongToUnionId()) | 
 |  |  |                     && StringUtils.isNotBlank(visits.getDdToDoId())){ | 
 |  |  |                 //标记当前钉钉审批已完成 | 
 |  |  |                 dingTalk.updToDoNoticeInfoStatus(visits.getDdBelongToUnionId(),visits.getDdToDoId()); | 
 |  |  |             } | 
 |  |  |         }else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( | 
 |  |  |                 Constants.approveObjectType.unCityUseCar)){ | 
 |  |  |             this.updDriver(approveDTO,approve,true); | 
 |  |  |             CarUseBook carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId()); | 
 |  |  |             carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId()); | 
 |  |  |             if(Objects.nonNull(carUseBook)){ | 
 |  |  |                 Member member = memberMapper.selectById(carUseBook.getMemberId()); | 
 |  |  |                 if(Objects.nonNull(member)&&StringUtils.isNotBlank(member.getPhone())){ | 
 |  |  |                 SystemUser systemUser = systemUserMapper.selectById(carUseBook.getCreator()); | 
 |  |  |                 //发送通知短息 | 
 |  |  |                 if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getMobile())){ | 
 |  |  |                     SmsEmailServiceImpl.sendCarUseSms(systemDictDataBiz, | 
 |  |  |                             emayService,smsEmailMapper,smsConfigMapper,carUseBookMapper,approveDTO.getObjId(), | 
 |  |  |                             Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?SmsConstants.carUseBookContent.carUseBookAuditSuccess: | 
 |  |  |                                     SmsConstants.carUseBookContent.carUseBookAuditFail, | 
 |  |  |                             approveDTO.getCheckInfo(),Arrays.asList(member.getPhone().split(",")) | 
 |  |  |                             approveDTO.getCheckInfo(),Arrays.asList(systemUser.getMobile().split(",")) | 
 |  |  |                     ); | 
 |  |  |                 } | 
 |  |  |                 if(Objects.nonNull(systemUser)&&StringUtils.isNotBlank(systemUser.getOpenid())){ | 
 |  |  |                     carUseBook.setMemberName(systemUser.getRealname()); | 
 |  |  |                     //发送微信公众号通知 | 
 |  |  |                     wxPlatNotice.sendCarUseBookTemplateNotice(systemDictDataBiz, | 
 |  |  |                             wxNoticeConfigMapper,carUseBook, | 
 |  |  |                             Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?WxPlatConstants.carUseBookContent.carUseBookAuditSuccess: WxPlatConstants.carUseBookContent.carUseBookAuditFail, | 
 |  |  |                             Arrays.asList(systemUser.getOpenid().split(",")),0); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             //钉钉通知发起人 | 
 |  |  |             Member creatMember = memberMapper.selectById(carUseBook.getMemberId()); | 
 |  |  |             if(Objects.nonNull(creatMember)&&StringUtils.isNotBlank(creatMember.getDdId())){ | 
 |  |  |                 dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()), | 
 |  |  |                         creatMember.getErpId(), | 
 |  |  |                         ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda() | 
 |  |  |                                 .eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO) | 
 |  |  |                                 .eq(DdNoticeConfig::getObjType,Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?10:11))>Constants.ZERO? | 
 |  |  |                                 dingTalk.getCarUseNoticeMsg(carUseBook,carUseBook.getMemberName() + "提交的公务用车,"+ | 
 |  |  |                                         (Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? "已审批通过":"已审批驳回")):null | 
 |  |  |                 ); | 
 |  |  |             } | 
 |  |  |             if(StringUtils.isNotBlank(carUseBook.getDdBelongToUnionId()) | 
 |  |  |                 && StringUtils.isNotBlank(carUseBook.getDdToDoId())){ | 
 |  |  |                 //标记当前钉钉审批已完成 | 
 |  |  |                 dingTalk.updToDoNoticeInfoStatus(carUseBook.getDdBelongToUnionId(),carUseBook.getDdToDoId()); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |         }else if(approveDTO.getObjType().equals(Constants.approveObjectType.reason)){ | 
 |  |  | 
 |  |  |                     approveDTO.getCheckInfo(),null | 
 |  |  |             ); | 
 |  |  |  | 
 |  |  |             //TODO 发送微信公众号消息 | 
 |  |  |             //发送微信公众号消息 | 
 |  |  |             SystemUser driver = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda() | 
 |  |  |                     .eq(SystemUser::getDeleted, Constants.ZERO) | 
 |  |  |                     .eq(SystemUser::getType, Constants.ZERO) | 
 |  |  |                     .eq(SystemUser::getMobile,platformBooks.getDriverPhone()) | 
 |  |  |                     .last(" limit 1 ")); | 
 |  |  |             if(Objects.nonNull(driver) && StringUtils.isNotBlank(driver.getOpenid())){ | 
 |  |  |                 //发送微信公众号通知 | 
 |  |  |                 wxPlatNotice.sendPlatformBookTemplateNotice(systemDictDataBiz, | 
 |  |  |                         wxNoticeConfigMapper, platformBooks, | 
 |  |  |                         Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?WxPlatConstants.platformBookContent.platformBookAuditSuccess: WxPlatConstants.platformBookContent.platformBookAuditFail, | 
 |  |  |                         Arrays.asList(driver.getOpenid().split(",")),0); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |         }else{ | 
 |  |  |             throw new BusinessException(ResponseStatus.BAD_REQUEST); | 
 |  |  |         } | 
 |  |  |         if(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)){ | 
 |  |  |             //处理通过 显示所有的抄送记录 | 
 |  |  |             approveMapper.update(null,new UpdateWrapper<Approve>().lambda().set(Approve::getStatus,Constants.TWO) | 
 |  |  |                     .set(Approve::getCheckDate,new Date()) | 
 |  |  |                     .eq(Approve::getObjId,approve.getObjId()) | 
 |  |  |             List<Approve> approveList = approveMapper.selectList(new QueryWrapper<Approve>().lambda().eq(Approve::getObjId,approve.getObjId()) | 
 |  |  |                     .eq(Approve::getObjType,approve.getObjType()) | 
 |  |  |                     .eq(Approve::getType,Constants.ONE) | 
 |  |  |             ); | 
 |  |  |                     .eq(Approve::getType,Constants.ONE)); | 
 |  |  |             if(CollectionUtils.isNotEmpty(approveList)){ | 
 |  |  |                 //处理通过 显示所有的抄送记录 | 
 |  |  |                 approveMapper.update(null,new UpdateWrapper<Approve>().lambda().set(Approve::getStatus,Constants.TWO) | 
 |  |  |                         .set(Approve::getCheckDate,new Date()) | 
 |  |  |                         .eq(Approve::getObjId,approve.getObjId()) | 
 |  |  |                         .eq(Approve::getObjType,approve.getObjType()) | 
 |  |  |                         .eq(Approve::getType,Constants.ONE) | 
 |  |  |                 ); | 
 |  |  |                 List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda() | 
 |  |  |                         .eq(Member::getIsdeleted,Constants.ZERO) | 
 |  |  |                         .eq(Member::getStatus,Constants.ZERO) | 
 |  |  |                         .isNotNull(Member::getDdId) | 
 |  |  |                         .in(Member::getId,approveList.stream().map(i->i.getChekorId()).collect(Collectors.toList()))); | 
 |  |  |                 if(CollectionUtils.isNotEmpty(memberList)){ | 
 |  |  |                     if(Objects.nonNull(visits)||Objects.nonNull(carUseBook)){ | 
 |  |  |                         dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()), | 
 |  |  |                                 StringUtils.join(memberList.stream().map(i->i.getDdId()).collect(Collectors.toList()),","), | 
 |  |  |                                 ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda() | 
 |  |  |                                                 .eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO) | 
 |  |  |                                                 .eq(DdNoticeConfig::getObjType, Objects.nonNull(visits)?(Constants.equalsInteger(visits.getType(),Constants.TWO)?8:4):12))>Constants.ZERO? | 
 |  |  |                                         Objects.nonNull(visits)? | 
 |  |  |                                                 dingTalk.getVisitNoticeMsg(visits,visits.getName()+"的"+(Constants.equalsInteger(visits.getType(),Constants.TWO)?"访客报备":"访客申请")+",抄送给您,请知晓"): | 
 |  |  |                                                 dingTalk.getCarUseNoticeMsg(carUseBook,carUseBook.getMemberName() + "提交的公务用车,抄送给您,请知晓"):null | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |                         ); | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |         if(approveDTO.getStatus()==Constants.TWO&&Constants.equalsInteger(approve.getDriverParam(),Constants.ONE)){ | 
 |  |  |             CarDriver carDriver = carDriverMapper.selectOne(new QueryWrapper<CarDriver>().lambda() | 
 |  |  |                     .eq(CarDriver::getIsdeleted,Constants.ZERO) | 
 |  |  |                     .eq(CarDriver::getStatus,Constants.ZERO) | 
 |  |  | //                    .eq(CarDriver::getStatus,Constants.ZERO) | 
 |  |  |                     .eq(CarDriver::getMemberId,approveDTO.getDriverId())); | 
 |  |  |             if(Objects.isNull(carDriver)){ | 
 |  |  |                 throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到司机信息"); |