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 cab5ce0..a5c21a4 100644 --- a/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java +++ b/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java @@ -100,6 +100,24 @@ public class ABClient { CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); } + /** + * 获取上游公司的AB数据推送接口 - 推送到双英 + * + * @return 返回调用信息 + */ + @PostMapping("/api/req/taginfo/shuangying") + @ResponseBody + public CommonResponse getDBTagInfoShuangYing(@RequestBody ABClientInterMessageVO vo) { + // 记录日志 + log.info("====== [ Shuangying request comming, request content is {} ] ======", vo.toString()); + // 转换实体类映射 + List dtos = ABMessageConverter.convertABMessageDTOFromVO(vo); + // 调用业务处理接口 返回校验成功的结果 + return abClientService.recordAndSendABClientMsgShuangYing(dtos) ? + CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); + } + + /** * 获取上游公司的AB数据推送接口 - 推送到潘达 @@ -199,8 +217,6 @@ public class ABClient { CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); } - - /** * AB单补推接口 * diff --git a/src/main/java/com/yuyou/openapi/openapi/dao/ShuangYingMessageRepository.java b/src/main/java/com/yuyou/openapi/openapi/dao/ShuangYingMessageRepository.java new file mode 100644 index 0000000..9ec44c5 --- /dev/null +++ b/src/main/java/com/yuyou/openapi/openapi/dao/ShuangYingMessageRepository.java @@ -0,0 +1,25 @@ +package com.yuyou.openapi.openapi.dao; + +import com.yuyou.openapi.openapi.model.dataobject.ShuangYingMessageDO; +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: + *