物料业务数据分发功能更新

ny

2024-12-12 f78656b3aff688567b0e8ff2e83646014ec098eb

物料业务数据分发功能更新

 src/main/java/com/itstyle/mdm/enumwrap/MdmEnum.java

@@ -18,7 +18,7 @@
    MDM_LADGPS_MATERIAL_DICTIONARY("局域物料词典编码数据获取","/api/V1/ztwo/getWLCDCodes"),

    /**
     * 局域物料词典编码
     * 局域物料业务编码数据获取
     */
    MDM_MATERIAL_DICTIONARY("物料业务编码数据获取","/api/V1/zbusiness/getWLYWCodes"),


 src/main/java/com/itstyle/mdm/service/impl/MdmServiceImpl.java

@@ -1,6 +1,7 @@
package com.itstyle.mdm.service.impl;


import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
@@ -59,16 +60,21 @@
                            continue;
                        }
                        jsonObj.put("renewstatus","update");
                        //wms需求：过滤件装规格为空的数据
                        if(!StringUtils.isEmpty(jsonObj.getString("specification"))){
                        newJsonArray.add(jsonObj);
                        }
                        //数据存在变化
                        dynamicQuery.update(mdm);//更新数据
                    }
                }else {
                    jsonObj.put("renewstatus","new");
                    //wms需求：过滤件装规格为空的数据
                    if(!StringUtils.isEmpty(jsonObj.getString("specification"))){
                    newJsonArray.add(jsonObj);
                    }
                    //说明该数据为新数据
                    mdmData.setUuid(UUID.randomUUID().toString());
                    System.out.println(mdmData.toString());
                    dynamicQuery.save(mdmData);
                }
            }

 src/main/java/com/itstyle/mdm/utils/MdmUtils.java

@@ -51,7 +51,8 @@
                records = records.replaceAll("\\p{Z}", "");
                JSONObject jsonObj = JSON.parseObject(records);
                records = jsonObj.getString("records");
                records = records.replaceAll("unit","unitName");
                records = records.replaceAll("attri2","unitName");
                records = records.replaceAll("brand","supplierName");
                records = records.replaceAll("jzgg","specification");
                records = records.replaceAll("model","specificationDisplayName");
                records = records.replaceAll("namecn","code");
@@ -73,7 +74,7 @@
                            "}");*/
                    //返回json格式参数
                    String toString = returnJson.toString();
                    System.out.println(toString);
                    System.out.println("响应参数分发："+toString);
                    //分发增量数据至异构系统
                    distributeDataToSys(toString,name);
                }
@@ -118,7 +119,6 @@
                            "}");
                    //返回json格式参数
                    String toString = returnJson.toString();
                    System.out.println(toString);
                    //分发增量数据至异构系统
                    distributeDataToSys(toString,name);
                }

 src/main/java/com/itstyle/quartz/web/JobController.java

@@ -103,7 +103,7 @@
            scheduler.unscheduleJob(triggerKey);  
            // 删除任务  
            scheduler.deleteJob(JobKey.jobKey(quartz.getJobName(), quartz.getJobGroup()));  
            System.out.println("removeJob:"+JobKey.jobKey(quartz.getJobName()));  

        } catch (Exception e) {  
            e.printStackTrace();
            return Result.error();