From eb6cd7fd2469bf9c2aad7defe111244f9752d9c2 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期二, 10 十二月 2024 19:05:56 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java | 26 +++++++++++++++++++++----- 1 files changed, 21 insertions(+), 5 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java index d1811f2..4203b81 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java @@ -56,6 +56,7 @@ import java.math.BigDecimal; import java.math.RoundingMode; +import java.net.URLEncoder; import java.util.*; import java.util.Date; import java.util.concurrent.TimeUnit; @@ -118,6 +119,8 @@ @Autowired private EmayService emayService; + @Autowired + private RedisTemplate<String, Object> redisTemplate; @Autowired private PlatformBroadcastLogMapper platformBroadcastLogMapper; @Autowired @@ -1433,10 +1436,19 @@ return platformJob; } - - /** - * 瀹屾垚浣滀笟 - */ + public PlatformJob getLastWaitJob(String uuid, LoginUserInfo loginUser){ + String u = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.BIGSCREEN_UUID); + if(!StringUtils.equals(u,uuid)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝浜岀淮鐮佸凡澶辨晥锛�"); + } + PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda() + .eq(PlatformJob::getDrivierPhone,loginUser.getMobile()) + .eq(PlatformJob::getIsdeleted,Constants.ZERO) + .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WART_SIGN_IN.getKey()) + .orderByDesc(PlatformJob::getCreateDate) + .last(" limit 1 ") ); + return platformJob; + } @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public PlatformJob finishWork(JobOperateDTO jobOperateDTO){ @@ -2110,7 +2122,11 @@ List<PlatformJob> calledList = platformJobList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())).collect(Collectors.toList()); largeScreenDataVO.setWaitWorkList(calledList); } - largeScreenDataVO.setQrCode(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_QRCODE).getCode()); + String u = UUID.randomUUID().toString(); + redisTemplate.opsForValue().set(Constants.RedisKeys.BIGSCREEN_UUID,u,3, TimeUnit.MINUTES); + String url = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),Constants.WxUrlParams.BISCREEN_CODE,u); + largeScreenDataVO.setQrCode(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_QRCODE_PREFIX).getCode().replace( "${param}", url)); + largeScreenDataVO.setAttention(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.SIGN_IN_ATTENTION).getCode()); return largeScreenDataVO; } -- Gitblit v1.9.3