package jnpf.onlinedev.service.impl;
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.baomidou.dynamic.datasource.annotation.DSTransactional;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import jnpf.base.ActionResult;
|
import jnpf.base.DataSourceApi;
|
import jnpf.base.ModuleApi;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.ModuleEntity;
|
import jnpf.base.entity.VisualdevEntity;
|
import jnpf.base.entity.VisualdevReleaseEntity;
|
import jnpf.base.mapper.FlowFormDataMapper;
|
import jnpf.base.model.*;
|
import jnpf.base.model.OnlineImport.VisualdevModelDataInfoVO;
|
import jnpf.base.model.flow.DataModel;
|
import jnpf.base.model.flow.FlowFormDataModel;
|
import jnpf.base.model.form.ModuleFormModel;
|
import jnpf.base.model.module.PropertyJsonModel;
|
import jnpf.base.service.SuperServiceImpl;
|
import jnpf.base.service.VisualdevReleaseService;
|
import jnpf.base.util.FlowFormDataUtil;
|
import jnpf.base.util.FormCheckUtils;
|
import jnpf.constant.MsgCode;
|
import jnpf.database.model.entity.DbLinkEntity;
|
import jnpf.database.model.superQuery.SuperJsonModel;
|
import jnpf.database.model.superQuery.SuperQueryJsonModel;
|
import jnpf.database.util.ConnUtil;
|
import jnpf.database.util.DynamicDataSourceUtil;
|
import jnpf.exception.WorkFlowException;
|
import jnpf.flowable.WorkFlowApi;
|
import jnpf.flowable.entity.TaskEntity;
|
import jnpf.model.OnlineDevData;
|
import jnpf.model.visualJson.FieLdsModel;
|
import jnpf.model.visualJson.FormCloumnUtil;
|
import jnpf.model.visualJson.FormDataModel;
|
import jnpf.model.visualJson.TableModel;
|
import jnpf.model.visualJson.analysis.FormAllModel;
|
import jnpf.model.visualJson.analysis.RecursionForm;
|
import jnpf.onlinedev.entity.VisualdevModelDataEntity;
|
import jnpf.onlinedev.mapper.VisualdevModelDataMapper;
|
import jnpf.onlinedev.model.OnlineDevListModel.VisualColumnSearchVO;
|
import jnpf.onlinedev.model.PaginationModel;
|
import jnpf.onlinedev.model.PaginationModelExport;
|
import jnpf.onlinedev.model.VisualParamModel;
|
import jnpf.onlinedev.model.log.VisualLogForm;
|
import jnpf.onlinedev.service.VisualDevInfoService;
|
import jnpf.onlinedev.service.VisualDevListService;
|
import jnpf.onlinedev.service.VisualLogService;
|
import jnpf.onlinedev.service.VisualdevModelDataService;
|
import jnpf.onlinedev.util.onlineDevUtil.OnlineProductSqlUtils;
|
import jnpf.onlinedev.util.onlineDevUtil.OnlinePublicUtils;
|
import jnpf.onlinedev.util.onlineDevUtil.OnlineSwapDataUtils;
|
import jnpf.permission.UserApi;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.permission.model.authorize.OnlineDynamicSqlModel;
|
import jnpf.permissions.PermissionInterfaceImpl;
|
import jnpf.util.*;
|
import jnpf.util.context.RequestContext;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
import lombok.Cleanup;
|
import org.mybatis.dynamic.sql.SqlBuilder;
|
import org.mybatis.dynamic.sql.SqlTable;
|
import org.mybatis.dynamic.sql.delete.DeleteDSL;
|
import org.mybatis.dynamic.sql.delete.DeleteModel;
|
import org.mybatis.dynamic.sql.render.RenderingStrategies;
|
import org.mybatis.dynamic.sql.select.QueryExpressionDSL;
|
import org.mybatis.dynamic.sql.select.SelectModel;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.sql.Connection;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author JNPF开发平台组
|
* @version V3.1.0
|
* @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com）
|
* @date 2021/3/16
|
*/
|
@Service
|
public class VisualdevModelDataServiceImpl extends SuperServiceImpl<VisualdevModelDataMapper, VisualdevModelDataEntity> implements VisualdevModelDataService {
|
|
|
@Autowired
|
private UserApi userApi;
|
@Autowired
|
private DataSourceApi dblinkService;
|
@Autowired
|
private VisualdevReleaseService visualdevReleaseService;
|
@Autowired
|
private VisualDevListService visualDevListService;
|
@Autowired
|
private OnlineSwapDataUtils onlineSwapDataUtils;
|
@Autowired
|
private FlowFormDataUtil flowFormDataUtil;
|
@Autowired
|
private FormCheckUtils formCheckUtils;
|
@Autowired
|
private WorkFlowApi workFlowApi;
|
@Autowired
|
private ModuleApi moduleService;
|
@Autowired
|
private VisualLogService visualLogService;
|
@Autowired
|
private VisualDevInfoService visualDevInfoService;
|
@Autowired
|
private FlowFormDataMapper flowFormDataMapper;
|
|
|
@Override
|
public List<VisualdevModelDataEntity> getList(String modelId) {
|
QueryWrapper<VisualdevModelDataEntity> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(VisualdevModelDataEntity::getVisualDevId, modelId);
|
return this.list(queryWrapper);
|
}
|
|
/**
|
* 表单字段
|
*
|
* @param id
|
* @param filterType 过滤类型，0或者不传为默认过滤子表和关联表单，1-弹窗配置需要过滤掉的类型
|
* @return
|
*/
|
@Override
|
public List<FormDataField> fieldList(String id, Integer filterType) {
|
VisualdevReleaseEntity entity = visualdevReleaseService.getById(id);
|
FormDataModel formData = JsonUtil.getJsonToBean(entity.getFormData(), FormDataModel.class);
|
|
List<FieLdsModel> fieLdsModelList = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class);
|
List<FieLdsModel> mainFieldModelList = new ArrayList<>();
|
|
OnlinePublicUtils.recursionFields(mainFieldModelList, fieLdsModelList);
|
//过滤掉无法传递的组件
|
List<String> notInList = new ArrayList<>();
|
notInList.add(JnpfKeyConsts.RELATIONFORM);
|
notInList.add(JnpfKeyConsts.CHILD_TABLE);
|
if (Objects.equals(filterType, 1)) {
|
notInList.add("link");
|
notInList.add("button");
|
notInList.add("JNPFText");
|
notInList.add("alert");
|
notInList.add(JnpfKeyConsts.POPUPSELECT);
|
notInList.add(JnpfKeyConsts.QR_CODE);
|
notInList.add(JnpfKeyConsts.BARCODE);
|
notInList.add(JnpfKeyConsts.CREATEUSER);
|
notInList.add(JnpfKeyConsts.CREATETIME);
|
notInList.add(JnpfKeyConsts.UPLOADIMG);
|
notInList.add(JnpfKeyConsts.UPLOADFZ);
|
notInList.add(JnpfKeyConsts.MODIFYUSER);
|
notInList.add(JnpfKeyConsts.MODIFYTIME);
|
|
notInList.add(JnpfKeyConsts.CURRORGANIZE);
|
notInList.add(JnpfKeyConsts.CURRPOSITION);
|
notInList.add(JnpfKeyConsts.IFRAME);
|
notInList.add(JnpfKeyConsts.RELATIONFORM_ATTR);
|
notInList.add(JnpfKeyConsts.POPUPSELECT_ATTR);
|
}
|
|
List<FormDataField> formDataFieldList = mainFieldModelList.stream().filter(fieLdsModel ->
|
!"".equals(fieLdsModel.getVModel())
|
&& StringUtil.isNotEmpty(fieLdsModel.getVModel())
|
&& !notInList.contains(fieLdsModel.getConfig().getJnpfKey())
|
).map(fieLdsModel -> {
|
FormDataField formDataField = new FormDataField();
|
formDataField.setLabel(fieLdsModel.getConfig().getLabel());
|
formDataField.setVModel(fieLdsModel.getVModel());
|
return formDataField;
|
}).collect(Collectors.toList());
|
|
return formDataFieldList;
|
}
|
|
@Override
|
public List<Map<String, Object>> getPageList(VisualdevEntity entity, PaginationModel paginationModel) {
|
// String json = null;
|
// if (StringUtil.isNotEmpty(paginationModel.getKeyword())) {
|
// Map<String, Object> map = new HashMap<>();
|
// map.put(paginationModel.getRelationField(), paginationModel.getKeyword());
|
// json = JsonUtil.getObjectToString(map);
|
// }
|
// paginationModel.setQueryJson(json);
|
VisualDevJsonModel visualJsonModel = OnlinePublicUtils.getVisualJsonModel(entity);
|
|
//判断请求客户端来源
|
if (!RequestContext.isOrignPc()) {
|
visualJsonModel.setColumnData(visualJsonModel.getAppColumnData());
|
}
|
List<Map<String, Object>> dataList = visualDevListService.getRelationFormList(visualJsonModel, paginationModel);
|
return dataList;
|
}
|
|
@Override
|
public List<Map<String, Object>> exportData(String[] keys, PaginationModelExport paginationModelExport, VisualDevJsonModel visualDevJsonModel) {
|
PaginationModel paginationModel = new PaginationModel();
|
BeanUtil.copyProperties(paginationModelExport, paginationModel);
|
List<String> keyList = Arrays.asList(keys);
|
List<Map<String, Object>> noSwapDataList;
|
ColumnDataModel columnDataModel = visualDevJsonModel.getColumnData();
|
List<VisualColumnSearchVO> searchVOList = new ArrayList<>();
|
List<TableModel> visualTables = visualDevJsonModel.getVisualTables();
|
TableModel mainTable = visualTables.stream().filter(vi -> vi.getTypeId().equals("1")).findFirst().orElse(null);
|
//解析控件
|
FormDataModel formDataModel = visualDevJsonModel.getFormData();
|
List<FieLdsModel> fieLdsModels = JsonUtil.getJsonToList(formDataModel.getFields(), FieLdsModel.class);
|
RecursionForm recursionForm = new RecursionForm(fieLdsModels, visualTables);
|
List<FormAllModel> formAllModel = new ArrayList<>();
|
FormCloumnUtil.recursionForm(recursionForm, formAllModel);
|
//封装查询条件
|
if (StringUtil.isNotEmpty(paginationModel.getQueryJson())) {
|
Map<String, Object> keyJsonMap = JsonUtil.stringToMap(paginationModel.getQueryJson());
|
searchVOList = JsonUtil.getJsonToList(columnDataModel.getSearchList(), VisualColumnSearchVO.class);
|
searchVOList = searchVOList.stream().map(searchVO -> {
|
searchVO.setValue(keyJsonMap.get(searchVO.getId()));
|
return searchVO;
|
}).filter(vo -> vo.getValue() != null && StringUtil.isNotEmpty(String.valueOf(vo.getValue()))).collect(Collectors.toList());
|
//左侧树查询
|
boolean b = false;
|
if (columnDataModel.getTreeRelation() != null) {
|
b = keyJsonMap.keySet().stream().anyMatch(t -> t.equalsIgnoreCase(String.valueOf(columnDataModel.getTreeRelation())));
|
}
|
if (b && keyJsonMap.size() > searchVOList.size()) {
|
String relation = String.valueOf(columnDataModel.getTreeRelation());
|
VisualColumnSearchVO vo = new VisualColumnSearchVO();
|
vo.setSearchType("1");
|
vo.setVModel(relation);
|
vo.setValue(keyJsonMap.get(relation));
|
searchVOList.add(vo);
|
}
|
}
|
//菜单id
|
String menuId = paginationModel.getMenuId();
|
//菜单判断是否启用流程-添加流程状态
|
ModuleEntity info = moduleService.getModuleByList(menuId);
|
if (info != null) {
|
//流程菜单
|
boolean enableFlow = Objects.equals(info.getType(), 9);
|
visualDevJsonModel.setEnableFlow(enableFlow);
|
if (enableFlow) {
|
PropertyJsonModel model = JsonUtil.getJsonToBean(info.getPropertyJson(), PropertyJsonModel.class);
|
List<String> flowVersionIds = workFlowApi.getFlowIdsByTemplateId(model.getModuleId());
|
visualDevJsonModel.setFlowId(model.getModuleId());
|
visualDevJsonModel.setFlowVersionIds(flowVersionIds);
|
}
|
}
|
|
if (visualDevJsonModel.getVisualTables().size() > 0) {
|
//当前用户信息
|
UserInfo userInfo = UserProvider.getUser();
|
//封装搜索数据
|
OnlineProductSqlUtils.queryList(formAllModel, visualDevJsonModel, paginationModel);
|
noSwapDataList = visualDevListService.getListWithTable(visualDevJsonModel, paginationModel, userInfo, keyList);
|
} else {
|
noSwapDataList = visualDevListService.getWithoutTableData(visualDevJsonModel.getId());
|
noSwapDataList = visualDevListService.getList(noSwapDataList, searchVOList, paginationModel);
|
}
|
|
//数据转换
|
List<FieLdsModel> fields = new ArrayList<>();
|
OnlinePublicUtils.recursionFields(fields, fieLdsModels);
|
noSwapDataList = onlineSwapDataUtils.getSwapList(noSwapDataList, fields, visualDevJsonModel.getId(), false);
|
|
return noSwapDataList;
|
}
|
|
|
@Override
|
public VisualdevModelDataEntity getInfo(String id) {
|
QueryWrapper<VisualdevModelDataEntity> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(VisualdevModelDataEntity::getId, id);
|
return this.getOne(queryWrapper);
|
}
|
|
@Override
|
public DataModel visualCreate(VisualParamModel visualParamModel) throws Exception {
|
VisualdevEntity visualdevEntity = visualParamModel.getVisualdevEntity();
|
Map<String, Object> map = visualParamModel.getData();
|
boolean isLink = visualParamModel.getIsLink();
|
boolean isUpload = visualParamModel.getIsUpload();
|
FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class);
|
ColumnDataModel columnDataModel = JsonUtil.getJsonToBean(visualdevEntity.getColumnData(), ColumnDataModel.class);
|
Boolean needP = false;
|
List<String> formPerList = new ArrayList<>();
|
if (columnDataModel != null && StringUtil.isNotEmpty(visualParamModel.getMenuId())) {
|
needP = columnDataModel.getUseFormPermission();
|
Map<String, Object> pMap = PermissionInterfaceImpl.getFormMap();
|
if (pMap.get(visualParamModel.getMenuId()) != null) {
|
formPerList = JsonUtil.getJsonToList(pMap.get(visualParamModel.getMenuId()), ModuleFormModel.class).stream()
|
.map(ModuleFormModel::getEnCode).collect(Collectors.toList());
|
}
|
}
|
List<FieLdsModel> list = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class);
|
List<TableModel> tableModels = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class);
|
DbLinkEntity linkEntity = StringUtil.isNotEmpty(visualdevEntity.getDbLinkId()) ? dblinkService.getInfo(visualdevEntity.getDbLinkId()) : null;
|
|
//递归遍历模板
|
RecursionForm recursionForm = new RecursionForm(list, tableModels);
|
List<FormAllModel> formAllModel = new ArrayList<>();
|
FormCloumnUtil.recursionForm(recursionForm, formAllModel);
|
//是否开启并发锁
|
Boolean concurrency = false;
|
Integer primaryKeyPolicy = formData.getPrimaryKeyPolicy();
|
if (formData.getConcurrencyLock()) {
|
//初始化version值
|
map.put(TableFeildsEnum.VERSION.getField(), 0);
|
concurrency = true;
|
}
|
OnlineSwapDataUtils.swapDatetime(list, map);
|
//单行唯一校验
|
if (!isUpload) {
|
CheckFormModel checkFormModel = CheckFormModel.builder().formFieldList(list).dataMap(map).linkEntity(linkEntity).tableModelList(tableModels)
|
.visualdevEntity(visualdevEntity).id(null).isLink(isLink).build();
|
String b = formCheckUtils.checkForm(checkFormModel);
|
if (StringUtil.isNotEmpty(b)) {
|
throw new WorkFlowException(b);
|
}
|
}
|
String mainId = RandomUtil.uuId();
|
UserInfo userInfo = UserProvider.getUser();
|
UserEntity info = userApi.getInfoById(userInfo.getUserId());
|
DataModel dataModel = DataModel.builder().visualId(visualdevEntity.getId())
|
.dataNewMap(map).fieLdsModelList(list).tableModelList(tableModels).formAllModel(formAllModel)
|
.mainId(mainId).link(linkEntity).userEntity(info).concurrencyLock(concurrency)
|
.primaryKeyPolicy(primaryKeyPolicy).linkOpen(isLink)
|
.needPermission(needP).formPerList(formPerList)
|
.build();
|
flowFormDataUtil.create(dataModel);
|
|
//数据日志
|
if (formData.isDataLog() && !isUpload && !isLink) {
|
visualLogService.createEventLog(VisualLogForm.builder().modelId(visualdevEntity.getId()).dataId(dataModel.getMainId()).newData(map).type(0).build());
|
}
|
return dataModel;
|
}
|
|
@Override
|
public DataModel visualUpdate(VisualParamModel visualParamModel) throws Exception {
|
VisualdevEntity visualdevEntity = visualParamModel.getVisualdevEntity();
|
Map<String, Object> map = visualParamModel.getData();
|
String id = visualParamModel.getId();
|
boolean isUpload = visualParamModel.getIsUpload();
|
boolean onlyUpdate = visualParamModel.getOnlyUpdate();
|
ColumnDataModel columnDataModel = JsonUtil.getJsonToBean(visualdevEntity.getColumnData(), ColumnDataModel.class);
|
FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class);
|
Boolean needP = false;
|
List<String> formPerList = new ArrayList<>();
|
if (columnDataModel != null && StringUtil.isNotEmpty(visualParamModel.getMenuId())) {
|
needP = columnDataModel.getUseFormPermission();
|
Map<String, Object> pMap = PermissionInterfaceImpl.getFormMap();
|
if (pMap.get(visualParamModel.getMenuId()) != null) {
|
formPerList = JsonUtil.getJsonToList(pMap.get(visualParamModel.getMenuId()), ModuleFormModel.class).stream()
|
.map(ModuleFormModel::getEnCode).collect(Collectors.toList());
|
}
|
}
|
List<FieLdsModel> list = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class);
|
boolean inlineEdit = columnDataModel.getType() != null && columnDataModel.getType() == 4;
|
if (inlineEdit && RequestContext.isOrignPc()) {
|
list = JsonUtil.getJsonToList(columnDataModel.getColumnList(), FieLdsModel.class);
|
list = list.stream().filter(f -> !f.getId().toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)).collect(Collectors.toList());
|
}
|
List<TableModel> tableModels = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class);
|
TableModel mainT = tableModels.stream().filter(t -> t.getTypeId().equals("1")).findFirst().orElse(null);
|
DbLinkEntity linkEntity = StringUtil.isNotEmpty(visualdevEntity.getDbLinkId()) ? dblinkService.getInfo(visualdevEntity.getDbLinkId()) : null;
|
|
//递归遍历模板
|
RecursionForm recursionForm = new RecursionForm(list, tableModels);
|
List<FormAllModel> formAllModel = new ArrayList<>();
|
FormCloumnUtil.recursionForm(recursionForm, formAllModel);
|
//是否开启并发锁
|
Boolean isConcurrencyLock = false;
|
Integer primaryKeyPolicy = formData.getPrimaryKeyPolicy();
|
if (formData.getConcurrencyLock()) {
|
if (map.get(TableFeildsEnum.VERSION.getField()) == null) {
|
map.put(TableFeildsEnum.VERSION.getField(), 0);
|
} else {
|
boolean version = true;
|
try {
|
Object realId = id;
|
if (Objects.equals(primaryKeyPolicy, 2)) {
|
realId = Long.parseLong(id);
|
}
|
version = flowFormDataUtil.getVersion(mainT.getTable(), linkEntity, map, realId);
|
} catch (Exception e) {
|
throw new WorkFlowException(e.getMessage(), e);
|
}
|
if (!version) {
|
throw new WorkFlowException(MsgCode.VS405.get());
|
} else {
|
Integer vs = Integer.valueOf(String.valueOf(map.get(TableFeildsEnum.VERSION.getField())));
|
map.put(TableFeildsEnum.VERSION.getField(), vs + 1);
|
}
|
}
|
isConcurrencyLock = true;
|
}
|
OnlineSwapDataUtils.swapDatetime(list, map);
|
//单行唯一校验
|
if (!isUpload) {
|
CheckFormModel checkFormModel = CheckFormModel.builder().formFieldList(list).dataMap(map).linkEntity(linkEntity).tableModelList(tableModels)
|
.visualdevEntity(visualdevEntity).id(id).build();
|
String b = formCheckUtils.checkForm(checkFormModel);
|
if (StringUtil.isNotEmpty(b)) {
|
throw new WorkFlowException(b);
|
}
|
}
|
|
//数据日志
|
VisualdevModelDataInfoVO resOld = visualDevInfoService.getDetailsDataInfo(id, visualdevEntity,
|
OnlineInfoModel.builder().needRlationFiled(true).needSwap(false).formAllModel(formAllModel).build());
|
Map<String, Object> oldData = JsonUtil.stringToMap(resOld.getData());
|
|
UserInfo userInfo = UserProvider.getUser();
|
UserEntity info = userApi.getInfoById(userInfo.getUserId());
|
DataModel dataModel = DataModel.builder().visualId(visualdevEntity.getId())
|
.dataNewMap(map).fieLdsModelList(list).tableModelList(tableModels).formAllModel(formAllModel)
|
.mainId(id).link(linkEntity).userEntity(info).concurrencyLock(isConcurrencyLock)
|
.primaryKeyPolicy(primaryKeyPolicy).onlyUpdate(onlyUpdate).logicalDelete(formData.getLogicalDelete())
|
.needPermission(needP).formPerList(formPerList)
|
.build();
|
flowFormDataUtil.update(dataModel);
|
VisualdevModelDataInfoVO res = visualDevInfoService.getDetailsDataInfo(id, visualdevEntity,
|
OnlineInfoModel.builder().needRlationFiled(true).needSwap(false).formAllModel(formAllModel).build());
|
Map<String, Object> newData = JsonUtil.stringToMap(res.getData());
|
VisualLogForm form = VisualLogForm.builder().modelId(visualdevEntity.getId()).dataId(id).oldData(oldData).newData(newData).type(1).build();
|
//处理变更字段信息-任务流程用
|
List<VisualLogModel> listLog = new ArrayList<>();
|
visualLogService.addLog(form, listLog);
|
dataModel.setListLog(listLog);
|
//数据日志
|
if (formData.isDataLog() && !isUpload) {
|
form.setListLog(listLog);
|
visualLogService.createEventLog(form);
|
}
|
return dataModel;
|
}
|
|
@Override
|
public void visualDelete(VisualdevEntity visualdevEntity, List<Map<String, Object>> data) throws Exception {
|
VisualDevJsonModel visualJsonModel = OnlinePublicUtils.getVisualJsonModel(visualdevEntity);
|
//判断请求客户端来源
|
if (!RequestContext.isOrignPc()) {
|
visualJsonModel.setColumnData(visualJsonModel.getAppColumnData());
|
}
|
List<String> idsList = new ArrayList<>();
|
StringJoiner errMess = new StringJoiner(",");
|
//todo 流程关联
|
for (Map<String, Object> map : data) {
|
String id = String.valueOf(map.get(FlowFormConstant.ID));
|
TaskEntity taskEntity = workFlowApi.getInfoSubmit(String.valueOf(map.get(FlowFormConstant.FLOWTASKID)));
|
if (taskEntity != null) {
|
try {
|
workFlowApi.delete(taskEntity);
|
idsList.add(id);
|
} catch (Exception e) {
|
errMess.add(e.getMessage());
|
}
|
} else {
|
idsList.add(id);
|
}
|
}
|
if (idsList.size() == 0) {
|
throw new WorkFlowException(errMess.toString());
|
}
|
if (!StringUtil.isEmpty(visualdevEntity.getVisualTables()) && !OnlineDevData.TABLE_CONST.equals(visualdevEntity.getVisualTables())) {
|
for (String id : idsList) {
|
try {
|
tableDelete(id, visualJsonModel);
|
} catch (Exception e) {
|
throw new WorkFlowException(e.getMessage(), e);
|
}
|
}
|
}
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void delete(VisualdevModelDataEntity entity) {
|
if (entity != null) {
|
this.removeById(entity.getId());
|
}
|
}
|
|
@Override
|
public boolean tableDelete(String id, VisualDevJsonModel visualDevJsonModel) throws Exception {
|
DbLinkEntity linkEntity = dblinkService.getInfo(visualDevJsonModel.getDbLinkId());
|
VisualDevJsonModel model = BeanUtil.copyProperties(visualDevJsonModel, VisualDevJsonModel.class);
|
return flowFormDataUtil.deleteTable(id, model, linkEntity);
|
}
|
|
@Override
|
public ActionResult tableDeleteMore(List<String> ids, VisualDevJsonModel visualDevJsonModel) throws Exception {
|
List<String> dataInfoVOList = new ArrayList<>();
|
for (String id : ids) {
|
boolean isDel = tableDelete(id, visualDevJsonModel);
|
if (isDel) {
|
dataInfoVOList.add(id);
|
}
|
}
|
visualDevJsonModel.setDataIdList(dataInfoVOList);
|
return ActionResult.success(MsgCode.SU003.get());
|
}
|
|
@Override
|
@DSTransactional
|
public void deleteByTableName(FlowFormDataModel model) throws Exception {
|
String tableName = model.getTableName();
|
List<Map<String, Object>> ruleList = model.getRuleList();
|
String realTableName = tableName;
|
VisualdevReleaseEntity entity = visualdevReleaseService.getById(model.getFormId());
|
List<TableModel> tableModels = JsonUtil.getJsonToList(entity.getVisualTables(), TableModel.class);
|
FormDataModel formData = JsonUtil.getJsonToBean(entity.getFormData(), FormDataModel.class);
|
Boolean logicalDelete = formData.getLogicalDelete();
|
DbLinkEntity linkEntity = StringUtil.isNotEmpty(entity.getDbLinkId()) ? dblinkService.getInfo(entity.getDbLinkId()) : null;
|
List<FieLdsModel> fieLdsModels = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class);
|
List<FieLdsModel> fields = new ArrayList<>();
|
OnlinePublicUtils.recursionFields(fields, fieLdsModels);
|
if (StringUtil.isNotEmpty(tableName) && tableName.toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)) {
|
FieLdsModel fieLdsModel = fields.stream().filter(t -> t.getVModel().equalsIgnoreCase(tableName)).findFirst().orElse(null);
|
if (fieLdsModel != null) {
|
realTableName = fieLdsModel.getConfig().getTableName();
|
}
|
}
|
String finalRealTableName = realTableName;
|
TableModel tableModel = tableModels.stream().filter(t -> t.getTable().equals(finalRealTableName)).findFirst().orElse(null);
|
List<OnlineDynamicSqlModel> sqlModelList = new ArrayList<>();
|
OnlineDynamicSqlModel sqlModel = new OnlineDynamicSqlModel();
|
SqlTable sqlTable = SqlTable.of(tableModel.getTable());
|
sqlModel.setSqlTable(sqlTable);
|
sqlModel.setTableName(tableModel.getTable());
|
sqlModelList.add(sqlModel);
|
SuperJsonModel ruleJsonModel = null;
|
//组装查询条件
|
if (ObjectUtil.isNotEmpty(ruleList)) {
|
ruleJsonModel = new SuperJsonModel();
|
ruleJsonModel.setMatchLogic(model.getRuleMatchLogic());
|
List<SuperQueryJsonModel> superQueryJsonModelList = new ArrayList<>();
|
for (Object obj : ruleList) {
|
SuperQueryJsonModel ruleQueryModel = JsonUtil.getJsonToBean(obj, SuperQueryJsonModel.class);
|
List<FieLdsModel> groups = ruleQueryModel.getGroups();
|
if (ObjectUtil.isNotEmpty(groups)) {
|
groups.stream().forEach(group -> {
|
if (group.getId().toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)) {
|
group.setVModel(group.getId().split("-")[1]);
|
}
|
});
|
}
|
superQueryJsonModelList.add(ruleQueryModel);
|
}
|
ruleJsonModel.setConditionList(superQueryJsonModelList);
|
}
|
DynamicDataSourceUtil.switchToDataSource(linkEntity);
|
try {
|
@Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity);
|
String dbType = conn.getMetaData().getDatabaseProductName().trim();
|
String pkeyId = flowFormDataUtil.getKey(tableModel, dbType);
|
List<Object> idStringList = new ArrayList<>();
|
if (ObjectUtil.isNotEmpty(ruleJsonModel)) {
|
QueryExpressionDSL<SelectModel>.QueryExpressionWhereBuilder where = SqlBuilder.selectDistinct(sqlTable.column(pkeyId)).from(sqlTable).where();
|
OnlineProductSqlUtils.getSuperSql(where, ruleJsonModel, sqlModelList, dbType, null, false);
|
List<Map<String, Object>> dataList = flowFormDataMapper.selectManyMappedRows(where.build().render(RenderingStrategies.MYBATIS3));
|
idStringList = dataList.stream().map(m -> m.get(pkeyId)).distinct().collect(Collectors.toList());
|
if (ObjectUtil.isEmpty(idStringList)) {
|
idStringList.add("nodata");
|
}
|
}
|
// if (logicalDelete) {
|
// SqlTable sqlt = SqlTable.of(tableModel.getTable());
|
// UpdateDSL<UpdateModel> updateModelUpdateDSL = SqlBuilder.update(sqlt);
|
// updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETEMARK.getField())).equalTo(1);
|
// updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETETIME.getField())).equalTo(new Date());
|
// updateModelUpdateDSL.set(sqlt.column(TableFeildsEnum.DELETEUSERID.getField())).equalTo(UserProvider.getUser().getUserId());
|
// UpdateDSL<UpdateModel>.UpdateWhereBuilder whereU = updateModelUpdateDSL.where();
|
// if (ObjectUtil.isNotEmpty(idStringList)) {
|
// whereU.and(sqlTable.column(pkeyId), SqlBuilder.isIn(idStringList));
|
// }
|
// flowFormDataMapper.update(whereU.build().render(RenderingStrategies.MYBATIS3));
|
// } else {
|
DeleteDSL<DeleteModel>.DeleteWhereBuilder whereD = SqlBuilder.deleteFrom(SqlTable.of(tableModel.getTable())).where();
|
if (ObjectUtil.isNotEmpty(idStringList)) {
|
whereD.and(sqlTable.column(pkeyId), SqlBuilder.isIn(idStringList));
|
}
|
flowFormDataMapper.delete(whereD.build().render(RenderingStrategies.MYBATIS3));
|
// }
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new WorkFlowException(MsgCode.FA103.get(),e.getMessage());
|
} finally {
|
DynamicDataSourceUtil.clearSwitchDataSource();
|
}
|
}
|
}
|
