From 29dc79cda80a592b6f85776e5634b8112788010c Mon Sep 17 00:00:00 2001 From: ZZM <1105966949@qq.com> Date: Wed, 11 Jun 2025 17:49:52 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E8=B0=83=E7=94=A8V3=E7=B3=BB=E7=BB=9F?= =?UTF-8?q?=E7=9A=84=E9=A3=8E=E9=99=A9=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../CrmGetV3SysRiskDataController.java | 76 ++++++++++++++++ .../crm/entity/VO/CrmApiResponseVO.java | 17 ++++ .../crm/entity/VO/CrmRiskCheckResultVO.java | 22 +++++ .../crm/entity/VO/CrmV3SystemicRiskVO.java | 18 ++++ .../crm/mapper/CrmQyfxjcjgMapper.java | 12 +++ .../crm/mapper/CrmQyfxjcjgZbmxMapper.java | 12 +++ .../crm/service/ICrmQyfxjcjgService.java | 42 +++++++++ .../crm/service/ICrmQyfxjcjgZbmxService.java | 42 +++++++++ .../service/impl/CrmQyfxjcjgServiceImpl.java | 44 ++++++++++ .../impl/CrmQyfxjcjgZbmxServiceImpl.java | 43 ++++++++++ .../java/com/kakarote/crm/testQyjxfp.java | 86 +++++++++++++------ 11 files changed, 388 insertions(+), 26 deletions(-) create mode 100644 crm/src/main/java/com/kakarote/crm/controller/CrmGetV3SysRiskDataController.java create mode 100644 crm/src/main/java/com/kakarote/crm/entity/VO/CrmApiResponseVO.java create mode 100644 crm/src/main/java/com/kakarote/crm/entity/VO/CrmRiskCheckResultVO.java create mode 100644 crm/src/main/java/com/kakarote/crm/entity/VO/CrmV3SystemicRiskVO.java create mode 100644 crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgMapper.java create mode 100644 crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgZbmxMapper.java create mode 100644 crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgService.java create mode 100644 crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgZbmxService.java create mode 100644 crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgServiceImpl.java create mode 100644 crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgZbmxServiceImpl.java diff --git a/crm/src/main/java/com/kakarote/crm/controller/CrmGetV3SysRiskDataController.java b/crm/src/main/java/com/kakarote/crm/controller/CrmGetV3SysRiskDataController.java new file mode 100644 index 0000000..7d9af2e --- /dev/null +++ b/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); + } + } + + +} diff --git a/crm/src/main/java/com/kakarote/crm/entity/VO/CrmApiResponseVO.java b/crm/src/main/java/com/kakarote/crm/entity/VO/CrmApiResponseVO.java new file mode 100644 index 0000000..d406dd1 --- /dev/null +++ b/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 data; // data是对象数组 +} diff --git a/crm/src/main/java/com/kakarote/crm/entity/VO/CrmRiskCheckResultVO.java b/crm/src/main/java/com/kakarote/crm/entity/VO/CrmRiskCheckResultVO.java new file mode 100644 index 0000000..d10ff73 --- /dev/null +++ b/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 crmQyfxjcjgZbmxList; +} diff --git a/crm/src/main/java/com/kakarote/crm/entity/VO/CrmV3SystemicRiskVO.java b/crm/src/main/java/com/kakarote/crm/entity/VO/CrmV3SystemicRiskVO.java new file mode 100644 index 0000000..1ad6d87 --- /dev/null +++ b/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"; + } +} diff --git a/crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgMapper.java b/crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgMapper.java new file mode 100644 index 0000000..aa8f5d0 --- /dev/null +++ b/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 { + List selectByExample(CrmQyfxjcjg example); +} diff --git a/crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgZbmxMapper.java b/crm/src/main/java/com/kakarote/crm/mapper/CrmQyfxjcjgZbmxMapper.java new file mode 100644 index 0000000..07cae98 --- /dev/null +++ b/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 { + List selectByExample(CrmQyfxjcjgZbmx example); +} diff --git a/crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgService.java b/crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgService.java new file mode 100644 index 0000000..ef5cfbf --- /dev/null +++ b/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 { + + /** + * 通过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 getQyfxjcjgList(CrmQyfxjcjg crmQyfxjcjg); +} diff --git a/crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgZbmxService.java b/crm/src/main/java/com/kakarote/crm/service/ICrmQyfxjcjgZbmxService.java new file mode 100644 index 0000000..45c6de1 --- /dev/null +++ b/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 { + + /** + * 通过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 getQyfxjcjgZbmxList(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx); +} diff --git a/crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgServiceImpl.java b/crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgServiceImpl.java new file mode 100644 index 0000000..db2fd98 --- /dev/null +++ b/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 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 getQyfxjcjgList(CrmQyfxjcjg crmQyfxjcjg) { + QueryWrapper CrmQyfxjcjgQueryWrapper = new QueryWrapper<>(); + return crmQyfxjcjgMapper.selectList(CrmQyfxjcjgQueryWrapper); + } +} diff --git a/crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgZbmxServiceImpl.java b/crm/src/main/java/com/kakarote/crm/service/impl/CrmQyfxjcjgZbmxServiceImpl.java new file mode 100644 index 0000000..0cbe6f0 --- /dev/null +++ b/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 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 getQyfxjcjgZbmxList(CrmQyfxjcjgZbmx crmQyfxjcjgZbmx) { + QueryWrapper CrmQyfxjcjgZbmxQueryWrapper = new QueryWrapper<>(); + return crmQyfxjcjgZbmxMapper.selectList(CrmQyfxjcjgZbmxQueryWrapper); + } +} diff --git a/crm/src/test/java/com/kakarote/crm/testQyjxfp.java b/crm/src/test/java/com/kakarote/crm/testQyjxfp.java index 632decd..4705f5e 100644 --- a/crm/src/test/java/com/kakarote/crm/testQyjxfp.java +++ b/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")); - - - - - - - - - - - - - - - - - - - - - - - - - - + } }