#

lty

昨天 276d837c0bb808e6d93ac7c7ba6abe654c75552e

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

@@ -1,18 +1,36 @@
package com.zy.asrs.service.impl;

import com.core.common.R;
import com.zy.asrs.entity.param.ArmPrecomputeParam;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.zy.asrs.entity.WrkDetl;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.entity.param.TaskCreateParam;
import com.zy.asrs.entity.param.TaskStatusFeedbackParam;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.OpenService;
import com.zy.asrs.service.WrkDetlService;
import com.zy.asrs.service.WrkMastService;
import com.zy.common.service.CommonService;
import com.zy.common.utils.HttpHandler;
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 com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.SiemensDevpThread;
import com.zy.core.model.DevpSlave;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.HashMap;
import java.util.Map;

/**
 * Created by vincent on 2022/4/9
@@ -21,5 +39,244 @@
@Service
public class OpenServiceImpl implements OpenService {

    @Value("${wms.url}")
    private String wmsUrl;

    @Autowired
    private ApiLogService apiLogService;
    
    @Autowired
    private CommonService commonService;
    
    @Autowired
    private WrkMastService wrkMastService;
    
    @Autowired
    private WrkDetlService wrkDetlService;
    
    @Autowired
    private SlaveProperties slaveProperties;


    @Override
    public boolean reportTaskStatus(String taskNo, Integer status, Integer ioType, String barcode) {
        try {
            TaskStatusFeedbackParam param = new TaskStatusFeedbackParam();
            param.setTaskNo(taskNo);
            param.setStatus(status);
            param.setIoType(ioType);
            param.setBarcode(barcode);
            param.setReportTime(new Date());

            Map<String, Object> headers = new HashMap<>();
            headers.put("appkey", "ea1f0459efc02a79f046f982767939ae");

            String response = new HttpHandler.Builder()
                    .setUri(wmsUrl)
                    .setPath("/taskStatusFeedback")
                    .setJson(JSON.toJSONString(param))
                    .setHeaders(headers)
                    .build()
                    .doPost();

            boolean success = false;
            log.info("任务状态反馈上报结果：{}", response);
            if (response != null) {
                try {
                    JSONObject jsonObject = JSON.parseObject(response);
                    // 假设返回code为200表示成功
                    if (jsonObject != null && jsonObject.containsKey("code") && jsonObject.getInteger("code") == 200) {
                        success = true;
                    }
                } catch (Exception e) {
                    log.warn("解析响应失败", e);
                }
            }

            // 记录日志
            try {
                apiLogService.save("任务状态反馈上报",
                        "/taskStatusFeedback",
                        "ea1f0459efc02a79f046f982767939ae",
                        wmsUrl,
                        JSON.toJSONString(param),
                        response,
                        success);
            } catch (Exception e) {
                log.error("保存API日志异常", e);
            }

            return success;
        } catch (Exception e) {
            log.error("任务状态反馈上报异常", e);
        }
        return false;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean taskCreate(TaskCreateParam param) {
        try {
            Integer ioType = 0;
            boolean Inbound = true;
            //1：出库，2：入库 3：移库
            //11：空板出库，12：空板入库
            //21：拣选出库 22：拣选入库
            //31：盘点出库 32：盘点入库
            switch (param.getIoType()){
                case 1:  Inbound = false;break;
                case 2 : Inbound = true;break;
                case 3:  Inbound = false;break;
                case 11: Inbound = false;ioType = 110;break;
                case 12: Inbound = true;break;
                case 21: Inbound = false;ioType = 103;break;
                case 22: Inbound = true;break;
                case 31: Inbound = false;ioType = 107;break;
                case 32: Inbound = true;break;
            }
            // 2. 保存WrkMast
            WrkMast wrkMast = new WrkMast();

            if(param.getIoType() == 2 || param.getIoType() == 12){
                wrkMast.setWrkNo(Integer.valueOf(param.getTaskNo()));
                wrkMast.setIoType(param.getIoType() != 2?10:1);
                wrkMast.setIoPri(param.getTaskPriority() != null ? param.getTaskPriority().doubleValue() : 11.0);
                wrkMast.setBarcode(param.getBarcode());
                wrkMast.setMemo(param.getMemo());
                wrkMast.setSourceStaNo(Integer.valueOf(param.getStartPoint()));
                wrkMast.setStaNo(Integer.valueOf(param.getTargetPoint()));
                wrkMast.setLocNo(param.getTargetLocNo());
                wrkMast.setSourceLocNo(param.getSourceLocNo());
            }else if(param.getIoType() == 22 || param.getIoType() == 32){
                wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("barcode",param.getBarcode()));
                wrkMast.setWrkSts(param.getIoType() != 32 ? 53L: 57L);
                wrkMast.setWrkNo(Integer.valueOf(param.getTaskNo()));
                wrkMast.setIoPri(param.getTaskPriority() != null ? param.getTaskPriority().doubleValue() : 11.0);
                wrkMast.setBarcode(param.getBarcode());
                wrkMast.setMemo(param.getMemo());
                wrkMast.setSourceStaNo(Integer.valueOf(param.getStartPoint()));
                wrkMast.setStaNo(Integer.valueOf(param.getTargetPoint()));
                wrkMast.setLocNo(param.getTargetLocNo());
                wrkMast.setSourceLocNo(param.getSourceLocNo());
            }else if(param.getIoType() == 3){
                wrkMast.setWrkNo(Integer.valueOf(param.getTaskNo()));
                wrkMast.setIoType(11);
                wrkMast.setIoPri(param.getTaskPriority() != null ? param.getTaskPriority().doubleValue() : 12.0);
                wrkMast.setBarcode(param.getBarcode());
                wrkMast.setMemo(param.getMemo());
                wrkMast.setSourceStaNo(Integer.valueOf(param.getStartPoint()));
                wrkMast.setStaNo(Integer.valueOf(param.getTargetPoint()));
                wrkMast.setLocNo(param.getTargetLocNo());
                wrkMast.setSourceLocNo(param.getSourceLocNo());
            }else{
                wrkMast.setWrkNo(Integer.valueOf(param.getTaskNo()));
                wrkMast.setIoType(ioType);
                wrkMast.setIoPri(param.getTaskPriority() != null ? param.getTaskPriority().doubleValue() : 11.0);
                wrkMast.setBarcode(param.getBarcode());
                wrkMast.setMemo(param.getMemo());
                wrkMast.setSourceStaNo(Integer.valueOf(param.getStartPoint()));
                wrkMast.setStaNo(Integer.valueOf(param.getTargetPoint()));
                wrkMast.setLocNo(param.getTargetLocNo());
                wrkMast.setSourceLocNo(param.getSourceLocNo());
            }

            if(Inbound){
                wrkMast.setWrkSts(2L);
            }else{
                wrkMast.setWrkSts(11L);
            }
            wrkMast.setAppeTime(new Date());
            wrkMast.setWrkDate(new Date());
            
            wrkMastService.insert(wrkMast);

            // 3. 保存WrkDetl
            if (param.getDetlList() != null && !param.getDetlList().isEmpty()) {
                for (TaskCreateParam.Detl detl : param.getDetlList()) {
                    WrkDetl wrkDetl = new WrkDetl();
                    wrkDetl.setWrkNo(wrkMast.getWrkNo());
                    wrkDetl.setZpallet(detl.getBarcode());
                    wrkDetl.setMatnr(detl.getMatnr());
                    wrkDetl.setBatch(detl.getBatch());
                    if (detl.getAnfme() != null) {
                        wrkDetl.setAnfme(detl.getAnfme().doubleValue());
                    }
                    wrkDetlService.insert(wrkDetl);
                }
            }
            
            // 4. 下发给PLC
            if(Inbound){
                writeToPlc(wrkMast);
            }

            // 记录日志
            try {
                apiLogService.save("任务下发",
                        "/taskCreate",
                        "ea1f0459efc02a79f046f982767939ae",
                        "LOCAL",
                        JSON.toJSONString(param),
                        "SUCCESS",
                        true);
            } catch (Exception e) {
                log.error("保存API日志异常", e);
            }
            
            return true;
        } catch (Exception e) {
            log.error("任务下发异常", e);
             try {
                apiLogService.save("任务下发",
                        "/taskCreate",
                        "ea1f0459efc02a79f046f982767939ae",
                        "LOCAL",
                        JSON.toJSONString(param),
                        "FAIL: " + e.getMessage(),
                        false);
            } catch (Exception ex) {
                // ignore
            }
            throw new RuntimeException(e); // 触发事务回滚
        }
    }
    
    private void writeToPlc(WrkMast wrkMast) {
        if (wrkMast.getSourceStaNo() == null) {
            log.warn("任务下发缺少源站点: wrkNo={}", wrkMast.getWrkNo());
            return;
        }
        
        Integer sourceStaNo = wrkMast.getSourceStaNo();
        
        for (DevpSlave devp : slaveProperties.getDevp()) {
             SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
             if (devpThread == null) continue;
             
             // 检查该PLC是否管理该站点
             if (devpThread.getStation().containsKey(sourceStaNo.shortValue())) {
                 StaProtocol staProtocol = devpThread.getStation().get(sourceStaNo.shortValue());
                 if (staProtocol != null && staProtocol.getWorkNo() == 9998) {

                     staProtocol.setWorkNo(wrkMast.getWrkNo());
                     if (wrkMast.getStaNo() != null) {
                        staProtocol.setStaNo(wrkMast.getStaNo().shortValue());
                     }
                     
                     // 下发PLC指令
                     devpThread.setPakMk(staProtocol.getSiteId(), false, 283);
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     
                     if (result) {
                         log.info("任务下发成功，已写入PLC。WrkNo: {}, Source: {}, Target: {}", 
                                 wrkMast.getWrkNo(), wrkMast.getSourceStaNo(), wrkMast.getStaNo());
                     } else {
                         log.error("任务下发失败，写入PLC队列失败。WrkNo: {}", wrkMast.getWrkNo());
                     }
                     return;
                 }
             }
        }
        log.warn("未找到对应的PLC站点或线程: {}", sourceStaNo);
    }
}