From c3aaf28f7316cce12eec007a9f85a96cbcddeec2 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期三, 07 五月 2025 10:34:20 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java | 867 ++++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 727 insertions(+), 140 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java index 384cdcc..d4ecce3 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java @@ -4,19 +4,32 @@ import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; -import com.doumee.core.model.PageData; -import com.doumee.core.model.PageWrap; +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.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.CarUseBookJoinMapper; 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; @@ -27,16 +40,13 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.doumee.service.system.NoticesService; +import com.doumee.service.business.third.EmayService; import com.github.xiaoymin.knife4j.core.util.CollectionUtils; import com.github.yulichang.wrapper.MPJLambdaWrapper; -import io.swagger.models.auth.In; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.apache.xpath.operations.Bool; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -60,6 +70,8 @@ @Autowired private SystemDictDataBiz systemDictDataBiz; + @Autowired + private WxNoticeConfigMapper wxNoticeConfigMapper; @Autowired private ApproveTemplMapper approveTemplMapper; @@ -75,40 +87,57 @@ @Autowired private CarUseBookMapper carUseBookMapper; + + @Autowired + private SystemUserMapper systemUserMapper; @Autowired private CarDriverMapper carDriverMapper; - @Autowired - private VisitsMapper visitsMapper; @Autowired - private VisitsJoinMapper visitsJoinMapper; + private VisitsJoinMapper visitsMapper; @Autowired private CarUseBookJoinMapper carUseBookJoinMapper; @Autowired private NoticesJoinMapper noticesJoinMapper; - - - + @Autowired + private PlatformBooksMapper platformBooksMapper; + @Autowired + private PlatformJobMapper platformJobMapper; + @Autowired + private PlatformLogMapper platformLogMapper; + @Autowired + 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; @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)) { @@ -253,14 +282,16 @@ if(CollectionUtils.isNotEmpty(noticesList)){ //寰呮垜澶勭悊鐨勬暟鎹� internalHomeVO.setNoticeWaitNum( - noticesList.stream().filter(i->Constants.equalsInteger(i.getUserId(),memberId) + noticesList.stream().filter(i-> + Constants.equalsInteger(i.getUserId(),memberId) &&Constants.equalsInteger(i.getStatus(),Constants.ZERO) &&Constants.equalsInteger(i.getSendacopy(),Constants.ZERO) ).count() ); //宸插鐞嗘暟鎹� internalHomeVO.setNoticeDealNum( - noticesList.stream().filter(i->Constants.equalsInteger(i.getUserId(),memberId) + noticesList.stream().filter(i-> + Constants.equalsInteger(i.getUserId(),memberId) &&StringUtils.equals(i.getParam4(),i.getUserId().toString()) &&Constants.equalsInteger(i.getStatus(),Constants.ONE) &&Constants.equalsInteger(i.getSendacopy(),Constants.ZERO) @@ -274,6 +305,7 @@ internalHomeVO.setNoticeCopyNum( noticesList.stream().filter(i->Constants.equalsInteger(i.getUserId(),memberId) &&Constants.equalsInteger(i.getSendacopy(),Constants.ONE) + &&Constants.equalsInteger(i.getReaded(),Constants.ZERO) ).count() ); } @@ -319,6 +351,7 @@ internalHomeVO.setNoticeCopyNum( noticesList.stream().filter(i->Constants.equalsInteger(i.getUserId(),noticesDTO.getMemberId()) &&Constants.equalsInteger(i.getSendacopy(),Constants.ONE) + &&Constants.equalsInteger(i.getReaded(),Constants.ZERO) ).count() ); } @@ -331,10 +364,11 @@ * @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) @@ -361,13 +395,56 @@ } 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,applyMember,businessId,approveList); + if(CollectionUtils.isEmpty(approveList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴侀厤缃敊璇�"); + } + //澶勭悊鎶勯�佹暟鎹� + if(CollectionUtils.isNotEmpty(approveCopyList)){ + this.organizeApproveCopyData(approveTempl,approveCopyList,businessId,approveList); + } + approveJoinMapper.insert(approveList); - this.organizeApproveData(approveTempl,approveParamList,createMember,businessId,approveList); + } + + + @Override + @Transactional(rollbackFor = {Exception.class,BusinessException.class}) + public void createApproveForPlatfrom(Integer tempId,Integer businessId,Integer createMemberId ){ + //鏌ヨ澶勭悊妯℃澘 + ApproveTempl approveTempl = approveTemplMapper.selectById(tempId); + if(Objects.isNull(approveTempl)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌瀹℃壒娴侀厤缃ā鏉�"); + } + //鏌ヨ閰嶇疆娴佺▼ + List<ApproveParam> approveParamAllList = approveParamMapper.selectList(new QueryWrapper<ApproveParam>() + .lambda().eq(ApproveParam::getIsdeleted,Constants.ZERO) + .eq(ApproveParam::getTemplId,approveTempl.getId()) + .orderByAsc(ApproveParam::getType) + .orderByAsc(ApproveParam::getLevel) + ); + if(Objects.isNull(approveParamAllList)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈厤缃鎵规祦绋�"); + } + //瀹℃壒閰嶇疆 + List<ApproveParam> approveParamList = approveParamAllList.stream().filter(i->i.getType().equals(Constants.ZERO)).collect(Collectors.toList()); + if(Objects.isNull(approveParamList)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈厤缃鎵规祦绋�"); + } + List<ApproveParam> approveCopyList = approveParamAllList.stream().filter(i->i.getType().equals(Constants.ONE)).collect(Collectors.toList()); + + Member createMember = memberMapper.selectById(createMemberId); + if(Objects.isNull(createMember)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鐢宠浜虹粍缁囦俊鎭紓甯�"); + } + List<Approve> approveList = new ArrayList<>(); + + this.organizeApproveData(approveTempl,approveParamList,createMember,null,businessId,approveList); if(CollectionUtils.isEmpty(approveList)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴侀厤缃敊璇�"); @@ -375,11 +452,9 @@ //澶勭悊鎶勯�佹暟鎹� if(CollectionUtils.isNotEmpty(approveCopyList)){ - this.organizeApproveCopyData(approveTempl,approveParamList,businessId,approveList); + this.organizeApproveCopyData(approveTempl,approveCopyList,businessId,approveList); } approveJoinMapper.insert(approveList); -// approveJoinMapper.insert(approveList); - } @@ -391,15 +466,18 @@ * @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("鍙戣捣鐢宠"); @@ -414,37 +492,55 @@ createUserApprove.setType(Constants.ZERO); 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.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()); - String title = "銆愯瀹㈢敵璇枫�戠敵璇蜂汉 - "; + String title = "[璁垮鐢宠]鐢宠浜�-"; Map<String,Object> jsonMap = new HashMap<>(); - for (int j = 0; j < ids.size(); j++) { - Integer memberId = ids.get(j); + for (int j = 0; j < memberList.size(); j++) { + Member member = memberList.get(j); + Integer memberId = member.getId(); //鐢熸垚寰呭姙 notices 琛ㄦ暟鎹� if(i==0){ if(jsonMap.isEmpty()){ 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(),"鏈煡璇㈠埌瀹℃壒浜轰俊鎭�"); } Notices notices = new Notices(); notices.setCreateDate(new Date()); @@ -461,7 +557,13 @@ notices.setSendacopy(Constants.ZERO); notices.setParam2("0"); notices.setParam3(""); - notices.setInfo("寰呭鐞�"); + notices.setParam5(memberNames); + notices.setRemark(member.getName()); + if(Constants.equalsInteger(memberNameList.size(),Constants.ONE)){ + notices.setInfo("寰�"+memberNameList.get(0)+"澶勭悊涓�"); + }else{ + notices.setInfo("寰�"+memberNameList.get(0)+"绛�"+memberList.size()+"浜哄鐞嗕腑"); + } noticesJoinMapper.insert(notices); } Approve approve = new Approve(); @@ -471,8 +573,8 @@ approve.setTemplatId(approveTempl.getId()); approve.setChekorId(memberId); approve.setStatus(i==0?Constants.ONE:Constants.ZERO); - approve.setStatusInfo(i==0?"瀹℃壒涓�":"寰呭鎵�"); - approve.setTitle("瀹℃壒浜�"); + approve.setStatusInfo(i==0?"瀹℃壒涓�":"寰呭鐞�"); + approve.setTitle(StringUtils.isBlank(approveParam.getRemark())?"瀹℃壒涓�":approveParam.getRemark()); approve.setIsEndCheck((i+1) == approveParamList.size()?Constants.ONE:Constants.ZERO); approve.setObjId(businessId); approve.setLevel(i+1); @@ -482,6 +584,82 @@ approve.setAddrParam(approveParam.getAddrParam()); 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)){ + //鐗╂祦杞﹂绾� + SmsEmailServiceImpl.sendPlatformBookSms(systemDictDataBiz, + emayService,smsEmailMapper,smsConfigMapper,platformBooksMapper,businessId, + 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, + emayService,smsEmailMapper,smsConfigMapper,visitsMapper,businessId, + 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, + emayService,smsEmailMapper,smsConfigMapper,carUseBookMapper,businessId, + 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); + } + } + } + } + } + + } } } @@ -493,7 +671,7 @@ 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) @@ -508,7 +686,7 @@ if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit)){ title = title + visits.getName(); }else{ - title = "銆愯瀹㈡姤澶囥�戠敵璇蜂汉 - " + visits.getName(); + title = "[璁垮鎶ュ]鐢宠浜�-" + visits.getName(); } jsonMap.put("name", "璁块棶浜�:" + visits.getCompanyName() + " - " + visits.getReceptMemberName()); jsonMap.put("sTime", "鍏ュ洯鏃堕棿:" + DateUtil.DateToStr(visits.getStarttime() , "yyyy-MM-dd HH:mm")); @@ -529,14 +707,23 @@ if(Objects.isNull(carUseBook)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏈煡璇㈠埌涓氬姟鏁版嵁淇℃伅"); } - title = "銆愮敤杞︾敵璇枫�戠敵璇蜂汉 - " + carUseBook.getMemberName(); + title = "[鐢ㄨ溅鐢宠]鐢宠浜�-" + carUseBook.getMemberName(); jsonMap.put("name", "鐢宠浜�:" + carUseBook.getCompanyName() + " - " + carUseBook.getMemberName()); jsonMap.put("sTime", "寮�濮嬫椂闂�:" + DateUtil.DateToStr(carUseBook.getStartTime() , "yyyy-MM-dd HH:mm")); jsonMap.put("eTime", "缁撴潫鏃堕棿:" + DateUtil.DateToStr(carUseBook.getEndTime() , "yyyy-MM-dd HH:mm")); jsonMap.put("usrNum", StringUtils.isBlank(carUseBook.getMemberIds())?"涔樿溅浜烘暟: 0浜�": "涔樿溅浜烘暟: " +carUseBook.getMemberIds().split(",").length +"浜�"); jsonMap.put("mdd", StringUtils.isBlank(carUseBook.getAddr())?"鐩殑鍦�: - ": "鐩殑鍦�:" +carUseBook.getAddr()); - }else { - throw new BusinessException(ResponseStatus.NOT_ALLOWED); + }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.reason)){ + //鐗╂祦杞﹂绾� + PlatformBooks platformBooks = platformBooksMapper.selectById(businessId); + 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()); } return title; } @@ -575,6 +762,7 @@ approve.setIsdeleted(Constants.ZERO); approve.setTemplatId(approveTempl.getId()); approve.setChekorId(memberId); + approve.setObjType(approveTempl.getType()); approve.setObjId(businessId); approve.setType(Constants.ONE); approveList.add(approve); @@ -608,7 +796,7 @@ if(Objects.isNull(memberCompany)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴侀厤缃敊璇痆鎸囧畾瀹℃壒閮ㄩ棬鏈煡璇㈠埌]"); } - Company auditCompany = this.getAuditCompanyHead(memberCompany.getParentId(),approveParam.getObjLevel()); + Company auditCompany = this.getAuditCompanyHead(memberCompany.getId(),approveParam.getObjLevel()); if(Objects.isNull(auditCompany)){ //瀹℃壒閮ㄩ棬涓虹┖ 鑷姩娴佽浆涓嬩竴绾у鎵归厤缃� throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴侀厤缃敊璇痆鎸囧畾瀹℃壒閮ㄩ棬鏈煡璇㈠埌]"); @@ -617,7 +805,7 @@ Member headMember = memberMapper.selectById(auditCompany.getHeadId()); if(Objects.isNull(headMember)){ //鏈煡璇㈠埌閮ㄩ棬璐熻矗浜� 鏍规嵁閰嶇疆澶勭悊 鐢变笂绾т富绠′唬鏇垮鏍�/鐩存帴缁撴潫娴佺▼ - if(approveParam.getNoleaderOpt().equals(Constants.ONE)&&!Objects.isNull(auditCompany.getParentId())){ + if(Constants.equalsInteger(approveParam.getNoleaderOpt(),Constants.ONE)&&Objects.nonNull(auditCompany.getParentId())){ auditCompany = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getId,auditCompany.getParentId())); //鏃犵埗绾� 鐩存帴娴佷紶涓嬩竴绾у鎵� if(Objects.isNull(auditCompany)){ @@ -632,9 +820,11 @@ userIds.add(headMember.getId()); } }else{ - //娣诲姞瀹℃壒浜� - userIds.add(headMember.getId()); + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴侀厤缃敊璇痆鎸囧畾瀹℃壒閮ㄩ棬涓荤鏈煡璇㈠埌]"); } + }else{ + //娣诲姞瀹℃壒浜� + userIds.add(headMember.getId()); } } } @@ -649,9 +839,12 @@ * @param objLevel 鏌ヨ绾у埆 */ public Company getAuditCompanyHead(Integer companyId, Integer objLevel){ - Integer queryLevel = Constants.ZERO; + if(Objects.isNull(objLevel)||Objects.isNull(companyId)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴侀厤缃紓甯革紝璇疯仈绯荤鐞嗗憳"); + } Company auditCompany = companyMapper.selectById(companyId); - while(queryLevel.equals(objLevel)){ + Integer queryLevel = Constants.ONE; + while(queryLevel<objLevel){ auditCompany = companyMapper.selectById(auditCompany.getParentId()); if(Objects.isNull(auditCompany)){ return null; @@ -680,6 +873,8 @@ .eq(Approve::getObjId,businessId) .eq(Approve::getObjType,businessType) .orderByAsc(Approve::getLevel) + .orderByAsc(Approve::getStatus) + ); //鏌ユ壘鍏ㄩ儴levelList @@ -697,6 +892,7 @@ if (CollectionUtils.isNotEmpty(copyList)) { Approve waitModel = new Approve(); waitModel.setApproveType(Constants.ONE); + waitModel.setCheckDate(copyList.get(Constants.ZERO).getCheckDate()); waitModel.setTitle("鎶勯�佷汉"); waitModel.setStatus(copyList.get(Constants.ZERO).getStatus()); waitModel.setType(Constants.ONE); @@ -718,7 +914,7 @@ private List<Approve> getLevelInfoFromList(Approve level,List<Approve> approveGroupList) { List<Approve> list = new ArrayList<>(); if(Constants.equalsInteger(level.getApproveType(),Constants.TWO)){ - level.setApproveType(Constants.ZERO); + level.setApproveType(Constants.TWO); //濡傛灉鏄崟浜哄鎵� list.add(level); return list; @@ -745,11 +941,17 @@ waitModel.setType(Constants.ZERO); waitModel.setTitle(StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�")); waitModel.setStatus(Constants.equalsInteger(waitList.get(Constants.ZERO).getStatus(),Constants.ONE)?Constants.ONE:Constants.ZERO); - waitModel.setStatusInfo("澶勭悊涓�"); - if(Constants.equalsInteger(level.getStatus(),Constants.approveStatus.auditIng) - ||Constants.equalsInteger(level.getStatus(),Constants.approveStatus.pass)){ - waitModel.setMemberName(waitList.size() +"浜轰細绛�"); + if(Constants.equalsInteger(waitModel.getStatus(),Constants.approveStatus.wait)){ + waitModel.setStatusInfo("寰呭鐞�"); + }else if(Constants.equalsInteger(waitModel.getStatus(),Constants.approveStatus.auditIng)){ + waitModel.setStatusInfo("澶勭悊涓�"); } + + waitModel.setMemberName(waitList.size() +"浜轰細绛�"); +// if(Constants.equalsInteger(level.getStatus(),Constants.approveStatus.auditIng) +// ||Constants.equalsInteger(level.getStatus(),Constants.approveStatus.pass)){ +// waitModel.setMemberName(waitList.size() +"浜轰細绛�"); +// } if(CollectionUtils.isNotEmpty(waitList)){ waitModel.setCreateDate(waitList.get(Constants.ZERO).getCreateDate()); } @@ -764,15 +966,17 @@ }else { if((waitList.size()> 0 || otherPassList.size()>0)){ Approve waitModel = new Approve(); - waitModel.setApproveType(Constants.ONE); + waitModel.setApproveType(Constants.ZERO); if(Constants.equalsInteger(level.getStatus(),Constants.approveStatus.pass)){ - waitModel.setStatus(Constants.approveStatus.pass); + waitModel.setStatus(level.getStatus()); waitModel.setType(Constants.ONE); - waitModel.setTitle("瀹℃壒浜猴紙鎶勯�佹垨绛惧鎵逛汉锛�"); + waitModel.setCheckDate(level.getCheckDate()); + waitModel.setTitle(StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�")); }else{ + waitModel.setStatus(level.getStatus()); waitModel.setType(Constants.ZERO); - waitModel.setStatusInfo(passList.size()<=0?StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�"):"鎶勯�佹垨绛惧鎵逛汉"); - waitModel.setStatus(passList.size()>0?Constants.ONE:Constants.ZERO); + waitModel.setTitle(passList.size()<=0?StringUtils.defaultString(level.getTitle(),"瀹℃壒浜�"):"鎶勯�佹垨绛惧鎵逛汉"); + } List<Approve> approveList = new ArrayList<>(); approveList.addAll(waitList); @@ -786,7 +990,11 @@ if(Constants.equalsInteger(waitModel.getStatus(),Constants.approveStatus.pass)){ waitModel.setMemberName("宸叉妱閫�"+ approveList.size() +"浜�"); }else if(Constants.equalsInteger(waitModel.getStatus(),Constants.approveStatus.wait)){ - waitModel.setMemberName("澶勭悊涓�"); + waitModel.setMemberName(waitList.size() +"浜烘垨绛�"); + waitModel.setStatusInfo("寰呭鐞�"); + }else{ + waitModel.setMemberName(waitList.size() +"浜烘垨绛�"); + waitModel.setStatusInfo("澶勭悊涓�"); } waitModel.setApproveList(approveList); list.add(waitModel); @@ -966,6 +1174,23 @@ return Constants.ZERO; } + @Override + public String getApproveUserName(Integer businessId,Integer businessType){ + List<Approve> approveList = approveJoinMapper.selectJoinList(Approve.class,new MPJLambdaWrapper<Approve>() + .selectAll(Approve.class) + .selectAs(Member::getName,Approve::getMemberName) + .leftJoin(Member.class,Member::getId,Approve::getChekorId) + .eq(Approve::getObjId,businessId) + .eq(Approve::getObjType,businessType) + .eq(Approve::getType,Constants.ZERO) + .eq(Approve::getStatus,Constants.approveStatus.auditIng) + ); + if(CollectionUtils.isNotEmpty(approveList)){ + List<String> names = approveList.stream().map(m->m.getMemberName()).collect(Collectors.toList()); + return String.join(",",names); + } + return null; + } @@ -973,6 +1198,7 @@ @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()) @@ -993,7 +1219,7 @@ .last(" limit 1") ); if(Objects.isNull(approve)){ - throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌瀹℃壒鏁版嵁"); + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鐢宠宸茶浠栦汉瀹℃壒"); } if(!approve.getStatus().equals(Constants.ONE)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒璁板綍鐘舵�侀敊璇�!"); @@ -1006,6 +1232,7 @@ .eq(Notices::getUserId,approve.getChekorId()) .eq(Notices::getSendacopy,Constants.ZERO) .eq(Notices::getIsdeleted,Constants.ZERO) + .eq(Notices::getStatus,Constants.ZERO) .last(" limit 1 ") ); if(Objects.isNull(notices)){ @@ -1057,29 +1284,29 @@ .eq(Approve::getObjType,approve.getObjType()) .ne(Approve::getId,approve.getId())); //澶勭悊鎵�鏈塏otice閫氱煡涓哄凡澶勭悊 - if(approve.getApproveType().equals(Constants.ZERO)){ - //淇敼鑷繁鐨勯�氱煡璁板綍 + //淇敼鑷繁鐨勯�氱煡璁板綍 + noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() + .set(Notices::getEditDate,new Date()) + .set(Notices::getParam4,approveDTO.getLoginUserInfo().getMemberId()) + .set(Notices::getInfo,"宸叉嫆缁�") + .set(Notices::getReaded,Constants.ONE) + .set(Notices::getParam2,Constants.TWO) + .set(Notices::getStatus,Constants.ONE) + .eq(Notices::getId,notices.getId()) + ); + //淇敼 鏈鐞嗙殑 閫氱煡鏁版嵁 涓烘妱閫� + if (!Constants.equalsInteger(approve.getApproveType(),Constants.TWO)){ noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() .set(Notices::getEditDate,new Date()) - .set(Notices::getParam4,approveDTO.getLoginUserInfo().getMemberId()) - .set(Notices::getReaded,Constants.ONE) - .set(Notices::getParam2,Constants.TWO) + .set(Notices::getSendacopy,Constants.ONE) .set(Notices::getStatus,Constants.ONE) - .eq(Notices::getId,notices.getId()) + .set(Notices::getParam2,Constants.TWO) + .set(Notices::getInfo,"宸叉嫆缁�") + .eq(Notices::getObjId,notices.getObjId()) + .eq(Notices::getObjType,notices.getObjType()) +// .eq(Notices::getReaded,Constants.ZERO) + .ne(Notices::getId,notices.getId()) ); - //淇敼 鏈鐞嗙殑 閫氱煡鏁版嵁 涓烘妱閫� - if (!Constants.equalsInteger(approve.getApproveType(),Constants.TWO)){ - noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() - .set(Notices::getEditDate,new Date()) - .set(Notices::getSendacopy,Constants.ONE) - .set(Notices::getStatus,Constants.ONE) - .set(Notices::getParam2,Constants.TWO) - .eq(Notices::getObjId,notices.getObjId()) - .eq(Notices::getObjType,notices.getObjType()) - .eq(Notices::getReaded,Constants.ZERO) - .ne(Notices::getId,notices.getId()) - ); - } } }else{ //澶勭悊鍏朵粬涓氬姟鏁版嵁 @@ -1106,6 +1333,19 @@ .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::getLevel,(approve.getLevel()+1))); + approveJoinMapper.update(null,new UpdateWrapper<Approve>() .lambda() .set(Approve::getStatus,Constants.approveStatus.auditIng) @@ -1116,15 +1356,62 @@ .eq(Approve::getObjType,approve.getObjType()) .eq(Approve::getLevel,(approve.getLevel()+1)) ); - if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( - Constants.approveObjectType.unCityUseCar)){ - this.updDriver(approveDTO,approve,false); - } + + //鍙戦�佺煭淇¢�氱煡 涓嬬骇瀹℃壒浜� + 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); +// } }else if(approve.getApproveType().equals(Constants.ONE)){ //浼氱 涓旂粓瀹� //鏃犱粬浜哄鎵圭殑鎯呭喌 鍒欎慨鏀规暟鎹姸鎬� 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) + .set(Approve::getTitle,"瀹℃壒浜�") + .set(Approve::getCheckDate,new Date()) + .eq(Approve::getStatus,Constants.approveStatus.wait) + .eq(Approve::getObjId,approve.getObjId()) + .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); +// } } } this.passNextNotices(dealBusinessBean,notices,approve,approveList,approveCopyList,approveDTO); @@ -1135,6 +1422,83 @@ } } + + + + public void sendNextLvSms(Approve approve ,ApproveDTO approveDTO , List<String> memberPhone ,List<String> openIdList){ + WxPlatNotice wxPlatNotice = new WxPlatNotice(); + //鐗╂祦杞﹂绾� + 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); + //鍙戦�佸叕浼楀彿閫氱煡 + if(CollectionUtils.isNotEmpty(openIdList)){ + CarUseBook carUseBook = carUseBookMapper.selectById(approve.getObjId()); + if(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); + } + } + } + }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 + ); + } + + } + } + } + + + /** * 澶勭悊寰呭姙淇℃伅 * @param dealBusinessBean 鏄惁闇�瑕佽繘琛屾洿鏂颁笟鍔℃暟鎹姸鎬� @@ -1142,81 +1506,102 @@ * @param approveList 鍚岀骇寰呭鎵规暟鎹� */ public void passNextNotices(Boolean dealBusinessBean,Notices notices,Approve approve,List<Approve> approveList,List<Approve> copyList,ApproveDTO approveDTO){ + //鏈紑鍚笅涓�绾ф椂锛屾搷浣滃悗鐨勫緟瀹℃壒浜� + String memberNames =notices.getParam5() + .replaceAll(","+notices.getRemark(),"") + .replaceAll(notices.getRemark()+",","") + .replaceAll(notices.getRemark(),""); + + + //1銆佷慨鏀硅嚜宸辩殑鏁版嵁璁板綍 noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() .set(Notices::getEditDate,new Date()) .set(Notices::getReaded,Constants.ONE) .set(Notices::getStatus,Constants.ONE) + .set(Notices::getInfo,Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?"宸查�氳繃":"宸叉嫆缁�") .set(dealBusinessBean,Notices::getParam2,Constants.ONE) .set(Notices::getParam4,approveDTO.getLoginUserInfo().getMemberId()) .eq(Notices::getId,notices.getId()) ); if(Constants.equalsInteger(approve.getApproveType(),Constants.ZERO)){ //鎴栫 - //2銆佹洿鏂颁粬浜虹殑鍚岀骇璁板綍 涓烘妱閫� + //2銆佹洿鏂颁粬浜虹殑鍚岀骇璁板綍 涓烘妱閫� 骞舵洿鏂� info 淇℃伅 noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() .set(Notices::getEditDate,new Date()) - .set(Notices::getReaded,Constants.ONE) + .set(Notices::getReaded,Constants.ZERO) .set(Notices::getSendacopy,Constants.ONE) .set(Notices::getStatus,Constants.ONE) .set(Notices::getParam4,approveDTO.getLoginUserInfo().getMemberId()) .set(dealBusinessBean,Notices::getParam2,Constants.ONE) .eq(Notices::getObjId,notices.getObjId()) + .eq(Notices::getStatus,Constants.ZERO) .eq(Notices::getObjType,notices.getObjType()) .ne(Notices::getId,notices.getId()) ); //3銆佸鏋滀笉鏄粓瀹$敓鎴愪笅涓�绾х殑鏁版嵁璁板綍 if(Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)&&!dealBusinessBean){ - this.saveNextNotice(notices,approve); + memberNames = this.saveNextNotice(notices,approve); } }else if(Constants.equalsInteger(approve.getApproveType(),Constants.ONE)){ //浼氱 //2銆佸鏋滄槸鏈�鍚庝竴浣嶅鎵逛汉 涓斾笉鏄粓瀹″紑鍚笅涓�绾ф暟鎹� if(Constants.equalsInteger(Constants.ZERO,approveList.size())){ if(Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)){ - this.saveNextNotice(notices,approve); + memberNames = this.saveNextNotice(notices,approve); } } }else{ //鍗曚汉绛� //2銆� 鏄惁鏄粓瀹� 寮�鍚笅涓�绾ф暟鎹� if(Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)){ - this.saveNextNotice(notices,approve); + memberNames = this.saveNextNotice(notices,approve); } } + String info = ""; + List<String> memberNameList = Arrays.asList(memberNames.split(",")); + if(Constants.equalsInteger(memberNameList.size(),Constants.ONE)){ + info = "寰�"+memberNameList.get(0)+"澶勭悊涓�"; + }else{ + info = "寰�"+memberNameList.get(0)+"绛�"+memberNameList.size()+"浜哄鐞嗕腑"; + } + //鏇存柊璇ヤ笟鍔℃暟鎹殑鎵�鏈夎褰曚俊鎭� + noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda() + .set(!dealBusinessBean,Notices::getInfo,info) + .set(dealBusinessBean,Notices::getInfo,"宸查�氳繃") + .set(Notices::getParam5,memberNames) + .eq(Notices::getObjId,notices.getObjId()) + .eq(Notices::getObjType,notices.getObjType())); + //缁堝涓氬姟 涓� 澶勭悊鏁版嵁 杩涜鎶勯�佸彂閫� if (Constants.equalsInteger(approve.getIsEndCheck(),Constants.ONE) && dealBusinessBean) { if(CollectionUtils.isNotEmpty(copyList)){ - Notices copyNotices = new Notices(); for (Approve copyApprove:copyList) { - if(Objects.isNull(copyNotices)){ - BeanUtils.copyProperties(notices,copyNotices); - notices.setId(null); - notices.setCreateDate(new Date()); - notices.setEditDate(new Date()); - notices.setParam2("2"); - notices.setParam3(""); - notices.setUserId(copyApprove.getChekorId()); - notices.setStatus(Constants.ZERO); - notices.setSendacopy(Constants.ONE); - notices.setReaded(Constants.ZERO); - noticesJoinMapper.insert(notices); - }else{ - notices.setId(null); - notices.setUserId(copyApprove.getChekorId()); - noticesJoinMapper.insert(notices); - } + Notices copyNotices = new Notices(); + BeanUtils.copyProperties(notices,copyNotices); + copyNotices.setId(null); + copyNotices.setCreateDate(new Date()); + copyNotices.setEditDate(new Date()); + copyNotices.setParam2("2"); + copyNotices.setParam3(""); + copyNotices.setInfo("宸查�氳繃"); + copyNotices.setUserId(copyApprove.getChekorId()); + copyNotices.setStatus(Constants.ZERO); + copyNotices.setSendacopy(Constants.ONE); + copyNotices.setReaded(Constants.ZERO); + noticesJoinMapper.insert(copyNotices); } } - - } } - public void saveNextNotice(Notices notices,Approve approve){ - List<Approve> nextApproveList = approveJoinMapper.selectList(new QueryWrapper<Approve>() - .lambda() + + public String saveNextNotice(Notices notices,Approve approve){ + List<Approve> nextApproveList = approveJoinMapper.selectJoinList(Approve.class,new MPJLambdaWrapper<Approve>() + .selectAll(Approve.class) + .selectAs(Member::getName,Approve::getMemberName) + .leftJoin(Member.class,Member::getId,Approve::getChekorId) .eq(Approve::getObjId,approve.getObjId()) .eq(Approve::getObjType,approve.getObjType()) .eq(Approve::getType,Constants.ZERO) @@ -1225,29 +1610,36 @@ if(CollectionUtils.isEmpty(nextApproveList)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀹℃壒娴佹暟鎹紓甯�"); } - Notices newNotices = new Notices(); + List<String> memberNameList =nextApproveList.stream().map(m->m.getMemberName()).collect(Collectors.toList()); + String memberNames = String.join(",",memberNameList); for (Approve nextDealApprove:nextApproveList) { - if(Objects.isNull(newNotices)){ - BeanUtils.copyProperties(notices,newNotices); - notices.setId(null); - notices.setCreateDate(new Date()); - notices.setParam2("0"); - notices.setParam3(""); - notices.setEditDate(new Date()); - notices.setUserId(nextDealApprove.getChekorId()); - notices.setStatus(Constants.ZERO); - notices.setSendacopy(Constants.ZERO); - notices.setReaded(Constants.ZERO); - noticesJoinMapper.insert(notices); + Notices newNotices = new Notices(); + BeanUtils.copyProperties(notices,newNotices); + newNotices.setId(null); + newNotices.setCreateDate(new Date()); + newNotices.setParam2("0"); + newNotices.setParam3(""); + newNotices.setEditDate(new Date()); + newNotices.setUserId(nextDealApprove.getChekorId()); + newNotices.setStatus(Constants.ZERO); + newNotices.setSendacopy(Constants.ZERO); + newNotices.setReaded(Constants.ZERO); + notices.setParam5(memberNames); + notices.setRemark(nextDealApprove.getMemberName()); + if(Constants.equalsInteger(memberNameList.size(),Constants.ONE)){ + notices.setInfo("寰�"+memberNameList.get(0)+"澶勭悊涓�"); }else{ - notices.setId(null); - notices.setUserId(nextDealApprove.getChekorId()); - noticesJoinMapper.insert(notices); + notices.setInfo("寰�"+memberNameList.get(0)+"绛�"+memberNameList.size()+"浜哄鐞嗕腑"); } + noticesJoinMapper.insert(newNotices); } + return memberNames; } + + public void dealBusinessData(ApproveDTO approveDTO,Approve approve){ + WxPlatNotice wxPlatNotice = new WxPlatNotice(); if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit) ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit) ||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)){ @@ -1259,15 +1651,210 @@ visits.setStatus(approveDTO.getStatus()); visits.setEditDate(new Date()); visits.setEditor(approveDTO.getLoginUserInfo().getMemberId()); + //涓嬪彂璁垮鎶ュ杞﹁締淇℃伅 + if(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)&&approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)){ + Boolean sendStatus = true; + //鏌ヨ褰撳墠鍚敤鐨勫仠杞﹀満 + List<Parks> parksList = parksMapper.selectList(new QueryWrapper<Parks>() + .lambda() + .isNotNull(Parks::getHkId) + .eq(Parks::getIsdeleted,Constants.ZERO)); + List<VisitPark> parkBookList = new ArrayList<>(); + if(CollectionUtils.isNotEmpty(parksList)){ + for (Parks parks:parksList) { + VisitPark visitPark = new VisitPark(); + visitPark.setIsdeleted(Constants.ZERO); + visitPark.setCreateDate(new Date()); + visitPark.setVisitApplyId(visits.getId().toString()); + visitPark.setCarCode(visits.getCarNos()); + visitPark.setParkId(parks.getId().toString()); + visitPark.setStartTime(visits.getStarttime()); + visitPark.setEndTime(visits.getEndtime()); + visitPark.setParkHkId(parks.getHkId()); + visitPark.setObjType(Constants.ZERO); + + ParkReservationAddRequest request = new ParkReservationAddRequest(); + request.setPlateNo(visitPark.getCarCode()); + request.setParkSyscode(visitPark.getParkHkId()); + request.setPhoneNo(visits.getPhone()); + request.setOwner(visits.getName()); + request.setAllowTimes(Constants.ONE+""); + request.setIsCharge(Constants.ONE+""); + request.setStartTime(Objects.isNull(visitPark.getStartTime())?DateUtil.getISO8601Timestamp2(new Date()):DateUtil.getISO8601Timestamp2(visitPark.getStartTime())); + request.setEndTime(Objects.isNull(visitPark.getEndTime())?"2999-12-31T00:00:00+08:00":DateUtil.getISO8601Timestamp2(visitPark.getEndTime())); + BaseResponse response = HKService.parkReservationAddition(request); + + visitPark.setHkDate(new Date()); + if(response!=null + && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ + ParkReservationAddResponse parkReservationAddResponse = (ParkReservationAddResponse) response.getData(); + visitPark.setHkId(parkReservationAddResponse.getReserveOrderNo()); + visitPark.setHkStatus(Constants.ONE); + visitPark.setRemark("鍖呮湡鎴愬姛"); + }else{ + visitPark.setHkStatus(Constants.TWO); + visitPark.setRemark("鍖呮湡澶辫触~"); + //涓嬪彂澶辫触 鏍囪涓讳笟鍔$姸鎬佷负涓嬪彂澶辫触 + sendStatus = false; + } + parkBookList.add(visitPark); + + } + visitParkMapper.insert(parkBookList); + } + if(sendStatus){ + visits.setStatus(Constants.VisitStatus.xfSuccess); + }else{ + visits.setStatus(Constants.VisitStatus.xfFail); + } + } + //璁垮鎶ュ + String objCode = ""; + if(approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)){ + //鍙戦�佺煭淇¢�氱煡 + SmsEmailServiceImpl.sendVisitReportSms(systemDictDataBiz, + emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), + Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?SmsConstants.visitReportingContent.visitReportingAuditSuccess: + SmsConstants.visitReportingContent.visitReportingAuditFail, + approveDTO.getCheckInfo(),null + ); + objCode = Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? + WxPlatConstants.visitReportContent.visitReportAuditSuccess:WxPlatConstants.visitReportContent.visitReportAuditFail; + + }else{ //璁垮鐢宠 + //鍙戦�佺煭淇¢�氱煡 + SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, + emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), + Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?SmsConstants.visitContent.visitAuditSuccess: + 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(",")) + ); + } + } + }else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals( Constants.approveObjectType.unCityUseCar)){ this.updDriver(approveDTO,approve,true); - }else if(approveDTO.getObjType().equals(Constants.approveObjectType.logisticsCarUse)){ - //TODO 鐗╂祦杞﹂绾� + CarUseBook carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId()); + if(Objects.nonNull(carUseBook)){ + 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(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); + } + } + + }else if(approveDTO.getObjType().equals(Constants.approveObjectType.reason)){ + //鐗╂祦杞﹂绾� + PlatformBooks platformBooks = platformBooksMapper.selectById(approveDTO.getObjId()); + if(Objects.isNull(platformBooks)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鐗╂祦杞﹂绾﹁褰�"); + } + platformBooks.setStatus(approveDTO.getStatus()); + platformBooks.setEditDate(new Date()); + platformBooks.setEditor(approveDTO.getLoginUserInfo().getMemberId()); + platformBooksMapper.updateById(platformBooks); + if(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)){ + PlatformReason platformReason = platformReasonMapper.selectById(platformBooks.getReasonId()); + if(Objects.isNull(platformReason)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍏ュ洯鍘熷洜鏁版嵁"); + } + PlatformGroup platformGroup = platformGroupMapper.selectById(platformReason.getGroupId()); + if(Objects.isNull(platformGroup)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍏ュ洯鍘熷洜閰嶇疆鏈堝彴缁勬暟鎹�"); + } + + //鐢熸垚浠诲姟璁板綍 + PlatformJob platformJob = platformBooks.toPlatformJob(); + platformJob.setId(null); + platformJob.setPlatformGroupId(platformReason.getGroupId().intValue()); + if(Constants.equalsInteger(platformGroup.getType(),Constants.ZERO)){ + platformJob.setType(Constants.platformJobType.wxcxh); + }else if(Constants.equalsInteger(platformGroup.getType(),Constants.ONE)){ + platformJob.setType(Constants.platformJobType.wxczh); + }else{ + platformJob.setType(Constants.platformJobType.sgscxh); + } + platformJob.setStatus(Constants.PlatformJobStatus.WART_SIGN_IN.getKey()); + platformJobMapper.insert(platformJob); + platformBooks.setJobId(platformJob.getId()); + platformBooksMapper.updateById(platformBooks); + //鐢熸垚浠诲姟鎿嶄綔璁板綍 + PlatformLog platformLog = new PlatformLog(); + platformLog.setCreateDate(new Date()); + platformLog.setJobId(platformJob.getId()); + platformLog.setIsdeleted(Constants.ZERO); + platformLog.setParam4(platformJob.getCarCodeFront()); + platformLog.setContent(Constants.PlatformJobLogType.CREATE.getInfo()); + platformLog.setObjType(Constants.PlatformJobLogType.CREATE.getKey()); + platformLog.setObjId(platformJob.getId().toString()); + platformLog.setAfterContent(JSONObject.toJSONString(platformJob)); + platformLogMapper.insert(platformLog); + } + //鍙戦�佺煭淇¢�氱煡 + SmsEmailServiceImpl.sendPlatformBookSms(systemDictDataBiz, + emayService,smsEmailMapper,smsConfigMapper,platformBooksMapper,platformBooks.getId(), + Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?SmsConstants.platformBookContent.platformBookAuditSuccess: + SmsConstants.platformBookContent.platformBookAuditFail, + approveDTO.getCheckInfo(),null + ); + + //鍙戦�佸井淇″叕浼楀彿娑堟伅 + 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()) + .eq(Approve::getObjType,approve.getObjType()) + .eq(Approve::getType,Constants.ONE) + ); } } @@ -1291,7 +1878,7 @@ 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(),"鏈煡璇㈠埌鍙告満淇℃伅"); -- Gitblit v1.9.3