楚江ERP-客户开发待办类型数量统计

+package com.lframework.xingyun.sc.bo.customer.develop;
+
+import com.lframework.starter.web.core.bo.BaseBo;
+import com.lframework.starter.web.core.dto.BaseDto;
+import com.lframework.xingyun.sc.entity.CustomerDevelopPlan;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+
+/**
+ * <p>
+ * 客户开发计划统计 BO
+ * </p>
+ *
+ */
+@Data
+public class CustomerDevelopPlanStatisticsBo extends BaseBo<CustomerDevelopPlan> implements BaseDto {
+
+    /**
+     * 全部数量
+     */
+    @ApiModelProperty("allCount")
+    private Integer allCount;
+
+    /**
+     * 已办数量
+     */
+    @ApiModelProperty("已办数量")
+    private Integer completedCount;
+
+    /**
+     * 待办数量
+     */
+    @ApiModelProperty("待办数量")
+    private Integer todoCount;
+}

@@ -15,6 +15,7 @@ import com.lframework.xingyun.basedata.service.customer.CustomerService;
 import com.lframework.xingyun.basedata.service.office.OfficeService;
 import com.lframework.xingyun.basedata.service.product.ProductVarietyService;
 import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
+import com.lframework.xingyun.sc.bo.customer.develop.CustomerDevelopPlanStatisticsBo;
 import com.lframework.xingyun.sc.bo.customer.develop.GetCustomerDevelopPlanBo;
 import com.lframework.xingyun.sc.enums.ExportType;
 import com.lframework.xingyun.sc.excel.customer.CustomerDevelopExportTaskWorker;
@@ -171,6 +172,19 @@ public class CustomerDevelopPlanController extends DefaultBaseController {
 
 
     /**
+     * 待办类型数量统计
+     *
+     */
+    @ApiOperation("待办类型数量统计")
+    @HasPermission({"customer-dev-manage:customer-dev-plan:statistics"})
+    @GetMapping("/todoTypeStatistics")
+    public InvokeResult<CustomerDevelopPlanStatisticsBo> todoTypeStatistics() {
+        CustomerDevelopPlanStatisticsBo statistics = customerDevelopPlanService.todoTypeStatistics();
+        return InvokeResultBuilder.success(statistics);
+    }
+
+
+    /**
      * 封装客户开发数据
      *
      * @param dataList  数据集

 package com.lframework.xingyun.sc.impl.customer;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
@@ -10,6 +11,7 @@ import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.utils.*;
+import com.lframework.xingyun.sc.bo.customer.develop.CustomerDevelopPlanStatisticsBo;
 import com.lframework.xingyun.sc.entity.CustomerDevelopPlan;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
 import com.lframework.starter.web.core.components.resp.PageResult;
@@ -262,4 +264,44 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
                 .eq(CustomerDevelopPlan::getId, id);
         getBaseMapper().update(updateWrapper);
     }
+
+
+    /**
+     * 统计待办任务类型数量
+     *
+     * @return  CustomerDevelopPlanStatisticsBo
+     */
+    @Override
+    public CustomerDevelopPlanStatisticsBo todoTypeStatistics() {
+        // 获取所有客户开发数据
+        LambdaQueryWrapper<CustomerDevelopPlan> queryWrapper = Wrappers.lambdaQuery(CustomerDevelopPlan.class);
+        List<CustomerDevelopPlan> customerDevelopPlans = this.getBaseMapper().selectList(queryWrapper);
+        if (CollectionUtils.isEmpty(customerDevelopPlans)) {
+            return null;
+        }
+        // 获取当前人员流程任务数据
+        List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo()
+                , SecurityUtil.getCurrentUser().getId());
+        List<String> businessIds = new ArrayList<>();
+        if (CollectionUtils.isNotEmpty(flowTaskList)) {
+            businessIds = flowTaskList.stream().map(FlowTaskDto::getBusinessId).collect(Collectors.toList());
+        }
+        int completedCount = 0;
+        int todoCount = 0;
+        for (CustomerDevelopPlan plan : customerDevelopPlans) {
+            CustomerDevelopStatus status = plan.getStatus();
+            if (CustomerDevelopStatus.PASS.equals(status)) {
+                completedCount++;
+            }
+            if (businessIds.contains(plan.getId())) {
+                todoCount++;
+            }
+        }
+        CustomerDevelopPlanStatisticsBo statisticsBo = new CustomerDevelopPlanStatisticsBo();
+        statisticsBo.setAllCount(customerDevelopPlans.size());
+        statisticsBo.setCompletedCount(completedCount);
+        statisticsBo.setTodoCount(todoCount);
+
+        return statisticsBo;
+    }
 }

 package com.lframework.xingyun.sc.service.customer;
 
+import com.lframework.xingyun.sc.bo.customer.develop.CustomerDevelopPlanStatisticsBo;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.vo.customer.develop.CreateCustomerDevelopPlanVo;
 import com.lframework.xingyun.sc.vo.customer.develop.QueryCustomerDevelopPlanVo;
@@ -76,4 +77,11 @@ public interface CustomerDevelopPlanService extends BaseMpService<CustomerDevelo
      * @param status    状态
      */
     void updateStatus(String id, CustomerDevelopStatus status);
+
+    /**
+     * 统计待办任务类型数量
+     *
+     * @return  CustomerDevelopPlanStatisticsBo
+     */
+    CustomerDevelopPlanStatisticsBo todoTypeStatistics();
 }