diff --git a/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/ApplyServiceImpl.java b/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/ApplyServiceImpl.java index 1388b494..fe03e09c 100644 --- a/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/ApplyServiceImpl.java +++ b/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/ApplyServiceImpl.java @@ -160,6 +160,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e); } } } @@ -295,6 +296,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e); } } @@ -304,6 +306,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e1.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e1); } } } @@ -493,6 +496,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e); } } } @@ -612,6 +616,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e); } } @@ -621,6 +626,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e1.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e1); } } @@ -905,6 +911,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e); } } @@ -920,6 +927,7 @@ public class ApplyServiceImpl extends ServiceImpl implem tDxHttpLog.setStatus("2"); confirmDao.insert(tDxHttpLog); e1.printStackTrace(); + log.error("执行定时任务报错,报错信息是:{}",e1); } } } diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/dao/TdxPlatformCheckLogDao.java b/dxhy-erp/src/main/java/com/dxhy/erp/dao/TdxPlatformCheckLogDao.java new file mode 100644 index 00000000..a58164ba --- /dev/null +++ b/dxhy-erp/src/main/java/com/dxhy/erp/dao/TdxPlatformCheckLogDao.java @@ -0,0 +1,9 @@ +package com.dxhy.erp.dao; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.dxhy.erp.entity.TdxPlatformCheckLog; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface TdxPlatformCheckLogDao extends BaseMapper { +} diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/entity/TdxPlatformCheckLog.java b/dxhy-erp/src/main/java/com/dxhy/erp/entity/TdxPlatformCheckLog.java new file mode 100644 index 00000000..652e3302 --- /dev/null +++ b/dxhy-erp/src/main/java/com/dxhy/erp/entity/TdxPlatformCheckLog.java @@ -0,0 +1,34 @@ +package com.dxhy.erp.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +@Data +@TableName("t_dx_platform_check_log") +public class TdxPlatformCheckLog implements Serializable { + + private static final long serialVersionUID = -6703830991573450761L; + + //id + private Long id; + + //发票代码 + private String invoiceCode; + + //发票号码 + private String invoiceNo; + + //请求参数 + private String requesPrams; + + //返回结果 + private String returnResult; + + //查验时间 + private Date chaeckDate; + +} diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/service/TdxPlatformCheckLogService.java b/dxhy-erp/src/main/java/com/dxhy/erp/service/TdxPlatformCheckLogService.java new file mode 100644 index 00000000..31ec689f --- /dev/null +++ b/dxhy-erp/src/main/java/com/dxhy/erp/service/TdxPlatformCheckLogService.java @@ -0,0 +1,7 @@ +package com.dxhy.erp.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.dxhy.erp.entity.TdxPlatformCheckLog; + +public interface TdxPlatformCheckLogService extends IService { +} diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoiceAuthServiceImpl.java b/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoiceAuthServiceImpl.java index d1519048..1574d470 100644 --- a/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoiceAuthServiceImpl.java +++ b/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoiceAuthServiceImpl.java @@ -378,6 +378,7 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl0){ @@ -412,6 +413,7 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl implements TdxPlatformCheckLogService { +} diff --git a/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtCustomsController.java b/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtCustomsController.java index ed14aa94..564957a6 100644 --- a/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtCustomsController.java +++ b/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtCustomsController.java @@ -3,6 +3,7 @@ package com.dxhy.extend.controller; import com.dxhy.common.aspect.SysLog; import com.dxhy.common.constant.CommonConstants; import com.dxhy.common.controller.AbstractController; +import com.dxhy.common.util.StringHelper; import com.dxhy.common.util.UserInfoUtil; import com.dxhy.common.utils.DateUtils; import com.dxhy.common.utils.R; @@ -143,6 +144,11 @@ public class ExtCustomsController extends AbstractController { pramsMap.put("postingTimeEnd", DateUtils.getNight(DateUtils.strToDate(pramsMap.get("postingTimeEnd").toString()))); } + String companyCode = (String) pramsMap.get("companyCode"); + if (StringHelper.isNotBlank(companyCode) && "99".equals(companyCode)){ + pramsMap.put("companyCodes",getUserInfo().getCompanyCodes()); + log.info("组织编码为====>{}",pramsMap.get("companyCodes")); + } log.info("请求列表的参数为:{}",pramsMap); diff --git a/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtInvoicePoolController.java b/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtInvoicePoolController.java index 18177435..bbcb9f87 100644 --- a/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtInvoicePoolController.java +++ b/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtInvoicePoolController.java @@ -10,7 +10,9 @@ import javax.annotation.Resource; import com.dxhy.auth.client.annotation.IgnoreClientToken; import com.dxhy.auth.client.annotation.IgnoreUserToken; +import com.dxhy.common.util.StringHelper; import com.dxhy.common.vo.TaxOrgCode; +import com.dxhy.common.vo.UserInfo; import com.dxhy.extend.entity.PullRecordReq; import org.apache.commons.lang3.StringUtils; import org.springframework.http.ResponseEntity; @@ -97,6 +99,11 @@ public class ExtInvoicePoolController extends AbstractController { } int curr = (int)pramsMap.get("curr"); int size = (int)pramsMap.get("size"); + String companyCode = (String) pramsMap.get("companyCode"); + if (StringHelper.isNotBlank(companyCode) && "99".equals(companyCode)){ + pramsMap.put("companyCodes",getUserInfo().getCompanyCodes()); + log.info("组织机构====>{}",pramsMap.get("companyCodes")); + } try { return ResponseEntity.ok(R.ok().put("data", extInvoicePoolService.listAddTax(pramsMap, curr, size))); } catch (Exception e) { @@ -170,6 +177,11 @@ public class ExtInvoicePoolController extends AbstractController { pramsMap.put("accountPeriod", accountPeriod); log.info("accountPeriod:{}",accountPeriod); } + String companyCode = (String) pramsMap.get("companyCode"); + if (StringHelper.isNotBlank(companyCode) && "99".equals(companyCode)){ + pramsMap.put("companyCodes",getUserInfo().getCompanyCodes()); + log.info("组织编码===>{}", pramsMap.get("companyCodes")); + } int curr = (int)pramsMap.get("curr"); int size = (int)pramsMap.get("size"); try { @@ -231,6 +243,10 @@ public class ExtInvoicePoolController extends AbstractController { } int curr = (int)pramsMap.get("curr"); int size = (int)pramsMap.get("size"); + String companyCode = (String) pramsMap.get("companyCode"); + if (StringHelper.isNotBlank(companyCode) && "99".equals(companyCode)){ + pramsMap.put("companyCodes",getUserInfo().getCompanyCodes()); + } try { return ResponseEntity.ok(Objects .requireNonNull(R.ok().put("data", extInvoicePoolService.listSaleInvoice(pramsMap, curr, size)))); diff --git a/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtTicketController.java b/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtTicketController.java index 8fa2d27e..b9c93f64 100644 --- a/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtTicketController.java +++ b/dxhy-extend/src/main/java/com/dxhy/extend/controller/ExtTicketController.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject; import com.dxhy.common.aspect.SysLog; import com.dxhy.common.constant.CommonConstants; import com.dxhy.common.controller.AbstractController; +import com.dxhy.common.util.StringHelper; import com.dxhy.common.util.UserInfoUtil; import com.dxhy.common.utils.DateUtils; import com.dxhy.common.utils.R; @@ -60,6 +61,7 @@ public class ExtTicketController extends AbstractController { return ResponseEntity.ok(R.ok().put("data", "")); } } + paramsMap.put("gfsh",gfshList); if (paramsMap.get("invoiceType") != null && !"".equals(paramsMap.get("invoiceType")) && !"99".equals(paramsMap.get("invoiceType"))) { String[] invoiceTypeArr = paramsMap.get("invoiceType").toString().split(","); @@ -107,6 +109,11 @@ public class ExtTicketController extends AbstractController { } int curr = (int)paramsMap.get("curr"); int size = (int)paramsMap.get("size"); + String companyCode = (String) paramsMap.get("companyCode"); + if (StringHelper.isNotBlank(companyCode) && "99".equals(companyCode)){ + paramsMap.put("companyCodes",getUserInfo().getCompanyCodes()); + log.info("组织编码======>{}",paramsMap.get("companyCodes")); + } try { return ResponseEntity.ok(R.ok().put("data", ticketService.queryList(paramsMap, curr, size))); } catch (Exception e) { diff --git a/dxhy-extend/src/main/java/com/dxhy/extend/entity/ExtOtherInvoice.java b/dxhy-extend/src/main/java/com/dxhy/extend/entity/ExtOtherInvoice.java index c9ad1d03..47e9ec2e 100644 --- a/dxhy-extend/src/main/java/com/dxhy/extend/entity/ExtOtherInvoice.java +++ b/dxhy-extend/src/main/java/com/dxhy/extend/entity/ExtOtherInvoice.java @@ -71,4 +71,5 @@ public class ExtOtherInvoice implements Serializable { private String inAccountStatus; private String bzdh; private String snVoucherNumber; + private String compCode; } diff --git a/dxhy-extend/src/main/java/com/dxhy/extend/entity/JkszhcxRespVO.java b/dxhy-extend/src/main/java/com/dxhy/extend/entity/JkszhcxRespVO.java index 3323651f..08c888c9 100644 --- a/dxhy-extend/src/main/java/com/dxhy/extend/entity/JkszhcxRespVO.java +++ b/dxhy-extend/src/main/java/com/dxhy/extend/entity/JkszhcxRespVO.java @@ -195,4 +195,5 @@ public class JkszhcxRespVO { private String entryUser; private String filePath; private String businessName; + private String compCode; } diff --git a/dxhy-extend/src/main/java/com/dxhy/extend/service/companypool/TicketServiceImpl.java b/dxhy-extend/src/main/java/com/dxhy/extend/service/companypool/TicketServiceImpl.java index dd25bcf2..6626fe6b 100644 --- a/dxhy-extend/src/main/java/com/dxhy/extend/service/companypool/TicketServiceImpl.java +++ b/dxhy-extend/src/main/java/com/dxhy/extend/service/companypool/TicketServiceImpl.java @@ -45,12 +45,12 @@ public class TicketServiceImpl extends MpBaseServiceImpl + @@ -49,12 +50,13 @@ DATE_FORMAT(t.qs_date,'%Y-%m-%d') qs_date,t.qs_type,t.qs_user,DATE_FORMAT(t.rzh_date,'%Y-%m-%d') rzh_date, t.rzh_yesorno,t.auth_status,t.bdk_status,t.confirm_user,t.rzh_belong_date,t.glzt, t.customs_scan_id,t.dept_name businessName,t.in_account_status,t.voucher_number,t.document_number,t.in_account_date,rzh_type,rzlx,t.create_date, - data_sources,t.image_id,t.posting_time,t.account_period + data_sources,t.image_id,t.posting_time,t.account_period,t.comp_code from t_dx_customs_record t - where export_mark = '0' and t.gf_tax_no in - - #{item} - + where export_mark = '0' + + + + and t.customs_code like CONCAT('%',#{keyWord},'%') @@ -146,6 +148,20 @@ and t.account_period = #{accountPeriod} + + and (t.comp_code in + + #{companyCode} + + or t.comp_code is null or t.comp_code = '' + ) + + + and t.comp_code = #{companyCode} + + + and (t.comp_code = '' or t.comp_code is null) + order by t.fill_in_date desc @@ -155,10 +171,11 @@ count(1) hjsl, sum(t.tax_amount) hjse from t_dx_customs_record t - where export_mark = '0' and t.gf_tax_no in - - #{item} - + where export_mark = '0' + + + + and t.customs_code like CONCAT('%',#{keyWord},'%') @@ -250,6 +267,20 @@ and t.account_period = #{accountPeriod} + + and (t.comp_code in + + #{companyCode} + + or t.comp_code is null or t.comp_code = '' + ) + + + and t.comp_code = #{companyCode} + + + and (t.comp_code = '' or t.comp_code is null) + diff --git a/dxhy-extend/src/main/resources/mapper/ExtInvoicePoolMapper.xml b/dxhy-extend/src/main/resources/mapper/ExtInvoicePoolMapper.xml index c67ce42c..b53126ca 100644 --- a/dxhy-extend/src/main/resources/mapper/ExtInvoicePoolMapper.xml +++ b/dxhy-extend/src/main/resources/mapper/ExtInvoicePoolMapper.xml @@ -69,10 +69,10 @@ like CONCAT('%',#{keyWord},'%') - and t.gf_tax_no in - - #{item} - + + + + and t.invoice_type = #{invoiceType} @@ -130,6 +130,20 @@ and t.invoice_source = #{invoiceSource} + + and (t.comp_code in + + #{companyCode} + + or t.comp_code is null or t.comp_code = '' + ) + + + and t.comp_code = #{companyCode} + + + and (t.comp_code = '' or t.comp_code is null) + and t.invoice_type not in ('91','95','97','99','101','00') @@ -279,10 +308,10 @@ AND CONCAT(IFNULL(invoice_code,''),IFNULL(invoice_no,'')) like CONCAT('%',#{keyWord},'%') - AND gf_tax_no in - - #{item} - + + + + AND invoice_type = #{invoiceType} @@ -317,6 +346,20 @@ and sn_voucher_number = #{snVoucherNumber} + + and (comp_code in + + #{companyCode} + + or comp_code is null or comp_code = '' + ) + + + and comp_code = #{companyCode} + + + and (comp_code is null or comp_code = '') + GROUP BY uuid having min(create_date) ) t @@ -416,10 +474,10 @@ like CONCAT('%',#{keyWord},'%') - and t.xf_tax_no in - - #{item} - + + + + and t.invoice_type = #{invoiceType} @@ -481,6 +539,20 @@ and t.bzdh = #{bzdh} + + and (t.comp_code in + + #{companyCode} + + or t.comp_code is null or t.comp_code = '' + ) + + + and t.comp_code = #{companyCode} + + + and (t.comp_code = '' or t.comp_code is null) + diff --git a/dxhy-extend/src/main/resources/mapper/TicketMapper.xml b/dxhy-extend/src/main/resources/mapper/TicketMapper.xml index 6323d1c1..c3f6c37e 100644 --- a/dxhy-extend/src/main/resources/mapper/TicketMapper.xml +++ b/dxhy-extend/src/main/resources/mapper/TicketMapper.xml @@ -26,10 +26,10 @@ and CONCAT(IFNULL(t.passenger,''),IFNULL(t.passenger_s_f_z_h,'')) like CONCAT('%',#{keyWord},'%') - and t.gf_tax_no in - - #{item} - + + + + and t.invoice_type in @@ -72,6 +72,20 @@ and t.sn_voucher_number = #{snVoucherNumber} + + and (t.comp_code in + + #{companyCode} + + or t.comp_code is null or t.comp_code = '' + ) + + + and t.comp_code = #{companyCode} + + + and (t.comp_code is null or t.comp_code = '') + @@ -90,10 +104,10 @@ and CONCAT(IFNULL(t.passenger,''),IFNULL(t.passenger_s_f_z_h,'')) like CONCAT('%',#{keyWord},'%') - and t.gf_tax_no in - - #{item} - + + + + and t.invoice_type in @@ -136,5 +150,19 @@ and t.sn_voucher_number = #{snVoucherNumber} + + and (t.comp_code in + + #{companyCode} + + or t.comp_code is null or t.comp_code = '' + ) + + + and t.comp_code = #{companyCode} + + + and (t.comp_code is null or t.comp_code = '') +