diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java b/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java index c65f9bc..0cc65eb 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/htpoex/msgRecv.java @@ -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 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 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 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 paramMap) { + } + // public void setList(List paramList) { // } -// -// private void sendMsg(MessageBean msg, BaseBean log) { -// try { -// String systemId = "SYS006"; -// String password = "123456"; -// String moudule = "流程待办"; -// String 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 = ""; + 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("
", " "); -// msgtt = meetingmsg + msgtt + " " + content; -// } -// if ("通知公告".equals(moudule)) { -// content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("
", " "); -// 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 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 + ""; -// messages = messages + "" + msgid + "" + pre + "" + user + "" + msgtt + "" + msgtt + "" + sendname + "" + refurl + "" + msgtime + "" + target + "" + extdata + ""; -// messages = messages + ""; -// if (!"流程待办".equals(moudule)) { -// String pctarget = "1"; -// pre = msgid; -// msgid = "MsgPCSYS006" + userid + (new Date()).getTime(); -// messages = messages + ""; -// messages = messages + "" + msgid + "" + pre + "" + user + "" + msgtt + "" + msgtt + "" + sendname + "" + pcurl + "" + msgtime + "" + pctarget + "" + extdata + ""; -// messages = 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 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("
", " "); + msgtt = meetingmsg + msgtt + " " + content; + } + if ("通知公告".equals(moudule)) { + content = content.substring(content.indexOf("~`~`7") + 6, content.indexOf("`~`8")).replaceAll("
", " "); + 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 useridset = msg.getRecivers(); + List 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 + ""; + messages = messages + "" + msgid + "" + pre + "" + user + "" + msgtt + "" + msgtt + "" + sendname + "" + refurl + "" + msgtime + "" + target + "" + extdata + ""; + messages = messages + ""; + if (!"流程待办".equals(moudule)) { + String pctarget = "1"; + pre = msgid; + msgid = "MsgPCSYS006" + userid + (new Date()).getTime(); + messages = messages + ""; + messages = messages + "" + msgid + "" + pre + "" + user + "" + msgtt + "" + msgtt + "" + sendname + "" + pcurl + "" + msgtime + "" + pctarget + "" + extdata + ""; + messages = 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 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())); + } + } +} diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/k3/CallPORequestService.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/k3/CallPORequestService.java index 1b29733..37a23ca 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/k3/CallPORequestService.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/k3/CallPORequestService.java @@ -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(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3PORequestAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3PORequestAction.java index 54237a7..845e3e1 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3PORequestAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3PORequestAction.java @@ -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())); } } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java index 749981a..5d9d9ba 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java @@ -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 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 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 normalRes = MessageService.sendMsg(messageVo, host, null); + System.out.println(JSONObject.toJSONString(normalRes)); + System.out.println(normalRes.getData()); + } + }