package com.by4cloud.platformx.business.controller;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.util.ArrayUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.by4cloud.platformx.admin.api.entity.SysDept;
|
import com.by4cloud.platformx.admin.api.feign.RemoteDeptService;
|
import com.by4cloud.platformx.business.entity.*;
|
import com.by4cloud.platformx.business.entity.invoice.vo.BipResVo;
|
import com.by4cloud.platformx.business.entity.invoice.vo.InvoicingVo;
|
import com.by4cloud.platformx.business.invoice.service.BIPYsService;
|
import com.by4cloud.platformx.business.service.*;
|
import com.by4cloud.platformx.business.vo.ContractOutBoundVo;
|
import com.by4cloud.platformx.common.core.util.R;
|
import com.by4cloud.platformx.common.data.mybatis.BaseModel;
|
import com.by4cloud.platformx.common.excel.annotation.ResponseExcel;
|
import com.by4cloud.platformx.common.log.annotation.SysLog;
|
import com.by4cloud.platformx.common.security.annotation.Inner;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.security.SecurityRequirement;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import lombok.RequiredArgsConstructor;
|
import org.springdoc.core.annotations.ParameterObject;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 销售挂账
|
*
|
* @author wjli
|
* @date 2026-05-21 16:16:31
|
*/
|
@RestController
|
@RequiredArgsConstructor
|
@RequestMapping("/saleCredit" )
|
@Tag(description = "saleCredit" , name = "销售挂账管理" )
|
@SecurityRequirement(name = HttpHeaders.AUTHORIZATION)
|
public class SaleCreditController {
|
|
private final SaleCreditService saleCreditService;
|
private final ContractService contractService;
|
private final BusinessCustomerService businessCustomerService;
|
private final ContractOutBoundService contractOutBoundService;
|
private final ProductService productService;
|
private final ContractSubjectMatterService contractSubjectMatterService;
|
private final RemoteDeptService remoteDeptService;
|
|
private final InvoiceService invoiceService;
|
private final BIPYsService bipYsService;
|
|
|
/**
|
* 分页查询
|
* @param page 分页对象
|
* @param saleCredit 销售挂账
|
* @return
|
*/
|
@Operation(summary = "分页查询" , description = "分页查询" )
|
@GetMapping("/page" )
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_view')" )
|
public R getSaleCreditPage(@ParameterObject Page page, @ParameterObject SaleCredit saleCredit) {
|
LambdaQueryWrapper<SaleCredit> wrapper = Wrappers.lambdaQuery();
|
return R.ok(saleCreditService.page(page, wrapper));
|
}
|
|
|
/**
|
* 通过id查询销售挂账
|
* @param id id
|
* @return R
|
*/
|
@Operation(summary = "通过id查询" , description = "通过id查询" )
|
@GetMapping("/{id}" )
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_view')" )
|
public R getById(@PathVariable("id" ) Long id) {
|
return R.ok(saleCreditService.getById(id));
|
}
|
|
/**
|
* 新增销售挂账
|
* @param saleCredit 销售挂账
|
* @return R
|
*/
|
@Operation(summary = "新增销售挂账" , description = "新增销售挂账" )
|
@SysLog("新增销售挂账" )
|
@PostMapping
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_add')" )
|
public R save(@RequestBody SaleCredit saleCredit) {
|
return R.ok(saleCreditService.save(saleCredit));
|
}
|
|
|
/**
|
* 新增销售挂账
|
* @param saleCredit 销售挂账
|
* @return R
|
*/
|
@Operation(summary = "销售挂账生成" , description = "销售挂账生成" )
|
@SysLog("销售挂账生成" )
|
@PostMapping("/saveSaleCredit")
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_add')" )
|
public R saveInvoice(@RequestBody SaleCredit saleCredit) {
|
//开票中
|
saleCredit.setStatus(1);
|
saleCreditService.save(saleCredit);
|
//标记出库单被标识
|
List<ContractOutBoundVo> contractOutBoundList = saleCredit.getContractOutBoundList();
|
if(contractOutBoundList==null){
|
return R.failed("请选择出库单！");
|
}
|
if(contractOutBoundList.size()==0){
|
return R.failed("请选择出库单！");
|
}
|
//开票之前，先记录开票信息
|
//1.出库单进行标记，将出库单发票记录id填入。将InvoiceSatus=1开票中。
|
String outBoundIds = "";
|
for(ContractOutBoundVo vo : contractOutBoundList){
|
if(StrUtil.isEmpty(outBoundIds)){
|
outBoundIds = "" + vo.getId();
|
}else{
|
outBoundIds += "," + vo.getId();
|
}
|
ContractOutBound outBound = contractOutBoundService.getById(vo.getId());
|
outBound.setSaleCreditId(saleCredit.getId());
|
outBound.setTotalPrice(vo.getTotalPrice());
|
outBound.setTotalTax(vo.getTotalTax());
|
outBound.setProductId(vo.getProductId());
|
outBound.setTaxRate(vo.getTaxRate());
|
outBound.setTaxClass(vo.getTaxClass());
|
outBound.setTaxCode(vo.getTaxCode());
|
outBound.setSpecification(vo.getSpecification());
|
outBound.setUnit(vo.getUnit());
|
outBound.setUnitPrice(vo.getUnitPrice());
|
outBound.setInvoiceSatus(1);
|
contractOutBoundService.updateById(outBound);
|
}
|
//结算中记录出库单ids.
|
saleCredit.setOutBoundIds(outBoundIds);
|
//生成结算单号
|
saleCredit.setEntrustCode("JsNo"+System.currentTimeMillis());
|
saleCreditService.updateById(saleCredit);
|
|
//生成vo
|
/* InvoicingVo invoicingVo = invoiceService.toGetByCompareByVo(saleCredit,contractOutBoundList);
|
try {
|
Map<String, Object> objectMap = invoiceService.toKaipiao(invoicingVo);
|
Boolean success = (Boolean) objectMap.get("success");
|
String message = (String) objectMap.get("message");
|
//System.out.println(saleCredit.getEntrustCode() + "的railwayEntrust蓝字开票结果为：" + success + "------" + message);
|
if(success){
|
saleCredit.setBlueResultStatus(1);
|
saleCreditService.updateById(saleCredit);
|
//StringBuffer errMsg = new StringBuffer();
|
BipResVo bipResVo = bipYsService.sendBIPYs(saleCredit);
|
if (!bipResVo.getCode().equals("200")) {
|
*//*if (StrUtil.isNotEmpty(errMsg)) {
|
errMsg.append(",");
|
}
|
errMsg.append(saleCredit.getCreditCodeB()+ "应收发票推送失败:" + bipResVo.getMessage());*//*
|
return R.failed("开票成功，推送bip失败，err:" + bipResVo.getMessage());
|
}else{
|
return R.ok("开票成功,推送big成功！");
|
}
|
}else{
|
saleCredit.setStatus(2);
|
saleCreditService.updateById(saleCredit);
|
return R.failed("开票失败！原因：" + message);
|
}
|
|
}catch (Exception e){
|
saleCredit.setStatus(3);
|
saleCreditService.updateById(saleCredit);
|
return R.failed("开票失败！");
|
}*/
|
//return R.ok("销售挂账生成！");
|
|
|
//出库单已开票
|
List<ContractOutBound> contractOutBounds = contractOutBoundService.list(new LambdaQueryWrapper<ContractOutBound>()
|
.eq(ContractOutBound::getSaleCreditId,saleCredit.getId())
|
);
|
for(ContractOutBound contractOutBound : contractOutBounds){
|
contractOutBound.setInvoiceSatus(2);
|
}
|
contractOutBoundService.updateBatchById(contractOutBounds);
|
|
//开票成功
|
//开票记录单蓝票信息存储
|
saleCredit.setBlueResultStatus(1);
|
saleCredit.setInvoiceRemark("开票成功！");
|
saleCredit.setBlueInvoiceTime(DateTime.now());
|
saleCreditService.updateById(saleCredit);
|
|
//相关合同金额和开票状态进行修改。
|
Contract contract = contractService.getById(saleCredit.getContractId());
|
String billingStatus = contract.getBillingStatus();
|
|
if(contract.getBillingAmout()==null){
|
contract.setBillingAmout(saleCredit.getTotalAmount());
|
}else{
|
contract.setBillingAmout(contract.getBillingAmout().add(saleCredit.getTotalAmount()));
|
}
|
|
int res = contract.getAmount().compareTo(contract.getBillingAmout());
|
|
if("2".equals(billingStatus)) {
|
if (res == 0) {
|
contract.setBillingStatus("3");
|
} else if (res > 0) {
|
contract.setBillingStatus("2");
|
} else {
|
return R.failed("已付金额不能大于总金额！");
|
}
|
}
|
|
contractService.updateById(contract);
|
return R.ok("开票成功，推送bip成功！");
|
}
|
|
/**
|
* 拼接销售挂账
|
* @param contract1 销售挂账
|
* @return R
|
*/
|
@Operation(summary = "获取发票列表" , description = "获取发票列表" )
|
@SysLog("获取发票列表" )
|
@GetMapping("/getInvoices")
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_view')" )
|
public R getInvoices(@ParameterObject Contract contract1) {
|
Contract contract = contractService.getById(contract1.getId());
|
if(contract==null){
|
return R.failed("合同id错误");
|
}
|
List<SaleCredit> saleCredits = saleCreditService.list(new LambdaQueryWrapper<SaleCredit>()
|
.eq(SaleCredit::getContractId,contract1.getId())
|
.orderByAsc(BaseModel::getCreateTime)
|
);
|
for(SaleCredit saleCredit : saleCredits){
|
if(saleCredit.getRedResultStatus()!=null && saleCredit.getRedResultStatus()>0){//说明已开红票
|
saleCredit.setBlueResultStatus(0);
|
if(saleCredit.getRedResultStatus()==1){
|
saleCredit.setInvoiceRemark("开红票成功！");
|
saleCredit.setInvoicRedUrl("红票url");
|
}else{
|
//显示 saleCredit.getInvoiceRemark();
|
}
|
}else{
|
if(saleCredit.getBlueResultStatus()==1){
|
saleCredit.setInvoiceRemark("开蓝票成功！");
|
saleCredit.setInvoicUrl("蓝票url");
|
}else if(saleCredit.getBlueResultStatus()==2){
|
//显示 saleCredit.getInvoiceRemark();
|
}
|
}
|
}
|
return R.ok(saleCredits);
|
}
|
|
/**
|
* 拼接销售挂账
|
* @param saleCredit1 销售挂账
|
* @return R
|
*/
|
@Operation(summary = "红冲发票" , description = "红冲发票" )
|
@SysLog("红冲发票" )
|
@PostMapping("/toRedStamp")
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_edit')" )
|
public R toRedStamp(@RequestBody SaleCredit saleCredit1) {
|
if(saleCredit1.getId()==null){
|
return R.failed("销售挂账id不能为空！");
|
}
|
SaleCredit saleCredit = saleCreditService.getById(saleCredit1.getId());
|
if(saleCredit==null){
|
return R.failed("销售挂账id不能为空！");
|
}
|
|
/*try {
|
Map<String, Object> map = invoiceService.toRedTicket(saleCredit);
|
Boolean success = (Boolean) map.get("success");
|
if(success){
|
return R.ok("红字开票成功");
|
}else {
|
return R.failed((String) map.get("message"));
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
return R.failed("红字开票失败");
|
}*/
|
|
|
//出库单恢复到未开票状态
|
List<ContractOutBound> outBoundList = contractOutBoundService.list(new LambdaQueryWrapper<ContractOutBound>()
|
.eq(ContractOutBound::getSaleCreditId,saleCredit.getId())
|
);
|
for(ContractOutBound outBound : outBoundList){
|
outBound.setInvoiceSatus(0);
|
outBound.setSaleCreditId(0l);
|
}
|
contractOutBoundService.updateBatchById(outBoundList);
|
|
saleCredit.setRedInvoiceTime(DateTime.now());
|
saleCredit.setRedResultStatus(1);
|
saleCredit.setInvoiceRemark("开红票成功！");
|
saleCreditService.updateById(saleCredit);
|
|
|
//合同已开票金额和状态还原
|
Contract contract = contractService.getById(saleCredit.getContractId());
|
String billingStatus = contract.getBillingStatus();
|
BigDecimal bill = contract.getBillingAmout() == null ? BigDecimal.ZERO : contract.getBillingAmout();
|
BigDecimal credit = saleCredit.getTotalAmount() == null ? BigDecimal.ZERO : saleCredit.getTotalAmount();
|
BigDecimal diff = bill.subtract(credit);
|
int res = diff.compareTo(BigDecimal.ZERO);
|
|
if("3".equals(billingStatus)){
|
if(res>=0){
|
contract.setBillingStatus("2");
|
contract.setBillingAmout(BigDecimal.ZERO);
|
}else{
|
return R.failed("已开票金额负数报错！");
|
}
|
}
|
contractService.updateById(contract);
|
return R.ok("红冲开票成功！");
|
}
|
|
|
|
/**
|
* 拼接销售挂账
|
* @param saleCredit 销售挂账
|
* @return R
|
*/
|
@Operation(summary = "拼接销售挂账" , description = "拼接销售挂账" )
|
@SysLog("拼接销售挂账" )
|
@GetMapping("/generatorInvoice")
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_view')" )
|
public R generatorInvoice(@ParameterObject SaleCredit saleCredit) {
|
if(saleCredit.getContractId()==null){
|
return R.failed("合同id不能为空");
|
}
|
Contract contract = contractService.getById(saleCredit.getContractId());
|
if(contract==null){
|
return R.failed("合同id错误");
|
}
|
saleCredit.setContractName(contract.getContractName());
|
saleCredit.setContractNo(contract.getContractNo());
|
|
BusinessCustomer partA = businessCustomerService.getById(contract.getPartyAId());
|
if(partA!=null){
|
saleCredit.setPartyA(partA.getCompanyName());
|
saleCredit.setCreditCodeA(partA.getCreditCode());
|
saleCredit.setBankAccountA(partA.getBankAccount());
|
saleCredit.setBankNameA(partA.getBankName());
|
}
|
R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
|
|
SysDept dept = r.getData();
|
if(dept!=null){
|
saleCredit.setPartyB(dept.getOrgName());
|
saleCredit.setCreditCodeB(dept.getOrgCode());
|
saleCredit.setBankAccountB(dept.getOrgBankAccount());
|
saleCredit.setBankNameB(dept.getOrgBank());
|
}
|
|
List<ContractOutBound> outBoundList = contractOutBoundService.list(new LambdaQueryWrapper<ContractOutBound>()
|
.eq(ContractOutBound::getContractId,contract.getId())
|
.eq(ContractOutBound::getInvoiceSatus,0)
|
.orderByAsc(ContractOutBound::getOutBoundTime)
|
);
|
|
if(outBoundList!=null){
|
if(!outBoundList.isEmpty()){
|
List<ContractOutBoundVo> list = new ArrayList<>();
|
for(ContractOutBound outBound : outBoundList){
|
ContractOutBoundVo vo = new ContractOutBoundVo();
|
BeanUtil.copyProperties(outBound,vo);
|
Product product = productService.getOne(new LambdaQueryWrapper<Product>().eq(Product::getErpCode,outBound.getSubjectMatterCode()).last("limit 1"));
|
Product productP = productService.getOne(new LambdaQueryWrapper<Product>().eq(Product::getId,product.getParentId()).last("limit 1"));
|
|
if(product!=null){
|
vo.setProductId(product.getId());
|
vo.setInvoiceName("*"+product.getTaxClass()+"*" + (productP!=null?productP.getProductName():"") + "*");
|
vo.setTaxClass(product.getTaxClass());
|
vo.setTaxCode(product.getTaxCode());
|
vo.setTaxRate(product.getTaxRate());
|
}
|
|
ContractSubjectMatter matter = contractSubjectMatterService.getOne(new LambdaQueryWrapper<ContractSubjectMatter>()
|
.eq(ContractSubjectMatter::getContractId,contract.getId())
|
.eq(ContractSubjectMatter::getMaterialCode,outBound.getSubjectMatterCode())
|
.last("limit 1")
|
);
|
|
if(matter!=null){
|
vo.setSpecification(matter.getSpecification());
|
vo.setUnit(matter.getUnit());
|
vo.setUnitPrice(matter.getUnitPrice());
|
}
|
|
list.add(vo);
|
}
|
saleCredit.setContractOutBoundList(list);
|
}
|
}
|
return R.ok(saleCredit);
|
}
|
|
|
|
/**
|
* 修改销售挂账
|
* @param saleCredit 销售挂账
|
* @return R
|
*/
|
@Operation(summary = "修改销售挂账" , description = "修改销售挂账" )
|
@SysLog("修改销售挂账" )
|
@PutMapping
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_edit')" )
|
public R updateById(@RequestBody SaleCredit saleCredit) {
|
return R.ok(saleCreditService.updateById(saleCredit));
|
}
|
|
/**
|
* 通过id删除销售挂账
|
* @param ids id列表
|
* @return R
|
*/
|
@Operation(summary = "通过id删除销售挂账" , description = "通过id删除销售挂账" )
|
@SysLog("通过id删除销售挂账" )
|
@DeleteMapping
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_del')" )
|
public R removeById(@RequestBody Long[] ids) {
|
return R.ok(saleCreditService.removeBatchByIds(CollUtil.toList(ids)));
|
}
|
|
|
/**
|
* 导出excel 表格
|
* @param saleCredit 查询条件
|
* @param ids 导出指定ID
|
* @return excel 文件流
|
*/
|
@ResponseExcel
|
@GetMapping("/export")
|
@PreAuthorize("@pms.hasPermission('business_saleCredit_export')" )
|
public List<SaleCredit> export(SaleCredit saleCredit,Long[] ids) {
|
return saleCreditService.list(Wrappers.lambdaQuery(saleCredit).in(ArrayUtil.isNotEmpty(ids), SaleCredit::getId, ids));
|
}
|
|
|
|
|
}
|
