From 43c7cf553e5c78d81b8f23a043901926c45eb0cf Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期一, 30 十二月 2024 18:46:00 +0800
Subject: [PATCH] 最新版本541200007

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java |  175 ++++------------------------------------------------------
 1 files changed, 13 insertions(+), 162 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 c13f906..3549483 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
@@ -20,6 +20,7 @@
 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.MemberMapper;
 import com.doumee.dao.business.dao.SmsConfigMapper;
 import com.doumee.dao.business.dao.SmsEmailMapper;
 import com.doumee.dao.business.join.PlatformJobJoinMapper;
@@ -35,7 +36,6 @@
 import com.doumee.dao.web.response.DriverHomeVO;
 import com.doumee.dao.web.response.LineUpVO;
 import com.doumee.dao.web.response.PlatformWorkVO;
-import com.doumee.dao.web.response.platformReport.WholeProvinceBoardVO;
 import com.doumee.service.business.PlatformJobService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -58,7 +58,6 @@
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
-import java.net.URLEncoder;
 import java.util.*;
 import java.util.Date;
 import java.util.concurrent.TimeUnit;
@@ -517,6 +516,14 @@
                 .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)
                 .eq(PlatformJob::getIsdeleted,Constants.ZERO)
                 .eq(PlatformJob::getDrivierPhone,loginUserInfo.getMobile())
+                .and(i->i.like(PlatformJob::getDoneDate,DateUtil.getCurrDate())
+                        .or().in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()
+                                ,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(),
+                                Constants.PlatformJobStatus.WART_SIGN_IN.getKey(),
+                                Constants.PlatformJobStatus.IN_WAIT.getKey(),
+                                Constants.PlatformJobStatus.CALLED.getKey(),
+                                Constants.PlatformJobStatus.WORKING.getKey())
+                )
                 .orderByDesc(PlatformJob::getId)
         );
         for (PlatformJob platformJob:platformJobList) {
@@ -527,7 +534,6 @@
         }
 
         driverHomeVO.setPlatformJobList(platformJobList);
-
         // 鍥尯瀵艰鍥�  鍥剧墖
         driverHomeVO.setReservationMap(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.PLATFORM_GUIDEMAP).getCode());
         // 棰勭害鎸囧崡 鏂囨湰
@@ -737,6 +743,7 @@
                                 ,PlatformJob::getId,lineUpDetailDTO.getJobId())
                         .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey(),
                                 Constants.PlatformJobStatus.IN_WAIT.getKey(),
+                                Constants.PlatformJobStatus.WORKING.getKey(),
                                 Constants.PlatformJobStatus.CALLED.getKey())
                         .orderByDesc(PlatformJob::getStatus)
                         .orderByAsc(PlatformJob::getSignDate)
@@ -908,6 +915,9 @@
             );
         }
     }
+
+
+
 
     private Logger logger = LoggerFactory.getLogger(PlatformJobServiceImpl.class);
 
@@ -2203,164 +2213,5 @@
     }
 
 
