广西融海科技有限公司

src/main/java/com/tiangua/star/controller/GXRHMd5CallBackController.java

@@ -0,0 +1,63 @@
+package com.tiangua.star.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.tiangua.star.model.CredentialStuffingDto;
+import com.tiangua.star.model.CredentialStuffingParam;
+import com.tiangua.star.service.CallBackService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+
+/**
+ * @author
+ * @description 本应用 +诚易融 需求开发上线一共两天
+ *              流程：诚易融定时任务扫，将api存在starl的http推送过来
+ *                  本应用使用http请求接受，获取数据，并对应星级，然后返回诚意融，不用mq 没有为什么
+  * @project loan-supermarket-parent
+ * @date 2025/3/21 10:45:49
+ */
+@RestController
+@RequestMapping(value = "/gxrhmd5/callback")
+@Slf4j
+public class GXRHMd5CallBackController {
+
+    @Autowired
+    private CallBackService callBackService;
+
+    @PostMapping("/request")
+    public CredentialStuffingDto request(@RequestBody CredentialStuffingParam param) {
+        log.info("广西融海科技有限公司 get begin dto{}",param);
+
+        if (param == null) {
+            log.info("广西融海科技有限公司解析回传数据为null");
+            CredentialStuffingDto dto1 = new CredentialStuffingDto();
+            dto1.setCode(500);
+            dto1.setMsg("请求数据为空");
+            return dto1;
+        }
+        CredentialStuffingDto dto = callBackService.gxthrequest(param);
+        log.info("广西融海科技有限公司 get end");
+        return dto;
+    }
+
+
+
+//    @PostMapping("/sendGetRequestHeiLongJiang")
+//    public void processInstitutionData() {
+//        String s1 = "99C0B3015254F583F3BF7C8430F328A5";
+//        String s2 = "8C32A04C7FED4B5EF9451CDB5D9DE770";
+//
+//        List<String> strings = new ArrayList<>();
+//        strings.add(s1);
+//        strings.add(s2);
+////
+////        String md5ListStr = [A4DAB7668AACAC1D134C1F37351689B2, AD7DE46FF63D14586BDB2960F8DFADA3, 830A6BF59D2BD7CC9BF348968F339679, BB0827AA0A5488D9888A9AB5F91EC1D9, 5DC81C7B49DF99B9EFD6AE60930684C3, 3FA262C2228781E91693FD1E491AD992, 2AA2F6D980D3AA1A99BC2668E6D17DF2, 5EF5B85D827A0D8DAF4F2F58492EAEF2, 5642D0403C64E28A35A458DD51D1835C, B042388F090D43BD65BF8041A077D498, 17E7DC0697D9778AC8CF3E34C1473A02, 19799C273D2A4AB61C83D032CAD58077, 6AD4F0A0B434BADD714008D993CCEB09, 1DC1BD9F6701A9D89E188A1215F644F0, 4350DEA1CE1875F7F307FA5D9BCD532A, 87E365716EC2308152C63EB815461794, 577DF2744FD39D6A8B62EE51E709ED33, 088249775E8CEB938D3FB8B0F24C0142];
+////        strings.add(md5ListStr);
+//        //sendGetRequestCQYXJ("4516","bff040093fee250512093334business","https://gw.rongxk.com/crm/api/channel/queryCustomerGrade",strings,"1D4C6329-399F-42CA-AC0C-236E0B048AD0",21540);
+//        sendGetRequestGZWA("4618", "a2f5cc8171d6250604105336business", "https://gw.rongxk.cn/crm/api/channel/queryCustomerGrade","苏州荣聚鑫科技有限公司","21540","8AF3F228-913D-4430-883A-2CEA88D8657E",strings);
+//    }
+}

src/main/java/com/tiangua/star/model/CredentialStuffingDto.java

@@ -0,0 +1,9 @@
+package com.tiangua.star.model;
+
+import lombok.Data;
+
+@Data
+public class CredentialStuffingDto {
+    private Integer code;
+    private String msg;
+}

