#

lsh

2024-06-21 352b3946e1afb9a27c96f58bb138e2ba5a010ec0

#

 src/main/java/com/zy/asrs/mapper/BasJarMastMapper.java

@@ -12,12 +12,17 @@
@Repository
public interface BasJarMastMapper extends BaseMapper<BasJarMast> {

    List<BasJarMast> getJarMastByJarId(@Param("jarId") Long jarId);
    List<BasJarMast> getJarMastByJarId(@Param("jarId") Integer jarId);

    BasJarMast getJarMastByJarIdMax(@Param("jarId") Long jarId);
    BasJarMast getJarMastByJarIdMax(@Param("jarId") Integer jarId);

    BasJarMast getJarMastByJarIdMin(@Param("jarId") Long jarId);
    BasJarMast getJarMastByJarIdMin(@Param("jarId") Integer jarId);

    Integer getJarMastByJarIdCount(@Param("jarId") Long jarId);
    Integer getJarMastByJarIdCount(@Param("jarId") Integer jarId);

    Integer selectJarMastOperation1(@Param("jarId") Integer jarId);
    Integer selectJarMastOperation2(@Param("jarId") Integer jarId);
    Integer selectJarMastOperation3(@Param("jarId") Integer jarId);
    Integer selectJarMastOperation4(@Param("jarId") Integer jarId);

}

 src/main/java/com/zy/asrs/mapper/WrkMastExecuteMapper.java

@@ -3,10 +3,13 @@
import com.zy.asrs.entity.WrkMastExecute;
import com.baomidou.mybatisplus.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;

@Mapper
@Repository
public interface WrkMastExecuteMapper extends BaseMapper<WrkMastExecute> {

    Integer getWrkMastByJarIdCount(@Param("jarId") Integer jarId);

}

 src/main/java/com/zy/asrs/service/BasJarMastService.java

@@ -7,12 +7,14 @@

public interface BasJarMastService extends IService<BasJarMast> {

    List<BasJarMast> getJarMastByJarId(Long jarId);
    List<BasJarMast> getJarMastByJarId(Integer jarId);

    BasJarMast getJarMastByJarIdMax(Long jarId);
    BasJarMast getJarMastByJarIdMax(Integer jarId);

    BasJarMast getJarMastByJarIdMin(Long jarId);
    BasJarMast getJarMastByJarIdMin(Integer jarId);

    Integer getJarMastByJarIdCount(Long jarId);
    Integer getJarMastByJarIdCount(Integer jarId);

    Integer selectJarMastOperation(Integer jarId,Integer type);

}

 src/main/java/com/zy/asrs/service/WrkMastExecuteService.java

@@ -5,4 +5,6 @@

public interface WrkMastExecuteService extends IService<WrkMastExecute> {

    Integer getWrkMastByJarIdCount(Integer jarId);

}

 src/main/java/com/zy/asrs/service/impl/BasJarMastServiceImpl.java

@@ -12,7 +12,7 @@
public class BasJarMastServiceImpl extends ServiceImpl<BasJarMastMapper, BasJarMast> implements BasJarMastService {

