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.*; import com.core.exception.CoolException; import com.zy.asrs.entity.WrkMast; import com.zy.asrs.entity.param.*; import com.zy.asrs.service.OpenService; import com.zy.asrs.service.WrkMastService; import com.zy.common.model.DetlDto; 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; import java.util.Map; /** * Created by vincent on 2022/4/8 */ @Slf4j @RestController @RequestMapping("open/asrs") public class OpenController extends BaseController { private static final boolean auth = true; public static final ArrayList APP_KEY_LIST = new ArrayList() {{ add("ea1f0459efc02a79f046f982767939ae"); }}; @Autowired private OpenService openService; @Autowired private WrkMastService wrkMastService; @GetMapping("/order/delete/v1") @AppAuth(memo = "订单信息删除") public synchronized R orderDelete(@RequestHeader(required = false) String appkey, @RequestParam String orderNo, HttpServletRequest request) { auth(appkey, orderNo, request); if (Cools.isEmpty(orderNo)) { return R.parse(BaseRes.PARAM); } openService.orderDelete(orderNo); return R.ok(); } @PostMapping("/tagSync/v1") @AppAuth(memo = "物料分类同步") public synchronized R tagSync(@RequestHeader(required = false) String appkey, @RequestBody(required = false) List> param, HttpServletRequest request) { auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } ArrayList params = new ArrayList<>(); for (Map map : param) { TagParam tagParam = new TagParam(map); params.add(tagParam); } openService.syncTag(params); return R.ok(); } @PostMapping("/wrkMast/finish/v1") @AppAuth(memo = "四向车任务完成") public synchronized R wrkMastFinish(@RequestHeader(required = false) String appkey, @RequestBody(required = false) ShuttleFinishParam param, HttpServletRequest request) { auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } try { WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", param.getTaskNo()).eq("crn_no",7)); if (Cools.isEmpty(wrkMast)) { throw new CoolException("四向库任务未找到"); } if (wrkMast.getIoType() == 1 || wrkMast.getIoType() == 10 || wrkMast.getIoType() == 53 || wrkMast.getIoType() == 54 || wrkMast.getIoType() == 57) { wrkMast.setWrkSts(4L); }else { wrkMast.setWrkSts(14L); } if (!wrkMastService.updateById(wrkMast)){ return R.error(); } }catch (Exception e) { throw new CoolException(e); } return R.ok(); } @PostMapping("/locDetl/select/time/v1") public synchronized R locDetlSelect(@RequestHeader(required = false) String appkey, @RequestBody(required = false) TimeSelectParam param, HttpServletRequest request) { auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } List locDetlByTimeDTOS = openService.selectTimeLocDetl(param); return R.ok(locDetlByTimeDTOS); } @PostMapping("/matSync/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("/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/new/package/v1") // @AppAuth(memo = "打包上线接口") // public synchronized R pakinOrderPackage(@RequestHeader(required = false) String appkey, // @RequestBody(required = false) PackParam param, // HttpServletRequest request) { // auth(appkey, param, request); // if (Cools.isEmpty(param)) { // return R.parse(BaseRes.PARAM); // } // openService.packageUp(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.getOrderDetails())) { return R.error("单据明细[orderDetails]不能为空"); } openService.pakinOrderCreate(param); return R.ok(); } /** * 入库单回写 */ @PostMapping("/order/pakin/complete/default/v1") public synchronized R orderPakinComplete(@RequestHeader(required = false) String appkey, @RequestBody(required = false) OpenOrderCompleteParam param, HttpServletRequest request) { auth(appkey, param, request); return R.ok().add(openService.pakinOrderComplete(param)); } /** * 添加出库单 */ @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.getOrderDetails())) { return R.error("单据明细[orderDetails]不能为空"); } openService.pakoutOrderCreate(param); return R.ok(); } /** * 出库单回写 */ @PostMapping("/order/pakout/complete/default/v1") public synchronized R orderPakoutComplete(@RequestHeader(required = false) String appkey, @RequestBody(required = false) OpenOrderCompleteParam param, HttpServletRequest request) { auth(appkey, param, request); return R.ok().add(openService.pakoutOrderComplete(param)); } /** * 库存统计 */ @RequestMapping("/stock/default/v1") public R queryStock(@RequestHeader(required = false) String appkey, HttpServletRequest request) { auth(appkey, null, request); return R.ok().add(openService.queryStock()); } 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无误！"); } } /** * 库存统计 */ @RequestMapping("/agv/haikang/complete/v1") public R agvHaiKang(@RequestHeader(required = false) String wrkNo, HttpServletRequest request) { // auth(wrkNo, null, request); return R.ok().add(openService.agvHaiKang(wrkNo)); } }