Ver código fonte

修改接口

zhaopeiqing 4 anos atrás
pai
commit
8f4c37c062

+ 27 - 48
src/main/java/com/ssm/controller/business/SendMessageContorller.java

@@ -168,57 +168,36 @@ public class SendMessageContorller {
 	 */
 	@WithoutUserLogin
 	@RoleLimit(pid = Const.SYSTEM_ROLE_LIMIT_PID, mid = Const.SYSTEM_ROLE_LIMIT_MID)
-	@Transactional(value="txManager")
-	@RequestMapping(value="sendSms")
-	public void sendSms(HttpServletRequest request,HttpServletResponse response){
+	@Transactional(value = "txManager")
+	@RequestMapping(value = "sendSms")
+	public void sendSms(HttpServletRequest request, HttpServletResponse response) {
 		JSONObject json = new JSONObject();
 		try {
 			request.setCharacterEncoding("utf-8");
-			String phones = request.getParameter("phones");
-			String contents = request.getParameter("contents");
-			String md5 = request.getParameter("md5");
-			if( phones == null || phones == "" ){
-				json.element("status", "1");
-				json.element("message", "参数缺失");
-			}else if( contents == null || contents == "" ){
-				json.element("status", "1");
-				json.element("message", "参数缺失");
-			}else if( md5 == null || md5 == "" ){
-				json.element("status", "1");
-				json.element("message", "参数缺失");
-			}else{
-				SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
-				String date = sdf.format(new Date());
-				String md = "phones="+phones+"&key=dgtissms&date="+date;
-				logger.info("md5 before ----" + md);
-				logger.info("md5 before request----" + md5);
-				md = MD5Utils.getMD5(md);
-				if(md.equalsIgnoreCase(md5)){
-					String[] phonesArray = phones.split(",");
-					//发送短信
-					String msgid = SmsUtil.SendSmsPost(phones, contents,phonesArray.length);
-					//将短信记录保存进数据库
-					SmsRecord smsRecord = new SmsRecord();
-					smsRecord.setContent(contents);
-					smsRecord.setCreateDate(new Date());
-					smsRecord.setPhoens(phones);
-					smsRecord.setMsgid(msgid);
-					smsRecordService.insertSelective(smsRecord);
-					
-					//查询返回值状态
-					String result = SmsUtil.StatusReportPost(msgid);
-					SmsSendState sss = new SmsSendState();
-					sss.setMsgid(msgid);
-					sss.setCreateDate(new Date());
-					sss.setContents(result);
-					smsSendStateService.insertSelective(sss);
-					
-					json.element("status", "0");
-					json.element("message", "发送成功");
-				}else {
-					json.element("status", "3");
-					json.element("message", "校验失败");
-				}
+			String smsUserPhoens = request.getParameter("phones");
+			String content = request.getParameter("contents");
+			String res = SmsUtil.sendNewSmsPost(smsUserPhoens, content);
+			Map mapObj = JSON.parseObject(res, Map.class);
+			String msgNo = mapObj.get("msg_no").toString();
+			Integer code = Integer.valueOf(mapObj.get("code").toString());
+			//将短信记录保存进数据库
+			SmsRecord smsRecord = new SmsRecord();
+			smsRecord.setContent(content);
+			smsRecord.setCreateDate(new Date());
+			smsRecord.setPhoens(smsUserPhoens);
+			smsRecord.setMsgid(msgNo);
+			smsRecordService.insertSelective(smsRecord);
+			if (code == 0) {// 提交供应商成功,查询发送是否成功
+				SmsSendState sss = new SmsSendState();
+				sss.setMsgid(msgNo);
+				sss.setCreateDate(new Date());
+				sss.setContents(res);
+				smsSendStateService.insertSelective(sss);
+				json.element("status", "0");
+				json.element("message", "发送成功");
+			} else {
+				json.element("status", "3");
+				json.element("message", "校验失败");
 			}
 		} catch (Exception e) {
 			json.element("status", SmsConst.ERROR);