|
@ -1,43 +1,28 @@ |
|
|
package org.dromara.sample.wayline.service.impl; |
|
|
package org.dromara.sample.wayline.service.impl; |
|
|
|
|
|
|
|
|
import cn.hutool.core.util.ObjectUtil; |
|
|
import cn.hutool.core.util.ObjectUtil; |
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper; |
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
import com.tdunning.math.stats.Sort; |
|
|
|
|
|
import lombok.Data; |
|
|
|
|
|
import lombok.RequiredArgsConstructor; |
|
|
import lombok.RequiredArgsConstructor; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import org.apache.dubbo.config.annotation.DubboReference; |
|
|
|
|
|
import org.apache.poi.ss.formula.functions.T; |
|
|
|
|
|
import org.dromara.business.api.RemoteBusinessTaskService; |
|
|
|
|
|
import org.dromara.common.core.constant.AiCompareStatusConstants; |
|
|
import org.dromara.common.core.constant.AiCompareStatusConstants; |
|
|
import org.dromara.common.core.constant.BusinessConstants; |
|
|
import org.dromara.common.core.constant.BusinessConstants; |
|
|
import org.dromara.common.core.utils.DateUtils; |
|
|
import org.dromara.common.core.utils.DateUtils; |
|
|
import org.dromara.common.core.utils.MapstructUtils; |
|
|
|
|
|
import org.dromara.common.core.utils.StringUtils; |
|
|
import org.dromara.common.core.utils.StringUtils; |
|
|
import org.dromara.common.mybatis.core.page.PageQuery; |
|
|
import org.dromara.common.mybatis.core.page.PageQuery; |
|
|
import org.dromara.common.mybatis.core.page.TableDataInfo; |
|
|
import org.dromara.common.mybatis.core.page.TableDataInfo; |
|
|
import org.dromara.sample.fegin.RemoteBusinessTaskFeign; |
|
|
import org.dromara.sample.feign.RemoteBusinessTaskFeign; |
|
|
import org.dromara.sample.media.mapper.IFileMapper; |
|
|
import org.dromara.sample.media.mapper.IFileMapper; |
|
|
import org.dromara.sample.media.model.MediaFileEntity; |
|
|
import org.dromara.sample.media.model.MediaFileEntity; |
|
|
import org.dromara.sample.wayline.mapper.IAiCompareQueueMapper; |
|
|
import org.dromara.sample.wayline.mapper.IAiCompareQueueMapper; |
|
|
import org.dromara.sample.wayline.mapper.IWaylineJobMapper; |
|
|
import org.dromara.sample.wayline.mapper.IWaylineJobMapper; |
|
|
import org.dromara.sample.wayline.model.dto.AiCompareDTO; |
|
|
|
|
|
import org.dromara.sample.wayline.model.dto.AiCompareQueueDTO; |
|
|
import org.dromara.sample.wayline.model.dto.AiCompareQueueDTO; |
|
|
import org.dromara.sample.wayline.model.entity.AiCompareEntity; |
|
|
|
|
|
import org.dromara.sample.wayline.model.entity.AiCompareQueueEntity; |
|
|
import org.dromara.sample.wayline.model.entity.AiCompareQueueEntity; |
|
|
import org.dromara.sample.wayline.model.entity.WaylineJobEntity; |
|
|
import org.dromara.sample.wayline.model.entity.WaylineJobEntity; |
|
|
import org.dromara.sample.wayline.service.IAiCompareQueueService; |
|
|
import org.dromara.sample.wayline.service.IAiCompareQueueService; |
|
|
import org.springframework.scheduling.annotation.Async; |
|
|
|
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
import java.time.LocalDateTime; |
|
|
|
|
|
import java.time.ZoneId; |
|
|
|
|
|
import java.util.Date; |
|
|
|
|
|
import java.util.List; |
|
|
import java.util.List; |
|
|
import java.util.Map; |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* @auther yq |
|
|
* @auther yq |
|
|