获取当前用户某一工序还在进行中的任务数

hx-mes/src/main/java/com/fjhx/mes/controller/production/ProductionTaskDetailController.java

@@ -90,4 +90,13 @@ public class ProductionTaskDetailController {
         return productionTaskDetailService.snInfo(productionTaskDetailDto.getProductSn());
     }
 
+    /**
+     * 获取当前用户某一工序还在进行中的任务数
+     */
+    ;
+    @PostMapping("/haveTaskCount")
+    Long haveTaskCount(@RequestBody ProductionTaskDetailDto dto) {
+        return productionTaskDetailService.haveTaskCount(dto);
+    }
+
 }

hx-mes/src/main/java/com/fjhx/mes/service/production/ProductionTaskDetailService.java

@@ -54,4 +54,9 @@ public interface ProductionTaskDetailService extends BaseService<ProductionTaskD
     void rejection(ProductionTaskDetailDto productionTaskDetailDto);
 
     ProductionTaskDetailVo snInfo(String sn);
+
+    /**
+     * 获取当前用户某一工序还在进行中的任务数
+     */
+    Long haveTaskCount(ProductionTaskDetailDto dto);
 }

hx-mes/src/main/java/com/fjhx/mes/service/production/impl/ProductionTaskDetailServiceImpl.java

@@ -7,12 +7,10 @@ import com.fjhx.common.enums.PushBusinessTypeEnum;
 import com.fjhx.common.utils.Assert;
 import com.fjhx.item.entity.product.po.ProductInfo;
 import com.fjhx.item.service.product.ProductInfoService;
-import com.fjhx.mes.entity.applicable.po.ApplicableProducts;
 import com.fjhx.mes.entity.production.dto.ProductionTaskDetailDto;
 import com.fjhx.mes.entity.production.dto.ProductionTaskDetailSelectDto;
 import com.fjhx.mes.entity.production.po.*;
 import com.fjhx.mes.entity.production.vo.ProductionTaskDetailVo;
-import com.fjhx.mes.entity.technology.po.Technology;
 import com.fjhx.mes.entity.work.po.WorkOrder;
 import com.fjhx.mes.entity.work.po.WorkOrderProductionProcesses;
 import com.fjhx.mes.entity.work.vo.WorkOrderVo;
@@ -338,4 +336,18 @@ public class ProductionTaskDetailServiceImpl extends ServiceImpl<ProductionTaskD
         return productionTaskDetailVo;
     }
 
+    /**
+     * 获取当前用户某一工序还在进行中的任务数
+     */
+    @Override
+    public Long haveTaskCount(ProductionTaskDetailDto dto){
+        //获取负责人为当前用户 工序为某一工序 未在流转（进行中） 未完成 的任务计数
+        return this.count(q->q
+                .eq(ProductionTaskDetail::getPersonLiableId,SecurityUtils.getUserId())
+                .eq(ObjectUtil.isNotEmpty(dto.getProductionProcessesId()),ProductionTaskDetail::getProductionProcessesId,dto.getProductionProcessesId())
+                .eq(ProductionTaskDetail::getCirculationStatus,0)
+                .eq(ProductionTaskDetail::getFinishStatus,0)
+        );
+    }
+
 }