From 373c47b31a4228c9eb9dccd5893136e8518cdc31 Mon Sep 17 00:00:00 2001
From: qyx <565485304@qq.com>
Date: Tue, 3 Nov 2020 18:30:17 +0800
Subject: [PATCH 1/4] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/resources/application.yml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 6edffb2..d53b2f7 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -15,7 +15,7 @@ server:
   port: 8090
 # 环境
 spring:
-  profiles: dev
+  profiles: prod
   # 数据库相关配置
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver

From b20182354e798988a9332ee2581d5a1822f760f8 Mon Sep 17 00:00:00 2001
From: qyx <565485304@qq.com>
Date: Sat, 7 Nov 2020 15:01:21 +0800
Subject: [PATCH 2/4] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=B2=B3=E5=B0=8F?=
 =?UTF-8?q?=E8=B1=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yuyou/openapi/openapi/api/ABClient.java   |  16 +++
 .../dao/HeXiaoXiangMessageRepository.java     |  25 ++++
 .../model/convert/ABMessageConverter.java     |  52 +++++++
 .../dataobject/HeXiaoXiangMessageDO.java      |  86 +++++++++++
 .../openapi/model/dto/HeXXMessageCovDTO.java  |  81 +++++++++++
 .../openapi/service/ABClientService.java      |   4 +
 .../service/impl/ABClientServiceImpl.java     |  23 +++
 .../service/impl/ABClientServiceProxy.java    |   5 +
 .../openapi/openapi/task/ABDownTask.java      | 136 +++++++++++++++++-
 src/main/resources/application.yml            |  19 ++-
 src/main/resources/logback.xml                |   4 +-
 .../com/yuyou/openapi/openapi/HttpTest.java   |  19 +++
 12 files changed, 459 insertions(+), 11 deletions(-)
 create mode 100644 src/main/java/com/yuyou/openapi/openapi/dao/HeXiaoXiangMessageRepository.java
 create mode 100644 src/main/java/com/yuyou/openapi/openapi/model/dataobject/HeXiaoXiangMessageDO.java
 create mode 100644 src/main/java/com/yuyou/openapi/openapi/model/dto/HeXXMessageCovDTO.java
 create mode 100644 src/test/java/com/yuyou/openapi/openapi/HttpTest.java

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<ABMessageDTO> 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:
+ * <author>          <time>          <version>          <desc>
+ * 钱昱欣             2020/10/22          v1.0              创建此文件
+ */
+@Repository
+public interface HeXiaoXiangMessageRepository extends JpaRepository<HeXiaoXiangMessageDO, Long>{
+    @Modifying
+    @Query("update HeXiaoXiangMessageDO t set t.sendStatus = ?1 where t.recId = ?2")
+    void updateSendStatus(Integer sendStatus, Long recId);
+}
+
diff --git a/src/main/java/com/yuyou/openapi/openapi/model/convert/ABMessageConverter.java b/src/main/java/com/yuyou/openapi/openapi/model/convert/ABMessageConverter.java
index 9cf9fdd..d74070c 100644
--- a/src/main/java/com/yuyou/openapi/openapi/model/convert/ABMessageConverter.java
+++ b/src/main/java/com/yuyou/openapi/openapi/model/convert/ABMessageConverter.java
@@ -130,6 +130,25 @@ public class ABMessageConverter {
         return abMessageDOs;
     }
 
