【DAOP-1.0】数据需求

【功能点】联调问题处理

 package com.csbr.qingcloud.portal.controller;
 package com.csbr.qingcloud.portal.controller;
 
 
 import com.csbr.cloud.common.response.CommonRes;
 import com.csbr.cloud.common.response.CommonRes;
-import com.csbr.qingcloud.portal.domain.vo.DemandApproveVO;
+import com.csbr.qingcloud.portal.domain.vo.*;
 import csbr.cloud.entity.annotation.SystemLog;
 import csbr.cloud.entity.annotation.SystemLog;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
 import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
 import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
-import com.csbr.qingcloud.portal.domain.vo.DemandQueryVO;
-import com.csbr.qingcloud.portal.domain.vo.DemandRQVO;
-import com.csbr.qingcloud.portal.domain.vo.DemandRSVO;
 import com.csbr.qingcloud.portal.service.DemandService;
 import com.csbr.qingcloud.portal.service.DemandService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -49,6 +46,14 @@ public class DemandController {
         demandService.updateDemand(vo);
         demandService.updateDemand(vo);
         return CommonRes.success(true);
         return CommonRes.success(true);
     }
     }
+
+    @PostMapping("/update-state")
+    @SystemLog(value = "数据需求-修改状态")
+    @Operation(summary = "数据需求-修改状态")
+    public CommonRes<Boolean> updateState(@RequestBody @Valid DemandUpdateStateVO vo) {
+        demandService.updateState(vo);
+        return CommonRes.success(true);
+    }
     
     
     @DeleteMapping("/delete")
     @DeleteMapping("/delete")
     @SystemLog(value = "数据需求-批量删除")
     @SystemLog(value = "数据需求-批量删除")

+package com.csbr.qingcloud.portal.domain.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+/**
+ * @program: D:/git/ms-data-circulation-portal-service
+ * @description: 数据需求状态修改参数
+ * @author: xcq
+ * @create: 2025-02-10
+ **/
+@Data
+@Schema(title = "数据需求状态修改参数")
+public class DemandUpdateStateVO {
+
+    @Schema(description = "加工单位唯一标识")
+    private String processCompanyGuid;
+
+    @Schema(description = "资源获取状态【N未开始 A进行中 Y已完成】")
+    private String resourceAcquisitionState;
+
+    @Schema(description = "产品加工状态【N未开始 A进行中 Y已完成】")
+    private String productProcessingState;
+
+    @Schema(description = "产品交付状态【N未开始 A进行中 Y已完成】")
+    private String productDeliveryState;
+
+    @Schema(description = "产品验收状态【N未开始 A进行中 Y已完成】")
+    private String productAcceptState;
+
+    
+}

 package com.csbr.qingcloud.portal.service;
 package com.csbr.qingcloud.portal.service;
 
 
 import com.csbr.qingcloud.portal.domain.vo.DemandApproveVO;
 import com.csbr.qingcloud.portal.domain.vo.DemandApproveVO;
+import com.csbr.qingcloud.portal.domain.vo.DemandUpdateStateVO;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
 import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
 import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
 import com.csbr.cloud.workflow.domain.vo.appove.FlowRQBaseVO;
 import com.csbr.cloud.workflow.domain.vo.appove.FlowRQBaseVO;
@@ -74,4 +75,6 @@ public interface DemandService {
     Boolean lastApprove(DemandApproveVO dto);
     Boolean lastApprove(DemandApproveVO dto);
 
 
     DemandRSVO getDemandDetailByProcess(String processOrderNo);
     DemandRSVO getDemandDetailByProcess(String processOrderNo);
+
+    void updateState(DemandUpdateStateVO vo);
 }
 }

@@ -318,6 +318,17 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService
         return convertToVO(list.get(0));
         return convertToVO(list.get(0));
     }
     }
 
 
+    @Override
+    public void updateState(DemandUpdateStateVO vo) {
+        LambdaUpdateWrapper<MfDemand> queryWrapper = new LambdaUpdateWrapper<>();
+        queryWrapper.eq(MfDemand::getProcessCompanyGuid,vo.getProcessCompanyGuid());
+        queryWrapper.set(StringUtils.isNotBlank(vo.getResourceAcquisitionState()),MfDemand::getResourceAcquisitionState,vo.getResourceAcquisitionState());
+        queryWrapper.set(StringUtils.isNotBlank(vo.getProductProcessingState()),MfDemand::getProductProcessingState,vo.getProductProcessingState());
+        queryWrapper.set(StringUtils.isNotBlank(vo.getProductDeliveryState()),MfDemand::getProductDeliveryState,vo.getProductDeliveryState());
+        queryWrapper.set(StringUtils.isNotBlank(vo.getProductAcceptState()),MfDemand::getProductAcceptState,vo.getProductAcceptState());
+        mfDemandService.update(queryWrapper);
+    }
+
     /**
     /**
      * 获取发起流程参数
      * 获取发起流程参数
      * @author xcq
      * @author xcq