|
|
@ -27,6 +27,7 @@ import com.weaver.workflow.list.api.rest.publicapi.WflRequestListRest;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
import org.apache.axis.client.Call;
|
|
|
|
import org.apache.axis.client.Call;
|
|
|
|
import org.apache.axis.client.Service;
|
|
|
|
import org.apache.axis.client.Service;
|
|
|
|
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
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.beans.factory.annotation.Value;
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
@ -97,7 +98,10 @@ public class MessageSubscriptionController {
|
|
|
|
String m_msgtitle = String.valueOf(params.get("title"));
|
|
|
|
String m_msgtitle = String.valueOf(params.get("title"));
|
|
|
|
String sendid = String.valueOf(params.get("senderId"));
|
|
|
|
String sendid = String.valueOf(params.get("senderId"));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
String receivers = String.valueOf(params.get("receivers")) ;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
logger.error(" receivers: " + receivers);
|
|
|
|
logger.error(" moudule: " + moudule);
|
|
|
|
logger.error(" moudule: " + moudule);
|
|
|
|
logger.error(" pcurl: " + pcurl);
|
|
|
|
logger.error(" pcurl: " + pcurl);
|
|
|
|
logger.error(" msgurl: " + msgurl);
|
|
|
|
logger.error(" msgurl: " + msgurl);
|
|
|
@ -143,8 +147,11 @@ public class MessageSubscriptionController {
|
|
|
|
String target = "2";
|
|
|
|
String target = "2";
|
|
|
|
String extdata = "";
|
|
|
|
String extdata = "";
|
|
|
|
// Set<String> useridset = msg.getRecivers();
|
|
|
|
// Set<String> useridset = msg.getRecivers();
|
|
|
|
String receivers = (String) params.get("receivers") ;
|
|
|
|
|
|
|
|
logger.error(" receivers: " + receivers);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 去除字符串两端的方括号
|
|
|
|
// 去除字符串两端的方括号
|
|
|
|
String trimmed = receivers.substring(1, receivers.length() - 1);
|
|
|
|
String trimmed = receivers.substring(1, receivers.length() - 1);
|
|
|
|
// 使用逗号和空格作为分隔符将字符串拆分成多个子字符串
|
|
|
|
// 使用逗号和空格作为分隔符将字符串拆分成多个子字符串
|
|
|
@ -153,9 +160,11 @@ public class MessageSubscriptionController {
|
|
|
|
List<String> list = new ArrayList<>();
|
|
|
|
List<String> list = new ArrayList<>();
|
|
|
|
// 遍历数组,将每个元素添加到 ArrayList 中
|
|
|
|
// 遍历数组,将每个元素添加到 ArrayList 中
|
|
|
|
for (String num : strArray) {
|
|
|
|
for (String num : strArray) {
|
|
|
|
list.add(num);
|
|
|
|
if(StringUtils.isNotEmpty(num)){
|
|
|
|
|
|
|
|
list.add(num);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
logger.error(" useridset: " + list);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Object[] arr = list.toArray();
|
|
|
|
Object[] arr = list.toArray();
|
|
|
@ -165,6 +174,8 @@ public class MessageSubscriptionController {
|
|
|
|
sb.append(rc.getWorkcode(arr[j] + "") + ",");
|
|
|
|
sb.append(rc.getWorkcode(arr[j] + "") + ",");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
String user = sb.toString().substring(0, sb.length() - 1);
|
|
|
|
String user = sb.toString().substring(0, sb.length() - 1);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
logger.error(" user: " + user);
|
|
|
|
String msgid = "MsgSYS006" + userid + (new Date()).getTime();
|
|
|
|
String msgid = "MsgSYS006" + userid + (new Date()).getTime();
|
|
|
|
messages = messages + "<message>";
|
|
|
|
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 + "<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>";
|
|
|
@ -179,10 +190,11 @@ public class MessageSubscriptionController {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
messages = messages + "</messages>";
|
|
|
|
messages = messages + "</messages>";
|
|
|
|
logger.error(" messages: " + messages);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
String typeNamespace = "http://message.ht_portal_webservice.com";
|
|
|
|
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";
|
|
|
|
// 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";
|
|
|
|
|
|
|
|
String endpoint = "http://sappod.hengtong.com:50000/XISOAPAdapter/MessageServlet?senderParty=&senderService=BS_HTU&receiverParty=&receiverService=&interface=SI_HTPortalMessage_OUT&interfaceNamespace=http%3A%2F%2Fhengtong.com%2FHTU%2FHTPortalMessage";
|
|
|
|
Service service = new Service();
|
|
|
|
Service service = new Service();
|
|
|
|
Call call = (Call) service.createCall();
|
|
|
|
Call call = (Call) service.createCall();
|
|
|
|
call.setTimeout(300000);
|
|
|
|
call.setTimeout(300000);
|
|
|
@ -201,14 +213,18 @@ public class MessageSubscriptionController {
|
|
|
|
headers = new Hashtable();
|
|
|
|
headers = new Hashtable();
|
|
|
|
call.setProperty("HTTP-Request-Headers", headers);
|
|
|
|
call.setProperty("HTTP-Request-Headers", headers);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
headers.put("Authorization", configProp.getUrl_password());
|
|
|
|
headers.put("Authorization", configProp.getUrl_password());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
logger.error(" Url_password(): " + configProp.getUrl_password());
|
|
|
|
|
|
|
|
logger.error(" systemId: " + systemId);
|
|
|
|
|
|
|
|
logger.error(" password: " + password);
|
|
|
|
|
|
|
|
logger.error(" moudule: " + moudule);
|
|
|
|
|
|
|
|
logger.error(" messages: " + messages);
|
|
|
|
|
|
|
|
|
|
|
|
Object[] val = new Object[] { systemId, password, moudule, messages };
|
|
|
|
Object[] val = new Object[] { systemId, password, moudule, messages };
|
|
|
|
String obj = (String) call.invoke(val);
|
|
|
|
String obj = (String) call.invoke(val);
|
|
|
|
|
|
|
|
|
|
|
|
logger.error(" obj: " + String.valueOf(obj));
|
|
|
|
logger.error(" obj: " + String.valueOf(obj));
|
|
|
|
|
|
|
|
|
|
|
|
logger.error(String.valueOf("----onMessage--<\n"));
|
|
|
|
logger.error(String.valueOf("----onMessage--<\n"));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|