TaskFinishController.java 2.13 KB
package com.huaheng.api.wcs.controller;

import com.huaheng.api.wcs.domain.TaskFinishDomain;
import com.huaheng.api.wcs.domain.WcsTask;
import com.huaheng.api.wcs.service.taskFinish.TaskFinishService;
import com.huaheng.framework.aspectj.lang.annotation.ApiLogger;
import com.huaheng.framework.aspectj.lang.annotation.Log;
import com.huaheng.framework.aspectj.lang.constant.BusinessType;
import com.huaheng.framework.web.controller.BaseController;
import com.huaheng.framework.web.domain.AjaxResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.collections.MapUtils;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

import java.util.HashMap;
import java.util.Map;

/**任务完成
 * wcs向wms传递数据
 * @author ricard
 * @date   2019/10/11
 *
 */

@RestController
@RequestMapping("/API/WMS/v2")
public class TaskFinishController extends BaseController {

    @Resource
    private TaskFinishService taskFinishService;

    public static Map<String, Boolean> PassbackMap = new HashMap<>();



    @Log(title = "wcs任务完成", action = BusinessType.INSERT)
    @PostMapping("/complete")
    @ApiOperation("wcs任务完成")
    @ResponseBody
    @ApiLogger(apiName = "wcs任务完成", from = "WCS")
    public AjaxResult complete(@RequestBody TaskFinishDomain taskFinishDomain)
    {

        String taskKey = "PassBackMap";
        if (MapUtils.getBoolean(PassbackMap, taskKey, false)) {
            return AjaxResult.error("不能同时访问");
        }
        PassbackMap.put(taskKey, true);
        AjaxResult ajaxResult = handleMultiProcess("complete",new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {
                try {
                    AjaxResult ajaxResult = taskFinishService.completeTaskByWCS(taskFinishDomain);
                    return ajaxResult;
                } catch (Exception e) {
                    return AjaxResult.error(e.getMessage());
                } finally {
                    PassbackMap.put(taskKey, false);
                }
            }
        });
        return ajaxResult;



    }

}