|  |  |  | 
|---|
|  |  |  | 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.param.OpenOrderCompleteParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.OpenOrderPakinParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.OpenOrderPakoutParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.PackParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.LocOwner; | 
|---|
|  |  |  | import com.zy.asrs.entity.Order; | 
|---|
|  |  |  | import com.zy.asrs.entity.OrderDetl; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.*; | 
|---|
|  |  |  | import com.zy.asrs.entity.result.StockVo; | 
|---|
|  |  |  | import com.zy.asrs.service.LocOwnerService; | 
|---|
|  |  |  | import com.zy.asrs.service.OpenService; | 
|---|
|  |  |  | import com.zy.asrs.service.OrderDetlService; | 
|---|
|  |  |  | import com.zy.asrs.service.OrderService; | 
|---|
|  |  |  | import com.zy.common.model.DetlDto; | 
|---|
|  |  |  | import com.zy.common.web.BaseController; | 
|---|
|  |  |  | import com.zy.system.entity.User; | 
|---|
|  |  |  | import com.zy.system.service.UserService; | 
|---|
|  |  |  | 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.security.acl.Owner; | 
|---|
|  |  |  | import java.util.ArrayList; | 
|---|
|  |  |  | import java.util.Date; | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  | import java.util.Map; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * Created by vincent on 2022/4/8 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private OpenService openService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private OrderService orderService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private OrderDetlService orderDetlService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private LocOwnerService locOwnerService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private UserService userService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /****************************************************************************/ | 
|---|
|  |  |  | /********************************* 打包上线 **********************************/ | 
|---|
|  |  |  | /****************************************************************************/ | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @PostMapping("/order/pakin/new/package/v1") | 
|---|
|  |  |  | @AppAuth(memo = "打包上线接口") | 
|---|
|  |  |  | public synchronized R pakinOrderPackage(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody(required = false) PackParam param) { | 
|---|
|  |  |  | auth(appkey, param); | 
|---|
|  |  |  | @PostMapping("/order/getInformation/notFinished") | 
|---|
|  |  |  | @AppAuth(memo = "订单未完成信息查询") | 
|---|
|  |  |  | public synchronized R orderInformationSelect(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody(required = false) Map<String,String> param, | 
|---|
|  |  |  | HttpServletRequest request) | 
|---|
|  |  |  | { | 
|---|
|  |  |  | auth(appkey, param, request); | 
|---|
|  |  |  | String name = param.get("name"); | 
|---|
|  |  |  | if (Cools.isEmpty(param)) { | 
|---|
|  |  |  | return R.parse(BaseRes.PARAM); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | openService.packageUp(param); | 
|---|
|  |  |  | User user = userService.selectOne(new EntityWrapper<User>().eq("username", name)); | 
|---|
|  |  |  | if (Cools.isEmpty(user)){ | 
|---|
|  |  |  | return R.error("未找到用户"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | List<Order> stringList = openService.selectOrderInformation(param); | 
|---|
|  |  |  | return R.ok(stringList); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @PostMapping("/order/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("/order/ownerSync/default/v1") | 
|---|
|  |  |  | @AppAuth(memo = "供应商档案同步接口") | 
|---|
|  |  |  | public synchronized R syncOwnerInfo(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody(required = false) Map<String,String> param, | 
|---|
|  |  |  | HttpServletRequest request){ | 
|---|
|  |  |  | auth(appkey, param, request); | 
|---|
|  |  |  | if (Cools.isEmpty(param)) { | 
|---|
|  |  |  | return R.parse(BaseRes.PARAM); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Integer deleteFlag = Integer.parseInt(param.get("deleteFlag")); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (deleteFlag == 1){ | 
|---|
|  |  |  | locOwnerService.delete(new EntityWrapper<LocOwner>().eq("owner",param.get("owner"))); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | LocOwner locOwner = new LocOwner(); | 
|---|
|  |  |  | locOwner.setOwner(param.get("owner")); | 
|---|
|  |  |  | locOwner.setPhone(param.get("phone")); | 
|---|
|  |  |  | locOwner.setAddr(param.get("addr")); | 
|---|
|  |  |  | locOwnerService.insert(locOwner); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加入库单 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @PostMapping("/order/pakin/new/default/v1") | 
|---|
|  |  |  | @PostMapping("/order/pakin/default/v1") | 
|---|
|  |  |  | @AppAuth(memo = "添加订单入库") | 
|---|
|  |  |  | public synchronized R pakinOrderCreate(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody OpenOrderPakinParam param) { | 
|---|
|  |  |  | auth(appkey, param); | 
|---|
|  |  |  | @RequestBody OpenOrderPakinParam param, | 
|---|
|  |  |  | HttpServletRequest request) { | 
|---|
|  |  |  | auth(appkey, param, request); | 
|---|
|  |  |  | if (Cools.isEmpty(param)) { | 
|---|
|  |  |  | return R.parse(BaseRes.PARAM); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 入库单回写 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @PostMapping("/order/pakin/complete/default/v1") | 
|---|
|  |  |  | public synchronized R orderPakinComplete(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody(required = false) OpenOrderCompleteParam param) { | 
|---|
|  |  |  | auth(appkey, param); | 
|---|
|  |  |  | return R.ok().add(openService.pakinOrderComplete(param)); | 
|---|
|  |  |  | /* | 
|---|
|  |  |  | * 速腾数字孪生调用接口 | 
|---|
|  |  |  | * */ | 
|---|
|  |  |  | @PostMapping("/digital/twin/inventory/quantity") | 
|---|
|  |  |  | public synchronized R inventoryQuantity(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | HttpServletRequest request) { | 
|---|
|  |  |  | auth(appkey, null, request); | 
|---|
|  |  |  | return R.ok(openService.inventoryQuantity()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加出库单 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @PostMapping("/order/pakout/new/default/v1") | 
|---|
|  |  |  | @PostMapping("/order/pakout/default/v1") | 
|---|
|  |  |  | @AppAuth(memo = "添加订单出库") | 
|---|
|  |  |  | public synchronized R pakoutOrderCreate(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody OpenOrderPakoutParam param) { | 
|---|
|  |  |  | auth(appkey, param); | 
|---|
|  |  |  | @RequestBody OpenOrderPakoutParam param, | 
|---|
|  |  |  | HttpServletRequest request) { | 
|---|
|  |  |  | auth(appkey, param, request); | 
|---|
|  |  |  | if (Cools.isEmpty(param)) { | 
|---|
|  |  |  | return R.parse(BaseRes.PARAM); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (Cools.isEmpty(param.getOrderNo())) { | 
|---|
|  |  |  | if (Cools.isEmpty(param.getCCode())) { | 
|---|
|  |  |  | return R.error("单据编号[orderNo]不能为空"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (Cools.isEmpty(param.getOrderType())) { | 
|---|
|  |  |  | if (Cools.isEmpty(param.getType())) { | 
|---|
|  |  |  | return R.error("单据类型[orderType]不能为空"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (Cools.isEmpty(param.getOrderDetails())) { | 
|---|
|  |  |  | if (Cools.isEmpty(param.getADDBody())) { | 
|---|
|  |  |  | return R.error("单据明细[orderDetails]不能为空"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | openService.pakoutOrderCreate(param); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 出库单回写 | 
|---|
|  |  |  | * 订单删除接口 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @PostMapping("/order/pakout/complete/default/v1") | 
|---|
|  |  |  | public synchronized R orderPakoutComplete(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody(required = false) OpenOrderCompleteParam param) { | 
|---|
|  |  |  | auth(appkey, param); | 
|---|
|  |  |  | return R.ok().add(openService.pakoutOrderComplete(param)); | 
|---|
|  |  |  | @PostMapping("/order/delete/default/v1") | 
|---|
|  |  |  | @AppAuth(memo = "单据删除") | 
|---|
|  |  |  | public synchronized R deleteOrder(@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.getCCode())) { | 
|---|
|  |  |  | return R.error("单据编号[orderNo]不能为空"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String orderNo = param.getCCode(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Order order = orderService.selectByNo(orderNo); | 
|---|
|  |  |  | if(Cools.isEmpty(order)){ | 
|---|
|  |  |  | return R.error("单据不存在"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (order.getSettle()>1){ | 
|---|
|  |  |  | return R.error("单据正在作业,无法删除该单据。"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | orderService.delete(new EntityWrapper<Order>().eq("id", order.getId())); | 
|---|
|  |  |  | orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_id", order.getId())); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return R.ok("单据删除成功"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 库存统计 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @RequestMapping("/stock/default/v1") | 
|---|
|  |  |  | public R queryStock(@RequestHeader(required = false) String appkey) { | 
|---|
|  |  |  | auth(appkey, null); | 
|---|
|  |  |  | return R.ok().add(openService.queryStock()); | 
|---|
|  |  |  | public R queryStock(@RequestHeader(required = false) String appkey, | 
|---|
|  |  |  | @RequestBody StockVo stockVo, | 
|---|
|  |  |  | HttpServletRequest request) { | 
|---|
|  |  |  | auth(appkey, stockVo, request); | 
|---|
|  |  |  | return R.ok().add(openService.queryStock(stockVo)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private void auth(String appkey, Object obj) { | 
|---|
|  |  |  | private void auth(String appkey, Object obj, HttpServletRequest request) { | 
|---|
|  |  |  | log.info("{}接口被访问;appkey:{};请求数据:{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj)); | 
|---|
|  |  |  | request.setAttribute("cache", obj); | 
|---|
|  |  |  | if (!auth) { | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if (!APP_KEY_LIST.contains(appkey)) { | 
|---|
|  |  |  | throw new CoolException("认证失败,请确认appkey无误!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /*******************************************************    数字孪生    *******************************************************/ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @PostMapping("/wrkdetl") | 
|---|
|  |  |  | public R getInOutDetl(){ | 
|---|
|  |  |  | return openService.getInOutDetl(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public static void main(String[] args) { | 
|---|
|  |  |  | 
|---|
|  |  |  | System.out.println(JSON.toJSONString(param1)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|