采购-供应商报价：中止、完成、成交

@@ -20,6 +20,7 @@ import com.lframework.xingyun.basedata.service.breed.BreedRelationshipService;
 import com.lframework.xingyun.sc.events.quotation.CommonChangedEvent;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProjectQuote;
+import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectQuoteMapper;
 import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectMapper;
 import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationProjectQuoteService;
 import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationProjectService;
@@ -56,12 +57,20 @@ public class SupplierQuotationProjectServiceImpl
     private static final String STATUS_COMPLETED_CN = "COMPLETED";
     //已中止
     private static final String STATUS_ABORTED_CN = "ABORTED";
+    //中标
+    private static final String BID_STATUS_WIN = "WIN";
+    //未中标
+    private static final String BID_STATUS_LOSE = "LOSE";
+    //废标
+    private static final String BID_STATUS_ABORT = "ABORT";
 
     @Resource
     private BreedRelationshipService breedRelationshipService;
     @Resource
     private SupplierQuotationProjectQuoteService supplierQuotationProjectQuoteService;
     @Resource
+    private SupplierQuotationProjectQuoteMapper supplierQuotationProjectQuoteMapper;
+    @Resource
     private ApplicationEventPublisher applicationEventPublisher;
 
     @Override
@@ -198,6 +207,13 @@ public class SupplierQuotationProjectServiceImpl
             throw new DefaultClientException("供应商报价项目不存在！");
         }
 
+        if (STATUS_ABORTED_CN.equals(status)) {
+            validateProjectCanAbort(id);
+            updateProjectQuoteStatusToAbort(id);
+        } else if (STATUS_COMPLETED_CN.equals(status)) {
+            updateProjectQuoteStatusToLoseWhenCompleted(id);
+        }
+
         LambdaUpdateWrapper<SupplierQuotationProject> updateWrapper = Wrappers.lambdaUpdate(SupplierQuotationProject.class)
                 .set(SupplierQuotationProject::getStatus, status)
                 .eq(SupplierQuotationProject::getId, id);
@@ -297,5 +313,32 @@ public class SupplierQuotationProjectServiceImpl
         applicationEventPublisher.publishEvent(new CommonChangedEvent(this, id, eventType));
     }
 
+    private void validateProjectCanAbort(String projectId) {
+        Integer winCount = supplierQuotationProjectQuoteMapper.selectCount(
+                Wrappers.lambdaQuery(SupplierQuotationProjectQuote.class)
+                        .eq(SupplierQuotationProjectQuote::getProjectId, projectId)
+                        .eq(SupplierQuotationProjectQuote::getBidStatus, BID_STATUS_WIN));
+        if (winCount != null && winCount > 0) {
+            throw new DefaultClientException("项目中存在已成交的供应商报价，不允许中止！");
+        }
+    }
+
+    private void updateProjectQuoteStatusToAbort(String projectId) {
+        supplierQuotationProjectQuoteMapper.update(null,
+                Wrappers.lambdaUpdate(SupplierQuotationProjectQuote.class)
+                        .set(SupplierQuotationProjectQuote::getBidStatus, BID_STATUS_ABORT)
+                        .eq(SupplierQuotationProjectQuote::getProjectId, projectId));
+    }
+
+    private void updateProjectQuoteStatusToLoseWhenCompleted(String projectId) {
+        supplierQuotationProjectQuoteMapper.update(null,
+                Wrappers.lambdaUpdate(SupplierQuotationProjectQuote.class)
+                        .set(SupplierQuotationProjectQuote::getBidStatus, BID_STATUS_LOSE)
+                        .eq(SupplierQuotationProjectQuote::getProjectId, projectId)
+                        .and(wrapper -> wrapper.isNull(SupplierQuotationProjectQuote::getBidStatus)
+                                .or()
+                                .ne(SupplierQuotationProjectQuote::getBidStatus, BID_STATUS_WIN)));
+    }
+
 }