From 0bf68984e6903ca4c0a5d64f95274841580be939 Mon Sep 17 00:00:00 2001
From: qyx <565485304@qq.com>
Date: Mon, 2 Nov 2020 19:43:47 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E4=BF=A1=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yuyou/openapi/openapi/api/ABClient.java   | 18 ++++
 .../openapi/dao/WxFansMessageRepository.java  | 25 ++++++
 .../model/convert/ABMessageConverter.java     | 51 +++++++++++
 .../model/dataobject/WxFansMessageDO.java     | 76 ++++++++++++++++
 .../model/dto/WxFansMessageCovDTO.java        | 39 ++++++++
 .../openapi/service/ABClientService.java      |  6 ++
 .../openapi/service/ABMessageService.java     |  6 ++
 .../service/impl/ABClientServiceImpl.java     | 22 +++++
 .../service/impl/ABClientServiceProxy.java    |  5 ++
 .../service/impl/ABMessageServiceImpl.java    | 17 ++++
 .../openapi/openapi/task/ABDownTask.java      | 90 ++++++++++++++++++-
 src/main/resources/application.yml            |  7 +-
 .../yuyou/openapi/openapi/ExcelFileTest.java  | 35 ++++++++
 13 files changed, 395 insertions(+), 2 deletions(-)
 create mode 100644 src/main/java/com/yuyou/openapi/openapi/dao/WxFansMessageRepository.java
 create mode 100644 src/main/java/com/yuyou/openapi/openapi/model/dataobject/WxFansMessageDO.java
 create mode 100644 src/main/java/com/yuyou/openapi/openapi/model/dto/WxFansMessageCovDTO.java
 create mode 100644 src/test/java/com/yuyou/openapi/openapi/ExcelFileTest.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 35d1447..3a62af2 100644
--- a/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java
+++ b/src/main/java/com/yuyou/openapi/openapi/api/ABClient.java
@@ -119,6 +119,24 @@ public class ABClient {
     }
 
 
