新增直播申请短信通知功能

王言钊
1 parent ada6fd6f
Showing 4 changed files with 34 additions and 8 deletions
src/main/java/com/cnlive/shenhe/job/LiveApplyJob.java
src/main/resources/application-dev.properties
src/main/resources/application-prod.properties
src/main/resources/application-test.properties
@@ -51,6 +51,9 @@ public class LiveApplyJob {
     @Value("${email_send_URL}")
     private String email_send_URL;
+    @Value("${mobile_send_URL}")
+    private String mobile_send_URL;
+
     @Autowired
     SitesService sitesService;
     @Autowired
@@ -118,15 +121,16 @@ public class LiveApplyJob {
                     String emailAddr = shyEmail.getEmail();
                     String title = liveApply.getSpid_desc() + "新直播开播申请";
                     String templateId = "4017";
-                    Map<String, String> params = new HashMap<>();
-                    params.put("appId", appId);
-                    params.put("emailAddr", emailAddr);
-                    params.put("title", title);
-                    params.put("content", content);
-                    params.put("templateId", templateId);
-                    params.put("sign", OpenUtil.sign(params, appKey));
+                    Map<String, String> emailparams = new HashMap<>();
+                    emailparams.put("appId", appId);
+                    emailparams.put("emailAddr", emailAddr);
+                    emailparams.put("title", title);
+                    emailparams.put("content", content);
+                    emailparams.put("templateId", templateId);
+                    emailparams.put("sign", OpenUtil.sign(emailparams, appKey));
                     HttpUtil httpUtil = HttpUtil.init();
-                    httpUtil.setParamMap(params);
+                    httpUtil.setParamMap(emailparams);
+                    int i = 0;
                     try {
                         Map<String, String> post = httpUtil.post(url);
                         logger.info("当前发送邮件用户为：" + emailAddr + ",发送邮件的直播申请审核云id为：" + liveApply.getId() + "结果为：" + post.get("result"));
@@ -134,12 +138,14 @@ public class LiveApplyJob {
                         if (result == null) {
                             noticeState = CommonConst.NOTICE_FAIL;
                             noticeMsg = noticeMsg + "\n" + dateTime + " 邮件服务器调用失败,result为空";
+                            i++;
                             break;
                         }
                         Integer code = result.getInteger("errorCode");
                         if (code != 0) {
                             noticeState = CommonConst.NOTICE_FAIL;
                             noticeMsg = noticeMsg + "\n" + dateTime + " 邮件服务器调用失败,result返回消息为：" + result.getString("errorMessage");
+                            i++;
                             break;
                         } else {
                             noticeState = CommonConst.NOTICE_SUCCESS;
@@ -149,8 +155,25 @@ public class LiveApplyJob {
                         logger.info("异常结果为：{}", e.getMessage());
                         noticeState = CommonConst.NOTICE_FAIL;
                         noticeMsg = noticeMsg + "\n" + dateTime + " 邮件服务器调用失败,服务器报错了";
+                        i++;
                         break;
                     }
+                    String taskId = "003_01";
+                    String signatureId = "0";
+                    Map<String, String> mobileparams = new HashMap<>(16);
+                    mobileparams.put("appId", appId);
+                    mobileparams.put("mobile", liveApply.getMobile());
+                    mobileparams.put("title", title);
+                    mobileparams.put("content", content);
+                    mobileparams.put("taskId", taskId);
+                    mobileparams.put("signatureId", signatureId);
+                    httpUtil.setParamMap(mobileparams);
+                    if (i >10) {
+                        Map<String, String> post = httpUtil.post(mobile_send_URL);
+                        logger.info("当前发送短信用户为：" + liveApply.getMobile() + ",发送短信的直播申请审核云id为：" + liveApply.getId() + "结果为：" + post.get("result"));
+                        noticeState = CommonConst.NOTICE_SUCCESS;
+                        noticeMsg = noticeMsg + "\n" + dateTime + "短信手机号" + liveApply.getMobile() + "(" + liveApply.getSender() + ")发送成功";
+                    }
                 }
                 liveApply.setEmail_notice_state(noticeState);
                 liveApply.setEmail_notice_msg(noticeMsg);
@@ -97,6 +97,7 @@ live_url=http://test.bc.cnlive.com/bokong/activity/activityShenHe
 email_app_id=769_jetja50p18
 email_app_key=ad101b9152817a79b5c33c3617b96ff91385096ff3b4ba
 email_send_URL=http://sms.cnlive.com/CnliveM3/email/sendMoreVarEmail.action
+mobile_send_URL=http://sms.cnlive.com/CnliveM3/msg/sendSms.action
 #\u62BD\u5E27\u5B58\u653Ebucket\u548C\u57DF\u540D
 qn_bucket=cnlivetest
@@ -91,6 +91,7 @@ live_url=http://bc.cnlive.com/bokong/activity/activityShenHe
 email_app_id=769_jetja50p18
 email_app_key=ad101b9152817a79b5c33c3617b96ff91385096ff3b4ba
 email_send_URL=http://sms.cnlive.com/CnliveM3/email/sendMoreVarEmail.action
+mobile_send_URL=http://sms.cnlive.com/CnliveM3/msg/sendSms.action
 qn_bucket=mam-sxzg-82
@@ -97,6 +97,7 @@ live_url=http://test.bc.cnlive.com/bokong/activity/activityShenHe
 email_app_id=769_jetja50p18
 email_app_key=ad101b9152817a79b5c33c3617b96ff91385096ff3b4ba
 email_send_URL=http://sms.cnlive.com/CnliveM3/email/sendMoreVarEmail.action
+mobile_send_URL=http://sms.cnlive.com/CnliveM3/msg/sendSms.action
 #\u62BD\u5E27\u5B58\u653Ebucket\u548C\u57DF\u540D
 qn_bucket=cnlivetest