diff --git a/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java b/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java index 2508889..0094e6a 100644 --- a/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java +++ b/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java @@ -47,6 +47,8 @@ public class ABClient { private ABDownTask abDownTask; + // ==================================== AB单推送 ================================== + /** * 获取上游公司的AB数据推送接口 - 推动到一早 * @@ -79,7 +81,24 @@ public class ABClient { // 调用业务处理接口 返回校验成功的结果 return abClientService.recordAndSendABClientMsgShiJi(dtos) ? CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); -} + } + + /** + * 获取上游公司的AB数据推送接口 - 推送到罗氏 + * + * @return 返回调用信息 + */ + @PostMapping("/api/req/taginfo/luoshi") + @ResponseBody + public CommonResponse getDBTagInfoLuoshi(@RequestBody ABClientInterMessageVO vo) { + // 记录日志 + log.info("====== [ Luoshi request comming, request content is {} ] ======", vo.toString()); + // 转换实体类映射 + List dtos = ABMessageConverter.convertABMessageDTOFromVO(vo); + // 调用业务处理接口 返回校验成功的结果 + return abClientService.recordAndSendABClientMsgLuoshi(dtos) ? + CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); + } /** diff --git a/src/main/java/com/yuyou/openapi/openapi/dao/LuoshiMessageRepository.java b/src/main/java/com/yuyou/openapi/openapi/dao/LuoshiMessageRepository.java new file mode 100644 index 0000000..5caab4d --- /dev/null +++ b/src/main/java/com/yuyou/openapi/openapi/dao/LuoshiMessageRepository.java @@ -0,0 +1,25 @@ +package com.yuyou.openapi.openapi.dao; + +import com.yuyou.openapi.openapi.model.dataobject.LuoshiMessageDO; +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.Modifying; +import org.springframework.data.jpa.repository.Query; +import org.springframework.stereotype.Repository; + +/** + * Copyright (C), 2012 - 2018, qyx + * FileName: LuoshiMessageRepository + * Author: 钱昱欣 + * Date: 2020/10/22 2:52 PM + * Description: TODO + * History: + *