#

whycq

2024-12-30 a12e16c98db1dd2b712a092912abf4aa20c3c00c

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

@@ -51,6 +51,8 @@
import java.util.*;
import java.util.stream.Collectors;

import static com.zy.common.utils.RandomValidateCodeUtil.code;

/**
 * 立体仓库WCS系统主流程业务
 * Created by vincent on 2020/8/6
@@ -3718,6 +3720,48 @@

    }

    public synchronized void getNeed() {
        for (DevpSlave devp : slaveProperties.getDevp()) {
            if (devp.getId() != 2) {
                continue;
            }
            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
            if (devpThread.isCalled == 1) {
                try {
                    String response = new HttpHandler.Builder()
                            .setUri(wmsUrl)
                            .setPath("/rpc/process/loc/v1")
                            .build()
                            .doPost();
                    JSONObject jsonObject = JSON.parseObject(response);
                    if (jsonObject.getInteger("code").equals(200)) {
                        log.info("任务下发成功");
                        boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, null));
                    } else {
                        log.error("请求接口失败！！！url：{}；response：{}", wmsUrl + "/mobile/comb/auth", response);
                    }
                    Thread.sleep(1000);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if (devpThread.isFinish == 1) {

                Integer weight = devpThread.weight;
                Integer isHalf = devpThread.isHalf;
                WrkMast lastWrkMast105 = wrkMastService.getLastWrkMast105();
                if (Cools.isEmpty(lastWrkMast105)) continue;
                List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(lastWrkMast105.getWrkNo());
                if (!Cools.isEmpty(wrkDetls)) {
                    for (WrkDetl wrkDetl : wrkDetls) {
                        wrkDetl.setWeight(weight.doubleValue());
                        wrkDetlService.updateById(wrkDetl);
                    }
                }
                boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, null));
            }
        }
    }
    public void CreateComb(String barcode,String code,Integer wrkNo,String batch,DevpSlave.Sta inSta) throws IOException {
        Double anfme = 0d;
        Double weight = 0d;