shilei
/
E10-secondev-new
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

#E10-28# 建模新增使用rpc接口创建优化

Browse Source
main
shilei 1 year ago
parent 32d44c532d
commit 2145463952
2 changed files with 171 additions and 181 deletions
Show Stats Download Patch File Download Diff File

264
src/main/java/com/weaver/seconddev/jcldoor/cmd/SelfServiceInfoCmd.java
Unescape Escape View File

@ -381,6 +381,41 @@ public class SelfServiceInfoCmd {
*/
public int initCustomServiceData(String groupId,String sourceType,String field_id,String employeeId,String uf_zzfwrktaby_qy,String uf_zzfwrkpz_qy,String objId){
int errcount = 0;
try{
List<Map<String,Object>> recordList = getFieldOptionList(sourceType,groupId,field_id);
log.error("initCustomServiceData-recordList:"+recordList.size());
updateServiceTabData(employeeId,sourceType,groupId,uf_zzfwrktaby_qy,recordList);
for(int i=0;i<recordList.size();i++) {
Map<String, Object> recordMap = recordList.get(i);
String name = String.valueOf(recordMap.get("name"));
String taby = String.valueOf(recordMap.get("taby"));
String tabid = getServiceTabId(employeeId, name, groupId, sourceType, uf_zzfwrktaby_qy,"1");
log.error("initCustomServiceData-tabid:"+tabid);
if(StringUtils.isNotBlank(tabid)){
initCustomServiceDataByType(employeeId,groupId,sourceType,taby,tabid,uf_zzfwrkpz_qy);
}
}
}catch (Exception e){
errcount++;
e.printStackTrace();
log.error("Exception-e:"+e);
}
return errcount;
}
/***
*
* @param sourceType
* @param groupId
* @param field_id
* @return
*/
public List<Map<String,Object>> getFieldOptionList(String sourceType,String groupId,String field_id){
List<Map<String,Object>> recordList = new ArrayList<Map<String,Object>>();
try{
String sql = " select name,value_key as taby from field_option where field_id=? and delete_type=0 and tenant_key = ?";
log.error("sql:"+sql);
@ -390,26 +425,52 @@ public class SelfServiceInfoCmd {
List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
recordList = databaseUtils.getDataSourceList(result);
}catch (Exception e){
log.error("getFieldOptionList-e:"+e);
}
return recordList;
}
/***
*
* @param employeeId
* @param sourceType
* @param groupId
* @param recordList
* @return
*/
public String updateServiceTabData(String employeeId,String sourceType,String groupId,String uf_zzfwrktaby_qy,List<Map<String,Object>> recordList){
String code = "200" ;
try{
String field_ry = "977243460998938628";
String field_tabymmc = "977680413716267009";
String field_qy = "977701557798322178";
String field_xssx = "981394667260444674";
String objId = "977243418007322626";
List<EBDataReqDto> EBDataReqDtoList = Lists.newArrayList();
List<EBDataReqDto> insertEbDataReqDtoList = Lists.newArrayList();
List<EBDataReqDto> updateEbDataReqDtoList = Lists.newArrayList();
for(int i=0;i<recordList.size();i++){
Map<String,Object> recordMap = recordList.get(i);
String taby = String.valueOf(recordMap.get("taby"));
String name = String.valueOf(recordMap.get("name"));
String tabid = getTabId(employeeId,name,groupId,sourceType,uf_zzfwrktaby_qy);
String tabid = getServiceTabId(employeeId,name,groupId,sourceType,uf_zzfwrktaby_qy,"0");
log.error("tabid:"+tabid);
if(StringUtils.isNotBlank(tabid)){
// int count = initCustomServiceDataByType(employeeId,groupId,sourceType,taby,tabid,uf_zzfwrkpz_qy);
// if(count>0){
// errcount++;
// }
// 数据1
EBDataReqDto ebDataReqDto = new EBDataReqDto();
List<EBDataReqDetailDto> mainData = Lists.newArrayList();
// 设置更新id
mainData.add(new EBDataReqDetailDto("id", tabid));
// 单行文本
mainData.add(new EBDataReqDetailDto(field_tabymmc, name));
// 选择框根据选项名赋值
mainData.add(new EBDataReqDetailDto(field_qy, uf_zzfwrktaby_qy));
mainData.add(new EBDataReqDetailDto(field_xssx, i+""));
ebDataReqDto.setMainDatas(mainData);
updateEbDataReqDtoList.add(ebDataReqDto);
}else{
EBDataReqDto ebDataReqDto = new EBDataReqDto();
@ -419,71 +480,19 @@ public class SelfServiceInfoCmd {
mainData.add(new EBDataReqDetailDto(field_qy, uf_zzfwrktaby_qy));
mainData.add(new EBDataReqDetailDto(field_xssx, i+""));
ebDataReqDto.setMainDatas(mainData);
EBDataReqDtoList.add(ebDataReqDto);
insertEbDataReqDtoList.add(ebDataReqDto);
}
}
log.error("EBDataReqDtoList:"+EBDataReqDtoList.size());
jucailinPortalUtils.saveModeData(objId,employeeId,tenant_key,EBDataReqDtoList);
}catch (Exception e){
errcount++;
e.printStackTrace();
log.error("Exception-e:"+e);
}
return errcount;
}
/***
*
* @param employeeId
* @param name
* @param xssx
* @param groupId
* @param sourceType
* @return
*/
public String insertTabData(String employeeId,String name,String xssx,String groupId,String sourceType,String uf_zzfwrktaby_qy){
String code = "" ;
try{
log.error("insertTabData");
long generate = IdGenerator.generate();
log.error("insertTabData--id:"+generate+" ry:"+employeeId+" tabymmc:"+name+" xssx:"+xssx);
// String sql =" insert into uf_zzfwrktaby(id,ry,tabymmc,qy,xssx,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type) " +
// " values(?,?,?,?,?,?,?,?,0,now(),now(),?,0,?,0)";
// List<String> paramList = new ArrayList<>(100);
// paramList.add(generate+"");
// paramList.add(employeeId);
// paramList.add(name);
// paramList.add(uf_zzfwrktaby_qy);
// paramList.add(xssx);
// paramList.add(generate+"");
// paramList.add(tenant_key);
// paramList.add(employeeId);
// List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
// Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
String sql =" insert into uf_zzfwrktaby(id,ry,tabymmc,qy,xssx,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type,is_flow,data_status,name,updater) " +
" values("+generate+","+employeeId+",'"+name+"',"+uf_zzfwrktaby_qy+",'"+xssx+"',"+generate+",0,now(),now(),'"+tenant_key+"',0,"+employeeId+",0,0,1,'"+name+"',"+employeeId+")";
log.error("sql:"+sql);
Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);
Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
while (iterator.hasNext()){
Map.Entry<String, Object> next = iterator.next();
log.error("insertTabData--key="+next.getKey()+" value="+String.valueOf(next.getValue()));
log.error("insertEbDataReqDtoList:"+insertEbDataReqDtoList.size());
if(insertEbDataReqDtoList !=null && insertEbDataReqDtoList.size()>0){
jucailinPortalUtils.saveModeData(objId,employeeId,tenant_key,insertEbDataReqDtoList);
}
if(result.containsKey("code")){
code = String.valueOf(result.get("code"));
log.error("updateEbDataReqDtoList:"+updateEbDataReqDtoList.size());
if(updateEbDataReqDtoList !=null && updateEbDataReqDtoList.size()>0){
jucailinPortalUtils.updateModeDataById(objId,employeeId,tenant_key,updateEbDataReqDtoList,false);
}
}catch (Exception e){
code = "-200";
log.error("insertTabData-e:"+e);
@ -491,6 +500,7 @@ public class SelfServiceInfoCmd {
log.error("insertTabData-code:"+code);
return code;
}
/***
*
* @param employeeId
@ -499,19 +509,16 @@ public class SelfServiceInfoCmd {
* @param sourceType
* @return
*/
public String getTabId(String employeeId,String name,String groupId,String sourceType,String uf_zzfwrktaby_qy){
public String getServiceTabId(String employeeId,String name,String groupId,String sourceType,String uf_zzfwrktaby_qy,String type){
String tabid = "" ;
try{
if("1".equals(type)){
String sql = "select id from uf_zzfwrktaby where ry = ? and tabymmc = ? and qy = ? and delete_type=0 and tenant_key = ?";
log.info("sql:"+sql);
List<String> paramList = new ArrayList<>(100);
paramList.add(employeeId);
paramList.add(name);
paramList.add(uf_zzfwrktaby_qy);
paramList.add(tenant_key);
List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
@ -519,6 +526,20 @@ public class SelfServiceInfoCmd {
Map<String, Object> recordMap = recordList.get(0);
tabid = String.valueOf(recordMap.get("id"));
}
}else{
String sql = "select id from uf_zzfwrktaby where ry = ? and tabymmc = ? and delete_type=0 and tenant_key = ?";
List<String> paramList = new ArrayList<>(100);
paramList.add(employeeId);
paramList.add(name);
paramList.add(tenant_key);
List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
if(!recordList.isEmpty() && recordList.size()>0){
Map<String, Object> recordMap = recordList.get(0);
tabid = String.valueOf(recordMap.get("id"));
}
}
}catch (Exception e){
log.error("getTabId-e:"+e);
}
@ -544,7 +565,8 @@ public class SelfServiceInfoCmd {
String field_fwtb = "977686869110833154";
String field_qy = "977703984547119105";
String field_xssx = "981394744418861058";
String objId = "977240471802363909";
String field_taby = "977686869110833157";
String objId = "977240471802363906";
try{
String sql =" select t.taby,t.fwtb,t.fwmc,t.fwdz " +
@ -553,6 +575,7 @@ public class SelfServiceInfoCmd {
" and t.taby= ?" +
" and t.tenant_key = ?" +
" order by ifnull(t.xssx,0) ";
log.error("initCustomServiceDataByType--sql:"+sql);
List<String> paramList = new ArrayList<>(100);
paramList.add(selectvalue);
@ -563,7 +586,6 @@ public class SelfServiceInfoCmd {
log.error("initCustomServiceDataByType--recordList:"+recordList.size());
List<EBDataReqDto> EBDataReqDtoList = Lists.newArrayList();
for(int i=0;i<recordList.size();i++){
@ -580,10 +602,11 @@ public class SelfServiceInfoCmd {
mainData.add(new EBDataReqDetailDto(field_fwtb, fwtb));
mainData.add(new EBDataReqDetailDto(field_qy, uf_zzfwrktaby_qy));
mainData.add(new EBDataReqDetailDto(field_xssx, i+""));
mainData.add(new EBDataReqDetailDto(field_taby, tabid));
ebDataReqDto.setMainDatas(mainData);
EBDataReqDtoList.add(ebDataReqDto);
}
log.error("EBDataReqDtoList:"+EBDataReqDtoList.size());
if(EBDataReqDtoList !=null && EBDataReqDtoList.size()>0){
jucailinPortalUtils.saveModeData(objId,employeeId,tenant_key,EBDataReqDtoList);
}
@ -593,95 +616,6 @@ public class SelfServiceInfoCmd {
return errcount;
}
/**
*
* @param employeeId
* @param name
* @param fwdz
* @param fwtb
* @param xssx
* @param groupId
* @param sourceType
* @param tabid
* @return
*/
public String insertCustomServiceData(String employeeId,String name,String fwdz,String fwtb,String xssx,String groupId,String sourceType,String tabid,String uf_zzfwrktaby_qy){
String code = "";
try {
long generate = IdGenerator.generate();
log.error("insertCustomServiceData--id:"+generate+" ry:"+employeeId+" fwmc:"+name+" fwdz:"+fwdz+" fwtb:"+fwtb+" taby:"+tabid+" xssx:"+xssx);
// String sql =" insert into uf_zzfwrkpz(id,ry,fwmc,fwdz,fwtb,taby,qy,xssx,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type) " +
// " values(?,?,?,?,?,?,?,?,?,0,now(),now(),?,0,?,0)";
// List<String> paramlist = new ArrayList<>(100);
// paramlist.add(generate+"");
// paramlist.add(employeeId);
// paramlist.add(name);
// paramlist.add(fwdz);
// paramlist.add(fwtb);
// paramlist.add(tabid);
// paramlist.add(uf_zzfwrktaby_qy);
// paramlist.add(xssx);
// paramlist.add(generate+"");
// paramlist.add(tenant_key);
// paramlist.add(employeeId);
// List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramlist);
// Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
List<EBDataReqDto> datas = Lists.newArrayList();
// 数据1
EBDataReqDto ebDataReqDto1 = new EBDataReqDto();
List<EBDataReqDetailDto> mainData1 = Lists.newArrayList();
// 单行文本
mainData1.add(new EBDataReqDetailDto("845949549147324416", "单行文本数据1"));
// 选择框根据选项名赋值
mainData1.add(new EBDataReqDetailDto("845949549147324419", "选项1", true));
ebDataReqDto1.setMainDatas(mainData1);
// 数据2
EBDataReqDto ebDataReqDto2 = new EBDataReqDto();
List<EBDataReqDetailDto> mainData2 = Lists.newArrayList();
// 单行文本
mainData2.add(new EBDataReqDetailDto("845949549147324416", "单行文本数据2"));
// 选择框根据选项key赋值
mainData2.add(new EBDataReqDetailDto("845949549147324419", "845949643627814915", false));
ebDataReqDto2.setMainDatas(mainData2);
datas.add(ebDataReqDto1);
datas.add(ebDataReqDto2);
String sql =" insert into uf_zzfwrkpz(id,ry,fwmc,fwdz,fwtb,taby,qy,xssx,form_data_id,data_index,create_time,update_time,tenant_key,is_delete,creator,delete_type,updater,name,is_flow,data_status) " +
" values("+generate+","+employeeId+",'"+name+"','"+fwdz+"','"+fwtb+"','"+tabid+"',"+uf_zzfwrktaby_qy+",'"+xssx+"',"+generate+",0,now(),now(),'"+tenant_key+"',0,"+employeeId+",0,"+employeeId+",'"+name+"',0,1)";
Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);
Iterator<Map.Entry<String, Object>> iterator = result.entrySet().iterator();
while (iterator.hasNext()){
Map.Entry<String, Object> next = iterator.next();
log.error("insertCustomServiceData--key="+next.getKey()+" value="+String.valueOf(next.getValue()));
}
if(result.containsKey("code")){
code = String.valueOf(result.get("code"));
}
}catch (Exception e){
e.printStackTrace();
log.error("insertCustomServiceData-e:"+e);
code = "-200";
}
log.error("insertCustomServiceData22--code= "+code);
return code ;
}
/***
*
* @param employeeId

64
src/main/java/com/weaver/seconddev/jcldoor/util/JucailinPortalUtils.java
Unescape Escape View File

@ -642,13 +642,69 @@ public class JucailinPortalUtils {
//
// datas.add(ebDataReqDto1);
// datas.add(ebDataReqDto2);
ebDataChangeReqDto.setDatas(datas);
EBDataChangeResult insertEbDataChangeResult = remoteSimpleDataService.saveFormData(ebDataChangeReqDto);
log.error("insertEbDataChangeResult:"+insertEbDataChangeResult.getMessage());
log.error("insertEbDataChangeResult:"+insertEbDataChangeResult.toString());
log.error("insertEbDataChangeResult:"+insertEbDataChangeResult.getStatus());
}
/***
*
*/
public void updateModeDataById(String objId,String operator,String tenant_key,List<EBDataReqDto> datas,boolean isNeedAdd){
/**
* 直接通过id更新数据， 即update table set a = '11' where id = 1
*/
EBDataChangeReqDto ebDataChangeReqDto = new EBDataChangeReqDto();
// 构建基础参数; objId 表单id, operator 操作人, tenantKey 租户
ebDataChangeReqDto.setHeader(new EBDataReqHeader(objId, operator, tenant_key));
// 请求操作信息
EBDataReqOperation ebDataReqOperation = new EBDataReqOperation();
ebDataReqOperation.setUpdateType(EBDataUpdateType.ids);
// 数据没有找到的时候是否新增数据
EBDataReqOperationInfo ebDataReqOperationInfo = new EBDataReqOperationInfo();
ebDataReqOperationInfo.setNeedAdd(isNeedAdd);
ebDataReqOperation.setMainData(ebDataReqOperationInfo);
ebDataChangeReqDto.setOperation(ebDataReqOperation);
// 数据组装
// List<EBDataReqDto> datas = Lists.newArrayList();
//// 数据1
// EBDataReqDto ebDataReqDto1 = new EBDataReqDto();
// List<EBDataReqDetailDto> mainData1 = Lists.newArrayList();
//// 设置更新id
// mainData1.add(new EBDataReqDetailDto("id", "845949549147324400"));
//// 单行文本
// mainData1.add(new EBDataReqDetailDto("845949549147324416", "单行文本数据1"));
//// 选择框根据选项名赋值
// mainData1.add(new EBDataReqDetailDto("845949549147324419", "选项1", true));
// ebDataReqDto1.setMainDatas(mainData1);
//
//// 数据2
// EBDataReqDto ebDataReqDto2 = new EBDataReqDto();
// List<EBDataReqDetailDto> mainData2 = Lists.newArrayList();
//// 设置更新id
// mainData2.add(new EBDataReqDetailDto("id", "845949549147324401"));
//// 单行文本
// mainData2.add(new EBDataReqDetailDto("845949549147324416", "单行文本数据2"));
//// 选择框根据选项key赋值
// mainData2.add(new EBDataReqDetailDto("845949549147324419", "845949643627814915", false));
// ebDataReqDto2.setMainDatas(mainData2);
//
// datas.add(ebDataReqDto1);
// datas.add(ebDataReqDto2);
ebDataChangeReqDto.setDatas(datas);
EBDataChangeResult ebDataChangeResult = remoteSimpleDataService.saveFormData(ebDataChangeReqDto);
log.error("ebDataChangeResult:"+ebDataChangeResult.getMessage());
log.error("ebDataChangeResult:"+ebDataChangeResult.toString());
log.error("ebDataChangeResult:"+ebDataChangeResult.getStatus());
EBDataChangeResult updateEbDataChangeResult = remoteSimpleDataService.updateFormData(ebDataChangeReqDto);
log.error("updateEbDataChangeResult:"+updateEbDataChangeResult.getMessage());
log.error("updateEbDataChangeResult:"+updateEbDataChangeResult.toString());
log.error("updateEbDataChangeResult:"+updateEbDataChangeResult.getStatus());
}
/***
*
* @param request

Write Preview
Loading…
Cancel
Save