From 281c6016ab0ea5b2eeecb9167d9ee690b6fdac1f Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期五, 04 七月 2025 17:17:06 +0800
Subject: [PATCH] 三方对接

---
 ruoyi-applet/src/main/java/com/ruoyi/web/controller/system/CompanyController.java |   76 ++++++++++++++++++++++++++++++++++----
 1 files changed, 68 insertions(+), 8 deletions(-)

diff --git a/ruoyi-applet/src/main/java/com/ruoyi/web/controller/system/CompanyController.java b/ruoyi-applet/src/main/java/com/ruoyi/web/controller/system/CompanyController.java
index 484c291..4aa39d2 100644
--- a/ruoyi-applet/src/main/java/com/ruoyi/web/controller/system/CompanyController.java
+++ b/ruoyi-applet/src/main/java/com/ruoyi/web/controller/system/CompanyController.java
@@ -5,11 +5,15 @@
 import cn.hutool.http.HttpRequest;
 import cn.hutool.http.HttpResponse;
 import cn.hutool.http.HttpUtil;
+import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fasterxml.jackson.databind.JsonNode;
 import com.ruoyi.common.core.domain.BasePage;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.domain.model.LoginUser;
+import com.ruoyi.common.core.redis.RedisCache;
+import com.ruoyi.common.utils.QiChaChaUtil;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.http.HttpUtils;
 import com.ruoyi.framework.web.service.TokenService;
@@ -36,7 +40,7 @@
 
 @Slf4j
 @RestController
-@RequestMapping("/user")
+@RequestMapping("/company")
 @Api(tags = "发布模块")
 public class CompanyController {
 
@@ -63,6 +67,12 @@
 
     @Autowired
     private TbCompanyTypeService companyTypeService;
+
+
+    @Autowired
+    private QiChaChaUtil qiChaChaUtil;
+
+
 
 
 
@@ -101,23 +111,51 @@
     public R<?> pushCompany(@Valid @RequestBody PushCompanyDto dto) {
         LoginUser loginUser = tokenService.getLoginUser();
         Long userId = loginUser.getUserId();
+        long count = tbCompanyService.count(new LambdaQueryWrapper<TbCompany>().eq(TbCompany::getCompanyName, dto.getCompanyName()).ne(TbCompany::getStatus, 3));
+        if (count > 0) {
+            return R.fail("该公司已发布");
+        }
         tbCompanyService.pushCompany(dto,userId);
         return R.ok();
     }
+
+    @ApiOperation(value = "发布前获取公司信息--企查查",tags = {"发布模块"})
+    @GetMapping("/getCompanyFromQiChaCha")
+    public R<Object> getCompanyFromQiChaCha(@RequestParam String companyName) {
+        long count = tbCompanyService.count(new LambdaQueryWrapper<TbCompany>().eq(TbCompany::getCompanyName,companyName).ne(TbCompany::getStatus, 3));
+        if (count > 0) {
+            return R.fail("该公司已发布");
+        }
+        Object qiChaChaToken = QiChaChaUtil.getQiChaChaCompanyInfo(companyName);
+        if(qiChaChaToken==null){
+            return R.fail("查询公司信息失败请联系客服");
+        }
+        return R.ok(qiChaChaToken);
+    }
+
+
 
     @ApiOperation(value = "编辑公司",tags = {"发布模块"})
     @PostMapping("/editCompany")
     public R<?> editCompany(@Valid @RequestBody EditCompanyDto dto) {
         LoginUser loginUser = tokenService.getLoginUser();
         Long userId = loginUser.getUserId();
+
         TbCompany company = tbCompanyService.getById(dto.getId());
         if (company == null || !company.getUserId().equals(userId.toString())) {
             return R.fail("非法操作");
         }
+
+        long count1 = tbCompanyService.count(new LambdaQueryWrapper<TbCompany>().eq(TbCompany::getCompanyName, dto.getCompanyName()).ne(TbCompany::getId,dto.getId()).ne(TbCompany::getStatus, 3));
+        if (count1 > 0) {
+            return R.fail("该公司已发布");
+        }
+
         long count = orderService.count(new LambdaQueryWrapper<TbOrder>().eq(TbOrder::getCompanyId, dto.getId()).in(TbOrder::getStatus, 3, 4, 5));
         if (count > 0) {
             return R.fail("订单状态不能修改");
         }
+
         tbCompanyService.editCompany(dto,company,userId);
         return R.ok();
     }
@@ -222,18 +260,18 @@
     }
 
 
-    public static void main(String[] args) {
+
+    private static Object getReport(String sign){
         HttpRequest post = HttpUtil.createPost("https://shuimui.szsmjr.com/index/index/result");
         HashMap<String, String> stringStringHashMap = new HashMap<>();
         stringStringHashMap.put("Origin","https://shuimui.szsmjr.com");
         post.addHeaders(stringStringHashMap);
-        post.body("{\"sn\":\""+"ZZD20250321019744801521301"+"\"}");
+        post.body("{\"sn\":\""+sign+"\"}");
         HttpResponse execute = post.execute();
-        System.out.println(execute.body());
+        String body = execute.body();
+        JSONObject jsonObject = JSONObject.parseObject(body);
+        return jsonObject;
     }
-
-
-
 
     @ApiOperation(value = "已完成",tags = {"发布模块"})
     @PostMapping("/saleSuccessOrder")
@@ -265,15 +303,37 @@
 
     @ApiOperation(value = "公司详情",tags = {"发布模块"})
     @GetMapping("/companyDetail")
-    public R<CompanyDetailVo> companyDetail(@RequestParam String companyId) {
+    public R<CompanyDetailVo> companyDetail(@RequestParam String companyId) throws Exception {
         if(StringUtils.isEmpty(companyId)){
             return R.fail("参数错误");
         }
         LoginUser loginUser = tokenService.getLoginUser();
         Long userId = loginUser.getUserId();
         CompanyDetailVo companyDetailVo = tbCompanyService.companyDetail(companyId,userId);
+        Object qiChaChaCompanyExceptionCheck = QiChaChaUtil.getQiChaChaCompanyExceptionCheck(companyDetailVo.getCompanyName());
+        companyDetailVo.setCompanyExceptionInfo(qiChaChaCompanyExceptionCheck);
+
         return R.ok(companyDetailVo);
     }
 
+    @ApiOperation(value = "公司详情--财务征信信息",tags = {"发布模块"})
+    @GetMapping("/companyDetailDataInfo")
+    public R<Object> companyDetailDataInfo(@RequestParam String companyId) {
+        if(StringUtils.isEmpty(companyId)){
+            return R.fail("参数错误");
+        }
+        TbCompany company = tbCompanyService.getById(companyId);
+        String link = company.getLink();
+        String sign = link.split("=")[1];
+        Object report = getReport(sign);
+        return R.ok(report);
+    }
+
+
+
+
+
+
+
 
 }

--
Gitblit v1.7.1