增加一些日志,调整获取第三方单据,第三方库存产品信息

fengcang
anthonyywj2 3 years ago
parent f332a826bf
commit 36dd7ba530

@ -1,7 +1,10 @@
package com.glxp.api.admin.controller.inventory; package com.glxp.api.admin.controller.inventory;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.entity.basic.BasicThirdSysDetailEntity; import com.glxp.api.admin.entity.basic.BasicThirdSysDetailEntity;
import com.glxp.api.admin.entity.basic.BasicThirdSysEntity;
import com.glxp.api.admin.entity.basic.UdiEntity; import com.glxp.api.admin.entity.basic.UdiEntity;
import com.glxp.api.admin.entity.thrsys.ThrInvProductsEntity; import com.glxp.api.admin.entity.thrsys.ThrInvProductsEntity;
import com.glxp.api.admin.httpclient.ErpInvClient; import com.glxp.api.admin.httpclient.ErpInvClient;
@ -9,15 +12,19 @@ import com.glxp.api.admin.req.basic.FilterUdiInfoRequest;
import com.glxp.api.admin.req.inventory.ErpOnhandRequest; import com.glxp.api.admin.req.inventory.ErpOnhandRequest;
import com.glxp.api.admin.req.thrsys.FilterThrInvProductsRequest; import com.glxp.api.admin.req.thrsys.FilterThrInvProductsRequest;
import com.glxp.api.admin.res.PageSimpleResponse; import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.basic.ErpProductsResponse;
import com.glxp.api.admin.res.basic.UdiRelevanceResponse; import com.glxp.api.admin.res.basic.UdiRelevanceResponse;
import com.glxp.api.admin.res.inventory.ErpInvProductResponse; import com.glxp.api.admin.res.inventory.ErpInvProductResponse;
import com.glxp.api.admin.service.basic.BasicThirdSysDetailService; import com.glxp.api.admin.service.basic.BasicThirdSysDetailService;
import com.glxp.api.admin.service.basic.BasicThirdSysService;
import com.glxp.api.admin.service.basic.UdiRelevanceService; import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.thrsys.ThrInvProductsService; import com.glxp.api.admin.service.thrsys.ThrInvProductsService;
import com.glxp.api.admin.util.FilterUdiUtils; import com.glxp.api.admin.util.FilterUdiUtils;
import com.glxp.api.admin.util.HttpOkClient;
import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils; import com.glxp.api.common.util.ResultVOUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.validation.BindingResult; import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
@ -27,6 +34,7 @@ import javax.annotation.Resource;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Slf4j
@RestController @RestController
public class InvErpOnhandController { public class InvErpOnhandController {
@ -38,6 +46,11 @@ public class InvErpOnhandController {
private ThrInvProductsService thrInvProductsService; private ThrInvProductsService thrInvProductsService;
@Resource @Resource
ErpInvClient erpInvClient; ErpInvClient erpInvClient;
@Resource
private BasicThirdSysService basicThirdSysService;
@Resource
HttpOkClient httpOkClient;
@GetMapping("/udiwms/inv/getOnHand") @GetMapping("/udiwms/inv/getOnHand")
public BaseResponse getOnhand(ErpOnhandRequest onhandQueryRequest, public BaseResponse getOnhand(ErpOnhandRequest onhandQueryRequest,
@ -102,6 +115,24 @@ public class InvErpOnhandController {
} }
@GetMapping("/udiwms/inv/getInvProducts")
public BaseResponse getInvProducts(ErpOnhandRequest udiwmsOnhandRequest) {
BasicThirdSysEntity basicThirdSysEntity = basicThirdSysService.selectByThirdId(udiwmsOnhandRequest.getThirdSys());
String url = basicThirdSysEntity.getThridUrl() + "/udiwms/erp/inv/getEnvProduct";
try {
String response = httpOkClient.uCloudPost(url, udiwmsOnhandRequest, basicThirdSysEntity);
BaseResponse<PageSimpleResponse<ErpInvProductResponse>> udiDlDeviceResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpInvProductResponse>>>() {
});
return udiDlDeviceResponse;
} catch (Exception e) {
log.error("获取库存产品信息异常", e);
return ResultVOUtils.error(500, "连接第三方系统接口服务出错!");
}
}
public UdiRelevanceResponse findByNamecode(String udi) { public UdiRelevanceResponse findByNamecode(String udi) {
FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest(); FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest();
filterUdiInfoRequest.setNameCode(udi); filterUdiInfoRequest.setNameCode(udi);

@ -177,7 +177,7 @@ public class DownloadThirdSysDataTask implements SchedulingConfigurer {
break; break;
} }
} else { } else {
log.error("第三方系统单据类型数据下载失败"); log.error("第三方系统单据类型数据下载失败(错误信息:" + busResponse.getMessage());
break; break;
} }
log.info("第三方系统往来产品信息数据下载完成"); log.info("第三方系统往来产品信息数据下载完成");

Loading…
Cancel
Save