feat:调用V3系统的风险接口

crm/src/main/java/com/kakarote/crm/controller/CrmGetV3SysRiskDataController.java

@@ -0,0 +1,76 @@
+package com.kakarote.crm.controller;
+
+
+import com.google.gson.Gson;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjg;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjgZbmx;
+import com.kakarote.crm.entity.VO.CrmApiResponseVO;
+import com.kakarote.crm.entity.VO.CrmV3SystemicRiskVO;
+import com.kakarote.crm.entity.VO.CrmRiskCheckResultVO;
+import com.kakarote.crm.service.ICrmQyfxjcjgService;
+import com.kakarote.crm.service.ICrmQyfxjcjgZbmxService;
+import okhttp3.MediaType;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import java.io.IOException;
+
+@RestController
+@RequestMapping("/crmGetData")
+public class CrmGetV3SysRiskDataController {
+
+    @Autowired
+    private ICrmQyfxjcjgService iCrmQyfxjcjgService;
+
+    @Autowired
+    private ICrmQyfxjcjgZbmxService iCrmQyfxjcjgZbmxService;
+
+    @PostMapping(value = "/resp")
+    public void getV3SysRiskData(@RequestBody CrmV3SystemicRiskVO crmV3SystemicRiskVO) {
+
+        OkHttpClient client = new OkHttpClient();
+
+        MediaType JSON = MediaType.get("application/json; charset=utf-8");
+
+        Gson gson = new Gson();
+        String json = gson.toJson(crmV3SystemicRiskVO);
+
+        okhttp3.RequestBody body = okhttp3.RequestBody.create(JSON, json);
+
+        Request request = new Request.Builder()
+                .url("https://v3-demo.lqyuns.com/api/risk/fxFxzbJcjgZbmx/openApi/getFxBynsrsbh")
+                .post(body)
+                .build();
+
+        try {
+            Response response = client.newCall(request).execute();
+            String respJson = response.body().string();
+
+            CrmApiResponseVO crmApiResponseVO = gson.fromJson(respJson, CrmApiResponseVO.class);
+
+            System.out.println(crmApiResponseVO);
+
+            System.out.println("响应消息:"+crmApiResponseVO.getMsg());
+            System.out.println("响应代码:"+crmApiResponseVO.getCode());
+            System.out.println("响应数据:"+crmApiResponseVO.getData());
+
+            for (CrmRiskCheckResultVO crmRiskCheckResultVO : crmApiResponseVO.getData()) {
+
+                CrmQyfxjcjg crmQyfxjcjg = crmRiskCheckResultVO.getCrmQyfxjcjg();
+                iCrmQyfxjcjgService.insertCrmQyfxjcjg(crmQyfxjcjg);
+
+                for (CrmQyfxjcjgZbmx item : crmRiskCheckResultVO.getCrmQyfxjcjgZbmxList()){
+
+                    iCrmQyfxjcjgZbmxService.insertQyfxjcjgZbmx(item);
+                }
+            }
+
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+
+}

crm/src/main/java/com/kakarote/crm/entity/VO/CrmApiResponseVO.java

@@ -0,0 +1,17 @@
+package com.kakarote.crm.entity.VO;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+//最外层响应体
+@Data
+public class CrmApiResponseVO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String msg;
+    private int code;
+    private List<CrmRiskCheckResultVO> data; // data是对象数组
+}

crm/src/main/java/com/kakarote/crm/entity/VO/CrmRiskCheckResultVO.java

@@ -0,0 +1,22 @@
+package com.kakarote.crm.entity.VO;
+
+import com.google.gson.annotations.SerializedName;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjg;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjgZbmx;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+//响应体中data的数据模型
+@Data
+public class CrmRiskCheckResultVO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @SerializedName("fxFxzbJcjg")
+    private CrmQyfxjcjg crmQyfxjcjg;
+
+    @SerializedName("fxFxzbJcjgZbmxList")
+    private List<CrmQyfxjcjgZbmx> crmQyfxjcjgZbmxList;
+}

crm/src/main/java/com/kakarote/crm/entity/VO/CrmV3SystemicRiskVO.java

@@ -0,0 +1,18 @@
+package com.kakarote.crm.entity.VO;
+
+import lombok.Data;
+
+@Data
+public class CrmV3SystemicRiskVO {
+
+    private Integer appId;
+
+    private String appSecret;
+
+    private String nsrsbh;
+
+    public CrmV3SystemicRiskVO() {
+        this.appId = 101011;
+        this.appSecret = "crmopenapi";
+    }
+}

crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgMapper.java

@@ -0,0 +1,12 @@
+package com.kakarote.crm.mapper;
+
+import com.kakarote.core.servlet.BaseMapper;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjg;
+import org.mapstruct.Mapper;
+
+import java.util.List;
+
+@Mapper
+public interface CrmQyfxjcjgMapper extends BaseMapper<CrmQyfxjcjg> {
+    List<CrmQyfxjcjg> selectByExample(CrmQyfxjcjg example);
+}

crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgZbmxMapper.java

@@ -0,0 +1,12 @@
+package com.kakarote.crm.mapper;
+
+import com.kakarote.core.servlet.BaseMapper;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjgZbmx;
+import org.mapstruct.Mapper;
+
+import java.util.List;
+
+@Mapper
+public interface CrmQyfxjcjgZbmxMapper extends BaseMapper<CrmQyfxjcjgZbmx> {
+    List<CrmQyfxjcjgZbmx> selectByExample(CrmQyfxjcjgZbmx example);
+}

crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgService.java

@@ -0,0 +1,42 @@
+package com.kakarote.crm.service;
+
+import com.kakarote.core.servlet.BaseService;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjg;
+
+import java.util.List;
+
+public interface ICrmQyfxjcjgService extends BaseService<CrmQyfxjcjg> {
+
+    /**
+     * 通过uuid获得风险模块风险指标检测批次结果信息
+     */
+    CrmQyfxjcjg getCrmQyfxjcjg(String jcpcUuid);
+
+    /**
+     * 插入风险模块风险指标检测批次结果信息
+     * @param crmQyfxjcjg
+     * @return
+     */
+    int insertCrmQyfxjcjg(CrmQyfxjcjg crmQyfxjcjg);
+
+    /**
+     * 更新风险模块风险指标检测批次结果信息
+     * @param crmQyfxjcjg
+     * @return
+     */
+    int updateCrmQyfxjcjg(CrmQyfxjcjg crmQyfxjcjg);
+
+    /**
+     * 删除风险模块风险指标检测批次结果信息
+     * @param jcpcUuid
+     * @return
+     */
+    int deleteCrmQyfxjcjg(String jcpcUuid);
+
+    /**
+     * 查询风险模块风险指标检测批次结果信息列表
+     * @param crmQyfxjcjg
+     * @return
+     */
+    List<CrmQyfxjcjg> getQyfxjcjgList(CrmQyfxjcjg crmQyfxjcjg);
+}

crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgZbmxService.java

@@ -0,0 +1,42 @@
+package com.kakarote.crm.service;
+
+import com.kakarote.core.servlet.BaseService;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjgZbmx;
+
+import java.util.List;
+
+public interface ICrmQyfxjcjgZbmxService extends BaseService<CrmQyfxjcjgZbmx> {
+
+    /**
+     * 通过uuid获得风险模块风险指标检测批次结果指标明细信息
+     */
+    CrmQyfxjcjgZbmx getQyfxjcjgZbmx(String zbmxUuid);
+
+    /**
+     * 插入风险模块风险指标检测批次结果指标明细信息
+     * @param crmQyfxjcjgZbmx
+     * @return
+     */
+    int insertQyfxjcjgZbmx(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx);
+
+    /**
+     * 更新风险模块风险指标检测批次结果指标明细信息
+     * @param crmQyfxjcjgZbmx
+     * @return
+     */
+    int updateQyfxjcjgZbmx(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx);
+
+    /**
+     * 删除风险模块风险指标检测批次结果指标明细信息
+     * @param zbmxUuid
+     * @return
+     */
+    int deleteQyfxjcjgZbmx(String zbmxUuid);
+
+    /**
+     * 查询风险模块风险指标检测批次结果指标明细信息列表
+     * @param crmQyfxjcjgZbmx
+     * @return
+     */
+    List<CrmQyfxjcjgZbmx> getQyfxjcjgZbmxList(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx);
+}

crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgServiceImpl.java

