| | |
| | | import com.hbbh.adapter.manager.DataSource; |
| | | import com.hbbh.adapter.pojo.Point; |
| | | import com.hbbh.adapter.pojo.golden.*; |
| | | import com.hbbh.adapter.utils.EmptyUtils; |
| | | import com.hbbh.adapter.utils.SearchConditionUtil; |
| | | import com.rtdb.enums.DataSort; |
| | | import com.rtdb.model.Entity; |
| | |
| | | |
| | | |
| | | public void insert(String flag, List<Point> point) { |
| | | log.info("golden 中 表 ----> {} 正在构建数据..."); |
| | | if (EmptyUtils.isEmpty(flag)) { |
| | | log.info("golden 中 未获取到表信息 -->{}", flag); |
| | | return; |
| | | } |
| | | if (point.size()==0) { |
| | | log.info("golden 中 表 ----> {} 没有数据", flag); |
| | | return; |
| | | } |
| | | |
| | | log.info("golden 中 表 ----> {} 正在构建数据...",flag); |
| | | TableEnum byType = TableEnum.getByType(flag); |
| | | |
| | | //TODO:部分表未介入 |
| | | if (EmptyUtils.isEmpty(byType)){ |
| | | log.info("golden 中 表 ----> {} 暂未介入adapter程序中", flag); |
| | | return; |
| | | } |
| | | |
| | | |
| | | |
| | | switch (byType) { |
| | | case SMS: |
| | |
| | | ktnz2CPlcDao.saveAndFlush(data); |
| | | }); |
| | | break; |
| | | default: |
| | | //TODO:剩下表构建 |
| | | } |
| | | log.info("golden 中 表 ----> {} 构建数据成功",flag); |
| | | |
| | | } |
| | | } |