feat: 同步全电红字确认单到订单服务

release
liufeilong 2 years ago
parent e8aefea901
commit d196b34978
  1. 10
      order-management-common/src/main/java/com/dxhy/order/constant/OrderInfoEnum.java
  2. 5
      order-management-common/src/main/java/com/dxhy/order/model/SpecialInvoiceReversalItem.java
  3. 13
      order-management-consumer/src/main/java/com/dxhy/order/consumer/config/OpenApiConfig.java
  4. 418
      order-management-consumer/src/main/java/com/dxhy/order/consumer/handle/SyncQdHzqrdTask.java
  5. 49
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoicespecial/model/SpecialInvoiceReversalEntity.java
  6. 2
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoicespecial/service/SpecialInvoiceReversalService.java
  7. 6
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoicespecial/service/impl/SpecialInvoiceReversalServiceImpl.java
  8. 19
      order-management-invoice/src/main/resources/mybatis/mapper/SpecialInvoiceReversalItemMapper.xml
  9. 117
      order-management-invoice/src/main/resources/mybatis/mapper/SpecialInvoiceReversalMapper.xml

@ -721,6 +721,16 @@ public enum OrderInfoEnum {
SPECIAL_INVOICE_STATUS_TZD0082("TZD0082", "已撤销"),
SPECIAL_INVOICE_STATUS_TZD0083("TZD0083", "已作废"),
SPECIAL_INVOICE_STATUS_B900071("B900071", "红字发票信息表已成功上传,无需重复上传"),
//全电红字确认单状态
SPECIAL_INVOICE_STATUS_01("01", "无需确认"),
SPECIAL_INVOICE_STATUS_02("02", "销方录入待购方确认"),
SPECIAL_INVOICE_STATUS_03("03", "购方录入待销方确认"),
SPECIAL_INVOICE_STATUS_04("04", "购销双方已确认"),
SPECIAL_INVOICE_STATUS_05("05", "作废(销方录入购方否认)"),
SPECIAL_INVOICE_STATUS_06("06", "作废(购方录入销方否认)"),
SPECIAL_INVOICE_STATUS_07("07", "作废(超72小时未确认)"),
SPECIAL_INVOICE_STATUS_08("08", "发起方撤销"),
/**
* 方格上传税局失败
*/

@ -58,4 +58,9 @@ public class SpecialInvoiceReversalItem implements Serializable {
private Date createTime;
/**
* 全电-蓝字发票明细序号
*/
private String lzmxxh;
}

@ -228,6 +228,12 @@ public class OpenApiConfig {
*/
@Value("${order.security.handlerReuqestParamUrlPaths:}")
private String handlerReuqestParamUrlPaths;
/**
* 调用大B服务URL
*/
@Value("${dxhy.userCenter.bigB.dBUserInfoUrl}")
private String dBUserInfoUrl;
/**
* 对外二维码短码
@ -327,6 +333,13 @@ public class OpenApiConfig {
public String configInvoiceErrorMsgList() {
return invoiceErrorMsgList;
}
/**
* 查询当前组织下所有组织信息
*/
public String queryAllDeptInfo(){
return dBUserInfoUrl+"/api/dept/queryAllDeptInfo";
}
}

@ -0,0 +1,418 @@
package com.dxhy.order.consumer.handle;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.dxhy.order.baseservice.module.base.service.BaseService;
import com.dxhy.order.baseservice.module.thirdservice.user.model.DeptEntity;
import com.dxhy.order.constant.*;
import com.dxhy.order.consumer.config.OpenApiConfig;
import com.dxhy.order.consumer.openapi.protocol.v6.hzqrd.QdCommonRspV6;
import com.dxhy.order.consumer.openapi.service.InterfaceServiceV6;
import com.dxhy.order.invoice.module.invoicespecial.model.CommonSpecialInvoice;
import com.dxhy.order.invoice.module.invoicespecial.model.SpecialInvoiceReversalEntity;
import com.dxhy.order.invoice.module.invoicespecial.service.SpecialInvoiceReversalService;
import com.dxhy.order.model.SpecialInvoiceReversalItem;
import com.dxhy.order.utils.HttpUtils;
import com.dxhy.order.utils.JsonUtils;
import com.google.common.collect.Maps;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.entity.ContentType;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
/**
* @Description: 同步全电红字确认单
* @Author liufeilong
* @Date 2023-04-15
**/
@Slf4j
@Component
@JobHandler(value = "/qdHzqrdTask")
@RequestMapping(value = "/qdHzqrd")
public class SyncQdHzqrdTask extends IJobHandler {
private static final String LOGGER_MSG = "(定时同步全电红字确认单)";
@Resource
private InterfaceServiceV6 interfaceServiceV6;
@Resource
private BaseService baseService;
@Resource
private SpecialInvoiceReversalService specialInvoiceReversalService;
@Resource
private OpenApiConfig openApiConfig;
@Override
@PostMapping("/sync")
public ReturnT<String> execute(String param) {
log.debug("{}定时任务开始,请求参数:{}", LOGGER_MSG, param);
try {
/**
* {
* "YHJSLX": "用户角色类型",
* "XSFNSRSBH": "(销售方)统一社会信用代码/纳税人识别号/身份证件号码",
* "XSFMC": "(销售方)名称",
* "GMFNSRSBH": "(购买方)统一社会信用代码/纳税人识别号/身份证件号码",
* "GMFMC": "(购买方)名称",
* "LRFSF": "录入方身份",
* "LRRQQ": "录入日期起",
* "LRRQZ": "录入日期止",
* "LZFPDM": "蓝字发票代码",
* "LZFPHM": "蓝字发票号码",
* "HZFPXXQRDBH": "红字确认单编号",
* "HZQRXXZTDM": "红字确认信息状态代码",
* "PAGENUMBER": "页码",
* "PAGESIZE": "每页数量"
* }
*/
Map paramMap = JsonUtils.getInstance().parseObject(param, Map.class);
List<Map> paramList = new ArrayList<>();
if (ObjectUtil.isNull(paramMap)) {
Map<String,String> shMap = new HashMap();
final List<DeptEntity> deptEntities = queryAllDeptInfo();
deptEntities.stream().forEach(f -> {
if(!shMap.containsKey(f.getTaxpayerCode())){
shMap.put(f.getTaxpayerCode(),f.getTaxpayerName());
}
});
final org.joda.time.DateTime dateTime = new org.joda.time.DateTime();
final String endTime = dateTime.toString(ConfigureConstant.DATE_FORMAT_DATE);
final String startTime = dateTime.minusDays(5).toString(ConfigureConstant.DATE_FORMAT_DATE);
for(Map.Entry<String, String> entry:shMap.entrySet()){
Map paramMap001 = new HashMap();
//用户角色类型 0:销方 1:购方
paramMap001.put("YHJSLX","0");
paramMap001.put("XSFNSRSBH",entry.getKey());
paramMap001.put("XSFMC",entry.getValue());
paramMap001.put("LRRQQ",startTime);
paramMap001.put("LRRQZ",endTime);
paramMap001.put("PAGENUMBER","1");
paramMap001.put("PAGESIZE","100");
paramList.add(paramMap001);
Map paramMap101 = new HashMap();
//用户角色类型 0:销方 1:购方
paramMap101.put("YHJSLX","1");
paramMap101.put("GMFNSRSBH",entry.getKey());
paramMap101.put("GMFMC",entry.getValue());
paramMap101.put("LRRQQ",startTime);
paramMap101.put("LRRQZ",endTime);
paramMap101.put("PAGENUMBER","1");
paramMap101.put("PAGESIZE","100");
paramList.add(paramMap101);
}
}else {
paramList.add(paramMap);
}
for(Map map:paramList){
String queryMainParam = JsonUtils.getInstance().toJsonString(map);
syncQdSpecialInvoice(queryMainParam);
}
} catch (Exception e) {
log.error("{}定时任务执行异常:{}", LOGGER_MSG, e);
return FAIL;
}
log.debug("{}定时任务完成", LOGGER_MSG);
return SUCCESS;
}
private void syncQdSpecialInvoice(String queryMainParam){
List<CommonSpecialInvoice> commonSpecialInvoiceAddList = new ArrayList<>();
List<CommonSpecialInvoice > commonSpecialInvoiceEditList = new ArrayList<>();
Map<String, List<SpecialInvoiceReversalEntity>> mainMap = queryQdSpecialInvoiceMain(queryMainParam);
List<SpecialInvoiceReversalEntity> addList = mainMap.get("add");
List<SpecialInvoiceReversalEntity> editList = mainMap.get("edit");
addList.forEach(f -> {
CommonSpecialInvoice csi = new CommonSpecialInvoice();
Map<String,String> queryDetailMap = new HashMap<>();
queryDetailMap.put("HZQRDUUID",f.getUuid());
queryDetailMap.put("XSFNSRSBH",f.getXhfNsrsbh());
String queryDetailParam = JsonUtils.getInstance().toJsonString(queryDetailMap);
List<SpecialInvoiceReversalItem> specialInvoiceReversalItems = queryQdSpecialInvoiceDetail(queryDetailParam, false, f.getId());
String dslbz = specialInvoiceReversalItems.get(0).getSl();
for(SpecialInvoiceReversalItem en:specialInvoiceReversalItems){
if(!dslbz.equals(en.getSl())){
dslbz = "多税率";
break;
}
}
f.setDslbz(dslbz);
csi.setSpecialInvoiceReversalEntity(f);
csi.setSpecialInvoiceReversalItemEntities(specialInvoiceReversalItems);
commonSpecialInvoiceAddList.add(csi);
});
editList.forEach(f -> {
CommonSpecialInvoice csi = new CommonSpecialInvoice();
Map<String,String> queryDetailMap = new HashMap<>();
queryDetailMap.put("HZQRDUUID",f.getUuid());
queryDetailMap.put("XSFNSRSBH",f.getXhfNsrsbh());
String queryDetailParam = JsonUtils.getInstance().toJsonString(queryDetailMap);
List<SpecialInvoiceReversalItem> specialInvoiceReversalItems = queryQdSpecialInvoiceDetail(queryDetailParam, true, f.getId());
String dslbz = specialInvoiceReversalItems.get(0).getSl();
for(SpecialInvoiceReversalItem en:specialInvoiceReversalItems){
if(!dslbz.equals(en.getSl())){
dslbz = "多税率";
break;
}
}
f.setDslbz(dslbz);
csi.setSpecialInvoiceReversalEntity(f);
csi.setSpecialInvoiceReversalItemEntities(specialInvoiceReversalItems);
commonSpecialInvoiceEditList.add(csi);
});
//数据库字段长度问题,单条报错不影响其他数据插入
for(CommonSpecialInvoice en:commonSpecialInvoiceAddList){
List<CommonSpecialInvoice > list = new ArrayList<>();
list.add(en);
try {
specialInvoiceReversalService.processCommonSpecialInvoice(false,list);
}catch (Exception e){
log.error("{},{}红字确认单同步失败:{}",LOGGER_MSG,en.getSpecialInvoiceReversalEntity().getXxbbh(),e);
}
}
for(CommonSpecialInvoice en:commonSpecialInvoiceEditList){
List<CommonSpecialInvoice > list = new ArrayList<>();
list.add(en);
try {
specialInvoiceReversalService.processCommonSpecialInvoice(true,list);
}catch (Exception e){
log.error("{},{}红字确认单同步失败:{}",LOGGER_MSG,en.getSpecialInvoiceReversalEntity().getXxbbh(),e);
}
}
}
private Map<String,List<SpecialInvoiceReversalEntity>> queryQdSpecialInvoiceMain(String param){
Map<String,List<SpecialInvoiceReversalEntity>> returnMap = new HashMap<>();
List<SpecialInvoiceReversalEntity> addList = new ArrayList<>();
List<SpecialInvoiceReversalEntity> editList = new ArrayList<>();
QdCommonRspV6 hzqrdRspV6 = interfaceServiceV6.processProxyForQd(ConfigurerInfo.QUERY_RED_CONFIRMATION_LIST, param);
if(ConfigureConstant.STRING_000000.equals(hzqrdRspV6.getZTDM())){
Map dataMap = JsonUtils.getInstance().parseObject(hzqrdRspV6.getDATA().toString(), Map.class);;
List<Map> list = (List<Map>) dataMap.get("LIST");
for(Map en:list){
Map<String,Object> enterMap = new HashMap<>();
enterMap.put("uuid",en.get("UUID"));
List<SpecialInvoiceReversalEntity> specialInvoiceReversalEntities = specialInvoiceReversalService.querySpecialInvoice(enterMap);
if(specialInvoiceReversalEntities.size() == 0){
SpecialInvoiceReversalEntity hzxxbEn = createHzxxbEn(en);
addList.add(hzxxbEn);
}else if(specialInvoiceReversalEntities.size() == 1){
SpecialInvoiceReversalEntity specialInvoiceReversalEntity = specialInvoiceReversalEntities.get(0);
specialInvoiceReversalEntity.setStatusCode((String)en.get("HZQRXXZTDM"));
specialInvoiceReversalEntity.setStatusMessage(getStatusMessage((String)en.get("HZQRXXZTDM")));
specialInvoiceReversalEntity.setQrrq((String)en.get("QRRQ"));
specialInvoiceReversalEntity.setDataStatus("Y".equals((String)en.get("YXBZ"))?"0":"1");
specialInvoiceReversalEntity.setEditorId("1");
specialInvoiceReversalEntity.setEditorName("系统管理员 ");
specialInvoiceReversalEntity.setUpdateTime(new Date());
editList.add(specialInvoiceReversalEntity);
}else {
log.info("{}根据uuid查询主表查出了多条,不做处理");
}
}
}
returnMap.put("add",addList);
returnMap.put("edit",editList);
return returnMap;
}
private List<SpecialInvoiceReversalItem> queryQdSpecialInvoiceDetail(String param,Boolean edit,String specialInvoiceId){
if(edit){
return specialInvoiceReversalService.querySpecialInvoiceReversalItems(specialInvoiceId);
}else {
List<SpecialInvoiceReversalItem> returnList = new ArrayList<>();
QdCommonRspV6 hzqrdRspV6 = interfaceServiceV6.processProxyForQd(ConfigurerInfo.QUERY_RED_CONFIRMATION_ITEM_LIST, param);
if(ConfigureConstant.STRING_000000.equals(hzqrdRspV6.getZTDM())){
Map detailMap = JsonUtils.getInstance().parseObject(hzqrdRspV6.getDATA().toString(), Map.class);
List<Map> list = (List<Map>) detailMap.get("HZQRXXMXLIST");
for(Map en:list){
SpecialInvoiceReversalItem hzxxbItem = createHzxxbItem(en, specialInvoiceId);
returnList.add(hzxxbItem);
}
}
return returnList;
}
}
private SpecialInvoiceReversalEntity createHzxxbEn(Map en){
String uuid = (String)en.get("UUID");
String hzfpxxqrdbh = (String)en.get("HZFPXXQRDBH");
String lrfsf = (String)en.get("LRFSF");
String xsfnsrsbh = (String)en.get("XSFNSRSBH");
String xsfmc = (String)en.get("XSFMC");
String gmfnsrsbh = (String)en.get("GMFNSRSBH");
String gmfmc = (String)en.get("GMFMC");
String lzfpdm = (String)en.get("LZFPDM");
String lzfphm = (String)en.get("LZFPHM");
String sfzzfpbz = (String)en.get("SFZZFPBZ");
String lzkprq = (String)en.get("LZKPRQ");
String lzhjje = (String)en.get("LZHJJE");
String lzhjse = (String)en.get("LZHJSE");
String lzfppzdm = (String)en.get("LZFPPZDM");
String lzfptdyslxdm = (String)en.get("LZFPTDYSLXDM");
String hzcxje = (String)en.get("HZCXJE");
String hzcxse = (String)en.get("HZCXSE");
String hzqrdmxsl = (String)en.get("HZQRDMXSL");
String chyydm = (String)en.get("CHYYDM");
String hzqrxxztdm = (String)en.get("HZQRXXZTDM");
String qrrq = (String)en.get("QRRQ");
String ykjhzfpbz = (String)en.get("YKJHZFPBZ");
String hzfphm = (String)en.get("HZFPHM");
String hzkprq = (String)en.get("HZKPRQ");
String yxbz = (String)en.get("YXBZ");
SpecialInvoiceReversalEntity redEn = new SpecialInvoiceReversalEntity();
String id = baseService.getGenerateShotKey();
redEn.setId(id);
redEn.setType(ConfigureConstant.STRING_5);
redEn.setSqsm(lrfsf);
redEn.setUuid(uuid);
redEn.setXxbbh(hzfpxxqrdbh);
redEn.setLrfsf(lrfsf);
redEn.setXhfNsrsbh(xsfnsrsbh);
redEn.setXhfMc(xsfmc);
redEn.setGhfNsrsbh(gmfnsrsbh);
redEn.setGhfMc(gmfmc);
redEn.setYfpDm(lzfpdm);
redEn.setYfpHm(lzfphm);
redEn.setSfzzfpbz(sfzzfpbz);
if(StrUtil.isNotBlank(lzkprq)){
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
try {
redEn.setYfpKprq(sdf.parse(lzkprq));
} catch (ParseException e) {
log.error("{}格式化蓝字发票开票日期错误:{}",LOGGER_MSG,e);
}
}
redEn.setLzhjje(lzhjje);
redEn.setLzhjse(lzhjse);
redEn.setLzfppzdm(lzfppzdm);
redEn.setLzfptdyslxdm(lzfptdyslxdm);
redEn.setHjbhsje(hzcxje);
redEn.setHjse(hzcxse);
redEn.setKphjje(new BigDecimal(hzcxje).add(new BigDecimal(hzcxse)).toString());
redEn.setHzqrdmxsl(hzqrdmxsl);
redEn.setChyy(chyydm);
redEn.setStatusCode(hzqrxxztdm);
redEn.setStatusMessage(getStatusMessage(hzqrxxztdm));
redEn.setQrrq(qrrq);
redEn.setKpzt("Y".equals(ykjhzfpbz)?"2":"0");
redEn.setFphm(hzfphm);
redEn.setDataStatus("Y".equals(yxbz)?"0":"1");
redEn.setInvoiceType("1");
redEn.setFpzlDm(lzfppzdm);
redEn.setNsrsbh(xsfnsrsbh);
redEn.setGhfqylx("01");
redEn.setCreatorId("1");
redEn.setCreatorName("系统管理员");
redEn.setEditorId("1");
redEn.setEditorName("系统管理员 ");
redEn.setCreateTime(new Date());
redEn.setUpdateTime(new Date());
redEn.setTksj(new Date());
return redEn;
}
private SpecialInvoiceReversalItem createHzxxbItem(Map en,String mainId){
String xh = (String)en.get("XH");
String lzmxxh = (String)en.get("LZMXXH");
String sphfwssflhbbm = (String)en.get("SPHFWSSFLHBBM");
String hwhyslwfwmc = (String)en.get("HWHYSLWFWMC");
String spfwjc = (String)en.get("SPFWJC");
String xmmc = (String)en.get("XMMC");
String ggxh = (String)en.get("GGXH");
String dw = (String)en.get("DW");
String fpspdj = (String)en.get("FPSPDJ");
String fpspsl = (String)en.get("FPSPSL");
String je = (String)en.get("JE");
String slv = (String)en.get("SLV");
String se = (String)en.get("SE");
SpecialInvoiceReversalItem item = new SpecialInvoiceReversalItem();
item.setId(baseService.getGenerateShotKey());
item.setSpecialInvoiceReversalId(mainId);
item.setSpbm(sphfwssflhbbm);
item.setXmmc(xmmc);
item.setGgxh(ggxh);
item.setXmdw(dw);
item.setXmsl(fpspsl);
item.setXmdj(fpspdj);
item.setXmje(je);
item.setSl(slv.replaceAll("(0)+$", ""));
item.setSe(se);
item.setHsbz("0");
item.setSphxh(xh);
item.setYhzcbs("0");
item.setCreateTime(new Date());
item.setLzmxxh(lzmxxh);
return item;
}
private String getStatusMessage(String status){
String statusMessage = "";
if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_01.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_01.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_02.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_02.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_03.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_03.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_04.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_04.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_05.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_05.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_06.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_06.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_07.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_07.getValue();
}else if(OrderInfoEnum.SPECIAL_INVOICE_STATUS_08.getKey().equals(status)){
statusMessage = OrderInfoEnum.SPECIAL_INVOICE_STATUS_08.getValue();
}
return statusMessage;
}
public List<DeptEntity> queryAllDeptInfo(){
Map<String,String> headMap = Maps.newHashMap();
headMap.put("Content-Type", ContentType.APPLICATION_JSON.toString());
Map<String,String> requestMap = Maps.newHashMap();
requestMap.put("deptId","0");
String result = HttpUtils.doPostWithHeader(openApiConfig.queryAllDeptInfo(), JSONObject.toJSONString(requestMap),headMap);
final String resultData = getDBResultData(result);
if(resultData != null){
final JSONArray jsonArray = JSONObject.parseObject(resultData, JSONArray.class);
return jsonArray.toJavaList(DeptEntity.class);
}
return null;
}
public String getDBResultData(String result){
if(StringUtils.isNotBlank(result)){
JSONObject jsonObject = JSONObject.parseObject(result, JSONObject.class);
Object code = jsonObject.get(OrderManagementConstant.CODE);
if(code != null && OrderInfoContentEnum.SUCCESS.getKey().equals((String) code)){
Object data = jsonObject.get(OrderManagementConstant.DATA);
if(data != null){
return JSONObject.toJSONString(data);
}
}
}
return null;
}
}

