ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/ServiceSubtaskAnswerController.java

@@ -83,7 +83,7 @@
    //@PreAuthorize("@ss.hasPermi('system:answer:add')")
    @Log(title = "任务问卷问题选项", businessType = BusinessType.INSERT)
    @ApiOperation("新增任务问卷问题选项")
@PostMapping("/add")
    @PostMapping("/add")
    public AjaxResult add(@RequestBody ServiceSubtaskAnswer serviceSubtaskAnswer) {
        SysUser user = getLoginUser().getUser();
        serviceSubtaskAnswer.setOrgid(user.getOrgid());
@@ -96,7 +96,7 @@
    //@PreAuthorize("@ss.hasPermi('system:answer:edit')")
    @Log(title = "任务问卷问题选项", businessType = BusinessType.UPDATE)
    @ApiOperation("修改任务问卷问题选项")
@PostMapping("/edit")
    @PostMapping("/edit")
    public AjaxResult edit(@RequestBody ServiceSubtaskAnswer serviceSubtaskAnswer) {
        log.info("【saveQuestionCache-----edit】的入参为：{}", serviceSubtaskAnswer);
        return toAjax(serviceSubtaskAnswerService.updateServiceSubtaskAnswer(serviceSubtaskAnswer));

 ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/ServiceSubtaskController.java

@@ -1,6 +1,8 @@
package com.ruoyi.web.controller.smartor;

import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.pagehelper.ISelect;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
@@ -14,20 +16,21 @@
import com.ruoyi.common.core.domain.model.LoginUser;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.dx.MessageSend;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.enums.MsgLSEnum;
import com.ruoyi.common.enums.PreachFormEnum;
import com.ruoyi.common.enums.SendStateEnum;
import com.ruoyi.common.exception.base.BaseException;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.DtoConversionUtils;
import com.ruoyi.common.utils.PageUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.*;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.utils.reflect.ReflectUtils;
import com.ruoyi.quartz.service.ICollectHISService;
import com.ruoyi.quartz.task.RyTask;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.system.service.ISysConfigService;
import com.ruoyi.system.service.ISysUserDeptService;
import com.smartor.common.LSHospTokenUtil;
import com.smartor.common.QwenLLMUtil;
import com.smartor.domain.*;
import com.smartor.domain.VO.HeLibraryCountVO;
@@ -50,6 +53,8 @@

import javax.servlet.http.HttpServletResponse;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
@@ -238,7 +243,7 @@
            for (ServiceSubtaskExport serviceSubtaskExport : serviceSubtaskExports) {
                String pf = PreachFormEnum.getDescByCode(serviceSubtaskExport.getPreachform());
                serviceSubtaskExport.setPreachform(pf);
                if(serviceSubtaskExport.getSendstate() != null) {
                if (serviceSubtaskExport.getSendstate() != null) {
                    String stName = SendStateEnum.getDescByCode("" + serviceSubtaskExport.getSendstate());
                    serviceSubtaskExport.setStName(stName);
                }
@@ -555,25 +560,21 @@

        Integer statisticaltype = serviceSubtaskCountReq.getStatisticaltype();

        if(ObjectUtils.isNotEmpty(statisticaltype)){
        if (ObjectUtils.isNotEmpty(statisticaltype)) {
            SysUser user = getLoginUser().getUser();
            if(!isAdmin.contains(user.getUserId())){
                if(statisticaltype==1){
                    if(CollectionUtils.isEmpty(serviceSubtaskCountReq.getLeavehospitaldistrictcodes())){
            if (!isAdmin.contains(user.getUserId())) {
                if (statisticaltype == 1) {
                    if (CollectionUtils.isEmpty(serviceSubtaskCountReq.getLeavehospitaldistrictcodes())) {
                        //全部病区
                        String deptInfo = user.getDeptInfo();
                        List<String> leavehospitaldistrictcodes = JSON.parseArray(deptInfo)
                                .stream()
                                .map(item -> (String) ((List<?>) item).get(0)).collect(Collectors.toList());
                        List<String> leavehospitaldistrictcodes = JSON.parseArray(deptInfo).stream().map(item -> (String) ((List<?>) item).get(0)).collect(Collectors.toList());
                        serviceSubtaskCountReq.setLeavehospitaldistrictcodes(leavehospitaldistrictcodes);
                    }
                }else if(statisticaltype==2){
                    if(CollectionUtils.isEmpty(serviceSubtaskCountReq.getDeptcodes())){
                } else if (statisticaltype == 2) {
                    if (CollectionUtils.isEmpty(serviceSubtaskCountReq.getDeptcodes())) {
                        //全部科室
                        String hospInfo = user.getHospInfo();
                        List<String> deptCodes = JSON.parseArray(hospInfo)
                                .stream()
                                .map(item -> (String) ((List<?>) item).get(0)).collect(Collectors.toList());
                        List<String> deptCodes = JSON.parseArray(hospInfo).stream().map(item -> (String) ((List<?>) item).get(0)).collect(Collectors.toList());
                        serviceSubtaskCountReq.setDeptcodes(deptCodes);
                    }
                }
@@ -878,6 +879,17 @@
        return serviceSubtaskService.getHeLibraryCount(heLibraryCountVO);
    }

    /**
     * æ‰‹åŠ¨å‘送问卷模板的短信功能
     *
     * @param subid
     * @return
     */
    @GetMapping(value = "/smsSubTask/{subid}")
    public Map<String, Object> smsSubTask(@PathVariable("subid") Long subid) {
        return serviceSubtaskService.smsSubTask(subid);
    }


    @PostMapping("/test")
    public void test() {
@@ -885,12 +897,12 @@
    }

    @PostMapping("/compensateTasktest")
    public void compensateTasktest(@RequestParam("subId")Long subId) {
    public void compensateTasktest(@RequestParam("subId") Long subId) {
        ryTask.compensateTaskTest(subId);
    }

    @PostMapping("/longTaskSendtest")
    public void longTaskSendtest(@RequestParam("subId")Long subId) {
    public void longTaskSendtest(@RequestParam("subId") Long subId) {
        ryTask.longTaskSendTest(subId);
    }

@@ -905,8 +917,7 @@
    }

    @PostMapping("/qwenLLMTest")
    public int qwenLLMTest(@RequestParam("voiceText") String questionText, @RequestParam("voiceText") String voiceText,
                                      @RequestParam("value") String value,@RequestParam("regexText") String regexText) {
    public int qwenLLMTest(@RequestParam("voiceText") String questionText, @RequestParam("voiceText") String voiceText, @RequestParam("value") String value, @RequestParam("regexText") String regexText) {
        int result = ryTask.qwenLLMTest(questionText, voiceText, value, regexText);
        return result;
    }

 ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/SmsTempletController.java

@@ -1,8 +1,10 @@
package com.smartor.controller;
package com.ruoyi.web.controller.smartor;

import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletResponse;

import cn.hutool.core.util.ObjectUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
@@ -35,11 +37,13 @@
     * æŸ¥è¯¢çŸ­ä¿¡æ¨¡æ¿åˆ—表
     */
    //@PreAuthorize("@ss.hasPermi('smartor:smstemplet:list')")
    @PostMapping("list")
    public TableDataInfo list(@RequestBody SmsTemplet smsTemplet) {
        startPage();
    @PostMapping("/list")
    public Map<String, Object> list(@RequestBody SmsTemplet smsTemplet) {
        //这个不需要分页，一个科室也不会有多少条短信模板
        smsTemplet.setPageNum(null);
        smsTemplet.setPageSize(null);
        List<SmsTemplet> list = smsTempletService.selectSmsTempletList(smsTemplet);
        return getDataTable(list);
        return getDataTable3(ObjectUtil.isNotEmpty(list)?list.size():0, list);
    }

    /**

 ruoyi-common/src/main/java/com/ruoyi/common/utils/DateUtils.java

@@ -4,6 +4,7 @@
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.*;
import java.time.temporal.ChronoUnit;
import java.util.Date;

import org.apache.commons.lang3.time.DateFormatUtils;
@@ -114,7 +115,9 @@
     * è®¡ç®—相差天数
     */
    public static int differentDaysByMillisecond(Date date1, Date date2) {
        return Math.abs((int) ((date2.getTime() - date1.getTime()) / (1000 * 3600 * 24)));
        LocalDate d1 = date1.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
        LocalDate d2 = date2.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
        return (int) ChronoUnit.DAYS.between(d1, d2);
    }

    /**

 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java

@@ -1346,7 +1346,7 @@
        Map<String, String> headerMap = new HashMap<>();
        headerMap.put("sign", encode);
        String result = HttpUtils.sendPostByHeader(wxqqxx.get(3), body, headerMap);

        log.info("【getWXCode】微信公众号返回参数：{}", result);
        JSONObject jsonObject = JSONObject.parseObject(result);
        String code = (String) jsonObject.toString();
        return code;

 ruoyi-system/src/main/java/com/ruoyi/system/domain/SmsTemplet.java

@@ -1,7 +1,9 @@
package com.ruoyi.system.domain;

import java.util.Date;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.ruoyi.common.annotation.Excel;
@@ -13,114 +15,84 @@
 * @author smartor
 * @date 2023-03-06
 */
public class SmsTemplet extends BaseEntity
{
@Data
public class SmsTemplet extends BaseEntity {
    private static final long serialVersionUID = 1L;

    /** $column.columnComment */
    /**
     * ä¸»é”®
     */
    private Long templetid;

    /** $column.columnComment */
    /**
     * çŸ­ä¿¡æ¨¡æ¿ç¼–号
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String templetno;

    /** $column.columnComment */
    /**
     * çŸ­ä¿¡æ¨¡æ¿åç§°
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String templetname;

    /** $column.columnComment */
    /**
     * æ¨¡æ¿å†…容
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String templetcontent;

    /** $column.columnComment */
    /**
     * éƒ¨é—¨ç¼–码
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String deptCode;

    /**
     * éƒ¨é—¨åç§°
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String deptName;

    /**
     * ç—…区编码
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String wardCode;

    /**
     * ç—…区名称
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String wardName;

    /**
     * ç”¨æˆ·å·¥å·
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String userName;

    /**
     * ç”¨æˆ·é“ç®”
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private String nickName;

    /**
     * $column.columnComment
     */
    private String delFlag;

    /** $column.columnComment */
    /**
     * $column.columnComment
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private Long isupload;

    /** $column.columnComment */
    /**
     * $column.columnComment
     */
    @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
    private Date uploadTime;

    public void setTempletid(Long templetid)
    {
        this.templetid = templetid;
    }

    public Long getTempletid()
    {
        return templetid;
    }
    public void setTempletno(String templetno)
    {
        this.templetno = templetno;
    }

    public String getTempletno()
    {
        return templetno;
    }
    public void setTempletname(String templetname)
    {
        this.templetname = templetname;
    }

    public String getTempletname()
    {
        return templetname;
    }
    public void setTempletcontent(String templetcontent)
    {
        this.templetcontent = templetcontent;
    }

    public String getTempletcontent()
    {
        return templetcontent;
    }
    public void setDelFlag(String delFlag)
    {
        this.delFlag = delFlag;
    }

    public String getDelFlag()
    {
        return delFlag;
    }
    public void setIsupload(Long isupload)
    {
        this.isupload = isupload;
    }

    public Long getIsupload()
    {
        return isupload;
    }
    public void setUploadTime(Date uploadTime)
    {
        this.uploadTime = uploadTime;
    }

    public Date getUploadTime()
    {
        return uploadTime;
    }

    @Override
    public String toString() {
        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
            .append("templetid", getTempletid())
            .append("templetno", getTempletno())
            .append("templetname", getTempletname())
            .append("templetcontent", getTempletcontent())
            .append("delFlag", getDelFlag())
            .append("updateBy", getUpdateBy())
            .append("updateTime", getUpdateTime())
            .append("createBy", getCreateBy())
            .append("createTime", getCreateTime())
            .append("isupload", getIsupload())
            .append("uploadTime", getUploadTime())
            .toString();
    }
}

 ruoyi-system/src/main/java/com/ruoyi/system/mapper/SmsTempletMapper.java

@@ -4,6 +4,8 @@

import java.util.List;

import org.apache.ibatis.annotations.Param;

/**
 * çŸ­ä¿¡æ¨¡æ¿Mapper接口
 *
@@ -58,5 +60,5 @@
     * @param templetids éœ€è¦åˆ é™¤çš„数据主键集合
     * @return ç»“æžœ
     */
    public int deleteSmsTempletByTempletids(Long[] templetids);
    public int deleteSmsTempletByTempletids(@Param("templetids") Long[] templetids);
}

 ruoyi-system/src/main/java/com/ruoyi/system/service/impl/SmsTempletServiceImpl.java

@@ -1,6 +1,7 @@
package com.ruoyi.system.service.impl;

import java.util.List;

import com.ruoyi.common.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -15,8 +16,7 @@
 * @date 2023-03-06
 */
@Service
public class SmsTempletServiceImpl implements ISmsTempletService
{
public class SmsTempletServiceImpl implements ISmsTempletService {
    @Autowired
    private SmsTempletMapper smsTempletMapper;

@@ -27,8 +27,7 @@
     * @return çŸ­ä¿¡æ¨¡æ¿
     */
    @Override
    public SmsTemplet selectSmsTempletByTempletid(Long templetid)
    {
    public SmsTemplet selectSmsTempletByTempletid(Long templetid) {
        return smsTempletMapper.selectSmsTempletByTempletid(templetid);
    }

@@ -39,8 +38,7 @@
     * @return çŸ­ä¿¡æ¨¡æ¿
     */
    @Override
    public List<SmsTemplet> selectSmsTempletList(SmsTemplet smsTemplet)
    {
    public List<SmsTemplet> selectSmsTempletList(SmsTemplet smsTemplet) {
        return smsTempletMapper.selectSmsTempletList(smsTemplet);
    }

@@ -51,8 +49,7 @@
     * @return ç»“æžœ
     */
    @Override
    public int insertSmsTemplet(SmsTemplet smsTemplet)
    {
    public int insertSmsTemplet(SmsTemplet smsTemplet) {
        smsTemplet.setCreateTime(DateUtils.getNowDate());
        return smsTempletMapper.insertSmsTemplet(smsTemplet);
    }
@@ -64,8 +61,7 @@
     * @return ç»“æžœ
     */
    @Override
    public int updateSmsTemplet(SmsTemplet smsTemplet)
    {
    public int updateSmsTemplet(SmsTemplet smsTemplet) {
        smsTemplet.setUpdateTime(DateUtils.getNowDate());
        return smsTempletMapper.updateSmsTemplet(smsTemplet);
    }
@@ -77,9 +73,8 @@
     * @return ç»“æžœ
     */
    @Override
    public int deleteSmsTempletByTempletids(Long[] templetids)
    {
        return smsTempletMapper.deleteSmsTempletByTempletids(templetids);
    public int deleteSmsTempletByTempletids(Long[] templetids) {
        return  smsTempletMapper.deleteSmsTempletByTempletids(templetids);
    }

    /**
@@ -89,8 +84,7 @@
     * @return ç»“æžœ
     */
    @Override
    public int deleteSmsTempletByTempletid(Long templetid)
    {
    public int deleteSmsTempletByTempletid(Long templetid) {
        return smsTempletMapper.deleteSmsTempletByTempletid(templetid);
    }
}

 ruoyi-system/src/main/resources/mapper/system/SmsTempletMapper.xml

@@ -1,40 +1,72 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ruoyi.system.mapper.SmsTempletMapper">

    <resultMap type="SmsTemplet" id="SmsTempletResult">
        <result property="templetid"    column="templetid"    />
        <result property="templetno"    column="templetno"    />
        <result property="templetname"    column="templetname"    />
        <result property="templetcontent"    column="templetcontent"    />
        <result property="delFlag"    column="del_flag"    />
        <result property="updateBy"    column="update_by"    />
        <result property="updateTime"    column="update_time"    />
        <result property="createBy"    column="create_by"    />
        <result property="createTime"    column="create_time"    />
        <result property="isupload"    column="isupload"    />
        <result property="uploadTime"    column="upload_time"    />
        <result property="guid"    column="guid"    />
        <result property="orgid"    column="orgid"    />
        <result property="templetid" column="templetid"/>
        <result property="templetno" column="templetno"/>
        <result property="templetname" column="templetname"/>
        <result property="templetcontent" column="templetcontent"/>
        <result property="delFlag" column="del_flag"/>
        <result property="updateBy" column="update_by"/>
        <result property="updateTime" column="update_time"/>
        <result property="createBy" column="create_by"/>
        <result property="createTime" column="create_time"/>
        <result property="isupload" column="isupload"/>
        <result property="uploadTime" column="upload_time"/>
        <result property="guid" column="guid"/>
        <result property="orgid" column="orgid"/>
        <result property="deptCode" column="dept_code"/>
        <result property="deptName" column="dept_name"/>
        <result property="wardName" column="ward_name"/>
        <result property="wardCode" column="ward_code"/>
        <result property="userName" column="user_name"/>
        <result property="nickName" column="nick_name"/>

    </resultMap>

    <sql id="selectSmsTempletVo">
        select templetid, templetno, orgid, templetname, templetcontent, del_flag, update_by, guid, update_time, create_by, create_time, isupload, upload_time from sms_templet
        select templetid,
               templetno,
               orgid,
               templetname,
               templetcontent,
               del_flag,
               update_by,
               guid,
               update_time,
               create_by,
               create_time,
               isupload,
               upload_time,
               dept_code,
               dept_name,
               ward_name,
               ward_code,
               user_name,
               nick_name
        from sms_templet
    </sql>

    <select id="selectSmsTempletList" parameterType="SmsTemplet" resultMap="SmsTempletResult">
        <include refid="selectSmsTempletVo"/>
        where 1=1
            <if test="orgid != null and orgid != ''">
                AND orgid = #{orgid}
            </if>
            <if test="templetno != null  and templetno != ''"> and templetno = #{templetno}</if>
            <if test="templetname != null  and templetname != ''"> and templetname like concat('%', #{templetname}, '%')</if>
            <if test="templetcontent != null  and templetcontent != ''"> and templetcontent = #{templetcontent}</if>
            <if test="isupload != null "> and isupload = #{isupload}</if>
            <if test="uploadTime != null "> and upload_time = #{uploadTime}</if>
        <if test="orgid != null and orgid != ''">
            AND orgid = #{orgid}
        </if>
        <if test="templetno != null  and templetno != ''">and templetno = #{templetno}</if>
        <if test="templetname != null  and templetname != ''">and templetname like concat('%', #{templetname}, '%')</if>
        <if test="templetcontent != null  and templetcontent != ''">and templetcontent = #{templetcontent}</if>
        <if test="isupload != null ">and isupload = #{isupload}</if>
        <if test="uploadTime != null ">and upload_time = #{uploadTime}</if>
        <if test="deptCode != null  and deptCode != ''">and dept_code = #{deptCode}</if>
        <if test="deptName != null  and deptName != ''">and dept_name = #{deptName}</if>
        <if test="wardName != null  and wardName != ''">and ward_name = #{wardName}</if>
        <if test="wardCode != null  and wardCode != ''">and ward_code = #{wardCode}</if>
        <if test="userName != null  and userName != ''">and user_name = #{userName}</if>
        <if test="nickName != null  and nickName != ''">and nick_name = #{nickName}</if>
    </select>

    <select id="selectSmsTempletByTempletid" parameterType="Long" resultMap="SmsTempletResult">
@@ -42,10 +74,10 @@
        where templetid = #{templetid}
    </select>

    <insert id="insertSmsTemplet" parameterType="SmsTemplet">
    <insert id="insertSmsTemplet" parameterType="SmsTemplet" useGeneratedKeys="true"
            keyProperty="templetid">
        insert into sms_templet
        <trim prefix="(" suffix=")" suffixOverrides=",">
            <if test="templetid != null">templetid,</if>
            <if test="templetno != null">templetno,</if>
            <if test="templetname != null">templetname,</if>
            <if test="templetcontent != null">templetcontent,</if>
@@ -58,9 +90,14 @@
            <if test="uploadTime != null">upload_time,</if>
            <if test="guid != null">guid,</if>
            <if test="orgid != null">orgid,</if>
         </trim>
            <if test="deptCode != null">dept_code,</if>
            <if test="deptName != null">dept_name,</if>
            <if test="wardCode != null">ward_code,</if>
            <if test="wardName != null">ward_name,</if>
            <if test="userName != null">user_name,</if>
            <if test="nickName != null">nick_name,</if>
        </trim>
        <trim prefix="values (" suffix=")" suffixOverrides=",">
            <if test="templetid != null">#{templetid},</if>
            <if test="templetno != null">#{templetno},</if>
            <if test="templetname != null">#{templetname},</if>
            <if test="templetcontent != null">#{templetcontent},</if>
@@ -73,7 +110,13 @@
            <if test="uploadTime != null">#{uploadTime},</if>
            <if test="guid != null">#{guid},</if>
            <if test="orgid != null">#{orgid},</if>
         </trim>
            <if test="deptCode != null">#{deptCode},</if>
            <if test="deptName != null">#{deptName},</if>
            <if test="wardCode != null">#{wardCode},</if>
            <if test="wardName != null">#{wardName},</if>
            <if test="userName != null">#{userName},</if>
            <if test="nickName != null">#{nickName},</if>
        </trim>
    </insert>

    <update id="updateSmsTemplet" parameterType="SmsTemplet">
@@ -91,17 +134,25 @@
            <if test="uploadTime != null">upload_time = #{uploadTime},</if>
            <if test="guid != null">guid = #{guid},</if>
            <if test="orgid != null">orgid = #{orgid},</if>
            <if test="deptCode != null">dept_code = #{deptCode},</if>
            <if test="deptName != null">dept_name = #{deptName},</if>
            <if test="wardCode != null">ward_code = #{wardCode},</if>
            <if test="wardName != null">ward_name = #{wardName},</if>
            <if test="userName != null">user_name = #{userName},</if>
            <if test="nickName != null">nick_name = #{nickName},</if>
        </trim>
        where templetid = #{templetid}
    </update>

    <delete id="deleteSmsTempletByTempletid" parameterType="Long">
        delete from sms_templet where templetid = #{templetid}
        update sms_templet
        set del_flag = '1'
        where templetid = #{templetid}
    </delete>

    <delete id="deleteSmsTempletByTempletids" parameterType="String">
        delete from sms_templet where templetid in
        <foreach item="templetid" collection="array" open="(" separator="," close=")">
        update sms_templet set del_flag = '1' where templetid in
        <foreach item="templetid" collection="templetids" open="(" separator="," close=")">
            #{templetid}
        </foreach>
    </delete>

 smartor/pom.xml

@@ -38,6 +38,12 @@
            <artifactId>aliyun-java-sdk-ecs</artifactId>
            <version>4.24.59</version>
        </dependency>
        <!-- é˜¿é‡Œäº‘自然语言处理（NLP） SDK -->
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-alinlp</artifactId>
            <version>1.8.17</version>
        </dependency>
        <!-- é€šç”¨å·¥å…·-->
        <dependency>
            <groupId>com.ruoyi</groupId>

 smartor/src/main/java/com/smartor/common/AliNlpUtil.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,299 @@
package com.smartor.common;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.aliyuncs.CommonRequest;
import com.aliyuncs.CommonResponse;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.http.MethodType;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import com.google.gson.Gson;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.util.Arrays;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * é˜¿é‡Œäº‘自然语言处理（NLP）工具类。
 * <p>
 * æ–‡æ¡£ï¼š<a href="https://help.aliyun.com/zh/document_detail/181284.html">NLP è‡ªå­¦ä¹ å¹³å° / åŸºç¡€æ–‡æœ¬æœåŠ¡</a>
 * <p>
 * è°ƒç”¨æ–¹å¼åŸºäºŽ {@code aliyun-java-sdk-alinlp} çš„ {@link CommonRequest}：
 * ç»Ÿä¸€å‘ {@code alinlp.cn-hangzhou.aliyuncs.com} å‘送 POST è¯·æ±‚，版本号 2020-06-29，
 * é€šè¿‡ä¼ å…¥ä¸åŒçš„ {@code Action} ä¸Ž {@code ServiceCode} è°ƒç”¨å…·ä½“能力。
 * <p>
 * é…ç½®é¡¹ï¼ˆapplication.yml）：
 * <pre>
 * aliyun:
 *   nlp:
 *     access-key-id: ${accessKeyId}       # é»˜è®¤å¤ç”¨ä¸»è´¦å· accessKeyId
 *     access-key-secret: ${accessKeySecret}
 *     region-id: cn-hangzhou
 *     domain: alinlp.cn-hangzhou.aliyuncs.com
 *     version: 2020-06-29
 *     read-timeout: 5000
 *     connect-timeout: 3000
 * </pre>
 */
@Slf4j
@Component
public class AliNlpUtil {

    /** é˜¿é‡Œäº‘ AccessKey ID，默认复用主账号配置 */
    @Value("${aliyun.nlp.access-key-id:${accessKeyId:}}")
    private String accessKeyId;

    /** é˜¿é‡Œäº‘ AccessKey Secret */
    @Value("${aliyun.nlp.access-key-secret:${accessKeySecret:}}")
    private String accessKeySecret;

    /** åœ°åŸŸ ID，公共云固定为 cn-hangzhou */
    @Value("${aliyun.nlp.region-id:cn-hangzhou}")
    private String regionId;

    /** æŽ¥å…¥åŸŸå */
    @Value("${aliyun.nlp.domain:alinlp.cn-hangzhou.aliyuncs.com}")
    private String domain = "alinlp.cn-hangzhou.aliyuncs.com";

    /** API ç‰ˆæœ¬å· */
    @Value("${aliyun.nlp.version:2020-06-29}")
    private String version = "2020-06-29";

    /** è¯»å–超时（毫秒） */
    @Value("${aliyun.nlp.read-timeout:5000}")
    private int readTimeout = 5000;

    /** è¿žæŽ¥è¶…时（毫秒） */
    @Value("${aliyun.nlp.connect-timeout:3000}")
    private int connectTimeout = 3000;

    // NLP地域固定 cn-hangzhou
    private static final String REGION_ID = "cn-hangzhou";
    private static final String PRODUCT = "nlp";
    private static final String VERSION = "2020-06-08";

    private static final Gson gson = new Gson();

    private IAcsClient client;

    @PostConstruct
    private void init() {
//        String accessKeyId = "LTAI5tPfc1VJzz7VuhzcBwug";
//        String accessKeySecret = "gG1srKxPFDBNWe2oHfqmK1qsSQkf1e";

        String accessKeyId = "LTAI5t6GBf9nUXfX37CUDi4H";
        String accessKeySecret = "BtjYAES4yjvde5Lwg46sTqnZefPnOE";
        String regionId = "cn-hangzhou";
        if (StringUtils.isBlank(accessKeyId) || StringUtils.isBlank(accessKeySecret)) {
            log.warn("阿里云 NLP æœªé…ç½® AccessKey，AliNlpUtil å°†ä¸å¯ç”¨");
            return;
        }
        IClientProfile profile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
        this.client = new DefaultAcsClient(profile);
    }

    // ============================== åŸºç¡€è°ƒç”¨ ==============================

    /**
     * é€šç”¨è°ƒç”¨å…¥å£ï¼šä¼ å…¥ Action ä¸Žä¸šåŠ¡å‚数，返回解析后的 JSON å¯¹è±¡ã€‚
     *
     * @param action API åŠ¨ä½œåï¼Œä¾‹å¦‚ {@code GetWsChGeneral}
     * @param params ä¸šåŠ¡å‚数，至少需要包含 {@code ServiceCode}、{@code Text} ç­‰
     * @return æŽ¥å£è¿”回的 JSON å¯¹è±¡ï¼›å¤±è´¥æ—¶è¿”回 {@code null}
     */
    public JSONObject invoke(String action, Map<String, String> params) {
        if (client == null) {
            log.error("阿里云 NLP å®¢æˆ·ç«¯æœªåˆå§‹åŒ–，无法调用 action={}", action);
            return null;
        }
        if (StringUtils.isBlank(action)) {
            throw new IllegalArgumentException("action ä¸èƒ½ä¸ºç©º");
        }

        CommonRequest request = new CommonRequest();
        request.setSysMethod(MethodType.POST);
        request.setSysDomain(domain);
        request.setSysVersion(version);
        request.setSysAction(action);
        request.setSysReadTimeout(readTimeout);
        request.setSysConnectTimeout(connectTimeout);
        if (params != null) {
            for (Map.Entry<String, String> e : params.entrySet()) {
                if (e.getValue() != null) {
                    request.putBodyParameter(e.getKey(), e.getValue());
                }
            }
        }

        try {
            CommonResponse response = client.getCommonResponse(request);
            String data = response.getData();
            if (StringUtils.isBlank(data)) {
                log.error("阿里云 NLP è¿”回为空，action={}, params={}", action, params);
                return null;
            }
            return JSONObject.parseObject(data);
        } catch (ClientException e) {
            log.error("阿里云 NLP è°ƒç”¨å¤±è´¥ action={}, params={}, errCode={}, errMsg={}",
                    action, params, e.getErrCode(), e.getErrMsg(), e);
            return null;
        } catch (Exception e) {
            log.error("阿里云 NLP è°ƒç”¨å¼‚常 action={}, params={}", action, params, e);
            return null;
        }
    }

    // ============================== ä¾¿æ·æ–¹æ³• ==============================

    /**
     * ä¸­æ–‡åˆ†è¯ï¼ˆé€šç”¨é¢†åŸŸï¼Œé«˜çº§ç‰ˆï¼‰ã€‚
     * å¯¹åº” Action：{@code GetWsChGeneral}，ServiceCode：{@code alinlp}。
     *
     * @param text     å¾…分词文本
     * @param tokenizer åˆ†è¯ç²’度，可空。常用值：{@code GENERAL_CHN}（通用基础粒度）
     * @return åˆ†è¯ç»“果列表；调用失败返回空列表
     */
    public List<String> segmentChinese(String text, String tokenizer) {
        if (StringUtils.isBlank(text)) {
            return Collections.emptyList();
        }
        Map<String, String> params = new LinkedHashMap<>();
        params.put("ServiceCode", "alinlp");
        params.put("Text", text);
        if (StringUtils.isNotBlank(tokenizer)) {
            params.put("TokenizerId", tokenizer);
        }
        JSONObject resp = invoke("GetWsChGeneral", params);
        return parseWordsFromData(resp);
    }

    /** ä¸­æ–‡åˆ†è¯ï¼Œä½¿ç”¨é»˜è®¤é€šç”¨ç²’度 {@code GENERAL_CHN}。 */
    public List<String> segmentChinese(String text) {
        return segmentChinese(text, "GENERAL_CHN");
    }

    /**
     * æƒ…感分析（通用领域，基础版）。
     * å¯¹åº” Action：{@code GetSaChGeneral}。
     *
     * @param text å¾…分析文本
     * @return å½¢å¦‚ {@code {"sentiment":"positive","positive_prob":0.97,...}} çš„对象；失败返回 {@code null}
     */
    public JSONObject sentimentAnalysis(String text) {
        if (StringUtils.isBlank(text)) {
            return null;
        }
        Map<String, String> params = new LinkedHashMap<>();
        params.put("ServiceCode", "alinlp");
        params.put("Text", text);
        JSONObject resp = invoke("GetSaChGeneral", params);
        return extractDataObject(resp);
    }

    // æµ‹è¯•å…¥å£
    @Test
    public void main() {
        String text1 = "这家奶茶超级好喝，下次还来！";
        String text2 = "味道很差，服务态度也不好，不推荐";
        String text3 = "今天出门买了一瓶矿泉水";

        this.init();
        JSONObject res1 = sentimentAnalysis(text1);
        JSONObject res2 = sentimentAnalysis(text2);
        JSONObject res3 = sentimentAnalysis(text3);

        System.out.println("正面文本结果：" + gson.toJson(res1));
        System.out.println("负面文本结果：" + gson.toJson(res2));
        System.out.println("中性文本结果：" + gson.toJson(res3));
    }

    /**
     * å‘½åå®žä½“识别（通用领域）。
     * å¯¹åº” Action：{@code GetNerChGeneral}。
     *
     * @param text å¾…识别文本
     * @return å®žä½“列表（每个元素含 word、tag、startIndex ç­‰å­—段）；失败返回空列表
     */
    public JSONArray namedEntityRecognition(String text) {
        if (StringUtils.isBlank(text)) {
            return new JSONArray();
        }
        Map<String, String> params = new LinkedHashMap<>();
        params.put("ServiceCode", "alinlp");
        params.put("Text", text);
        JSONObject resp = invoke("GetNerChGeneral", params);
        JSONObject data = extractDataObject(resp);
        if (data == null) {
            return new JSONArray();
        }
        JSONArray arr = data.getJSONArray("result");
        return arr == null ? new JSONArray() : arr;
    }

    // ============================== å“åº”解析 ==============================

    /**
     * è§£æžé˜¿é‡Œ NLP çš„ {@code Data} å­—段（字符串化的 JSON）。
     * é¡¶å±‚响应形如：{@code {"Data":"{...}","RequestId":"..."}}。
     */
    private JSONObject extractDataObject(JSONObject resp) {
        if (resp == null) {
            return null;
        }
        String dataStr = resp.getString("Data");
        if (StringUtils.isBlank(dataStr)) {
            log.warn("阿里云 NLP å“åº”缺少 Data å­—段，resp={}", resp);
            return null;
        }
        try {
            return JSONObject.parseObject(dataStr);
        } catch (Exception e) {
            log.error("阿里云 NLP Data å­—段解析失败，dataStr={}", dataStr, e);
            return null;
        }
    }

    /**
     * ä»Žåˆ†è¯å“åº”里抽取词列表。result å½¢å¦‚ {@code [{"word":"今天","tag":"t"},...]}。
     */
    private List<String> parseWordsFromData(JSONObject resp) {
        JSONObject data = extractDataObject(resp);
        if (data == null) {
            return Collections.emptyList();
        }
        JSONArray result = data.getJSONArray("result");
        if (result == null || result.isEmpty()) {
            return Collections.emptyList();
        }
        String[] words = new String[result.size()];
        for (int i = 0; i < result.size(); i++) {
            JSONObject item = result.getJSONObject(i);
            words[i] = item == null ? "" : item.getString("word");
        }
        return Arrays.asList(words);
    }

    @Test
    public void test() {
        List <String> result = segmentChinese("阿里巴巴集团的使命是让天下没有难做的生意。");
        log.info(result.toString());
    }

    @Test
    public void testP() {
        JSONObject result = sentimentAnalysis("我觉得你可能是对的");
        log.info(result.toString());
    }
}

 smartor/src/main/java/com/smartor/domain/ServiceSubtaskCountReq.java

@@ -2,7 +2,6 @@

import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.ruoyi.common.annotation.Excel;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -45,6 +44,14 @@
    @ApiModelProperty(value = "结束时间")
    private Date endTime;

    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "出院开始时间")
    private Date hospitalStartTime;

    @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "出院结束时间")
    private Date hospitalEndTime;

    @ApiModelProperty(value = "服务类型")
    private List<Long> serviceType;


 smartor/src/main/java/com/smartor/domain/ServiceSubtaskExport.java

@@ -21,11 +21,11 @@
    private static final long serialVersionUID = 1L;

    /**
     * ä»»åŠ¡åç§°
     * ç§‘室名称
     */
    @Excel(name = "任务名称")
    @ApiModelProperty(value = "任务名称")
    private String taskName;
    @Excel(name = "科室名称")
    @ApiModelProperty(value = "科室名称")
    private String deptname;

    /**
     * å‘送人
@@ -33,28 +33,6 @@
    @Excel(name = " å§“名 ")
    @ApiModelProperty(value = "发送人")
    private String sendname;

    /**
     * å‘送状态
     */
//    @Excel(name = " ä»»åŠ¡çŠ¶æ€ ")
    @ApiModelProperty(value = "发送状态 1 è¢«é¢†å–(在任务中是新建，在服务中是被领取)  2 å¾…发送  3 å·²å‘送  4 ä¸æ‰§è¡Œ  5 å‘送失败 6 å·²å®Œæˆ 7 è¶…æ—¶(人工)")
    private Long sendstate;

    /**
     * å‘送状态
     */
    @Excel(name = " ä»»åŠ¡çŠ¶æ€ ")
    @ApiModelProperty(value = "发送状态 1 è¢«é¢†å–(在任务中是新建，在服务中是被领取)  2 å¾…发送  3 å·²å‘送  4 ä¸æ‰§è¡Œ  5 å‘送失败 6 å·²å®Œæˆ 7 è¶…æ—¶(人工)")
    private String stName;

    /**
     * å®Œæˆæ—¶é—´
     */
    @Excel(name = " å®Œæˆæ—¶é—´ ", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(pattern = "yyyy-MM-dd")
    @ApiModelProperty(value = "完成时间")
    private Date finishtime;

    /**
     * å‡ºé™¢æ—¶é—´
@@ -71,6 +49,19 @@
    @ApiModelProperty(value = "应随访日期")
    private Date visitTime;

    /**
     * å®Œæˆæ—¶é—´
     */
    @Excel(name = " å®Œæˆæ—¶é—´ ", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(pattern = "yyyy-MM-dd")
    @ApiModelProperty(value = "完成时间")
    private Date finishtime;

    /**
     * éšè®¿äººå‘˜
     */
    @Excel(name = "随访人员")
    private String updateBy;

    /**
     * åŒ»ç”Ÿå§“名
@@ -79,15 +70,32 @@
    @ApiModelProperty(value = "医生姓名")
    private String drname;

    /**
     * éšè®¿äººå‘˜
     */
    @Excel(name = "随访人员")
    private String updateBy;

    @Excel(name = "出院天数", suffix = "天")
    @ApiModelProperty(value = "出院天数")
    private Integer endDay;

    /**
     * å‡ºé™¢è¯Šæ–­
     */
    @Excel(name = " å‡ºé™¢è¯Šæ–­ ")
    @ApiModelProperty(value = "出院诊断")
    private String leavediagname;


    /**
     * å‘送状态
     */
//    @Excel(name = " ä»»åŠ¡çŠ¶æ€ ")
    @ApiModelProperty(value = "发送状态 1 è¢«é¢†å–(在任务中是新建，在服务中是被领取)  2 å¾…发送  3 å·²å‘送  4 ä¸æ‰§è¡Œ  5 å‘送失败 6 å·²å®Œæˆ 7 è¶…æ—¶(人工)")
    private Long sendstate;

    /**
     * å‘送状态
     */
    @Excel(name = " ä»»åŠ¡çŠ¶æ€ ")
    @ApiModelProperty(value = "发送状态 1 è¢«é¢†å–(在任务中是新建，在服务中是被领取)  2 å¾…发送  3 å·²å‘送  4 ä¸æ‰§è¡Œ  5 å‘送失败 6 å·²å®Œæˆ 7 è¶…æ—¶(人工)")
    private String stName;


    /**
     * èº«ä»½è¯å·
@@ -113,14 +121,6 @@


    /**
     * ç§‘室名称
     */
    @Excel(name = "科室名称")
    @ApiModelProperty(value = "科室名称")
    private String deptname;


    /**
     * å‡ºé™¢ç—…区名称
     */
    @ApiModelProperty(value = "出院病区名称")
@@ -143,10 +143,18 @@
    @Excel(name = "任务执行方式")
    private String preachform;

    /**
     * ä»»åŠ¡åç§°
     */
    @Excel(name = "任务名称")
    @ApiModelProperty(value = "任务名称")
    private String taskName;


    /**
     * å¤‡æ³¨
     */
    @Excel(name = "备注")
    @ApiModelProperty(value = "备注")
    private String remark;


 smartor/src/main/java/com/smartor/domain/entity/ServiceSubtaskEntity.java

@@ -31,6 +31,12 @@
    @ApiModelProperty(value = "主键id")
    private Long subId;

    /**
     * ä¸»é”®id集合
     */
    @ApiModelProperty(value = "主键id集合")
    private List<Long> subIdList;


    /**
     * ç¬¬ä¸‰æ–¹ä»»åŠ¡ID

 smartor/src/main/java/com/smartor/service/IServiceSubtaskService.java

@@ -186,4 +186,6 @@
    public void setFailSubTaskDefalutVal(Long failDay);

    public Map<String, Object> getHeLibraryCount(@RequestBody HeLibraryCountVO heLibraryCountVO);

    Map<String, Object> smsSubTask(Long subid);
}

 smartor/src/main/java/com/smartor/service/impl/ServiceSLTDHealthcareRecordServiceImpl.java

@@ -74,6 +74,10 @@
    @Value("${lwl_app_key}")
    private String APP_KEY;


    @Value("${spring.profiles.active}")
    private String active;

    @Override
    public List<ServiceSLTDInhospResDTO> queryHealthcareRecordList(ServiceSLTDInhospReqVO reqVO) {
        try {
@@ -783,6 +787,16 @@
        patMedInhosp.setCampusid(dto.getCampusId());
        if (StringUtils.isNotEmpty(dto.getHealthcareRecordStatus()) && dto.getHealthcareRecordStatus().equals("FH0109.25"))
            patMedInhosp.setRemark("预出院");
        if (active.equals("nhfy") && dto.getAreaId() != null && dto.getAreaId().toString().equals("40003483") && StringUtils.isNotEmpty(patMedInhosp.getPatname())) {
            //南华附一的产科，要求不生成“之子、之女、之婴”的随访任务
            if (patMedInhosp.getPatname().contains("之子") || patMedInhosp.getPatname().contains("之女") || patMedInhosp.getPatname().contains("之婴")) {
                patMedInhosp.setDeptcheckFlag("3");
                patMedInhosp.setWardcheckFlag("3");
                patMedInhosp.setDiagcheckFlag("3");
                patMedInhosp.setRemark(patMedInhosp.getRemark() + ";不生成之子、之女、之婴问卷");
            }
        }

        return patMedInhosp;
    }

@@ -815,12 +829,11 @@
     */
    private PatArchive processPatientArchive(ServiceSLTDInhospResDTO dto) {
        // æž„建锁的 key：基于 patientno æˆ– idcardno
        String lockKey = "pat_archive_lock:" + 
            (StringUtils.isNotEmpty(dto.getMedicalRecordNo()) ? dto.getMedicalRecordNo() : dto.getIdCardNo());
        
        String lockKey = "pat_archive_lock:" + (StringUtils.isNotEmpty(dto.getMedicalRecordNo()) ? dto.getMedicalRecordNo() : dto.getIdCardNo());

        // å°è¯•èŽ·å–分布式锁，最多等待 3 ç§’，锁定 10 ç§’自动释放
        Boolean lockAcquired = redisTemplate.opsForValue().setIfAbsent(lockKey, "1", 10, TimeUnit.SECONDS);
        

        if (lockAcquired == null || !lockAcquired) {
            log.warn("【processPatientArchive】获取分布式锁失败，跳过本次处理（其他线程正在处理），patientno={}", dto.getMedicalRecordNo());
            // ç­‰å¾…一段时间后重试查询
@@ -830,7 +843,7 @@
                Thread.currentThread().interrupt();
            }
        }
        

        try {
            return doProcessPatientArchive(dto);
        } finally {
@@ -865,9 +878,8 @@
        }

        PatArchive patArchive = buildPatientArchive(dto);
        log.info("【processPatientArchive】患者档案查重完成，patientno={}, æ˜¯å¦å·²å­˜åœ¨={}", 
            patArchive.getPatientno(), CollectionUtils.isEmpty(existingArchives) ? "否" : "是(id=" + existingArchives.get(0).getId() + ")");
        
        log.info("【processPatientArchive】患者档案查重完成，patientno={}, æ˜¯å¦å·²å­˜åœ¨={}", patArchive.getPatientno(), CollectionUtils.isEmpty(existingArchives) ? "否" : "是(id=" + existingArchives.get(0).getId() + ")");

        if (CollectionUtils.isEmpty(existingArchives)) {
            try {
                // æœ€ç»ˆç¡®è®¤æŸ¥è¯¢ï¼ˆé˜²å¾¡æ€§ç¼–程：防止Redis锁失效等极端情况）
@@ -878,15 +890,13 @@
                if (StringUtils.isNotEmpty(dto.getMedicalRecordNo())) {
                    finalQuery.setPatientno(dto.getMedicalRecordNo());
                }
                

                List<PatArchive> finalCheck = patArchiveService.selectPatArchiveList(finalQuery);
                log.info("【processPatientArchive】最终确认查询，patientno={}, idcardno={}, ç»“果数量={}", 
                    dto.getMedicalRecordNo(), dto.getIdCardNo(), finalCheck.size());
                
                log.info("【processPatientArchive】最终确认查询，patientno={}, idcardno={}, ç»“果数量={}", dto.getMedicalRecordNo(), dto.getIdCardNo(), finalCheck.size());

                if (CollectionUtils.isEmpty(finalCheck)) {
                    patArchiveService.insertPatArchive(patArchive);
                    log.info("【processPatientArchive】✓ æ–°å¢žæ‚£è€…档案成功，patientno={}, id={}", 
                        patArchive.getPatientno(), patArchive.getId());
                    log.info("【processPatientArchive】✓ æ–°å¢žæ‚£è€…档案成功，patientno={}, id={}", patArchive.getPatientno(), patArchive.getId());
                } else {
                    // å…¶ä»–线程已经插入，直接使用已有记录
                    existingArchives = finalCheck;
@@ -896,8 +906,7 @@
                    log.info("【processPatientArchive】档案已被其他线程创建，使用已有记录，id={}", patArchive.getId());
                }
            } catch (org.springframework.dao.DuplicateKeyException e) {
                log.warn("【processPatientArchive】患者档案已存在(并发插入异常)，跳过：patientno={}, idcardno={}", 
                    patArchive.getPatientno(), patArchive.getIdcardno());
                log.warn("【processPatientArchive】患者档案已存在(并发插入异常)，跳过：patientno={}, idcardno={}", patArchive.getPatientno(), patArchive.getIdcardno());
                // å¹¶å‘插入场景，重新查询获取已存在的记录
                PatArchive queryRetry = new PatArchive();
                queryRetry.setPatientno(patArchive.getPatientno());
@@ -917,8 +926,7 @@
            patArchive.setNotrequiredFlag(existingArchives.get(0).getNotrequiredFlag());
            patArchive.setNotrequiredreason(existingArchives.get(0).getNotrequiredreason());
            patArchiveService.updateArchive(patArchive);
            log.info("【processPatientArchive】✓ æ›´æ–°æ‚£è€…档案，patientno={}, id={}", 
                patArchive.getPatientno(), patArchive.getId());
            log.info("【processPatientArchive】✓ æ›´æ–°æ‚£è€…档案，patientno={}, id={}", patArchive.getPatientno(), patArchive.getId());
        }

        return patArchive;

 smartor/src/main/java/com/smartor/service/impl/ServiceSubtaskServiceImpl.java

@@ -12,7 +12,10 @@
import com.ruoyi.common.utils.*;
import com.ruoyi.common.core.service.IConfigService;
import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.system.mapper.SysConfigMapper;
import com.smartor.common.FtpService;
import com.smartor.common.MtSubmitSmUtil;
import com.smartor.config.PhoneUtils;
import com.smartor.domain.DTO.ServiceSubtaskDetailDTO;
import com.smartor.domain.*;
@@ -135,6 +138,12 @@

    @Value("${ASRCallBackPath}")
    private String ASRCallBackPath;

    @Autowired
    private MtSubmitSmUtil mtSubmitSmUtil;

    @Autowired
    private SysConfigMapper sysConfigMapper;

    @Autowired
    private RedisTemplate redisTemplate;
@@ -343,18 +352,17 @@
//            serviceTaskVO.setPreachform(result);
        }

        if(StringUtils.isNotEmpty(serviceTaskVO.getPreachformDesc())){
        if (StringUtils.isNotEmpty(serviceTaskVO.getPreachformDesc())) {
            //直接通过PreachformDesc生成List返回
            try {
                List<Map<String, Object>> mapList = objectMapper.readValue(serviceTaskVO.getPreachformDesc(), List.class);
                serviceTaskVO.setPreachformList(mapList);
            }catch (Exception e) {
            } catch (Exception e) {
            }
        }else {
            if(CollectionUtils.isNotEmpty(list)){
        } else {
            if (CollectionUtils.isNotEmpty(list)) {
                //获取该患者所有的执行状态
                List<ServiceSubtaskPreachform> serviceSubtaskPreachformList = serviceSubtaskPreachformLists.stream()
                        .filter((item -> item.getSubid().equals(list.get(0).getId()) && item.getTaskid().equals(serviceTask.getTaskid()))).collect(Collectors.toList());
                List<ServiceSubtaskPreachform> serviceSubtaskPreachformList = serviceSubtaskPreachformLists.stream().filter((item -> item.getSubid().equals(list.get(0).getId()) && item.getTaskid().equals(serviceTask.getTaskid()))).collect(Collectors.toList());
                List<Map<String, Object>> resultList = serviceSubtaskPreachformList.stream().map(item -> {
                    Map<String, Object> map = new HashMap<>();
                    map.put("sort", item.getSort());
@@ -390,7 +398,8 @@
                serviceSubtaskRes.setContinueContent(serviceSubtask.getContinueContent());
            }
//            1：待随访（2 å¾…发送）；2：随访中（3 å·²å‘送、1 è¢«é¢†å–）、3：未完成（5 å‘送失败、7、超时）、4：已完成（ 6 å·²å®Œæˆï¼‰ã€5：无需随访（4 ä¸æ‰§è¡Œï¼‰
            if (serviceSubtaskRes.getSendstate() == 1 || serviceSubtaskRes.getSendstate() == 2L || serviceSubtaskRes.getSendstate() == 3L || serviceSubtaskRes.getSendstate() == 5 || serviceSubtaskRes.getSendstate() == 7L) serviceSubtaskRes.setSendstateView(1L);
            if (serviceSubtaskRes.getSendstate() == 1 || serviceSubtaskRes.getSendstate() == 2L || serviceSubtaskRes.getSendstate() == 3L || serviceSubtaskRes.getSendstate() == 5 || serviceSubtaskRes.getSendstate() == 7L)
                serviceSubtaskRes.setSendstateView(1L);
            if (serviceSubtaskRes.getSendstate() == 6) serviceSubtaskRes.setSendstateView(2L);
            if (serviceSubtaskRes.getSendstate() == 4) serviceSubtaskRes.setSendstateView(3L);
            serviceSubtaskResList.add(serviceSubtaskRes);
@@ -694,8 +703,8 @@
                    //南华附一的icd10code是有重复的，所以不能用南华附一的icd10code去查询
                    log.info("----serviceTaskdiag的值为：{}", serviceTaskdiag);
                    if (!StringUtils.isEmpty(serviceTaskVO.getIcd10name())) {
                        String[] Icd10Names = serviceTaskVO.getIcd10name().split(",");
                        String[] Icd10codes = serviceTaskVO.getIcd10code().split(",");
                        String[] Icd10Names = serviceTaskVO.getIcd10name().split("$");
                        String[] Icd10codes = serviceTaskVO.getIcd10code().split("$");
                        for (int i = 0; i < Icd10Names.length; i++) {
                            serviceTaskdiag.setIcd10code(Icd10codes[i]);
                            serviceTaskdiag.setIcd10name(Icd10Names[i]);
@@ -773,8 +782,8 @@
                    serviceSubtask.setInhospid(patTaskRelevance.getHospid());
                    //新建完成就是待发送状态
                    serviceSubtask.setSendstate(2L);
                    serviceSubtask.setDeptcode(StringUtils.isNotEmpty(patTaskRelevance.getDeptcode())?patTaskRelevance.getDeptcode():serviceTaskVO.getDeptcode());
                    serviceSubtask.setDeptname(StringUtils.isNotEmpty(patTaskRelevance.getDeptName())?patTaskRelevance.getDeptName():serviceTaskVO.getDeptname());
                    serviceSubtask.setDeptcode(StringUtils.isNotEmpty(patTaskRelevance.getDeptcode()) ? patTaskRelevance.getDeptcode() : serviceTaskVO.getDeptcode());
                    serviceSubtask.setDeptname(StringUtils.isNotEmpty(patTaskRelevance.getDeptName()) ? patTaskRelevance.getDeptName() : serviceTaskVO.getDeptname());
                    serviceSubtask.setLeavehospitaldistrictcode(patTaskRelevance.getLeavehospitaldistrictcode());
                    serviceSubtask.setLeavehospitaldistrictname(patTaskRelevance.getLeavehospitaldistrictname());
                    serviceSubtask.setType(serviceTaskVO.getType());
@@ -797,7 +806,8 @@
                    serviceSubtask.setUpdateBy(serviceTask.getCreateBy());
                    serviceSubtask.setVisitTime(DateUtils.parseDate(serviceTaskVO.getShowTimeMorn()));
                    //如果立即执行，时间就是当前时间
                    if(serviceTaskVO.getSendType()!=null&&serviceTaskVO.getSendType()==2) serviceSubtask.setVisitTime(new Date());
                    if (serviceTaskVO.getSendType() != null && serviceTaskVO.getSendType() == 2)
                        serviceSubtask.setVisitTime(new Date());
                    if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1) {
                        serviceSubtask.setLongSendTime(patTaskRelevance.getLongSendTime());
                        serviceSubtask.setVisitTime(patTaskRelevance.getVisittime());
@@ -952,7 +962,7 @@
                    if (StringUtils.isNotEmpty(serviceTaskVO.getIcd10code())) {
                        String[] icd10codes = serviceTaskVO.getIcd10code().split(",");
                        String[] icd10names = serviceTaskVO.getIcd10name().split(",");
                        if(!active.equals("nhfy")&&!active.equals("druid")){
                        if (!active.equals("nhfy") && !active.equals("druid")) {
                            if (icd10codes.length != icd10names.length) {
                                throw new BaseException("疾病编码和疾病名称数量不一致");
                            }
@@ -3039,6 +3049,7 @@
        }
        return serviceSubtaskStatistic;
    }

    /**
     * é¦–次随访统计
     *
@@ -4481,6 +4492,60 @@
        return resultMap;
    }

    @Override
    public Map<String, Object> smsSubTask(Long subid) {
        log.info("smsSubTask的入参为：{}", subid);
        Map<String, Object> resultMap = new HashMap<>();
        resultMap.put("code", "500");
        resultMap.put("msg", "发送失败");

        //获取患者的基本信息
        ServiceSubtask serviceSubtask = selectServiceSubtaskById(subid);
        RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
        String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);
        String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key);
        String taskId = rsaPublicKeyExample.encryptedData(serviceSubtask.getTaskid().toString(), pub_key);

        //发送数据的封装
        ServiceOutPath serviceOutPath = new ServiceOutPath();
        serviceOutPath.setParam1(taskId);
        serviceOutPath.setParam2(patid);
        serviceOutPath.setParam3(serviceSubtask.getTaskName());
        serviceOutPath.setParam6(subId);
        serviceOutPath.setCreateTime(new Date());
        serviceOutPath.setOrgid(serviceSubtask.getOrgid());
        iServiceOutPathService.insertServiceOutPath(serviceOutPath);
        String format = String.format("%03X", serviceOutPath.getId());
        serviceOutPath.setRadix(format);
        serviceOutPath.setUpdateTime(new Date());
        iServiceOutPathService.updateServiceOutPath(serviceOutPath);

        SendMagParam sendMagParam = new SendMagParam();
        sendMagParam.setType("4");
        sendMagParam.setPhone(serviceSubtask.getPhone());
        sendMagParam.setUrl(StringUtils.isNotEmpty(req_path) ? localIP + ":" + req_path + "/wt?p=" + format : localIP + "/wt?p=" + format);

        SysConfig sysConfig = new SysConfig();

        sysConfig = sysConfigMapper.checkConfigKeyUnique("wj.sms.template");

        if (!Objects.isNull(sysConfig)) {
            String smsContemt = sysConfig.getConfigValue();
            sendMagParam.setContent(smsContemt.replace("${wjurl}", sendMagParam.getUrl()));
        }

        if (active.equals("nhfy")) {
            Map<String, Object> smsResult = mtSubmitSmUtil.submitSm(sendMagParam.getPhone(), sendMagParam.getContent());
            if (smsResult != null && smsResult.get("result") != null && smsResult.get("result").toString().equals("0")) {
                resultMap.put("code", "200");
                resultMap.put("msg", "发送成功");
                serviceSubtask.setRemark(StringUtils.isNotEmpty(serviceSubtask.getRemark()) ? serviceSubtask.getRemark() + ";短信发送成功" : "短信发送成功");
                log.info("是否发送成功：{}", serviceSubtask.getRemark());
                updateServiceSubtask(serviceSubtask);
            }
        }
        return resultMap;
    }

    private Boolean saveServiceSubtaskDetail(ServiceSubtask serviceSubtask) {
        Boolean result = true;

 smartor/src/main/resources/mapper/smartor/ServiceSubtaskMapper.xml

@@ -355,6 +355,12 @@
                #{state}
            </foreach>
        </if>
        <if test="subIdList != null  and sendstates.size() > 0">
            AND id IN
            <foreach collection="subIdList" item="subId" open="(" separator="," close=")">
                #{subId}
            </foreach>
        </if>
        <!-- taskIds筛选 -->
        <if test="taskIds != null and taskIds.size() > 0">
            AND taskid IN
@@ -1530,6 +1536,10 @@
            AND visit_time >= DATE(#{startTime})
            AND visit_time &lt; DATE_ADD(DATE(#{endTime}), INTERVAL 1 DAY)
        </if>
        <if test="hospitalStartTime != null and hospitalEndTime!=null">
            AND endtime >= DATE(#{hospitalStartTime})
            AND endtime &lt; DATE_ADD(DATE(#{hospitalEndTime}), INTERVAL 1 DAY)
        </if>
        <if test="visitDeptCode != null">and visit_dept_code = #{visitDeptCode}</if>
        <if test="visitDeptName != null">and visit_dept_name = #{visitDeptName}</if>
        <if test="isabnormal != null">and isabnormal = #{isabnormal}</if>
@@ -1709,6 +1719,10 @@
            AND visit_time >= DATE(#{startTime})
            AND visit_time &lt; DATE_ADD(DATE(#{endTime}), INTERVAL 1 DAY)
        </if>
        <if test="hospitalStartTime != null and hospitalEndTime!=null">
            AND endtime >= DATE(#{hospitalStartTime})
            AND endtime &lt; DATE_ADD(DATE(#{hospitalEndTime}), INTERVAL 1 DAY)
        </if>
        <if test="visitDeptCode != null">and visit_dept_code = #{visitDeptCode}</if>
        <if test="visitDeptName != null">and visit_dept_name = #{visitDeptName}</if>
        <if test="isabnormal != null">and isabnormal = #{isabnormal}</if>