src/main/java/com/tiangua/star/model/CredentialStuffingParam.java

@@ -0,0 +1,26 @@
+package com.tiangua.star.model;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class CredentialStuffingParam {
+
+    @ApiModelProperty(value = "渠道ID")
+    private String channelId;
+
+    @ApiModelProperty(value = "客户电话(md5加密后)")
+    private String phoneMd5;
+
+    @ApiModelProperty(value = "星级(-1-零星,0-未评级，1-一星级......5--5星级)")
+    private Integer customerStart;
+
+    @ApiModelProperty(value = "(1-未接通,2-已接通)")
+    private String phoneStatus;
+
+    @ApiModelProperty(value = "微信号状态（1-未加好友，2-已加好友）")
+    private String wechatStatus;
+
+    @ApiModelProperty(value = "最新跟进记录")
+    private String remark;
+}

src/main/java/com/tiangua/star/service/CallBackService.java

@@ -1,6 +1,8 @@
 package com.tiangua.star.service;
 
 import com.alibaba.fastjson.JSONObject;
+import com.tiangua.star.model.CredentialStuffingDto;
+import com.tiangua.star.model.CredentialStuffingParam;
 import com.tiangua.star.model.ThirdStarDto;
 import com.tiangua.star.model.XdOrderDto;
 
@@ -15,4 +17,6 @@ public interface CallBackService {
     JSONObject kydrequest(JSONObject json);
 
     JSONObject shxtrequest(JSONObject json);
+
+    CredentialStuffingDto gxthrequest(CredentialStuffingParam param);
 }

src/main/java/com/tiangua/star/service/impl/CasllBackDataProcessor.java

@@ -4,9 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.tiangua.star.enmus.CommercialCallBackReadyEnum;
-import com.tiangua.star.model.CustomerFollowup;
-import com.tiangua.star.model.ThirdStarDto;
-import com.tiangua.star.model.XdOrderDto;
+import com.tiangua.star.model.*;
 import com.tiangua.star.service.CallBackService;
 import com.tiangua.star.util.HttpClientThreeUtil;
 import com.tiangua.star.util.SignUtil;
@@ -551,6 +549,40 @@ public class CasllBackDataProcessor implements CallBackService {
 
     }
 
+    @Override
+    public CredentialStuffingDto gxthrequest(CredentialStuffingParam param) {
+        List<CustomerFollowup> followupList = new ArrayList<>();
+        CustomerFollowup followup = new CustomerFollowup();
+        followup.setPhoneMd5(param.getPhoneMd5());
+        String businessId = "b880f032c628250611050421business";
+        followup.setBusiId(businessId);
+        followup.setProductBizId(4652);
+        followup.setFollowTime(new Date());
+        followup.setSourceType(3);
+        String star = param.getCustomerStart().toString();
+        if ("-1".equals(star)) {
+            followup.setStarLevel(new BigDecimal(0));
+        }else if ("1".equals(star)) {
+            followup.setStarLevel(new BigDecimal(0));
+        }else if ("2".equals(star)) {
+            followup.setStarLevel(new BigDecimal(0));
+        }else if ("3".equals(star)) {
+            followup.setStarLevel(new BigDecimal(2));
+        }else if ("4".equals(star)) {
+            followup.setStarLevel(new BigDecimal(3));
+        }else if ("5".equals(star)) {
+            followup.setStarLevel(new BigDecimal(4));
+        }else if ("6".equals(star)) {
+            followup.setStarLevel(new BigDecimal(5));
+        }
+        followupList.add(followup);
+        handleMappedData(businessId,followupList);
+        CredentialStuffingDto dto = new CredentialStuffingDto();
+        dto.setCode(200);
+        dto.setMsg("成功");
+        return dto;
+    }
+
 
     private void sendGetRequestSXRKX(String productBizId,String busiId,String url,Map<String, String> resultMap){
         JSONObject param = SignUtil.generateSign(81, 43, "730969D3F673BA42432C574378B9A8F1");