@@ -0,0 +1,44 @@
+package com.kakarote.crm.service.impl;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.kakarote.core.servlet.BaseServiceImpl;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjg;
+import com.kakarote.crm.mapper.CrmQyfxjcjgMapper;
+import com.kakarote.crm.service.ICrmQyfxjcjgService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.util.List;
+
+@Service
+public class CrmQyfxjcjgServiceImpl extends BaseServiceImpl<CrmQyfxjcjgMapper, CrmQyfxjcjg> implements ICrmQyfxjcjgService {
+
+    @Autowired
+    private CrmQyfxjcjgMapper crmQyfxjcjgMapper;
+
+    @Override
+    public CrmQyfxjcjg getCrmQyfxjcjg(String jcpcUuid) {
+        return crmQyfxjcjgMapper.selectById(jcpcUuid);
+    }
+
+    @Override
+    public int insertCrmQyfxjcjg(CrmQyfxjcjg crmQyfxjcjg) {
+        return crmQyfxjcjgMapper.insert(crmQyfxjcjg);
+    }
+
+    @Override
+    public int updateCrmQyfxjcjg(CrmQyfxjcjg crmQyfxjcjg) {
+        return crmQyfxjcjgMapper.updateById(crmQyfxjcjg);
+    }
+
+    @Override
+    public int deleteCrmQyfxjcjg(String jcpcUuid) {
+        return crmQyfxjcjgMapper.deleteById(jcpcUuid);
+    }
+
+    @Override
+    public List<CrmQyfxjcjg> getQyfxjcjgList(CrmQyfxjcjg crmQyfxjcjg) {
+        QueryWrapper<CrmQyfxjcjg> CrmQyfxjcjgQueryWrapper = new QueryWrapper<>();
+        return crmQyfxjcjgMapper.selectList(CrmQyfxjcjgQueryWrapper);
+    }
+}

crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgZbmxServiceImpl.java

@@ -0,0 +1,43 @@
+package com.kakarote.crm.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.kakarote.core.servlet.BaseServiceImpl;
+import com.kakarote.crm.entity.PO.CrmQyfxjcjgZbmx;
+import com.kakarote.crm.mapper.CrmQyfxjcjgZbmxMapper;
+import com.kakarote.crm.service.ICrmQyfxjcjgZbmxService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.util.List;
+
+@Service
+public class CrmQyfxjcjgZbmxServiceImpl extends BaseServiceImpl<CrmQyfxjcjgZbmxMapper, CrmQyfxjcjgZbmx> implements ICrmQyfxjcjgZbmxService {
+
+    @Autowired
+    private CrmQyfxjcjgZbmxMapper crmQyfxjcjgZbmxMapper;
+
+    @Override
+    public CrmQyfxjcjgZbmx getQyfxjcjgZbmx(String zbmxUuid) {
+        return crmQyfxjcjgZbmxMapper.selectById(zbmxUuid);
+    }
+
+    @Override
+    public int insertQyfxjcjgZbmx(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx) {
+        return crmQyfxjcjgZbmxMapper.insert(crmQyfxjcjgZbmx);
+    }
+
+    @Override
+    public int updateQyfxjcjgZbmx(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx) {
+        return crmQyfxjcjgZbmxMapper.updateById(crmQyfxjcjgZbmx);
+    }
+
+    @Override
+    public int deleteQyfxjcjgZbmx(String zbmxUuid) {
+        return crmQyfxjcjgZbmxMapper.deleteById(zbmxUuid);
+    }
+
+    @Override
+    public List<CrmQyfxjcjgZbmx> getQyfxjcjgZbmxList(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx) {
+        QueryWrapper<CrmQyfxjcjgZbmx> CrmQyfxjcjgZbmxQueryWrapper = new QueryWrapper<>();
+        return crmQyfxjcjgZbmxMapper.selectList(CrmQyfxjcjgZbmxQueryWrapper);
+    }
+}

crm/src/test/java/com/kakarote/crm/testQyjxfp.java

