package com.zy.asrs.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.annotations.AppAuth;
|
import com.core.common.BaseRes;
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.InventoryCheckOrder;
|
import com.zy.asrs.entity.InventoryCheckOrderDetl;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.entity.param.*;
|
import com.zy.asrs.service.*;
|
import com.zy.common.web.BaseController;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* Created by vincent on 2022/4/8
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("open/wms")
|
public class OpenMesController extends BaseController {
|
|
private static final boolean auth = true;
|
public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{
|
add("ea1f0459efc02a79f046f982767939ae");
|
}};
|
|
@Autowired
|
private OpenService openService;
|
|
@Autowired
|
private ManLocDetlService manLocDetlService;
|
|
@Autowired
|
private WrkMastService wrkMastService;
|
|
@Autowired
|
private InventoryCheckOrderService inventoryCheckOrderService;
|
|
@Autowired
|
private InventoryCheckOrderDetlService inventoryCheckOrderDetlService;
|
|
|
@PostMapping("/mat/sync/default/v1")
|
@AppAuth(memo = "商品信息同步接口")
|
public synchronized R syncMatInfo(@RequestHeader(required = false) String appkey,
|
@RequestBody(required = false) MatSyncParam param,
|
HttpServletRequest request) {
|
auth(appkey, param, request);
|
if (Cools.isEmpty(param)) {
|
return R.parse(BaseRes.PARAM);
|
}
|
openService.syncMat(param);
|
return R.ok();
|
}
|
|
@PostMapping("/inventory/result")
|
@AppAuth(memo = "盘点结果同步接口")
|
public synchronized R inventory(@RequestHeader(required = false) String appkey,
|
@RequestBody(required = false) CheckResult param,
|
HttpServletRequest request) {
|
auth(appkey, param, request);
|
if (Cools.isEmpty(param)) {
|
return R.parse(BaseRes.PARAM);
|
}
|
WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode());
|
if (Cools.isEmpty(wrkMast)) {
|
return R.error("无法通过托盘码找到该工作档,请检查托盘码是否正确");
|
}
|
LocDetlAdjustParam adjustParam = new LocDetlAdjustParam();
|
adjustParam.setLocNo(wrkMast.getWrkSts() < 100 ? wrkMast.getLocNo() : wrkMast.getSourceLocNo());
|
List<LocDetlAdjustParam.LocDetlAdjust> list = new ArrayList<>();
|
param.getDetails().forEach(elem -> {
|
list.add(new LocDetlAdjustParam.LocDetlAdjust(elem.getMatnr(), elem.getBatch(), elem.getActulQty(), elem.getDanger()));
|
});
|
manLocDetlService.adjustLocDetl2(adjustParam, getUserId());
|
return R.ok();
|
}
|
|
@PostMapping("/orderSync/default/v1")
|
@AppAuth(memo = "订单信息同步接口")
|
public synchronized R syncOrderInfo(@RequestHeader(required = false) String appkey,
|
@RequestBody(required = false) GTOrderParam param,
|
HttpServletRequest request) {
|
auth(appkey, param, request);
|
if (Cools.isEmpty(param)) {
|
return R.parse(BaseRes.PARAM);
|
}
|
|
return R.ok();
|
}
|
|
|
/**
|
* 添加入库单
|
*/
|
@PostMapping("/order/pakin/default/v1")
|
@AppAuth(memo = "入库单据下发")
|
public synchronized R pakinOrderCreate(@RequestHeader(required = false) String appkey,
|
@RequestBody OpenOrderPakinParam param,
|
HttpServletRequest request) {
|
auth(appkey, param, request);
|
if (Cools.isEmpty(param)) {
|
return R.parse(BaseRes.PARAM);
|
}
|
if (Cools.isEmpty(param.getOrderNo())) {
|
return R.error("单据编号[orderNo]不能为空");
|
}
|
if (Cools.isEmpty(param.getOrderType())) {
|
return R.error("单据类型[orderType]不能为空");
|
}
|
if (Cools.isEmpty(param.getDetails())) {
|
return R.error("单据明细[orderDetails]不能为空");
|
}
|
openService.pakinOrderCreate(param);
|
return R.ok();
|
}
|
|
|
/**
|
* 添加出库单
|
*/
|
@PostMapping("/order/pakout/default/v1")
|
@AppAuth(memo = "添加订单出库")
|
public synchronized R pakoutOrderCreate(@RequestHeader(required = false) String appkey,
|
@RequestBody OpenOrderPakoutParam param,
|
HttpServletRequest request) {
|
auth(appkey, param, request);
|
if (Cools.isEmpty(param)) {
|
return R.parse(BaseRes.PARAM);
|
}
|
if (Cools.isEmpty(param.getLgort())) {
|
return R.error("单据编号[lgort]不能为空");
|
}
|
if (!param.getLgort().equals("5006")) {
|
return R.ok();
|
}
|
if (Cools.isEmpty(param.getOrderNo())) {
|
return R.error("单据编号[orderNo]不能为空");
|
}
|
if (Cools.isEmpty(param.getOrderType())) {
|
return R.error("单据类型[orderType]不能为空");
|
}
|
if (Cools.isEmpty(param.getDetails())) {
|
return R.error("单据明细[orderDetails]不能为空");
|
}
|
openService.pakoutOrderCreate(param);
|
return R.ok();
|
}
|
|
/**
|
* 添加盘点单
|
*/
|
@PostMapping("/inventory/trigger/v1")
|
@AppAuth(memo = "添加盘点单")
|
public synchronized R check(@RequestHeader(required = false) String appkey,
|
@RequestBody CheckOrderParam param,
|
HttpServletRequest request) {
|
auth(appkey, param, request);
|
String orderNo = param.getOrderNo();
|
long time = new Date().getTime();
|
if (Cools.isEmpty(orderNo)) {
|
switch (param.getArea()) {
|
case "堆垛机":
|
orderNo = "DDJ" + time;
|
break;
|
case "四向库":
|
orderNo = "SXK" + time;
|
break;
|
case "CTU":
|
orderNo = "CTU" + time;
|
break;
|
}
|
param.setOrderNo(orderNo);
|
}
|
|
int count = inventoryCheckOrderService.selectCount(new EntityWrapper<InventoryCheckOrder>().eq("order_no", orderNo));
|
if (count > 0) {
|
return R.parse("单据编号已经存在：" + orderNo);
|
}
|
InventoryCheckOrder checkOrder = new InventoryCheckOrder();
|
checkOrder.setOrderNo(orderNo);
|
checkOrder.setCreateBy(getUserId().toString());
|
checkOrder.setCreateTime(new Date());
|
checkOrder.setStatus("1");
|
param.getDetails().forEach(elem -> {
|
checkOrder.setArea(param.getArea());
|
InventoryCheckOrderDetl detail = new InventoryCheckOrderDetl();
|
detail.setMatnr(elem.getMatnr());
|
detail.setBatch(elem.getBatch());
|
inventoryCheckOrderDetlService.insert(detail);
|
});
|
inventoryCheckOrderService.insert(checkOrder);
|
|
|
return R.ok();
|
}
|
|
|
private void auth(String appkey, Object obj, HttpServletRequest request) {
|
log.info("{}接口被访问；appkey:{}；请求数据：{}", request.getRequestURI(), appkey, JSON.toJSONString(obj));
|
request.setAttribute("cache", obj);
|
if (!auth) {
|
return;
|
}
|
if (Cools.isEmpty(appkey)) {
|
throw new CoolException("认证失败，请确认appkey无误！");
|
}
|
if (!APP_KEY_LIST.contains(appkey)) {
|
throw new CoolException("认证失败，请确认appkey无误！");
|
}
|
}
|
|
|
}
|
