Merge remote-tracking branch 'origin/beta' into beta

beta-prop-all^2
yishiqihuasheng 2 years ago
commit 03d03dce71
  1. 21
      jianshui-invoice-all/src/main/java/com/jianshui/invoiceall/service/impl/AutonomousSqServiceImpl.java

@ -53,6 +53,7 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
*/ */
@Override @Override
public Object autonomousAuthorization(AutonomousAuthorizationDTO autonomousAuthorization) { public Object autonomousAuthorization(AutonomousAuthorizationDTO autonomousAuthorization) {
log.info("自主信息授权回调接口,入参:{}",JSONUtil.toJsonStr(autonomousAuthorization));
// 存流水号 // 存流水号
InvoiceAllLoginResult invoiceAllLoginResult = new InvoiceAllLoginResult(); InvoiceAllLoginResult invoiceAllLoginResult = new InvoiceAllLoginResult();
BeanUtil.copyProperties(autonomousAuthorization,invoiceAllLoginResult); BeanUtil.copyProperties(autonomousAuthorization,invoiceAllLoginResult);
@ -74,9 +75,11 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
@Override @Override
public AjaxResult qdLogin(InoviceAllQdLoginDTO inoviceAllQdLoginDTO) { public AjaxResult qdLogin(InoviceAllQdLoginDTO inoviceAllQdLoginDTO) {
// 全电登录 // 全电登录
log.info("全电登录接口,入参:{}",JSONUtil.toJsonStr(inoviceAllQdLoginDTO));
ValidateUtils.validate(inoviceAllQdLoginDTO); ValidateUtils.validate(inoviceAllQdLoginDTO);
Companyservice companyservice = companyserviceMapper.selectCompanyserviceByTaxcode(inoviceAllQdLoginDTO.getNsrsbh()); Companyservice companyservice = companyserviceMapper.selectCompanyserviceByTaxcode(inoviceAllQdLoginDTO.getNsrsbh());
if (BeanUtil.isEmpty(inoviceAllQdLoginDTO.getNsrInfo())) { if (BeanUtil.isEmpty(inoviceAllQdLoginDTO.getNsrInfo())) {
log.error("全电登录接口,传入报文错误,请检查,纳税人信息为空!");
return AjaxResult.error("传入报文错误,请检查,纳税人信息为空!"); return AjaxResult.error("传入报文错误,请检查,纳税人信息为空!");
} }
ValidateUtils.validate(inoviceAllQdLoginDTO.getNsrInfo()); ValidateUtils.validate(inoviceAllQdLoginDTO.getNsrInfo());
@ -85,8 +88,13 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
inoviceAllQdLoginDTO.setTraceno(qqlsh); inoviceAllQdLoginDTO.setTraceno(qqlsh);
try { try {
// 回调地址 // 回调地址
inoviceAllQdLoginDTO.setLoginType("1");
inoviceAllQdLoginDTO.setCallback("http://dev.goldentaxcloud.com:8081/api/invoice_all/v1/autonomousAuthorization"); inoviceAllQdLoginDTO.setCallback("http://dev.goldentaxcloud.com:8081/api/invoice_all/v1/autonomousAuthorization");
String result = HttpUtils.sendJsonPost("http://221.222.184.98:8880/login/getLogin2", inoviceAllQdLoginDTO); log.info("全电登录接口,请求上游,地址:{},参数:{}","http://221.222.184.98:8880/login/getLogin2",JSONUtil.toJsonStr(inoviceAllQdLoginDTO));
Thread requestThread = new Thread(() -> {
HttpUtils.sendJsonPost("http://221.222.184.98:8880/login/getLogin2", inoviceAllQdLoginDTO);
});
requestThread.start();
// 用户信息封装 // 用户信息封装
InvoiceAllYhdj yhdj = BeanUtil.copyProperties(inoviceAllQdLoginDTO, InvoiceAllYhdj.class); InvoiceAllYhdj yhdj = BeanUtil.copyProperties(inoviceAllQdLoginDTO, InvoiceAllYhdj.class);
yhdj.setDlsfmm(inoviceAllQdLoginDTO.getNsrInfo().getGsnsmm()); yhdj.setDlsfmm(inoviceAllQdLoginDTO.getNsrInfo().getGsnsmm());
@ -132,19 +140,23 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
*/ */
@Override @Override
public AjaxResult submitNote(InvoiceAllSubmitNoteDTO invoiceAllSubmitNoteDTO) { public AjaxResult submitNote(InvoiceAllSubmitNoteDTO invoiceAllSubmitNoteDTO) {
// 全电登录 log.info("自主授权短信提交接口,入参:{}",JSONUtil.toJsonStr(invoiceAllSubmitNoteDTO));
// 短信提交
ValidateUtils.validate(invoiceAllSubmitNoteDTO); ValidateUtils.validate(invoiceAllSubmitNoteDTO);
Companyservice companyservice = companyserviceMapper.selectCompanyserviceByTaxcode(invoiceAllSubmitNoteDTO.getNsrsbh()); Companyservice companyservice = companyserviceMapper.selectCompanyserviceByTaxcode(invoiceAllSubmitNoteDTO.getNsrsbh());
// 根据流水号获取登录结果 // 根据流水号获取登录结果
InvoiceAllLoginResult invoiceAllLogin = invoiceAllLoginResultMapper.findByQqlsh(invoiceAllSubmitNoteDTO.getTraceno()); InvoiceAllLoginResult invoiceAllLogin = invoiceAllLoginResultMapper.findByQqlsh(invoiceAllSubmitNoteDTO.getTraceno());
if (invoiceAllLogin == null){ if (invoiceAllLogin == null){
return AjaxResult.error("未查询到相关信息,请确认后输入"); log.info("自主授权短信提交接口,未查询到该流水号相关信息,请确认后输入");
return AjaxResult.error("未查询到该流水号相关信息,请确认后输入");
} }
if ("S000".equals(invoiceAllLogin.getCode())){ if ("S000".equals(invoiceAllLogin.getCode())){
JSONObject result = new JSONObject(); JSONObject result = new JSONObject();
try { try {
// 请求封装 // 请求封装
log.info("自主授权短信提交接口,请求上游地址:{},入参:{}","http://221.222.184.98:8880/login/submitSms",JSONUtil.toJsonStr(invoiceAllSubmitNoteDTO));
String sendFormPost = HttpUtils.sendJsonPost("http://221.222.184.98:8880/login/submitSms", invoiceAllSubmitNoteDTO); String sendFormPost = HttpUtils.sendJsonPost("http://221.222.184.98:8880/login/submitSms", invoiceAllSubmitNoteDTO);
log.info("自主授权短信提交接口,请求上游返回结果:{}",sendFormPost);
result = JSONUtil.parseObj(sendFormPost); result = JSONUtil.parseObj(sendFormPost);
String code = result.get("code") != null ? result.get("code").toString() : ""; String code = result.get("code") != null ? result.get("code").toString() : "";
String msg = result.get("msg") != null ? result.get("msg").toString() : ""; String msg = result.get("msg") != null ? result.get("msg").toString() : "";
@ -164,6 +176,7 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
invoiceAllApiLog.setRequestId(tokenId); invoiceAllApiLog.setRequestId(tokenId);
allApiLogMapper.insert(invoiceAllApiLog); allApiLogMapper.insert(invoiceAllApiLog);
} else { } else {
log.error("自主授权短信提交接口,提交短信失败,失败原因:{}",msg);
return AjaxResult.error(msg); return AjaxResult.error(msg);
} }
@ -172,8 +185,10 @@ public class AutonomousSqServiceImpl implements AutonomousSqService {
log.error("【金四服务类】【金财数科】【全电登录】API请求异常,外部报文返回code非S000。错误信息:{}", e.getMessage()); log.error("【金四服务类】【金财数科】【全电登录】API请求异常,外部报文返回code非S000。错误信息:{}", e.getMessage());
return AjaxResult.error(ErrorCode.INCOME_ERROR); return AjaxResult.error(ErrorCode.INCOME_ERROR);
} }
log.error("自主授权短信提交接口,提交短信成功,结果:{}",result);
return AjaxResult.success(result); return AjaxResult.success(result);
}else { }else {
log.error("自主授权短信提交接口,提交短信失败,失败原因:{}","登录失败,请重新登录");
return AjaxResult.error("登录失败,请重新登录"); return AjaxResult.error("登录失败,请重新登录");
} }
} }