Skip to content

Y
yanxuan-qc-change-system
Commit acc199e3 by “zcwang”
Options

Merge remote-tracking branch 'origin/feature-changeFlow-221110' into feature-changeFlow-221110

parents cac2304e cb3e5bd7
Showing with 34 additions and 56 deletions
yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/email/service/UasClientService.java
......@@ -12,6 +12,4 @@ public interface UasClientService {
void sendEmail(String subject, String content, Collection<String> toList, Collection<String> ccList, List<File> fileList);
void sendEmail1(String subject, String content, Collection<String> toList, Collection<String> ccList, List<File> fileList);
}
yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/email/service/impl/IUasClientEhcImpl.java
......@@ -34,6 +34,10 @@ public class IUasClientEhcImpl implements IUasEhcClient {
List<File> fileList) {
if (!CollectionUtils.isEmpty(toList)) {
Map<String, String> params = new HashMap();
logger.error("参数查看"+subject);
if (subject == null || subject.equals("")){
subject = "测试标题";
}
params.put("subject", subject);
params.put("content", content);
if (!CollectionUtils.isEmpty(toList)) {
......
yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/email/service/impl/UasClientServiceImpl.java
......@@ -46,6 +46,7 @@ public class UasClientServiceImpl implements UasClientService {
if (!CollectionUtils.isEmpty(ccList)) {
params.put("cc", StringUtils.join(ccList, ","));
}
logger.info(JSONObject.toJSONString(params));
String res = service.sendEmail(params);
this.logger.info("返回信息日志打印\n"+res);
this.logger.info("[op:sendEmail] res={} ", new Object[]{res});
......@@ -56,28 +57,4 @@ public class UasClientServiceImpl implements UasClientService {
}
}
public void sendEmail1(String subject, String content, Collection<String> toList, Collection<String> ccList, List<File> fileList) {
logger.info("调用接口111~~~~~~~~~~~~~~~~~~~~~~~~");
if (!CollectionUtils.isEmpty(toList)) {
//String url = MessageFormat.format("http://{0}{1}/{2}", this.thirdPartyDrmConfig.getUasHostInner(), "/push/email/", this.thirdPartyDrmConfig.getUasProduct());
Map<String, String> params = new HashMap();
params.put("subject", subject);
params.put("content", content);
params.put("to", StringUtils.join(toList, ","));
params.put("topic", "qc");
if (!CollectionUtils.isEmpty(ccList)) {
params.put("cc", StringUtils.join(ccList, ","));
}
String res = service.sendEmail1(params);
this.logger.info("返回信息日志打印\n"+res);
this.logger.info("[op:sendEmail] res={} ", new Object[]{res});
JSONObject jsonObject = JSON.parseObject(res);
if (jsonObject.getInteger("code") != 200) {
this.logger.error("SendEmail", (String)null, "send email failed, subject={},toList={},ccList={}", new Object[]{subject, JSON.toJSONString(toList), JSON.toJSONString(ccList)});
}
}
}
}
yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/flow/email/EmailRpcService.java
......@@ -15,15 +15,12 @@ import java.util.Map;
public interface EmailRpcService {
//templates/flowx/template/assemble.json
//yanxuan-qc-change-system
@PostMapping("/push/email/attach/yanxuan-qc-change-system/upload.json")
//@PostMapping("/push/email/attach/yanxuan-qc-change-system/upload.json")
@PostMapping("/push/email/attach/yanxuan-qc-ecr-system/upload.json")
String sendEmail(Map<String, String> params);
@PostMapping("/push/email/yanxuan-qc-change-system/upload.json")
String sendEmail1(Map<String, String> params);
//yanxuan-sc-ehc
@PostMapping("/push/email/bpm_risk_evaluation_11")
@PostMapping("/push/email/yanxuan-qc-ehc/upload.json")
String sendEmailInfo(Map<String, String> params);
}
yanxuan-qc-change-system-web/src/main/java/com/netease/mail/yanxuan/change/web/controller/ChangeConfigController.java
......@@ -124,38 +124,40 @@ public class ChangeConfigController {
ArrayList<String> strings = new ArrayList<>();
logger.info("调用接口~~~~~~~~~~~~~~~~~~~~~~~~");
strings.add("wb.tanglongwei@mesg.corp.netease.com");
iEmailService.sendEmail("测试标题","{\n" +
" \"headline\" : \"测试标题\",\n" +
" \"text\" : \"测试文本内容\"\n" +
iEmailService.sendEmail("yxqc_release_flow","{\n" +
" \"flowId\":\"工单ID\",\n" +
" \"releaseId\":\"发起人账号\",\n" +
" \"releaseName\":\"发起人姓名\",\n" +
" \"abnormalTitle\":\"异常标题\",\n" +
" \"flowLink\":\"工单链接\",\n" +
" \"findTime\":\"findTime\",\n" +
" \"findDes\":\"findDes\"\n" +
"\n" +
"}", strings,null,null);
}
@GetMapping("/test1")
public void queryCommanderInfo1(){
ArrayList<String> strings = new ArrayList<>();
logger.info("调用接口~~~~~~~~~~~~~~~~~~~~~~~~");
strings.add("wb.tanglongwei@mesg.corp.netease.com");
iEmailService.sendEmail1("测试标题","{\n" +
" \"headline\" : \"测试标题\",\n" +
" \"text\" : \"测试文本内容\"\n" +
"}", strings,null,null);
}
@GetMapping("/test2")
public void queryCommanderInfo2(){
ArrayList<String> strings = new ArrayList<>();
logger.info("调用接口~~~~~~~~~~~~~~~~~~~~~~~~");
strings.add("wb.tanglongwei@mesg.corp.netease.com");
client.sendEmail("测试标题","{\n" +
" \"flowId\":\"工单ID\",\n" +
" \"releaseId\":\"发起人账号\",\n" +
" \"releaseName\":\"发起人姓名\",\n" +
" \"abnormalTitle\":\"异常标题\",\n" +
" \"flowLink\":\"工单链接\",\n" +
" \"findTime\":\"findTime\",\n" +
" \"findDes\":\"findDes\"\n" +
client.sendEmail("bpm_risk_evaluation_11","{\n" +
"\n" +
"\u200B \"itemId\":\"商品id\",\n" +
"\n" +
"\u200B \"itemName\":\"商品名称\",\n" +
"\n" +
"\u200B \"sqeId\":\"sqeId\",\n" +
"\n" +
"\u200B \"sqeName\":\"sqe名称\",\n" +
"\n" +
"\u200B \"createTime\":\"开始时间\",\n" +
"\n" +
"\u200B \"flowId\":\"工单id\",\n" +
"\n" +
"\u200B \"flowUrl\":\"工单链接\",\n" +
"\n" +
"\u200B\t”subject“：\"xxx\"\n" +
"\n" +
"}", strings,null,null);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment