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

#E10-27# 建模新增使用rpc接口创建

Browse Source
main
shilei 1 year ago
parent c51450e1d6
commit 216d06aa50
2 changed files with 124 additions and 21 deletions
Show Stats Download Patch File Download Diff File

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

@ -2,10 +2,13 @@ package com.weaver.seconddev.jcldoor.cmd;
import com.weaver.common.distribution.genid.IdGenerator; import com.weaver.common.distribution.genid.IdGenerator;
import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity;
import com.weaver.ebuilder.form.client.entity.data.EBDataReqDetailDto;
import com.weaver.ebuilder.form.client.entity.data.EBDataReqDto;
import com.weaver.seconddev.jcldoor.util.DatabaseUtils; import com.weaver.seconddev.jcldoor.util.DatabaseUtils;
import com.weaver.seconddev.jcldoor.util.JucailinPortalUtils; import com.weaver.seconddev.jcldoor.util.JucailinPortalUtils;
import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.teams.security.context.UserContext; import com.weaver.teams.security.context.UserContext;
import org.apache.commons.compress.utils.Lists;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -383,6 +386,14 @@ public class SelfServiceInfoCmd {
List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList); List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramList);
Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam);
List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result); List<Map<String,Object>> recordList = databaseUtils.getDataSourceList(result);
String objId = "977243418007322629";
String field_ry = "977243460998938628";
String field_tabymmc = "977680413716267009";
String field_qy = "977701557798322178";
String field_xssx = "981394667260444674";
List<EBDataReqDto> EBDataReqDtoList = Lists.newArrayList();
for(int i=0;i<recordList.size();i++){ for(int i=0;i<recordList.size();i++){
Map<String,Object> recordMap = recordList.get(i); Map<String,Object> recordMap = recordList.get(i);
String taby = String.valueOf(recordMap.get("taby")); String taby = String.valueOf(recordMap.get("taby"));
@ -391,23 +402,23 @@ public class SelfServiceInfoCmd {
String tabid = getTabId(employeeId,name,groupId,sourceType,uf_zzfwrktaby_qy); String tabid = getTabId(employeeId,name,groupId,sourceType,uf_zzfwrktaby_qy);
log.error("tabid:"+tabid); log.error("tabid:"+tabid);
if(StringUtils.isNotBlank(tabid)){ if(StringUtils.isNotBlank(tabid)){
int count = initCustomServiceDataByType(employeeId,groupId,sourceType,taby,tabid,uf_zzfwrkpz_qy); // int count = initCustomServiceDataByType(employeeId,groupId,sourceType,taby,tabid,uf_zzfwrkpz_qy);
if(count>0){ // if(count>0){
errcount++; // errcount++;
} // }
}else{ }else{
String code = insertTabData(employeeId,name,i+"",groupId,sourceType,uf_zzfwrktaby_qy);
if("200".equals(code)){ EBDataReqDto ebDataReqDto = new EBDataReqDto();
tabid = getTabId(employeeId,name,groupId,sourceType,uf_zzfwrktaby_qy); List<EBDataReqDetailDto> mainData = Lists.newArrayList();
log.error("tabid2:"+tabid); mainData.add(new EBDataReqDetailDto(field_ry, employeeId));
if(StringUtils.isNotBlank(tabid)){ mainData.add(new EBDataReqDetailDto(field_tabymmc, name));
int count = initCustomServiceDataByType(employeeId,groupId,sourceType,taby,tabid,uf_zzfwrkpz_qy); mainData.add(new EBDataReqDetailDto(field_qy, uf_zzfwrktaby_qy));
if(count>0){ mainData.add(new EBDataReqDetailDto(field_xssx, i+""));
errcount++; ebDataReqDto.setMainDatas(mainData);
} EBDataReqDtoList.add(ebDataReqDto);
} log.error("EBDataReqDtoList:"+EBDataReqDtoList.size());
}else{ if(EBDataReqDtoList !=null && EBDataReqDtoList.size()>0){
errcount++; jucailinPortalUtils.saveModeData(objId,employeeId,tenant_key,EBDataReqDtoList);
} }
} }
} }
@ -520,6 +531,15 @@ public class SelfServiceInfoCmd {
public int initCustomServiceDataByType(String employeeId,String groupId,String sourceType,String selectvalue,String tabid,String uf_zzfwrktaby_qy){ public int initCustomServiceDataByType(String employeeId,String groupId,String sourceType,String selectvalue,String tabid,String uf_zzfwrktaby_qy){
int errcount = 0 ; int errcount = 0 ;
String field_ry = "977242052157390850";
String field_fwmc = "977686396664430594";
String field_fwdz = "977686396664430595";
String field_fwtb = "977686869110833154";
String field_qy = "977703984547119105";
String field_xssx = "981394744418861058";
String objId = "977240471802363909";
try{ try{
String sql =" select t.taby,t.fwtb,t.fwmc,t.fwdz " + String sql =" select t.taby,t.fwtb,t.fwmc,t.fwdz " +
" from uf_zzfwcsh t \n" + " from uf_zzfwcsh t \n" +
@ -537,15 +557,29 @@ public class SelfServiceInfoCmd {
log.error("initCustomServiceDataByType--recordList:"+recordList.size()); log.error("initCustomServiceDataByType--recordList:"+recordList.size());
List<EBDataReqDto> EBDataReqDtoList = Lists.newArrayList();
for(int i=0;i<recordList.size();i++){ for(int i=0;i<recordList.size();i++){
Map<String,Object> recordMap = recordList.get(i); Map<String,Object> recordMap = recordList.get(i);
String fwtb = String.valueOf(recordMap.get("fwtb")); String fwtb = String.valueOf(recordMap.get("fwtb"));
String fwmc = String.valueOf(recordMap.get("fwmc")); String fwmc = String.valueOf(recordMap.get("fwmc"));
String fwdz = String.valueOf(recordMap.get("fwdz")); String fwdz = String.valueOf(recordMap.get("fwdz"));
String code = insertCustomServiceData(employeeId,fwmc,fwdz,fwtb,i+"",groupId,sourceType,tabid,uf_zzfwrktaby_qy);
if(!"200".equals(code)){ EBDataReqDto ebDataReqDto = new EBDataReqDto();
errcount++; List<EBDataReqDetailDto> mainData = Lists.newArrayList();
mainData.add(new EBDataReqDetailDto(field_ry, employeeId));
mainData.add(new EBDataReqDetailDto(field_fwmc, fwmc));
mainData.add(new EBDataReqDetailDto(field_fwdz, fwdz));
mainData.add(new EBDataReqDetailDto(field_fwtb, fwtb));
mainData.add(new EBDataReqDetailDto(field_qy, uf_zzfwrktaby_qy));
mainData.add(new EBDataReqDetailDto(field_xssx, i+""));
ebDataReqDto.setMainDatas(mainData);
EBDataReqDtoList.add(ebDataReqDto);
} }
if(EBDataReqDtoList !=null && EBDataReqDtoList.size()>0){
jucailinPortalUtils.saveModeData(objId,employeeId,tenant_key,EBDataReqDtoList);
} }
}catch (Exception e){ }catch (Exception e){
errcount++; errcount++;
@ -589,6 +623,33 @@ public class SelfServiceInfoCmd {
// List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramlist); // List<SqlParamEntity> sqlparam = databaseUtils.getSqlParamEntity(paramlist);
// Map<String, Object> result = databaseUtils.executeForQuery(sourceType, groupId, sql,sqlparam); // 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) " + 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)"; " 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); Map<String, Object> result = databaseUtils.execute(sourceType, groupId, sql);

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

@ -9,18 +9,20 @@ import com.weaver.common.hrm.service.HrmCommonEmployeePlusService;
import com.weaver.common.hrm.util.HrmCommonUtil; import com.weaver.common.hrm.util.HrmCommonUtil;
import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity; import com.weaver.ebuilder.datasource.api.entity.SqlParamEntity;
import com.weaver.ebuilder.datasource.api.enums.SqlParamType; import com.weaver.ebuilder.datasource.api.enums.SqlParamType;
import com.weaver.ebuilder.form.client.entity.data.*;
import com.weaver.em.msg.api.entity.Request; import com.weaver.em.msg.api.entity.Request;
import com.weaver.em.msg.api.entity.Response; import com.weaver.em.msg.api.entity.Response;
import com.weaver.framework.rpc.annotation.RpcReference; import com.weaver.framework.rpc.annotation.RpcReference;
import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.teams.security.context.UserContext; import com.weaver.teams.security.context.UserContext;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.compress.utils.Lists;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import com.weaver.ebuilder.form.client.service.data.RemoteSimpleDataService;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
@ -44,6 +46,9 @@ public class JucailinPortalUtils {
@Autowired @Autowired
private HrmCommonUtil hrmCommonUtil; private HrmCommonUtil hrmCommonUtil;
@RpcReference(group="ebuilderform")
private RemoteSimpleDataService remoteSimpleDataService;
public String getUfPropData(String pkey,String tenant_key) { public String getUfPropData(String pkey,String tenant_key) {
String pvalue = "" ; String pvalue = "" ;
String groupId = "weaver-ebuilder-form-service"; String groupId = "weaver-ebuilder-form-service";
@ -601,6 +606,43 @@ public class JucailinPortalUtils {
return simpleEmployee; return simpleEmployee;
} }
// objid = 977243418007322629
// operator = 6488080121949444347
public void saveModeData(String objId,String operator,String tenant_key,List<EBDataReqDto> datas){
EBDataChangeReqDto ebDataChangeReqDto = new EBDataChangeReqDto();
// 构建基础参数; objId 表单id, operator 操作人, tenantKey 租户
ebDataChangeReqDto.setHeader(new EBDataReqHeader(objId, operator,tenant_key));
// 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);
ebDataChangeReqDto.setDatas(datas);
EBDataChangeResult ebDataChangeResult = remoteSimpleDataService.saveFormData(ebDataChangeReqDto);
log.error("ebDataChangeResult:"+ebDataChangeResult.getMessage());
log.error("ebDataChangeResult:"+ebDataChangeResult.toString());
log.error("ebDataChangeResult:"+ebDataChangeResult.getStatus());
}
} }

Write Preview
Loading…
Cancel
Save