package com.ruoyi.system.service.impl;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.ruoyi.common.utils.LongUtil;
|
import com.ruoyi.system.domain.SysTaskEmergency;
|
import com.ruoyi.system.mapper.SysTaskEmergencyMapper;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.system.domain.SysInvoice;
|
import com.ruoyi.system.mapper.SysInvoiceMapper;
|
import com.ruoyi.system.mapper.LegacyInvoiceMapper;
|
import com.ruoyi.system.mapper.SysUserMapper;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.system.service.ISysInvoiceService;
|
|
/**
|
* 发票申请Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2026-02-02
|
*/
|
@Service
|
public class SysInvoiceServiceImpl implements ISysInvoiceService
|
{
|
private static final Logger log = LoggerFactory.getLogger(SysInvoiceServiceImpl.class);
|
|
@Autowired
|
private SysInvoiceMapper sysInvoiceMapper;
|
|
@Autowired
|
private LegacyInvoiceMapper legacyInvoiceMapper;
|
|
@Autowired
|
private SysUserMapper sysUserMapper;
|
|
@Autowired
|
private SysTaskEmergencyMapper sysTaskEmergencyMapper;
|
|
/**
|
* 查询发票申请
|
*
|
* @param invoiceId 发票申请主键
|
* @return 发票申请
|
*/
|
@Override
|
public SysInvoice selectSysInvoiceByInvoiceId(Long invoiceId)
|
{
|
return sysInvoiceMapper.selectSysInvoiceByInvoiceId(invoiceId);
|
}
|
|
/**
|
* 查询发票申请列表
|
*
|
* @param sysInvoice 发票申请
|
* @return 发票申请
|
*/
|
@Override
|
public List<SysInvoice> selectSysInvoiceList(SysInvoice sysInvoice)
|
{
|
return sysInvoiceMapper.selectSysInvoiceList(sysInvoice);
|
}
|
|
/**
|
* 查询我的发票申请列表（App端，返回Map包含serviceCode）
|
*
|
* @param sysInvoice 发票申请
|
* @return 发票申请
|
*/
|
@Override
|
public List<Map<String, Object>> selectMyInvoiceList(SysInvoice sysInvoice)
|
{
|
return sysInvoiceMapper.selectMyInvoiceList(sysInvoice);
|
}
|
|
/**
|
* 新增发票申请
|
*
|
* @param sysInvoice 发票申请
|
* @return 结果
|
*/
|
@Override
|
public int insertSysInvoice(SysInvoice sysInvoice)
|
{
|
Long taskId = sysInvoice.getServiceOrderId();
|
Long legacyServiceOrdId = sysInvoice.getLegacyServiceOrderId();
|
if(LongUtil.isNotEmpty(taskId) && LongUtil.isEmpty(legacyServiceOrdId)){
|
SysTaskEmergency taskEmergency= sysTaskEmergencyMapper.selectSysTaskEmergencyByTaskId(taskId);
|
if(taskEmergency!=null){
|
legacyServiceOrdId=taskEmergency.getLegacyServiceOrdId();
|
}
|
|
}
|
sysInvoice.setLegacyServiceOrderId(legacyServiceOrdId);
|
sysInvoice.setApplyTime(DateUtils.getNowDate());
|
sysInvoice.setStatus(0); // 待审核
|
sysInvoice.setSyncStatus(0); // 未同步
|
int rows = sysInvoiceMapper.insertSysInvoice(sysInvoice);
|
|
// 自动尝试同步到旧系统
|
if (rows > 0) {
|
try {
|
syncToLegacySystem(sysInvoice.getInvoiceId());
|
} catch (Exception e) {
|
log.error("同步发票申请到旧系统失败", e);
|
}
|
}
|
return rows;
|
}
|
|
/**
|
* 修改发票申请
|
*
|
* @param sysInvoice 发票申请
|
* @return 结果
|
*/
|
@Override
|
public int updateSysInvoice(SysInvoice sysInvoice)
|
{
|
return sysInvoiceMapper.updateSysInvoice(sysInvoice);
|
}
|
|
/**
|
* 批量删除发票申请
|
*
|
* @param invoiceIds 需要删除的发票申请主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteSysInvoiceByInvoiceIds(Long[] invoiceIds)
|
{
|
return sysInvoiceMapper.deleteSysInvoiceByInvoiceIds(invoiceIds);
|
}
|
|
/**
|
* 删除发票申请信息
|
*
|
* @param invoiceId 发票申请主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteSysInvoiceByInvoiceId(Long invoiceId)
|
{
|
return sysInvoiceMapper.deleteSysInvoiceByInvoiceId(invoiceId);
|
}
|
|
/**
|
* 同步发票申请到旧系统 (SQL Server)
|
*/
|
@Override
|
public int syncToLegacySystem(Long invoiceId) {
|
SysInvoice invoice = sysInvoiceMapper.selectSysInvoiceByInvoiceId(invoiceId);
|
if (invoice == null) return 0;
|
|
Map<String, Object> params = new HashMap<>();
|
params.put("ServiceOrderIDPK", invoice.getLegacyServiceOrderId());
|
params.put("InvoiceType", invoice.getInvoiceType());
|
params.put("InvoiceName", invoice.getInvoiceName());
|
params.put("InvoiceMakeout", invoice.getInvoiceRemarks());
|
params.put("InvoiceCompanyPhone", invoice.getContactPhone());
|
params.put("InvoiceCompanyID", ""); // 税号字段若有可补
|
params.put("InvoiceCompanyAdd", invoice.getCompanyAddress());
|
params.put("InvoiceCompanyBank", invoice.getCompanyBank());
|
params.put("InvoiceCompanyBankNo", invoice.getCompanyBankNo());
|
params.put("InvoiceZipCode", invoice.getZipCode());
|
params.put("Invoice_strAdd", invoice.getMailAddress());
|
params.put("Invoice_strName", invoice.getContactName());
|
params.put("Invoice_strPhone", invoice.getContactPhone());
|
params.put("Invoice_strEmail", invoice.getContactEmail());
|
params.put("InvoiceMoney", invoice.getInvoiceMoney());
|
|
// 通过创建人BID查询OA用户ID
|
Integer oaUserId = 0;
|
if (invoice.getApplyUserId() != null) {
|
SysUser user = sysUserMapper.selectUserById(invoice.getApplyUserId());
|
if (user != null && user.getOaUserId() != null) {
|
oaUserId = user.getOaUserId();
|
}
|
}
|
params.put("ApplyOAID", oaUserId);
|
|
try {
|
int rows = legacyInvoiceMapper.insertLegacyInvoice(params);
|
if (rows > 0) {
|
// SQL Server insert 会通过 useGeneratedKeys 返回自增 ID 到 Map 的 keyProperty
|
Object legacyId = params.get("InvoiceID");
|
if (legacyId != null) {
|
invoice.setLegacyInvoiceId(Integer.valueOf(legacyId.toString()));
|
invoice.setSyncStatus(1); // 已同步
|
sysInvoiceMapper.updateSysInvoice(invoice);
|
}
|
}
|
return rows;
|
} catch (Exception e) {
|
log.error("同步发票到旧系统异常: {}", e.getMessage());
|
invoice.setSyncStatus(2); // 同步失败
|
sysInvoiceMapper.updateSysInvoice(invoice);
|
throw e;
|
}
|
}
|
|
/**
|
* 编辑后同步更新到旧系统
|
* - 已有 legacyInvoiceId：直接 UPDATE 旧系统记录
|
* - 无 legacyInvoiceId（历史同步失败）：重新 INSERT
|
*/
|
@Override
|
public void syncUpdateToLegacySystem(Long invoiceId) {
|
SysInvoice invoice = sysInvoiceMapper.selectSysInvoiceByInvoiceId(invoiceId);
|
if (invoice == null) return;
|
|
Map<String, Object> params = new HashMap<>();
|
params.put("InvoiceType", invoice.getInvoiceType());
|
params.put("InvoiceName", invoice.getInvoiceName());
|
params.put("InvoiceMakeout", invoice.getInvoiceRemarks());
|
params.put("InvoiceCompanyPhone", invoice.getContactPhone());
|
params.put("InvoiceCompanyID", "");
|
params.put("InvoiceCompanyAdd", invoice.getCompanyAddress());
|
params.put("InvoiceCompanyBank", invoice.getCompanyBank());
|
params.put("InvoiceCompanyBankNo",invoice.getCompanyBankNo());
|
params.put("InvoiceZipCode", invoice.getZipCode());
|
params.put("Invoice_strAdd", invoice.getMailAddress());
|
params.put("Invoice_strName", invoice.getContactName());
|
params.put("Invoice_strPhone", invoice.getContactPhone());
|
params.put("Invoice_strEmail", invoice.getContactEmail());
|
params.put("ServiceOrderIDPK", invoice.getLegacyServiceOrderId());
|
params.put("InvoiceMoney", invoice.getInvoiceMoney());
|
|
Integer oaUserId = 0;
|
if (invoice.getApplyUserId() != null) {
|
SysUser user = sysUserMapper.selectUserById(invoice.getApplyUserId());
|
if (user != null && user.getOaUserId() != null) {
|
oaUserId = user.getOaUserId();
|
}
|
}
|
params.put("ApplyOAID", oaUserId);
|
|
try {
|
if (invoice.getLegacyInvoiceId() != null && invoice.getLegacyInvoiceId() > 0) {
|
// 旧系统已有记录，UPDATE
|
params.put("InvoiceID", invoice.getLegacyInvoiceId());
|
int rows = legacyInvoiceMapper.updateLegacyInvoice(params);
|
if (rows > 0) {
|
invoice.setSyncStatus(1);
|
sysInvoiceMapper.updateSysInvoice(invoice);
|
log.info("发票编辑同步旧系统成功(UPDATE), invoiceId={}, legacyId={}", invoiceId, invoice.getLegacyInvoiceId());
|
}
|
} else {
|
// 旧系统无记录，重新 INSERT
|
params.put("ServiceOrderIDPK", invoice.getLegacyServiceOrderId());
|
int rows = legacyInvoiceMapper.insertLegacyInvoice(params);
|
if (rows > 0) {
|
Object legacyId = params.get("InvoiceID");
|
if (legacyId != null) {
|
invoice.setLegacyInvoiceId(Integer.valueOf(legacyId.toString()));
|
}
|
invoice.setSyncStatus(1);
|
sysInvoiceMapper.updateSysInvoice(invoice);
|
log.info("发票编辑同步旧系统成功(INSERT), invoiceId={}", invoiceId);
|
}
|
}
|
} catch (Exception e) {
|
log.error("发票编辑同步旧系统异常, invoiceId={}: {}", invoiceId, e.getMessage());
|
invoice.setSyncStatus(2);
|
sysInvoiceMapper.updateSysInvoice(invoice);
|
}
|
}
|
|
/**
|
* 从旧系统同步发票状态变化
|
*/
|
@Override
|
public void syncStatusFromLegacySystem() {
|
// 查询最近3天有变化的数据
|
String lastSyncTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addDays(new Date(), -3));
|
List<Map<String, Object>> updatedList = legacyInvoiceMapper.selectUpdatedInvoices(lastSyncTime);
|
|
for (Map<String, Object> legacyData : updatedList) {
|
Integer legacyId = (Integer) legacyData.get("InvoiceID");
|
SysInvoice invoice = sysInvoiceMapper.selectSysInvoiceByLegacyId(legacyId);
|
|
if (invoice != null) {
|
// 状态映射：旧系统 AuditStatus (假设 3=通过, 4=拒绝, 其他=申请中)
|
Integer auditStatus = (Integer) legacyData.get("AuditStatus");
|
if (auditStatus != null) {
|
if (auditStatus == 3) invoice.setStatus(1); // 已通过
|
else if (auditStatus == 4) invoice.setStatus(2); // 已驳回
|
}
|
|
// 更新其他信息
|
if (legacyData.get("InvoiceNo") != null) {
|
invoice.setInvoiceNo(legacyData.get("InvoiceNo").toString());
|
}
|
|
// 发票文件链接 (优先取 EleCloud_PDF)
|
String pdf = legacyData.get("EleCloud_PDF") != null ? legacyData.get("EleCloud_PDF").toString() : null;
|
String url = legacyData.get("InvoiceURL") != null ? legacyData.get("InvoiceURL").toString() : null;
|
invoice.setInvoiceUrl(pdf != null && !pdf.isEmpty() ? pdf : url);
|
|
if (legacyData.get("AuditTime") != null) {
|
invoice.setAuditTime((Date) legacyData.get("AuditTime"));
|
}
|
if (legacyData.get("AuditMakeout") != null) {
|
invoice.setAuditRemarks(legacyData.get("AuditMakeout").toString());
|
}
|
|
sysInvoiceMapper.updateSysInvoice(invoice);
|
}
|
}
|
}
|
|
/**
|
* 查询可选择的任务列表
|
*/
|
@Override
|
public List<Map<String, Object>> selectSelectableTasks(Long userId, String searchKeyword, String serviceOrdClass) {
|
return sysInvoiceMapper.selectSelectableTasks(userId, searchKeyword, serviceOrdClass);
|
}
|
}
|
