11

tjx

2025-12-04 0e96e64e353192138d770c2aef62a3175c8aa648

11

 src/main/java/com/gs/dingtalk/entity/MesAdDataExc.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,135 @@
package com.gs.dingtalk.entity;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;

/**
 * 
 * @TableName MES_AD_DATA_EXC
 */
@TableName(value ="MES_AD_DATA_EXC")
@Data
public class MesAdDataExc implements Serializable {
    /**
     * 
     */
    @TableId
    private Long id;

    /**
     * 
     */
    private String scallno;

    /**
     * 
     */
    private String snedvalues;

    /**
     * 
     */
    private String errCode;

    /**
     * 
     */
    private String lineNo;

    /**
     * 
     */
    private String procNo;

    /**
     * 
     */
    private String procLine;

    /**
     * 
     */
    private Date recDate;

    /**
     * 
     */
    private String createBy;

    /**
     * 
     */
    private Date createDate;

    /**
     * 
     */
    private String lastupdateBy;

    /**
     * 
     */
    private Date lastupdateDate;

    /**
     * 
     */
    private String memo;

    /**
     * 
     */
    private String fstatus;

    /**
     * 
     */
    private String excBy;

    /**
     * 
     */
    private Date excDate;

    /**
     * 
     */
    private String errMemo;

    /**
     * 
     */
    private String recBy;

    /**
     * 
     */
    private String errExc;

    /**
     * 
     */
    private Long mid;

    /**
     * 5分钟
     */
    private Integer fiveMinute;

    /**
     * 15分钟
     */
    private Integer fifteenMinute;

    /**
     * 30分钟
     */
    private Integer thirtyMinute;

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

 src/main/java/com/gs/dingtalk/entity/SendMessage.java

@@ -141,4 +141,19 @@
     * (分钟)
     */
    private Integer rem;

    /**
     *
     */
    private Integer fiveMinute;

    /**
     *
     */
    private Integer fifteenMinute;

    /**
     *
     */
    private Integer thirtyMinute;
}

 src/main/java/com/gs/dingtalk/mapper/MesAdDataExcMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,18 @@
package com.gs.dingtalk.mapper;

import com.gs.dingtalk.entity.MesAdDataExc;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;

/**
* @author Administrator
* @description é’ˆå¯¹è¡¨ã€MES_AD_DATA_EXC】的数据库操作Mapper
* @createDate 2025-12-04 15:44:14
* @Entity com.gs.dingtalk.entity.MesAdDataExc
*/
public interface MesAdDataExcMapper extends BaseMapper<MesAdDataExc> {

}





 src/main/java/com/gs/dingtalk/service/MesAdDataExcService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,13 @@
package com.gs.dingtalk.service;

import com.gs.dingtalk.entity.MesAdDataExc;
import com.baomidou.mybatisplus.extension.service.IService;

/**
* @author Administrator
* @description é’ˆå¯¹è¡¨ã€MES_AD_DATA_EXC】的数据库操作Service
* @createDate 2025-12-04 15:44:14
*/
public interface MesAdDataExcService extends IService<MesAdDataExc> {

}

 src/main/java/com/gs/dingtalk/service/SendMessageService.java

@@ -7,5 +7,7 @@

public interface SendMessageService extends IService<SendMessage> {

    List<SendMessage> getSendMessageList();
    List<SendMessage> getSendMessageList(int Minutes);

    boolean setSendMessage(Long id,int Minutes);
}

 src/main/java/com/gs/dingtalk/service/impl/MesAdDataExcServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package com.gs.dingtalk.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gs.dingtalk.entity.MesAdDataExc;
import com.gs.dingtalk.service.MesAdDataExcService;
import com.gs.dingtalk.mapper.MesAdDataExcMapper;
import org.springframework.stereotype.Service;

/**
* @author Administrator
* @description é’ˆå¯¹è¡¨ã€MES_AD_DATA_EXC】的数据库操作Service实现
* @createDate 2025-12-04 15:44:14
*/
@Service
public class MesAdDataExcServiceImpl extends ServiceImpl<MesAdDataExcMapper, MesAdDataExc>
    implements MesAdDataExcService{

}





 src/main/java/com/gs/dingtalk/service/impl/SendDingtalkServiceImpl.java

