wms / wms_changshushengyi · Files

package com.huaheng.api.acs.controller;

import java.math.BigDecimal;

import javax.annotation.Resource;

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

import com.alibaba.fastjson.JSON;

import com.huaheng.api.acs.domain.AcsStatus;
import com.huaheng.api.acs.service.AcsService;

import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.http.OkHttpUtils;

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.domain.WeightRollNumberInfo;
import com.huaheng.pc.sap.service.WeightRollNumberInfoService;

import io.swagger.annotations.ApiOperation;

@RestController

@RequestMapping("/agv")

public class AcsController extends BaseController {

    @Resource
    private AcsService acsService;

    @Resource
    private WeightRollNumberInfoService weightRollNumberInfoService;

    private AddressService addressService;

    /**

     * status 20 任务执行中；
     * 50 取货完成；

     * 90 任务完成；

     * @param  acsStatus

     * @return
     */

    @PostMapping("/notifyAGVTask")

    @ApiOperation("更新AGV状态")
    @ResponseBody

    @ApiLogger(apiName = "更新AGV状态", from = "acs")

    public AjaxResult notifyAGVTask(@RequestBody AcsStatus acsStatus) {

        AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {

                AjaxResult ajaxResult = acsService.notifyAGVTask(acsStatus);

                return ajaxResult;
            }
        });

        return ajaxResult;

    }

    /**
     * status 20 任务执行中；
     * 50 取货完成；
     * 90 任务完成；
     * @param  acsStatus
     * @return
     */
    @PostMapping("/bindContainer")
    @ApiOperation("玻璃布物料绑定托盘")
    @ResponseBody
    @ApiLogger(apiName = "玻璃布物料绑定托盘", from = "acs")
    public AjaxResult bindContainer(@RequestBody AcsStatus acsStatus) {
        AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {

                AjaxResult ajaxResult = acsService.bindContainer(acsStatus);
                return ajaxResult;

            }
        });
        return ajaxResult;

    }

    @PostMapping("/pushWeightRollNumber")
    @ApiOperation("推送卷号重量信息")
    @ResponseBody
    @ApiLogger(apiName = "推送卷号重量信息", from = "acs")
    public AjaxResult pushWeightRollNumber(@RequestBody WeightRollNumberInfo weightRollNumberInfo) {

        String rollNumber = weightRollNumberInfo.getRollNumber();
        BigDecimal weight = weightRollNumberInfo.getWeight();
        String area = weightRollNumberInfo.getArea();
        String warehouseCode = weightRollNumberInfo.getWarehouseCode();
        if (StringUtils.isEmpty(area)) {
            return AjaxResult.error("area不为空：");
        }
        if (StringUtils.isEmpty(warehouseCode)) {
            return AjaxResult.error("warehouseCode不为空：");
        }
        if (StringUtils.isEmpty(rollNumber)) {
            return AjaxResult.error("卷号不为空：");
        }
        if (weight.compareTo(BigDecimal.ZERO) <= 0) {
            return AjaxResult.error("重量不为空：");
        }
        AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {
                boolean save = weightRollNumberInfoService.save(weightRollNumberInfo);

                String bodypost = null;
                try {

                    String url = addressService.selectAddress(QuantityConstant.WEIGHT_ROLLNUMBER_URL, weightRollNumberInfo.getWarehouseCode(),
                        weightRollNumberInfo.getArea());

                    String param = JSON.toJSONString(weightRollNumberInfo);
                    bodypost = OkHttpUtils.bodypost(url, param);
                    weightRollNumberInfo.setSend(1);
                    weightRollNumberInfoService.updateById(weightRollNumberInfo);
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    return AjaxResult.toAjax(save).setData(bodypost);
                }

            }
        });
        return ajaxResult;
    }

}