项目计划数据

src/main/java/com/malk/eastar/util/YidaFieldMapper.java

@@ -0,0 +1,414 @@
+package com.malk.eastar.util;
+
+import cn.hutool.core.annotation.Alias;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 宜搭表单字段映射工具
+ * 根据阶段属性匹配表单字段，填充时间数据
+ */
+public class YidaFieldMapper {
+
+    /**
+     * 阶段数据对象
+     */
+    public static class StageData {
+        @Alias("textField_mgu5rm3f")
+        private String stage;              // 阶段：textField_mgu5rm3f
+        @Alias("dateField_mgu5rm3g")
+        private String planStartTime;      // 计划开始时间：dateField_mgu5rm3g
+        @Alias("dateField_mp4t9q5o")
+        private String planStartTimeLatest; // 计划开始时间（最新）：dateField_mp4t9q5o
+        @Alias("dateField_mgu5rm3h")
+        private String planEndTime;        // 计划结束时间：dateField_mgu5rm3h
+        @Alias("dateField_mp4t9q5p")
+        private String planEndTimeLatest;  // 计划结束时间（最新）：dateField_mp4t9q5p
+        @Alias("dateField_mp4t9q5q")
+        private String actualStartTime;    // 实际开始时间：dateField_mp4t9q5q
+        @Alias("dateField_mp4t9q5r")
+        private String actualEndTime;      // 实际结束时间：dateField_mp4t9q5r
+
+        public StageData() {}
+
+        public StageData(String stage, String planStartTime, String planStartTimeLatest,
+                        String planEndTime, String planEndTimeLatest,
+                        String actualStartTime, String actualEndTime) {
+            this.stage = stage;
+            this.planStartTime = planStartTime;
+            this.planStartTimeLatest = planStartTimeLatest;
+            this.planEndTime = planEndTime;
+            this.planEndTimeLatest = planEndTimeLatest;
+            this.actualStartTime = actualStartTime;
+            this.actualEndTime = actualEndTime;
+        }
+
+        // Getters and Setters
+        public String getStage() { return stage; }
+        public void setStage(String stage) { this.stage = stage; }
+        
+        public String getPlanStartTime() { return planStartTime; }
+        public void setPlanStartTime(String planStartTime) { this.planStartTime = planStartTime; }
+        
+        public String getPlanStartTimeLatest() { return planStartTimeLatest; }
+        public void setPlanStartTimeLatest(String planStartTimeLatest) { this.planStartTimeLatest = planStartTimeLatest; }
+        
+        public String getPlanEndTime() { return planEndTime; }
+        public void setPlanEndTime(String planEndTime) { this.planEndTime = planEndTime; }
+        
+        public String getPlanEndTimeLatest() { return planEndTimeLatest; }
+        public void setPlanEndTimeLatest(String planEndTimeLatest) { this.planEndTimeLatest = planEndTimeLatest; }
+        
+        public String getActualStartTime() { return actualStartTime; }
+        public void setActualStartTime(String actualStartTime) { this.actualStartTime = actualStartTime; }
+        
+        public String getActualEndTime() { return actualEndTime; }
+        public void setActualEndTime(String actualEndTime) { this.actualEndTime = actualEndTime; }
+    }
+
+    /**
+     * 表单字段映射结果
+     */
+    static class FormFieldMapping {
+        private Map<String, String> fieldValues = new HashMap<>();
+
+        public void put(String fieldId, String value) {
+            if (value != null && !value.isEmpty()) {
+                fieldValues.put(fieldId, value);
+            }
+        }
+
+        public Map<String, String> getFieldValues() {
+            return fieldValues;
+        }
+
+        @Override
+        public String toString() {
+            return fieldValues.toString();
+        }
+    }
+
+    /**
+     * 阶段名称与表单字段前缀的映射关系
+     * 根据之前获取的宜搭表单字段信息建立映射
+     */
+    private static final Map<String, String> STAGE_TO_FIELD_PREFIX = new HashMap<>();
+    
+    static {
+        // 初始化阶段与字段前缀的映射关系
+        // 格式：阶段名称 -> 表单字段名称中"-"之前的部分
+        STAGE_TO_FIELD_PREFIX.put("立项", "立项");
+        STAGE_TO_FIELD_PREFIX.put("白样", "白样");
+        STAGE_TO_FIELD_PREFIX.put("制版", "制版");
+        STAGE_TO_FIELD_PREFIX.put("产前样", "产前样");
+        STAGE_TO_FIELD_PREFIX.put("大货样", "大货样");
+        STAGE_TO_FIELD_PREFIX.put("大货", "大货");
+        STAGE_TO_FIELD_PREFIX.put("包装", "包装");
+        STAGE_TO_FIELD_PREFIX.put("出货", "出货");
+        STAGE_TO_FIELD_PREFIX.put("结项", "结项");
+    }
+
+    /**
+     * 表单字段ID映射表
+     * 根据阶段前缀和时间类型获取对应的字段ID
+     */
+    private static final Map<String, Map<String, String>> FIELD_ID_MAP = new HashMap<>();
+    
+    static {
+        // 立项阶段
+        Map<String, String> lixiang = new HashMap<>();
+        lixiang.put("planStartTime", "dateField_mgu5rm3g");
+        lixiang.put("planStartTimeLatest", "dateField_mp4t9q5o");
+        lixiang.put("planEndTime", "dateField_mgu5rm3h");
+        lixiang.put("planEndTimeLatest", "dateField_mp4t9q5p");
+        lixiang.put("actualStartTime", "dateField_mp4t9q5q");
+        lixiang.put("actualEndTime", "dateField_mp4t9q5r");
+        FIELD_ID_MAP.put("立项", lixiang);
+
+        // 白样阶段
+        Map<String, String> baiyang = new HashMap<>();
+        baiyang.put("planStartTime", "dateField_mpqn6ucm");
+        baiyang.put("planStartTimeLatest", "dateField_mpqn6uco");
+        baiyang.put("planEndTime", "dateField_mpqn6ucq");
+        baiyang.put("planEndTimeLatest", "dateField_mpqn6ucs");
+        baiyang.put("actualStartTime", "dateField_mpqn6ucv");
+        baiyang.put("actualEndTime", "dateField_mpqn6ucx");
+        FIELD_ID_MAP.put("白样", baiyang);
+
+        // 制版阶段
+        Map<String, String> zhiban = new HashMap<>();
+        zhiban.put("planStartTime", "dateField_mpqn6ud4");
+        zhiban.put("planStartTimeLatest", "dateField_mpqn6ud6");
+        zhiban.put("planEndTime", "dateField_mpqn6ud8");
+        zhiban.put("planEndTimeLatest", "dateField_mpqn6uda");
+        zhiban.put("actualStartTime", "dateField_mpqn6udd");
+        zhiban.put("actualEndTime", "dateField_mpqn6udf");
+        FIELD_ID_MAP.put("制版", zhiban);
+
+        // 产前样阶段
+        Map<String, String> chanqianyang = new HashMap<>();
+        chanqianyang.put("planStartTime", "dateField_mpqn6udm");
+        chanqianyang.put("planStartTimeLatest", "dateField_mpqn6udo");
+        chanqianyang.put("planEndTime", "dateField_mpqn6udq");
+        chanqianyang.put("planEndTimeLatest", "dateField_mpqn6uds");
+        chanqianyang.put("actualStartTime", "dateField_mpqn6udv");
+        chanqianyang.put("actualEndTime", "dateField_mpqn6udx");
+        FIELD_ID_MAP.put("产前样", chanqianyang);
+
+        // 大货样阶段
+        Map<String, String> dahuoyang = new HashMap<>();
+        dahuoyang.put("planStartTime", "dateField_mpqn6ue4");
+        dahuoyang.put("planStartTimeLatest", "dateField_mpqn6ue6");
+        dahuoyang.put("planEndTime", "dateField_mpqn6ue8");
+        dahuoyang.put("planEndTimeLatest", "dateField_mpqn6uea");
+        dahuoyang.put("actualStartTime", "dateField_mpqn6ued");
+        dahuoyang.put("actualEndTime", "dateField_mpqn6uef");
+        FIELD_ID_MAP.put("大货样", dahuoyang);
+
+        // 大货阶段
+        Map<String, String> dahuo = new HashMap<>();
+        dahuo.put("planStartTime", "dateField_mpqn6uem");
+        dahuo.put("planStartTimeLatest", "dateField_mpqn6ueo");
+        dahuo.put("planEndTime", "dateField_mpqn6ueq");
+        dahuo.put("planEndTimeLatest", "dateField_mpqn6ues");
+        dahuo.put("actualStartTime", "dateField_mpqn6uev");
+        dahuo.put("actualEndTime", "dateField_mpqn6uex");
+        FIELD_ID_MAP.put("大货", dahuo);
+
+        // 包装阶段
+        Map<String, String> baozhuang = new HashMap<>();
+        baozhuang.put("planStartTime", "dateField_mpqn6uf4");
+        baozhuang.put("planStartTimeLatest", "dateField_mpqn6uf6");
+        baozhuang.put("planEndTime", "dateField_mpqn6uf8");
+        baozhuang.put("planEndTimeLatest", "dateField_mpqn6ufa");
+        baozhuang.put("actualStartTime", "dateField_mpqn6ufd");
+        baozhuang.put("actualEndTime", "dateField_mpqn6uff");
+        FIELD_ID_MAP.put("包装", baozhuang);
+
+        // 出货阶段
+        Map<String, String> chuhuo = new HashMap<>();
+        chuhuo.put("planStartTime", "dateField_mpqn6ufm");
+        chuhuo.put("planStartTimeLatest", "dateField_mpqn6ufo");
+        chuhuo.put("planEndTime", "dateField_mpqn6ufq");
+        chuhuo.put("planEndTimeLatest", "dateField_mpqn6ufs");
+        chuhuo.put("actualStartTime", "dateField_mpqn6ufv");
+        chuhuo.put("actualEndTime", "dateField_mpqn6ufx");
+        FIELD_ID_MAP.put("出货", chuhuo);
+
+        // 结项阶段
+        Map<String, String> jiexiang = new HashMap<>();
+        jiexiang.put("planStartTime", "dateField_mpqn6ug4");
+        jiexiang.put("planStartTimeLatest", "dateField_mpqn6ug6");
+        jiexiang.put("planEndTime", "dateField_mpqn6ug8");
+        jiexiang.put("planEndTimeLatest", "dateField_mpqn6uga");
+        jiexiang.put("actualStartTime", "dateField_mpqn6ugd");
+        jiexiang.put("actualEndTime", "dateField_mpqn6ugf");
+        FIELD_ID_MAP.put("结项", jiexiang);
+    }
+
+    /**
+     * 根据阶段数据列表生成表单字段映射
+     * 
+     * @param stageDataList 阶段数据对象集合
+     * @return 表单字段ID到值的映射Map
+     */
+    public static Map<String, String> mapStageDataToFormFields(List<StageData> stageDataList) {
+        if (stageDataList == null || stageDataList.isEmpty()) {
+            return new HashMap<>();
+        }
+
+        Map<String, String> result = new HashMap<>();
+
+        for (StageData stageData : stageDataList) {
+            String stage = stageData.getStage();
+            
+            if (stage == null || stage.isEmpty()) {
+                continue;
+            }
+
+            // 查找匹配的阶段前缀
+            String matchedPrefix = findMatchingStagePrefix(stage);
+            
+            if (matchedPrefix == null) {
+                System.out.println("警告：未找到阶段 '" + stage + "' 对应的表单字段前缀");
+                continue;
+            }
+
+            // 获取该阶段的字段ID映射
+            Map<String, String> fieldIdMap = FIELD_ID_MAP.get(matchedPrefix);
+            
+            if (fieldIdMap == null) {
+                System.out.println("警告：阶段 '" + matchedPrefix + "' 没有配置字段ID映射");
+                continue;
+            }
+
+            // 填充时间数据到对应的字段
+            fillTimeData(result, fieldIdMap, stageData);
+        }
+
+        return result;
+    }
+
+    /**
+     * 查找匹配的阶段前缀
+     * 
+     * @param stage 阶段值
+     * @return 匹配的阶段前缀，未找到返回null
+     */
+    private static String findMatchingStagePrefix(String stage) {
+        // 直接匹配
+        if (STAGE_TO_FIELD_PREFIX.containsKey(stage)) {
+            return stage;
+        }
+
+        // 尝试模糊匹配：检查阶段值是否包含某个已知阶段名称
+        for (String knownStage : STAGE_TO_FIELD_PREFIX.keySet()) {
+            if (stage.contains(knownStage) || knownStage.contains(stage)) {
+                return knownStage;
+            }
+        }
+
+        return null;
+    }
+
+    /**
+     * 填充时间数据到结果Map
+     * 
+     * @param result 结果Map
+     * @param fieldIdMap 字段ID映射
+     * @param stageData 阶段数据
+     */
+    private static void fillTimeData(Map<String, String> result, 
+                                    Map<String, String> fieldIdMap, 
+                                    StageData stageData) {
+        // 计划开始时间
+        if (stageData.getPlanStartTime() != null && !stageData.getPlanStartTime().isEmpty()) {
+            String fieldId = fieldIdMap.get("planStartTime");
+            if (fieldId != null) {
+                result.put(fieldId, stageData.getPlanStartTime());
+            }
+        }
+
+        // 计划开始时间（最新）
+        if (stageData.getPlanStartTimeLatest() != null && !stageData.getPlanStartTimeLatest().isEmpty()) {
+            String fieldId = fieldIdMap.get("planStartTimeLatest");
+            if (fieldId != null) {
+                result.put(fieldId, stageData.getPlanStartTimeLatest());
+            }
+        }
+
+        // 计划结束时间
+        if (stageData.getPlanEndTime() != null && !stageData.getPlanEndTime().isEmpty()) {
+            String fieldId = fieldIdMap.get("planEndTime");
+            if (fieldId != null) {
+                result.put(fieldId, stageData.getPlanEndTime());
+            }
+        }
+
+        // 计划结束时间（最新）
+        if (stageData.getPlanEndTimeLatest() != null && !stageData.getPlanEndTimeLatest().isEmpty()) {
+            String fieldId = fieldIdMap.get("planEndTimeLatest");
+            if (fieldId != null) {
+                result.put(fieldId, stageData.getPlanEndTimeLatest());
+            }
+        }
+
+        // 实际开始时间
+        if (stageData.getActualStartTime() != null && !stageData.getActualStartTime().isEmpty()) {
+            String fieldId = fieldIdMap.get("actualStartTime");
+            if (fieldId != null) {
+                result.put(fieldId, stageData.getActualStartTime());
+            }
+        }
+
+        // 实际结束时间
+        if (stageData.getActualEndTime() != null && !stageData.getActualEndTime().isEmpty()) {
+            String fieldId = fieldIdMap.get("actualEndTime");
+            if (fieldId != null) {
+                result.put(fieldId, stageData.getActualEndTime());
+            }
+        }
+    }
+
+    /**
+     * 测试方法
+     */
+    public static void main(String[] args) {
+        // 创建测试数据
+        List<StageData> stageDataList = new ArrayList<>();
+        
+        // 立项阶段数据
+        StageData lixiang = new StageData(
+            "立项",
+            "2024-01-01",
+            "2024-01-02",
+            "2024-01-10",
+            "2024-01-11",
+            "2024-01-03",
+            "2024-01-09"
+        );
+        stageDataList.add(lixiang);
+
+        // 白样阶段数据
+        StageData baiyang = new StageData(
+            "白样",
+            "2024-01-15",
+            "2024-01-16",
+            "2024-01-25",
+            "2024-01-26",
+            "2024-01-17",
+            "2024-01-24"
+        );
+        stageDataList.add(baiyang);
+
+        // 制版阶段数据
+        StageData zhiban = new StageData(
+            "制版",
+            "2024-02-01",
+            "2024-02-02",
+            "2024-02-10",
+            "2024-02-11",
+            "2024-02-03",
+            "2024-02-09"
+        );
+        stageDataList.add(zhiban);
+
+        // 执行映射
+        Map<String, String> formFields = mapStageDataToFormFields(stageDataList);
+
+        // 输出结果
+        System.out.println("=== 表单字段映射结果 ===");
+        System.out.println("共映射 " + formFields.size() + " 个字段\n");
+        
+        // 按阶段分组展示
+        Map<String, List<Map.Entry<String, String>>> groupedByStage = new LinkedHashMap<>();
+        
+        for (Map.Entry<String, String> entry : formFields.entrySet()) {
+            String fieldId = entry.getKey();
+            String stage = getStageByFieldId(fieldId);
+            
+            groupedByStage.computeIfAbsent(stage, k -> new ArrayList<>()).add(entry);
+        }
+        
+        for (Map.Entry<String, List<Map.Entry<String, String>>> entry : groupedByStage.entrySet()) {
+            System.out.println("【" + entry.getKey() + "】");
+            for (Map.Entry<String, String> field : entry.getValue()) {
+                System.out.println("  " + field.getKey() + " = " + field.getValue());
+            }
+            System.out.println();
+        }
+    }
+
+    /**
+     * 根据字段ID获取阶段名称（用于展示）
+     */
+    private static String getStageByFieldId(String fieldId) {
+        for (Map.Entry<String, Map<String, String>> entry : FIELD_ID_MAP.entrySet()) {
+            if (entry.getValue().containsValue(fieldId)) {
+                return entry.getKey();
+            }
+        }
+        return "未知";
+    }
+}