@@ -104,7 +104,7 @@

    @Override
    public void chatSendMessage() throws Exception {
        List<SendMessage> sendMessageList = sendMessageService.getSendMessageList();
        List<SendMessage> sendMessageList = sendMessageService.getSendMessageList(0);

        sendMessageList.forEach(s -> {

@@ -129,7 +129,7 @@
    }

    private void getMessage(List<SendDingtalk> list, int Minutes) {
        List<SendMessage> sendMessageList = sendMessageService.getSendMessageList();
        List<SendMessage> sendMessageList = sendMessageService.getSendMessageList(Minutes);

        sendMessageList.forEach(s -> {

@@ -159,6 +159,8 @@

            if (dingTalkMessage.getErrcode() == 0) {
                System.out.println("发送成功");

                sendMessageService.setSendMessage(s.getId(),Minutes);
            }
        });
    }

 src/main/java/com/gs/dingtalk/service/impl/SendMessageServiceImpl.java

@@ -1,9 +1,12 @@
package com.gs.dingtalk.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gs.dingtalk.entity.MesAdDataExc;
import com.gs.dingtalk.entity.SendMessage;
import com.gs.dingtalk.mapper.SendMessageMapper;
import com.gs.dingtalk.service.MesAdDataExcService;
import com.gs.dingtalk.service.SendMessageService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
@@ -16,11 +19,26 @@
@Transactional(rollbackFor = Exception.class)
public class SendMessageServiceImpl extends ServiceImpl<SendMessageMapper, SendMessage> implements SendMessageService {

    private final MesAdDataExcService mesAdDataExcService;

    @Override
    public List<SendMessage> getSendMessageList() {
    public List<SendMessage> getSendMessageList(int Minutes) {
        LambdaQueryWrapper<SendMessage> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(SendMessage::getFstatus, "待处理");
        queryWrapper
                .eq(SendMessage::getFstatus, "待处理")
                .eq(Minutes == 5,SendMessage::getFiveMinute, 0)
                .eq(Minutes == 15,SendMessage::getFifteenMinute, 0)
                .eq(Minutes == 30,SendMessage::getThirtyMinute, 0);
        return list(queryWrapper);
    }

    @Override
    public boolean setSendMessage(Long id, int Minutes) {
        LambdaUpdateWrapper<MesAdDataExc> wrapper = new LambdaUpdateWrapper<>();
        wrapper.set(Minutes == 5, MesAdDataExc::getFiveMinute, 1)
                .set(Minutes == 15, MesAdDataExc::getFifteenMinute, 1)
                .set(Minutes == 30, MesAdDataExc::getThirtyMinute, 1)
                .eq(MesAdDataExc::getId, id);
        return mesAdDataExcService.update(wrapper);
    }
}

 src/main/resources/application.yml

@@ -5,7 +5,7 @@
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: oracle.jdbc.OracleDriver
    url: jdbc:oracle:thin:@172.16.0.219:1521/orcl
    url: jdbc:oracle:thin:@192.168.0.100:1521/orcl
    username: yc_dev
    password: ycdev
    druid:

 src/main/resources/mapper/MesAdDataExcMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,40 @@
<?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">
<mapper namespace="com.gs.dingtalk.mapper.MesAdDataExcMapper">

    <resultMap id="BaseResultMap" type="com.gs.dingtalk.entity.MesAdDataExc">
            <id property="id" column="ID" />
            <result property="scallno" column="SCALLNO" />
            <result property="snedvalues" column="SNEDVALUES" />
            <result property="errCode" column="ERR_CODE" />
            <result property="lineNo" column="LINE_NO" />
            <result property="procNo" column="PROC_NO" />
            <result property="procLine" column="PROC_LINE" />
            <result property="recDate" column="REC_DATE" />
            <result property="createBy" column="CREATE_BY" />
            <result property="createDate" column="CREATE_DATE" />
            <result property="lastupdateBy" column="LASTUPDATE_BY" />
            <result property="lastupdateDate" column="LASTUPDATE_DATE" />
            <result property="memo" column="MEMO" />
            <result property="fstatus" column="FSTATUS" />
            <result property="excBy" column="EXC_BY" />
            <result property="excDate" column="EXC_DATE" />
            <result property="errMemo" column="ERR_MEMO" />
            <result property="recBy" column="REC_BY" />
            <result property="errExc" column="ERR_EXC" />
            <result property="mid" column="MID" />
            <result property="fiveMinute" column="FIVE_MINUTE" />
            <result property="fifteenMinute" column="FIFTEEN_MINUTE" />
            <result property="thirtyMinute" column="THIRTY_MINUTE" />
    </resultMap>

    <sql id="Base_Column_List">
        ID,SCALLNO,SNEDVALUES,ERR_CODE,LINE_NO,PROC_NO,
        PROC_LINE,REC_DATE,CREATE_BY,CREATE_DATE,LASTUPDATE_BY,
        LASTUPDATE_DATE,MEMO,FSTATUS,EXC_BY,EXC_DATE,
        ERR_MEMO,REC_BY,ERR_EXC,MID,FIVE_MINUTE,
        FIFTEEN_MINUTE,THIRTY_MINUTE
    </sql>
</mapper>