luminghui
/
sdny-jxpt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ariesy 增加判断区块链发票推送逻辑

Browse Source
release
yefei 2 years ago
parent 7a7582c6b9
commit 5457730f88
1 changed files with 124 additions and 144 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. 268
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoiceAuthServiceImpl.java

268
dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoiceAuthServiceImpl.java
Unescape View File

@ -43,7 +43,7 @@ import java.util.stream.Collectors;
@Service @Service
@Slf4j @Slf4j
public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao, RecordInvoice> public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao, RecordInvoice>
implements InvoiceAuthService { implements InvoiceAuthService {
@Resource @Resource
AuthRecordDao authRecordDao; AuthRecordDao authRecordDao;
@ -58,7 +58,7 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
@Override @Override
public String applyInvoiceAuth(GlobalInfo globalInfo, Map<String, String> map, HttpServletRequest request, public String applyInvoiceAuth(GlobalInfo globalInfo, Map<String, String> map, HttpServletRequest request,
HttpServletResponse response, Authorize authorize) { HttpServletResponse response, Authorize authorize) {
ReturnStateInfo run = new ReturnStateInfo(); ReturnStateInfo run = new ReturnStateInfo();
InterfaceCode interfaceCode = new InterfaceCode(); InterfaceCode interfaceCode = new InterfaceCode();
AuthDateReq data = null; AuthDateReq data = null;
@ -85,7 +85,7 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
interfaceCode.setReturnStateInfo(run); interfaceCode.setReturnStateInfo(run);
return JSON.toJSONString(interfaceCode); return JSON.toJSONString(interfaceCode);
} }
List<Map<String, Object>> authStateList = (List<Map<String, Object>>)data.getInvoices(); List<Map<String, Object>> authStateList = (List<Map<String, Object>>) data.getInvoices();
run = getCheckData(authStateList, data.getContentRows()); run = getCheckData(authStateList, data.getContentRows());
if (run.getReturnCode() != null || run.getReturnMessage() != null) { if (run.getReturnCode() != null || run.getReturnMessage() != null) {
interfaceCode.setReturnStateInfo(run); interfaceCode.setReturnStateInfo(run);
@ -125,39 +125,39 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
} }
for (Map<String, Object> authState : authStateList) { for (Map<String, Object> authState : authStateList) {
DynamicContextHolder.push(dbName + DbConstant.BUSINESS_READ); DynamicContextHolder.push(dbName + DbConstant.BUSINESS_READ);
TdxRecordInvoice recordInvoice = tDxrecordInvoiceDao.getRecordInvoice((String)authState.get("buyerTaxNo"), TdxRecordInvoice recordInvoice = tDxrecordInvoiceDao.getRecordInvoice((String) authState.get("buyerTaxNo"),
(String)authState.get("invoiceCode"), (String)authState.get("invoiceNo")); (String) authState.get("invoiceCode"), (String) authState.get("invoiceNo"));
DynamicContextHolder.push(dbName + DbConstant.BUSINESS_WRITE); DynamicContextHolder.push(dbName + DbConstant.BUSINESS_WRITE);
if (recordInvoice != null) { if (recordInvoice != null) {
if ("01".equals(recordInvoice.getInvoiceType()) || "03".equals(recordInvoice.getInvoiceType()) if ("01".equals(recordInvoice.getInvoiceType()) || "03".equals(recordInvoice.getInvoiceType())
|| "08".equals(recordInvoice.getInvoiceType()) || "14".equals(recordInvoice.getInvoiceType()) || "08".equals(recordInvoice.getInvoiceType()) || "14".equals(recordInvoice.getInvoiceType())
|| "31".equals(recordInvoice.getInvoiceType())) { || "31".equals(recordInvoice.getInvoiceType())) {
if ("5".equals(data.getApplyRzlx())) { if ("5".equals(data.getApplyRzlx())) {
if (!"4".equals(recordInvoice.getCxrzStatus()) && !"2".equals(recordInvoice.getCxrzStatus()) if (!"4".equals(recordInvoice.getCxrzStatus()) && !"2".equals(recordInvoice.getCxrzStatus())
&& !"1".equals(recordInvoice.getCxrzStatus())) { && !"1".equals(recordInvoice.getCxrzStatus())) {
String invoiceCode = StringUtils.isBlank((String)authState.get("invoiceCode"))?"":(String)authState.get("invoiceCode"); String invoiceCode = StringUtils.isBlank((String) authState.get("invoiceCode")) ? "" : (String) authState.get("invoiceCode");
tDxrecordInvoiceDao.updateCxrz((String)authState.get("applyTaxPeriod"), tDxrecordInvoiceDao.updateCxrz((String) authState.get("applyTaxPeriod"),
invoiceCode+ (String)authState.get("invoiceNo")); invoiceCode + (String) authState.get("invoiceNo"));
} }
} else if ("6".equals(data.getApplyRzlx())) { } else if ("6".equals(data.getApplyRzlx())) {
if (!"4".equals(recordInvoice.getCxbdkStatus()) && !"2".equals(recordInvoice.getCxbdkStatus()) if (!"4".equals(recordInvoice.getCxbdkStatus()) && !"2".equals(recordInvoice.getCxbdkStatus())
&& !"1".equals(recordInvoice.getCxrzStatus())) { && !"1".equals(recordInvoice.getCxrzStatus())) {
String invoiceCode = StringUtils.isBlank((String)authState.get("invoiceCode"))?"":(String)authState.get("invoiceCode"); String invoiceCode = StringUtils.isBlank((String) authState.get("invoiceCode")) ? "" : (String) authState.get("invoiceCode");
tDxrecordInvoiceDao.updateCxbdk((String)authState.get("applyTaxPeriod"), tDxrecordInvoiceDao.updateCxbdk((String) authState.get("applyTaxPeriod"),
invoiceCode + (String)authState.get("invoiceNo")); invoiceCode + (String) authState.get("invoiceNo"));
} }
} else { } else {
if (!"4".equals(recordInvoice.getAuthStatus()) && !"3".equals(recordInvoice.getAuthStatus()) if (!"4".equals(recordInvoice.getAuthStatus()) && !"3".equals(recordInvoice.getAuthStatus())
&& !"2".equals(recordInvoice.getAuthStatus())) { && !"2".equals(recordInvoice.getAuthStatus())) {
if ("1".equals(data.getApplyRzlx())) { if ("1".equals(data.getApplyRzlx())) {
tDxrecordInvoiceDao.updateRz(authState, data.getApplyRzlx(), "1", tDxrecordInvoiceDao.updateRz(authState, data.getApplyRzlx(), "1",
recordInvoice.getUuid()); recordInvoice.getUuid());
} else if ("4".equals(data.getApplyRzlx())) { } else if ("4".equals(data.getApplyRzlx())) {
tDxrecordInvoiceDao.updateRz(authState, data.getApplyRzlx(), "2", tDxrecordInvoiceDao.updateRz(authState, data.getApplyRzlx(), "2",
recordInvoice.getUuid()); recordInvoice.getUuid());
} else { } else {
tDxrecordInvoiceDao.updateRz(authState, data.getApplyRzlx(), "99", tDxrecordInvoiceDao.updateRz(authState, data.getApplyRzlx(), "99",
recordInvoice.getUuid()); recordInvoice.getUuid());
} }
} }
} }
@ -178,17 +178,17 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
for (Map<String, Object> map : list) { for (Map<String, Object> map : list) {
AuthRecord authRecord = new AuthRecord(); AuthRecord authRecord = new AuthRecord();
authRecord.setBatchNo(batchNo); authRecord.setBatchNo(batchNo);
authRecord.setInvoiceCode((String)map.get("invoiceCode")); authRecord.setInvoiceCode((String) map.get("invoiceCode"));
authRecord.setInvoiceNo((String)map.get("invoiceNo")); authRecord.setInvoiceNo((String) map.get("invoiceNo"));
authRecord.setUuid(map.get("invoiceCode") + (String)map.get("invoiceNo")); authRecord.setUuid(map.get("invoiceCode") + (String) map.get("invoiceNo"));
if (StringUtils.isBlank(rzlx)) { if (StringUtils.isBlank(rzlx)) {
authRecord.setRzlx("1"); authRecord.setRzlx("1");
} else { } else {
authRecord.setRzlx(rzlx); authRecord.setRzlx(rzlx);
} }
authRecord.setApplyTaxPeriod((String)map.get("applyTaxPeriod")); authRecord.setApplyTaxPeriod((String) map.get("applyTaxPeriod"));
authRecord.setBuyerTaxNo((String)map.get("buyerTaxNo")); authRecord.setBuyerTaxNo((String) map.get("buyerTaxNo"));
authRecord.setYxse((String)map.get("taxCredit")); authRecord.setYxse((String) map.get("taxCredit"));
authRecord.setCreateDate(new Date()); authRecord.setCreateDate(new Date());
authRecordList.add(authRecord); authRecordList.add(authRecord);
} }
@ -197,7 +197,7 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
@Override @Override
public String getAuthResult(GlobalInfo globalInfo, Map<String, String> map, HttpServletRequest request, public String getAuthResult(GlobalInfo globalInfo, Map<String, String> map, HttpServletRequest request,
HttpServletResponse response, Authorize authorize) { HttpServletResponse response, Authorize authorize) {
ReturnStateInfo run = new ReturnStateInfo(); ReturnStateInfo run = new ReturnStateInfo();
InterfaceCode interfaceCode = new InterfaceCode(); InterfaceCode interfaceCode = new InterfaceCode();
AuthDateReq data = null; AuthDateReq data = null;
@ -288,22 +288,22 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
} else { } else {
authStatus.setTaxCredit(""); authStatus.setTaxCredit("");
} }
if("5".equals(authStatus.getRzlx())){ if ("5".equals(authStatus.getRzlx())) {
authStatus.setAuthState(authStatus.getCxrzStatus()); authStatus.setAuthState(authStatus.getCxrzStatus());
} }
if(StringUtils.isBlank(authStatus.getInvoiceCode())){ if (StringUtils.isBlank(authStatus.getInvoiceCode())) {
authStatus.setInvoiceCode(""); authStatus.setInvoiceCode("");
} }
authStatus.setTaxCredit(""); authStatus.setTaxCredit("");
if ("1".equals(authStatus.getRzlx()) || "4".equals(authStatus.getRzlx())) { if ("1".equals(authStatus.getRzlx()) || "4".equals(authStatus.getRzlx())) {
if(StringUtils.isNotBlank(authStatus.getTaxCredit())){ if (StringUtils.isNotBlank(authStatus.getTaxCredit())) {
authStatus.setTaxCredit(df.format(new BigDecimal(authStatus.getTaxCredit()))); authStatus.setTaxCredit(df.format(new BigDecimal(authStatus.getTaxCredit())));
} }
} }
if("5".equals(authStatus.getRzlx())){ if ("5".equals(authStatus.getRzlx())) {
authStatus.setAuthState(authStatus.getCxrzStatus()); authStatus.setAuthState(authStatus.getCxrzStatus());
} }
if("6".equals(authStatus.getRzlx())){ if ("6".equals(authStatus.getRzlx())) {
authStatus.setAuthState(authStatus.getCxbdkStatus()); authStatus.setAuthState(authStatus.getCxbdkStatus());
} }
} }
@ -331,11 +331,11 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
StringBuilder promsg = new StringBuilder(); StringBuilder promsg = new StringBuilder();
String zdata2 = isInput.getZDATA(); String zdata2 = isInput.getZDATA();
List<ZDATA> zdata = JSON.parseArray(zdata2, ZDATA.class); List<ZDATA> zdata = JSON.parseArray(zdata2, ZDATA.class);
AuthDateReq authDateReq=new AuthDateReq(); AuthDateReq authDateReq = new AuthDateReq();
authDateReq.setBatchNo(isInput.getSAPKEY()); authDateReq.setBatchNo(isInput.getSAPKEY());
authDateReq.setApplyRzlx("1"); authDateReq.setApplyRzlx("1");
StringBuilder errorMsg = new StringBuilder(); StringBuilder errorMsg = new StringBuilder();
DynamicContextHolder.push("business"+DbConstant.BUSINESS_READ); DynamicContextHolder.push("business" + DbConstant.BUSINESS_READ);
List<String> fplxList = new ArrayList<>(); List<String> fplxList = new ArrayList<>();
fplxList.add("01"); fplxList.add("01");
fplxList.add("03"); fplxList.add("03");
@ -346,145 +346,125 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
fplxList.add("14"); fplxList.add("14");
fplxList.add("31"); fplxList.add("31");
fplxList.add("32"); fplxList.add("32");
for(ZDATA zdata1:zdata){ for (ZDATA zdata1 : zdata) {
log.info("zdata1.getZFPHM()===>{}",zdata1.getZFPHM()); log.info("zdata1.getZFPHM()===>{}", zdata1.getZFPHM());
String collect = fplxList.stream().collect(Collectors.joining(",")); String collect = fplxList.stream().collect(Collectors.joining(","));
if(!collect.contains(convertFpzldm(zdata1.getZFPLX()))){ if (!collect.contains(convertFpzldm(zdata1.getZFPLX()))) {
log.info("非增值税先不处理：{}",JSON.toJSONString(zdata1)); log.info("非增值税先不处理：{}", JSON.toJSONString(zdata1));
continue; continue;
} }
String fphm = zdata1.getZFPHM(); String fphm = zdata1.getZFPHM();
if (org.apache.commons.lang3.StringUtils.isNotBlank(fphm) && fphm.length() > 8 && !("26".equals(zdata1.getZFPLX()) || "27".equals(zdata1.getZFPLX()))){ if (org.apache.commons.lang3.StringUtils.isNotBlank(fphm) && fphm.length() > 8 && !("26".equals(zdata1.getZFPLX()) || "27".equals(zdata1.getZFPLX()))) {
fphm = fphm.replace(zdata1.getZFPDM(),""); fphm = fphm.replace(zdata1.getZFPDM(), "");
log.info("非全电但是号码"); log.info("非全电但是号码");
} }
log.info("发票号码{}",fphm); log.info("发票号码{}", fphm);
String uuid = zdata1.getZFPDM()+fphm; String uuid = zdata1.getZFPDM() + fphm;
zdata1.setZFPLX(convertFpzldm(zdata1.getZFPLX())); zdata1.setZFPLX(convertFpzldm(zdata1.getZFPLX()));
TdxRecordInvoice recordInvoiceByUuid = tDxrecordInvoiceDao.getRecordInvoiceByUuid(uuid); TdxRecordInvoice recordInvoiceByUuid = tDxrecordInvoiceDao.getRecordInvoiceByUuid(uuid);
//查询票池 //查询票池
QueryWrapper<TDxInvoiceReimburse> queryWrapper = new QueryWrapper<>(); QueryWrapper<TDxInvoiceReimburse> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("uuid",uuid); queryWrapper.eq("uuid", uuid);
TDxInvoiceReimburse tDxInvoiceReimburse = tDxInvoiceReimburseService.getBaseMapper().selectOne(queryWrapper); TDxInvoiceReimburse tDxInvoiceReimburse = tDxInvoiceReimburseService.getBaseMapper().selectOne(queryWrapper);
//没法区分来源是不是销项发票 //没法区分来源是不是销项发票
TdxSaleRecordInvoice tdxSaleRecordInvoice = tdxSaleRecordInvoiceDao.selectByUuid(uuid); TdxSaleRecordInvoice tdxSaleRecordInvoice = tdxSaleRecordInvoiceDao.selectByUuid(uuid);
if(recordInvoiceByUuid==null && tDxInvoiceReimburse==null && tdxSaleRecordInvoice==null){ if (recordInvoiceByUuid == null && tDxInvoiceReimburse == null && tdxSaleRecordInvoice == null) {
errorMsg.append("发票号码:"+zdata1.getZFPHM()); errorMsg.append("发票号码:" + zdata1.getZFPHM());
} }
} }
if(errorMsg.length()>1){ if (errorMsg.length() > 1) {
es.setZMESSAGE(errorMsg.toString()+"不存在"); es.setZMESSAGE(errorMsg.toString() + "不存在");
es.setZTYPE("E"); es.setZTYPE("E");
return es; return es;
} }
for(ZDATA zdata1:zdata){ for (ZDATA zdata1 : zdata) {
//成功或者失败标识 //成功或者失败标识
boolean flag = false; boolean flag = false;
log.info("zdata1.getZFPHM():{}",zdata1.getZFPHM()); log.info("zdata1.getZFPHM():{}", zdata1.getZFPHM());
String fphm = zdata1.getZFPHM(); String fphm = zdata1.getZFPHM();
if (org.apache.commons.lang3.StringUtils.isNotBlank(fphm) && fphm.length() > 8 && !("26".equals(zdata1.getZFPLX()) || "27".equals(zdata1.getZFPLX()))){ if (org.apache.commons.lang3.StringUtils.isNotBlank(fphm) && fphm.length() > 8 && !("26".equals(zdata1.getZFPLX()) || "27".equals(zdata1.getZFPLX()))) {
fphm = fphm.replace(zdata1.getZFPDM(),""); fphm = fphm.replace(zdata1.getZFPDM(), "");
log.info("非全电但是号码"); log.info("非全电但是号码");
} }
log.info("发票号码{}",fphm); log.info("发票号码{}", fphm);
String uuid = zdata1.getZFPDM()+fphm; String uuid = zdata1.getZFPDM() + fphm;
//销项标识
String xxbs = zdata1.getXXBS();
String uuid = zdata1.getZFPDM()+zdata1.getZFPHM();
//销项标识 //销项标识
String xxbs = zdata1.getXXBS(); String xxbs = zdata1.getXXBS();
DynamicContextHolder.push("business"+DbConstant.BUSINESS_READ); DynamicContextHolder.push("business" + DbConstant.BUSINESS_READ);
if(fplxList.contains(zdata1.getZFPLX()) && !"X".equalsIgnoreCase(xxbs)){ if (fplxList.contains(zdata1.getZFPLX()) && !"X".equalsIgnoreCase(xxbs)) {
TdxRecordInvoice recordInvoiceByUuid = tDxrecordInvoiceDao.getRecordInvoiceByUuid(uuid); TdxRecordInvoice recordInvoiceByUuid = tDxrecordInvoiceDao.getRecordInvoiceByUuid(uuid);
if(recordInvoiceByUuid!=null){ if (recordInvoiceByUuid != null) {
UpdateWrapper updateWrapper = new UpdateWrapper(); UpdateWrapper updateWrapper = new UpdateWrapper();
updateWrapper.eq("uuid",uuid); updateWrapper.eq("uuid", uuid);
//凭证号 //凭证号
updateWrapper.set("sn_voucher_number",zdata1.getBELNR()); updateWrapper.set("sn_voucher_number", zdata1.getBELNR());
//凭证过账日期 //凭证过账日期
updateWrapper.set("posting_time",zdata1.getBUDAT()); updateWrapper.set("posting_time", zdata1.getBUDAT());
//账期 //账期
updateWrapper.set("account_period",zdata1.getBUDAT().substring(0,7)); updateWrapper.set("account_period", zdata1.getBUDAT().substring(0, 7));
//报账单号 //报账单号
updateWrapper.set("bzdh",zdata1.getZBZDH()); updateWrapper.set("bzdh", zdata1.getZBZDH());
//入账状态 //入账状态
updateWrapper.set("inaccount_status",zdata1.getZYWZT()); updateWrapper.set("inaccount_status", zdata1.getZYWZT());
updateWrapper.set("comp_code",zdata1.getZGSDM()); updateWrapper.set("comp_code", zdata1.getZGSDM());
updateWrapper.set("bzr",zdata1.getZJBRT()); updateWrapper.set("bzr", zdata1.getZJBRT());
DynamicContextHolder.push("business"+DbConstant.BUSINESS_WRITE); DynamicContextHolder.push("business" + DbConstant.BUSINESS_WRITE);
int update = tDxrecordInvoiceDao.update(null, updateWrapper); int update = tDxrecordInvoiceDao.update(null, updateWrapper);
if(update>0){ if (update > 0) {
DynamicContextHolder.push(DbConstant.BASICS_READ); DynamicContextHolder.push(DbConstant.BASICS_READ);
SysDeptEntity org = sysDeptDao.getOrg(recordInvoiceByUuid.getGfTaxNo()); SysDeptEntity org = sysDeptDao.getOrg(recordInvoiceByUuid.getGfTaxNo());
zdata1.setZFPLX(convertFpzldm(zdata1.getZFPLX())); zdata1.setZFPLX(convertFpzldm(zdata1.getZFPLX()));
//如果设置的自动认证走申请认证逻辑 //如果设置的自动认证走申请认证逻辑
if(org!=null && "1".equals(org.getAutoRz()) && ("01".equals(zdata1.getZFPLX()) || "03".equals(zdata1.getZFPLX()) if (org != null && "1".equals(org.getAutoRz()) && ("01".equals(zdata1.getZFPLX()) || "03".equals(zdata1.getZFPLX())
|| "08".equals(zdata1.getZFPLX()) || "14".equals(zdata1.getZFPLX()) || "08".equals(zdata1.getZFPLX()) || "14".equals(zdata1.getZFPLX())
|| "31".equals(zdata1.getZFPLX())) && StringUtils.isNotBlank(zdata1.getBUDAT())){ || "31".equals(zdata1.getZFPLX())) && StringUtils.isNotBlank(zdata1.getBUDAT())) {
if(!"4".equals(recordInvoiceByUuid.getAuthStatus()) && !"3".equals(recordInvoiceByUuid.getAuthStatus()) if (!"4".equals(recordInvoiceByUuid.getAuthStatus()) && !"3".equals(recordInvoiceByUuid.getAuthStatus())
&& !"2".equals(recordInvoiceByUuid.getAuthStatus())){ && !"2".equals(recordInvoiceByUuid.getAuthStatus())) {
Map<String,Object> authState = new HashMap<>(); Map<String, Object> authState = new HashMap<>();
authState.put("rz_user",zdata1.getZJBRT()); authState.put("rz_user", zdata1.getZJBRT());
authState.put("applyTaxPeriod",zdata1.getBUDAT().substring(0,7).replace("-","")); authState.put("applyTaxPeriod", zdata1.getBUDAT().substring(0, 7).replace("-", ""));
DynamicContextHolder.push("business"+DbConstant.BUSINESS_WRITE); DynamicContextHolder.push("business" + DbConstant.BUSINESS_WRITE);
tDxrecordInvoiceDao.updateRz(authState,"1","1",recordInvoiceByUuid.getUuid()); tDxrecordInvoiceDao.updateRz(authState, "1", "1", recordInvoiceByUuid.getUuid());
} }
} }
} }
} }
}else { } else {
UpdateWrapper updateWrapper = convertRecordInvoice(zdata1,uuid); UpdateWrapper updateWrapper = convertRecordInvoice(zdata1, uuid);
DynamicContextHolder.push("business"+DbConstant.BUSINESS_WRITE); DynamicContextHolder.push("business" + DbConstant.BUSINESS_WRITE);
tDxInvoiceReimburseService.getBaseMapper().update(null,updateWrapper); tDxInvoiceReimburseService.getBaseMapper().update(null, updateWrapper);
} }
<<<<<<<<< Temporary merge branch 1
if ("X".equals(xxbs)){
DynamicContextHolder.push("business"+DbConstant.BUSINESS_WRITE);
UpdateWrapper updateWrapper = new UpdateWrapper();
updateWrapper.set("sn_voucher_number",zdata1.getBELNR());
updateWrapper.set("posting_time",zdata1.getBUDAT());
updateWrapper.set("account_period",zdata1.getBUDAT().substring(0,7));
updateWrapper.set("bzdh",zdata1.getZBZDH());
updateWrapper.set("inaccount_status",zdata1.getZYWZT());
updateWrapper.set("comp_code",zdata1.getZGSDM());
updateWrapper.set("bzr",zdata1.getZJBRT());
updateWrapper.eq("uuid",uuid);
=========
if ("X".equalsIgnoreCase(xxbs)){ if ("X".equalsIgnoreCase(xxbs)){
DynamicContextHolder.push("business"+DbConstant.BUSINESS_WRITE); DynamicContextHolder.push("business"+DbConstant.BUSINESS_WRITE);
UpdateWrapper updateWrapper = convertRecordInvoice(zdata1,uuid); UpdateWrapper updateWrapper = convertRecordInvoice(zdata1,uuid);
>>>>>>>>> Temporary merge branch 2
tdxSaleRecordInvoiceDao.update(null,updateWrapper); tdxSaleRecordInvoiceDao.update(null,updateWrapper);
} }
zdataresp.setPROMSG(promsg.toString());
if(!flag){ zdataresp.setPROTYP("S");
promsg.append("票据号码:"+zdata1.getZFPHM()+"绑定成功! "); es.setZMESSAGE("处理成功");
} es.setZdata(zdataresp);
return es;
} }
zdataresp.setPROMSG(promsg.toString());
zdataresp.setPROTYP("S");
es.setZMESSAGE("处理成功");
es.setZdata(zdataresp);
return es; return es;
} }
public UpdateWrapper convertRecordInvoice(ZDATA zdata,String uuid){ public UpdateWrapper convertRecordInvoice(ZDATA zdata, String uuid) {
UpdateWrapper updateWrapper = new UpdateWrapper(); UpdateWrapper updateWrapper = new UpdateWrapper();
updateWrapper.set("sn_voucher_number",zdata.getBELNR()); updateWrapper.set("sn_voucher_number", zdata.getBELNR());
try { try {
DateTime parse = DateTime.parse(zdata.getBUDAT()); DateTime parse = DateTime.parse(zdata.getBUDAT());
updateWrapper.set("posting_time",zdata.getBUDAT()); updateWrapper.set("posting_time", zdata.getBUDAT());
//账期 //账期
updateWrapper.set("account_period",zdata.getBUDAT().substring(0,7)); updateWrapper.set("account_period", zdata.getBUDAT().substring(0, 7));
} catch (Exception e) { } catch (Exception e) {
log.error("时间转换异常：{}",e); log.error("时间转换异常：{}", e);
} }
updateWrapper.set("bzdh",zdata.getZBZDH()); updateWrapper.set("bzdh", zdata.getZBZDH());
updateWrapper.set("inaccount_status",zdata.getZYWZT()); updateWrapper.set("inaccount_status", zdata.getZYWZT());
updateWrapper.set("comp_code",zdata.getZGSDM()); updateWrapper.set("comp_code", zdata.getZGSDM());
updateWrapper.set("bzr",zdata.getZJBRT()); updateWrapper.set("bzr", zdata.getZJBRT());
updateWrapper.eq("uuid",uuid); updateWrapper.eq("uuid", uuid);
return updateWrapper; return updateWrapper;
} }
@ -504,24 +484,24 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
// return run; // return run;
// } // }
boolean r = boolean r =
!(CheckUtils.stringLength((String)map.get("invoiceNo"), 8) || CheckUtils.stringLength((String)map.get("invoiceNo"), 10) !(CheckUtils.stringLength((String) map.get("invoiceNo"), 8) || CheckUtils.stringLength((String) map.get("invoiceNo"), 10)
|| CheckUtils.stringLength((String)map.get("invoiceNo"), 18) || CheckUtils.stringLength((String)map.get("invoiceNo"), 20)); || CheckUtils.stringLength((String) map.get("invoiceNo"), 18) || CheckUtils.stringLength((String) map.get("invoiceNo"), 20));
if (CheckUtils.isNullOrEmpty((String)map.get("invoiceNo")) || r) { if (CheckUtils.isNullOrEmpty((String) map.get("invoiceNo")) || r) {
run.setReturnCode(ReturnCodeEnum.DMHMBF.getFhzDm()); run.setReturnCode(ReturnCodeEnum.DMHMBF.getFhzDm());
run.setReturnMessage(ReturnCodeEnum.DMHMBF.getFhzMc(ReturnCodeEnum.DMHMBF.getIndex())); run.setReturnMessage(ReturnCodeEnum.DMHMBF.getFhzMc(ReturnCodeEnum.DMHMBF.getIndex()));
} }
if (StringUtils.isBlank((String)map.get("applyTaxPeriod")) if (StringUtils.isBlank((String) map.get("applyTaxPeriod"))
|| ((String)map.get("applyTaxPeriod")).length() != 6) { || ((String) map.get("applyTaxPeriod")).length() != 6) {
run.setReturnCode(ReturnCodeEnum.SKSSQBF.getFhzDm()); run.setReturnCode(ReturnCodeEnum.SKSSQBF.getFhzDm());
run.setReturnMessage(ReturnCodeEnum.SKSSQBF.getFhzMc(ReturnCodeEnum.SKSSQBF.getIndex())); run.setReturnMessage(ReturnCodeEnum.SKSSQBF.getFhzMc(ReturnCodeEnum.SKSSQBF.getIndex()));
return run; return run;
} }
if (StringUtils.isBlank((String)map.get("buyerTaxNo"))) { if (StringUtils.isBlank((String) map.get("buyerTaxNo"))) {
run.setReturnCode(ReturnCodeEnum.SHBNWK.getFhzDm()); run.setReturnCode(ReturnCodeEnum.SHBNWK.getFhzDm());
run.setReturnMessage(ReturnCodeEnum.SHBNWK.getFhzMc(ReturnCodeEnum.SHBNWK.getIndex())); run.setReturnMessage(ReturnCodeEnum.SHBNWK.getFhzMc(ReturnCodeEnum.SHBNWK.getIndex()));
return run; return run;
} }
if (StringUtils.isBlank((String)map.get("rz_user"))) { if (StringUtils.isBlank((String) map.get("rz_user"))) {
run.setReturnCode(ReturnCodeEnum.RZRBNWK.getFhzDm()); run.setReturnCode(ReturnCodeEnum.RZRBNWK.getFhzDm());
run.setReturnMessage(ReturnCodeEnum.RZRBNWK.getFhzMc(ReturnCodeEnum.RZRBNWK.getIndex())); run.setReturnMessage(ReturnCodeEnum.RZRBNWK.getFhzMc(ReturnCodeEnum.RZRBNWK.getIndex()));
return run; return run;
@ -535,27 +515,27 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
} }
return run; return run;
} }
public String convertFpzldm(String fpzldm){ public String convertFpzldm(String fpzldm) {
if("10".equals(fpzldm)){ if ("10".equals(fpzldm)) {
fpzldm= FplxEnum.ZP.getFplxDm(); fpzldm = FplxEnum.ZP.getFplxDm();
}else if("11".equals(fpzldm)){ } else if ("11".equals(fpzldm)) {
fpzldm=FplxEnum.PP.getFplxDm(); fpzldm = FplxEnum.PP.getFplxDm();
}else if("12".equals(fpzldm)){ } else if ("12".equals(fpzldm)) {
fpzldm=FplxEnum.DZP.getFplxDm(); fpzldm = FplxEnum.DZP.getFplxDm();
}else if("13".equals(fpzldm)){ } else if ("13".equals(fpzldm)) {
fpzldm=FplxEnum.JSP.getFplxDm(); fpzldm = FplxEnum.JSP.getFplxDm();
}else if("14".equals(fpzldm)){ } else if ("14".equals(fpzldm)) {
fpzldm=FplxEnum.JDC.getFplxDm(); fpzldm = FplxEnum.JDC.getFplxDm();
}else if("15".equals(fpzldm)){ } else if ("15".equals(fpzldm)) {
fpzldm=FplxEnum.ESC.getFplxDm(); fpzldm = FplxEnum.ESC.getFplxDm();
}else if("24".equals(fpzldm)){ } else if ("24".equals(fpzldm)) {
fpzldm=FplxEnum.TXF.getFplxDm(); fpzldm = FplxEnum.TXF.getFplxDm();
}else if("25".equals(fpzldm)){ } else if ("25".equals(fpzldm)) {
fpzldm=FplxEnum.DZZP.getFplxDm(); fpzldm = FplxEnum.DZZP.getFplxDm();
}else if("26".equals(fpzldm)){ } else if ("26".equals(fpzldm)) {
fpzldm= FplxEnum.QDZZP.getFplxDm(); fpzldm = FplxEnum.QDZZP.getFplxDm();
}else if("27".equals(fpzldm)){ } else if ("27".equals(fpzldm)) {
fpzldm=FplxEnum.QDPP.getFplxDm(); fpzldm = FplxEnum.QDPP.getFplxDm();
} }
return fpzldm; return fpzldm;
} }
@ -566,17 +546,17 @@ public class InvoiceAuthServiceImpl extends MpBaseServiceImpl<RecordInvoiceDao,
DateTime parse1 = DateTime.parse("2012-12-01"); DateTime parse1 = DateTime.parse("2012-12-01");
Date date11 = parse1.toDate(); Date date11 = parse1.toDate();
HashMap<Object, Object> map = Maps.newHashMap(); HashMap<Object, Object> map = Maps.newHashMap();
map.put("1","3"); map.put("1", "3");
try { try {
DateTime parse = DateTime.parse("0000-00-00"); DateTime parse = DateTime.parse("0000-00-00");
map.put("2","3"); map.put("2", "3");
Date date1 = parse.toDate(); Date date1 = parse.toDate();
String s = parse.toString("yyyy-MM-dd "); String s = parse.toString("yyyy-MM-dd ");
System.out.println(""); System.out.println("");
} catch (Exception e) { } catch (Exception e) {
// throw new RuntimeException(e); // throw new RuntimeException(e);
} }
map.put("3","3"); map.put("3", "3");
System.out.println(); System.out.println();
// String d="2023"; // String d="2023";
// String substring = d.substring(0, 7); // String substring = d.substring(0, 7);

Write Preview
Loading…
Cancel
Save