增加短信发送

src/main/java/com/example/civilizedcity/controller/TaIssueProcessController.java

@@ -6,8 +6,10 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.example.civilizedcity.common.*;
 
+import com.example.civilizedcity.entity.SysOrg;
 import com.example.civilizedcity.entity.SysUser;
 import com.example.civilizedcity.entity.TaIssue;
+import com.example.civilizedcity.service.SysOrgService;
 import com.example.civilizedcity.service.TaIssueService;
 import com.example.civilizedcity.service.TaOrgIssueService;
 import io.swagger.annotations.Api;

src/main/java/com/example/civilizedcity/entity/SysOrg.java

@@ -52,10 +52,10 @@ public class SysOrg implements Serializable,Cloneable{
     /** 创建时间 */
     @ApiModelProperty(name = "创建时间",notes = "")
     private LocalDateTime createDate ;
-//
-//     /** 短信接收者 */
-//     @ApiModelProperty(name = "短信接收者",notes = "")
-//     private String smsPson ;
+
+     /** 短信接收者 */
+     @ApiModelProperty(name = "短信接收者",notes = "")
+     private String smsPson ;
 
 
 }

src/main/java/com/example/civilizedcity/event/MessagEvent.java

@@ -2,12 +2,14 @@ package com.example.civilizedcity.event;
 
 import com.example.civilizedcity.entity.TaIssue;
 import com.example.civilizedcity.entity.TaIssueApply;