src/test/java/YdTest.java

@@ -0,0 +1,64 @@
+import cn.hutool.core.bean.BeanUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.malk.eastar.LtcEastarApplication;
+import com.malk.eastar.util.YidaFieldMapper;
+import com.malk.server.aliwork.YDConf;
+import com.malk.server.aliwork.YDParam;
+import com.malk.service.aliwork.YDClient;
+import com.malk.service.aliwork.YDService;
+import com.malk.utils.UtilMap;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.*;
+
+@Slf4j
+@SpringBootTest(classes = LtcEastarApplication.class)
+@RunWith(SpringRunner.class)
+public class YdTest {
+
+    @Autowired
+    private YDClient ydClient;
+    @Autowired
+    private YDService ydService;
+    @Autowired
+    private YDConf ydConf;
+
+    @Test
+    public void test() {
+        List<Map> list=ydService.queryFormData_all(YDParam.builder().formUuid("FORM-D8DFF1F8C07A4869BCC850090F3A3B4EE0AV").build());
+        System.out.println(list.size());
+        for (Map formData : list) {
+            List<Map> table= UtilMap.getList(formData,"tableField_mgu5rm3e");
+            System.out.println(table);
+            List<YidaFieldMapper.StageData> stageDataList = new ArrayList<>();
+            for(Map map:table){
+                stageDataList.add(BeanUtil.toBean(map,YidaFieldMapper.StageData.class));
+            }
+            System.out.println(stageDataList);
+            // 执行映射
+            Map<String, String> formFields = YidaFieldMapper.mapStageDataToFormFields(stageDataList);
+            System.out.println(JSONObject.toJSONString(formFields));
+            Map save=new HashMap();
+            save.put("textField_me2hyldc",String.valueOf(formData.get("textField_me2hyldc")));
+            save.put("textField_me87x1nz",String.valueOf(formData.get("textField_me87x1nz")));
+            save.put("associationFormField_me9n24kk",ydConf.getDataByCompId(formData,"associationFormField_me9n24kk"));
+            save.put("associationFormField_me2hylda",ydConf.getDataByCompId(formData,"associationFormField_me2hylda"));
+            save.put("checkboxField_me9n37rs",String.valueOf(formData.get("checkboxField_me9n37rs")));
+            save.put("associationFormField_mdy7w1wn",ydConf.getDataByCompId(formData,"associationFormField_mdy7w1wn"));
+            save.put("textField_me2hyldb",String.valueOf(formData.get("textField_me2hyldb")));
+            save.put("associationFormField_mpsk95b8",ydConf.associationForm("FORM-D8DFF1F8C07A4869BCC850090F3A3B4EE0AV",String.valueOf(formData.get("instanceId")),
+                    String.valueOf(formData.get("textField_me87x1nz")),"",true));
+            save.putAll(formFields);
+            ydClient.operateData(YDParam.builder().formUuid("FORM-F836816D100C49A0968F0BA159B817773XSI")
+                    .formDataJson(JSONObject.toJSONString(save)).searchCondition(JSONObject.toJSONString(Arrays.asList(
+                            ydConf.searchCondition_TextFiled("textField_me2hyldc",String.valueOf(formData.get("textField_me2hyldc")),"eq")
+                    ))).build(), YDConf.FORM_OPERATION.upsert);
+        }
+    }
+
+}