package com.zy.asrs.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.core.common.Cools;
|
import com.core.common.DateUtils;
|
import com.core.common.R;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.domain.enums.WorkNoType;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.mapper.*;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.utils.*;
|
import com.zy.common.model.LocTypeDto;
|
import com.zy.common.model.MatDto;
|
import com.zy.common.model.SearchLocParam;
|
import com.zy.common.model.StartupDto;
|
import com.zy.common.service.CommonService;
|
import com.zy.common.utils.CollectionUtils;
|
import com.zy.common.utils.HttpHandler;
|
import com.zy.common.utils.RedisUtil;
|
import com.zy.common.utils.RgvUtils;
|
import com.zy.core.CrnThread;
|
import com.zy.core.DevpThread;
|
import com.zy.core.Slave;
|
import com.zy.core.cache.MessageQueue;
|
import com.zy.core.cache.SlaveConnection;
|
import com.zy.core.enums.*;
|
import com.zy.core.model.*;
|
import com.zy.core.model.command.*;
|
import com.zy.core.model.cpmmandParam.CrnCommandParam;
|
import com.zy.core.model.protocol.*;
|
import com.zy.core.properties.SlaveProperties;
|
import com.zy.core.thread.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
import springfox.documentation.spring.web.json.Json;
|
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
/**
|
* 立体仓库WCS系统主流程业务
|
* Created by vincent on 2020/8/6
|
*/
|
@Slf4j
|
@Service("mainService")
|
@Transactional
|
public class MainServiceImpl {
|
|
public static final long COMMAND_TIMEOUT = 5 * 1000;
|
// private static final int[][] execute = new int[][]{{1,4},{2,4},{3,4},{4,4},{5,6},{6,6},{7,4},{8,4},{9,3},{10,4},{11,4}};
|
private static final int[][] execute = new int[][]{{1,4},{2,4},{3,4},{4,4},{5,6},{6,6},{7,4},{8,4},{9,3},{10,4},{11,4}};
|
|
private static final Integer jarMaxLoc = 7;
|
private static final Float jarTemperature = 50F;
|
@Autowired
|
private CommonService commonService;
|
@Autowired
|
private SlaveProperties slaveProperties;
|
@Autowired
|
private WrkMastMapper wrkMastMapper;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
@Autowired
|
private WaitPakinMapper waitPakinMapper;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired
|
private StaDescService staDescService;
|
@Autowired
|
private BasCrnpService basCrnpService;
|
@Autowired
|
private BasRgvService basRgvService;
|
@Autowired
|
private BasDevpService basDevpService;
|
@Autowired
|
private LocDetlService locDetlService;
|
@Autowired
|
private BasErrLogService basErrLogService;
|
@Autowired
|
private BasCrnErrorMapper basCrnErrorMapper;
|
@Autowired
|
private BasRgvErrMapper basRgvErrMapper;
|
@Autowired
|
private BasRgvErrLogService basRgvErrLogService;
|
@Autowired
|
private BasRgvPathService basRgvPathService;
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private WrkMastStaMapper wrkMastStaMapper;
|
@Autowired
|
private BasRgvMapMapper basRgvMapMapper;
|
@Autowired
|
private RgvOneSignMapper rgvOneSignMapper;
|
@Autowired
|
private WrkMastCrnMapper wrkMastCrnMapper;
|
@Autowired
|
private WrkMastSplitTwinMapper wrkMastSplitTwinMapper;
|
@Autowired
|
private WrkMastSplitTwinService wrkMastSplitTwinService;
|
@Autowired
|
private BasJarMastService basJarMastService;
|
@Autowired
|
private WrkMastExecuteService wrkMastExecuteService;
|
@Autowired
|
private BasJarService basJarService;
|
@Autowired
|
private BasJarMapper basJarMapper;
|
|
@Value("${wms.url}")
|
private String wmsUrl;
|
|
|
}
|
