//package com.zy.core;
//
//import com.core.exception.CoolException;
//import com.zy.asrs.entity.LocMast;
//import com.zy.asrs.entity.WrkMast;
//import com.zy.asrs.service.WrkMastService;
//import com.zy.core.cache.MessageQueue;
//import com.zy.core.cache.SlaveConnection;
//import com.zy.core.enums.SlaveType;
//import com.zy.core.model.Task;
//import com.zy.core.model.protocol.StaProtocol;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.transaction.interceptor.TransactionAspectSupport;
//
//import java.util.Date;
//
//public class Test {
//
//    public synchronized void autoEmptyOut() {
//        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
//        Integer autoOutSite = 103;
//        //如果站点可出禁用，则不生成空盘出库任务
//        StaProtocol staProtocol = devpThread.getStation().get(autoOutSite);
//        if (staProtocol == null) {
//            return;
//        } else {
//            staProtocol = staProtocol.clone();
//        }
//        if (staProtocol.isAutoing()  //自动
//                && !staProtocol.isLoading()  //无物
////                && staProtocol.isOutEnable()  //可出信号
//                && staProtocol.getWorkNo() == 0) {
////            WrkMast pakoutEmpty = wrkMastMapper.selectPakoutEmpty(autoOutSite);
////            if (null != pakoutEmpty) {
////                return;
////            }
//
//            LocMast locMast = locMastService.getById("0200404");
//            if (locMast != null && locMast.getLocSts().equalsIgnoreCase("D")) {
//                try {
//                    Date now = new Date();
//                    // 保存工作档
//                    WrkMast wrkMast = new WrkMast();
//                    int workNo = commonService.getWorkNo(0);
//                    wrkMast.setWrkNo(workNo);
//                    wrkMast.setIoTime(now);
//                    wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID
//                    wrkMast.setIoType(110); // 入出库状态： 110.空板出库
//                    wrkMast.setIoPri(999D);
//                    wrkMast.setSourceStaNo(103); // 源站
//                    wrkMast.setStaNo(0); // 目标站
//                    wrkMast.setCrnNo(1);
//                    wrkMast.setSourceLocNo("0200404"); // 源库位
//                    wrkMast.setFullPlt("N"); // 满板：Y
//                    wrkMast.setPicking("N"); // 拣料
//                    wrkMast.setExitMk("N"); // 退出
//                    wrkMast.setEmptyMk("Y"); // 空板
//                    wrkMast.setLinkMis("N");
//                    wrkMast.setAppeUser(1L);
//                    wrkMast.setTenant(1L);
//                    wrkMast.setAppeTime(now);
//                    wrkMast.setModiUser(1L);
//                    wrkMast.setModiTime(now);
//                    wrkMast.setMemo("生成自动空板出库");
//                    boolean res = wrkMastService.save(wrkMast);
//                    // 更新库位状态 D.空板 -> R.出库预约
//                    if (locMast.getLocSts().equals("D")) {
//                        locMast.setLocSts("R");
//                        locMast.setModiUser(1L);
//                        locMast.setModiTime(now);
//                        if (!locMastService.updateById(locMast)) {
//                            throw new CoolException("更新库位状态失败");
//                        }
//                    }
//                } catch (Exception e) {
//                    e.printStackTrace();
//                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
//                }
//            }
//        }
//    }
//
//    @Autowired
//    private WrkMastService wrkMastService;
//
//    public synchronized void autoEmptyIn() {
//        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
//        StaProtocol staProtocol = devpThread.getStation().get(103);
//        if (staProtocol == null) {
//            return;
//        } else {
//            staProtocol = staProtocol.clone();
//        }
//        if (staProtocol.isAutoing()  //自动
//                && staProtocol.isLoading()  //有物
////                && staProtocol.isInEnable()  //可入信号
//            // && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() >= 9990) //工作号为0或者工作号是9991~9999（输送机留用）
//        ) {
//            LocMast locMast = locMastService.getById("0200404");
//            if (locMast != null && locMast.getLocSts().equalsIgnoreCase("O")) {
//                try {
//                    Date now = new Date();
//                    // 生成工作档
//                    WrkMast wrkMast = new WrkMast();
//                    int workNo = commonService.getWorkNo(0);
//                    wrkMast.setWrkNo(workNo);
//                    wrkMast.setIoTime(now);
//                    wrkMast.setWrkSts(2L);
//                    wrkMast.setIoPri(999D);
//                    wrkMast.setIoType(10);
//                    wrkMast.setTenant(1L);
//                    wrkMast.setCrnNo(1);
//                    wrkMast.setSourceStaNo(101);
//                    wrkMast.setStaNo(103);
//                    wrkMast.setLocNo("0200404");
//                    wrkMast.setFullPlt("N"); // 满板：N
//                    wrkMast.setPicking("N"); // 拣料
//                    wrkMast.setExitMk("N"); // 退出
//                    wrkMast.setEmptyMk("Y"); // 空板
//                    wrkMast.setLinkMis("Y");
//                    // 操作人员数据
//                    wrkMast.setAppeTime(now);
//                    wrkMast.setModiTime(now);
//                    wrkMast.setMemo("自动空托入库");
//                    boolean res = wrkMastService.save(wrkMast);
//                    staProtocol.setWorkNo(Short.parseShort(wrkMast.getWrkNo() + ""));
//                    staProtocol.setStaNo(Short.parseShort(wrkMast.getStaNo() + ""));
//                    boolean result = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
//                    log.info("输送线下发(存在设备上走的工作档，直接下发！))：" + wrkMast.getWrkNo() + "," + wrkMast.getStaNo());
//                    // 更新目标库位状态
//                    if (locMast.getLocSts().equals("O")) {
//                        locMast.setLocSts("S"); // S.入库预约
//                        locMast.setModiUser(789L);
//                        locMast.setModiTime(now);
//                        if (!locMastService.updateById(locMast)) {
//                            throw new CoolException("改变库位状态失败");
//                        }
//                    }
//                } catch (Exception e) {
//                    e.printStackTrace();
//                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
//                }
//            }
//        }
//    }
//}