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 2e8a6b5..93e133e 100644 --- a/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java +++ b/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java @@ -118,6 +118,22 @@ public class ABClient { CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); } + /** + * 获取上游公司的AB数据推送接口 - 推送到潘达 + * + * @return 返回调用信息 + */ + @PostMapping("/api/req/taginfo/hxx") + @ResponseBody + public CommonResponse getDBTagInfoHeXiaoXiang(@RequestBody ABClientInterMessageVO vo) { + // 记录日志 + log.info("====== [ HeXiaoXiang request comming, request content is {} ] ======", vo.toString()); + // 转换实体类映射 + List dtos = ABMessageConverter.convertABMessageDTOFromVO(vo); + // 调用业务处理接口 返回校验成功的结果 + return abClientService.recordAndSendABClientMsgHeXiaoXiang(dtos) ? + CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试"); + } /** * 获取上游公司的AB数据推送接口 - 推送到微信加粉 diff --git a/src/main/java/com/yuyou/openapi/openapi/dao/HeXiaoXiangMessageRepository.java b/src/main/java/com/yuyou/openapi/openapi/dao/HeXiaoXiangMessageRepository.java new file mode 100644 index 0000000..bdc62c6 --- /dev/null +++ b/src/main/java/com/yuyou/openapi/openapi/dao/HeXiaoXiangMessageRepository.java @@ -0,0 +1,25 @@ +package com.yuyou.openapi.openapi.dao; + +import com.yuyou.openapi.openapi.model.dataobject.HeXiaoXiangMessageDO; +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: HeXiaoXiangMessageRepository + * Author: 钱昱欣 + * Date: 2020/10/22 2:52 PM + * Description: TODO + * History: + *