rj
/
ht
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/ht' into ht

Browse Source
webservice
calyrex 3 months ago
parent dfb9427eea 33ce7263ae
commit 8a587ba494
4 changed files with 280 additions and 207 deletions
Show Stats Download Patch File Download Diff File

419
secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java
Unescape Escape View File

@ -1,211 +1,224 @@
////
//// Source code recreated from a .class file by IntelliJ IDEA
//// (powered by Fernflower decompiler)
////
//package com.weaver.seconddev.htpoex;
//
//import com.alibaba.fastjson.JSONArray;
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//
package com.weaver.seconddev.htpoex;
import com.alibaba.fastjson.JSONArray;
//import com.cloudstore.dev.api.bean.MessageBean;
//import com.weaver.base.msgcenter.channel.IMessageReceive;
//import java.net.URLEncoder;
//import java.text.SimpleDateFormat;
//import java.util.Date;
//import java.util.Hashtable;
//import java.util.Iterator;
//import java.util.List;
//import java.util.Map;
//import java.util.Set;
//import javax.xml.namespace.QName;
//import javax.xml.rpc.ParameterMode;
//import javax.xml.rpc.encoding.XMLType;
//import org.apache.axis.client.Call;
//import org.apache.axis.client.Service;
//import com.weaver.common.i18n.tool.util.I18nContextUtil;
//import org.springframework.core.env.Environment;
//import java.lang.*;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import com.weaver.verupgrade.general.BaseBean;
//import com.weaver.verupgrade.hrm.resource.ResourceComInfo;
//
///**
// * eip消息推送 门户消息推送
// * WeaReceiveManager 消息推送类 加载ECOLOGY_MESSAGE_SUBSCRIBE 表的实现类 WeaReceiveAQ调 队列调用实现类的
// * onMessage方法
// */
//public class msgRecv implements IMessageReceive {
//
// public static final org.slf4j.Logger logger_d01caf55 = LoggerFactory.getLogger(msgRecv.class);
//
// public msgRecv() {
// }
//
// public void onMessage(String paramString) {
// BaseBean log = new BaseBean();
// logger_d01caf55.info(String.valueOf(">---onMessage---\n"));
// logger_d01caf55.info(String.valueOf(paramString + "\n"));
// List<MessageBean> localList = JSONArray.parseArray(paramString, MessageBean.class);
// if (localList != null) {
// Iterator var4 = localList.iterator();
// while (var4.hasNext()) {
// MessageBean messageBean = (MessageBean) var4.next();
// this.sendMsg(messageBean, log);
// }
// }
// }
//
// public void onStart() {
// }
//
// public void onEnd() {
// }
//
// public void setProp(Map<String, String> paramMap) {
// }
//
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.xml.namespace.QName;
import javax.xml.rpc.ParameterMode;
import javax.xml.rpc.encoding.XMLType;
import com.weaver.openapi.pojo.message.params.MessageVo;
import com.weaver.openapi.pojo.message.params.vo.MessageReciver;
import com.weaver.seconddev.interfaces.prop.ConfigProp;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import java.lang.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.weaver.verupgrade.general.BaseBean;
import com.weaver.verupgrade.hrm.resource.ResourceComInfo;
/**
* eip消息推送 门户消息推送
* WeaReceiveManager 消息推送类 加载ECOLOGY_MESSAGE_SUBSCRIBE 表的实现类 WeaReceiveAQ调 队列调用实现类的
* onMessage方法
*/
public class msgRecv {
public static final org.slf4j.Logger logger_d01caf55 = LoggerFactory.getLogger(msgRecv.class);
@Autowired
private ConfigProp configProp;
public msgRecv() {
}
public void onMessage(String paramString) {
BaseBean log = new BaseBean();
logger_d01caf55.info(String.valueOf(">---onMessage---\n"));
logger_d01caf55.info(String.valueOf(paramString + "\n"));
List<MessageVo> localList = JSONArray.parseArray(paramString, MessageVo.class);
if (localList != null) {
Iterator var4 = localList.iterator();
while (var4.hasNext()) {
MessageVo messageBean = (MessageVo) var4.next();
this.sendMsg(messageBean, log);
}
}
}
public void onStart() {
}
public void onEnd() {
}
public void setProp(Map<String, String> paramMap) {
}
// public void setList(List<IMessageReceive> paramList) {
// }
//
// private void sendMsg(MessageBean msg, BaseBean log) {
// try {
// String systemId = "SYS006";
// String password = "123456";
// String moudule = "流程待办";
// String messages = "<messages>";
// logger_d01caf55.info(String.valueOf("code:" + msg.getMessageType().getCode()));
// int code = msg.getMessageType().getCode();
// String meetingmsg = "";
// switch(code) {
// case 19:
// case 20:
// case 21:
// case 22:
// case 23:
// case 24:
// case 25:
// break;
// case 60:
// moudule = "通知公告";
// break;
// case 124:
// moudule = "会议";
// meetingmsg = "您有一个新的会议，会议名称：";
// break;
// case 125:
// moudule = "会议";
// meetingmsg = "您有一个会议即将开始，会议名称：";
// break;
// case 127:
// moudule = "会议";
// meetingmsg = "您有一个会议已取消，会议名称：";
// break;
// case 137:
// moudule = "会议";
// meetingmsg = "您有一个会议已变更，会议名称：";
// break;
// case 579:
// moudule = "接待日历";
// break;
// default:
// return;
// }
// logger_d01caf55.info(String.valueOf(moudule));
// String content = msg.getContext();
// String url = msg.getLinkUrl();
// String mobileurl = msg.getLinkMobileUrl();
// // TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.pc_url 维护到weaver-secondev-service.properties中
private void sendMsg(MessageVo msg, BaseBean log) {
try {
String systemId = "SYS006";
String password = "123456";
String moudule = "流程待办";
String messages = "<messages>";
logger_d01caf55.info(String.valueOf("code:" + msg.getEventId()));
int code = msg.getEventId();
String meetingmsg = "";
switch(code) {
case 19:
case 20:
case 21:
case 22:
case 23:
case 24:
case 25:
break;
case 60:
moudule = "通知公告";
break;
case 124:
moudule = "会议";
meetingmsg = "您有一个新的会议，会议名称：";
break;
case 125:
moudule = "会议";
meetingmsg = "您有一个会议即将开始，会议名称：";
break;
case 127:
moudule = "会议";
meetingmsg = "您有一个会议已取消，会议名称：";
break;
case 137:
moudule = "会议";
meetingmsg = "您有一个会议已变更，会议名称：";
break;
case 579:
moudule = "接待日历";
break;
default:
return;
}
logger_d01caf55.info(String.valueOf(moudule));
String content = msg.getText();
String url = msg.getEntity().getPcUrl();
String mobileurl = msg.getEntity().getH5Url();
// TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.pc_url 维护到weaver-secondev-service.properties中
// String pcurl = I18nContextUtil.getBean(Environment.class).getProperty("htportaloaUrl.pc_url") + URLEncoder.encode(url);
// // TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.pc_url 维护到weaver-secondev-service.properties中
String pcurl = configProp.getPc_url()+ URLEncoder.encode(url);
// TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.pc_url 维护到weaver-secondev-service.properties中
// String msgurl = I18nContextUtil.getBean(Environment.class).getProperty("htportaloaUrl.pc_url") + URLEncoder.encode(mobileurl);
// String m_msgtitle = msg.getTitle();
// int sendid = msg.getCreater();
// String sendname = "系统管理员";
// ResourceComInfo rc = I18nContextUtil.getBean(ResourceComInfo.class);
// String userid = "1";
// if (sendid != 1) {
// sendname = rc.getLastname(sendid + "");
// userid = rc.getWorkcode(sendid + "");
// }
// String pre = "";
// String msgtt = m_msgtitle;
// if (m_msgtitle.contains("~`~`7")) {
// msgtt = m_msgtitle.substring(m_msgtitle.indexOf("~`~`7") + 6, m_msgtitle.indexOf("`~`8"));
// }
// if ("会议".equals(moudule)) {
// content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("<br/>", " ");
// msgtt = meetingmsg + msgtt + " " + content;
// }
// if ("通知公告".equals(moudule)) {
// content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("<br/>", " ");
// msgtt = "您有新的待阅文档：" + msgtt;
// }
// String refurl;
// if ("流程待办".equals(moudule)) {
// refurl = msg.getDetailTitle();
// if (refurl.contains("~`~`7")) {
// refurl = refurl.substring(refurl.indexOf("~`~`7") + 6, refurl.indexOf("`~`8"));
// msgtt = refurl + "：" + msgtt;
// }
// }
// logger_d01caf55.info(String.valueOf(content));
// logger_d01caf55.info(String.valueOf(msgtt));
// refurl = msgurl;
// SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// String msgtime = df.format(new Date());
// String target = "2";
// String extdata = "";
// Set<String> useridset = msg.getUserList();
// Object[] arr = useridset.toArray();
// for (int i = 0; i < arr.length; i += 100) {
// StringBuilder sb = new StringBuilder();
// for (int j = i; j < i + 100 && j < arr.length; ++j) {
// sb.append(rc.getWorkcode(arr[j] + "") + ",");
// }
// String user = sb.toString().substring(0, sb.length() - 1);
// String msgid = "MsgSYS006" + userid + (new Date()).getTime();
// messages = messages + "<message>";
// messages = messages + "<MSG_ID>" + msgid + "</MSG_ID><PRE_MSG_ID>" + pre + "</PRE_MSG_ID><USER_ID>" + user + "</USER_ID><MSG_TITLE>" + msgtt + "</MSG_TITLE><MSG_CONTENT>" + msgtt + "</MSG_CONTENT><SENDER_NAME>" + sendname + "</SENDER_NAME><REF_URL>" + refurl + "</REF_URL><MSG_TIME>" + msgtime + "</MSG_TIME><TARGET>" + target + "</TARGET><EXT_DATA>" + extdata + "</EXT_DATA>";
// messages = messages + "</message>";
// if (!"流程待办".equals(moudule)) {
// String pctarget = "1";
// pre = msgid;
// msgid = "MsgPCSYS006" + userid + (new Date()).getTime();
// messages = messages + "<message>";
// messages = messages + "<MSG_ID>" + msgid + "</MSG_ID><PRE_MSG_ID>" + pre + "</PRE_MSG_ID><USER_ID>" + user + "</USER_ID><MSG_TITLE>" + msgtt + "</MSG_TITLE><MSG_CONTENT>" + msgtt + "</MSG_CONTENT><SENDER_NAME>" + sendname + "</SENDER_NAME><REF_URL>" + pcurl + "</REF_URL><MSG_TIME>" + msgtime + "</MSG_TIME><TARGET>" + pctarget + "</TARGET><EXT_DATA>" + extdata + "</EXT_DATA>";
// messages = messages + "</message>";
// }
// }
// messages = messages + "</messages>";
// logger_d01caf55.info(String.valueOf(messages));
// String typeNamespace = "http://message.ht_portal_webservice.com";
// String endpoint = "https://sappop.htgd.com.cn:50001/XISOAPAdapter/MessageServlet?senderParty=&senderService=BS_HTU_POP&receiverParty=&receiverService=&interface=SI_HTPortalMessage_OUT&interfaceNamespace=http%3A%2F%2Fhengtong.com%2FHTU%2FHTPortalMessage";
// Service service = new Service();
// Call call = (Call) service.createCall();
// call.setTimeout(300000);
// call.setTargetEndpointAddress(endpoint);
// call.setOperationName(new QName(typeNamespace, "message"));
// call.addParameter(new QName(typeNamespace, "systemId"), XMLType.XSD_STRING, ParameterMode.IN);
// call.addParameter(new QName(typeNamespace, "password"), XMLType.XSD_STRING, ParameterMode.IN);
// call.addParameter(new QName(typeNamespace, "moudule"), XMLType.XSD_STRING, ParameterMode.IN);
// call.addParameter(new QName(typeNamespace, "messages"), XMLType.XSD_STRING, ParameterMode.IN);
// call.setReturnClass(String.class);
// call.setReturnQName(new QName(typeNamespace, "messageResponse"));
// call.setUseSOAPAction(true);
// call.setSOAPActionURI("http://sap.com/xi/WebService/soap1.1");
// Hashtable<String, String> headers = (Hashtable) call.getProperty("HTTP-Request-Headers");
// if (headers == null) {
// headers = new Hashtable();
// call.setProperty("HTTP-Request-Headers", headers);
// }
// // TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.url_password 维护到weaver-secondev-service.properties中
String msgurl = configProp.getPc_url()+ URLEncoder.encode(mobileurl);
String m_msgtitle = msg.getTitle();
String sendid = msg.getSender().getEmployeeId();
String sendname = "系统管理员";
ResourceComInfo rc = I18nContextUtil.getBean(ResourceComInfo.class);
String userid = "1";
if (sendid != "1") {
sendname = rc.getLastname(sendid + "");
userid = rc.getWorkcode(sendid + "");
}
String pre = "";
String msgtt = m_msgtitle;
if (m_msgtitle.contains("~`~`7")) {
msgtt = m_msgtitle.substring(m_msgtitle.indexOf("~`~`7") + 6, m_msgtitle.indexOf("`~`8"));
}
if ("会议".equals(moudule)) {
content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("<br/>", " ");
msgtt = meetingmsg + msgtt + " " + content;
}
if ("通知公告".equals(moudule)) {
content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("<br/>", " ");
msgtt = "您有新的待阅文档：" + msgtt;
}
String refurl;
if ("流程待办".equals(moudule)) {
refurl = msg.getTitle();
if (refurl.contains("~`~`7")) {
refurl = refurl.substring(refurl.indexOf("~`~`7") + 6, refurl.indexOf("`~`8"));
msgtt = refurl + "：" + msgtt;
}
}
logger_d01caf55.info(String.valueOf(content));
logger_d01caf55.info(String.valueOf(msgtt));
refurl = msgurl;
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String msgtime = df.format(new Date());
String target = "2";
String extdata = "";
// Set<String> useridset = msg.getRecivers();
List<MessageReciver> useridset = msg.getRecivers();
Object[] arr = useridset.toArray();
for (int i = 0; i < arr.length; i += 100) {
StringBuilder sb = new StringBuilder();
for (int j = i; j < i + 100 && j < arr.length; ++j) {
sb.append(rc.getWorkcode(arr[j] + "") + ",");
}
String user = sb.toString().substring(0, sb.length() - 1);
String msgid = "MsgSYS006" + userid + (new Date()).getTime();
messages = messages + "<message>";
messages = messages + "<MSG_ID>" + msgid + "</MSG_ID><PRE_MSG_ID>" + pre + "</PRE_MSG_ID><USER_ID>" + user + "</USER_ID><MSG_TITLE>" + msgtt + "</MSG_TITLE><MSG_CONTENT>" + msgtt + "</MSG_CONTENT><SENDER_NAME>" + sendname + "</SENDER_NAME><REF_URL>" + refurl + "</REF_URL><MSG_TIME>" + msgtime + "</MSG_TIME><TARGET>" + target + "</TARGET><EXT_DATA>" + extdata + "</EXT_DATA>";
messages = messages + "</message>";
if (!"流程待办".equals(moudule)) {
String pctarget = "1";
pre = msgid;
msgid = "MsgPCSYS006" + userid + (new Date()).getTime();
messages = messages + "<message>";
messages = messages + "<MSG_ID>" + msgid + "</MSG_ID><PRE_MSG_ID>" + pre + "</PRE_MSG_ID><USER_ID>" + user + "</USER_ID><MSG_TITLE>" + msgtt + "</MSG_TITLE><MSG_CONTENT>" + msgtt + "</MSG_CONTENT><SENDER_NAME>" + sendname + "</SENDER_NAME><REF_URL>" + pcurl + "</REF_URL><MSG_TIME>" + msgtime + "</MSG_TIME><TARGET>" + pctarget + "</TARGET><EXT_DATA>" + extdata + "</EXT_DATA>";
messages = messages + "</message>";
}
}
messages = messages + "</messages>";
logger_d01caf55.info(String.valueOf(messages));
String typeNamespace = "http://message.ht_portal_webservice.com";
String endpoint = "https://sappop.htgd.com.cn:50001/XISOAPAdapter/MessageServlet?senderParty=&senderService=BS_HTU_POP&receiverParty=&receiverService=&interface=SI_HTPortalMessage_OUT&interfaceNamespace=http%3A%2F%2Fhengtong.com%2FHTU%2FHTPortalMessage";
Service service = new Service();
Call call = (Call) service.createCall();
call.setTimeout(300000);
call.setTargetEndpointAddress(endpoint);
call.setOperationName(new QName(typeNamespace, "message"));
call.addParameter(new QName(typeNamespace, "systemId"), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new QName(typeNamespace, "password"), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new QName(typeNamespace, "moudule"), XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new QName(typeNamespace, "messages"), XMLType.XSD_STRING, ParameterMode.IN);
call.setReturnClass(String.class);
call.setReturnQName(new QName(typeNamespace, "messageResponse"));
call.setUseSOAPAction(true);
call.setSOAPActionURI("http://sap.com/xi/WebService/soap1.1");
Hashtable<String, String> headers = (Hashtable) call.getProperty("HTTP-Request-Headers");
if (headers == null) {
headers = new Hashtable();
call.setProperty("HTTP-Request-Headers", headers);
}
// TODO 获取配置文件信息发生变化,请将配置内容:htportaloaUrl.url_password 维护到weaver-secondev-service.properties中
// headers.put("Authorization", I18nContextUtil.getBean(Environment.class).getProperty("htportaloaUrl.url_password"));
// Object[] val = new Object[] { systemId, password, moudule, messages };
// String obj = (String) call.invoke(val);
// logger_d01caf55.info(String.valueOf(obj));
// logger_d01caf55.info(String.valueOf("----onMessage--<\n"));
// } catch (Exception var35) {
// var35.printStackTrace();
// logger_d01caf55.info(String.valueOf("推送流程消息出错：" + var35.toString()));
// }
// }
//}
headers.put("Authorization", configProp.getUrl_password());
Object[] val = new Object[] { systemId, password, moudule, messages };
String obj = (String) call.invoke(val);
logger_d01caf55.info(String.valueOf(obj));
logger_d01caf55.info(String.valueOf("----onMessage--<\n"));
} catch (Exception var35) {
var35.printStackTrace();
logger_d01caf55.info(String.valueOf("推送流程消息出错：" + var35.toString()));
}
}
}

