访客系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
jiangping
2024-11-12 95ddc157639fc6e9102d2e1fa8ca164af66685d6 
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformJobServiceImpl.java


@@ -18,6 +18,7 @@


import com.doumee.core.tms.model.response.TmsLockStatusQueryResponse;


import com.doumee.core.utils.*;


import com.doumee.dao.business.*;


import com.doumee.dao.business.dao.SmsConfigMapper;


import com.doumee.dao.business.dao.SmsEmailMapper;


import com.doumee.dao.business.join.PlatformJobJoinMapper;


import com.doumee.dao.business.join.PlatformJoinMapper;


@@ -321,6 +322,7 @@


                .selectAs(Platform::getName,PlatformJob::getPlatformName)


                .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate)


                .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName)


                .select(" case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end ioQty ")


                .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)


                .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode)


                .leftJoin(PlatformBooks.class,PlatformBooks::getJobId,PlatformJob::getId)


@@ -362,8 +364,9 @@


        IPage<PlatformJob> platformJobIPage = platformJobJoinMapper.selectJoinPage(page,PlatformJob.class,queryWrapper);


        platformJobIPage.getRecords().forEach(i->{


            i.dealTime();


            this.getWmsJobData(i);


            this.queryWaitNum(i);


            i.setTotalNum(i.getIoQty());


//            this.getWmsJobData(i);


//            this.queryWaitNum(i);


        });


        return PageData.from(platformJobIPage);


    }


@@ -374,7 +377,6 @@


            || Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.zyczh)


            || Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.wxcxh)


                || Constants.equalsInteger(platformJob.getType(),Constants.platformJobType.wxczh)) {




            PlatformWmsJob platformWmsJob = platformWmsJobMapper.selectOne(new QueryWrapper<PlatformWmsJob>().lambda()


                    .eq(PlatformWmsJob::getIsdeleted,Constants.ZERO)


                    .eq(PlatformWmsJob::getJobId,platformJob.getId())


@@ -406,11 +408,7 @@


                    }else{


                        platformJob.setLockStatus(Constants.ONE);   //部分上锁


                    }




                }








            }


        } 


    }


@@ -441,7 +439,8 @@


                    sumWorkRate = sumWorkRate.add(linePlatformJob.getTotalNum());


                }


                //计算预计等待时间


                List<Platform> platformList = platformJoinMapper.selectList(new QueryWrapper<Platform>().lambda().eq(Platform::getIsdeleted,Constants.ZERO).eq(Platform::getGroupId,platformJob.getPlatformGroupId()));


                List<Platform> platformList = platformJoinMapper.selectList(new QueryWrapper<Platform>().lambda()


                        .eq(Platform::getIsdeleted,Constants.ZERO).eq(Platform::getGroupId,platformJob.getPlatformGroupId()));


                BigDecimal workRate = platformList.stream().map(m->m.getWorkRate()).reduce(BigDecimal.ZERO,BigDecimal::add);


                if(sumWorkRate.compareTo(BigDecimal.ZERO) > Constants.ZERO && workRate.compareTo(BigDecimal.ZERO)  > Constants.ZERO ){


                    BigDecimal sumMinute = sumWorkRate.divide(workRate,1, RoundingMode.HALF_DOWN).multiply(BigDecimal.valueOf(60L));


@@ -966,6 +965,7 @@


    public void cancelInPark(PlatformJob platformJob){


        if(Constants.equalsInteger(platformJob.getType(),Constants.TWO)


                || Constants.equalsInteger(platformJob.getType(),Constants.THREE)


                || StringUtils.isBlank(platformJob.getCarCodeFront())


                || Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){




            List<VisitPark> visitParkList = visitParkMapper.selectList(new QueryWrapper<VisitPark>().lambda()


@@ -973,6 +973,8 @@


                    .eq(VisitPark::getObjType,Constants.ONE)


                    .eq(VisitPark::getHkStatus,Constants.ONE)


                    .isNotNull(VisitPark::getHkId)


                    .apply("  END_TIME > now() ")


                    .orderByDesc(VisitPark::getCreateDate)


            );


            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(visitParkList)){


                for (VisitPark visitPark:visitParkList) {


@@ -1209,9 +1211,16 @@


        if(Objects.isNull(platformJob)){


            throw new BusinessException(ResponseStatus.DATA_EMPTY);


        }




        if(!Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){


            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起,业务状态已流转！");


        }




        Platform platform = platformJoinMapper.selectById(jobOperateDTO.getPlatformId());


        if(Objects.isNull(platform)){


            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到月台信息");


        }




        PlatformJob oldPlatformJob = new PlatformJob();


        BeanUtils.copyProperties(platformJob,oldPlatformJob);




@@ -1226,7 +1235,10 @@


                emayService,smsEmailMapper,smsConfigMapper,platformJobMapper,platformJob.getId(),


                SmsConstants.platformJobContent.platformJobOverNum,null,null


        );




        platformJob.setPlatformName(platform.getName());


        this.broadcastAndLEed(platformJob, StringUtils.isBlank(platform.getLedContent())?Constants.PlatformLedContent.IDEL_CONTNET.getName():platform.getLedContent(),


                null


        );




        return platformJob;


    }


@@ -1673,10 +1685,11 @@


    @Override


    public PlatformWorkVO getPlatformWorkVOById(Integer platformId){


        //获取月台下的所有作业数据


        List<PlatformJob> platformJobList =  platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>()


        List<PlatformJob> allPlatformJobList =  platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>()


                .selectAll(PlatformJob.class)


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 5 order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 4 order by pl.CREATE_DATE desc  limit 1  ) as newCallDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+" order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.CALLED.getKey()+" order by pl.CREATE_DATE desc  limit 1  ) as newCallDate  ")


                .select(" case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end ioQty ")


                .selectAs(Platform::getName,PlatformJob::getPlatformName)


                .selectAs(Platform::getWorkRate,PlatformJob::getWorkRate)


                .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName)


