1. 新增定时任务和定时任务日志数据库表映射； 2. 修改异常分析和日、月统计分析定时任务的执行逻辑

feiyu02

2023-10-26 b34727ebd73a4f346d53730865e83fd5b3e5a0ef

1. 新增定时任务和定时任务日志数据库表映射；
2. 修改异常分析和日、月统计分析定时任务的执行逻辑

 pom.xml

@@ -96,6 +96,11 @@
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-boot-starter</artifactId>
            <version>3.0.0</version>
        </dependency>
    </dependencies>

    <build>

 src/main/java/com/flightfeather/monitor/config/Swagger2Configuration.kt

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,45 @@
package com.flightfeather.monitor.config

import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import springfox.documentation.builders.ApiInfoBuilder
import springfox.documentation.builders.PathSelectors
import springfox.documentation.builders.RequestHandlerSelectors
import springfox.documentation.oas.annotations.EnableOpenApi
import springfox.documentation.spi.DocumentationType
import springfox.documentation.spring.web.plugins.Docket

/**
 * Date: 2023/10/25
 */
@Configuration
@EnableOpenApi
class Swagger2Configuration {

    companion object {
        const val SWAGGER_SCAN_BASE_PACKAGE = "com.flightfeather.monitor"

        const val VERSION = "1.0.0"
    }

//    @Value("\${springfox.documentation.swagger.v2.enabled}")
    var swagger2Enable: Boolean = true

    @Bean
    fun createRestApi(): Docket =
        Docket(DocumentationType.OAS_30)
            .enable(swagger2Enable)
            .apiInfo(apiInfo())
            .select()
            .apis(RequestHandlerSelectors.basePackage(SWAGGER_SCAN_BASE_PACKAGE))
            .paths(PathSelectors.any())
            .build()


    private fun apiInfo() =
        ApiInfoBuilder()
            .title("监测数据质量分析服务")
            .description("监测数据质量分析服务 API æŽ¥å£æ–‡æ¡£")
            .version(VERSION)
            .build()
}

 src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTask.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,119 @@
package com.flightfeather.monitor.domain.ds1.entity;

import java.util.Date;
import javax.persistence.*;

@Table(name = "du_js_t_request_task")
public class RequestTask {
    @Id
    private Integer id;

    /**
     * ä»»åŠ¡å¼€å¯æ—¶é—´
     */
    @Column(name = "start_time")
    private Date startTime;

    /**
     * ä»»åŠ¡ç»“束时间
     */
    @Column(name = "end_time")
    private Date endTime;

    /**
     * è¿è¡ŒçŠ¶æ€
     */
    @Column(name = "running_status")
    private Boolean runningStatus;

    /**
     * ä»»åŠ¡æ˜¯å¦æˆåŠŸå®Œæˆ
     */
    private Boolean success;

    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }

    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }

    /**
     * èŽ·å–任务开启时间
     *
     * @return start_time - ä»»åŠ¡å¼€å¯æ—¶é—´
     */
    public Date getStartTime() {
        return startTime;
    }

    /**
     * è®¾ç½®ä»»åŠ¡å¼€å¯æ—¶é—´
     *
     * @param startTime ä»»åŠ¡å¼€å¯æ—¶é—´
     */
    public void setStartTime(Date startTime) {
        this.startTime = startTime;
    }

    /**
     * èŽ·å–任务结束时间
     *
     * @return end_time - ä»»åŠ¡ç»“束时间
     */
    public Date getEndTime() {
        return endTime;
    }

    /**
     * è®¾ç½®ä»»åŠ¡ç»“束时间
     *
     * @param endTime ä»»åŠ¡ç»“束时间
     */
    public void setEndTime(Date endTime) {
        this.endTime = endTime;
    }

    /**
     * èŽ·å–运行状态
     *
     * @return running_status - è¿è¡ŒçŠ¶æ€
     */
    public Boolean getRunningStatus() {
        return runningStatus;
    }

    /**
     * è®¾ç½®è¿è¡ŒçŠ¶æ€
     *
     * @param runningStatus è¿è¡ŒçŠ¶æ€
     */
    public void setRunningStatus(Boolean runningStatus) {
        this.runningStatus = runningStatus;
    }

    /**
     * èŽ·å–任务是否成功完成
     *
     * @return success - ä»»åŠ¡æ˜¯å¦æˆåŠŸå®Œæˆ
     */
    public Boolean getSuccess() {
        return success;
    }

    /**
     * è®¾ç½®ä»»åŠ¡æ˜¯å¦æˆåŠŸå®Œæˆ
     *
     * @param success ä»»åŠ¡æ˜¯å¦æˆåŠŸå®Œæˆ
     */
    public void setSuccess(Boolean success) {
        this.success = success;
    }
}

 src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskLog.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,98 @@
