对接接口开发

dubin

1 天以前 2a9f6d72baa207bc91c98d0a5cd2235be9816691

 src/main/java/com/zy/asrs/controller/OpenController.java

@@ -9,6 +9,9 @@
import com.core.exception.CoolException;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.param.*;
import com.zy.asrs.entity.result.OpenInventoryVo;
import com.zy.asrs.entity.result.OpenSummaryVo;
import com.zy.asrs.entity.result.TokenVo;
import com.zy.asrs.service.LocDetlService;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.OpenService;
@@ -234,7 +237,7 @@
        int i1 = locMastService.selectCount(new EntityWrapper<LocMast>().in("loc_sts", Arrays.asList("D", "F", "P", "Q", "R", "S")));
        BigDecimal dividend = new BigDecimal(i1 - i);
        BigDecimal divisor = new BigDecimal(i1);
        BigDecimal quotient = dividend.divide(divisor,4);
        BigDecimal quotient = dividend.divide(divisor,4, BigDecimal.ROUND_HALF_UP);
        return R.ok().add(quotient);
    }

@@ -292,4 +295,118 @@
//        System.out.println(JSON.toJSONString(param1));
//    }

    /*========================================new Agreement==============================================================*/

    /**
     * 获取token
     * @param param
     * @param request
     * @return
     */
    @PostMapping("/getToken")
    public synchronized R getToken(@RequestBody(required = true) TokenParam param,
                                   HttpServletRequest request){
        authNew(param, param, request);
        if (Cools.isEmpty(param)) {
            return R.parse(BaseRes.PARAM);
        }
        TokenVo tokenVo = new TokenVo();
        String token = Cools.enToken(System.currentTimeMillis() + param.getAppId(), param.getAppSecret());
        tokenVo.setToken(token);
        tokenVo.setValidTime(30);
        return R.ok().add(tokenVo);
    }

    private void authNew(TokenParam param, Object obj, HttpServletRequest request) {
        log.info("{}接口被访问；appSecret:{}；请求数据：{}", "open/sensorType/list/auth/v1", param.getAppSecret(), JSON.toJSONString(obj));
        request.setAttribute("cache", obj);
        if (!auth) {
            return;
        }
        if (Cools.isEmpty(param.getAppId()) || Cools.isEmpty(param.getAppSecret())) {
            throw new CoolException("认证失败，请确认appId和appSecret无误！");
        }
        if (!param.getAppId().contains("HLWMS")){
            throw new CoolException("认证失败，请确认appId无误！");
        }
        if (!APP_KEY_LIST.contains(param.getAppSecret())) {
            throw new CoolException("认证失败，请确认appSecret无误！");
        }
    }

    /**
     * 物料基础信息同步
     * @param appkey
     * @param param
     * @param request
     * @return
     */
    @PostMapping("/erp/mat/sync")
    public synchronized R syncMatInfoV2(@RequestHeader(required = false) String appkey,
                                        @RequestBody(required = false) List<MatSyncParam.MatParam> param,
                                        HttpServletRequest request){
        if (Cools.isEmpty(param)){
            return R.parse(BaseRes.PARAM);
        }
        MatSyncParam matSyncParam = new MatSyncParam();
        List<MatSyncParam.MatParam> objects = new ArrayList<>();
        objects = param;
        matSyncParam.matDetails = objects;
        openService.syncMat(matSyncParam);
        return R.ok();
    }

    /**
     * 入/出库通知单下发
     * @param param
     * @return
     */
    @PostMapping("/erp/order/add")
    public synchronized R addOrder(@RequestBody OpenOrderParam param){
        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.getWkType())){
            return R.error("业务类型[wkType]不能为空");
        }
        if (Cools.isEmpty(param.getOrderItems())){
            return R.error("订单明细[orderItems]不能为空");
        }
        openService.orderCreate(param);
        return R.ok();
    }

    /**
     * 库存明细查询
     * @param param
     * @return
     */
    @PostMapping("/erp/inventory/details")
    public synchronized R queryInventoryDetails(@RequestBody OpenInventoryParam param){
        if (Cools.isEmpty(param)){
            return R.parse(BaseRes.PARAM);
        }
        OpenInventoryVo openInventoryVo = openService.queryInventoryDetails(param);
        return R.ok(openInventoryVo);
    }

    /**
     * 库存汇总查询
     * @param param
     * @return
     */
    @PostMapping("/erp/inventory/summary")
    public synchronized R queryInventorySummary(@RequestBody OpenSummaryParam param){
        if (Cools.isEmpty(param)){
            return R.parse(BaseRes.PARAM);
        }
        OpenSummaryVo openSummaryVo = openService.queryInventorySummary(param);
        return R.ok(openSummaryVo);
    }
}