+import com.example.civilizedcity.entity.TaOrgIssue;
 import org.springframework.context.ApplicationEvent;
 
 public class MessagEvent extends ApplicationEvent {
 
     private TaIssueApply taIssueApply = null;
     private TaIssue taIssue = null;
+    private TaOrgIssue taOrgIssue = null;
 
     public MessagEvent(Object source, TaIssue taIssue) {
         super(source);
@@ -19,6 +21,11 @@ public class MessagEvent extends ApplicationEvent {
         this.taIssueApply = taIssueApply;
     }
 
+    public MessagEvent(Object source, TaOrgIssue taOrgIssue) {
+        super(source);
+        this.taOrgIssue = taOrgIssue;
+    }
+
     public TaIssue getTaIssue() {
         return taIssue;
     }
@@ -26,4 +33,8 @@ public class MessagEvent extends ApplicationEvent {
     public TaIssueApply getTaIssueApply() {
         return taIssueApply;
     }
+
+    public TaOrgIssue getTaOrgIssue() {
+        return taOrgIssue;
+    }
 }

src/main/java/com/example/civilizedcity/event/listener/MessagEventListener.java

@@ -20,5 +20,9 @@ public class MessagEventListener implements ApplicationListener<MessagEvent> {
         if (null != event.getTaIssueApply()) {
             taMessageService.sendMessage(event.getTaIssueApply());
         }
+
+        if (null != event.getTaOrgIssue()) {
+            taMessageService.sendMessage(event.getTaOrgIssue());
+        }
     }
 }

src/main/java/com/example/civilizedcity/message/IMessage.java

@@ -0,0 +1,5 @@
+package com.example.civilizedcity.message;
+
+public interface IMessage {
+    void send(String toUser, String code, String message) throws Exception;
+}

src/main/java/com/example/civilizedcity/message/impl/SMS.java

@@ -0,0 +1,120 @@
+package com.example.civilizedcity.message.impl;
+
+import com.example.civilizedcity.message.IMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+@Slf4j
+@Component
+public class SMS implements IMessage {
+
+    @Value("${message.sms.enable}")
+    boolean enable;
+
+    @Value("${message.sms.httpUrl}")
+    String httpUrl;
+
+    @Value("${message.sms.userName}")
+    String userName;
+
+    @Value("${message.sms.password}")
+    String password;
+
+    @Value("${message.sms.template}")
+    String template;
+
+    @Override
+    public void send(String toUser, String code, String message) throws Exception {
+        if (!enable) return;
+
+        String content = String.format(template, message);
+
+        String searchStr = "u=" + userName;
+        searchStr += "&p=" + md5(password);
+        searchStr += "&m=" + toUser;
+        searchStr += "&c=" + encodeUrlString(content, "UTF-8");
+
+        String resp = request(httpUrl, searchStr);
+        log.debug(String.format("Send sms to %s , that result is : [ %s ]", toUser, resp));
+
+        if (!"0".equals(resp)) {
+            SMSError error = SMSError.getEnum(resp);
+            String errMsg = null == error ? "未知错误" : error.getMessage();
+            String errorMessage = String.format("Send sms to %s , that result is : [ %s ]: %s", toUser, resp, errMsg);
+            throw new Exception(errorMessage);
+        }
+    }
+
+    private String request(String httpUrl, String httpArg) {
+        BufferedReader reader = null;
+        String result = null;
+        StringBuffer sbf = new StringBuffer();
+        httpUrl = httpUrl + "?" + httpArg;
+
+        try {
+            URL url = new URL(httpUrl);
+            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+            connection.setRequestMethod("GET");
+            connection.connect();
+            InputStream is = connection.getInputStream();
+            reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
+            String strRead = reader.readLine();
+            if (strRead != null) {
+                sbf.append(strRead);
+                while ((strRead = reader.readLine()) != null) {
+                    sbf.append("\n");
+                    sbf.append(strRead);
+                }
+            }
+            reader.close();
+            result = sbf.toString();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    private String md5(String plainText) {
+        StringBuffer buf = null;
+        try {
+            MessageDigest md = MessageDigest.getInstance("MD5");
+            md.update(plainText.getBytes());
+            byte b[] = md.digest();
+            int i;
+            buf = new StringBuffer("");
+            for (int offset = 0; offset < b.length; offset++) {
+                i = b[offset];
+                if (i < 0)
+                    i += 256;
+                if (i < 16)
+                    buf.append("0");
+                buf.append(Integer.toHexString(i));
+            }
+        } catch (NoSuchAlgorithmException e) {
+            e.printStackTrace();
+        }
+        return buf.toString();
+    }
+
+    private String encodeUrlString(String str, String charset) {
+        String strret = null;
+        if (str == null)
+            return str;
+        try {
+            strret = java.net.URLEncoder.encode(str, charset);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+        return strret;
+    }
+}

src/main/java/com/example/civilizedcity/message/impl/SMSError.java

@@ -0,0 +1,36 @@
+package com.example.civilizedcity.message.impl;
+
+public enum SMSError {
+    SUCCESS("0", "成功"),
+    ERROR_PASSWORD("30", "错误密码"),
+    ERROR_ACCOUNT("40", "账号不存在"),
+    ERROR_BALANCE("41", "余额不足"),
+    ERROR_IP("43", "IP地址限制"),
+    ERROR_CONTENT("50", "内容含有敏感词"),
+    ERROR_PHONE("51", "手机号码不正确");
+
+    private String code;
+    private String message;
+
+    private SMSError(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public static SMSError getEnum(String code) {
+        for (SMSError smsError : SMSError.values()) {
+            if (smsError.getCode().equals(code)) {
+                return smsError;
+            }
+        }
+        return null;
+    }
+}

src/main/java/com/example/civilizedcity/service/TaMessageService.java

@@ -4,8 +4,9 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.example.civilizedcity.entity.TaIssue;
 import com.example.civilizedcity.entity.TaIssueApply;
 import com.example.civilizedcity.entity.TaMessage;
+import com.example.civilizedcity.entity.TaOrgIssue;
 
- /**
+/**
  * 消息通知;(ta_message)表服务接口
  * @author : http://njyunzhi.com
  * @date : 2023-1-2
@@ -15,4 +16,6 @@ public interface TaMessageService extends IBaseService<TaMessage> {
      void sendMessage(TaIssue taIssue);
 
      void sendMessage(TaIssueApply taIssueApply);
+
+     void sendMessage(TaOrgIssue taOrgIssue);
  }

src/main/java/com/example/civilizedcity/service/impl/TaMessageServiceImpl.java

@@ -2,19 +2,21 @@ package com.example.civilizedcity.service.impl;
 
 import com.example.civilizedcity.common.Constants;
 import com.example.civilizedcity.common.StringUtils;
-import com.example.civilizedcity.entity.TaIssue;
-import com.example.civilizedcity.entity.TaIssueApply;
+import com.example.civilizedcity.entity.*;
+import com.example.civilizedcity.mapper.SysOrgMapper;
+import com.example.civilizedcity.mapper.SysUserMapper;
+import com.example.civilizedcity.message.impl.SMS;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.stereotype.Service;
-import com.example.civilizedcity.entity.TaMessage;
 import com.example.civilizedcity.mapper.TaMessageMapper;
 import com.example.civilizedcity.service.TaMessageService;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
+import java.util.List;
 
 /**
  * 消息通知;(ta_message)表服务实现类
@@ -25,6 +27,15 @@ import java.time.LocalDateTime;
 @Service
 public class TaMessageServiceImpl extends BaseServiceImpl<TaMessageMapper, TaMessage> implements TaMessageService {
 
+    @Autowired
+    SysOrgMapper sysOrgMapper;
+
+    @Autowired
+    SysUserMapper sysUserMapper;
+
+    @Autowired
+    SMS sms;
+
     /**
      * 平台流程
      * @param taIssue
@@ -140,4 +151,29 @@ public class TaMessageServiceImpl extends BaseServiceImpl<TaMessageMapper, TaMes
 
         save(taMessage);
     }
+
+    @Async
+    @Override
+    public void sendMessage(TaOrgIssue taOrgIssue) {
+        SysOrg sysOrg = sysOrgMapper.selectById(taOrgIssue.getOrgId());
+        if (null == sysOrg || StringUtils.isEmpty(sysOrg.getSmsPson())) {
+            return ;
+        }
+
+        String[] smsPsons = sysOrg.getSmsPson().split(",");
+        for (String p : smsPsons) {
+            List<SysUser> userList = sysUserMapper.getListByPhone(p);
+            if (null == userList || userList.size() == 0) {
+                continue;
+            }
+
+            SysUser sysUser = userList.get(0);
+
+            try {
+                sms.send(sysUser.getPhone(), null, sysUser.getName());
+            } catch (Exception e) {
+                log.error("发送短信失败", e);
+            }
+        }
+    }
 }

src/main/java/com/example/civilizedcity/service/impl/TaOrgIssueServiceImpl.java

@@ -4,8 +4,10 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.example.civilizedcity.common.Constants;
 import com.example.civilizedcity.common.StringUtils;
 import com.example.civilizedcity.entity.*;
+import com.example.civilizedcity.event.MessagEvent;
 import com.example.civilizedcity.mapper.*;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import com.example.civilizedcity.service.TaOrgIssueService;
 import org.springframework.transaction.annotation.Transactional;
@@ -38,6 +40,8 @@ public class TaOrgIssueServiceImpl extends BaseServiceImpl<TaOrgIssueMapper, TaO
     @Autowired
     TaAttachMapper taAttachMapper;
 
+    @Autowired
+    ApplicationEventPublisher applicationEventPublisher;
 
     private void transParams(Map<String, Object> params) {
         params.put("processNode", null);
@@ -104,6 +108,9 @@ public class TaOrgIssueServiceImpl extends BaseServiceImpl<TaOrgIssueMapper, TaO
         taIssueProcess.setCreateDate(LocalDateTime.now());
         taIssueProcess.setStatus(Constants.STATUS_NORMAL);
         taIssueProcessMapper.insert(taIssueProcess);
+
+        // 发送短信通知
+        applicationEventPublisher.publishEvent(new MessagEvent(this, taOrgIssue));
     }
 
     @Override

src/main/resources/application.yml

@@ -14,6 +14,15 @@ spring:
   profiles:
     active: @profileActive@
 
+### 仅 h5 版本用到
+message:
+  sms:
+    enable: true
+    httpUrl: http://api.smsbao.com/sms
+    userName: pzhgd
+    password: PZHdt@147293ac
+    template: 【文明创城办】%s，您有一条工作待办请前往{XXXAPP}及时处理
+
 ###
 sms:
   captcha: