package com.vincent.rsf.server.manager.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.vincent.rsf.server.manager.entity.Task;
import com.vincent.rsf.server.manager.enums.TaskStsType;
import com.vincent.rsf.server.manager.mapper.TaskMapper;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 任务明细 plat_order_code 对应云仓通知单号时，是否仍有执行中任务
 */
@Component
public class CloudWmsOrderTaskRunningHelper {

    @Autowired
    private TaskMapper taskMapper;

    public boolean hasRunningTasksForPlatOrder(String platOrderCode) {
        if (StringUtils.isBlank(platOrderCode)) {
            return false;
        }
        QueryWrapper<Task> qw = new QueryWrapper<>();
        qw.eq("deleted", 0);
        qw.apply("EXISTS (SELECT 1 FROM man_task_item ti WHERE ti.task_id = man_task.id AND ti.deleted = 0 AND ti.plat_order_code = {0})", platOrderCode);
        qw.and(w -> w
                .nested(n -> n.lt("task_type", 100).lt("task_status", TaskStsType.COMPLETE_IN.id))
                .or(n -> n.ge("task_type", 101).lt("task_status", TaskStsType.COMPLETE_OUT.id)));
        Integer cnt = taskMapper.selectCount(qw);
        return cnt != null && cnt > 0;
    }
}