更新计量单位解析功能

1

2024-01-24 67fb3bd7367fdf8a5b2186d4ff1c0f4d572c6d91

更新计量单位解析功能

 src/main/java/com/itstyle/mdm/job/MdmJob.java

@@ -64,7 +64,7 @@
    public String obtainMdmUnitData(){
        mdmUtils = (MdmUtils) applicationContext.getBean("mdmUtils");
        logger.info("MDM计量单位数据获取开始");
        mdmUtils.queryMaterial();
        mdmUtils.queryUnit();
        return "";
    }


 src/main/java/com/itstyle/mdm/service/MdmService.java

@@ -15,7 +15,14 @@
     * @param
     * @return 返回分发json
     */
    JSONArray saveMdmData(JSONArray recordArray);
    JSONArray saveMdmData(JSONArray recordArray,String name);

    /**
     * 将获取的MDM数据进行储存
     * @param
     * @return 返回分发json
     */
    JSONArray saveMdmUnitData(JSONArray recordArray,String name);

    /**
     * 获取需要分发的异构系统

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

@@ -29,7 +29,7 @@

    @Override
    @Transactional
    public JSONArray saveMdmData(JSONArray recordArray) {
    public JSONArray saveMdmData(JSONArray recordArray,String name) {
        JSONArray newJsonArray = new JSONArray();
        int size = recordArray.size();
        Object[] params = new  Object[]{};
@@ -43,7 +43,7 @@
                String updatedat = jsonObj.getString("updatedat");
                String updatetime = jsonObj.getString("updatetime");
                mdmData = new MdmData();
                mdmData.setType("局域物料名称编码数据获取");
                mdmData.setType(name);
                mdmData.setId(id);
                mdmData.setTgcoriginalCode(tgcoriginalcode);
                mdmData.setUpdatedat(updatedat);
@@ -76,6 +76,54 @@
    }

    @Override
    @Transactional
    public JSONArray saveMdmUnitData(JSONArray recordArray, String name) {
        JSONArray newJsonArray = new JSONArray();
        int size = recordArray.size();
        Object[] params = new  Object[]{};
        MdmData mdmData = null;
        if(size != 0){
            for (int i = 0; i < size; i++) {
                String json = recordArray.get(i).toString();
                JSONObject jsonObj = JSON.parseObject(json);
                String id = jsonObj.getString("code");
                String tgcoriginalcode = jsonObj.getString("originalcode");
                //String updatedat = jsonObj.getString("updatedat");
                String updatetime = jsonObj.getString("updatetime");
                mdmData = new MdmData();
                mdmData.setType(name);
                mdmData.setId(id);
                mdmData.setTgcoriginalCode(tgcoriginalcode);
                mdmData.setUpdatedat("");
                mdmData.setUpdatetime(updatetime);
                String countSql = "SELECT mdm.uuid,mdm.id,mdm.tgcoriginalCode,mdm.updatedat,mdm.updatetime FROM mdm_data AS mdm where mdm.tgcoriginalCode='"+tgcoriginalcode+"' ";
                List<MdmData> list = dynamicQuery.nativeQueryList(MdmData.class,countSql,params);
                if(list.size()>0){
                    //说明存在数据
                    for (MdmData mdm : list) {
                        String updatetime1 = mdm.getUpdatetime();
                        if(updatetime1.equals(updatetime)){
                            //数据无变化
                            continue;
                        }
                        jsonObj.put("renewstatus","update");
                        newJsonArray.add(jsonObj);
                        //数据存在变化
                        dynamicQuery.update(mdm);//更新数据
                    }
                }else {
                    jsonObj.put("renewstatus","new");
                    newJsonArray.add(jsonObj);
                    //说明该数据为新数据
                    mdmData.setUuid(UUID.randomUUID().toString());
                    dynamicQuery.save(mdmData);
                }
            }
        }
        return newJsonArray;
    }

    @Override
    public List<SysConfigEntity> querySysConfigs(String interfaceName) {
        Object[] params = new  Object[]{interfaceName};
        String countSql = "select id,ADDRESS as address,DESCRIPTION as description,cronExpression,isEnable,sysName,association from sys_config where isEnable='启用' and association=?";

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

@@ -53,7 +53,7 @@
                records = jsonObj.getString("records");
                JSONArray recordArray = JSON.parseArray(records);//物料数据信息
                //将数据保存至数据库
                JSONArray newJson = mdmService.saveMdmData(recordArray);
                JSONArray newJson = mdmService.saveMdmData(recordArray,"局域物料名称编码数据获取");
                if(newJson.size()!=0){
                    //定义返回json格式
                    returnJson.append("{\n" +
@@ -98,10 +98,10 @@
                String records = httpClientResult.getContent();
                records = records.replaceAll("\\p{Z}", "");
                JSONObject jsonObj = JSON.parseObject(records);
                records = jsonObj.getString("records");
                records = jsonObj.getString("data");
                JSONArray recordArray = JSON.parseArray(records);//物料数据信息
                //将数据保存至数据库
                JSONArray newJson = mdmService.saveMdmData(recordArray);
                JSONArray newJson = mdmService.saveMdmUnitData(recordArray,"计量单位业务基础数据编码获取");
                if(newJson.size()!=0){
                    //定义返回json格式
                    returnJson.append("{\n" +