From bb48c066cc11f571be02eb0dc7f9ef26dd3151ca Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期三, 02 四月 2025 10:08:48 +0800 Subject: [PATCH] 代码初始化 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java | 64 +++++++++++++++++--------------- 1 files changed, 34 insertions(+), 30 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 613d663..30efcd9 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 @@ -9,8 +9,8 @@ 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; @@ -302,7 +302,7 @@ 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) @@ -364,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) @@ -394,18 +395,15 @@ } 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); @@ -417,7 +415,7 @@ @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)){ @@ -446,7 +444,7 @@ } 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(),"瀹℃壒娴侀厤缃敊璇�"); @@ -468,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("鍙戣捣鐢宠"); @@ -518,22 +519,25 @@ 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(),"鏈煡璇㈠埌瀹℃壒浜轰俊鎭�"); @@ -1304,7 +1308,7 @@ .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()) ); } -- Gitblit v1.9.3