| | |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | map4.put("entity", resultJson); |
| | | mmItemResultDao.savePredictJsonValue(map4); |
| | | |
| | | Map<String, Object> params = new HashMap(4); |
| | | params.put("TABLENAME", T_MM_ITEM_RESULT); |
| | | params.put("OUTPUTID", entry.getKey()); |
| | | params.put("STARTTIME", importList.get(0).getDatatime()); |
| | | params.put("ENDTIME", importList.get(importList.size() - 1).getDatatime()); |
| | | mmItemResultDao.deletePredictValue(params); |
| | | // Map<String, Object> params = new HashMap(4); |
| | | // params.put("TABLENAME", T_MM_ITEM_RESULT); |
| | | // params.put("OUTPUTID", entry.getKey()); |
| | | // params.put("STARTTIME", importList.get(0).getDatatime()); |
| | | // params.put("ENDTIME", importList.get(importList.size() - 1).getDatatime()); |
| | | // mmItemResultDao.deletePredictValue(params); |
| | | } |
| | | mmItemResultDao.insertBatch(importList,max_group_count); |
| | | // 存在则修改,不存在插入 |
| | | mmItemResultDao.saveOrUpdateItemResult(importList); |
| | | |
| | | Map<String, Object> map3 = new HashMap<>(2); |
| | | map3.put("TABLENAME", "T_MM_ITEM_RESULT_LAST_POINT"); |