package com.flightfeather.monitor.domain.ds1.entity;

import java.util.Date;
import javax.persistence.*;

@Table(name = "du_js_t_request_task_log")
public class RequestTaskLog {
    @Id
    private Integer id;

    @Column(name = "request_id")
    private Integer requestId;

    /**
     * åˆ›å»ºæ—¶é—´
     */
    @Column(name = "create_time")
    private Date createTime;

    @Column(name = "log_type")
    private String logType;

    private String log;

    /**
     * @return id
     */
    public Integer getId() {
        return id;
    }

    /**
     * @param id
     */
    public void setId(Integer id) {
        this.id = id;
    }

    /**
     * @return request_id
     */
    public Integer getRequestId() {
        return requestId;
    }

    /**
     * @param requestId
     */
    public void setRequestId(Integer requestId) {
        this.requestId = requestId;
    }

    /**
     * èŽ·å–创建时间
     *
     * @return create_time - åˆ›å»ºæ—¶é—´
     */
    public Date getCreateTime() {
        return createTime;
    }

    /**
     * è®¾ç½®åˆ›å»ºæ—¶é—´
     *
     * @param createTime åˆ›å»ºæ—¶é—´
     */
    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    /**
     * @return log_type
     */
    public String getLogType() {
        return logType;
    }

    /**
     * @param logType
     */
    public void setLogType(String logType) {
        this.logType = logType == null ? null : logType.trim();
    }

    /**
     * @return log
     */
    public String getLog() {
        return log;
    }

    /**
     * @param log
     */
    public void setLog(String log) {
        this.log = log == null ? null : log.trim();
    }
}

 src/main/java/com/flightfeather/monitor/domain/ds1/mapper/RequestTaskLogMapper.kt

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper

import com.flightfeather.monitor.domain.ds1.entity.RequestTaskLog
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper

@Mapper
interface RequestTaskLogMapper : MyMapper<RequestTaskLog?>

 src/main/java/com/flightfeather/monitor/domain/ds1/mapper/RequestTaskMapper.kt

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,8 @@
package com.flightfeather.monitor.domain.ds1.mapper

import com.flightfeather.monitor.domain.ds1.entity.RequestTask
import com.flightfeather.monitor.domain.util.MyMapper
import org.apache.ibatis.annotations.Mapper

@Mapper
interface RequestTaskMapper : MyMapper<RequestTask?>

 src/main/java/com/flightfeather/monitor/domain/ds1/repository/DustExceptionDataRep.kt

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