+    /**
+     * 批量转DTO为DO
+     * @param dtos
+     * @return
+     */
+    public static List<HeXiaoXiangMessageDO> convertHeXiaoXiangABMessageDOFromDTO(List<ABMessageDTO> dtos) {
+        if (CollectionUtils.isEmpty(dtos)) {
+            return null;
+        }
+        List<HeXiaoXiangMessageDO> abMessageDOs = new ArrayList<>();
+        dtos.forEach(each -> {
+            HeXiaoXiangMessageDO abMessageDO = convertHeXiaoXiangMessageDOFromDTO(each);
+            if (abMessageDO != null) {
+                abMessageDOs.add(abMessageDO);
+            }
+        });
+        return abMessageDOs;
+    }
+
 
     /**
      * 批量转DTO为DO
@@ -326,6 +345,39 @@ public class ABMessageConverter {
         return pandaMessageDO;
     }
 
+
+
+    /**
+     * Luoshi DTO层转为DO层
+     * @param abMessageDTO
+     * @return
+     */
+    public static HeXiaoXiangMessageDO convertHeXiaoXiangMessageDOFromDTO(ABMessageDTO abMessageDTO) {
+        HeXiaoXiangMessageDO heXiaoXiangMessageDO = new HeXiaoXiangMessageDO();
+        if (abMessageDTO == null) {
+            return heXiaoXiangMessageDO;
+        }
+
+        BeanUtils.copyProperties(abMessageDTO, heXiaoXiangMessageDO);
+        heXiaoXiangMessageDO.setPushTime(DateUtils.date(abMessageDTO.getTimestamp()));
+        heXiaoXiangMessageDO.setStartTime(DateUtils.date(abMessageDTO.getStartTime()));
+        try{
+            heXiaoXiangMessageDO.setRecId(Long.valueOf(abMessageDTO.getRecId()));
+        }catch (Exception e){
+            log.error("String convert Long type Error.", e);
+        }
+
+        // AES加密
+        try {
+            String encryptedMobile = SecurityService.encrypt(abMessageDTO.getMobile(), SecurityConstants.PHONE);
+            heXiaoXiangMessageDO.setPnum(encryptedMobile);
+        } catch (Exception e) {
+            log.error("Encrypt Mobile raise Error, recId = {}, error is :", abMessageDTO.getRecId(), e);
+            heXiaoXiangMessageDO.setPnum(abMessageDTO.getMobile());
+        }
+        return heXiaoXiangMessageDO;
+    }
+
     /**
      * Luoshi DTO层转为DO层
      * @param abMessageDTO
diff --git a/src/main/java/com/yuyou/openapi/openapi/model/dataobject/HeXiaoXiangMessageDO.java b/src/main/java/com/yuyou/openapi/openapi/model/dataobject/HeXiaoXiangMessageDO.java
new file mode 100644
index 0000000..6f1f961
--- /dev/null
+++ b/src/main/java/com/yuyou/openapi/openapi/model/dataobject/HeXiaoXiangMessageDO.java
@@ -0,0 +1,86 @@
+package com.yuyou.openapi.openapi.model.dataobject;
+
+import lombok.Data;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ * Copyright (C), 2012 - 2018, qyx
+ * FileName: HeXiaoXiangMessageDO
+ * Author:   钱昱欣
+ * Date:     2020/10/22 2:49 PM
+ * Description: TODO
+ * History:
+ * <author>          <time>          <version>          <desc>
+ * 钱昱欣             2020/10/22          v1.0              创建此文件
+ */
+@Data
+@Table(name = "hexiaoxiang_message")
+@Entity
+@EntityListeners(AuditingEntityListener.class)
+public class HeXiaoXiangMessageDO {
+
+    @Id
+    @GeneratedValue(strategy= GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "gmt_create")
+    @CreatedDate
+    private Date gmtCreate;
+
+    @Column(name = "gmt_modified")
+    @LastModifiedDate
+    private Date gmtModified;
+
+    /**
+     * 记录id
+     */
+    @Column(name = "rec_id")
+    private Long recId;
+
+    /**
+     * 业务码
+     */
+    @Column(name = "pnum")
+    private String pnum;
+
+    /**
+     * 业务名
+     */
+    @Column(name = "act_name")
+    private String actName;
+
+    /**
+     * 业务开始时间
+     */
+    @Column(name = "start_time")
+    private Date startTime;
+
+    /**
+     * 业务类别(1:A,2:B,3:C,4:D,5:E,6:F)
+     */
+    @Column(name = "client_type")
+    private Integer clientType;
+
+    /**
+     * 上游推送用户id
+     */
+    @Column(name = "app_id")
+    private String appId;
+
+    /**
+     * 上游推送时间
+     */
+    @Column(name = "push_time")
+    private Date pushTime;
+
+    /**
+     * 默认值为0 是否处理过请求 0 - 未处理 1 - 处理过
+     */
+    @Column(name = "send_status")
+    private Integer sendStatus = 0;
+}
diff --git a/src/main/java/com/yuyou/openapi/openapi/model/dto/HeXXMessageCovDTO.java b/src/main/java/com/yuyou/openapi/openapi/model/dto/HeXXMessageCovDTO.java
new file mode 100644
index 0000000..11fc015
--- /dev/null
+++ b/src/main/java/com/yuyou/openapi/openapi/model/dto/HeXXMessageCovDTO.java
@@ -0,0 +1,81 @@
+package com.yuyou.openapi.openapi.model.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * Copyright (C), 2012 - 2018, qyx
+ * FileName: LuoshiMessageCovDTO
+ * Author:   钱昱欣
+ * Date:     2020/10/22 2:55 PM
+ * Description: TODO
+ * History:
+ * <author>          <time>          <version>          <desc>
+ * 钱昱欣             2020/10/22          v1.0              创建此文件
+ */
+
+/**
+ * 罗氏科技的任务
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class HeXXMessageCovDTO {
+
+    /**
+     * 推送用户的ID
+     */
+//    @JSONField(serialize = false)
+    private String appId;
+
+    /**
+     * 请求时间戳
+     */
+//    @JSONField(serialize = false)
+    private Long timestamp;
+
+    /**
+     * 校验码: sha1(“app_id=AppId&nonce_str=time_stamp”)
+     */
+    private String signature;
+
+    /**
+     * 具体数据，每条为json格式
+     */
+    private List<HeXXData> data;
+
+
+    @Data
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class HeXXData{
+        /**
+         * poneNum 这个字段是用Base64进行加密
+         */
+        @JSONField(name = "info")
+        private String info;
+        /**
+         * 呼叫开始时间 时间戳
+         */
+        @JSONField(name = "time")
+        private Long time;
+
+        /**
+         * 业务名称 这个字段是用Base64进行加密
+         */
+        @JSONField(name = "subType")
+        @JsonIgnore
+        private String actName;
+
+        /**
+         * 用于下游声明的标识   AB单，A-1代表，B-2代表
+         */
+        @JSONField(name = "type")
+        private Integer type;
+    }
+}
diff --git a/src/main/java/com/yuyou/openapi/openapi/service/ABClientService.java b/src/main/java/com/yuyou/openapi/openapi/service/ABClientService.java
index dd6a38f..849c7f1 100644
--- a/src/main/java/com/yuyou/openapi/openapi/service/ABClientService.java
+++ b/src/main/java/com/yuyou/openapi/openapi/service/ABClientService.java
@@ -37,6 +37,10 @@ public interface ABClientService {
      */
     boolean recordAndSendABClientMsgPanda(List<ABMessageDTO> dtos);
 
+    /**
+     * 记录接口推送信息对数据进行入库,并异步进行发送给下游
+     */
+    boolean recordAndSendABClientMsgHeXiaoXiang(List<ABMessageDTO> dtos);
 
     /**
      * 记录接口推送信息对数据进行入库,并异步进行发送给下游
diff --git a/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceImpl.java b/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceImpl.java
index 2c2c233..63a5e01 100644
--- a/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceImpl.java
+++ b/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceImpl.java
@@ -73,6 +73,9 @@ public class ABClientServiceImpl implements ABClientService {
     @Autowired
     private XuebaMessageRepository xuebaMessageRepository;
 
+    @Autowired
+    private HeXiaoXiangMessageRepository heXiaoXiangMessageRepository;
+
     @Override
     public boolean recordAndSendABClientMsg(List<ABMessageDTO> dtos) {
         if (CollectionUtils.isEmpty(dtos)) {
@@ -133,6 +136,26 @@ public class ABClientServiceImpl implements ABClientService {
         return Boolean.TRUE;
     }
 
+    @Override
+    public boolean recordAndSendABClientMsgHeXiaoXiang(List<ABMessageDTO> dtos) {
+        if (CollectionUtils.isEmpty(dtos)) {
+            log.error("Param dtos is empty");
+            return Boolean.FALSE;
+        }
+        // 调用接口进行入库
+        List<HeXiaoXiangMessageDO> abMessageDOS = ABMessageConverter.convertHeXiaoXiangABMessageDOFromDTO(dtos);
+        // TODO: 2020/8/10 0010 加密存储
+        List<HeXiaoXiangMessageDO> dos = heXiaoXiangMessageRepository.saveAll(abMessageDOS);
+        if (CollectionUtils.isEmpty(dos)){
+            log.error("========== [insert data error , please check .] ==========");
+            return Boolean.FALSE;
+        }
+        // 调用异步任务进行转发AB单 - 这里是这有一条数据
+        // 返回处理结果
+        abDownTask.doRunHeXXTask(dtos);
+        return Boolean.TRUE;
+    }
+
     @Override
     public boolean recordAndSendABClientMsgWxFans(List<ABMessageDTO> dtos) {
         if (CollectionUtils.isEmpty(dtos)) {
diff --git a/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceProxy.java b/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceProxy.java
index c786e03..f980948 100644
--- a/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceProxy.java
+++ b/src/main/java/com/yuyou/openapi/openapi/service/impl/ABClientServiceProxy.java
@@ -68,6 +68,11 @@ public class ABClientServiceProxy implements ABClientService {
         return abClientService.recordAndSendABClientMsgPanda(dto);
     }
 
+    @Override
+    public boolean recordAndSendABClientMsgHeXiaoXiang(List<ABMessageDTO> dtos) {
+        return abClientService.recordAndSendABClientMsgHeXiaoXiang(dtos);
+    }
+
     @Override
     public boolean recordAndSendABClientMsgWxFans(List<ABMessageDTO> dtos) {
         return abClientService.recordAndSendABClientMsgWxFans(dtos);
diff --git a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
index 5751e9e..9a384e0 100644
--- a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
+++ b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
@@ -109,6 +109,10 @@ public class ABDownTask {
      */
     @Value("${ab.wxfans.url}")
     private String wxFansUrl;
+    @Value("${ab.wxfans.taskid.url}")
+    private String wxFansTaskIdUrl;
+    @Value("${ab.wxfans.secret}")
+    private String wxSecretKey;
 
     /**
      * 任务处理入口,主要用于时间记录
@@ -443,6 +447,95 @@ public class ABDownTask {
         return Boolean.TRUE;
     }
 
+    /**
+     * 任务处理入口,主要用于时间记录
+     *
+     * @return
+     */
+    @Async(value = "abTaskExecutor")
+    public void doRunHeXXTask(List<ABMessageDTO> messageDTOList){
+        Long satrtMilliSecond = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli();
+        log.info("====== [ task start running, task name is {} ] ======", "doRunHeXXTask");
+        runHeXXTask(messageDTOList);
+        Long endMilliSecond = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli();
+        log.info("====== [ task start end, task name is {},cost milliSecond is {} ] ======", "doRunHeXXTask", (endMilliSecond-satrtMilliSecond));
+    }
+
+    /**
+     * 真实的任务执行入口
+     *
+     * @return
+     */
+    private boolean runHeXXTask(List<ABMessageDTO> messageDTOList){
+        int count = 0; // 设置请求失败计数
+        // 数据实体进行映射转换 - 目前是只有一条给
+        HeXXMessageCovDTO heXXMessageCovDTO = new HeXXMessageCovDTO();
+        // 对特殊情况进行过滤,只要AB单的用户,且字段加密规则要重新进行制定
+        List<ABMessageDTO> collect = messageDTOList.stream()
+                .filter(item -> (1 == item.getClientType()) || 2 == item.getClientType())
+                .map(item -> {
+                    // pno通配
+                    String reverse = StringUtils.reverse(item.getMobile());
+                    item.setMobile(reverse);
+                    // startTime 通配下游到秒
+                    Long startTime = item.getStartTime();
+                    if (startTime != null && startTime.toString().length() == 13) {
+                        item.setStartTime(startTime / 1000);
+                    }
+                    return item;
+                })
+                .collect(Collectors.toList());
+        List<HeXXMessageCovDTO.HeXXData> data = new ArrayList<>();
+        // 进行转换
+        collect.forEach(
+                each->{
+                    HeXXMessageCovDTO.HeXXData heXXData = new HeXXMessageCovDTO.HeXXData();
+                    // BeanUtils.copyProperties(each, luoshiData);
+                    heXXData.setInfo(each.getMobile());
+                    heXXData.setType(1);
+                    heXXData.setTime(each.getStartTime());
+                    data.add(heXXData);
+                }
+        );
+        // 进行设置
+        if (!CollectionUtils.isEmpty(data)){
+            heXXMessageCovDTO.setData(data);
+        }
+        // 补充其他的下游请求字段
+        long time = System.currentTimeMillis() / 1000;
+        heXXMessageCovDTO.setTimestamp(time);
+        heXXMessageCovDTO.setAppId(panDaAppId);
+        heXXMessageCovDTO.setSignature(SecureUtil.sha1("app_id="+ panDaAppId +"&timestamp="+ time + "&secret=" + panDaSecretKey));
+        // 数据实体转成Json 不忽略空kv 有序
+        String jsonStr = JSON.toJSONString(heXXMessageCovDTO);
+        log.info("========== [ready send json is {} ] =============", jsonStr);
+        // 请求的响应处理
+        // todo 失败重发请求3次
+        while (count <= 3){
+            // 调用HTTP请求发送数据
+            HttpResponse httpResponse = sendPandaReq(jsonStr);
+            if (httpResponse.isOk() && httpResponse.body().contains("success")){
+                log.info("========== [request success, response is {} ] ==========", httpResponse.body());
+                break;
+            }else{
+                count ++;
+                try {
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    log.error("sleep error!");
+                }
+                log.error("========== [request fail, response is {} ] ==========", httpResponse.body());
+            }
+        }
+        if (count > 3) {
+            return Boolean.FALSE;
+        }
+        collect.forEach(
+                // FIXME: 2020/8/12 0012 可能会造成更新失败,检查更新语句
+                each ->  abMessageService.updateSendPDSatus(Long.valueOf(each.getRecId()), Boolean.TRUE)
+        );
+        return Boolean.TRUE;
+    }
 
     /**
      * 任务处理入口,主要用于时间记录
@@ -483,11 +576,26 @@ public class ABDownTask {
         String jsonStr = JSON.toJSONString(wxFansMessageCovDTO);
         log.info("========== [ready send json is {} ] =============", jsonStr);
         // 请求的响应处理
+        HttpResponse wxTaskIdResponse = getWxTaskId();
+        Integer wxTaskId = null;
+        if (wxTaskIdResponse.isOk() && wxTaskIdResponse.body().contains("true")){
+            JSONObject jsonObject = JSON.parseObject(wxTaskIdResponse.body());
+            if (jsonObject != null){
+                wxTaskId = (Integer)jsonObject.get("data");
+            }
+            if (wxTaskId ==  null || wxTaskId <= 0){
+                log.error("========== [wxTaskId is null,please check . ] =============");
+                return Boolean.FALSE;
+            }
+        }else {
+            log.error("========== [get WX taskId task error, http error response is  {} . ] =============" ,wxTaskIdResponse.body());
+            return Boolean.FALSE;
+        }
         // todo 失败重发请求3次
         while (count <= 3){
             // 调用HTTP请求发送数据
-            HttpResponse httpResponse = sendWxReq(jsonStr);
-            if (httpResponse.isOk() && httpResponse.body().contains("true")){
+            HttpResponse httpResponse = sendWxReq(jsonStr, wxTaskId);
+            if (httpResponse!= null && httpResponse.isOk() && httpResponse.body().contains("true")){
                 log.info("========== [request success, response is {} ] ==========", httpResponse.body());
                 break;
             }else{
@@ -640,14 +748,34 @@ public class ABDownTask {
      * @param json 请求的body内容
      * @return
      */
-    private HttpResponse sendWxReq(String json){
+    private HttpResponse sendWxReq(String json, Integer wxTaskId){
+
         HttpResponse httpResponse = HttpRequest
-                .post(wxFansUrl)
+                .post(wxFansUrl + wxTaskId)
                 .body(json)
                 .execute();
         return httpResponse;
     }
 
+    /**
+     * 获取微信Id的请求
+     * @return
+     */
+    private HttpResponse getWxTaskId(){
+        // 拼装请求
+        StringBuilder url = new StringBuilder();
+        url.append(wxFansTaskIdUrl)
+                .append("?")
+                .append("secret=")
+                .append(wxSecretKey);
+
+        // 发送get请求
+        HttpResponse response = HttpRequest
+                .get(url.toString())
+                .execute();
+        return response;
+    }
+
     /**
      * 调用liehe HTTP请求发送数据
      * @param json
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index d53b2f7..1296280 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,6 +1,6 @@
 spring:
   profiles:
-    active: prod
+    active: dev
   # 序列化忽略null的k-v配置
   jackson:
     default-property-inclusion: non_null
@@ -15,7 +15,7 @@ server:
   port: 8090
 # 环境
 spring:
-  profiles: prod
+  profiles: dev
   # 数据库相关配置
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
@@ -49,7 +49,10 @@ ab:
     url: https://pre-api.aircourses.com/common/open/n/stuClue/add/callback
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
   wxfans:
-    url: https://api.wooxin.cn/tketong/30
+    url: https://api.wooxin.cn/tketong/
+    taskid:
+      url: https://api.wooxin.cn/tketong/getLastAddId
+    secret: pmDclwRSYQgeiAKDghqXgs9m69OT7m69
 ---
 # 端口
 server:
@@ -90,7 +93,10 @@ ab:
     url: https://api.aircourses.com/common/open/n/stuClue/add/callback
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
   wxfans:
-    url: https://api.wooxin.cn/tketong/30
+    url: https://api.wooxin.cn/tketong/
+    taskid:
+      url: https://api.wooxin.cn/tketong/getLastAddId
+    secret: pmDclwRSYQgeiAKDghqXgs9m69OT7m69
 logging:
   config: classpath:logback.xml
 ---
@@ -133,6 +139,9 @@ ab:
     url: https://data.hzluoshi.cn/index/phoneapi
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
   wxfans:
-    url: https://api.wooxin.cn/tketong/30
+    url: https://api.wooxin.cn/tketong/
+    taskid:
+      url: https://api.wooxin.cn/tketong/getLastAddId
+    secret: pmDclwRSYQgeiAKDghqXgs9m69OT7m69
 #logging:
 #  config: classpath:logback.xml
\ No newline at end of file
diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml
index 77e8fb7..afa4c7b 100644
--- a/src/main/resources/logback.xml
+++ b/src/main/resources/logback.xml
@@ -37,7 +37,7 @@
 
     <root level="INFO">
         <!-- TODO prod 环境去掉std -->
-        <!--<appender-ref ref="stdAppender"/>-->
-        <appender-ref ref="fileAppender"/>
+        <appender-ref ref="stdAppender"/>
+        <!--<appender-ref ref="fileAppender"/>-->
     </root>
 </configuration>
\ No newline at end of file
diff --git a/src/test/java/com/yuyou/openapi/openapi/HttpTest.java b/src/test/java/com/yuyou/openapi/openapi/HttpTest.java
new file mode 100644
index 0000000..2e16be0
--- /dev/null
+++ b/src/test/java/com/yuyou/openapi/openapi/HttpTest.java
@@ -0,0 +1,19 @@
+package com.yuyou.openapi.openapi;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import org.junit.Test;
+
+public class HttpTest {
+
+    @Test
+    public void test(){
+        String str = "{\"data\":127,\"success\":true,\"message\":\"Everything is ok\",\"time\":1604466616,\"formatTime\":\"2020-11-04 13:10:16\"}";
+
+        JSONObject jsonObject = JSON.parseObject(str);
+
+        Integer id = (Integer) jsonObject.get("data");
+
+        System.out.println(id);
+    }
+}

From 8c285593af277a13f7f1c7dbd2e5c773f9cf19ef Mon Sep 17 00:00:00 2001
From: qyx <565485304@qq.com>
Date: Sat, 7 Nov 2020 15:23:05 +0800
Subject: [PATCH 3/4] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=B2=B3=E5=B0=8F?=
 =?UTF-8?q?=E8=B1=A1=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../openapi/service/ABMessageService.java     |  5 +++
 .../service/impl/ABMessageServiceImpl.java    | 16 ++++++++++
 .../openapi/openapi/task/ABDownTask.java      | 32 +++++++++++++++++--
 src/main/resources/application.yml            | 12 +++++++
 4 files changed, 62 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/yuyou/openapi/openapi/service/ABMessageService.java b/src/main/java/com/yuyou/openapi/openapi/service/ABMessageService.java
index 87d18fe..21e58fd 100644
--- a/src/main/java/com/yuyou/openapi/openapi/service/ABMessageService.java
+++ b/src/main/java/com/yuyou/openapi/openapi/service/ABMessageService.java
@@ -41,6 +41,11 @@ public interface ABMessageService {
      */
     boolean updateSendPDSatus(Long recId, boolean sucess);
 
+    /**
+     * 更新河小象发送记录 - 单条更新
+     */
+    boolean updateSendHeXXSatus(Long recId, boolean sucess);
+
 
     /**
      * 更新罗什发送记录 - 单条更新
diff --git a/src/main/java/com/yuyou/openapi/openapi/service/impl/ABMessageServiceImpl.java b/src/main/java/com/yuyou/openapi/openapi/service/impl/ABMessageServiceImpl.java
index 4db1233..06a7fd4 100644
--- a/src/main/java/com/yuyou/openapi/openapi/service/impl/ABMessageServiceImpl.java
+++ b/src/main/java/com/yuyou/openapi/openapi/service/impl/ABMessageServiceImpl.java
@@ -35,6 +35,8 @@ public class ABMessageServiceImpl implements ABMessageService {
     private PandaMessageRepository pandaMessageRepository;
     @Autowired
     private WxFansMessageRepository wxFansMessageRepository;
+    @Autowired
+    private HeXiaoXiangMessageRepository heXiaoXiangMessageRepository;
 
     @Override
     @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
@@ -106,6 +108,20 @@ public class ABMessageServiceImpl implements ABMessageService {
         return Boolean.TRUE;
     }
 
+    @Override
+    @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
+    public boolean updateSendHeXXSatus(Long recId, boolean sucess) {
+        if (recId == null) {
+            return Boolean.FALSE;
+        }
+        if (sucess) {
+            heXiaoXiangMessageRepository.updateSendStatus(1, recId);
+        }else {
+            heXiaoXiangMessageRepository.updateSendStatus(0, recId);
+        }
+        return Boolean.TRUE;
+    }
+
     @Override
     @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
     public boolean updateSendWxFansSatus(Long recId, boolean sucess) {
diff --git a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
index 9a384e0..4ed5b5a 100644
--- a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
+++ b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
@@ -114,6 +114,18 @@ public class ABDownTask {
     @Value("${ab.wxfans.secret}")
     private String wxSecretKey;
 
+    /**
+     * 配置文件中加载配置信息 - 河小象
+     */
+    @Value("${ab.hexx.appId}")
+    private String hexxAppId;
+
+    @Value("${ab.hexx.url}")
+    private String hexxUrl;
+
+    @Value("${ab.hexx.secretKey}")
+    private String hexxSecretKey;
+
     /**
      * 任务处理入口,主要用于时间记录
      *
@@ -504,8 +516,8 @@ public class ABDownTask {
         // 补充其他的下游请求字段
         long time = System.currentTimeMillis() / 1000;
         heXXMessageCovDTO.setTimestamp(time);
-        heXXMessageCovDTO.setAppId(panDaAppId);
-        heXXMessageCovDTO.setSignature(SecureUtil.sha1("app_id="+ panDaAppId +"&timestamp="+ time + "&secret=" + panDaSecretKey));
+        heXXMessageCovDTO.setAppId(hexxAppId);
+        heXXMessageCovDTO.setSignature(SecureUtil.sha1("app_id="+ hexxAppId +"&timestamp="+ time + "&secret=" + hexxSecretKey));
         // 数据实体转成Json 不忽略空kv 有序
         String jsonStr = JSON.toJSONString(heXXMessageCovDTO);
         log.info("========== [ready send json is {} ] =============", jsonStr);
@@ -513,7 +525,7 @@ public class ABDownTask {
         // todo 失败重发请求3次
         while (count <= 3){
             // 调用HTTP请求发送数据
-            HttpResponse httpResponse = sendPandaReq(jsonStr);
+            HttpResponse httpResponse = sendHXXReq(jsonStr);
             if (httpResponse.isOk() && httpResponse.body().contains("success")){
                 log.info("========== [request success, response is {} ] ==========", httpResponse.body());
                 break;
@@ -742,6 +754,20 @@ public class ABDownTask {
         return httpResponse;
     }
 
+    /**
+     * 调用HTTP请求发送数据
+     *
+     * @param json 请求的body内容
+     * @return
+     */
+    private HttpResponse sendHXXReq(String json){
+        HttpResponse httpResponse = HttpRequest
+                .post(hexxUrl)
+                .body(json)
+                .execute();
+        return httpResponse;
+    }
+
     /**
      * 调用HTTP请求发送数据
      *
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 1296280..59d39e2 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -48,6 +48,10 @@ ab:
     appId: 10671792
     url: https://pre-api.aircourses.com/common/open/n/stuClue/add/callback
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
+  hexx:
+    appId: 9067cf8713cb5518
+    url: https://apitest.hexiaoxiang.com/managerportal/clue
+    secretKey: c0990e72836828ab
   wxfans:
     url: https://api.wooxin.cn/tketong/
     taskid:
@@ -92,6 +96,10 @@ ab:
     appId: 10671792
     url: https://api.aircourses.com/common/open/n/stuClue/add/callback
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
+  hexx:
+    appId: 9067cf8713cb5518
+    url: https://api.hexiaoxiang.com/managerportal/clue
+    secretKey: c0990e72836828ab
   wxfans:
     url: https://api.wooxin.cn/tketong/
     taskid:
@@ -138,6 +146,10 @@ ab:
     appId: Hangzhouyunuo
     url: https://data.hzluoshi.cn/index/phoneapi
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
+  hexx:
+    appId: 9067cf8713cb5518
+    url: https://api.hexiaoxiang.com/managerportal/clue
+    secretKey: c0990e72836828ab
   wxfans:
     url: https://api.wooxin.cn/tketong/
     taskid:

From 9459da864d284be5305e429bc03654a8f0f30722 Mon Sep 17 00:00:00 2001
From: qyx <565485304@qq.com>
Date: Tue, 10 Nov 2020 19:20:37 +0800
Subject: [PATCH 4/4] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=B2=B3=E5=B0=8F?=
 =?UTF-8?q?=E8=B1=A1=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java | 2 +-
 src/main/resources/application.yml                           | 4 ++--
 src/main/resources/logback.xml                               | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
index 4ed5b5a..57ef8d3 100644
--- a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
+++ b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
@@ -544,7 +544,7 @@ public class ABDownTask {
         }
         collect.forEach(
                 // FIXME: 2020/8/12 0012 可能会造成更新失败,检查更新语句
-                each ->  abMessageService.updateSendPDSatus(Long.valueOf(each.getRecId()), Boolean.TRUE)
+                each ->  abMessageService.updateSendHeXXSatus(Long.valueOf(each.getRecId()), Boolean.TRUE)
         );
         return Boolean.TRUE;
     }
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 59d39e2..46141e7 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,6 +1,6 @@
 spring:
   profiles:
-    active: dev
+    active: prod
   # 序列化忽略null的k-v配置
   jackson:
     default-property-inclusion: non_null
@@ -50,7 +50,7 @@ ab:
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
   hexx:
     appId: 9067cf8713cb5518
-    url: https://apitest.hexiaoxiang.com/managerportal/clue
+    url: https://api.hexiaoxiang.com/managerportal/clue
     secretKey: c0990e72836828ab
   wxfans:
     url: https://api.wooxin.cn/tketong/
diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml
index afa4c7b..77e8fb7 100644
--- a/src/main/resources/logback.xml
+++ b/src/main/resources/logback.xml
@@ -37,7 +37,7 @@
 
     <root level="INFO">
         <!-- TODO prod 环境去掉std -->
-        <appender-ref ref="stdAppender"/>
-        <!--<appender-ref ref="fileAppender"/>-->
+        <!--<appender-ref ref="stdAppender"/>-->
+        <appender-ref ref="fileAppender"/>
     </root>
 </configuration>
\ No newline at end of file