diff --git a/ruoyi/pom.xml b/ruoyi/pom.xml
index 441fcaba2..3c71b5eec 100644
--- a/ruoyi/pom.xml
+++ b/ruoyi/pom.xml
@@ -269,6 +269,24 @@
</exclusions>
</dependency>
+ <!-- 极光短信包 -->
+ <dependency>
+ <groupId>cn.jpush.api</groupId>
+ <artifactId>jiguang-common</artifactId>
+ <version>1.0.8</version>
+ <exclusions>
+ <exclusion>
+ <artifactId>okhttp</artifactId>
+ <groupId>com.squareup.okhttp3</groupId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>cn.jpush.api</groupId>
+ <artifactId>jsms-client</artifactId>
+ <version>1.2.8</version>
+ </dependency>
+
<!-- 其他工具包 -->
<dependency>
<groupId>com.google.code.gson</groupId>
diff --git a/ruoyi/src/main/java/com/ruoyi/common/config/CommonConfig.java b/ruoyi/src/main/java/com/ruoyi/common/config/CommonConfig.java
new file mode 100644
index 000000000..6e4ab5749
--- /dev/null
+++ b/ruoyi/src/main/java/com/ruoyi/common/config/CommonConfig.java
@@ -0,0 +1,31 @@
+package com.ruoyi.common.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class CommonConfig {
+
+ @Value("${sms.appkey}")
+ private String smsAppkey;
+
+ @Value("${sms.secret}")
+ private String smsSecret;
+
+ public String getSmsAppkey() {
+ return smsAppkey;
+ }
+
+ public void setSmsAppkey(String smsAppkey) {
+ this.smsAppkey = smsAppkey;
+ }
+
+ public String getSmsSecret() {
+ return smsSecret;
+ }
+
+ public void setSmsSecret(String smsSecret) {
+ this.smsSecret = smsSecret;
+ }
+}
+
diff --git a/ruoyi/src/main/java/com/ruoyi/common/service/impl/SMSService.java b/ruoyi/src/main/java/com/ruoyi/common/service/impl/SMSService.java
new file mode 100644
index 000000000..3124dc57d
--- /dev/null
+++ b/ruoyi/src/main/java/com/ruoyi/common/service/impl/SMSService.java
@@ -0,0 +1,204 @@
+package com.ruoyi.common.service.impl;
+
+import cn.jiguang.common.resp.APIConnectionException;
+import cn.jiguang.common.resp.APIRequestException;
+import cn.jsms.api.common.SMSClient;
+import cn.jsms.api.common.model.SMSPayload;
+import com.ruoyi.common.config.CommonConfig;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Service
+public class SMSService {
+
+ Logger logger = LoggerFactory.getLogger (this.getClass ());
+
+ @Resource
+ private CommonConfig commonConfig;
+
+ private SMSClient client;
+
+ private static int registerTempId = 148418; // 注册模板
+ private static int loginTempId = 148417; // 登录模板
+ private static int regSucId = 152215; // 注册成功模板
+ private static int addEmpId = 151527; // 添加员工模板
+ private static int resetEmpPsw = 151221; // 重置员工密码模板
+ private static int applyId = 151637; // 报名验证码模板
+ private static int patriarchLoginId = 152601; // 家长端登录验证码模板
+ private static int publicCodeId = 154801;// 通用的验证码模板
+ private static int birthTeacher = 199895; // 教师生日祝福模板
+ private static int warn = 199897;// 平台剩余日期提醒模板
+
+ // private static int TEMP_TYPE_NOTICE = 2; // 通知类
+ // private static int TEMP_TYPE_AD = 3; // 营销类
+
+ @PostConstruct
+ public void init () {
+ client = new SMSClient (commonConfig.getSmsSecret (), commonConfig.getSmsAppkey ());
+ }
+
+ /**
+ * @param mobile
+ * @Title: sendRegisterSMS
+ * @Description: 发送生日祝福
+ */
+ public void sendBirthTeacherSMS (String mobile) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (birthTeacher)
+ .build ();
+
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile
+ * @param days
+ * @Title: sendRegisterSMS
+ * @Description: 平台剩余日期提醒
+ */
+ public void sendWarnSMS (String mobile,String days) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (warn)
+ .addTempPara("days",days).build ();
+
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile
+ * @param code
+ * @Title: sendRegisterSMS
+ * @Description: 发送注册验证码
+ */
+ public void sendRegisterSMS (String mobile, String code) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (registerTempId)
+ .addTempPara ("code", code).build ();
+
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile
+ * @param code
+ * @Title: sendLoginSMS
+ * @Description: 发送登录验证码
+ */
+ public void sendLoginSMS (String mobile, String code) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (loginTempId)
+ .addTempPara ("code", code).build ();
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile 接收手机号
+ * @Title: sendRegSucSMS
+ * @Description: 发送注册成功短信
+ */
+ public void sendRegSucSMS (String mobile) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (regSucId).build ();
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile 接收手机号
+ * @param password 密码
+ * @Title: sendAddEmpSMS
+ * @Description: 发送添加员工成功短信
+ */
+ public void sendAddEmpSMS (String mobile, String password) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (addEmpId)
+ .addTempPara ("userName", mobile)
+ .addTempPara ("password", password)
+ .build ();
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile
+ * @param password
+ * @Title: sendResetEmpPswSMS
+ * @Description: 重置员工密码短信
+ */
+ public void sendResetEmpPswSMS (String mobile, String password) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (resetEmpPsw)
+ .addTempPara ("password", password)
+ .build ();
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+ /**
+ * @param mobile
+ * @param code
+ * @Title: sendLoginSMS
+ * @Description: 发送登录验证码
+ */
+ public void sendApplySMS (String mobile, String code) {
+ SMSPayload payload = SMSPayload.newBuilder ().setMobileNumber (mobile).setTempId (applyId)
+ .addTempPara ("code", code).build ();
+ try {
+ client.sendTemplateSMS (payload);
+ } catch (APIRequestException e) {
+ logger.error ("Error response from JPush server. Should review and fix it. ", e);
+
+ } catch (APIConnectionException e) {
+ logger.error ("Connection error. Should retry later. ", e);
+ }
+ }
+
+
+
+ public void setClient (SMSClient client) {
+ this.client = client;
+ }
+}
diff --git a/ruoyi/src/main/java/com/ruoyi/framework/task/RyTask.java b/ruoyi/src/main/java/com/ruoyi/framework/task/RyTask.java
index 2a44a2189..a1da69ecf 100644
--- a/ruoyi/src/main/java/com/ruoyi/framework/task/RyTask.java
+++ b/ruoyi/src/main/java/com/ruoyi/framework/task/RyTask.java
@@ -1,14 +1,17 @@
package com.ruoyi.framework.task;
+import com.ruoyi.common.service.impl.SMSService;
import com.ruoyi.project.benyi.domain.BySchoolNews;
import com.ruoyi.project.benyi.service.IBySchoolNewsService;
import com.ruoyi.project.bysite.domain.ByNews;
import com.ruoyi.project.bysite.service.IByNewsService;
import com.ruoyi.project.common.SchoolCommon;
import com.ruoyi.project.system.domain.BySchool;
+import com.ruoyi.project.system.domain.ByTeacherJbxx;
import com.ruoyi.project.system.domain.SysDept;
import com.ruoyi.project.system.domain.SysUser;
import com.ruoyi.project.system.service.IBySchoolService;
+import com.ruoyi.project.system.service.IByTeacherJbxxService;
import com.ruoyi.project.system.service.ISysDeptService;
import com.ruoyi.project.system.service.ISysUserService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -38,6 +41,10 @@ public class RyTask {
private IBySchoolNewsService iBySchoolNewsService;
@Autowired
private IByNewsService iByNewsService;
+ @Autowired
+ private IByTeacherJbxxService iByTeacherJbxxService;
+ @Autowired
+ private SMSService smsService;
public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
@@ -110,6 +117,16 @@ public class RyTask {
iBySchoolNewsService.updateBySchoolNews(newBySchoolNews);
}
}
+ } else if (params.equals("birthteacher")) {
+ System.out.println("birthteacher");
+ List<ByTeacherJbxx> list = iByTeacherJbxxService.selectByTeacherBrithList(null);
+ if (list != null && list.size() > 0) {
+ for (int i = 0; i < list.size(); i++) {
+ String phone = list.get(i).getUser().getUserName();
+ smsService.sendBirthTeacherSMS(phone);
+ }
+ }
+
}
System.out.println("执行有参方法：" + params);
}
diff --git a/ruoyi/src/main/java/com/ruoyi/project/system/mapper/ByTeacherJbxxMapper.java b/ruoyi/src/main/java/com/ruoyi/project/system/mapper/ByTeacherJbxxMapper.java
index 7e86fe7b9..d67ab192f 100644
--- a/ruoyi/src/main/java/com/ruoyi/project/system/mapper/ByTeacherJbxxMapper.java
+++ b/ruoyi/src/main/java/com/ruoyi/project/system/mapper/ByTeacherJbxxMapper.java
@@ -27,6 +27,14 @@ public interface ByTeacherJbxxMapper
*/
public List<ByTeacherJbxx> selectByTeacherJbxxList(ByTeacherJbxx byTeacherJbxx);
+ /**
+ * 查询教师基本信息列表
+ *
+ * @param byTeacherJbxx 教师基本信息
+ * @return 教师基本信息集合
+ */
+ public List<ByTeacherJbxx> selectByTeacherBrithList(ByTeacherJbxx byTeacherJbxx);
+
/**
* 查询教师基本信息列表
*
diff --git a/ruoyi/src/main/java/com/ruoyi/project/system/service/IByTeacherJbxxService.java b/ruoyi/src/main/java/com/ruoyi/project/system/service/IByTeacherJbxxService.java
index 81a77e9af..ae9844990 100644
--- a/ruoyi/src/main/java/com/ruoyi/project/system/service/IByTeacherJbxxService.java
+++ b/ruoyi/src/main/java/com/ruoyi/project/system/service/IByTeacherJbxxService.java
@@ -27,6 +27,14 @@ public interface IByTeacherJbxxService
*/
public List<ByTeacherJbxx> selectByTeacherJbxxList(ByTeacherJbxx byTeacherJbxx);
+ /**
+ * 查询教师基本信息列表
+ *
+ * @param byTeacherJbxx 教师基本信息
+ * @return 教师基本信息集合
+ */
+ public List<ByTeacherJbxx> selectByTeacherBrithList(ByTeacherJbxx byTeacherJbxx);
+
/**
* 查询教师基本信息列表
*
diff --git a/ruoyi/src/main/java/com/ruoyi/project/system/service/impl/ByTeacherJbxxServiceImpl.java b/ruoyi/src/main/java/com/ruoyi/project/system/service/impl/ByTeacherJbxxServiceImpl.java
index 4b397e1a0..cefb515f9 100644
--- a/ruoyi/src/main/java/com/ruoyi/project/system/service/impl/ByTeacherJbxxServiceImpl.java
+++ b/ruoyi/src/main/java/com/ruoyi/project/system/service/impl/ByTeacherJbxxServiceImpl.java
@@ -43,6 +43,17 @@ public class ByTeacherJbxxServiceImpl implements IByTeacherJbxxService {
return byTeacherJbxxMapper.selectByTeacherJbxxList(byTeacherJbxx);
}
+ /**
+ * 查询教师基本信息列表
+ *
+ * @param byTeacherJbxx 教师基本信息
+ * @return 教师基本信息集合
+ */
+ @Override
+ public List<ByTeacherJbxx> selectByTeacherBrithList(ByTeacherJbxx byTeacherJbxx) {
+ return byTeacherJbxxMapper.selectByTeacherBrithList(byTeacherJbxx);
+ }
+
/**
* 查询教师基本信息列表
*
diff --git a/ruoyi/src/main/resources/application.yml b/ruoyi/src/main/resources/application.yml
index a2850884a..9bf39cb5c 100644
--- a/ruoyi/src/main/resources/application.yml
+++ b/ruoyi/src/main/resources/application.yml
@@ -135,3 +135,8 @@ wx:
appid: wx0370c4756118456a
secret: f57143e81f3c95b0d909d91b3116cc82
domain: https://api.weixin.qq.com/sns/oauth2/access_token
+
+#jiguang
+sms:
+ appkey: 438b95319ada13c8c6ffacfe
+ secret: c77c8aded1dd8c2fb083ebd3
diff --git a/ruoyi/src/main/resources/mybatis/system/ByTeacherJbxxMapper.xml b/ruoyi/src/main/resources/mybatis/system/ByTeacherJbxxMapper.xml
index 41e279084..ef5a85013 100644
--- a/ruoyi/src/main/resources/mybatis/system/ByTeacherJbxxMapper.xml
+++ b/ruoyi/src/main/resources/mybatis/system/ByTeacherJbxxMapper.xml
@@ -70,6 +70,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
${dataScope}
</select>
+
+ <select id="selectByTeacherBrithList" parameterType="ByTeacherJbxx" resultMap="ByTeacherJbxxResult">
+ select t.id, t.userid, t.zjhm, t.csrq, t.byyx, t.zy, t.xl, t.xw, t.cjgzrq, t.zgzs, t.createuserid, t.createtime,
+ u.user_id, u.nick_name, u.user_name from by_teacher_jbxx t left join sys_user u on t.userid=u.user_id
+ where MONTH(t.csrq) = MONTH(NOW()) and DAY(t.csrq) = DAY(NOW()) and u.del_flag='0' and u.status='0'
+ </select>
+
<select id="selectByTeacherJbGroupXw" parameterType="ByTeacherJbxx" resultMap="ByTeacherJbxxResult">
select (CASE WHEN (select dict_label from sys_dict_data where dict_type='sys_jsxl' and dict_value=t.xl ) is null THEN '未设置' ELSE (select dict_label from sys_dict_data where dict_type='sys_jsxl' and dict_value=t.xl ) END )xl,count(*) byyx
from by_teacher_jbxx t