package com.battery.business.report;
|
|
import java.sql.Timestamp;
|
import java.util.HashSet;
|
import java.util.List;
|
import javax.sql.DataSource;
|
import com.alibaba.fastjson2.JSON;
|
import com.battery.business.domain.TBatteryGroupField;
|
import com.battery.business.service.ITBatteryGroupFieldService;
|
import com.fasterxml.jackson.annotation.JsonAnySetter;
|
import com.ruoyi.common.exception.ServiceException;
|
import jakarta.validation.Valid;
|
import jakarta.validation.constraints.*;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.jdbc.support.GeneratedKeyHolder;
|
import org.springframework.stereotype.Service;
|
|
/** 拼接模板独立存储，应用与修改均不回写任何已保存报表。 */
|
@Service
|
public class SpliceFieldTemplateService
|
{
|
private final JdbcTemplate jdbc;
|
private final ITBatteryGroupFieldService definitions;
|
public SpliceFieldTemplateService(DataSource source, ITBatteryGroupFieldService definitions)
|
{ jdbc = new JdbcTemplate(source); this.definitions = definitions; }
|
|
public record Template(long id, String name, String type, List<SpliceField> fields, String creator, long updatedAt) { }
|
public record Request(@NotBlank @Size(max = 100) String name,
|
@NotNull @Size(min = 1, max = 100) List<@NotNull @Valid SpliceField> fields)
|
{
|
/** 模板不能保存报表来源或人工填写值。 */
|
@JsonAnySetter
|
public void rejectUnknown(String field, Object value) { throw new ServiceException("拼接模板不允许提交属性：" + field); }
|
}
|
|
/** 校验字段身份；普通编辑只使用冻结身份，不依赖仍然存在的共享定义。 */
|
public List<SpliceField> validate(List<SpliceField> fields, boolean resolveDefinitions)
|
{
|
if (fields == null || fields.size() > 100 || fields.contains(null)) throw new ServiceException("拼接字段结构无效");
|
var names = new HashSet<String>(); var ids = new HashSet<Long>();
|
var current = resolveDefinitions ? definitions.selectBatteryGroupFieldList(new TBatteryGroupField()) : List.<TBatteryGroupField>of();
|
return fields.stream().map(field -> {
|
if (!names.add(field.name())) throw new ServiceException("拼接字段不能重复");
|
Long id = field.fieldDefinitionId();
|
// 控制台字段只有名称；没有明确共享身份时不得凭同名绑定组字段。
|
if ("battery".equals(field.category()) && resolveDefinitions && id != null)
|
id = current.stream().filter(item -> item.getFieldId().equals(field.fieldDefinitionId()))
|
.findFirst().orElseThrow(() -> new ServiceException("共享字段不存在：" + field.name())).getFieldId();
|
if (id != null && !ids.add(id)) throw new ServiceException("共享字段不能重复");
|
return new SpliceField(field.name(), field.category(), field.unit(), id, field.displayName());
|
}).toList();
|
}
|
|
/** 返回拼接所属类型的全部模板，保持字段保存顺序。 */
|
public List<Template> list()
|
{
|
return jdbc.query("select template_id,template_name,fields_json,creator_name,updated_at_utc from t_splice_report_field_template where template_type='splice' order by template_name,template_id",
|
(rs, index) -> new Template(rs.getLong(1), rs.getString(2), "splice", JSON.parseArray(rs.getString(3), SpliceField.class), rs.getString(4), rs.getTimestamp(5).getTime()));
|
}
|
|
/** 新增仅含字段结构的拼接模板，同名模板须显式更新。 */
|
public long create(Request request, long userId, String userName)
|
{
|
var fields = validate(request.fields(), true);
|
var key = new GeneratedKeyHolder();
|
try
|
{
|
jdbc.update(connection -> {
|
var statement = connection.prepareStatement("insert into t_splice_report_field_template(template_name,template_type,fields_json,creator_id,creator_name,created_at_utc,updated_at_utc) values(?,'splice',?,?,?,?,?)", java.sql.Statement.RETURN_GENERATED_KEYS);
|
statement.setString(1, request.name().trim()); statement.setString(2, JSON.toJSONString(fields));
|
statement.setLong(3, userId); statement.setString(4, userName);
|
var now = new Timestamp(System.currentTimeMillis()); statement.setTimestamp(5, now); statement.setTimestamp(6, now);
|
return statement;
|
}, key);
|
return key.getKey().longValue();
|
}
|
catch (org.springframework.dao.DuplicateKeyException error) { throw new ServiceException("模板名称已存在"); }
|
}
|
|
/** 修改仅影响后续主动应用，允许有编辑权限的其他创建人协作。 */
|
public void update(long id, Request request)
|
{
|
var fields = validate(request.fields(), true);
|
try
|
{
|
if (jdbc.update("update t_splice_report_field_template set template_name=?,fields_json=?,updated_at_utc=? where template_id=? and template_type='splice'",
|
request.name().trim(), JSON.toJSONString(fields), new Timestamp(System.currentTimeMillis()), id) == 0)
|
throw new ServiceException("拼接字段模板不存在");
|
}
|
catch (org.springframework.dao.DuplicateKeyException error) { throw new ServiceException("模板名称已存在"); }
|
}
|
}
|
