package com.ruoyi.system.service.impl;
|
|
import java.util.List;
|
import java.util.Map;
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
import com.fasterxml.jackson.databind.JsonNode;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.node.ArrayNode;
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.system.domain.CjFormConfig;
|
import com.ruoyi.system.mapper.CjFillTaskMapper;
|
import com.ruoyi.system.mapper.CjFormConfigMapper;
|
import com.ruoyi.system.service.ICjFormConfigService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.core.io.ClassPathResource;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* 填表配置Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2026-09-09
|
*/
|
@Service
|
public class CjFormConfigServiceImpl implements ICjFormConfigService
|
{
|
private static final Logger log = LoggerFactory.getLogger(CjFormConfigServiceImpl.class);
|
|
/** 内置35字段定义资源（classpath） */
|
private static final String BUILTIN_RESOURCE = "form/builtinDefault.json";
|
|
@Autowired
|
private CjFormConfigMapper cjFormConfigMapper;
|
@Autowired
|
private CjFillTaskMapper cjFillTaskMapper;
|
|
private final ObjectMapper objectMapper = new ObjectMapper();
|
|
/**
|
* 查询填表配置
|
*
|
* @param configId 填表配置主键
|
* @return 填表配置
|
*/
|
@Override
|
public CjFormConfig selectCjFormConfigByConfigId(Long configId)
|
{
|
return cjFormConfigMapper.selectCjFormConfigByConfigId(configId);
|
}
|
|
/**
|
* 查询填表配置列表
|
*
|
* @param cjFormConfig 填表配置
|
* @return 填表配置集合
|
*/
|
@Override
|
public List<CjFormConfig> selectCjFormConfigList(CjFormConfig cjFormConfig)
|
{
|
return cjFormConfigMapper.selectCjFormConfigList(cjFormConfig);
|
}
|
|
/**
|
* 新增填表配置
|
*
|
* @param cjFormConfig 填表配置
|
* @return 结果
|
*/
|
@Override
|
public int insertCjFormConfig(CjFormConfig cjFormConfig)
|
{
|
if (cjFormConfig.getConfigName() == null || cjFormConfig.getConfigName().trim().isEmpty())
|
{
|
throw new ServiceException("请填写配置名称");
|
}
|
// groups 为空则自动载入内置35字段；attachments 缺省为空数组
|
String groups = cjFormConfig.getGroupsJson();
|
if (groups == null || groups.trim().isEmpty())
|
{
|
try
|
{
|
JsonNode root = readBuiltin();
|
groups = objectMapper.writeValueAsString(root.path("groups"));
|
cjFormConfig.setGroupsJson(groups);
|
if (cjFormConfig.getAttachmentsJson() == null || cjFormConfig.getAttachmentsJson().trim().isEmpty())
|
{
|
cjFormConfig.setAttachmentsJson(objectMapper.writeValueAsString(root.path("attachments")));
|
}
|
}
|
catch (Exception e)
|
{
|
throw new ServiceException("读取内置字段库失败: " + e.getMessage());
|
}
|
}
|
cjFormConfig.setFieldCount(countFields(cjFormConfig.getGroupsJson()));
|
if (cjFormConfig.getVersion() == null) { cjFormConfig.setVersion(1L); }
|
if (cjFormConfig.getStatus() == null || cjFormConfig.getStatus().isEmpty()) { cjFormConfig.setStatus("0"); }
|
cjFormConfig.setCreateBy(username());
|
cjFormConfig.setCreateTime(DateUtils.getNowDate());
|
return cjFormConfigMapper.insertCjFormConfig(cjFormConfig);
|
}
|
|
/**
|
* 修改填表配置
|
*
|
* @param cjFormConfig 填表配置
|
* @return 结果
|
*/
|
@Override
|
public int updateCjFormConfig(CjFormConfig cjFormConfig)
|
{
|
CjFormConfig old = cjFormConfigMapper.selectCjFormConfigByConfigId(cjFormConfig.getConfigId());
|
if (old == null)
|
{
|
throw new ServiceException("填表配置不存在");
|
}
|
if (cjFormConfig.getGroupsJson() != null && !cjFormConfig.getGroupsJson().trim().isEmpty())
|
{
|
cjFormConfig.setFieldCount(countFields(cjFormConfig.getGroupsJson()));
|
}
|
cjFormConfig.setVersion(old.getVersion() == null ? 2L : old.getVersion() + 1);
|
cjFormConfig.setUpdateBy(username());
|
cjFormConfig.setUpdateTime(DateUtils.getNowDate());
|
return cjFormConfigMapper.updateCjFormConfig(cjFormConfig);
|
}
|
|
/**
|
* 批量删除填表配置（被填表任务引用时拒绝）
|
*
|
* @param configIds 需要删除的填表配置主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteCjFormConfigByConfigIds(Long[] configIds)
|
{
|
if (configIds == null || configIds.length == 0) { return 0; }
|
if (cjFillTaskMapper.countByConfigIds(configIds) > 0)
|
{
|
throw new ServiceException("所选配置已被填表任务引用，禁止删除（任务会保留表单快照）");
|
}
|
return cjFormConfigMapper.deleteCjFormConfigByConfigIds(configIds);
|
}
|
|
/**
|
* 获取内置默认表单定义（{configName, groups, attachments}）
|
*
|
* @return 内置表单 Map
|
*/
|
@Override
|
public Map<String, Object> getBuiltin()
|
{
|
try
|
{
|
return objectMapper.convertValue(readBuiltin(), new TypeReference<Map<String, Object>>() { });
|
}
|
catch (Exception e)
|
{
|
throw new ServiceException("读取内置字段库失败: " + e.getMessage());
|
}
|
}
|
|
// ========== 私有工具 ==========
|
|
/** 读取 classpath 内置字段库根节点 */
|
private JsonNode readBuiltin() throws Exception
|
{
|
ClassPathResource resource = new ClassPathResource(BUILTIN_RESOURCE);
|
return objectMapper.readTree(resource.getInputStream());
|
}
|
|
/** 统计 groups 数组内字段总数 */
|
private Long countFields(String groupsJson)
|
{
|
if (groupsJson == null || groupsJson.trim().isEmpty()) { return 0L; }
|
try
|
{
|
JsonNode groups = objectMapper.readTree(groupsJson);
|
long n = 0;
|
if (groups.isArray())
|
{
|
for (JsonNode group : groups)
|
{
|
JsonNode fields = group.path("fields");
|
if (fields.isArray()) { n += fields.size(); }
|
}
|
}
|
return n;
|
}
|
catch (Exception e)
|
{
|
log.warn("解析 groups_json 统计字段数失败，按 0 计: {}", e.getMessage());
|
return 0L;
|
}
|
}
|
|
/** 当前登录用户名（无上下文时返回 null） */
|
private String username()
|
{
|
try { return SecurityUtils.getUsername(); } catch (Exception e) { return null; }
|
}
|
}
|
