From 843d20d3b513c3513b77cfd623368571f9345e3c Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期五, 13 三月 2026 13:13:18 +0800
Subject: [PATCH] fix: 移除数据同步类型,修改数据来源方式

---
 src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java |   12 +++++-------
 1 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java b/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java
index b04cf5a..c5bed01 100644
--- a/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java
+++ b/src/main/java/com/ruoyi/productionPlan/service/impl/ProductionPlanServiceImpl.java
@@ -24,6 +24,7 @@
 import com.ruoyi.productionPlan.dto.ProductionPlanDto;
 import com.ruoyi.productionPlan.dto.ProductionPlanImportDto;
 import com.ruoyi.productionPlan.dto.ProductionPlanSummaryDto;
+import com.ruoyi.productionPlan.enums.DataSourceTypeEnum;
 import com.ruoyi.productionPlan.mapper.ProductOrderPlanMapper;
 import com.ruoyi.productionPlan.mapper.ProductionPlanMapper;
 import com.ruoyi.productionPlan.pojo.ProductOrderPlan;
@@ -45,7 +46,6 @@
 import java.util.concurrent.locks.ReentrantLock;
 import java.util.stream.Collectors;
 
-import static com.ruoyi.productionPlan.enums.DataSourceTypeEnum.PRODUCTION_FORECAST;
 
 /**
  * <br>
@@ -190,7 +190,7 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public boolean add(ProductionPlanDto productionPlanDto) {
-        productionPlanDto.setDataSourceType(PRODUCTION_FORECAST.getCode());
+        productionPlanDto.setDataSourceType(DataSourceTypeEnum.MANUAL.getCode());
         productionPlanMapper.insert(productionPlanDto);
         return true;
     }
@@ -236,7 +236,7 @@
     @Transactional(rollbackFor = Exception.class)
     public void syncProdData(Integer dataSyncType) {
         if (!syncLock.tryLock()) {
-            log.warn("鍚屾姝e湪杩涜涓紝鏈 {} 鍚屾璇锋眰琚烦杩�", dataSyncType == 1 ? "鎵嬪姩" : "瀹氭椂浠诲姟");
+            log.warn("鍚屾姝e湪杩涜涓紝鏈 {} 鍚屾璇锋眰琚烦杩�", dataSyncType == 1 ? "鎵嬪姩鍚屾" : "瀹氭椂浠诲姟鍚屾");
             return;
         }
 
@@ -453,8 +453,7 @@
 
                 plan.setFormCreatedTime(parseUtcTime(item.getString("createdTimeGMT")));
                 plan.setFormModifiedTime(parseUtcTime(item.getString("modifiedTimeGMT")));
-                plan.setDataSyncType(dataSyncType);
-                plan.setDataSourceType(1);
+                plan.setDataSourceType(DataSourceTypeEnum.DING_TALK.getCode());
                 plan.setCreateTime(now);
                 plan.setUpdateTime(now);
                 plan.setTotalCount(totalCount);
@@ -553,8 +552,7 @@
             entity.setAssignedQuantity(BigDecimal.ZERO);
             entity.setCreateTime(LocalDateTime.now());
             entity.setUpdateTime(LocalDateTime.now());
-            entity.setDataSourceType(2);
-            entity.setDataSyncType(1);
+            entity.setDataSourceType(DataSourceTypeEnum.DING_TALK.getCode());
 
             // 鏍规嵁鐗╂枡缂栫爜濉厖鍏宠仈ID
             if (StringUtils.isNotEmpty(dto.getMaterialCode())) {

--
Gitblit v1.9.3