AcsByCSController.java 2.38 KB
package com.huaheng.api.acs.controller;

import javax.annotation.Resource;

import org.springframework.web.bind.annotation.*;

import com.huaheng.api.acs.domain.AcsByCSStatus;
import com.huaheng.api.acs.service.AcsByCSWXFService;
import com.huaheng.api.acs.service.AcsReceiptService;
import com.huaheng.api.wcs.controller.EmptyContainerController;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.framework.aspectj.lang.annotation.ApiLogger;
import com.huaheng.framework.web.controller.BaseController;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.address.service.AddressService;
import com.huaheng.pc.sap.service.WeightRollNumberInfoService;

import io.swagger.annotations.ApiOperation;

@RestController
@RequestMapping("/agvCS")
public class AcsByCSController extends BaseController {

    @Resource
    private AcsByCSWXFService acsByCSWXFService;
    @Resource
    private WeightRollNumberInfoService weightRollNumberInfoService;
    @Resource
    private AddressService addressService;
    @Resource
    private AcsReceiptService acsReceiptService;
    @Resource
    private EmptyContainerController emptyContainerController;

    /**
     * status 20 任务执行中;
     * 50 取货完成;
     * 100 任务完成;
     * @param  acsByCSStatus
     * @return
     */
    @PostMapping("/notifyAGVTask")
    @ApiOperation("长沙更新AGV状态")
    @ResponseBody
    @ApiLogger(apiName = "长沙更新AGV状态", from = "acs")
    public AjaxResult notifyAGVTaskCS(@RequestBody AcsByCSStatus acsByCSStatus) {
        if (acsByCSStatus == null) {
            return AjaxResult.error("传输数据为空");
        }
        String taskNo = acsByCSStatus.getTaskNo();
        String carNo = acsByCSStatus.getCardNo();
        int status = acsByCSStatus.getStatus();

        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("更新AGV状态,任务号为空");
        }

        if (status == 0) {
            return AjaxResult.error("更新AGV状态,状态信息为空");
        }

        AjaxResult ajaxResult = handleMultiProcess("notifyAGVTaskCS", new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {
                AjaxResult ajaxResult = acsByCSWXFService.notifyAGVTask(taskNo, carNo, status, "acs");
                return ajaxResult;
            }
        });
        return ajaxResult;
    }

}