From 3bc8c584155ce04d1ba04496a4d94d82174df488 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期二, 10 十二月 2024 15:32:38 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java | 31 ++++++++++++++++++++----------- 1 files changed, 20 insertions(+), 11 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java index 09ac819..15ceb11 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java @@ -23,6 +23,8 @@ import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.*; +import com.doumee.core.wx.WXConstant; +import com.doumee.core.wx.wxPlat.WxPlatConstants; import com.doumee.core.wx.wxPlat.WxPlatNotice; import com.doumee.dao.admin.response.InterestedListVO; import com.doumee.dao.admin.response.PCWorkPlatformDataVO; @@ -129,6 +131,9 @@ @Autowired private SmsEmailMapper smsEmailMapper; + + @Autowired + private WxNoticeConfigMapper wxNoticeConfigMapper; @Autowired private EmayService emayService; @@ -251,7 +256,7 @@ if(StringUtils.isNotBlank(visits.getFaceImg())&&(Constants.equalsInteger(visits.getType(),Constants.ZERO)|| Constants.equalsInteger(visits.getType(),Constants.TWO))){ //浜鸿劯璇勫垎 FacePictureCheckRequest param = new FacePictureCheckRequest(); - String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + + String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); param.setFacePicUrl(prefixUrl + visits.getFaceImg()); BaseResponse<FacePictureCheckResponse> response = HKService.facePictureCheck(param); @@ -279,10 +284,6 @@ }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝鍙戣捣鎷滆瀹℃壒鐢宠澶辫触锛�"); } - //鍙戦�佸井淇″叕浼楀彿閫氱煡 - wxPlatNotice.sendVisitAuditTemplateNotice(visits, - systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_PREFIX).getCode(), - systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_AUDIT_VISIT).getCode()); }else if(dataSyncConfig.getVisitorDataOrigin().equals(Constants.ZERO)){ visits.setStatus(Constants.VisitStatus.waitCheck); visitsMapper.updateById(visits); @@ -292,6 +293,17 @@ } initWithVisitInfo(visits); updateProblemLog(visits,problemLog,member); + + //鍙戦�佸井淇″叕浼楀彿閫氱煡 - 鐢宠鎻愪氦鎴愬姛寰呭鏍� + if(StringUtils.isNotBlank(visits.getOpenid())){ + WxPlatNotice wxPlatNotice = new WxPlatNotice(); + wxPlatNotice.sendVisitTemplateNotice( + wxNoticeConfigMapper,visits, + Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload, + systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(), + Arrays.asList(visits.getOpenid().split(",")) + ); + } //鍒涘缓瀹℃壒璁板綍 createApprove(visits,visitMember); @@ -1486,11 +1498,6 @@ if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess)){ //濡傛灉涓嬪彂鎴愬姛锛� visitsMapper.updateById(visits); - if(Objects.isNull(visits.getParentId())){ - wxPlatNotice.sendVisitAuditTemplateNotice(visits, - systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_PREFIX).getCode(), - systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_AUDIT_VISIT).getCode()); - } }else{ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"閲嶆柊涓嬪彂浼氬け璐ワ紒"); } @@ -1551,7 +1558,8 @@ //鍦ㄥ洯闀挎湡鐩稿叧鏂逛汉鏁� pcWorkPlatformDataVO.setInParkLwUserNum( - retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) && Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count() + retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) + && Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count() ); pcWorkPlatformDataVO.setLwUserInNum(Constants.ZERO); pcWorkPlatformDataVO.setLwUserOutNum(Constants.ZERO); @@ -1648,6 +1656,7 @@ List<Integer> companyIds = companyList.stream().map(i->i.getId()).collect(Collectors.toList()); List<Retention> retentionList = retentionMapper.selectList( new QueryWrapper<Retention>().lambda() + .eq(Retention::getType,Constants.TWO) .in(Retention::getCompanyId,companyIds) ); for (Company company:companyList) { -- Gitblit v1.9.3