From c5a0ff2661fe362dddbe88c6a28d19c48c24c39b Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期一, 21 十月 2024 20:39:32 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java | 58 +++++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 53 insertions(+), 5 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 3098750..6ed3d47 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 @@ -24,10 +24,7 @@ import com.doumee.core.model.LoginUserInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; -import com.doumee.core.utils.Constants; -import com.doumee.core.utils.DESUtil; -import com.doumee.core.utils.DateUtil; -import com.doumee.core.utils.Utils; +import com.doumee.core.utils.*; import com.doumee.core.wx.wxPlat.WxPlatNotice; import com.doumee.dao.admin.response.InterestedListVO; import com.doumee.dao.admin.response.PCWorkPlatformDataVO; @@ -58,6 +55,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.doumee.service.business.impl.hksync.HkSyncVisitServiceImpl; +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; @@ -78,6 +76,7 @@ import java.nio.file.Path; import java.nio.file.Paths; import java.util.*; +import java.util.Date; import java.util.stream.Collectors; /** @@ -132,6 +131,15 @@ private NoticesJoinMapper noticesJoinMapper; @Autowired private InoutDayCountMapper inoutDayCountMapper; + + @Autowired + private SmsConfigMapper smsConfigMapper; + + @Autowired + private SmsEmailMapper smsEmailMapper; + + @Autowired + private EmayService emayService; @Override public Integer create(Visits visits) { @@ -1220,6 +1228,18 @@ queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); + //鏁版嵁鏉冮檺寮�濮�--------------------start---------------- + LoginUserInfo userInfo =pageWrap.getModel().getLoginUserInfo(); + if(userInfo!=null && userInfo.getCompanyIdList()!=null){ + if( userInfo.getCompanyIdList().size() ==0){ + //鍙兘鐪嬭嚜宸�(鎷滆浜猴級 + queryWrapper.eq(Member::getId,userInfo.getMemberId()); + }else{ + queryWrapper.in(Company::getId ,userInfo.getCompanyIdList()); + } + } + //鏁版嵁鏉冮檺寮�濮�--------------------end---------------- + queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getType())&&Constants.equalsInteger(pageWrap.getModel().getType(),Constants.TWO),Visits::getType,pageWrap.getModel().getType()); queryWrapper.ne(Objects.nonNull(pageWrap.getModel().getType())&&!Constants.equalsInteger(pageWrap.getModel().getType(),Constants.TWO),Visits::getType,Constants.TWO); @@ -1677,13 +1697,41 @@ }else{ pcWorkPlatformDataVO.setTimeOutVisitList(result); } + } + return pcWorkPlatformDataVO; + } + @Override + public void syncTimeOutData(){ + String times = systemDictDataBiz.queryByCode(Constants.VISIT_CONFIG,Constants.TIME_OUT_CONFIG).getCode(); + List<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda() + .eq(Visits::getStatus,Constants.VisitStatus.signin) + .eq(Visits::getSendTimeOutNotice,Constants.ZERO) + .apply(" now() >= DATE_ADD(ENDTIME,INTERVAL -"+times+" MINUTE) ") + ); + for (Visits visits:visitsList) { + if(Constants.equalsInteger(visits.getType(),Constants.TWO)){ + SmsEmailServiceImpl.sendVisitReportSms(systemDictDataBiz, + emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), + SmsConstants.visitReportingContent.visitReportingTimeOutSignOut, + null,Arrays.asList(visits.getPhone().split(",")) + ); + }else{ + SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, + emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), + SmsConstants.visitContent.visitTimeOutSignOut, + null,Arrays.asList(visits.getPhone().split(",")) + ); + } + visits.setSendTimeOutNotice(Constants.ONE); + visitsMapper.updateById(visits); } - return pcWorkPlatformDataVO; } + + } -- Gitblit v1.9.3