11

skyouc

7 天以前 aad36163fc3424143f6373d486494dfc6786c263

11

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java

@@ -18,6 +18,7 @@
import com.zy.acs.common.utils.GsonUtils;
import com.zy.acs.common.utils.Utils;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.framework.common.R;
import com.zy.acs.framework.common.SnowflakeIdWorker;
import com.zy.acs.framework.exception.CoolException;
import com.zy.acs.manager.common.domain.TaskDto;
@@ -28,10 +29,12 @@
import com.zy.acs.manager.core.domain.TaskPosDto;
import com.zy.acs.manager.core.service.astart.MapDataDispatcher;
import com.zy.acs.manager.core.utils.HttpHandler;
import com.zy.acs.manager.manager.controller.param.LocSiteParams;
import com.zy.acs.manager.manager.controller.param.OpenBusSubmitParam;
import com.zy.acs.manager.manager.entity.*;
import com.zy.acs.manager.manager.enums.*;
import com.zy.acs.manager.manager.service.*;
import com.zy.acs.manager.manager.service.impl.LocStsServiceImpl;
import com.zy.acs.manager.manager.service.impl.WebsocketServiceImpl;
import com.zy.acs.manager.manager.utils.ActionSorter;
import com.zy.acs.manager.system.service.ConfigService;
@@ -104,6 +107,8 @@
    private TaskReportService taskReportService;
    @Autowired
    private AgvDurationService agvDurationService;
    @Autowired
    private LocStsService locStsService;

    @SuppressWarnings("all")
    @Transactional
@@ -2407,4 +2412,41 @@
        }
        return false;
    }

    /**
     * @author Ryan
     * @date 2025/11/10
     * @description: 修改库位状态
     * @version 1.0
     */
    @Transactional(rollbackFor = Exception.class)
    public R modifyStatus(LocSiteParams params) {
        if (Objects.isNull(params.getStatus())) {
            return R.error("修改状态不能为空！！");
        }
        LocSts locSts = locStsService.getOne(new LambdaQueryWrapper<LocSts>().eq(LocSts::getUuid, params.getStatus()));
        if (Objects.isNull(locSts)) {
            return R.error("数据错误，未找到对应工作状态！！");
        }
        if (!params.getType().equals("loc")) {
            Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, params.getCode()));
            if (Objects.isNull(loc)) {
                return R.error("库位信息不存在！！");
            }
            loc.setLocSts(locSts.getId());
            if (!locService.updateById(loc)) {
                return R.ok("库位状态修改失败！！");
            }
        } else {
            Sta sta = staService.getOne(new LambdaQueryWrapper<Sta>().eq(Sta::getStaNo, params.getCode()));
            if (Objects.isNull(sta)) {
                return R.error("站点信息不存在！！");
            }
            sta.setStatus(locSts.getStatus());
            if (!staService.updateById(sta)) {
                return R.error("站点状态修改失败！！");
            }
        }
        return R.ok();
    }
}

 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/OpenController.java

@@ -9,6 +9,7 @@
import com.zy.acs.manager.common.domain.TaskDto;
import com.zy.acs.manager.core.constant.LocGroupConstant;
import com.zy.acs.manager.core.service.MainService;
import com.zy.acs.manager.manager.controller.param.LocSiteParams;
import com.zy.acs.manager.manager.controller.param.OpenBusSubmitParam;
import com.zy.acs.manager.manager.entity.Loc;
import com.zy.acs.manager.manager.entity.Sta;
@@ -53,7 +54,6 @@
    private TaskService taskService;


    //@PreAuthorize("hasAuthority('open:bus:submit')")
    @PostMapping("/bus/submit")
    @OperationLog("generate task from open api")
    public synchronized R save(@RequestBody OpenBusSubmitParam param) {
@@ -69,6 +69,15 @@
        return R.ok("generate tasks success");
    }

    @OperationLog("修改库位或站点状态")
    @PostMapping("/modify/status")
    public R modifyLocOrSite(@RequestBody LocSiteParams params) {
        if (Objects.isNull(params)) {
            return R.error("参数不能为空！！");
        }
        return mainService.modifyStatus(params);
    }


    @OperationLog("Cancel Task")
    @PostMapping("/task/cancel")

 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/controller/param/LocSiteParams.java

New file
@@ -0,0 +1,26 @@
package com.zy.acs.manager.manager.controller.param;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.experimental.Accessors;

import java.io.Serializable;

@Data
@Accessors(chain = true)
@ApiModel(value = "LocSiteParams", description = "库位或状态参数")
public class LocSiteParams implements Serializable {

    private static final long serialVersionUID = 1L;

    @ApiModelProperty("类型：loc: 库位， site: 站点")
    private String type = "loc";

    @ApiModelProperty("站点或库位")
    private String code;

    @ApiModelProperty("库位或站点状态")
    private String status;

}