@ -171,4 +171,53 @@ public class SpecialInvoiceReversalEntity implements Serializable {
* 蓝票entId
*/
private String entId;
/**
* 全电-红字确认单UUID
*/
private String uuid;
/**
* 全电-录入方身份 0销方 1购方
*/
private String lrfsf;
/**
* 全电-是否纸质发票标志 Y=纸质发票N=电子发票
*/
private String sfzzfpbz;
/**
* 全电-蓝字发票合计金额
*/
private String lzhjje;
/**
* 全电-蓝字发票合计税额
*/
private String lzhjse;
/**
* 全电-蓝字发票票种代码
* 01: 增值税专用发票
* 02: 普通发票
* 03: 机动车统一销售发票
* 04: 二手车统一销售发票
*/
private String lzfppzdm;
/**
* 全电-蓝字发票特定要素类型代码
*/
private String lzfptdyslxdm;
/**
* 全电-红字确认单明细数量
*/
private String hzqrdmxsl;
/**
* 全电-确认日期
*/
private String qrrq;
}

@ -192,4 +192,6 @@ public interface SpecialInvoiceReversalService {
* @return
*/
SpecialInvoiceReversalEntity selectSpecialInvoiceReversalBySqdh(String sqdwybh);
List<SpecialInvoiceReversalEntity> querySpecialInvoice(Map<String, Object> params);
}

