Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit
| | |
| | | |
| | | @ApiOperation("获取月台组信息") |
| | | @PostMapping("/getPlatformGroupList") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<List<PlatformGroup>> getPlatformGroupList (@RequestBody PlatformDataDTO platformDataDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | return ApiResponse.success(platformGroupService.getAllPlatformGroup(platformDataDTO,getLoginUser(token))); |
| | | } |
| | | |
| | | @ApiOperation("获取月台任务信息") |
| | | @GetMapping("/getPlatformWorkData") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PlatformWorkVO> getPlatformWorkData (@RequestParam Integer platformId, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | return ApiResponse.success(platformJobService.getPlatformWorkVOById(platformId)); |
| | | } |
| | | |
| | | @ApiOperation("更新月台配置信息") |
| | | @GetMapping("/updUserPlatformConfig") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse updUserPlatformConfig (@RequestParam List<Integer> ids, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | platformShowParamService.updUserConfig(ids,getLoginUser(token)); |
| | | return ApiResponse.success("操作成功"); |
| | |
| | | |
| | | @ApiOperation("车辆排队情况") |
| | | @PostMapping("/platformLineUpPage") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PageData<PlatformJob>> platformLineUpPage (@RequestBody PageWrap<PlatformJob> pageWrap, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | return ApiResponse.success(platformJobService.platformCallList(pageWrap)); |
| | | } |
| | |
| | | |
| | | @ApiOperation("叫号列表") |
| | | @PostMapping("/platformCallList") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PageData<PlatformJob>> platformCallList (@RequestBody PageWrap<PlatformJob> pageWrap, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | return ApiResponse.success(platformJobService.platformCallList(pageWrap)); |
| | | } |
| | |
| | | |
| | | @ApiOperation("叫号入园") |
| | | @PostMapping("/platformInPark") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformInPark (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.platformInPark(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("月台叫号") |
| | | @PostMapping("/platformCallNumber") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformCallNumber (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob oldPlatformJob = platformJobService.findById(jobOperateDTO.getJobId()); |
| | |
| | | |
| | | @ApiOperation("转移月台") |
| | | @PostMapping("/platformMove") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformMove (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | platformJobService.platformMove(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("月台过号") |
| | | @PostMapping("/platformOverNumber") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformOverNumber (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | platformJobService.platformOverNumber(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("异常挂起") |
| | | @PostMapping("/platformErr") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformErr (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | platformJobService.platformErr(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("手动开始作业") |
| | | @PostMapping("/beginWork") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse beginWork (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.beginWork(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("完成作业") |
| | | @PostMapping("/finishWork") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse finishWork (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.finishWork(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("授权离场") |
| | | @PostMapping("/powerLevel") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse powerLevel (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.powerLevel(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("获取月台组 等待与异常挂起数据") |
| | | @GetMapping("/getPlatformGroupWork") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PlatformGroupWorkVO> getPlatformGroupWork (@RequestParam Integer platformGroupId, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | return ApiResponse.success(platformGroupService.getPlatformGroupWork(platformGroupId)); |
| | | } |
| | |
| | | package com.doumee.cloud.web; |
| | | |
| | | import com.doumee.api.BaseController; |
| | | import com.doumee.config.annotation.CloudRequiredPermission; |
| | | import com.doumee.config.annotation.LoginNoRequired; |
| | | import com.doumee.core.annotation.trace.Trace; |
| | | import com.doumee.core.model.ApiResponse; |
| | |
| | | |
| | | @ApiOperation("获取月台组信息") |
| | | @PostMapping("/getPlatformGroupList") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<List<PlatformGroup>> getPlatformGroupList (@RequestBody PlatformDataDTO platformDataDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | return ApiResponse.success(platformGroupService.getAllPlatformGroup(platformDataDTO,getLoginUser(token))); |
| | | } |
| | | |
| | | @ApiOperation("获取月台任务信息") |
| | | @GetMapping("/getPlatformWorkData") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PlatformWorkVO> getPlatformWorkData (@RequestParam Integer platformId, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | return ApiResponse.success(platformJobService.getPlatformWorkVOById(platformId)); |
| | | } |
| | | |
| | | @ApiOperation("更新月台配置信息") |
| | | @GetMapping("/updUserPlatformConfig") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse updUserPlatformConfig (@RequestParam List<Integer> ids, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | platformShowParamService.updUserConfig(ids,getLoginUser(token)); |
| | | return ApiResponse.success("操作成功"); |
| | |
| | | |
| | | @ApiOperation("修改禁启用状态") |
| | | @PostMapping("/updPlatformStatus") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse updPlatformStatus (@RequestBody Platform platform, @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | platform.setLoginUserInfo(getLoginUser(token)); |
| | | platformService.updateStatusById(platform); |
| | |
| | | |
| | | @ApiOperation("车辆排队情况") |
| | | @PostMapping("/platformLineUpPage") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PageData<PlatformJob>> platformLineUpPage (@RequestBody PageWrap<PlatformJob> pageWrap, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | return ApiResponse.success(platformJobService.platformCallList(pageWrap)); |
| | | } |
| | |
| | | |
| | | @ApiOperation("叫号列表") |
| | | @PostMapping("/platformCallList") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PageData<PlatformJob>> platformCallList (@RequestBody PageWrap<PlatformJob> pageWrap, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | return ApiResponse.success(platformJobService.platformCallList(pageWrap)); |
| | | } |
| | |
| | | |
| | | @ApiOperation("叫号入园") |
| | | @PostMapping("/platformInPark") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformInPark (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.platformInPark(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("月台叫号") |
| | | @PostMapping("/platformCallNumber") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformCallNumber (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob oldPlatformJob = platformJobService.findById(jobOperateDTO.getJobId()); |
| | |
| | | |
| | | @ApiOperation("转移月台") |
| | | @PostMapping("/platformMove") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformMove (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | platformJobService.platformMove(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("月台过号") |
| | | @PostMapping("/platformOverNumber") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformOverNumber (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | platformJobService.platformOverNumber(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("异常挂起") |
| | | @PostMapping("/platformErr") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse platformErr (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | platformJobService.platformErr(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("手动开始作业") |
| | | @PostMapping("/beginWork") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse beginWork (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.beginWork(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("完成作业") |
| | | @PostMapping("/finishWork") |
| | | @CloudRequiredPermission("business:platform:update") |
| | | public ApiResponse finishWork (@RequestBody JobOperateDTO jobOperateDTO, @RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | jobOperateDTO.setLoginUserInfo(getLoginUser(token)); |
| | | PlatformJob platformJob = platformJobService.finishWork(jobOperateDTO); |
| | |
| | | |
| | | @ApiOperation("WMS运输单详情") |
| | | @GetMapping("/wmsJobDetail") |
| | | @CloudRequiredPermission("business:platform:query") |
| | | public ApiResponse<PlatformWmsJob> wmsJobDetail(@RequestParam Integer id) { |
| | | return ApiResponse.success(platformWmsJobService.findByDetailId(id)); |
| | | } |
| | |
| | | @TableField(exist = false) |
| | | private String platformName ; |
| | | |
| | | |
| | | @ApiModelProperty(value = "作业量" ,hidden = true) |
| | | @TableField(exist = false) |
| | | private BigDecimal workNum ; |
| | | |
| | | |
| | | @ApiModelProperty(value = "WMS任务时间") |
| | | @TableField(exist = false) |
| | | private String ioCreatedate; |
| | |
| | | @ExcelColumn(name="是否删除0否 1是") |
| | | private Integer isdeleted; |
| | | |
| | | @ApiModelProperty(value = "备注") |
| | | @ApiModelProperty(value = "作业月台") |
| | | @ExcelColumn(name="备注") |
| | | private String remark; |
| | | |
| | |
| | | public class PlatformGroupWorkVO { |
| | | |
| | | @ApiModelProperty(value = "等待数量") |
| | | private Long waitNum ; |
| | | private Integer waitNum ; |
| | | |
| | | @ApiModelProperty(value = "异常数量") |
| | | private Long exceptionNum ; |
| | | private Integer exceptionNum ; |
| | | |
| | | } |
| | |
| | | .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 ") |
| | | .selectAs(PlatformWmsJob::getCarrierName,PlatformJob::getCarrierName) |
| | | .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(Platform::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getStatus, |
| | | Constants.PlatformJobStatus.WAIT_CALL.getKey(), |
| | | Constants.PlatformJobStatus.IN_WAIT.getKey(), |
| | |
| | | public static PlatformWorkVO getPlatformWorkVO(Platform platform,List<PlatformJob> platformJobList){ |
| | | PlatformWorkVO platformWorkVO = new PlatformWorkVO(); |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){ |
| | | //获取月台下的所有作业数据 |
| | | //获取月台组下的所有作业数据 |
| | | List<PlatformJob> platformJobs = platformJobList.stream().filter( |
| | | i->Constants.equalsInteger(i.getPlatformId(),platform.getId()) |
| | | || Constants.equalsInteger(i.getPlatformGroupId(),platform.getGroupId()) |
| | |
| | | |
| | | platformWorkVO.setWaitNum( |
| | | platformJobs.stream().filter(i-> |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) |
| | | || Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) |
| | | Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) |
| | | ).collect(Collectors.toList()).size() |
| | | + |
| | | platformJobList.stream().filter(i->Constants.equalsInteger(platform.getId(),i.getPlatformId()) |
| | | && (Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) |
| | | && (Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.IN_WAIT.getKey()) || Constants.equalsInteger(i.getStatus(),Constants.PlatformJobStatus.TRANSFERING.getKey()) |
| | | ) |
| | | ).collect(Collectors.toList()).size() |
| | | ); |
| | |
| | | @Override |
| | | public PlatformGroupWorkVO getPlatformGroupWork(Integer platformGroupId){ |
| | | PlatformGroupWorkVO platformGroupWorkVO = new PlatformGroupWorkVO(); |
| | | platformGroupWorkVO.setExceptionNum(platformJobJoinMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | platformGroupWorkVO.setExceptionNum(platformJobJoinMapper.selectJoinCount(new MPJLambdaWrapper<PlatformJob>() |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(Platform::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getPlatformGroupId,platformGroupId) |
| | | .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.EXCEPTION.getKey()) |
| | | ) |
| | | ); |
| | | |
| | | platformGroupWorkVO.setWaitNum(platformJobJoinMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | platformGroupWorkVO.setWaitNum(platformJobJoinMapper.selectJoinCount(new MPJLambdaWrapper<PlatformJob>() |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(Platform::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getPlatformGroupId,platformGroupId) |
| | | .and( i->i.eq(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CALL.getKey()).or() |
| | | .eq(PlatformJob::getStatus,Constants.PlatformJobStatus.IN_WAIT.getKey()).or() |
| | | .apply(" ( status = "+Constants.PlatformJobStatus.TRANSFERING.getKey()+" and PLATFORM_GROUP_ID = "+platformGroupId+" ) ") |
| | | .apply(" ( t.status = "+Constants.PlatformJobStatus.TRANSFERING.getKey()+" and t.PLATFORM_GROUP_ID = "+platformGroupId+" ) ") |
| | | ) |
| | | ) |
| | | ); |
| | |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) |
| | | .leftJoin(PlatformBooks.class,PlatformBooks::getJobId,PlatformJob::getId) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(Platform::getIsdeleted,Constants.ZERO) |
| | | .eq(pageWrap.getModel().getPlatformGroupId() != null, PlatformJob::getPlatformGroupId, pageWrap.getModel().getPlatformGroupId()) |
| | | .like(pageWrap.getModel().getCarCodeFront() != null, PlatformJob::getCarCodeFront, pageWrap.getModel().getCarCodeFront()) |
| | | |
| | |
| | | if(Constants.equalsInteger(platformJob.getType(),Constants.TWO) |
| | | || Constants.equalsInteger(platformJob.getType(),Constants.THREE) |
| | | || Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){ |
| | | |
| | | //查询当前启用的停车场 |
| | | List<Parks> parksList = parksMapper.selectList(new QueryWrapper<Parks>() |
| | | .lambda() |
| | | .isNotNull(Parks::getHkId) |
| | | .eq(Parks::getIsdeleted,Constants.ZERO)); |
| | | |
| | | //取消当前车辆所有权限 |
| | | List<VisitPark> cancelParkList = visitParkMapper.selectList(new QueryWrapper<VisitPark>().lambda() |
| | | .eq(VisitPark::getCarCode,platformJob.getCarCodeFront()) |
| | | .eq(VisitPark::getObjType,Constants.ONE) |
| | | .eq(VisitPark::getHkStatus,Constants.ONE) |
| | | .isNotNull(VisitPark::getHkId) |
| | | .apply(" END_TIME > now() ") |
| | | ); |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(cancelParkList)){ |
| | | for (VisitPark visitPark:cancelParkList) { |
| | | ParkReservationDelRequest param = new ParkReservationDelRequest(); |
| | | param.setReserveOrderNo(visitPark.getHkId()); |
| | | HKService.parkReservationDeletion(param); |
| | | } |
| | | } |
| | | |
| | | |
| | | List<VisitPark> visitParkList = new ArrayList<>(); |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(parksList)){ |
| | | Boolean sendStatus = true; |
| | |
| | | || Constants.equalsInteger(platformJob.getType(),Constants.FOUR)){ |
| | | |
| | | List<VisitPark> visitParkList = visitParkMapper.selectList(new QueryWrapper<VisitPark>().lambda() |
| | | .eq(VisitPark::getVisitApplyId,platformJob.getId()) |
| | | .eq(VisitPark::getCarCode,platformJob.getCarCodeFront()) |
| | | .eq(VisitPark::getObjType,Constants.ONE) |
| | | .eq(VisitPark::getHkStatus,Constants.ONE) |
| | | .isNotNull(VisitPark::getHkId) |
| | |
| | | platformLog.setParam2(DateUtil.dateTypeToString(platformLog.getCreateDate(),"yyyy-MM-dd HH:mm:ss")); |
| | | String v = Long.toString((platformLog.getCreateDate().getTime() - DateUtil.StringToDate(lastBeginPlatform.getParam1(),"yyyy-MM-dd HH:mm:ss").getTime() )/ 1000) ; |
| | | platformLog.setParam3(v); |
| | | platformLog.setRemark(platformJobBefor.getPlatformId().toString()); |
| | | }else if(Constants.equalsInteger(objType,Constants.PlatformJobLogType.TRANSFERING.getKey())){ |
| | | //查询最后一次日志是否为异常挂起,异常挂起后可进行转移 如果进行转移那么业务就需要重新进行开始就不需要特殊处理 ,如果不是异常挂起进行数据结束 则直接查询最后一次开始的时间 |
| | | PlatformLog lastPlatformLog = platformLogMapper.selectOne(new QueryWrapper<PlatformLog>().lambda() |
| | |
| | | List<PlatformJob> platformJobList = platformJobJoinMapper.selectJoinList(PlatformJob.class,new MPJLambdaWrapper<PlatformJob>() |
| | | .selectAll(PlatformJob.class) |
| | | .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 ") |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | |
| | | .orderByDesc(PlatformJob::getStatus) |
| | | .orderByAsc(PlatformJob::getSignDate) |
| | | ); |
| | | if(CollectionUtils.isEmpty(platformJobList)){ |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformJobList)){ |
| | | for (PlatformJob platformJob:platformJobList) { |
| | | if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.WORKING.getKey())){ |
| | | //计算已作业时长 根据月台工作效率 计算任务量需要时间 |
| | | if(Objects.isNull(platformJob.getTotalNum()) || Objects.isNull(platformJob.getWorkRate())){ |
| | | if(Objects.isNull(platformJob.getWorkNum()) || Objects.isNull(platformJob.getWorkRate())){ |
| | | platformJob.setOptTime(0L); |
| | | }else{ |
| | | Integer workMinute = platformJob.getTotalNum().multiply(new BigDecimal(60)).divide(platformJob.getWorkRate()).intValue(); |
| | | Integer workMinute = platformJob.getWorkNum().multiply(new BigDecimal(60)).divide(platformJob.getWorkRate()).intValue(); |
| | | Date overDate = DateUtil.getXMinuteAfterDate(platformJob.getNewStartDate(),workMinute); |
| | | platformJob.setOptTime(overDate.getTime()/1000); |
| | | platformJob.setOptTime(overDate.getTime()); |
| | | } |
| | | }else if(Constants.equalsInteger(platformJob.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){ |
| | | //计算已叫号时间 |
| | |
| | | .selectAs(PlatformGroup::getName,Platform::getGroupName) |
| | | .select(" (select ifnull(TIMESTAMPDIFF(HOUR, '2023-01-01 '||pg.start_time||':00', '2023-01-01 '||pg.end_time||':00' ),0) from platform_group pg " + |
| | | " where t.group_id = pg.id ) as openTime ") |
| | | .select(" ( select ROUND( ifnull(SUM(pl.PARAM3),0) / 3600 , 2 ) from platform_log pl where pl.OBJ_ID = t.id and pl.remark = t.id " + |
| | | " and pl.CREATE_DATE > '"+Utils.Date.getStart(platform.getQueryDateStart())+"' " + |
| | | "and pl.CREATE_DATE <= '"+Utils.Date.getEnd(platform.getQueryDateEnd())+"' ) as workCountTime ") |
| | | .select(" ( select ROUND( ifnull(SUM(pl.PARAM3),0) / 3600 , 2 ) from platform_log pl where pl.remark = t.id " + |
| | | " and pl.CREATE_DATE > '"+DateUtil.getFomartDate(platform.getQueryDateStart(),"yyyy-MM-dd")+" 00:00:00' " + |
| | | "and pl.CREATE_DATE <= '"+DateUtil.getFomartDate(platform.getQueryDateEnd(),"yyyy-MM-dd")+" 23:59:59' ) as workCountTime ") |
| | | .leftJoin(PlatformGroup.class,PlatformGroup::getId,Platform::getGroupId); |
| | | queryWrapper |
| | | .eq(platform.getGroupId() != null, Platform::getGroupId, platform.getGroupId()) |