+    /**
+     * 获取上游公司的AB数据推送接口 - 推送到微信加粉
+     *
+     * @return 返回调用信息
+     */
+    @PostMapping("/api/req/taginfo/wxfans")
+    @ResponseBody
+    public CommonResponse getDBTagInfoWxFans(@RequestBody ABClientInterMessageVO vo) {
+        // 记录日志
+        log.info("====== [ WX fans request comming, request content is {} ] ======", vo.toString());
+        // 转换实体类映射
+        List<ABMessageDTO> dtos = ABMessageConverter.convertABMessageDTOFromVO(vo);
+        // 调用业务处理接口  返回校验成功的结果
+        return abClientService.recordAndSendABClientMsgWxFans(dtos) ?
+                CommonResponse.createBySuccess() : CommonResponse.createByErrorMessage("调用失败请重试");
+    }
+
+
     /**
      * AB单补推接口
      *
diff --git a/src/main/java/com/yuyou/openapi/openapi/dao/WxFansMessageRepository.java b/src/main/java/com/yuyou/openapi/openapi/dao/WxFansMessageRepository.java
new file mode 100644
index 0000000..40219ea
--- /dev/null
+++ b/src/main/java/com/yuyou/openapi/openapi/dao/WxFansMessageRepository.java
@@ -0,0 +1,25 @@
+package com.yuyou.openapi.openapi.dao;
+
+import com.yuyou.openapi.openapi.model.dataobject.WxFansMessageDO;
+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:
+ * <author>          <time>          <version>          <desc>
+ * 钱昱欣             2020/10/22          v1.0              创建此文件
+ */
+@Repository
+public interface WxFansMessageRepository extends JpaRepository<WxFansMessageDO, Long>{
+    @Modifying
+    @Query("update WxFansMessageDO 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 82dca05..9cf9fdd 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
@@ -131,6 +131,26 @@ public class ABMessageConverter {
     }
 
 
+    /**
+     * 批量转DTO为DO
+     * @param dtos
+     * @return
+     */
+    public static List<WxFansMessageDO> convertWxFansABMessageDOFromDTO(List<ABMessageDTO> dtos) {
+        if (CollectionUtils.isEmpty(dtos)) {
+            return null;
+        }
+        List<WxFansMessageDO> abMessageDOs = new ArrayList<>();
+        dtos.forEach(each -> {
+            WxFansMessageDO abMessageDO = convertWxFansMessageDOFromDTO(each);
+            if (abMessageDO != null) {
+                abMessageDOs.add(abMessageDO);
+            }
+        });
+        return abMessageDOs;
+    }
+
+
     /**
      * DTO层转为DO层
      * @param abMessageDTO
@@ -306,6 +326,37 @@ public class ABMessageConverter {
         return pandaMessageDO;
     }
 
+    /**
+     * Luoshi DTO层转为DO层
+     * @param abMessageDTO
+     * @return
+     */
+    public static WxFansMessageDO convertWxFansMessageDOFromDTO(ABMessageDTO abMessageDTO) {
+        WxFansMessageDO wxFansMessageDO = new WxFansMessageDO();
+        if (abMessageDTO == null) {
+            return wxFansMessageDO;
+        }
+
+        BeanUtils.copyProperties(abMessageDTO, wxFansMessageDO);
+        wxFansMessageDO.setPushTime(DateUtils.date(abMessageDTO.getTimestamp()));
+        wxFansMessageDO.setStartTime(DateUtils.date(abMessageDTO.getStartTime()));
+        try{
+            wxFansMessageDO.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);
+            wxFansMessageDO.setPnum(encryptedMobile);
+        } catch (Exception e) {
+            log.error("Encrypt Mobile raise Error, recId = {}, error is :", abMessageDTO.getRecId(), e);
+            wxFansMessageDO.setPnum(abMessageDTO.getMobile());
+        }
+        return wxFansMessageDO;
+    }
+
 
 
 
diff --git a/src/main/java/com/yuyou/openapi/openapi/model/dataobject/WxFansMessageDO.java b/src/main/java/com/yuyou/openapi/openapi/model/dataobject/WxFansMessageDO.java
new file mode 100644
index 0000000..32999af
--- /dev/null
+++ b/src/main/java/com/yuyou/openapi/openapi/model/dataobject/WxFansMessageDO.java
@@ -0,0 +1,76 @@
+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;
+
+@Data
+@Table(name = "wxfans_message")
+@Entity
+@EntityListeners(AuditingEntityListener.class)
+public class WxFansMessageDO {
+
+    @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/WxFansMessageCovDTO.java b/src/main/java/com/yuyou/openapi/openapi/model/dto/WxFansMessageCovDTO.java
new file mode 100644
index 0000000..943d4df
--- /dev/null
+++ b/src/main/java/com/yuyou/openapi/openapi/model/dto/WxFansMessageCovDTO.java
@@ -0,0 +1,39 @@
+package com.yuyou.openapi.openapi.model.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * Copyright (C), 2012 - 2018, qyx
+ * FileName: WxFansMessageCovDTO
+ * 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 WxFansMessageCovDTO {
+
+    /**
+     * 推送用户的ID
+     */
+//    @JSONField(serialize = false)
+    private String type;
+
+    /**
+     * 具体数据，每条为json格式
+     */
+    private List<String> data;
+
+}
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 b813367..60784eb 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,12 @@ public interface ABClientService {
      */
     boolean recordAndSendABClientMsgPanda(List<ABMessageDTO> dtos);
 
+
+    /**
+     * 记录接口推送信息对数据进行入库,并异步进行发送给下游
+     */
+    boolean recordAndSendABClientMsgWxFans(List<ABMessageDTO> dtos);
+
     /**
      * TODO:临时用.后续根据业务设计与recordAndSendABClientMsg合并
      * @param dtos
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 bea53bd..87d18fe 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,12 @@ public interface ABMessageService {
      */
     boolean updateSendPDSatus(Long recId, boolean sucess);
 
+
+    /**
+     * 更新罗什发送记录 - 单条更新
+     */
+    boolean updateSendWxFansSatus(Long recId, boolean sucess);
+
     /**
      * 查询未发送成功的数据
      */
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 5bd0fec..de3823f 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
@@ -67,6 +67,8 @@ public class ABClientServiceImpl implements ABClientService {
 
     @Autowired
     private SongshuMessageRepository songshuMessageRepository;
+    @Autowired
+    private WxFansMessageRepository wxFansMessageRepository;
 
     @Override
     public boolean recordAndSendABClientMsg(List<ABMessageDTO> dtos) {
@@ -128,6 +130,26 @@ public class ABClientServiceImpl implements ABClientService {
         return Boolean.TRUE;
     }
 
+    @Override
+    public boolean recordAndSendABClientMsgWxFans(List<ABMessageDTO> dtos) {
+        if (CollectionUtils.isEmpty(dtos)) {
+            log.error("Param dtos is empty");
+            return Boolean.FALSE;
+        }
+        // 调用接口进行入库
+        List<WxFansMessageDO> abMessageDOS = ABMessageConverter.convertWxFansABMessageDOFromDTO(dtos);
+        // TODO: 2020/8/10 0010 加密存储
+        List<WxFansMessageDO> dos = wxFansMessageRepository.saveAll(abMessageDOS);
+        if (CollectionUtils.isEmpty(dos)){
+            log.error("========== [insert data error , please check .] ==========");
+            return Boolean.FALSE;
+        }
+        // 调用异步任务进行转发AB单 - 这里是这有一条数据
+        // 返回处理结果
+        abDownTask.doRunWxFansTask(dtos);
+        return Boolean.TRUE;
+    }
+
 
     @Override
     public boolean recordAndSendABClientMsgLuoshi(List<ABMessageDTO> 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 245e0bb..8622dd6 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 recordAndSendABClientMsgWxFans(List<ABMessageDTO> dtos) {
+        return abClientService.recordAndSendABClientMsgWxFans(dtos);
+    }
+
     @Override
     public boolean recordAndSendLieheMsg(List<ABMessageDTO> dtos) {
         return abClientService.recordAndSendLieheMsg(dtos);
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 4ecd457..4db1233 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
@@ -33,6 +33,8 @@ public class ABMessageServiceImpl implements ABMessageService {
     private LuoshiMessageRepository luoshiMessageRepository;
     @Autowired
     private PandaMessageRepository pandaMessageRepository;
+    @Autowired
+    private WxFansMessageRepository wxFansMessageRepository;
 
     @Override
     @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
@@ -104,6 +106,21 @@ public class ABMessageServiceImpl implements ABMessageService {
         return Boolean.TRUE;
     }
 
+    @Override
+    @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
+    public boolean updateSendWxFansSatus(Long recId, boolean sucess) {
+        if (recId == null) {
+            return Boolean.FALSE;
+        }
+        if (sucess) {
+            wxFansMessageRepository.updateSendStatus(1, recId);
+        }else {
+            wxFansMessageRepository.updateSendStatus(0, recId);
+        }
+        return Boolean.TRUE;
+    }
+
+
     @Override
     public List<ABMessageDTO> queryUnSendMessage(Date startPushTime, Date endPushTime) {
 
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 7627d53..5751e9e 100644
--- a/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
+++ b/src/main/java/com/yuyou/openapi/openapi/task/ABDownTask.java
@@ -37,6 +37,11 @@ import java.util.stream.Collectors;
 @Slf4j
 public class ABDownTask {
 
+    /**
+     * 微信加粉标识
+     */
+    private static final String FIX_WX_ADD_FANS_TAG = "addfriend";
+
 
     @Autowired
     private ABMessageService abMessageService;
@@ -99,7 +104,11 @@ public class ABDownTask {
     @Value("${ab.panda.secretKey}")
     private String panDaSecretKey;
 
-
+    /**
+     * 配置文件中加载配置信息 - 微信加粉
+     */
+    @Value("${ab.wxfans.url}")
+    private String wxFansUrl;
 
     /**
      * 任务处理入口,主要用于时间记录
@@ -435,6 +444,71 @@ public class ABDownTask {
     }
 
 
+    /**
+     * 任务处理入口,主要用于时间记录
+     *
+     * @return
+     */
+    @Async(value = "abTaskExecutor")
+    public void doRunWxFansTask(List<ABMessageDTO> messageDTOList){
+        Long satrtMilliSecond = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli();
+        log.info("====== [ task start running, task name is {} ] ======", "doRunWxFansTask");
+        runWxFansTask(messageDTOList);
+        Long endMilliSecond = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli();
+        log.info("====== [ task start end, task name is {},cost milliSecond is {} ] ======", "doRunWxFansTask", (endMilliSecond-satrtMilliSecond));
+    }
+
+    /**
+     * 真实的任务执行入口
+     *
+     * @return
+     */
+    private boolean runWxFansTask(List<ABMessageDTO> messageDTOList){
+        int count = 0; // 设置请求失败计数
+        // 数据实体进行映射转换 - 目前是只有一条给
+        WxFansMessageCovDTO wxFansMessageCovDTO = new WxFansMessageCovDTO();
+        // 号码集合
+        List<String> data = new ArrayList<>();
+        // 进行转换
+        messageDTOList.forEach(
+                each-> data.add(each.getMobile())
+        );
+        // 进行设置
+        if (!CollectionUtils.isEmpty(data)){
+            wxFansMessageCovDTO.setData(data);
+        }
+        // 补充其他的下游请求字段
+        wxFansMessageCovDTO.setType(FIX_WX_ADD_FANS_TAG);
+        // 数据实体转成Json 不忽略空kv 有序
+        String jsonStr = JSON.toJSONString(wxFansMessageCovDTO);
+        log.info("========== [ready send json is {} ] =============", jsonStr);
+        // 请求的响应处理
+        // todo 失败重发请求3次
+        while (count <= 3){
+            // 调用HTTP请求发送数据
+            HttpResponse httpResponse = sendWxReq(jsonStr);
+            if (httpResponse.isOk() && httpResponse.body().contains("true")){
+                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;
+        }
+        messageDTOList.forEach(
+                // FIXME: 2020/8/12 0012 可能会造成更新失败,检查更新语句
+                each ->  abMessageService.updateSendWxFansSatus(Long.valueOf(each.getRecId()), Boolean.TRUE)
+        );
+        return Boolean.TRUE;
+    }
 
 
     /**
@@ -560,6 +634,20 @@ public class ABDownTask {
         return httpResponse;
     }
 
+    /**
+     * 调用HTTP请求发送数据
+     *
+     * @param json 请求的body内容
+     * @return
+     */
+    private HttpResponse sendWxReq(String json){
+        HttpResponse httpResponse = HttpRequest
+                .post(wxFansUrl)
+                .body(json)
+                .execute();
+        return httpResponse;
+    }
+
     /**
      * 调用liehe HTTP请求发送数据
      * @param json
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 1ed0c23..6edffb2 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -48,7 +48,8 @@ ab:
     appId: 10671792
     url: https://pre-api.aircourses.com/common/open/n/stuClue/add/callback
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
-
+  wxfans:
+    url: https://api.wooxin.cn/tketong/30
 ---
 # 端口
 server:
@@ -88,6 +89,8 @@ ab:
     appId: 10671792
     url: https://api.aircourses.com/common/open/n/stuClue/add/callback
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
+  wxfans:
+    url: https://api.wooxin.cn/tketong/30
 logging:
   config: classpath:logback.xml
 ---
@@ -129,5 +132,7 @@ ab:
     appId: Hangzhouyunuo
     url: https://data.hzluoshi.cn/index/phoneapi
     secretKey: fee2824fb2e0d1f166084cb66fc9d391
+  wxfans:
+    url: https://api.wooxin.cn/tketong/30
 #logging:
 #  config: classpath:logback.xml
\ No newline at end of file
diff --git a/src/test/java/com/yuyou/openapi/openapi/ExcelFileTest.java b/src/test/java/com/yuyou/openapi/openapi/ExcelFileTest.java
new file mode 100644
index 0000000..4cb5e33
--- /dev/null
+++ b/src/test/java/com/yuyou/openapi/openapi/ExcelFileTest.java
@@ -0,0 +1,35 @@
+package com.yuyou.openapi.openapi;
+
+import org.junit.Test;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.nio.file.StandardOpenOption;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class ExcelFileTest {
+
+    @Test
+    public void testReadAllFiles() throws IOException {
+
+
+        List<String> stringList = Files.readAllLines(Paths.get("H:\\1.txt"));
+
+        System.out.println(stringList.size());
+
+        List<String> collect = stringList.stream()
+                .distinct()
+                .filter(each -> (each.trim().length() == 24))
+                .collect(Collectors.toList());
+
+        System.out.println(collect.size());
+
+        Files.write(Paths.get("H:\\all.txt"),collect, StandardOpenOption.CREATE);
+
+    }
+
+
+
+}