|  |  | 
 |  |  | package com.zy.asrs.controller; | 
 |  |  |  | 
 |  |  | import com.alibaba.fastjson.JSON; | 
 |  |  | 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.service.ApiLogService; | 
 |  |  | import com.zy.asrs.entity.param.PackParam; | 
 |  |  | import com.zy.asrs.service.OpenService; | 
 |  |  | import com.zy.common.model.DetlDto; | 
 |  |  | import com.zy.common.utils.IpTools; | 
 |  |  | import com.zy.common.web.BaseController; | 
 |  |  | import lombok.extern.slf4j.Slf4j; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private OpenService openService; | 
 |  |  |     @Autowired | 
 |  |  |     private ApiLogService apiLogService; | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     @PostMapping("/order/pakin/new/package/v1") | 
 |  |  |     @AppAuth(memo = "打包上线接口") | 
 |  |  |     public synchronized R pakinOrderPackage(@RequestHeader(required = false) String appkey, | 
 |  |  |                                             @RequestParam(required = false) String barcode, | 
 |  |  |                                             @RequestBody(required = false) PackParam param, | 
 |  |  |                                             HttpServletRequest request) { | 
 |  |  |         auth(appkey, barcode); | 
 |  |  |         if (Cools.isEmpty(barcode)) { | 
 |  |  |         auth(appkey, param, request); | 
 |  |  |         if (Cools.isEmpty(param)) { | 
 |  |  |             return R.parse(BaseRes.PARAM); | 
 |  |  |         } | 
 |  |  |         openService.packageUp(barcode); | 
 |  |  |         // 保存接口日志 | 
 |  |  |         apiLogService.save( | 
 |  |  |                 "打包上线接口", | 
 |  |  |                 request.getRequestURI(), | 
 |  |  |                 appkey, | 
 |  |  |                 IpTools.gainRealIp(request), | 
 |  |  |                 barcode, | 
 |  |  |                 JSON.toJSONString(R.ok()), | 
 |  |  |                 Boolean.TRUE | 
 |  |  |         ); | 
 |  |  |         openService.packageUp(param); | 
 |  |  |         return R.ok(); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @PostMapping("/order/pakin/new/default/v1") | 
 |  |  |     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); | 
 |  |  |         } | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @PostMapping("/order/pakin/complete/default/v1") | 
 |  |  |     public synchronized R orderPakinComplete(@RequestHeader(required = false) String appkey, | 
 |  |  |                                         @RequestBody(required = false) OpenOrderCompleteParam param) { | 
 |  |  |         auth(appkey, param); | 
 |  |  |                                              @RequestBody(required = false) OpenOrderCompleteParam param, | 
 |  |  |                                              HttpServletRequest request) { | 
 |  |  |         auth(appkey, param, request); | 
 |  |  |         return R.ok().add(openService.pakinOrderComplete(param)); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |      * 添加出库单 | 
 |  |  |      */ | 
 |  |  |     @PostMapping("/order/pakout/new/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.getLgort())) { | 
 |  |  |             return R.error("单据编号[lgort]不能为空"); | 
 |  |  |         } | 
 |  |  |         if (!param.getLgort().equals("5006")) { | 
 |  |  |             return R.ok(); | 
 |  |  |         } | 
 |  |  |         if (Cools.isEmpty(param.getOrderNo())) { | 
 |  |  |             return R.error("单据编号[orderNo]不能为空"); | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @PostMapping("/order/pakout/complete/default/v1") | 
 |  |  |     public synchronized R orderPakoutComplete(@RequestHeader(required = false) String appkey, | 
 |  |  |                                         @RequestBody(required = false) OpenOrderCompleteParam param) { | 
 |  |  |         auth(appkey, param); | 
 |  |  |                                               @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) { | 
 |  |  |         auth(appkey, null); | 
 |  |  |     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) { | 
 |  |  |         log.info("{}接口被访问!appkey:{},请求数据:{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(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; | 
 |  |  |         } |