Commit c5d5dd1d authored by ZWT's avatar ZWT

feat(吉林演示): 松原

1.基础信息配置模块创建基础风机电站表及基础风机电站关联测风塔表,同时生成对应代码;
2.开发基础信息配置模块基础风机电站新增接口,完成接口冒烟测试并生成接口文档同时生成接口测试用例;
3.开发基础信息配置模块基础风机电站详情接口,完成接口冒烟测试并生成接口文档同时生成接口测试用例;
4.开发基础信息配置模块基础风机电站修改接口,完成接口冒烟测试并生成接口文档同时生成接口测试用例;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent 149d1003
......@@ -106,41 +106,45 @@ public class BaseWindTurbineService {
BaseWindTurbineMapper mapper = context.getBean(BaseWindTurbineMapper.class);
mapper.insert(entity);
//封装子表信息
List<BaseWindTowerInput> windTowerList = input.getWindTowerList();
if (CollUtil.isNotEmpty(windTowerList)) {
BaseWindTowerView view;
List<BaseWindTowerView> windTowerViewList = new ArrayList<>(windTowerList.size());
for (BaseWindTowerInput towerInput : windTowerList) {
view = new BaseWindTowerView();
BaseUtils.setBaseModelDefault(view, session);
view.setStationId(entity.getId());
view.setTowerId(towerInput.getTowerId());
view.setTowerName(towerInput.getTowerName());
view.setId(UUID.randomUUID(true).toString(true));
windTowerViewList.add(view);
}
BaseWindTowerViewMapper viewMapper = context.getBean(BaseWindTowerViewMapper.class);
viewMapper.batchInsert(windTowerViewList);
}
this.batchInsert(context, input.getWindTowerList(), session, entity.getId());
return XServiceResult.OK;
});
}
@XApiAnonymous
/**
* 修改基础风机电站
*
* @param context 上下文
* @param input 输入
* @return {@link XServiceResult }
*/
@XText("修改")
@XApiPost
public XServiceResult updateBaseWindTurbine(XContext context, UpdateBaseWindTurbineInput input) {
return XTransactionHelper.begin(context, () -> {
//更新主表信息
BaseWindTurbineMapper mapper = context.getBean(BaseWindTurbineMapper.class);
QueryWrapper<BaseWindTurbineEnt> queryWrapper = new QueryWrapper<>();
queryWrapper.lambda().eq(BaseWindTurbineEnt::getId, input.getId());
BaseWindTurbineEnt entity = mapper.selectOne(queryWrapper);
if (entity == null) {
BaseWindTurbineEnt entity = mapper.selectOne(new LambdaQueryWrapper<BaseWindTurbineEnt>()
.eq(BaseWindTurbineEnt::getId, input.getId()));
if (ObjectUtil.isNull(entity)) {
return XServiceResult.error(context, XError.NotFound);
}
PpsUserSession session = getSession(context);
XCopyUtils.copyObject(input, entity);
BaseUtils.setBaseModelDefault(entity, session);
mapper.updateById(entity);
//删除关联信息
BaseWindTowerMapper towerMapper = context.getBean(BaseWindTowerMapper.class);
towerMapper.delete(new LambdaQueryWrapper<BaseWindTowerEnt>()
.eq(BaseWindTowerEnt::getStationId, entity.getId())
);
//封装子表信息
this.batchInsert(context, input.getWindTowerList(), session, entity.getId());
return XServiceResult.OK;
});
}
@XApiAnonymous
@XApiPost
public XServiceResult deleteBaseWindTurbine(XContext context, DeleteBaseWindTurbineInput input) {
......@@ -218,4 +222,31 @@ public class BaseWindTurbineService {
return XPageResult.success(outputs, input, pageInfo.getTotal());
}
/*-----------------------------------private-----------------------------------*/
/**
* 批量插入
*
* @param context 上下文
* @param windTowerList 风塔列表
* @param session 阶段
* @param stationId 站点id
*/
private void batchInsert(XContext context, List<BaseWindTowerInput> windTowerList, PpsUserSession session, String stationId) {
if (CollUtil.isNotEmpty(windTowerList)) {
BaseWindTowerView view;
List<BaseWindTowerView> windTowerViewList = new ArrayList<>(windTowerList.size());
for (BaseWindTowerInput towerInput : windTowerList) {
view = new BaseWindTowerView();
BaseUtils.setBaseModelDefault(view, session);
view.setStationId(stationId);
view.setTowerId(towerInput.getTowerId());
view.setTowerName(towerInput.getTowerName());
view.setId(UUID.randomUUID(true).toString(true));
windTowerViewList.add(view);
}
BaseWindTowerViewMapper viewMapper = context.getBean(BaseWindTowerViewMapper.class);
viewMapper.batchInsert(windTowerViewList);
}
}
}
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment