*

lsh

2024-10-17 6e5dbbf19de06b0307ac7841bb326d2d88e8d357

*

 src/main/java/com/zy/asrs/controller/SiteController.java

@@ -173,7 +173,7 @@
    @PostMapping("/detl/update")
    @ManagerAuth(memo = "修改站点数据")
    public R siteDetlUpdate(@RequestParam Integer siteId,
                            @RequestParam Integer workNo,
                            @RequestParam Long workNo,
                            @RequestParam Integer staNo,
                            @RequestParam String pakMk){
        for (DevpSlave devp : slaveProperties.getDevp()) {

 src/main/java/com/zy/asrs/domain/vo/SiteDetailVo.java

@@ -13,7 +13,7 @@
    private Integer siteId;

    // 工作号
    private Integer workNo;
    private Long workNo;

    // 工作状态
    private String wrkSts = "";

 src/main/java/com/zy/asrs/domain/vo/SiteLatestDataVo.java

@@ -14,7 +14,7 @@
    private String siteId;

    // 工作号
    private Integer workNo;
    private Long workNo;

    // 站点状态
    private SiteStatusType siteStatus;

 src/main/java/com/zy/asrs/domain/vo/SiteTableVo.java

@@ -12,7 +12,7 @@
    private Integer devNo;

    // 工作号
    private Integer workNo = 0;
    private Long workNo = 0L;

    // 自动
    private String autoing = "-";

 src/main/java/com/zy/asrs/entity/BasRgv.java

@@ -60,14 +60,14 @@
     */
    @ApiModelProperty(value= "任务号")
    @TableField("wrk_no1")
    private Integer wrkNo1;
    private Long wrkNo1;

    /**
     * 堆垛机号
     */
    @ApiModelProperty(value= "堆垛机号")
    @TableField("wrk_no2")
    private Integer wrkNo2;
    private Long wrkNo2;

    /**
     * 错误码
@@ -133,7 +133,7 @@

    public BasRgv() {}

    public BasRgv(Integer rgvNo,String inEnable,String outEnable,Integer rgvSts,Integer wrkNo1,Integer wrkNo2,Long rgvErr,String pakMk,Integer status,Long createBy,Date createTime,Long updateBy,Date updateTime,String memo) {
    public BasRgv(Integer rgvNo,String inEnable,String outEnable,Integer rgvSts,Long wrkNo1,Long wrkNo2,Long rgvErr,String pakMk,Integer status,Long createBy,Date createTime,Long updateBy,Date updateTime,String memo) {
        this.rgvNo = rgvNo;
        this.inEnable = inEnable;
        this.outEnable = outEnable;

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

@@ -1,10 +1,14 @@
package com.zy.asrs.service.impl;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.common.R;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.entity.param.WcsTaskDistributionParam;
import com.zy.asrs.service.OpenService;
import com.zy.asrs.service.WrkMastService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@@ -17,6 +21,9 @@
@Service
public class OpenServiceImpl implements OpenService {

    @Autowired
    private WrkMastService wrkMastService;

    @Override
    @Transactional
    public List<String> queryStock() {
@@ -26,12 +33,17 @@
    @Override
    @Transactional
    public R wcsTaskDistribution(WcsTaskDistributionParam param) {
        WrkMast wrkMast1 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrkNo", param.getTaskNo()));
        if (!Cools.isEmpty(wrkMast1)){
            return R.error().add("工作号已存在，taskNo="+param.getTaskNo());
        }
        WrkMast wrkMast = new WrkMast();
        wrkMast.setWrkNo(param.getTaskNo());
        wrkMast.setSourceStaNo(param.getStartSta$());
        wrkMast.setStaNo(param.getEndSta$());
        wrkMast.setWrkSts(1L);
        wrkMast.setIoType(1);
        wrkMastService.insert(wrkMast);
        return R.ok();
    }


 src/main/java/com/zy/core/model/protocol/RgvProtocol.java

@@ -185,7 +185,7 @@
        if (alarm!=null) {
            basRgv.setRgvErr(alarm.longValue());
        }
        basRgv.setWrkNo1(taskNo1.intValue());
        basRgv.setWrkNo1(taskNo1.longValue());
        return basRgv;
    }


 src/main/java/com/zy/core/thread/SiemensDevpThread.java

@@ -158,7 +158,7 @@
                    staProtocol.setSiteId(siteId);
                    station.put(siteId, staProtocol);
                }
                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransUInt32(result.Content, i*8));     // 工作号
                staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransUInt32(result.Content, i*4));     // 工作号
            }
        }