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 | 106 +++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 103 insertions(+), 3 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 1d917d6..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 @@ -1,12 +1,21 @@ package com.ruoyi.web.controller.system; +import cn.hutool.core.map.MapUtil; +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; import com.ruoyi.system.dto.*; import com.ruoyi.system.model.*; @@ -25,11 +34,13 @@ import org.springframework.web.bind.annotation.*; import javax.validation.Valid; +import java.util.Date; +import java.util.HashMap; import java.util.List; @Slf4j @RestController -@RequestMapping("/user") +@RequestMapping("/company") @Api(tags = "发布模块") public class CompanyController { @@ -51,6 +62,18 @@ @Autowired private TbMessageService messageService; + @Autowired + private TbLicenceService licenceService; + + @Autowired + private TbCompanyTypeService companyTypeService; + + + @Autowired + private QiChaChaUtil qiChaChaUtil; + + + @ApiOperation(value = "获取我发布的公司",tags = {"发布模块"}) @@ -69,28 +92,70 @@ return R.ok(page1); } + @ApiOperation(value = "获取公司类型信息",tags = {"发布模块"}) + @GetMapping("/getCompanyTypeList") + public R<Page<TbCompanyType>> getCompanyTypeList(BasePage page) { + Page<TbCompanyType> page1 = companyTypeService.page(new Page<>(page.getPageNum(),page.getPageSize()),new LambdaQueryWrapper<TbCompanyType>().eq(TbCompanyType::getDelFlag,0).orderByDesc(TbCompanyType::getOrderNum)); + return R.ok(page1); + } + + @ApiOperation(value = "获取许可证信息",tags = {"发布模块"}) + @GetMapping("/getLicenceList") + public R<Page<TbLicence>> getLicenceList(BasePage page) { + Page<TbLicence> page1 = licenceService.page(new Page<>(page.getPageNum(),page.getPageSize()),new LambdaQueryWrapper<TbLicence>().eq(TbLicence::getDelFlag,0).orderByDesc(TbLicence::getOrderNum)); + return R.ok(page1); + } + @ApiOperation(value = "立即发布",tags = {"发布模块"}) @PostMapping("/pushCompany") 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(); } @@ -137,7 +202,9 @@ return R.fail("该订单状态不需要确认"); } order.setStatus(3); + order.setConfirmTime(new Date()); order.updateById(); + return R.ok(); } @@ -194,7 +261,17 @@ - + 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\":\""+sign+"\"}"); + HttpResponse execute = post.execute(); + String body = execute.body(); + JSONObject jsonObject = JSONObject.parseObject(body); + return jsonObject; + } @ApiOperation(value = "已完成",tags = {"发布模块"}) @PostMapping("/saleSuccessOrder") @@ -216,6 +293,7 @@ return R.fail("该订单状态不能完成"); } order.setStatus(5); + order.setSellerFinishTime(new Date()); order.updateById(); messageService.addMessage("您有订单卖家已完成,等待确认", order.getUserId(),orderId); @@ -225,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