package com.zy.asrs.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; 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.param.*; import com.zy.asrs.service.OpenService; 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.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; /** * 库存统计 */ @RequestMapping("/stock/default/v1") public R queryStock(@RequestHeader(required = false) String appkey, HttpServletRequest request) { auth(appkey, null, request); return R.ok().add(openService.queryStock()); } /** * 商品信息同步接口 */ @PostMapping("/mat/v1") @AppAuth(memo = "物料同步接口") public synchronized R syncMatInfoErp(@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("更新成功"); } 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 (Cools.isEmpty(appkey)) { throw new CoolException("认证失败，请确认appkey无误！"); } if (!APP_KEY_LIST.contains(appkey)) { throw new CoolException("认证失败，请确认appkey无误！"); } } @PostMapping("/order/pak/default/v1") @AppAuth(memo = "生成退货补货单据") public synchronized R orderAccept(@RequestHeader(required = false) String appkey, @RequestBody(required = true) OrderSyncParam param, HttpServletRequest request){ auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } String docName = param.get操作单据(); boolean pakin = param.getPakin() == 1 ? true : false; openService.syncOrder(param,pakin,docName); return R.ok("单据接受成功"); } @PostMapping("/order/pakin/default/v1") @AppAuth(memo = "生成入库单据") public synchronized R orderPakin(@RequestHeader(required = false) String appkey, @RequestBody(required = true) OrderSyncParam param, HttpServletRequest request){ auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } String docName = !Cools.isEmpty(param.getOrderType()) ? param.getOrderType() : param.getChildren().get(0).getIQuantity() > 0 ? "银座采购入库单" : "银座采购退货单"; boolean pakin = param.getChildren().get(0).getIQuantity() > 0 ? true : false; openService.syncOrder(param,pakin,docName); return R.ok("单据接受成功"); } /* 盘点接口 */ @PostMapping("/check/default/v1") @AppAuth(memo = "库存盘点") public synchronized R checkLoc(@RequestHeader(required = false) String appkey, @RequestBody(required = true) CheckParam param, HttpServletRequest request){ auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } openService.checkAndAdjustLocDetl(param); return R.ok("库存调整成功"); } @PostMapping("/order/pakout/default/v1") @AppAuth(memo = "同步工单单据") public synchronized R orderPakout(@RequestHeader(required = false) String appkey, //@RequestBody(required = false) HashMap param, @RequestBody(required = false) OrderProdSyncParam param, HttpServletRequest request){ auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } if(!Cools.eq("生产",param.getCVouchtype())){ String docName = param.getIQuantity() > 0 ? "银座委外入库单" : "银座委外入库退货单"; boolean pakin = param.getIQuantity() > 0 ? true : false; mappingPakInOrderParam(param,pakin,docName); if(!Cools.isEmpty(param.getChildren())){ String docName1 = param.getChildren().get(0).getIQuantity() > 0 ? "银座委外材料出库单" : "银座委外材料退料单"; boolean pakin1 = param.getChildren().get(0).getIQuantity() > 0 ? true : false; mappingPakOutOrderParam(param,pakin1,docName1); } }else if(!Cools.isEmpty(param.getChildren())) { String docName1 = param.getChildren().get(0).getIQuantity() > 0 ? "银座生产材料出库单" : "银座生产材料退料单"; boolean pakin1 = param.getChildren().get(0).getIQuantity() > 0 ? true : false; mappingPakOutOrderParam(param,pakin1,docName1); } return R.ok("单据接受成功"); } @PostMapping("/order/delete/default/v1") @AppAuth(memo = "单据删除审核") public synchronized R orderDelete(@RequestHeader(required = false) String appkey, @RequestBody(required = false) Map param, HttpServletRequest request){ auth(appkey, param, request); if (Cools.isEmpty(param)) { return R.parse(BaseRes.PARAM); } boolean success = openService.orderDelete(param.get("id").toString()); if(success){ return R.ok("单据删除成功"); }else { return R.error("单据正在执行，删除失败"); } } private void mappingPakInOrderParam(OrderProdSyncParam param,boolean pakin,String docName){ //生成单据主体 OrderSyncParam orderSyncParam = new OrderSyncParam(); orderSyncParam.set操作系统号(param.get操作系统号()); orderSyncParam.setcPOID(param.getOrderNoT()); orderSyncParam.setDdate(param.getOrderTime()); orderSyncParam.setcMemo(param.getCMemo()); //生成单据明细 OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); orderDetl.setcInvCode(param.getCInvCode()); orderDetl.setiQuantity(param.getIQuantity()); orderDetl.setcDefine22(param.getDefine24()); orderDetl.setbFree1(param.getBFree1()); orderDetl.setId(param.getId()); orderDetl.setIvouchrowno(param.getIvouchrowno()); //添加单据明细到单据主体 List orderDetls = new ArrayList<>(); orderDetls.add(orderDetl); orderSyncParam.setChildren(orderDetls); // String docName = param.getIQuantity() > 0 ? "银座产品生产入库单" : "入库退回单"; // boolean pakin = param.getIQuantity() > 0 ? true : false; openService.syncOrder(orderSyncParam,pakin,docName); //return orderSyncParam; } private void mappingPakOutOrderParam(OrderProdSyncParam param,boolean pakin,String docName){ OrderSyncParam orderSyncParam = new OrderSyncParam(); List child = param.getChildren(); //生成单据主体 orderSyncParam.set操作系统号(param.get操作系统号()); orderSyncParam.setcPOID(child.get(0).getOrderNoT()); orderSyncParam.setDdate(param.getOrderTime()); orderSyncParam.setcMemo(""); //生成单据明细 List orderDetls = new ArrayList<>(); for(OrderProdSyncParam.ChildInfo childInfo : child){ OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl(); orderDetl.setcInvCode(childInfo.getCInvCode()); orderDetl.setiQuantity(childInfo.getIQuantity()); orderDetl.setCsocode(param.getCsocode()); orderDetl.setbFree1(childInfo.getBFree1()); orderDetl.setId(childInfo.getIds()); orderDetl.setIvouchrowno(childInfo.getIvouchrowno()); orderDetls.add(orderDetl); } orderSyncParam.setChildren(orderDetls); openService.syncOrder(orderSyncParam,false,docName); //return orderSyncParam; } }