批量插入

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java

@@ -14,5 +14,5 @@

    List<CokingAnalyIndEntity> list(Map<String, Object> params);

    void save(CokingAnalyIndEntity analyIndEntity);
    void save(List<CokingAnalyIndEntity> entityList);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceDeviationService.java

@@ -15,5 +15,5 @@
public interface CokingTraceDeviationService {
    List<CokingTraceDeviationEntity> list(Map<String, Object> params);

    void save(CokingTraceDeviationEntity deviationEntity);
    void save(List<CokingTraceDeviationEntity> entityList);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java

@@ -14,5 +14,5 @@

    List<CokingTraceIndEntity> list(Map<String, Object> params);

    void save(CokingTraceIndEntity cokingTraceIndEntity);
    void save(List<CokingTraceIndEntity> entityList);
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java

@@ -31,7 +31,7 @@
    }

    @Override
    public void save(CokingAnalyIndEntity analyIndEntity) {
        cokingAnalyIndDao.insert(analyIndEntity);
    public void save(List<CokingAnalyIndEntity> entityList) {
        cokingAnalyIndDao.insert(entityList);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceDeviationServiceImpl.java

@@ -35,7 +35,7 @@
    }

    @Override
    public void save(CokingTraceDeviationEntity deviationEntity) {
        cokingTraceDeviationDao.insert(deviationEntity);
    public void save(List<CokingTraceDeviationEntity> entityList) {
        cokingTraceDeviationDao.insert(entityList);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java

@@ -31,7 +31,7 @@
    }

    @Override
    public void save(CokingTraceIndEntity cokingTraceIndEntity) {
        cokingTraceIndDao.insert(cokingTraceIndEntity);
    public void save(List<CokingTraceIndEntity> entityList) {
        cokingTraceIndDao.insert(entityList);
    }
}

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java

@@ -182,6 +182,7 @@
            String steamFirstColoum = result.get("steamFirstColoum"+i).toString();
            if(StringUtils.isNotBlank(steamFirstColoum)){
                JSONArray responseArr = JSON.parseArray(steamFirstColoum);
                List<CokingTraceDeviationEntity> entityList = new ArrayList<>();
                for (int j = 0; j < responseArr.size(); j++) {
                    JSONArray element = JSON.parseArray(responseArr.get(j).toString());
                    CokingTraceDeviationEntity deviationEntity = new CokingTraceDeviationEntity();
@@ -193,7 +194,8 @@
                    deviationEntity.setIndName(steamIndexMaps.get(element.get(0).toString()));
                    deviationEntity.setIndValue(element.get(1).toString());
                    deviationEntity.setCreateDate(new Date());
                    cokingTraceDeviationService.save(deviationEntity);
                    entityList.add(deviationEntity);
                    cokingTraceDeviationService.save(entityList);
                }
            }
        }
@@ -201,7 +203,7 @@
            String steamSecondColoum = result.get("steamSecondColoum"+i).toString();
            if(StringUtils.isNotBlank(steamSecondColoum)){
                JSONArray responseArr = JSON.parseArray(steamSecondColoum);

                List<CokingTraceDeviationEntity> entityList = new ArrayList<>();
                for (int j = 0; j < responseArr.size(); j++) {
                    JSONArray element = JSON.parseArray(responseArr.get(j).toString());
                    CokingTraceDeviationEntity deviationEntity = new CokingTraceDeviationEntity();
@@ -213,7 +215,8 @@
                    deviationEntity.setIndName(steamIndexMaps.get(element.get(0).toString()));
                    deviationEntity.setIndValue(element.get(1).toString());
                    deviationEntity.setCreateDate(new Date());
                    cokingTraceDeviationService.save(deviationEntity);
                    entityList.add(deviationEntity);
                    cokingTraceDeviationService.save(entityList);
                }
            }
        }
@@ -222,6 +225,7 @@

    public void saveAnalyInd(Map<String, Object> tMap,JSONObject result) {
        String[] analyContent = tMap.get("analyContent").toString().split(";");
        List<CokingAnalyIndEntity> entityList = new ArrayList<>();
        for(int i=0;i<analyContent.length;i++){
            CokingAnalyIndEntity analyIndEntity = new CokingAnalyIndEntity();
            analyIndEntity.setRelId(tMap.get("relId").toString());
@@ -230,7 +234,8 @@
            analyIndEntity.setAnalyClass(tMap.get("analyClass").toString());
            analyIndEntity.setAnalyContent(analyContent[i]);
            analyIndEntity.setSort(i+1);
            cokingAnalyIndService.save(analyIndEntity);
            entityList.add(analyIndEntity);
            cokingAnalyIndService.save(entityList);
        }
    }

@@ -242,6 +247,7 @@
            logger.info("ConfLis is Empty");
            return;
        }
        List<CokingTraceIndEntity> entityList = new ArrayList<>();
        for (CokingTraceConfEntity conf : list) {
            if (StringUtils.isBlank(conf.getDataType())) {
                logger.info("DataType is Empty");
@@ -277,7 +283,8 @@
            cokingTraceIndEntity.setIndName(conf.getIndName());
            cokingTraceIndEntity.setIndValue(value);
            cokingTraceIndEntity.setIndUnit(conf.getIndUnit());
            cokingTraceIndService.save(cokingTraceIndEntity);
            entityList.add(cokingTraceIndEntity);
            cokingTraceIndService.save(entityList);

        }
    }