2
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/k3/CallPORequestService.java
Unescape Escape View File

@ -18,6 +18,8 @@ public class CallPORequestService extends BaseBean {
@Autowired
private ConfigProp configProp;
public PORequestServiceStub.PORequestRes buildPORequest(PORequestServiceStub.PORequestReq req) {
logger_7febacb3.info(String.valueOf("调用k3采购申请接口开始 "));
PORequestServiceStub.PORequestRes result = new PORequestServiceStub.PORequestRes();
try {
// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("htk3oasync.porequest_url")).trim();

6
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3PORequestAction.java
Unescape Escape View File

@ -177,20 +177,20 @@ public class K3PORequestAction extends BaseBean implements Action, EsbServerless
if (!"1".equals(code)) {
requestInfo.getRequestManager().setMessageid("ERROR");
requestInfo.getRequestManager().setMessagecontent("K3Cloud系统返回错误信息" + message);
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
return WeaResult.fail(500, message, getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
}
logger_7396c45f.info(String.valueOf("K3PORequestAction--end--" + requestID));
} catch (Exception e) {
logger_7396c45f.info(String.valueOf("K3Cloud系统接口失败，请联系K3Cloud系统管理员！"));
requestInfo.getRequestManager().setMessageid("ERROR");
requestInfo.getRequestManager().setMessagecontent("K3Cloud系统返回错误信息接口失败，请联系K3Cloud系统管理员！");
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
return WeaResult.fail(500, e.toString(), getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
}
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestInfo.getRequestManager()));
} catch (Exception e) {
e.printStackTrace();
logger_7396c45f.error("K3PORequestAction e: {}", e.getMessage());
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestInfo.getRequestManager())), requestInfo.getRequestManager()));
return WeaResult.success(getResultMapForAction(weaverResultMap, e.toString(), WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestInfo.getRequestManager())), requestInfo.getRequestManager()));
}
}

