|
@@ -9,6 +9,7 @@ import com.bowintek.practice.services.service.TempService;
|
|
import com.bowintek.practice.services.service.UserService;
|
|
import com.bowintek.practice.services.service.UserService;
|
|
import com.bowintek.practice.util.DateUtils;
|
|
import com.bowintek.practice.util.DateUtils;
|
|
import com.bowintek.practice.vo.temp.TempObjectModel;
|
|
import com.bowintek.practice.vo.temp.TempObjectModel;
|
|
|
|
+import com.bowintek.practice.vo.temp.TempSaveResult;
|
|
import com.bowintek.practice.vo.user.DataRange;
|
|
import com.bowintek.practice.vo.user.DataRange;
|
|
import com.bowintek.practice.vo.user.UserInfoModel;
|
|
import com.bowintek.practice.vo.user.UserInfoModel;
|
|
import com.github.pagehelper.PageHelper;
|
|
import com.github.pagehelper.PageHelper;
|
|
@@ -27,47 +28,63 @@ public class TempServiceImpl implements TempService {
|
|
TempCQuery tempCQuery;
|
|
TempCQuery tempCQuery;
|
|
@Autowired
|
|
@Autowired
|
|
SrSaerchtempMapper srSaerchtempMapper;
|
|
SrSaerchtempMapper srSaerchtempMapper;
|
|
|
|
+ @Autowired
|
|
|
|
+ SrSubjectMapper srSubjectMapper;
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public TempObjectModel getTemp(String tempId){
|
|
|
|
+ TempObjectModel data = new TempObjectModel();
|
|
|
|
+ data.temp = srSaerchtempMapper.selectByPrimaryKey(tempId);
|
|
|
|
+ data.sub = srSubjectMapper.selectByPrimaryKey(data.temp.getSubId());
|
|
|
|
+ data.bases = tempCQuery.selectDimensionByTempId(Arrays.asList(data.temp.getTempId()));
|
|
|
|
+ data.wheres = tempCQuery.selectFieldByTempId(Arrays.asList(data.temp.getTempId()));
|
|
|
|
+ data.measures = tempCQuery.selectMeasureByTempId(Arrays.asList(data.temp.getTempId()));
|
|
|
|
+
|
|
|
|
+ return data;
|
|
|
|
+ }
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public int saveTemp(TempObjectModel data, String userID){
|
|
|
|
- int result = 0;
|
|
|
|
|
|
+ public TempSaveResult saveTemp(TempObjectModel data, String userID){
|
|
|
|
+ TempSaveResult rtn = new TempSaveResult();
|
|
//保存模板主表
|
|
//保存模板主表
|
|
if(data.temp.getTempId().isEmpty()){
|
|
if(data.temp.getTempId().isEmpty()){
|
|
|
|
+ rtn.tempId = UUID.randomUUID().toString();
|
|
data.temp.setTempId(UUID.randomUUID().toString());
|
|
data.temp.setTempId(UUID.randomUUID().toString());
|
|
data.temp.setCreateTime(new Date());
|
|
data.temp.setCreateTime(new Date());
|
|
data.temp.setCreatedBy(userID);
|
|
data.temp.setCreatedBy(userID);
|
|
data.temp.setStatus(0);
|
|
data.temp.setStatus(0);
|
|
- result += srSaerchtempMapper.insert(data.temp);
|
|
|
|
-
|
|
|
|
- data.bases.forEach(row->{
|
|
|
|
- row.setTempFeildId(UUID.randomUUID().toString());
|
|
|
|
- row.setTempId(data.temp.getTempId());
|
|
|
|
- });
|
|
|
|
- data.wheres.forEach(row->{
|
|
|
|
- row.setTempFeildId(UUID.randomUUID().toString());
|
|
|
|
- row.setTempId(data.temp.getTempId());
|
|
|
|
- });
|
|
|
|
- data.measures.forEach(row->{
|
|
|
|
- row.setTempFeildId(UUID.randomUUID().toString());
|
|
|
|
- row.setTempId(data.temp.getTempId());
|
|
|
|
- });
|
|
|
|
|
|
+ rtn.effectCount += srSaerchtempMapper.insert(data.temp);
|
|
}
|
|
}
|
|
else{
|
|
else{
|
|
|
|
+ rtn.tempId = data.temp.getTempId();
|
|
data.temp.setModifyTime(new Date());
|
|
data.temp.setModifyTime(new Date());
|
|
data.temp.setModifyBy(userID);
|
|
data.temp.setModifyBy(userID);
|
|
- result += srSaerchtempMapper.updateByPrimaryKey(data.temp);
|
|
|
|
|
|
+ rtn.effectCount += srSaerchtempMapper.updateByPrimaryKey(data.temp);
|
|
|
|
|
|
tempCQuery.deletesDimensionByTempId(Arrays.asList(data.temp.getTempId()));
|
|
tempCQuery.deletesDimensionByTempId(Arrays.asList(data.temp.getTempId()));
|
|
tempCQuery.deletesFieldByTempId(Arrays.asList(data.temp.getTempId()));
|
|
tempCQuery.deletesFieldByTempId(Arrays.asList(data.temp.getTempId()));
|
|
tempCQuery.deletesMeasureByTempId(Arrays.asList(data.temp.getTempId()));
|
|
tempCQuery.deletesMeasureByTempId(Arrays.asList(data.temp.getTempId()));
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ data.bases.forEach(row->{
|
|
|
|
+ row.setTempFeildId(UUID.randomUUID().toString());
|
|
|
|
+ row.setTempId(data.temp.getTempId());
|
|
|
|
+ });
|
|
|
|
+ data.wheres.forEach(row->{
|
|
|
|
+ row.setTempFeildId(UUID.randomUUID().toString());
|
|
|
|
+ row.setTempId(data.temp.getTempId());
|
|
|
|
+ });
|
|
|
|
+ data.measures.forEach(row->{
|
|
|
|
+ row.setTempFeildId(UUID.randomUUID().toString());
|
|
|
|
+ row.setTempId(data.temp.getTempId());
|
|
|
|
+ });
|
|
|
|
+
|
|
//保存模板 维度、度量、查询信息
|
|
//保存模板 维度、度量、查询信息
|
|
- result += tempCQuery.batchInsertDimension(data.bases);
|
|
|
|
- result += tempCQuery.batchInsertField(data.wheres);
|
|
|
|
- result += tempCQuery.batchInsertMeasure(data.measures);
|
|
|
|
|
|
+ rtn.effectCount += tempCQuery.batchInsertDimension(data.bases);
|
|
|
|
+ rtn.effectCount += tempCQuery.batchInsertField(data.wheres);
|
|
|
|
+ rtn.effectCount += tempCQuery.batchInsertMeasure(data.measures);
|
|
|
|
|
|
- return result;
|
|
|
|
|
|
+ return rtn;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|