root
/
jianshui-all
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

自主授权接口开发

Browse Source
beta-prop-all^2
kane 2 years ago
parent bfd379cc3a
commit ed41b4fa12
5 changed files with 156 additions and 116 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 9
      jianshui-admin/src/main/java/com/jianshui/api/controller/http/invoiceall/v1/InvoiceAllController.java
  2. 7
      jianshui-invoice-all/src/main/java/com/jianshui/invoiceall/service/AutonomousSqService.java
  3. 48
      jianshui-invoice-all/src/main/java/com/jianshui/invoiceall/service/impl/AutonomousSqServiceImpl.java
  4. 2
      jianshui-system/src/main/java/com/jianshui/system/mapper/InvoiceAllLoginResultMapper.java

9
jianshui-admin/src/main/java/com/jianshui/api/controller/http/invoiceall/v1/InvoiceAllController.java
Unescape View File

@ -91,6 +91,15 @@ public class InvoiceAllController {
return autonomousSqService.submitNote(invoiceAllSubmitNoteDTO);
}
@ApiOperation("获取提交短信验证码结果")
@ApiImplicitParams({
@ApiImplicitParam(name = "identity", value = "身份认证", dataType = "java.lang.Void", example = "1130", required = true),
@ApiImplicitParam(name = "inoviceAllQdLoginDTO", value = "请求体",dataType = "java.lang.Void", required = true)})
@PostMapping("/api/invoice_all/v1/submitNoteResult")
public Object submitNoteResult(@RequestBody InvoiceAllSubmitNoteDTO invoiceAllSubmitNoteDTO) throws Exception{
return autonomousSqService.submitNoteResult(invoiceAllSubmitNoteDTO);
}
@ApiOperation("用户登记接口")

7
jianshui-invoice-all/src/main/java/com/jianshui/invoiceall/service/AutonomousSqService.java
Unescape View File

@ -33,4 +33,11 @@ public interface AutonomousSqService {
* @return : java.lang.Object
*/
Object autonomousAuthorization(AutonomousAuthorizationDTO autonomousAuthorization);
/**
* 功能描述: 获取短信验证结果
* @param invoiceAllSubmitNoteDTO
* @return : java.lang.Object
*/
Object submitNoteResult(InvoiceAllSubmitNoteDTO invoiceAllSubmitNoteDTO);
}

48
jianshui-invoice-all/src/main/java/com/jianshui/invoiceall/service/impl/AutonomousSqServiceImpl.java
Unescape View File

@ -2,7 +2,6 @@ package com.jianshui.invoiceall.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.jianshui.common.core.domain.AjaxResult;
@ -26,6 +25,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.List;
/**
* @author xingze
@ -67,6 +67,29 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
return AjaxResult.success();
}
/**
* 功能描述: 获取短信验证结果
* @param invoiceAllSubmitNoteDTO
* @return : java.lang.Object
*/
@Override
public Object submitNoteResult(InvoiceAllSubmitNoteDTO invoiceAllSubmitNoteDTO) {
log.info("获取短信验证结果入口，入参：{}", JSONUtil.toJsonStr(invoiceAllSubmitNoteDTO));
// 短信提交
ValidateUtils.validate(invoiceAllSubmitNoteDTO);
List<InvoiceAllLoginResult> invoiceAllLoginResultList = invoiceAllLoginResultMapper.findByQqlsh(invoiceAllSubmitNoteDTO.getTraceno());
if (invoiceAllLoginResultList == null || invoiceAllLoginResultList.size() <= 0) {
log.info("自主授权短信提交接口，未查询到该流水号相关信息，请确认后输入");
return AjaxResult.error("未查询到该流水号相关信息，请确认后输入");
}
for (InvoiceAllLoginResult invoiceAllLoginResult : invoiceAllLoginResultList) {
if ("S000".equals(invoiceAllLoginResult.getCode())){
return AjaxResult.success();
}
}
return AjaxResult.error();
}
/**
* 功能描述: 全电登录
*
@ -145,29 +168,30 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
// 短信提交
ValidateUtils.validate(invoiceAllSubmitNoteDTO);
// 根据流水号获取登录结果
InvoiceAllLoginResult invoiceAllLogin = invoiceAllLoginResultMapper.findByQqlsh(invoiceAllSubmitNoteDTO.getTraceno());
if (invoiceAllLogin == null) {
List<InvoiceAllLoginResult> invoiceAllLoginResultList = invoiceAllLoginResultMapper.findByQqlsh(invoiceAllSubmitNoteDTO.getTraceno());
if (invoiceAllLoginResultList == null || invoiceAllLoginResultList.size() <= 0) {
log.info("自主授权短信提交接口，未查询到该流水号相关信息，请确认后输入");
return AjaxResult.error("未查询到该流水号相关信息，请确认后输入");
}
JSONObject result = null;
if ("SMS".equals(invoiceAllLogin.getCode())) {
for (InvoiceAllLoginResult invoiceAllLoginResult : invoiceAllLoginResultList) {
if ("SMS".equals(invoiceAllLoginResult.getCode())) {
try {
// 请求封装
log.info("自主授权短信提交接口，请求上游地址：{}，入参：{}", "http://221.222.184.98:8880/login/submitSms", JSONUtil.toJsonStr(invoiceAllSubmitNoteDTO));
String sendResult = HttpUtils.sendJsonPost("http://221.222.184.98:8880/login/submitSms", invoiceAllSubmitNoteDTO);
result = JSONUtil.parseObj(sendResult);
log.info("自主授权短信提交接口，请求上游结果：{}",result);
Thread requestThread = new Thread(() -> {
HttpUtils.sendJsonPost("http://221.222.184.98:8880/login/submitSms", invoiceAllSubmitNoteDTO);
});
requestThread.start();
} catch (Exception e) {
e.printStackTrace();
log.error("【金四服务类】【金财数科】【自主授权提交短信验证码】API请求异常，外部报文返回code非S000。错误信息:{}", e.getMessage());
return AjaxResult.error(ErrorCode.INCOME_ERROR);
}
return AjaxResult.success(result);
} else {
log.error("自主授权短信提交接口，提交短信失败，失败原因：{}", "登录失败，请重新登录");
return AjaxResult.error("登录失败，请重新登录");
log.error("自主授权短信提交接口，提交短信失败，失败原因：{}", "登录失败，请重新授权登录");
return AjaxResult.error("登录失败，请重新授权登录");
}
}
return AjaxResult.success();
}
}

2
jianshui-system/src/main/java/com/jianshui/system/mapper/InvoiceAllLoginResultMapper.java
Unescape View File

@ -65,5 +65,5 @@ public interface InvoiceAllLoginResultMapper
* @param qqlsh
* @return : com.jianshui.system.domain.InvoiceAllLoginResult
*/
InvoiceAllLoginResult findByQqlsh(@Param("qqlsh") String qqlsh);
List<InvoiceAllLoginResult> findByQqlsh(@Param("qqlsh") String qqlsh);
}