@@ -44,6 +44,12 @@ public class testQyjxfp {
     @Autowired
     private ICrmQycbrsService iCrmQycbrsService;
 
+    @Autowired
+    private ICrmQyfxjcjgService iCrmQyfxjcjgService;
+
+    @Autowired
+    private ICrmQyfxjcjgZbmxService iCrmQyfxjcjgZbmxService;
+
     @Test
     public void testCrmQyjxfpService() {
         CrmQyjxfp crmQyjxfp = new CrmQyjxfp();
@@ -346,34 +352,62 @@ public class testQyjxfp {
 
     }
 
+    @Test
+    public void testCrmQyfxjcjgService(){
+        CrmQyfxjcjg crmQyfxjcjg1 = new CrmQyfxjcjg();
+        crmQyfxjcjg1.setJcpcUuid("ddd").setQyid("fff").setQysbh("ddd").setFxjcPcjg("asd")
+                .setJcsj(new Date()).setJcSsqq(new Date()).setJcSsqz(new Date()).setNsrmc("ddd")
+                .setPljcId("HHH").setCreateBy("bb").setCreateTime(new Date()).setUpdateBy("cc").setUpdateTime(new Date());
+
+        CrmQyfxjcjg crmQyfxjcjg2 = new CrmQyfxjcjg();
+        crmQyfxjcjg2.setJcpcUuid("eee").setQyid("fff").setQysbh("ddd").setFxjcPcjg("asd")
+                .setJcsj(new Date()).setJcSsqq(new Date()).setJcSsqz(new Date()).setNsrmc("ddd")
+                .setPljcId("HHH").setCreateBy("bb").setCreateTime(new Date()).setUpdateBy("cc").setUpdateTime(new Date());
+
+        iCrmQyfxjcjgService.insertCrmQyfxjcjg(crmQyfxjcjg1);
+        iCrmQyfxjcjgService.insertCrmQyfxjcjg(crmQyfxjcjg2);
+
+        System.out.println(iCrmQyfxjcjgService.getQyfxjcjgList(crmQyfxjcjg1));
+
+        CrmQyfxjcjg crmQyfxjcjg3 = new CrmQyfxjcjg();
+        crmQyfxjcjg3.setJcpcUuid("eee").setQyid("123456").setQysbh("ddd").setFxjcPcjg("asd")
+                .setJcsj(new Date()).setJcSsqq(new Date()).setJcSsqz(new Date()).setNsrmc("ddd")
+                .setPljcId("HHH").setCreateBy("bb").setCreateTime(new Date()).setUpdateBy("cc").setUpdateTime(new Date());
+
+        iCrmQyfxjcjgService.updateCrmQyfxjcjg(crmQyfxjcjg3);
+
+        iCrmQyfxjcjgService.deleteCrmQyfxjcjg("ddd");
+
+        System.out.println(iCrmQyfxjcjgService.getCrmQyfxjcjg("eee"));
+    }
+
+    @Test
+    public void setCrmQyfxjcjgZbmxService() {
+        CrmQyfxjcjgZbmx crmQyfxjcjgZbmx1 = new CrmQyfxjcjgZbmx();
+        crmQyfxjcjgZbmx1.setZbmxUuid("QQQ").setJcpcUuid("eee").setFxzbDm("ttt").setFxzbJcjg("ggg")
+                .setJcsj(new Date()).setCode(200).setCreateBy("bb").setCreateTime(new Date()).setUpdateBy("cc").setUpdateTime(new Date());
+
+        CrmQyfxjcjgZbmx crmQyfxjcjgZbmx2 = new CrmQyfxjcjgZbmx();
+        crmQyfxjcjgZbmx2.setZbmxUuid("WWW").setJcpcUuid("rrr").setFxzbDm("ttt").setFxzbJcjg("ggg")
+                .setJcsj(new Date()).setCode(200).setCreateBy("bb").setCreateTime(new Date()).setUpdateBy("cc").setUpdateTime(new Date());
+
+        iCrmQyfxjcjgZbmxService.insertQyfxjcjgZbmx(crmQyfxjcjgZbmx1);
+        iCrmQyfxjcjgZbmxService.insertQyfxjcjgZbmx(crmQyfxjcjgZbmx2);
+
+        System.out.println(iCrmQyfxjcjgZbmxService.getQyfxjcjgZbmxList(crmQyfxjcjgZbmx1));
+
+        CrmQyfxjcjgZbmx crmQyfxjcjgZbmx3 = new CrmQyfxjcjgZbmx();
+        crmQyfxjcjgZbmx3.setZbmxUuid("QQQ").setJcpcUuid("zzz").setFxzbDm("zzz").setFxzbJcjg("zzz")
+                .setJcsj(new Date()).setCode(200).setCreateBy("bb").setCreateTime(new Date()).setUpdateBy("cc").setUpdateTime(new Date());
+
+        iCrmQyfxjcjgZbmxService.updateQyfxjcjgZbmx(crmQyfxjcjgZbmx3);
+
+        iCrmQyfxjcjgZbmxService.deleteQyfxjcjgZbmx("WWW");
+
+        System.out.println(iCrmQyfxjcjgZbmxService.getQyfxjcjgZbmx("QQQ"));
 
 
-
+    }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
 }