Merge branch 'yukun'

 shasteel-biz/src/main/java/com/iailab/module/shasteel/api/controller/admin/MessageInfoController.java

对比新文件
@@ -0,0 +1,40 @@
package com.iailab.module.shasteel.api.controller.admin;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.iailab.framework.common.pojo.CommonResult;
import com.iailab.framework.common.pojo.PageResult;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import com.iailab.module.shasteel.job.service.MessageInfoService;
import io.swagger.v3.oas.annotations.Operation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

import static com.iailab.framework.common.pojo.CommonResult.success;

@Slf4j
@RestController
@RequestMapping("/shasteel/api/message")
public class MessageInfoController {

    @Autowired
    private MessageInfoService messageInfoService;

    @GetMapping("/page")
    public CommonResult<PageResult<MessageInfoEntity>> queryMessagePage(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize) {
        PageResult<MessageInfoEntity> page = messageInfoService.getMessagePage(pageNo,pageSize);
        return success(page);
    }

    @GetMapping("/count")
    public long getUnreadMessageCount(){
        return messageInfoService.getUnreadMessageCount();
    }

    @PostMapping("/read")
    public void read(@RequestBody List<String> ids){
        messageInfoService.readMessage(ids);
    }
}

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/dao/MessageInfoDao.java

对比新文件
@@ -0,0 +1,9 @@
package com.iailab.module.shasteel.job.dao;

import com.iailab.framework.common.dao.BaseDao;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import org.apache.ibatis.annotations.Mapper;

@Mapper
public interface MessageInfoDao extends BaseDao<MessageInfoEntity> {
}

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/entity/MessageInfoEntity.java

对比新文件
@@ -0,0 +1,58 @@
package com.iailab.module.shasteel.job.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;

@Data
@TableName("t_msg_info")
public class MessageInfoEntity implements Serializable {
    private static final long serialVersionUID = 1L;

    /**
     * 主键
     */
    @TableId(value = "id",type = IdType.ASSIGN_UUID)
    private String id;
    /**
     * 消息标题
     */
    private String title;
    /**
     * 消息内容
     */
    private String content;
    /**
     * 发送时间
     */
    private Date sendTime;
    /**
     * 读取状态
     */
    private String readStatus;
    /**
     * 业务ID
     */
    private String businessKey;
    /**
     * 消息来源
     */
    private String messageSource;
    /**
     * 创建时间
     */
    private Date createDate;
    /**
     * 修改人
     */
    private String updater;
    /**
     * 修改时间
     */
    private Date updateDate;

}

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/service/MessageInfoService.java

对比新文件
@@ -0,0 +1,22 @@
package com.iailab.module.shasteel.job.service;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.iailab.framework.common.pojo.PageResult;
import com.iailab.framework.common.service.BaseService;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import org.springframework.stereotype.Service;

import java.util.List;

public interface MessageInfoService extends BaseService<MessageInfoEntity> {

    List<MessageInfoEntity> getMessageList();

    long getUnreadMessageCount();

    void create(MessageInfoEntity messageInfoEntity);

    PageResult<MessageInfoEntity> getMessagePage(Integer pageNo, Integer pageSize);

    void readMessage(List<String> ids);
}

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/service/impl/MessageInfoServiceImpl.java

对比新文件
@@ -0,0 +1,50 @@
package com.iailab.module.shasteel.job.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.iailab.framework.common.pojo.PageResult;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.module.shasteel.job.dao.MessageInfoDao;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import com.iailab.module.shasteel.job.service.MessageInfoService;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class MessageInfoServiceImpl extends BaseServiceImpl<MessageInfoDao, MessageInfoEntity> implements MessageInfoService {

    @Override
    public void create(MessageInfoEntity messageInfoEntity) {
        baseDao.insert(messageInfoEntity);
    }

    @Override
    public PageResult<MessageInfoEntity> getMessagePage(Integer pageNo, Integer pageSize) {
        Page<MessageInfoEntity> params = new Page<>(pageNo, pageSize);
        IPage<MessageInfoEntity> page = baseDao.selectPage(params, null);
        return new PageResult<>(page.getRecords(), page.getTotal());
    }

    @Override
    public void readMessage(List<String> ids) {
        List<MessageInfoEntity> list = baseDao.selectBatchIds(ids);
        list.forEach(
                item->item.setReadStatus("1")
        );
        baseDao.updateById(list);
    }

    @Override
    public List<MessageInfoEntity> getMessageList() {
        return baseDao.selectList(new QueryWrapper<MessageInfoEntity>());
    }

    @Override
    public long getUnreadMessageCount() {
        return baseDao.selectCount(new QueryWrapper<MessageInfoEntity>().eq(
                "read_status", 0
        ));
    }
}

 shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleOnaOptTask.java

@@ -9,6 +9,8 @@
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
import com.iailab.module.model.enums.CommonConstant;
import com.iailab.module.model.enums.ScheduleTriggerMethodEnum;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import com.iailab.module.shasteel.job.service.MessageInfoService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -57,6 +59,9 @@

    @Autowired
    private MdkApi mdkApi;

    @Autowired
    private MessageInfoService messageInfoService;

    private Map<String, StScheduleSchemeDTO> schemeMap = new HashMap<>();

@@ -261,5 +266,13 @@
        alarm.setAlarmType(adjustValue.compareTo(BigDecimal.ZERO) > 0 ? "超上限" : "超下限");
        alarm.setAlarmTime(scheduleTime);
        mcsApi.createAlarmMessage(alarm);
        MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
        messageInfoEntity.setTitle(title);
        messageInfoEntity.setContent(content);
        messageInfoEntity.setSendTime(scheduleTime);
        messageInfoEntity.setBusinessKey(alarm.getId());
        messageInfoEntity.setMessageSource("模型预警");
        messageInfoEntity.setCreateDate(new Date());
        messageInfoService.create(messageInfoEntity);
    }
}

 shasteel-biz/src/main/resources/application-dev.yaml

@@ -39,12 +39,12 @@
          username: root
          password: 123456

  # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优
  redis:
    host: 127.0.0.1 # 地址
    port: 6379 # 端口
    database: 0 # 数据库索引
    password: 123456 # 密码，建议生产环境开启
#  # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优
#  redis:
#    host: 127.0.0.1 # 地址
#    port: 6379 # 端口
#    database: 0 # 数据库索引
#    password: 123456 # 密码，建议生产环境开启

--- #################### 监控相关配置 ####################


 shasteel-biz/src/main/resources/application.yaml

@@ -4,7 +4,7 @@
    name: shasteel-server

  profiles:
    active: prod
    active: dev

  cloud:
    nacos:
@@ -153,6 +153,7 @@
      - qrtz_triggers
      - schedule_job
      - schedule_job_log
      - t_msg_info
  swagger:
    title: 沙钢智慧能源后台
    description: 提供管理员管理的所有功能