标签：06 String get kd 2021 new import paramMap 07
代码
package kd.bos.lianmei.plugin;
import java.io.IOException;
import java.util.ArrayList;
import java.util.EventObject;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import kd.bos.algo.DataSet;
import kd.bos.algo.Row;
import kd.bos.context.RequestContext;
import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.dataentity.entity.DynamicObjectCollection;
import kd.bos.db.DB;
import kd.bos.db.DBRoute;
import kd.bos.entity.AppMetadataCache;
import kd.bos.form.control.events.ClickListener;
import kd.bos.form.control.events.ItemClickEvent;
import kd.bos.orm.query.QCP;
import kd.bos.orm.query.QFilter;
import kd.bos.service.DispatchService;
import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.QueryServiceHelper;
import kd.fi.bcm.business.olap.OlapSaveBuilder;
import kd.fi.bcm.common.Pair;
import kd.fi.bcm.formplugin.report.ReportListPlugin;
import kd.bos.servicehelper.permission.PermissionServiceHelper;
/**
* 0调用api代码中，登录用户写死，值为【kingdee】
* 1对“同步报表”按钮设置权限
* 2通过组织成员基本信息中“报表合并”获取组织
* 3解决跨库查fi库的表数据
* 请求服务节点B，获取B-Olap数据后，新增数据到A-Olap（联美->联美量子）
* @author chens
*
*/
public class LmPlugin extends ReportListPlugin implements ClickListener {
private final static String KEY_BUTTON = "lm_getdata";//联美按钮
//体系编码
private final static String CubeNum = "CUBELM0011094912461905123328";//联美
//第三应用/系统编码
private final static String AppId = "OlapData";//联美量子
//第三应用/系统密码
private final static String AppSecuret = "1234567890qwerty";//联美量子
//管理中心/数据中心ID
private final static String AccountId = "1561691182942805408";//联美量子
//管理中心/租户id
private final static String Tenantid = "luenmeilz";//联美量子
private final static String BaseUrl = "https://luenmeilz.kdcloud.com";//联美量子
private final static String GetAppTokenUrl = BaseUrl+"/api/getAppToken.do";
private final static String GetAccessTokenUrl=BaseUrl+"/api/login.do";
private final static String GetOlapDataUrl=BaseUrl+"/kapi/app/cm/GetOlapData";
/**
* 控件添加监听事件/注册控件事件
* 1.获取控件（控件在View层）
* 2.给控件添加监听
*/
@Override
public void registerListener(EventObject e) {
// TODO Auto-generated method stub
super.registerListener(e);
//按钮点击事件监听
this.addItemClickListeners(KEY_BUTTON);
}
/**
* 用户点击按钮所带的子按钮时，触发此事件
*/
@Override
public void itemClick(ItemClickEvent evt) {
super.itemClick(evt);
String key=evt.getItemKey();
if(StringUtils.equals(key, KEY_BUTTON)) {
//当前用户对按钮是否有权限
long userId = Long.parseLong(RequestContext.get().getUserId()); //用户ID
RequestContext.get().getUserName();
String KEY_APPID = "lm_cm_ext";
String appId = AppMetadataCache.getAppInfo(KEY_APPID).getAppId(); //应用ID
String entityNum = "bcm_report_list"; //实体标识
String permItemId = ""; //权限项ID
String permItemNum = "tbbb";//权限项编码
String permItemEntity = "perm_permitem";//权限项实体名
DynamicObjectCollection dynObjColl = QueryServiceHelper.query(permItemEntity, "id", new QFilter[]{new QFilter("number", QFilter.equals, permItemNum)});
for(DynamicObject dynObj:dynObjColl) {
permItemId = dynObj.getString("id");
}
Boolean hasSpecificPerm = PermissionServiceHelper.hasSpecificPerm(userId, appId, entityNum, permItemId);
if(!hasSpecificPerm) {
this.getView().showErrorNotification("您没有此操作权限！");
return;
}
//获取参数 年、月、组织
DynamicObject yearDynamicObject= (DynamicObject)this.getModel().getValue("year");
DynamicObject periodDynamicObject= (DynamicObject)this.getModel().getValue("period");
if(yearDynamicObject == null || periodDynamicObject == null) {
this.getView().showErrorNotification("请选择财年和期间！");
return;
}
String year =yearDynamicObject.getString("number");
String period = periodDynamicObject.getString("number");
List<String> entityList = new ArrayList();
//获取组织
String entityName = "bcm_entitymembertree";
String selectFields = "number";
QFilter[] filters = {new QFilter("lm_tbbb",QCP.equals,"1"),new QFilter("storagetype",QCP.equals,"2")};
DynamicObject[] rows = BusinessDataServiceHelper.load(entityName, selectFields, filters);
// 递归读取子实体各行的属性值
for (DynamicObject row : rows){
entityList.add(row.getString("number"));
}
if(!(entityList!=null && entityList.size()>0)) {
this.getView().showErrorNotification("没有找到需要同步报表的组织！请检查组织成员基本信息中“同步报表”是否勾选！");
return;
}
//发送请求
Map<String, Object> paramMap = new HashMap<>();
Map<String, Object> resultMap = new HashMap();
List<Map> resultList = new ArrayList();
String result ="";
//获取appToken
String appToken = "";
resultMap = new HashMap();
paramMap = new HashMap<>();
paramMap.put("appId", AppId);
paramMap.put("appSecuret", AppSecuret);
paramMap.put("accountId", AccountId);
try {
result = postData(GetAppTokenUrl, paramMap, "UTF-8");
resultMap = toMap(result);
appToken =( (Map<String, String>) resultMap.get("data")).get("app_token");
} catch (Exception e) {
e.printStackTrace();
}
//获取accessToken
String accessToken = "";
paramMap = new HashMap<>();
String user = RequestContext.get().getUserName();
paramMap.put("user","kingdee");//用户名称/手机号/邮箱
paramMap.put("apptoken", appToken);
paramMap.put("tenantid", Tenantid);//租户id
paramMap.put("accountId", AccountId);
paramMap.put("usertype", "UserName");
try {
result = postData(GetAccessTokenUrl, paramMap, "UTF-8");
resultMap = toMap(result);
accessToken =( (Map<String, String>) resultMap.get("data")).get("access_token");
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//获取多维数据
paramMap = new HashMap<>();
paramMap.put("year",year );
paramMap.put("period", period);
paramMap.put("entity",entityList);
paramMap.put("accessToken", accessToken);
try {
result = postData(GetOlapDataUrl, paramMap, "UTF-8");
resultList = toList(result);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
resultMap = toMap(result);
if(resultMap.get("success").equals("true")) {
//新增数据到A-Olap
OlapSaveBuilder save = new OlapSaveBuilder(CubeNum);
save.setCrossDimensions(new String[]{"Account","Scenario","Process","AuditTrail","Year","Currency","ChangeType","Entity","Period","InternalCompany","ZH"});
save.setMeasures("FMONEY");
List<Pair<String[], Object>> saveValPairs = new ArrayList<>();
//多个值则for循环加
for(Map<String,String> itemMap:resultList){
saveValPairs.add(Pair.onePair(new String[]{itemMap.get("Account"),itemMap.get("Scenario"),itemMap.get("Process"),itemMap.get("AuditTrail"),itemMap.get("Year"),itemMap.get("Currency"),itemMap.get("ChangeType"),itemMap.get("Entity"),itemMap.get("Period"),itemMap.get("InternalCompany"),itemMap.get("ZH")},itemMap.get("FMONEY") ));
}
save.setCellSet(saveValPairs);
save.doSave();
this.getView().showSuccessNotification("同步成功，数据"+resultList.size()+"条！");
}else {
if(resultMap.get("error_desc")!=null) {
this.getView().showErrorNotification(resultMap.get("error_desc").toString());
}else {
this.getView().showErrorNotification("同步失败");
}
}
}
}
/**
* 发起post请求 有参数的情况
* @param url
* @param params
* @param codePage
* @return
* @throws Exception
*/
private synchronized static String postData(String url, Map<String, Object> params, String codePage) throws Exception {
//创建post请求对象
HttpPost httppost = new HttpPost(url);
// 获取到httpclient客户端
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
//创建参数集合
List<BasicNameValuePair> list = new ArrayList<BasicNameValuePair>();
//添加请求头参数
if(url.equals(GetOlapDataUrl)) {
httppost.addHeader("Content-Type", "application/json");
httppost.addHeader("accessToken",params.get("accessToken").toString());
}
// 设置请求的一些配置设置，主要设置请求超时，连接超时等参数
RequestConfig requestConfig = RequestConfig.custom()
.setConnectTimeout(10000).setConnectionRequestTimeout(10000).setSocketTimeout(10000)
.build();
httppost.setConfig(requestConfig);
//添加参数
httppost.setEntity(new StringEntity(JSONObject.toJSONString(params), ContentType.create("application/json", codePage)));
// 请求结果
String resultString = "";
//启动执行请求，并获得返回值
CloseableHttpResponse response = httpclient.execute(httppost);
if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
// 获取请求响应结果
HttpEntity entity = response.getEntity();
if (entity != null) {
// 将响应内容转换为指定编码的字符串
resultString = EntityUtils.toString(entity, codePage);
System.out.printf("Response content:{}", resultString);
return resultString;
}
} else {
System.out.println("请求失败！");
return resultString;
}
} catch (Exception e) {
throw e;
} finally {
httpclient.close();
}
return null;
}
/**
* 将str转化为Map<String, Object>
* @param str
* @return
*/
private static Map<String, Object> toMap(String str) {
Map<String, Object> data = new HashMap();
// 将json字符串转换成jsonObject
net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(str);
Iterator json = jsonObject.keys();
// 遍历jsonObject数据,添加到Map对象
while (json.hasNext()) {
String key = json.next().toString();
String value = jsonObject.get(key).toString();
if(value.startsWith("{")) {
net.sf.json.JSONObject itemJsonObject = net.sf.json.JSONObject.fromObject(value);
Iterator itemJson = itemJsonObject.keys();
Map<String, String> itemData = new HashMap<String, String>();
while (itemJson.hasNext()) {
String itemKey = itemJson.next().toString();
String itemValue = itemJsonObject.get(itemKey).toString();
itemData.put(itemKey, itemValue);
}
data.put(key, itemData);
}else {
data.put(key, value);
}
}
return data;
}
/**
* 将str转化为List<Map>
* @param str
* @return
*/
private static List<Map> toList(String str) {
List<Map> resultList = new ArrayList();
// 将json字符串转换成jsonObject
JSONObject jsonObject = JSONObject.parseObject(str);//转换成JSON格式
JSONArray records = JSONObject.parseArray(jsonObject.get("data").toString());
if (!records.isEmpty()) {//如果返回的数据不为空
resultList = JSONArray.parseArray(records.toJSONString(), Map.class);//转换成对象
}
return resultList;
}
}
标签：06,String,get,kd,2021,new,import,paramMap,07 来源： https://blog.csdn.net/CHENCALL111/article/details/117661563
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。