*待判接口开发

lsh

7 天以前 f6e17ebcf5e66b590391e13595968b7e05a7f966

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

@@ -2,8 +2,13 @@

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;
@@ -24,8 +29,12 @@
    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};
@@ -46,4 +55,47 @@
        }
    }

    @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++;
        }
    }

}