@@ -1696,13 +1709,13 @@


                )


                .orderByDesc(PlatformJob::getId)


        );


        for (PlatformJob platformJob:platformJobList) {


            //处理WSM数量


            this.getWmsJobData(platformJob);


            //查询前方排队数量


            this.queryWaitNum(platformJob);


        }


        PlatformWorkVO platformWorkVO = PlatformGroupServiceImpl.getPlatformWorkVO(platformJoinMapper.selectById(platformId),platformJobList);


//        List<PlatformJob> platformJobList = allPlatformJobList.stream().filter(i->Constants.equalsInteger(i.getPlatformId(),platformId)).collect(Collectors.toList());


//        for (PlatformJob platformJob:platformJobList) {


//            platformJob.setTotalNum(platformJob.getIoQty());


//            //查询前方排队数量


//            this.queryWaitNum(platformJob);


//        }


        PlatformWorkVO platformWorkVO = PlatformGroupServiceImpl.getPlatformWorkVO(platformJoinMapper.selectById(platformId),allPlatformJobList);


        return platformWorkVO;


    }




@@ -1754,8 +1767,8 @@


                    .selectAs(Platform::getWorkRate, PlatformJob::getWorkRate)


                    .selectAs(Platform::getName, PlatformJob::getPlatformName)


                    .select(" case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end workNum ")


                    .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 5 order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                    .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 4 order by pl.CREATE_DATE desc  limit 1  ) as newCallDate  ")


                    .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+"  order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                    .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.CALLED.getKey()+" order by pl.CREATE_DATE desc  limit 1  ) as newCallDate  ")


                    .leftJoin(Platform.class, Platform::getId, PlatformJob::getPlatformId)


                    .eq(PlatformJob::getStatus, Constants.PlatformJobStatus.WORKING.getKey())


                    .eq(PlatformJob::getPlatformId, platform.getId())


@@ -1955,8 +1968,8 @@


                .selectAs(Platform::getName,PlatformJob::getPlatformName)


                .selectAs(PlatformGroup::getWaitCallTime,PlatformJob::getWorktimeOutAlarmTime)


                .select(" case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end workNum ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 5 order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 4 order by pl.CREATE_DATE desc  limit 1  ) as newCallDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+"  order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.CALLED.getKey()+" order by pl.CREATE_DATE desc  limit 1  ) as newCallDate  ")


                .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)


                .leftJoin(PlatformGroup.class,PlatformGroup::getId,Platform::getGroupId)


                .eq(PlatformJob::getIsdeleted,Constants.ZERO)


@@ -2040,7 +2053,7 @@


        List<PlatformJob> platformJobList =  platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>()


                .selectAll(PlatformJob.class)


                .selectAs(Platform::getName,PlatformJob::getPlatformName)


                .select(" ( now() >= DATE_ADD( ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 4 " +


                .select(" ( now() >= DATE_ADD( ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.CALLED.getKey()+" " +


                        "order by pl.CREATE_DATE desc  limit 1  )  ,INTERVAL t2.WAIT_CALL_TIME MINUTE) ) as isTimeOut   ")


                .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)


                .leftJoin(PlatformGroup.class,PlatformGroup::getId,Platform::getGroupId)


@@ -2072,7 +2085,7 @@


                .selectAs(Platform::getWorkRate, PlatformJob::getWorkRate)


                .selectAs(Platform::getWorkTimeoutAlarmTime, PlatformJob::getWorktimeOutAlarmTime)


                .select(" case when t.total_num is null  then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id  ) else t.total_num end workNum ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = 5 order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                .select(" ( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+"  order by pl.CREATE_DATE desc  limit 1  ) as newStartDate  ")


                .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId)


                .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey())


                .eq(PlatformJob::getInOut,Constants.ONE)