import com.flightfeather.monitor.domain.ds1.entity.DustExceptionData
import com.flightfeather.monitor.domain.ds1.mapper.DustExceptionDataMapper
import com.github.pagehelper.PageHelper
import org.springframework.stereotype.Repository
import tk.mybatis.mapper.entity.Example
import java.time.LocalDate
@@ -13,9 +14,15 @@
     * èŽ·å–最新一条记录
     */
    fun findLatestData(): DustExceptionData? {
        return dustExceptionDataMapper.selectOneByExample(Example(DustExceptionData::class.java).apply {
        val p = PageHelper.startPage<DustExceptionData>(1, 1)
        dustExceptionDataMapper.selectByExample(Example(DustExceptionData::class.java).apply {
            orderBy("endTime").desc()
        })
        return if (p.isNotEmpty()) {
            p[0]
        } else {
            null
        }
    }

    /**

 src/main/java/com/flightfeather/monitor/domain/ds1/repository/DustExceptionSettingRep.kt

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

import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting
import com.flightfeather.monitor.domain.ds1.mapper.DustExceptionSettingMapper
import com.github.pagehelper.PageHelper
import org.springframework.stereotype.Repository
import tk.mybatis.mapper.entity.Example

@@ -13,9 +14,15 @@
     * @param region åŒºåŽ¿
     */
    fun findLatestSetting(region: String): DustExceptionSetting? {
        return dustExceptionSettingMapper.selectOneByExample(Example(DustExceptionSetting::class.java).apply {
        val p = PageHelper.startPage<DustExceptionSetting>(1, 1)
        dustExceptionSettingMapper.selectByExample(Example(DustExceptionSetting::class.java).apply {
            createCriteria().andEqualTo("region", region)
            orderBy("version").desc()
        })
        return if (p.isNotEmpty()) {
            p[0]
        } else {
            null
        }
    }
}

 src/main/java/com/flightfeather/monitor/domain/ds1/repository/DustStatisticsValueRep.kt

@@ -1,9 +1,8 @@
package com.flightfeather.monitor.domain.ds1.repository

import com.flightfeather.monitor.domain.ds1.entity.DustExceptionData
import com.flightfeather.monitor.domain.ds1.entity.DustSiteData
import com.flightfeather.monitor.domain.ds1.entity.DustStatisticsValue
import com.flightfeather.monitor.domain.ds1.mapper.DustStatisticsValueMapper
import com.github.pagehelper.PageHelper
import org.springframework.stereotype.Repository
import tk.mybatis.mapper.entity.Example
import java.time.Duration
@@ -13,10 +12,16 @@
class DustStatisticsValueRep(private val dustStatisticsValueMapper: DustStatisticsValueMapper) {

    fun findLatestData(type: String): DustStatisticsValue? {
        return dustStatisticsValueMapper.selectOneByExample(Example(DustStatisticsValue::class.java).apply {
        val p = PageHelper.startPage<DustStatisticsValue>(1, 1)
        dustStatisticsValueMapper.selectByExample(Example(DustStatisticsValue::class.java).apply {
            createCriteria().andEqualTo("type", type)
            orderBy("lst").desc()
        })
        return if (p.isNotEmpty()) {
            p[0]
        } else {
            null
        }
    }



 src/main/java/com/flightfeather/monitor/domain/ds1/repository/RequestTaskRep.kt

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package com.flightfeather.monitor.domain.ds1.repository

import com.flightfeather.monitor.domain.ds1.entity.RequestTask
import com.flightfeather.monitor.domain.ds1.mapper.RequestTaskMapper
import com.github.pagehelper.PageHelper
import org.springframework.stereotype.Repository
import tk.mybatis.mapper.entity.Example
import java.time.LocalDateTime

@Repository
class RequestTaskRep(private val requestTaskMapper: RequestTaskMapper) {

    /**
     * æŸ¥è¯¢æœ€è¿‘的一个任务
     */
    fun findLatestTask(localDateTime: LocalDateTime): RequestTask? {
        val p = PageHelper.startPage<RequestTask>(1, 1)
        val s = localDateTime.withHour(0).withMinute(0).withSecond(0)
        val e = localDateTime.withHour(23).withMinute(59).withSecond(59)
        requestTaskMapper.selectByExample(Example(RequestTask::class.java).apply {
            createCriteria().andBetween("startTime", s, e)
            orderBy("startTime").desc()
        })
        return if (p.isNotEmpty()) {
            p[0]
        } else {
            null
        }
    }
}

 src/main/java/com/flightfeather/monitor/scheduledtasks/DustAnalysisTask.kt

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,68 @@
package com.flightfeather.monitor.scheduledtasks

import com.flightfeather.monitor.analysis.dust.ExceptionAnalysisController
import com.flightfeather.monitor.analysis.dust.StatisticAnalysisController
import com.flightfeather.monitor.domain.ds1.entity.RequestTask
import com.flightfeather.monitor.domain.ds1.repository.RequestTaskRep
import org.springframework.stereotype.Component
import java.time.LocalDateTime

/**
 * æ‰¬å°˜æ•°æ®åˆ†æžä»»åŠ¡
 */
@Component
class DustAnalysisTask(
    private val statisticAnalysisController: StatisticAnalysisController,
    private val exceptionAnalysisController: ExceptionAnalysisController,
    private val requestTaskRep: RequestTaskRep,
) : BaseTimingTask() {

    // ä»»åŠ¡æ˜¯å¦å»¶è¿Ÿæ‰§è¡Œ
    private var task1Delay = false
    private var task2Delay = false
    private var task3Delay = false

    override val period: Long = 15

    override fun execute(localtime: LocalDateTime) {
        doTask(localtime)
    }

    override fun doTask(localtime: LocalDateTime) {
        if (task1Delay || (localtime.hour == 8 && localtime.minute == 0)) {
            // åˆ¤æ–­ä»Šæ—¥çˆ¬å–任务是否完成
            val task = requestTaskRep.findLatestTask(localtime)
            task1Delay = isTaskDelay(task)
            if (task1Delay) return
            log.info("异常分析执行")
            exceptionAnalysisController.init()
            exceptionAnalysisController.autoRun()
        }

        if (task2Delay || (localtime.hour == 9 && localtime.minute == 0)) {
            val task = requestTaskRep.findLatestTask(localtime)
            task2Delay = isTaskDelay(task)
            if (task2Delay) return
            log.info("日分析执行")
            statisticAnalysisController.autoRunDailyStatics()
        }

        if (localtime.dayOfMonth == 1 && localtime.hour == 9 && localtime.minute == 0) {
            val task = requestTaskRep.findLatestTask(localtime)
            task3Delay = isTaskDelay(task)
            if (task3Delay) return
            log.info("月分析执行")
            statisticAnalysisController.autoRunMonthlyStatics()
        }
    }

    /**
     * å½“任务开始执行时，判断任务状态，决定是否延迟执行
     */
    private fun isTaskDelay(task: RequestTask?): Boolean {
        // ä»»åŠ¡æ­£åœ¨æ‰§è¡Œï¼Œè·³è¿‡æ­¤æ¬¡åˆ†æžï¼Œåœ¨ä¸‹ä¸€å‘¨æœŸç»§ç»­åˆ¤æ–­ï¼Œç­‰å¾…任务完成后进行分析
        return if (task == null || task.runningStatus) {
            true
        } else !task.success
    }
}

 src/main/java/com/flightfeather/monitor/scheduledtasks/DustMonthlyStatisticAnalysisTask.kt

@@ -13,7 +13,7 @@
    override fun execute(localtime: LocalDateTime) {
//        println("月分析轮询")
//        println(localtime)
        if (localtime.dayOfMonth == 2 && localtime.hour == 0 && localtime.minute == 0) {
        if (localtime.dayOfMonth == 1 && localtime.hour == 9 && localtime.minute == 0) {
            doTask(localtime)
        }
    }

 src/main/java/com/flightfeather/monitor/scheduledtasks/TaskController.kt

@@ -14,17 +14,17 @@
/**
 * æ•°æ®èŽ·å–控制器
 */
@Slf4j
@Component
class TaskController(
    dustExceptionAnalysisTask: DustExceptionAnalysisTask,
    dustDailyStatisticAnalysisTask: DustDailyStatisticAnalysisTask,
    dustMonthlyStatisticAnalysisTask: DustMonthlyStatisticAnalysisTask,
    dustAnalysisTask: DustAnalysisTask,
) {

    companion object {
        private const val FETCH_PERIOD_MIN = 1L * 60
        private const val MAINTAIN_PERIOD_MIN = 5L * 60
        private const val FETCH_PERIOD_MIN = 15L
        private const val MAINTAIN_PERIOD_MIN = 15L
        val log: Logger = LoggerFactory.getLogger(TaskController::class.java)
    }

@@ -37,10 +37,10 @@
    init {
        log.info("添加定时任务")
        timeTask.clear()
       /*做的定时任务加进来*/
        timeTask.add(dustExceptionAnalysisTask)
        timeTask.add(dustDailyStatisticAnalysisTask)
        timeTask.add(dustMonthlyStatisticAnalysisTask)
//        timeTask.add(dustExceptionAnalysisTask)
//        timeTask.add(dustDailyStatisticAnalysisTask)
//        timeTask.add(dustMonthlyStatisticAnalysisTask)
        timeTask.add(dustAnalysisTask)
        log.info("添加定时任务完成，任务总计${timeTask.size}个")
    }

@@ -51,8 +51,8 @@

    private fun fetchTask(isFirst: Boolean = false) {
        val time = LocalTime.now()
        val sec = time.second
        val delay = 60L - sec
        val min = time.minute
        val delay = FETCH_PERIOD_MIN - min % FETCH_PERIOD_MIN
//        var localtime = LocalDateTime.of(2021, 4, 16, 9, 0)
        if (!isFirst) {
            schedule = closeThread(schedule)
@@ -70,7 +70,7 @@
                it.execute(localtime)
            }
//            localtime = localtime.plusMinutes(1)
        }, delay, FETCH_PERIOD_MIN, TimeUnit.SECONDS)
        }, delay, FETCH_PERIOD_MIN, TimeUnit.MINUTES)
    }

    private fun maintainTask(isFirst: Boolean = false) {
@@ -82,7 +82,7 @@
            if (Date().time - taskTime.time > (FETCH_PERIOD_MIN + 1) * 60 * 1000) {
                fetchTask()
            }
        }, 0, MAINTAIN_PERIOD_MIN, TimeUnit.SECONDS)
        }, 0, MAINTAIN_PERIOD_MIN, TimeUnit.MINUTES)
    }

    private fun closeThread(s: ScheduledExecutorService): ScheduledExecutorService {

 src/main/java/com/flightfeather/monitor/utils/DateUtil.kt

@@ -6,18 +6,20 @@

    fun findDurationDate(s: LocalDate, e: LocalDate): List<LocalDate> {
        val res = mutableListOf<LocalDate>()
        while (s.isBefore(e) || s.isEqual(e)) {
            res.add(s)
            s.plusDays(1)
        var sT = s
        while (sT.isBefore(e) || sT.isEqual(e)) {
            res.add(sT)
            sT = sT.plusDays(1)
        }
        return res
    }

    fun findDurationMonth(s: LocalDate, e: LocalDate): List<LocalDate> {
        val res = mutableListOf<LocalDate>()
        while (s.monthValue <= e.monthValue) {
            res.add(s)
            s.plusMonths(1)
        var sT = s
        while (sT.monthValue <= e.monthValue) {
            res.add(sT)
            sT = sT.plusMonths(1)
        }
        return res
    }

 src/main/resources/application.yml

@@ -20,7 +20,8 @@

mybatis:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
#    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl
    map-underscore-to-camel-case: true
  type-aliases-package: com.flightfeather.monitor.domain.ds1.entity
  mapper-locations: classpath*:mapper/**/*.xml

 src/main/resources/generator/generatorConfig4ds1.xml

@@ -50,10 +50,10 @@
<!--               enableCountByExample="false"-->
<!--               enableUpdateByExample="false" enableDeleteByExample="false"-->
<!--               enableSelectByExample="false" selectByExampleQueryId="false"/>-->
        <table tableName="du_js_t_site_latest_time" domainObjectName="DustSiteStatus"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
<!--        <table tableName="du_js_t_site_latest_time" domainObjectName="DustSiteStatus"-->
<!--               enableCountByExample="false"-->
<!--               enableUpdateByExample="false" enableDeleteByExample="false"-->
<!--               enableSelectByExample="false" selectByExampleQueryId="false"/>-->
<!--        <table tableName="du_js_t_site_map" domainObjectName="DustSiteMap"-->
<!--               enableCountByExample="false"-->
<!--               enableUpdateByExample="false" enableDeleteByExample="false"-->
@@ -82,5 +82,13 @@
<!--               enableCountByExample="false"-->
<!--               enableUpdateByExample="false" enableDeleteByExample="false"-->
<!--               enableSelectByExample="false" selectByExampleQueryId="false"/>-->
        <table tableName="du_js_t_request_task_log" domainObjectName="RequestTaskLog"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
        <table tableName="du_js_t_request_task" domainObjectName="RequestTask"
               enableCountByExample="false"
               enableUpdateByExample="false" enableDeleteByExample="false"
               enableSelectByExample="false" selectByExampleQueryId="false"/>
    </context>
</generatorConfiguration>

 src/main/resources/mapper/ds1/RequestTaskLogMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,31 @@
<?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.flightfeather.monitor.domain.ds1.mapper.RequestTaskLogMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.RequestTaskLog">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="request_id" jdbcType="INTEGER" property="requestId" />
    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
    <result column="log_type" jdbcType="VARCHAR" property="logType" />
  </resultMap>
  <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.flightfeather.monitor.domain.ds1.entity.RequestTaskLog">
    <!--
      WARNING - @mbg.generated
    -->
    <result column="log" jdbcType="LONGVARCHAR" property="log" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, request_id, create_time, log_type
  </sql>
  <sql id="Blob_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    log
  </sql>
</mapper>

 src/main/resources/mapper/ds1/RequestTaskMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
<?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.flightfeather.monitor.domain.ds1.mapper.RequestTaskMapper">
  <resultMap id="BaseResultMap" type="com.flightfeather.monitor.domain.ds1.entity.RequestTask">
    <!--
      WARNING - @mbg.generated
    -->
    <id column="id" jdbcType="INTEGER" property="id" />
    <result column="start_time" jdbcType="TIMESTAMP" property="startTime" />
    <result column="end_time" jdbcType="TIMESTAMP" property="endTime" />
    <result column="running_status" jdbcType="BIT" property="runningStatus" />
    <result column="success" jdbcType="BIT" property="success" />
  </resultMap>
  <sql id="Base_Column_List">
    <!--
      WARNING - @mbg.generated
    -->
    id, start_time, end_time, running_status, success
  </sql>
</mapper>