    @Override
    public List<BasJarMast> getJarMastByJarId(Long jarId) {
    public List<BasJarMast> getJarMastByJarId(Integer jarId) {
        return this.baseMapper.getJarMastByJarId(jarId);
    }

@@ -20,7 +20,7 @@
    * 获取jarLocDigit最大的BasJarMast
    * */
    @Override
    public BasJarMast getJarMastByJarIdMax(Long jarId) {
    public BasJarMast getJarMastByJarIdMax(Integer jarId) {
        return this.baseMapper.getJarMastByJarIdMax(jarId);
    }

@@ -28,13 +28,29 @@
     * 获取jarLocDigit最小的BasJarMast
     * */
    @Override
    public BasJarMast getJarMastByJarIdMin(Long jarId) {
    public BasJarMast getJarMastByJarIdMin(Integer jarId) {
        return this.baseMapper.getJarMastByJarIdMin(jarId);
    }

    @Override
    public Integer getJarMastByJarIdCount(Long jarId) {
    public Integer getJarMastByJarIdCount(Integer jarId) {
        return this.baseMapper.getJarMastByJarIdCount(jarId);
    }

    @Override
    public Integer selectJarMastOperation(Integer jarId,Integer type) {
        switch (type){
            case 1:
                return this.baseMapper.selectJarMastOperation1(jarId);
            case 2:
                return this.baseMapper.selectJarMastOperation2(jarId);
            case 3:
                return this.baseMapper.selectJarMastOperation3(jarId);
            case 4:
                return this.baseMapper.selectJarMastOperation4(jarId);
            default:
                return 99;
        }
    }

}

 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java

@@ -109,6 +109,8 @@
    private WrkMastSplitTwinService wrkMastSplitTwinService;
    @Autowired
    private BasJarMastService basJarMastService;
    @Autowired
    private WrkMastExecuteService wrkMastExecuteService;

    @Value("${wms.url}")
    private String wmsUrl;
@@ -4411,18 +4413,42 @@
     */
    public synchronized void jarGenerateWrkMastSta() {
        for (JarSlave jarSlave : slaveProperties.getJar()) {
            try{
                Integer count = basJarMastService.getJarMastByJarIdCount(jarSlave.getId().longValue());
                if (count>=7){
            for(JarSlave.StaStn staStn : jarSlave.getJarInSta()){
                // 获取硫化罐入库站信息
                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, staStn.getDevpPlcId());
                StaProtocol staProtocol = devpThread.getStation().get(staStn.getStaNo());
                if (staProtocol == null) {
                    continue;
                } else {
                    staProtocol = staProtocol.clone();
                }
                BasJarMast jarMastByJarIdMax = basJarMastService.getJarMastByJarIdMax(jarSlave.getId().longValue());
                if (!Cools.isEmpty(jarMastByJarIdMax) && jarMastByJarIdMax.getJarLocDigit()==7){
                    continue;
                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo()!=0){
                    try{
                        if (basJarMastService.selectJarMastOperation(jarSlave.getId(),1)!=0){
                            break;
                        }
                        if (wrkMastExecuteService.getWrkMastByJarIdCount(jarSlave.getId())!=0){
                            break;
                        }
                        if (basJarMastService.getJarMastByJarIdCount(jarSlave.getId())>=7){
                            continue;
                        }
                        BasJarMast jarMastByJarIdMax = basJarMastService.getJarMastByJarIdMax(jarSlave.getId());
                        if (!Cools.isEmpty(jarMastByJarIdMax) && jarMastByJarIdMax.getJarLocDigit()==7){
                            continue;
                        }
                        WrkMast wrkMast = wrkMastMapper.selectById(staProtocol.getWorkNo());
                        if (Cools.isEmpty(wrkMast) || wrkMast.getWrkSts()!=2){
                            continue;
                        }
                        if (jarGenerateWrkMastStaExecute(jarSlave,wrkMast)){
                            return;
                        };
                    }catch (Exception e){
                        log.error(jarSlave.getId()+"号小车复位线程报错！"+e);
                    }
                    break;
                }
                jarGenerateWrkMastStaExecute(jarSlave);
            }catch (Exception e){
                log.error(jarSlave.getId()+"号小车复位线程报错！"+e);
            }
        }
    }
@@ -4430,7 +4456,7 @@
    /**
     *  Jar任务创建  执行
     */
    public synchronized boolean jarGenerateWrkMastStaExecute(JarSlave jarSlave) {
    public synchronized boolean jarGenerateWrkMastStaExecute(JarSlave jarSlave,WrkMast wrkMast) {
        try{
            // 获取堆垛机信息
            JarThread jarThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getId());
@@ -4451,8 +4477,8 @@
                return false;
            }

            //自动、空闲、右门关闭、
            if (jarProtocol.isAutoing() && !jarProtocol.isRightDoor() && jarProtocol.jarErr==0 && !jarOtherProtocol.isLeftDoor() && jarOtherProtocol.jarErr==0){
            //自动、空闲、右门关闭、   Other左门关闭
            if (jarProtocol.isAutoing() && !jarProtocol.isRightDoor() && jarProtocol.jarErr==0 && !jarOtherProtocol.isLeftDoor()){

            }


 src/main/java/com/zy/asrs/service/impl/WrkMastExecuteServiceImpl.java

@@ -8,5 +8,8 @@

@Service("wrkMastExecuteService")
public class WrkMastExecuteServiceImpl extends ServiceImpl<WrkMastExecuteMapper, WrkMastExecute> implements WrkMastExecuteService {

    @Override
    public Integer getWrkMastByJarIdCount(Integer jarId) {
        return this.baseMapper.getWrkMastByJarIdCount(jarId);
    }
}

 src/main/resources/mapper/BasJarMastMapper.xml

@@ -51,4 +51,32 @@
        and jar_id = #{jarId}
    </select>

    <select id="selectJarMastOperation1" resultType="Integer">
        select count(1) from asr_bas_jar_mast
        where 1=1
        and jar_id = #{jarId}
        and wrk_sts
    </select>

    <select id="selectJarMastOperation2" resultType="Integer">
        select count(1) from asr_bas_jar_mast
        where 1=1
          and jar_id = #{jarId}
          and wrk_sts
    </select>

    <select id="selectJarMastOperation3" resultType="Integer">
        select count(1) from asr_bas_jar_mast
        where 1=1
          and jar_id = #{jarId}
          and wrk_sts
    </select>

    <select id="selectJarMastOperation4" resultType="Integer">
        select count(1) from asr_bas_jar_mast
        where 1=1
          and jar_id = #{jarId}
          and wrk_sts
    </select>

</mapper>