|
|
@@ -8,8 +8,10 @@ import cn.start.tz.module.pressure2.controller.admin.dynamictbins.vo.DynamicTbIn
|
|
|
import cn.start.tz.module.pressure2.controller.admin.dynamictbins.vo.DynamicTbInsSaveReqVO;
|
|
|
import cn.start.tz.module.pressure2.controller.admin.dynamictbins.vo.InitInstanceVO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.dynamictb.DynamicTbDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.dynamictbcol.DynamicTbColDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.dynamictbins.DynamicTbInsDO;
|
|
|
import cn.start.tz.module.pressure2.dal.dataobject.dynamictbval.DynamicTbValDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.dynamictbcol.DynamicTbColMapper;
|
|
|
import cn.start.tz.module.pressure2.dal.mysql.dynamictbins.DynamicTbInsMapper;
|
|
|
import cn.start.tz.module.pressure2.service.dynamicOFData.IDynamicOFData;
|
|
|
import cn.start.tz.module.pressure2.service.dynamicOFData.util.AutoDataBoilerService;
|
|
|
@@ -32,6 +34,7 @@ import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
import java.util.UUID;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
import static cn.start.tz.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
import static cn.start.tz.module.pressure2.enums.ErrorCodeConstants.DYNAMIC_TB_INS_NOT_EXISTS;
|
|
|
@@ -64,6 +67,9 @@ public class DynamicTbInsServiceImpl extends ServiceImpl<DynamicTbInsMapper, Dyn
|
|
|
@Resource
|
|
|
private AutoDataPipeService autoDataPipeService;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private DynamicTbColMapper dynamicTbColMapper;
|
|
|
+
|
|
|
@Override
|
|
|
public String createDynamicTbIns(DynamicTbInsSaveReqVO createReqVO) {
|
|
|
// 插入
|
|
|
@@ -139,6 +145,11 @@ public class DynamicTbInsServiceImpl extends ServiceImpl<DynamicTbInsMapper, Dyn
|
|
|
} else {
|
|
|
ofData = findOFService.getOfDataByVO(ruleVO);
|
|
|
}
|
|
|
+ List<DynamicTbColDO> dynamicTbColDOS = dynamicTbColMapper.selectList(DynamicTbColDO::getColRound, 2);
|
|
|
+ if (dynamicTbColDOS != null && !dynamicTbColDOS.isEmpty()) {
|
|
|
+ Map<String, String> collect = dynamicTbColDOS.stream().collect(Collectors.toMap(DynamicTbColDO::getColCode, DynamicTbColDO::getNote));
|
|
|
+ ofData.putAll(collect);
|
|
|
+ }
|
|
|
|
|
|
// 将json的value非String转成字符串
|
|
|
ofData = JsonConvertUtil.convertAllFieldsToString(ofData);
|