#

lsh

2025-03-16 92c2c71666ff1a1c7b151d75f64674b7ee8840c0

 src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java

@@ -2,11 +2,17 @@

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.RgvOneSign;
import com.zy.asrs.entity.WrkMastSta;
import com.zy.asrs.service.BasDevpService;
import com.zy.asrs.service.RgvOneSignService;
import com.zy.asrs.service.WrkMastStaService;
import com.zy.asrs.service.impl.BasDevpServiceImpl;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.OneLouHangJiaHandler;
import com.zy.asrs.task.handler.RailwayPlatformHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -15,6 +21,7 @@
 * Created by Monkey D. Luffy on 2023.09.17
 * 徐工汉云..............以下.............上饶江铜.............退库拆码垛
 */
@Slf4j
@Component
public class OneLouHangJiaScheduler {

@@ -22,21 +29,72 @@
    private OneLouHangJiaHandler oneLouHangJiaHandler;
    @Autowired
    private WrkMastStaService wrkMastStaService;
    @Autowired
    private BasDevpService basDevpService;
    @Autowired
    private RgvOneSignService rgvOneSignService;

    @Scheduled(cron = "0/3 * * * * ? ")
    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute(){//退库拆码垛
//        int[] staNos =new int[]{118,119};
        int[] staNos =new int[]{118};
        for (int staNo : staNos){
            WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("sta_end",staNo)
                    .eq("type", 2).eq("wrk_sts", 0).eq("wrk_type", 2));
            if (!Cools.isEmpty(wrkMastSta)){
                break;
            try{
                WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("sta_end",staNo)
                        .eq("type", 2).eq("wrk_sts", 0).eq("wrk_type", 2));
                if (!Cools.isEmpty(wrkMastSta)){
                    break;
                }
                ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
                if (result.getCode()==200){
                    break;
                }
            }catch (Exception e){
                log.error("退库拆码垛"+staNo+"站点处理失败，异常信息："+e);
            }
            ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
            if (result.getCode()==200){
                break;
        }
    }

    @Scheduled(cron = "0/1 * * * * ? ")
    private void executeoTHER(){//131、135标记自动清除
//        int[] staNos =new int[]{131,135};
        int[][] staNoLists =new int[2][3];
        staNoLists[0] = new int[]{131,118,119};
        staNoLists[1] = new int[]{135,120,121};
        int i = 0;
        for (int[] staNos : staNoLists){
            if (i==0){
                RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign"));
                if (rgvOneSign.getRgvOneSign()==1){//1:退库模式
                    i++;
                    continue;
                }
            }
            boolean sign = true;
            int j =0;
            for (int staNo : staNos){
                try{
                    BasDevp basDevp = basDevpService.selectById(staNo);
                    if (!Cools.isEmpty(basDevp) && basDevp.getAutoing().equals("Y")){
                        if (
                                (j==0 && basDevp.getReportSign()==1 && basDevp.getLoading().equals("Y")&& basDevp.getLoadingSuper().equals("Y"))
                                ||
                                (j!=0 && basDevp.getReportSign()==0)
                        ){
                            j++;
                            continue;
                        }
                    }
                }catch (Exception e){
                    log.error("131、135标记自动清除"+staNo+"站点处理失败，异常信息："+e);
                }
                sign = false;
                j++;
            }
            if (sign){
                basDevpService.updateReportSignFalse(staNos[0]);
            }
            i++;
        }
    }