Skip to content

I
ibzdst
提交 4ba88071 编写于 作者: ibizdev's avatar ibizdev
浏览文件
操作

ibiz4j 发布系统代码 [ibz-dst，应用]

上级 064f97e0
隐藏空白字符变更
内嵌 并排
正在显示 包含 185 行增加 和 170 行删除
ibzdst-core/src/main/java/cn/ibizlab/core/analysis/service/impl/DABuildServiceImpl.java
浏览文件 @ 4ba88071
......@@ -54,9 +54,6 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaModelService metamodelService;
@Autowired
@Lazy
IDABuildService proxyService;
protected int batchSize = 500;
......@@ -183,7 +180,7 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -201,10 +198,10 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -223,10 +220,10 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -240,6 +237,9 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
this.remove(new QueryWrapper<DABuild>().eq("modelid",id));
}
public IDABuildService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByModelId(String id,List<DABuild> list) {
if(list==null)
......@@ -262,11 +262,11 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......@@ -330,6 +330,7 @@ public class DABuildServiceImpl extends ServiceImpl<DABuildMapper, DABuild> impl
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/analysis/service/impl/DAChartServiceImpl.java
浏览文件 @ 4ba88071
......@@ -48,9 +48,6 @@ import org.springframework.util.StringUtils;
@Service("DAChartServiceImpl")
public class DAChartServiceImpl extends ServiceImpl<DAChartMapper, DAChart> implements IDAChartService {
@Autowired
@Lazy
IDAChartService proxyService;
protected int batchSize = 500;
......@@ -136,7 +133,7 @@ public class DAChartServiceImpl extends ServiceImpl<DAChartMapper, DAChart> impl
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -153,10 +150,10 @@ public class DAChartServiceImpl extends ServiceImpl<DAChartMapper, DAChart> impl
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -174,10 +171,10 @@ public class DAChartServiceImpl extends ServiceImpl<DAChartMapper, DAChart> impl
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -226,6 +223,10 @@ public class DAChartServiceImpl extends ServiceImpl<DAChartMapper, DAChart> impl
public IDAChartService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/analysis/service/impl/DADimensionServiceImpl.java
浏览文件 @ 4ba88071
......@@ -111,9 +111,9 @@ public class DADimensionServiceImpl implements IDADimensionService {
this.removeBatch(delIds);
}
@Autowired
@Lazy
IDADimensionService proxyService;
public IDADimensionService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByBuildid(String build_id,List<DADimension> list) {
if(list==null)
......@@ -136,11 +136,11 @@ public class DADimensionServiceImpl implements IDADimensionService {
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/analysis/service/impl/DAMetricServiceImpl.java
浏览文件 @ 4ba88071
......@@ -51,9 +51,6 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
@Autowired
@Lazy
protected cn.ibizlab.core.analysis.service.IDABuildService dabuildService;
@Autowired
@Lazy
IDAMetricService proxyService;
protected int batchSize = 500;
......@@ -144,7 +141,7 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -162,10 +159,10 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -184,10 +181,10 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -217,6 +214,9 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
this.remove(new QueryWrapper<DAMetric>().eq("buildid",build_id));
}
public IDAMetricService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByBuildId(String build_id,List<DAMetric> list) {
if(list==null)
......@@ -239,11 +239,11 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......@@ -308,6 +308,7 @@ public class DAMetricServiceImpl extends ServiceImpl<DAMetricMapper, DAMetric> i
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/analysis/service/impl/DAReportServiceImpl.java
浏览文件 @ 4ba88071
......@@ -48,9 +48,6 @@ import org.springframework.util.StringUtils;
@Service("DAReportServiceImpl")
public class DAReportServiceImpl extends ServiceImpl<DAReportMapper, DAReport> implements IDAReportService {
@Autowired
@Lazy
IDAReportService proxyService;
protected int batchSize = 500;
......@@ -136,7 +133,7 @@ public class DAReportServiceImpl extends ServiceImpl<DAReportMapper, DAReport> i
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -153,10 +150,10 @@ public class DAReportServiceImpl extends ServiceImpl<DAReportMapper, DAReport> i
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -174,10 +171,10 @@ public class DAReportServiceImpl extends ServiceImpl<DAReportMapper, DAReport> i
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -226,6 +223,10 @@ public class DAReportServiceImpl extends ServiceImpl<DAReportMapper, DAReport> i
public IDAReportService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/DstDataSourceServiceImpl.java
浏览文件 @ 4ba88071
......@@ -51,9 +51,6 @@ public class DstDataSourceServiceImpl extends ServiceImpl<DstDataSourceMapper, D
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaEntityService metaentityService;
@Autowired
@Lazy
IDstDataSourceService proxyService;
protected int batchSize = 500;
......@@ -155,7 +152,7 @@ public class DstDataSourceServiceImpl extends ServiceImpl<DstDataSourceMapper, D
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -172,10 +169,10 @@ public class DstDataSourceServiceImpl extends ServiceImpl<DstDataSourceMapper, D
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -193,10 +190,10 @@ public class DstDataSourceServiceImpl extends ServiceImpl<DstDataSourceMapper, D
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -245,6 +242,10 @@ public class DstDataSourceServiceImpl extends ServiceImpl<DstDataSourceMapper, D
public IDstDataSourceService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/DstSystemServiceImpl.java
浏览文件 @ 4ba88071
......@@ -57,9 +57,6 @@ public class DstSystemServiceImpl extends ServiceImpl<DstSystemMapper, DstSystem
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaModuleService metamoduleService;
@Autowired
@Lazy
IDstSystemService proxyService;
protected int batchSize = 500;
......@@ -145,7 +142,7 @@ public class DstSystemServiceImpl extends ServiceImpl<DstSystemMapper, DstSystem
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -162,10 +159,10 @@ public class DstSystemServiceImpl extends ServiceImpl<DstSystemMapper, DstSystem
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -183,10 +180,10 @@ public class DstSystemServiceImpl extends ServiceImpl<DstSystemMapper, DstSystem
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -251,6 +248,10 @@ public class DstSystemServiceImpl extends ServiceImpl<DstSystemMapper, DstSystem
public IDstSystemService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaDataSetServiceImpl.java
浏览文件 @ 4ba88071
......@@ -51,9 +51,6 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaEntityService metaentityService;
@Autowired
@Lazy
IMetaDataSetService proxyService;
protected int batchSize = 500;
......@@ -144,7 +141,7 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -162,10 +159,10 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -184,10 +181,10 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -201,6 +198,9 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
this.remove(new QueryWrapper<MetaDataSet>().eq("entityid",entity_id));
}
public IMetaDataSetService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByEntityId(String entity_id,List<MetaDataSet> list) {
if(list==null)
......@@ -223,11 +223,11 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......@@ -290,6 +290,7 @@ public class MetaDataSetServiceImpl extends ServiceImpl<MetaDataSetMapper, MetaD
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaEntityServiceImpl.java
浏览文件 @ 4ba88071
......@@ -66,9 +66,6 @@ public class MetaEntityServiceImpl extends ServiceImpl<MetaEntityMapper, MetaEnt
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaModuleService metamoduleService;
@Autowired
@Lazy
IMetaEntityService proxyService;
protected int batchSize = 500;
......@@ -191,7 +188,7 @@ public class MetaEntityServiceImpl extends ServiceImpl<MetaEntityMapper, MetaEnt
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -209,10 +206,10 @@ public class MetaEntityServiceImpl extends ServiceImpl<MetaEntityMapper, MetaEnt
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -231,10 +228,10 @@ public class MetaEntityServiceImpl extends ServiceImpl<MetaEntityMapper, MetaEnt
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -346,6 +343,10 @@ public class MetaEntityServiceImpl extends ServiceImpl<MetaEntityMapper, MetaEnt
public IMetaEntityService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaFieldServiceImpl.java
浏览文件 @ 4ba88071
......@@ -56,9 +56,6 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaRelationshipService metarelationshipService;
@Autowired
@Lazy
IMetaFieldService proxyService;
protected int batchSize = 500;
......@@ -149,7 +146,7 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -167,10 +164,10 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -189,10 +186,10 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -206,6 +203,9 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
this.remove(new QueryWrapper<MetaField>().eq("entityid",entity_id));
}
public IMetaFieldService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByEntityId(String entity_id,List<MetaField> list) {
if(list==null)
......@@ -228,11 +228,11 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
@Override
......@@ -337,6 +337,7 @@ public class MetaFieldServiceImpl extends ServiceImpl<MetaFieldMapper, MetaField
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaLookupServiceImpl.java
浏览文件 @ 4ba88071
......@@ -111,9 +111,9 @@ public class MetaLookupServiceImpl implements IMetaLookupService {
this.removeBatch(delIds);
}
@Autowired
@Lazy
IMetaLookupService proxyService;
public IMetaLookupService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByRelationid(String id,List<MetaLookup> list) {
if(list==null)
......@@ -136,11 +136,11 @@ public class MetaLookupServiceImpl implements IMetaLookupService {
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaModelServiceImpl.java
浏览文件 @ 4ba88071
......@@ -60,9 +60,6 @@ public class MetaModelServiceImpl extends ServiceImpl<MetaModelMapper, MetaModel
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IDstSystemService dstsystemService;
@Autowired
@Lazy
IMetaModelService proxyService;
protected int batchSize = 500;
......@@ -204,7 +201,7 @@ public class MetaModelServiceImpl extends ServiceImpl<MetaModelMapper, MetaModel
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -221,10 +218,10 @@ public class MetaModelServiceImpl extends ServiceImpl<MetaModelMapper, MetaModel
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -242,10 +239,10 @@ public class MetaModelServiceImpl extends ServiceImpl<MetaModelMapper, MetaModel
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -303,6 +300,10 @@ public class MetaModelServiceImpl extends ServiceImpl<MetaModelMapper, MetaModel
public IMetaModelService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaModuleServiceImpl.java
浏览文件 @ 4ba88071
......@@ -54,9 +54,6 @@ public class MetaModuleServiceImpl extends ServiceImpl<MetaModuleMapper, MetaMod
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IDstSystemService dstsystemService;
@Autowired
@Lazy
IMetaModuleService proxyService;
protected int batchSize = 500;
......@@ -142,7 +139,7 @@ public class MetaModuleServiceImpl extends ServiceImpl<MetaModuleMapper, MetaMod
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -159,10 +156,10 @@ public class MetaModuleServiceImpl extends ServiceImpl<MetaModuleMapper, MetaMod
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -180,10 +177,10 @@ public class MetaModuleServiceImpl extends ServiceImpl<MetaModuleMapper, MetaMod
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -241,6 +238,10 @@ public class MetaModuleServiceImpl extends ServiceImpl<MetaModuleMapper, MetaMod
public IMetaModuleService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/lite/service/impl/MetaRelationshipServiceImpl.java
浏览文件 @ 4ba88071
......@@ -54,9 +54,6 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaEntityService metaentityService;
@Autowired
@Lazy
IMetaRelationshipService proxyService;
protected int batchSize = 500;
......@@ -147,7 +144,7 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -165,10 +162,10 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -187,10 +184,10 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -204,6 +201,9 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
this.remove(new QueryWrapper<MetaRelationship>().eq("entityid",entity_id));
}
public IMetaRelationshipService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByEntityId(String entity_id,List<MetaRelationship> list) {
if(list==null)
......@@ -226,11 +226,11 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
@Override
......@@ -264,11 +264,11 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......@@ -342,6 +342,7 @@ public class MetaRelationshipServiceImpl extends ServiceImpl<MetaRelationshipMap
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/rule/service/impl/ExecLogServiceImpl.java
浏览文件 @ 4ba88071
......@@ -48,9 +48,6 @@ import org.springframework.util.StringUtils;
@Service("ExecLogServiceImpl")
public class ExecLogServiceImpl extends ServiceImpl<ExecLogMapper, ExecLog> implements IExecLogService {
@Autowired
@Lazy
IExecLogService proxyService;
protected int batchSize = 500;
......@@ -136,7 +133,7 @@ public class ExecLogServiceImpl extends ServiceImpl<ExecLogMapper, ExecLog> impl
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -153,10 +150,10 @@ public class ExecLogServiceImpl extends ServiceImpl<ExecLogMapper, ExecLog> impl
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -174,10 +171,10 @@ public class ExecLogServiceImpl extends ServiceImpl<ExecLogMapper, ExecLog> impl
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -226,6 +223,10 @@ public class ExecLogServiceImpl extends ServiceImpl<ExecLogMapper, ExecLog> impl
public IExecLogService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/rule/service/impl/ExecResultServiceImpl.java
浏览文件 @ 4ba88071
......@@ -51,9 +51,6 @@ public class ExecResultServiceImpl extends ServiceImpl<ExecResultMapper, ExecRes
@Autowired
@Lazy
protected cn.ibizlab.core.rule.service.IRuleItemService ruleitemService;
@Autowired
@Lazy
IExecResultService proxyService;
protected int batchSize = 500;
......@@ -160,7 +157,7 @@ public class ExecResultServiceImpl extends ServiceImpl<ExecResultMapper, ExecRes
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -178,10 +175,10 @@ public class ExecResultServiceImpl extends ServiceImpl<ExecResultMapper, ExecRes
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -200,10 +197,10 @@ public class ExecResultServiceImpl extends ServiceImpl<ExecResultMapper, ExecRes
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -294,6 +291,10 @@ public class ExecResultServiceImpl extends ServiceImpl<ExecResultMapper, ExecRes
public IExecResultService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
}
......
ibzdst-core/src/main/java/cn/ibizlab/core/rule/service/impl/RuleItemServiceImpl.java
浏览文件 @ 4ba88071
......@@ -54,9 +54,6 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
@Autowired
@Lazy
protected cn.ibizlab.core.lite.service.IMetaModelService metamodelService;
@Autowired
@Lazy
IRuleItemService proxyService;
protected int batchSize = 500;
......@@ -179,7 +176,7 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
if (null == et) {
return false;
} else {
return checkKey(et) ? proxyService.update(et) : proxyService.create(et);
return checkKey(et) ? getProxyService().update(et) : getProxyService().create(et);
}
}
......@@ -197,10 +194,10 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
return true;
}
......@@ -219,10 +216,10 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
}
}
if (create.size() > 0) {
proxyService.createBatch(create);
getProxyService().createBatch(create);
}
if (update.size() > 0) {
proxyService.updateBatch(update);
getProxyService().updateBatch(update);
}
}
......@@ -236,6 +233,9 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
this.remove(new QueryWrapper<RuleItem>().eq("modelid",id));
}
public IRuleItemService getProxyService() {
return cn.ibizlab.util.security.SpringContextHolder.getBean(this.getClass());
}
@Override
public void saveByModelId(String id,List<RuleItem> list) {
if(list==null)
......@@ -258,11 +258,11 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
_create.add(sub);
}
if(_update.size()>0)
proxyService.updateBatch(_update);
getProxyService().updateBatch(_update);
if(_create.size()>0)
proxyService.createBatch(_create);
getProxyService().createBatch(_create);
if(delIds.size()>0)
proxyService.removeBatch(delIds);
getProxyService().removeBatch(delIds);
}
......@@ -326,6 +326,7 @@ public class RuleItemServiceImpl extends ServiceImpl<RuleItemMapper, RuleItem> i
}
......
ibzdst-core/src/main/resources/liquibase/h2_table.xml
浏览文件 @ 4ba88071
......@@ -4,7 +4,7 @@
<!--输出实体[DA_BUILD]数据结构 -->
<changeSet author="root" id="tab-da_build-71-1">
<changeSet author="a_A_5d9d78509" id="tab-da_build-71-1">
<createTable tableName="IBZDABUILD">
<column name="BUILDID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_DA_BUILD_BUILDID"/>
......@@ -32,7 +32,7 @@
<!--输出实体[DA_CHART]数据结构 -->
<changeSet author="root" id="tab-da_chart-22-2">
<changeSet author="a_A_5d9d78509" id="tab-da_chart-22-2">
<createTable tableName="IBZDACHART">
<column name="CHARTID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_DA_CHART_CHARTID"/>
......@@ -54,7 +54,7 @@
<!--输出实体[DA_METRIC]数据结构 -->
<changeSet author="root" id="tab-da_metric-63-3">
<changeSet author="a_A_5d9d78509" id="tab-da_metric-63-3">
<createTable tableName="IBZDAMETRIC">
<column name="DA_METRICID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_DA_METRIC_DA_METRICID"/>
......@@ -82,7 +82,7 @@
<!--输出实体[DA_REPORT]数据结构 -->
<changeSet author="root" id="tab-da_report-24-4">
<changeSet author="a_A_5d9d78509" id="tab-da_report-24-4">
<createTable tableName="IBZDAREPORT">
<column name="REPORTID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_DA_REPORT_REPORTID"/>
......@@ -104,7 +104,7 @@
<!--输出实体[DST_DATASOURCE]数据结构 -->
<changeSet author="root" id="tab-dst_datasource-6-5">
<changeSet author="a_A_5d9d78509" id="tab-dst_datasource-6-5">
<createTable tableName="IBZDATASOURCE">
<column name="DSID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_DST_DATASOURCE_DSID"/>
......@@ -120,7 +120,7 @@
<!--输出实体[DST_SYSTEM]数据结构 -->
<changeSet author="root" id="tab-dst_system-5-6">
<changeSet author="a_A_5d9d78509" id="tab-dst_system-5-6">
<createTable tableName="IBZPSSYSTEM">
<column name="PSSYSTEMID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_DST_SYSTEM_PSSYSTEMID"/>
......@@ -140,7 +140,7 @@
<!--输出实体[RU_EXECLOG]数据结构 -->
<changeSet author="root" id="tab-ru_execlog-31-7">
<changeSet author="a_A_5d9d78509" id="tab-ru_execlog-31-7">
<createTable tableName="IBZRULELOG">
<column name="RU_EXECLOGID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_RU_EXECLOG_RU_EXECLOGID"/>
......@@ -170,7 +170,7 @@
<!--输出实体[RU_EXECRESULT]数据结构 -->
<changeSet author="root" id="tab-ru_execresult-46-8">
<changeSet author="a_A_5d9d78509" id="tab-ru_execresult-46-8">
<createTable tableName="IBZRULERESULT">
<column name="RU_EXECRESULTID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_RU_EXECRESULT_RU_EXECRESULT"/>
......@@ -210,7 +210,7 @@
<!--输出实体[META_DATASET]数据结构 -->
<changeSet author="root" id="tab-meta_dataset-2-9">
<changeSet author="a_A_5d9d78509" id="tab-meta_dataset-2-9">
<createTable tableName="IBZDATASET">
<column name="DATASETID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_META_DATASET_DATASETID"/>
......@@ -232,7 +232,7 @@
<!--输出实体[META_ENTITY]数据结构 -->
<changeSet author="root" id="tab-meta_entity-13-10">
<changeSet author="a_A_5d9d78509" id="tab-meta_entity-13-10">
<createTable tableName="IBZENTITY">
<column name="ENTITYID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_META_ENTITY_ENTITYID"/>
......@@ -264,7 +264,7 @@
<!--输出实体[META_FIELD]数据结构 -->
<changeSet author="root" id="tab-meta_field-7-11">
<changeSet author="a_A_5d9d78509" id="tab-meta_field-7-11">
<createTable tableName="IBZFIELD">
<column name="FIELDID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_META_FIELD_FIELDID"/>
......@@ -328,7 +328,7 @@
<!--输出实体[META_MODEL]数据结构 -->
<changeSet author="root" id="tab-meta_model-64-12">
<changeSet author="a_A_5d9d78509" id="tab-meta_model-64-12">
<createTable tableName="IBZMODEL">
<column name="MODELID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_META_MODEL_MODELID"/>
......@@ -354,7 +354,7 @@
<!--输出实体[META_MODULE]数据结构 -->
<changeSet author="root" id="tab-meta_module-7-13">
<changeSet author="a_A_5d9d78509" id="tab-meta_module-7-13">
<createTable tableName="IBZMODULE">
<column name="MODULEID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_META_MODULE_MODULEID"/>
......@@ -372,7 +372,7 @@
<!--输出实体[META_RELATION]数据结构 -->
<changeSet author="root" id="tab-meta_relation-6-14">
<changeSet author="a_A_5d9d78509" id="tab-meta_relation-6-14">
<createTable tableName="IBZRELATION">
<column name="RELATIONID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_META_RELATION_RELATIONID"/>
......@@ -404,7 +404,7 @@
<!--输出实体[RU_ENGINE]数据结构 -->
<changeSet author="root" id="tab-ru_engine-45-15">
<changeSet author="a_A_5d9d78509" id="tab-ru_engine-45-15">
<createTable tableName="IBZRULEENGINE">
<column name="ENGINEID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_RU_ENGINE_ENGINEID"/>
......@@ -432,7 +432,7 @@
<!--输出实体[RU_ITEM]数据结构 -->
<changeSet author="root" id="tab-ru_item-79-16">
<changeSet author="a_A_5d9d78509" id="tab-ru_item-79-16">
<createTable tableName="IBZRULE">
<column name="RULEID" remarks="" type="VARCHAR(100)">
<constraints primaryKey="true" primaryKeyName="PK_RU_ITEM_RULEID"/>
......@@ -469,7 +469,7 @@
<!--输出实体[DA_BUILD]外键关系 -->
<!--输出实体[DA_CHART]外键关系 -->
<!--输出实体[DA_METRIC]外键关系 -->
<changeSet author="root" id="fk-da_metric-63-17">
<changeSet author="a_A_5d9d78509" id="fk-da_metric-63-17">
<addForeignKeyConstraint baseColumnNames="BUILDID" baseTableName="IBZDAMETRIC" constraintName="DER1N_DA_METRIC_DA_BUILD_BUILD" deferrable="false" initiallyDeferred="false" onDelete="RESTRICT" onUpdate="RESTRICT" referencedColumnNames="BUILDID" referencedTableName="IBZDABUILD" validate="true"/>
</changeSet>
<!--输出实体[DA_REPORT]外键关系 -->
......
Markdown 格式
0% or
您添加了 0 人 到此讨论。请谨慎行事。
先完成此消息的编辑！
想要评论请 注册 或