发货计划：移动端审核按钮展示权限

@@ -129,6 +129,9 @@ public class GetReplenishmentOrderBo extends BaseBo<ReplenishmentOrder> {
     @ApiModelProperty("状态名称")
     private String statusName;
 
+    @ApiModelProperty("是否展示审核按钮")
+    private Boolean showExamine;
+
     /**
      * 补货单物料行
      */

@@ -2,12 +2,16 @@ package com.lframework.xingyun.sc.controller.shipments;
 
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.lframework.starter.bpm.dto.FlowTaskDto;
+import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
+import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.utils.CollectionUtil;
 import com.lframework.starter.web.core.annotations.security.HasPermission;
 import com.lframework.starter.web.core.components.resp.InvokeResult;
 import com.lframework.starter.web.core.components.resp.InvokeResultBuilder;
 import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.controller.DefaultBaseController;
 import com.lframework.starter.web.core.utils.PageResultUtil;
 import com.lframework.starter.web.inner.entity.SysDataDicItem;
@@ -71,6 +75,8 @@ public class ReplenishmentOrderController extends DefaultBaseController {
     private PurchaseOrderInfoService purchaseOrderInfoService;
     @Resource
     private ReplenishmentOrderLineService replenishmentOrderLineService;
+    @Resource
+    private FlowTaskWrapperMapper flowTaskWrapperMapper;
 
 
     public static final String AUDIT_STATUS_DIC_CODE = "AUDIT_STATUS"; // 审核状态
@@ -205,6 +211,12 @@ public class ReplenishmentOrderController extends DefaultBaseController {
         });
 
         result.setReplenishmentOrderLineList(lineBoList);
+        // 获取当前人员的待办任务数据
+        List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
+        if (org.apache.commons.collections.CollectionUtils.isNotEmpty(flowTaskList)) {
+            List<String> businessIds = flowTaskList.stream().map(FlowTaskDto::getBusinessId).collect(Collectors.toList());
+            result.setShowExamine(businessIds.contains(result.getId()));
+        }
         return InvokeResultBuilder.success(result);
     }
 

 package com.lframework.xingyun.sc.controller.shipments.car;
 
+import com.github.pagehelper.PageInfo;
+import com.lframework.starter.bpm.dto.FlowTaskDto;
+import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
+import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.utils.CollectionUtil;
 import com.lframework.starter.web.core.annotations.security.HasPermission;
@@ -18,6 +22,7 @@ import com.lframework.xingyun.sc.vo.shipments.car.*;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
@@ -43,6 +48,8 @@ public class DraftRequestCarTicketController extends DefaultBaseController {
     private DraftRequestCarTicketService draftRequestCarTicketService;
     @Resource
     private PurchaseOrderInfoService purchaseOrderInfoService;
+    @Resource
+    private FlowTaskWrapperMapper flowTaskWrapperMapper;
     /**
      * 查询列表
      */
@@ -104,6 +111,12 @@ public class DraftRequestCarTicketController extends DefaultBaseController {
                 result.setDraftCreateBy(true);
             }
         }
+        // 获取当前人员的待办任务数据
+        List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
+        if (CollectionUtils.isNotEmpty(flowTaskList)) {
+            List<String> businessIds = flowTaskList.stream().map(FlowTaskDto::getBusinessId).collect(Collectors.toList());
+            result.setShowExamine(businessIds.contains(result.getId()));
+        }
 
         return InvokeResultBuilder.success(result);
     }

 package com.lframework.xingyun.sc.controller.shipments.delay;
 
+import com.lframework.starter.bpm.dto.FlowTaskDto;
+import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
+import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.web.core.annotations.security.HasPermission;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.controller.DefaultBaseController;
 import com.lframework.starter.web.core.utils.PageResultUtil;
 import com.lframework.starter.web.core.components.resp.PageResult;
 import com.lframework.starter.web.core.components.resp.InvokeResult;
+
+import javax.annotation.Resource;
 import javax.validation.constraints.NotBlank;
 import com.lframework.xingyun.sc.bo.shipments.delay.GetDelayedShipmentBo;
 import com.lframework.xingyun.sc.entity.DelayedShipment;
@@ -44,6 +49,8 @@ public class DelayedShipmentController extends DefaultBaseController {
     private DelayedShipmentService delayedShipmentService;
     @Autowired
     private DelayedShipmentDetailService delayedShipmentDetailService;
+    @Resource
+    private FlowTaskWrapperMapper flowTaskWrapperMapper;
 
     /**
      * 查询列表
@@ -97,6 +104,12 @@ public class DelayedShipmentController extends DefaultBaseController {
         vo.setDelayedShipmentId(id);
         List<DelayedShipmentDetail> delayedShipmentDetailList = delayedShipmentDetailService.query(vo);
         result.setDelayedShipmentDetailList(delayedShipmentDetailList);
+        // 获取当前人员的待办任务数据
+        List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
+        if (org.apache.commons.collections.CollectionUtils.isNotEmpty(flowTaskList)) {
+            List<String> businessIds = flowTaskList.stream().map(FlowTaskDto::getBusinessId).collect(Collectors.toList());
+            result.setShowExamine(businessIds.contains(result.getId()));
+        }
 
         return InvokeResultBuilder.success(result);
     }