60
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java
Unescape Escape View File

@ -1,5 +1,6 @@
package com.weaver.seconddev.interfaces.workflow.controller;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Maps;
import com.weaver.common.authority.annotation.WeaPermission;
import com.weaver.common.base.entity.result.WeaResult;
@ -12,6 +13,17 @@ import com.weaver.ecode.api.rpc.EcodeService;
import com.weaver.framework.client.annotation.WeaverConfigCenter;
import com.weaver.framework.rpc.annotation.RpcReference;
import com.weaver.framework.rpc.context.impl.TenantRpcContext;
import com.weaver.openapi.pojo.ApiResult;
import com.weaver.openapi.pojo.auth.params.AccessTokenParam;
import com.weaver.openapi.pojo.auth.params.CodeParam;
import com.weaver.openapi.pojo.auth.res.AccessToken;
import com.weaver.openapi.pojo.auth.res.Code;
import com.weaver.openapi.pojo.message.params.MessageVo;
import com.weaver.openapi.pojo.message.params.vo.MessageEntity;
import com.weaver.openapi.pojo.message.params.vo.MessageReciver;
import com.weaver.openapi.pojo.message.params.vo.MessageSender;
import com.weaver.openapi.service.AuthService;
import com.weaver.openapi.service.MessageService;
import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.teams.security.context.UserContext;
import com.weaver.teams.security.user.User;
@ -20,7 +32,6 @@ import com.weaver.workflow.common.entity.list.api.publicapi.RequestListInfoPAEnt
import com.weaver.workflow.list.api.rest.publicapi.WflRequestListRest;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.json.JSONObject;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
@ -28,6 +39,7 @@ import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.bind.annotation.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@ -97,5 +109,51 @@ public class ApiController {
}
@GetMapping("/sendmes")
public WeaResult<String> sendmes(@RequestParam("send") String send , @RequestParam("recive") String recive) {
sendcusmes(send, recive);
return WeaResult.success("消息已发送");
}
private static void sendcusmes(String send, String recive){
String corpId = "9d18deb9bbeb98f7a2402808f8bb8ce8";
String host = "http://10.6.23.235:20600";
String appKey = "179a9854c471d161db69ec9f16c6e1e";
String app_secret = "9aa17e9391d8fdf4be44f78e2a26be30";
CodeParam codeParam = new CodeParam(corpId, "code", "xxx");
Code code = AuthService.getAuthCode(codeParam, host, null);
logger.error(" sendcusmes code == "+code.getCode());
AccessTokenParam tokenParam = new AccessTokenParam(appKey, app_secret, "authorization_code", code.getCode());
AccessToken token = AuthService.getAuthAccessToken(tokenParam, host, null);
logger.error(" sendcusmes token == "+token.getAccessToken());
MessageVo messageVo = new MessageVo();
messageVo.setAccessToken(token.getAccessToken());
messageVo.setText("sdk test msg send");
messageVo.setTitle("sdk aaaaaa");
// 定义消息发送者
MessageSender messageSender = new MessageSender(send, "t6kj9c07jr", "sdk小助手");
messageVo.setSender(messageSender);
messageVo.setEventId(8);
messageVo.setModuleId(111);
// 定义消息接收者
List<MessageReciver> reciverList = new ArrayList<>();
MessageReciver messageReciver = new MessageReciver(recive, "t6kj9c07jr");
reciverList.add(messageReciver);
messageVo.setRecivers(reciverList);
// 定义事项
MessageEntity messageEntity = new MessageEntity("123", "third eneity name", "https://127.0.0.1:1000/aaaa", "https://127.0.0.1:1000/h5/aaa");
messageVo.setEntity(messageEntity);
ApiResult<String> normalRes = MessageService.sendMsg(messageVo, host, null);
System.out.println(JSONObject.toJSONString(normalRes));
System.out.println(normalRes.getData());
}
}

Write Preview
Loading…
Cancel
Save