@ -384,4 +384,10 @@ public class SpecialInvoiceReversalServiceImpl implements SpecialInvoiceReversal
query.setSqdh(sqdwybh);
return specialInvoiceReversalMapper.selectSpecialInvoiceReversal(query);
}
@Override
public List<SpecialInvoiceReversalEntity> querySpecialInvoice(Map<String, Object> params){
List<SpecialInvoiceReversalEntity> list = specialInvoiceReversalMapper.selectSpecialInvoiceReversals(params);
return list;
}
}

@ -23,12 +23,13 @@
<result column="zzstsgl" property="zzstsgl" jdbcType="VARCHAR"/>
<result column="wcje" property="wcje" jdbcType="VARCHAR"/>
<result column="create_time" property="createTime" jdbcType="TIMESTAMP"/>
<result column="lzmxxh" property="lzmxxh" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
id
, special_invoice_reversal_id, spbm, zxbm, xmmc, ggxh, xmdw, xmsl, xmdj, kce, xmje,
sl, se, hsbz, fphxz, sphxh, lslbs, yhzcbs, zzstsgl, wcje, create_time
sl, se, hsbz, fphxz, sphxh, lslbs, yhzcbs, zzstsgl, wcje, create_time,lzmxxh
</sql>
<select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.String">
@ -57,13 +58,13 @@
xmsl, xmdj, kce, xmje,
sl, se, hsbz, fphxz,
sphxh, lslbs, yhzcbs,
zzstsgl, wcje, create_time)
zzstsgl, wcje, create_time,lzmxxh)
values (#{id,jdbcType=VARCHAR}, #{specialInvoiceReversalId,jdbcType=VARCHAR}, #{spbm,jdbcType=VARCHAR},
#{zxbm,jdbcType=VARCHAR}, #{xmmc,jdbcType=VARCHAR}, #{ggxh,jdbcType=VARCHAR}, #{xmdw,jdbcType=VARCHAR},
#{xmsl,jdbcType=VARCHAR}, #{xmdj,jdbcType=VARCHAR}, #{kce,jdbcType=VARCHAR}, #{xmje,jdbcType=VARCHAR},
#{sl,jdbcType=VARCHAR}, #{se,jdbcType=VARCHAR}, #{hsbz,jdbcType=VARCHAR}, #{fphxz,jdbcType=VARCHAR},
#{sphxh,jdbcType=VARCHAR}, #{lslbs,jdbcType=VARCHAR}, #{yhzcbs,jdbcType=VARCHAR},
#{zzstsgl,jdbcType=VARCHAR}, #{wcje,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP})
#{zzstsgl,jdbcType=VARCHAR}, #{wcje,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP}, #{lzmxxh,jdbcType=VARCHAR})
</insert>
<insert id="insertSpecialInvoiceReversalItem" parameterType="com.dxhy.order.model.SpecialInvoiceReversalItem">
@ -132,6 +133,9 @@
<if test="createTime != null">
create_time,
</if>
<if test="lzmxxh != null">
lzmxxh,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
@ -197,6 +201,9 @@
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
<if test="lzmxxh != null">
#{lzmxxh,jdbcType=VARCHAR},
</if>
</trim>
</insert>
@ -263,6 +270,9 @@
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="lzmxxh != null">
lzmxxh = #{lzmxxh,jdbcType=VARCHAR},
</if>
</set>
where id = #{id,jdbcType=VARCHAR}
</update>
@ -288,7 +298,8 @@
yhzcbs = #{yhzcbs,jdbcType=VARCHAR},
zzstsgl = #{zzstsgl,jdbcType=VARCHAR},
wcje = #{wcje,jdbcType=VARCHAR},
create_time = #{createTime,jdbcType=TIMESTAMP}
create_time = #{createTime,jdbcType=TIMESTAMP},
lzmxxh = #{lzmxxh,jdbcType=VARCHAR}
where id = #{id,jdbcType=VARCHAR}
</update>

@ -60,6 +60,15 @@
<result column="scfg_status" property="scfgStatus" jdbcType="VARCHAR"/>
<result column="xzfg_status" property="xzfgStatus" jdbcType="VARCHAR"/>
<result column="ywddh" property="ywddh" jdbcType="VARCHAR"/>
<result column="uuid" property="uuid" jdbcType="VARCHAR"/>
<result column="lrfsf" property="lrfsf" jdbcType="VARCHAR"/>
<result column="sfzzfpbz" property="sfzzfpbz" jdbcType="VARCHAR"/>
<result column="lzhjje" property="lzhjje" jdbcType="VARCHAR"/>
<result column="lzhjse" property="lzhjse" jdbcType="VARCHAR"/>
<result column="lzfppzdm" property="lzfppzdm" jdbcType="VARCHAR"/>
<result column="lzfptdyslxdm" property="lzfptdyslxdm" jdbcType="VARCHAR"/>
<result column="hzqrdmxsl" property="hzqrdmxsl" jdbcType="VARCHAR"/>
<result column="qrrq" property="qrrq" jdbcType="VARCHAR"/>
</resultMap>
<resultMap id="selectSpecialInvoiceReversalsCountResultMap" type="com.dxhy.order.invoice.module.invoicespecial.model.bo.SpecialInvoiceReversalsCountBO">
@ -73,7 +82,8 @@
xhf_zh, ghf_mc, ghf_nsrsbh, ghf_dz, ghf_dh, ghf_yh, ghf_zh, ghfqylx, hjbhsje, hjse,
kphjje, dslbz, xxbbh, bmbbbh, kpzt, fpdm, fphm, sld, sld_mc, fjh, chyy, kpr, fhr,
skr, agent_name, status_code, status_message, creator_id, creator_name, editor_id,
editor_name, create_time, update_time, data_status,scfg_status,xzfg_status,ywddh
editor_name, create_time, update_time, data_status,scfg_status,xzfg_status,ywddh,
uuid,lrfsf,sfzzfpbz,lzhjje,lzhjse,lzfppzdm,lzfptdyslxdm,hzqrdmxsl,qrrq
</sql>
@ -248,6 +258,18 @@
<if test="id != null and id != '' ">
and id = #{id,jdbcType=VARCHAR}
</if>
<if test="uuid != null and uuid != '' ">
and uuid = #{uuid,jdbcType=VARCHAR}
</if>
<if test="lrfsf != null and lrfsf != '' ">
and lrfsf = #{lrfsf,jdbcType=VARCHAR}
</if>
<if test="lzfppzdm != null and lzfppzdm != '' ">
and lzfppzdm = #{lzfppzdm,jdbcType=VARCHAR}
</if>
<if test="lzfptdyslxdm != null and lzfptdyslxdm != '' ">
and lzfptdyslxdm = #{lzfptdyslxdm,jdbcType=VARCHAR}
</if>
</where>
</sql>
@ -383,6 +405,18 @@
<if test="xxbbh != null">
and xxbbh = #{xxbbh,jdbcType=VARCHAR}
</if>
<if test="uuid != null and uuid != '' ">
and uuid = #{uuid,jdbcType=VARCHAR}
</if>
<if test="lrfsf != null and lrfsf != '' ">
and lrfsf = #{lrfsf,jdbcType=VARCHAR}
</if>
<if test="lzfppzdm != null and lzfppzdm != '' ">
and lzfppzdm = #{lzfppzdm,jdbcType=VARCHAR}
</if>
<if test="lzfptdyslxdm != null and lzfptdyslxdm != '' ">
and lzfptdyslxdm = #{lzfptdyslxdm,jdbcType=VARCHAR}
</if>
</sql>
@ -645,6 +679,33 @@
<if test="xzfgStatus != null">
xzfg_status,
</if>
<if test="uuid != null">
uuid,
</if>
<if test="lrfsf != null">
lrfsf,
</if>
<if test="sfzzfpbz != null">
sfzzfpbz,
</if>
<if test="lzhjje != null">
lzhjje,
</if>
<if test="lzhjse != null">
lzhjse,
</if>
<if test="lzfppzdm != null">
lzfppzdm,
</if>
<if test="lzfptdyslxdm != null">
lzfptdyslxdm,
</if>
<if test="hzqrdmxsl != null">
hzqrdmxsl,
</if>
<if test="qrrq != null">
qrrq,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
@ -818,6 +879,33 @@
<if test="xzfgStatus != null">
#{xzfgStatus,jdbcType=VARCHAR},
</if>
<if test="uuid != null">
#{uuid,jdbcType=VARCHAR},
</if>
<if test="lrfsf != null">
#{lrfsf,jdbcType=VARCHAR},
</if>
<if test="sfzzfpbz != null">
#{sfzzfpbz,jdbcType=VARCHAR},
</if>
<if test="lzhjje != null">
#{lzhjje,jdbcType=VARCHAR},
</if>
<if test="lzhjse != null">
#{lzhjse,jdbcType=VARCHAR},
</if>
<if test="lzfppzdm != null">
#{lzfppzdm,jdbcType=VARCHAR},
</if>
<if test="lzfptdyslxdm != null">
#{lzfptdyslxdm,jdbcType=VARCHAR},
</if>
<if test="hzqrdmxsl != null">
#{hzqrdmxsl,jdbcType=VARCHAR},
</if>
<if test="qrrq != null">
#{qrrq,jdbcType=VARCHAR},
</if>
</trim>
</insert>
@ -1006,6 +1094,33 @@
<if test="xzfgStatus != null">
xzfg_status = #{xzfgStatus,jdbcType=VARCHAR},
</if>
<if test="uuid != null">
uuid = #{uuid,jdbcType=VARCHAR},
</if>
<if test="lrfsf != null">
lrfsf = #{lrfsf,jdbcType=VARCHAR},
</if>
<if test="sfzzfpbz != null">
sfzzfpbz = #{sfzzfpbz,jdbcType=VARCHAR},
</if>
<if test="lzhjje != null">
lzhjje = #{lzhjje,jdbcType=VARCHAR},
</if>
<if test="lzhjse != null">
lzhjse = #{lzhjse,jdbcType=VARCHAR},
</if>
<if test="lzfppzdm != null">
lzfppzdm = #{lzfppzdm,jdbcType=VARCHAR},
</if>
<if test="lzfptdyslxdm != null">
lzfptdyslxdm = #{lzfptdyslxdm,jdbcType=VARCHAR},
</if>
<if test="hzqrdmxsl != null">
hzqrdmxsl = #{hzqrdmxsl,jdbcType=VARCHAR},
</if>
<if test="qrrq != null">
qrrq = #{qrrq,jdbcType=VARCHAR},
</if>
</set>
<where>
<if test="id != null and id != '' ">

Loading…
Cancel
Save