|
|
|
@ -13,6 +13,7 @@ import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
|
|
import org.dromara.common.core.domain.R;
|
|
|
|
|
import org.dromara.common.core.exception.ServiceException;
|
|
|
|
|
import org.dromara.common.core.utils.MapstructUtils;
|
|
|
|
|
import org.dromara.common.core.utils.ObjectUtils;
|
|
|
|
|
import org.dromara.common.core.utils.StringUtils;
|
|
|
|
|
import org.dromara.common.mybatis.Utils.UniqueCodeUtils;
|
|
|
|
|
import org.dromara.common.mybatis.core.page.PageQuery;
|
|
|
|
@ -93,9 +94,10 @@ public class WmsCheckTaskServiceImpl implements IWmsCheckTaskService {
|
|
|
|
|
MPJLambdaWrapper<WmsCheckTask> lqw = JoinWrappers.lambda(WmsCheckTask.class)
|
|
|
|
|
.selectAll(WmsCheckTask.class)
|
|
|
|
|
|
|
|
|
|
//获取物料类型名称
|
|
|
|
|
.select(BaseMaterialType::getMatrialTypeName)
|
|
|
|
|
.leftJoin(BaseMaterialType.class,BaseMaterialType::getMatrialTypeId, WmsCheckTask::getMaterialTypeId)
|
|
|
|
|
|
|
|
|
|
//获取仓库名称
|
|
|
|
|
.select(WmsBaseWarehouse::getWarehouseCode, WmsBaseWarehouse::getWarehouseName)
|
|
|
|
|
.leftJoin(WmsBaseWarehouse.class,WmsBaseWarehouse::getWarehouseId, WmsCheckTask::getWarehouseId)
|
|
|
|
|
|
|
|
|
@ -142,12 +144,15 @@ public class WmsCheckTaskServiceImpl implements IWmsCheckTaskService {
|
|
|
|
|
R<Long> jobResp = remoteJobService.addClusterJob(job);
|
|
|
|
|
Long jobId = jobResp != null ? jobResp.getData() : null;//任务ID
|
|
|
|
|
add.setJobId(jobId);
|
|
|
|
|
|
|
|
|
|
if(ObjectUtils.isNotEmpty(jobId)){
|
|
|
|
|
boolean flag = baseMapper.insert(add) > 0;
|
|
|
|
|
if (flag) {
|
|
|
|
|
bo.setTaskId(add.getTaskId());
|
|
|
|
|
}
|
|
|
|
|
return flag;
|
|
|
|
|
} else {
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|