-    /**
-     * 绱鍑哄簱閲忕粺璁� - 澶у睆
-     * @param data
-     */
-    @Override
-    public void wholeProvinceCenterData(WholeProvinceBoardVO data){
-//        //绱鏈勾搴﹀嚭搴撻噺
-//        List<PlatformJob> platformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
-//                .lambda()
-//                .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED)
-//                .isNotNull(PlatformJob::getDoneDate)
-//                .in(PlatformJob::getType,Constants.platformJobType.wxczh,Constants.platformJobType.zyczh)
-//                .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy"))
-//        );
-//        data.setYearOutTotal(platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
-//        data.setYearOutTimes(platformJobList.size());
-//
-//
-//        List<PlatformJob> platformJobsMonthList = platformJobList.stream().filter(i->DateUtil.getFomartDate(i.getDoneDate(),"yyyy-MM").equals(DateUtil.getFomartDate(new Date(),"yyyy-MM"))).collect(Collectors.toList());
-//        data.setMonthOutTotal(platformJobsMonthList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
-//        data.setMonthOutTimes(platformJobsMonthList.size());
-//        String beforYear = DateUtil.getBeforYear(new Date(),1);
-//
-//        //绱鏈勾搴﹀嚭搴撻噺
-//        List<PlatformJob> beforYearPlatformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
-//                .lambda()
-//                .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED)
-//                .isNotNull(PlatformJob::getDoneDate)
-//                .in(PlatformJob::getType,Constants.platformJobType.wxczh,Constants.platformJobType.zyczh)
-//                .like( PlatformJob::getDoneDate, beforYear.substring(0,4))
-//        );
-//
-//        List<PlatformJob> beforPlatformJobsMonthList = platformJobList.stream().filter(i->DateUtil.getFomartDate(i.getDoneDate(),"yyyy-MM").equals(beforYear.substring(0,7))).collect(Collectors.toList());
-//        //鍚屾瘮鏁版嵁
-//        data.setYearOutTotalOnYear(beforYearPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
-//        data.setMonthOutTotalOnYear(beforPlatformJobsMonthList.stream().filter(i->Objects.nonNull(i.getTotalNum())).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add));
-//
-
-    }
-
-    @Override
-    public void centerDataForInOut(WholeProvinceBoardVO data){
-//        //浠婃棩瀹屾垚鐨勫嚭鍏ュ簱鎵�鏈夋暟鎹�
-//        List<PlatformJob> platformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
-//                .lambda()
-//                .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED)
-//                .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd"))
-//        );
-//        //浠婃棩涔嬪墠 鎵�鏈夋湭瀹屾垚鐨勫嚭鍏ュ簱鏁版嵁 - WMS鎺ㄩ��
-//        List<PlatformJob> wmsPlatformJobList  = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
-//                .lambda()
-//                .notIn(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED
-//                        ,Constants.PlatformJobStatus.CANCEL)
-//                .eq(PlatformJob::getOrigin ,Constants.ONE)
-//                .le(PlatformJob::getCreateDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd") +" 23:59:59")
-//        );
-//        //浠婃棩涔嬪墠 鎵�鏈夋湭瀹屾垚鐨勫嚭鍏ュ簱鏁版嵁 - 棰勭害鏁版嵁
-//        List<PlatformJob> bookPlatformJobList  = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
-//                .lambda()
-//                .notIn(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED
-//                        ,Constants.PlatformJobStatus.CANCEL)
-//                .eq(PlatformJob::getOrigin ,Constants.ONE)
-//                .le(PlatformJob::getArriveDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd") +" 23:59:59")
-//        );
-//
-//        BigDecimal finishOutTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        BigDecimal unFinishWmsOutTotal = wmsPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        BigDecimal unFinishBookOutTotal = bookPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//
-//        BigDecimal finishInTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        BigDecimal unFinishWmsInTotal = wmsPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        BigDecimal unFinishBookInTotal = bookPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//
-//        data.setOutTotal(finishOutTotal);
-//        data.setOutPlanTotal(finishOutTotal.add(unFinishWmsOutTotal).add(unFinishBookOutTotal));
-//
-//        data.setInTotal(finishInTotal);
-//        data.setInPlanTotal(finishInTotal.add(unFinishWmsInTotal).add(unFinishBookInTotal));
-
-    }
-
-
-
-
-    @Override
-    public void centerDataOutInRata(WholeProvinceBoardVO data){
-//        //绱鏈湀搴︽墍鏈夋搷浣滈噺
-//        List<PlatformJob> platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>()
-//                        .selectAll(PlatformJob.class)
-//                        .select(" ( select ifnull(sum(p.param3),0) from platform_log p where p.obj_id = platform_job.id  ) ",PlatformJob::getWorkTime)
-//                .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED)
-//                .isNotNull(PlatformJob::getDoneDate)
-//                .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy-MM"))
-//        );
-//
-//        //鑾峰彇鏈湀鎵�鏈夊嚭搴撻噺
-//        BigDecimal monthOutTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        Long monthOutWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
-//        BigDecimal monthInTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        Long monthInWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
-//
-//        data.setMonthOutRata(BigDecimal.ZERO);
-//        //鏈堝害鍑哄簱鏁堢巼
-//        if(Objects.nonNull(monthOutTotal) && Objects.nonNull(monthOutWorkTotal) && monthOutWorkTotal>0L && monthOutTotal.compareTo(BigDecimal.ZERO) > 0){
-//            BigDecimal workTotal = new BigDecimal(monthOutWorkTotal);
-//            data.setMonthOutRata(monthOutTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
-//        }
-//
-//        //鏈堝害鍏ュ簱鏁堢巼
-//
-//        data.setMonthInRata(BigDecimal.ZERO);
-//        if(Objects.nonNull(monthInTotal) && Objects.nonNull(monthInWorkTotal) && monthInWorkTotal>0L && monthInTotal.compareTo(BigDecimal.ZERO) > 0){
-//            BigDecimal workTotal = new BigDecimal(monthInWorkTotal);
-//            data.setMonthInRata(monthInTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
-//        }
-//
-//
-//
-//        List<PlatformJob> dayPlatformJobList = platformJobJoinMapper.selectList(new QueryWrapper<PlatformJob>()
-//                .lambda()
-//                .in(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE
-//                        ,Constants.PlatformJobStatus.AUTHED_LEAVE
-//                        ,Constants.PlatformJobStatus.LEAVED)
-//                .isNotNull(PlatformJob::getDoneDate)
-//                .like( PlatformJob::getDoneDate, DateUtil.getFomartDate(new Date(),"yyyy-MM-dd"))
-//        );
-//
-//        BigDecimal dayOutTotal = dayPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        Long dayOutWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.wxczh)||i.getType().equals(Constants.platformJobType.zyczh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
-//        BigDecimal dayInTotal = dayPlatformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getTotalNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
-//        Long dayInWorkTotal = platformJobList.stream().filter(i->Objects.nonNull(i.getTotalNum())&&(i.getType().equals(Constants.platformJobType.zycxh)||i.getType().equals(Constants.platformJobType.wxcxh)||i.getType().equals(Constants.platformJobType.sgscxh))).map(i->i.getWorkTime()).reduce(Long.valueOf(Constants.ZERO),Long::sum);
-//
-//        data.setDayOutRata(BigDecimal.ZERO);
-//        //鏃ュ嚭搴撴晥鐜�
-//        if(Objects.nonNull(dayOutTotal) && Objects.nonNull(dayOutWorkTotal) && dayOutWorkTotal>0L && dayOutTotal.compareTo(BigDecimal.ZERO) > 0){
-//            BigDecimal workTotal = new BigDecimal(dayOutWorkTotal);
-//            data.setDayOutRata(dayOutTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
-//        }
-//        //鏃ュ叆搴撴晥鐜�
-//        data.setDayInRata(BigDecimal.ZERO);
-//        if(Objects.nonNull(dayInTotal) && Objects.nonNull(dayInWorkTotal) && dayInWorkTotal>0L && dayInTotal.compareTo(BigDecimal.ZERO) > 0){
-//            BigDecimal workTotal = new BigDecimal(dayInWorkTotal);
-//            data.setMonthInRata(dayInTotal.multiply(new BigDecimal(3600)).divide(workTotal,2,BigDecimal.ROUND_UP));
-//        }
-
-
-    }
 
 }

--
Gitblit v1.9.3