无锡代码
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liusheng
6 天以前 24166f2d9ae0bb72f061a38b96a113b1b6e44fbc 
 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java


@@ -1,8 +1,6 @@


package com.ruoyi.quartz.task;




import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONObject;


import com.fasterxml.jackson.core.JsonParser;


import com.fasterxml.jackson.databind.JsonNode;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.google.common.reflect.TypeToken;


@@ -11,14 +9,12 @@


import com.google.gson.JsonObject;


import com.ruoyi.common.core.redis.RedisCache;


import com.ruoyi.common.enums.ServiceFromEnum;


import com.ruoyi.common.utils.DtoConversionUtils;


import com.ruoyi.common.utils.HttpUtil;


import com.ruoyi.common.utils.RSAPublicKeyExample;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.http.HttpUtils;


import com.ruoyi.common.utils.sign.Md5Utils;


import com.ruoyi.quartz.util.RandomStringGenerator;


import com.smartor.common.SendService;


import com.smartor.common.RandomStringGenerator;


import com.smartor.domain.*;


import com.smartor.mapper.ServiceSubtaskMapper;


import com.smartor.mapper.ServiceTaskMapper;


@@ -26,7 +22,6 @@


import com.smartor.service.*;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections4.CollectionUtils;


import org.apache.commons.lang3.ObjectUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.stereotype.Component;


@@ -36,7 +31,6 @@


import java.io.File;


import java.io.FileWriter;


import java.io.IOException;


import java.io.UnsupportedEncodingException;


import java.lang.reflect.Type;


import java.net.URLEncoder;


import java.nio.charset.StandardCharsets;


@@ -44,9 +38,7 @@


import java.nio.file.Paths;


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.LocalTime;


import java.time.ZoneId;


import java.time.format.DateTimeFormatter;


import java.util.*;


@@ -387,8 +379,7 @@


                    }




                } else if (descByCode.equals("短信")) {


                    RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();


                    String taskId = rsaPublicKeyExample.encryptedData(ivrTask1.getTaskid().toString(), pub_key);




                    for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) {


                        log.error("短信长期任务发送---------进来了吗？{}", serviceSubtask);


                        boolean dateToday = isDateToday(serviceSubtask.getLongSendTime());


@@ -401,33 +392,19 @@


                                    serviceSubtask.setResult("error");


                                    serviceSubtask.setRemark(patArchive.getNotrequiredreason());


                                    serviceSubtask.setSendstate(4L);


//                                    serviceSubtask.setFinishtime(new Date());


                                    iServiceSubtaskService.insertServiceSubtask(serviceSubtask);


                                    continue;


                                }


                                String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);




                                SendMagParam sendMagParam = new SendMagParam();


                                sendMagParam.setType("4");


                                ServiceOutPath serviceOutPath = new ServiceOutPath();


                                serviceOutPath.setParam1(taskId);


                                serviceOutPath.setParam2(patid);


                                serviceOutPath.setParam3(ivrTask1.getTaskName());


                                serviceOutPath.setCreateTime(new Date());


                                iServiceOutPathService.insertServiceOutPath(serviceOutPath);


                                //十六进制，再加小时数


                                String format = String.format("%03X", serviceOutPath.getId()) + RandomStringGenerator.generateRandomString();


                                serviceOutPath.setRadix(format);


                                serviceOutPath.setUpdateTime(new Date());


                                iServiceOutPathService.updateServiceOutPath(serviceOutPath);


                                sendMagParam.setPhone(serviceSubtask.getPhone());


                                sendMagParam.setUrl(ip + ":" + req_path + "/wt?p=" + format);


                                sendMagParam.setContent("您好，邀请您填写出院调查表，请点击" + sendMagParam.getUrl() + "   填写。感谢您配合！");


                                sendMagParam.setContent("您好，邀请您填写出院调查表，请点击" + serviceSubtask.getOutPath() + "   填写。感谢您配合！");




                                //send_mac：签名值，=md5(send_source+send_to_mobiles+send_text+签名编码)，32位小写


                                String mac = "shuifang" + sendMagParam.getPhone() + sendMagParam.getContent() + "ShuiFang_jjty_20250106";


                                String mac = "shuifang" + serviceSubtask.getPhone() + sendMagParam.getContent() + "ShuiFang_jjty_20250106";




                                StringBuilder strb = new StringBuilder();


                                strb.append("send_source=shuifang&send_to_mobiles=" + sendMagParam.getPhone());


                                strb.append("send_source=shuifang&send_to_mobiles=" + serviceSubtask.getPhone());


                                strb.append("&send_text=" + sendMagParam.getContent());


                                strb.append("&send_mac=" + Md5Utils.hash(mac));


                                SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddhhmmsszzz"); // 输出日期格式