Doubao-Seed-Code

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "java.compile.nullAnalysis.mode": "automatic"
+}

server_code/src/main/java/com/cl/controller/YishengyuyueController.java

@@ -29,6 +29,9 @@
 
 import com.cl.service.YishengyuyueService;
 import com.cl.service.TokenService;
+import com.cl.service.SmsService;
+import com.cl.service.YishengService;
+import com.cl.service.YonghuService;
 import com.cl.utils.PageUtils;
 import com.cl.utils.R;
 import com.cl.utils.MPUtil;
@@ -47,6 +50,15 @@
 public class YishengyuyueController {
     @Autowired
     private YishengyuyueService yishengyuyueService;
+
+    @Autowired
+    private SmsService smsService;
+
+    @Autowired
+    private YishengService yishengService;
+
+    @Autowired
+    private YonghuService yonghuService;
 
 
 
@@ -149,6 +161,8 @@ public R detail(@PathVariable("id") Long id){
     public R save(@RequestBody YishengyuyueEntity yishengyuyue, HttpServletRequest request){
     	//ValidatorUtils.validateEntity(yishengyuyue);
         yishengyuyueService.insert(yishengyuyue);
+        // 发送短信通知医生
+        sendSmsToDoctor(yishengyuyue);
         return R.ok();
     }
 
@@ -160,8 +174,29 @@ public R save(@RequestBody YishengyuyueEntity yishengyuyue, HttpServletRequest r
     public R add(@RequestBody YishengyuyueEntity yishengyuyue, HttpServletRequest request){
     	//ValidatorUtils.validateEntity(yishengyuyue);
         yishengyuyueService.insert(yishengyuyue);
+        // 发送短信通知医生
+        sendSmsToDoctor(yishengyuyue);
         return R.ok();
     }
+
+    /**
+     * 发送短信通知医生
+     */
+    private void sendSmsToDoctor(YishengyuyueEntity yishengyuyue) {
+        try {
+            // 根据医生账号获取医生信息
+            com.cl.entity.YishengEntity doctor = yishengService.selectOne(new com.baomidou.mybatisplus.mapper.EntityWrapper<com.cl.entity.YishengEntity>()
+                .eq("yishengzhanghao", yishengyuyue.getYishengzhanghao()));
+
+            if (doctor != null && doctor.getDianhua() != null) {
+                String phone = doctor.getDianhua();
+                String content = "尊敬的" + doctor.getYishengxingming() + "医生，您有一个新的预约，请及时查看。";
+                smsService.sendSms(phone, content);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
 
 
 
@@ -187,13 +222,38 @@ public R update(@RequestBody Long[] ids, @RequestParam String sfsh, @RequestPara
         List<YishengyuyueEntity> list = new ArrayList<YishengyuyueEntity>();
         for(Long id : ids) {
             YishengyuyueEntity yishengyuyue = yishengyuyueService.selectById(id);
+            String oldSfsh = yishengyuyue.getSfsh();
             yishengyuyue.setSfsh(sfsh);
             yishengyuyue.setShhf(shhf);
             list.add(yishengyuyue);
+
+            // 如果审核通过，发送短信通知用户
+            if ("审核通过".equals(sfsh) && !"审核通过".equals(oldSfsh)) {
+                sendSmsToUser(yishengyuyue);
+            }
         }
         yishengyuyueService.updateBatchById(list);
         return R.ok();
     }
+
+    /**
+     * 发送短信通知用户
+     */
+    private void sendSmsToUser(YishengyuyueEntity yishengyuyue) {
+        try {
+            // 根据用户账号获取用户信息
+            com.cl.entity.YonghuEntity user = yonghuService.selectOne(new com.baomidou.mybatisplus.mapper.EntityWrapper<com.cl.entity.YonghuEntity>()
+                .eq("zhanghao", yishengyuyue.getZhanghao()));
+
+            if (user != null && user.getShouji() != null) {
+                String phone = user.getShouji();
+                String content = "尊敬的" + user.getXingming() + "，您的预约已审核通过，请按时就诊。";
+                smsService.sendSms(phone, content);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
 
 
 

server_code/src/main/java/com/cl/service/SmsService.java

@@ -0,0 +1,22 @@
+package com.cl.service;
+
+/**
+ * 短信服务接口
+ */
+public interface SmsService {
+
+    /**
+     * 发送短信
+     * @param phone 手机号
+     * @param content 短信内容
+     * @return 是否发送成功
+     */
+    boolean sendSms(String phone, String content);
+
+    /**
+     * 验证手机号格式是否正确
+     * @param phone 手机号
+     * @return 是否正确
+     */
+    boolean validatePhone(String phone);
+}

server_code/src/main/java/com/cl/service/impl/SmsServiceImpl.java

@@ -0,0 +1,98 @@
+package com.cl.service.impl;
+
+import com.cl.entity.SyslogEntity;
+import com.cl.service.SmsService;
+import com.cl.service.SyslogService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.regex.Pattern;
+
+/**
+ * 短信服务实现类
+ */
+@Service("smsService")
+public class SmsServiceImpl implements SmsService {
+
+    @Autowired
+    private SyslogService syslogService;
+
+    // 手机号正则表达式
+    private static final String PHONE_REGEX = "^1[3-9]\\d{9}$";
+
+    // 最大重试次数
+    private static final int MAX_RETRY = 2;
+
+    @Override
+    public boolean sendSms(String phone, String content) {
+        // 验证手机号
+        if (!validatePhone(phone)) {
+            logSmsSend(phone, content, "失败", "手机号格式不正确");
+            return false;
+        }
+
+        int retryCount = 0;
+        boolean success = false;
+
+        // 重试机制
+        while (retryCount <= MAX_RETRY && !success) {
+            try {
+                // 模拟短信发送
+                success = simulateSmsSend(phone, content);
+                if (success) {
+                    logSmsSend(phone, content, "成功", "");
+                } else {
+                    logSmsSend(phone, content, "失败", "发送失败，正在重试...");
+                    retryCount++;
+                    // 重试间隔
+                    Thread.sleep(1000);
+                }
+            } catch (Exception e) {
+                logSmsSend(phone, content, "失败", e.getMessage());
+                retryCount++;
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException ie) {
+                    Thread.currentThread().interrupt();
+                }
+            }
+        }
+
+        if (!success) {
+            logSmsSend(phone, content, "失败", "达到最大重试次数");
+        }
+
+        return success;
+    }
+
+    @Override
+    public boolean validatePhone(String phone) {
+        return Pattern.matches(PHONE_REGEX, phone);
+    }
+
+    /**
+     * 模拟短信发送
+     */
+    private boolean simulateSmsSend(String phone, String content) {
+        // 模拟短信发送，这里只是打印日志
+        System.out.println("模拟发送短信到 " + phone + "，内容：" + content);
+        // 模拟90%的成功率
+        return Math.random() < 0.9;
+    }
+
+    /**
+     * 记录短信发送日志
+     */
+    private void logSmsSend(String phone, String content, String status, String remark) {
+        SyslogEntity log = new SyslogEntity();
+        log.setUsername("system");
+        log.setOperation("短信发送");
+        log.setMethod("SmsServiceImpl.sendSms");
+        log.setParams("phone=" + phone + ", content=" + content + ", status=" + status + ", remark=" + remark);
+        log.setTime(1L);
+        log.setIp("127.0.0.1");
+        log.setAddtime(new Date());
+        syslogService.insert(log);
+    }
+}

server_code/src/main/resources/application.yml

@@ -12,7 +12,7 @@ spring:
         driverClassName: com.mysql.cj.jdbc.Driver
         url: jdbc:mysql://127.0.0.1:3306/cl515882190?useUnicode=true&characterEncoding=utf-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&useSSL=false
         username: root
-        password: 202911
+        password: 123456
 
 #        driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver
 #        url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=cl515882190

server_code/target/classes/application.yml

@@ -12,7 +12,7 @@ spring:
         driverClassName: com.mysql.cj.jdbc.Driver
         url: jdbc:mysql://127.0.0.1:3306/cl515882190?useUnicode=true&characterEncoding=utf-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2B8&useSSL=false
         username: root
-        password: 202911
+        password: 123456
 
 #        driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver
 #        url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=cl515882190