package com.ruoyi.web.controller.system;
|
|
import java.util.List;
|
import java.util.Map;
|
import java.util.HashMap;
|
import javax.servlet.http.HttpServletResponse;
|
|
import com.ruoyi.common.utils.LongUtil;
|
import com.ruoyi.system.domain.SysTaskEmergency;
|
import com.ruoyi.system.service.ISysTaskEmergencyService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.PutMapping;
|
import org.springframework.web.bind.annotation.DeleteMapping;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.apache.commons.lang3.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.ruoyi.common.annotation.Log;
|
import com.ruoyi.common.core.controller.BaseController;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.core.domain.entity.SysDept;
|
import com.ruoyi.system.service.ISysDeptService;
|
import com.ruoyi.common.enums.BusinessType;
|
import com.ruoyi.system.domain.SysInvoice;
|
import com.ruoyi.system.service.ISysInvoiceService;
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
import com.ruoyi.common.core.page.TableDataInfo;
|
import com.ruoyi.common.utils.SecurityUtils;
|
|
/**
|
* 发票申请Controller
|
*
|
* @author ruoyi
|
* @date 2026-02-02
|
*/
|
@RestController
|
@RequestMapping("/system/invoice")
|
public class SysInvoiceController extends BaseController
|
{
|
private static final Logger log = LoggerFactory.getLogger(SysInvoiceController.class);
|
|
@Autowired
|
private ISysInvoiceService sysInvoiceService;
|
|
@Autowired
|
private ISysDeptService sysDeptService;
|
|
|
@Autowired
|
private ISysTaskEmergencyService sysTaskEmergencyService;
|
|
/**
|
* 查询发票申请列表
|
*/
|
@PreAuthorize("@ss.hasPermi('system:invoice:list')")
|
@GetMapping("/list")
|
public TableDataInfo list(SysInvoice sysInvoice)
|
{
|
startPage();
|
List<SysInvoice> list = sysInvoiceService.selectSysInvoiceList(sysInvoice);
|
return getDataTable(list);
|
}
|
|
/**
|
* App端查询我的发票申请列表
|
*/
|
@GetMapping("/myList")
|
public TableDataInfo myList(SysInvoice sysInvoice)
|
{
|
sysInvoice.setApplyUserId(SecurityUtils.getUserId());
|
startPage();
|
List<Map<String, Object>> list = sysInvoiceService.selectMyInvoiceList(sysInvoice);
|
return getDataTable(list);
|
}
|
|
/**
|
* 导出发票申请列表
|
*/
|
@PreAuthorize("@ss.hasPermi('system:invoice:export')")
|
@Log(title = "发票申请", businessType = BusinessType.EXPORT)
|
@PostMapping("/export")
|
public void export(HttpServletResponse response, SysInvoice sysInvoice)
|
{
|
List<SysInvoice> list = sysInvoiceService.selectSysInvoiceList(sysInvoice);
|
ExcelUtil<SysInvoice> util = new ExcelUtil<SysInvoice>(SysInvoice.class);
|
util.exportExcel(response, list, "发票申请数据");
|
}
|
|
/**
|
* 获取发票申请详细信息
|
*/
|
@PreAuthorize("@ss.hasAnyPermi('system:invoice:query, system:invoice:edit')")
|
@GetMapping(value = "/{invoiceId}")
|
public AjaxResult getInfo(@PathVariable("invoiceId") Long invoiceId)
|
{
|
return AjaxResult.success(sysInvoiceService.selectSysInvoiceByInvoiceId(invoiceId));
|
}
|
|
/**
|
* 新增发票申请
|
*/
|
@Log(title = "发票申请", businessType = BusinessType.INSERT)
|
@PostMapping
|
public AjaxResult add(@RequestBody SysInvoice sysInvoice)
|
{
|
sysInvoice.setApplyUserId(SecurityUtils.getUserId());
|
return toAjax(sysInvoiceService.insertSysInvoice(sysInvoice));
|
}
|
|
/**
|
* 修改发票申请
|
*/
|
@PreAuthorize("@ss.hasPermi('system:invoice:edit')")
|
@Log(title = "发票申请", businessType = BusinessType.UPDATE)
|
@PutMapping
|
public AjaxResult edit(@RequestBody SysInvoice sysInvoice)
|
{
|
return toAjax(sysInvoiceService.updateSysInvoice(sysInvoice));
|
}
|
|
/**
|
* 删除发票申请
|
*/
|
@PreAuthorize("@ss.hasPermi('system:invoice:remove')")
|
@Log(title = "发票申请", businessType = BusinessType.DELETE)
|
@DeleteMapping("/{invoiceIds}")
|
public AjaxResult remove(@PathVariable Long[] invoiceIds)
|
{
|
return toAjax(sysInvoiceService.deleteSysInvoiceByInvoiceIds(invoiceIds));
|
}
|
|
/**
|
* 手动触发同步 (仅限管理员)
|
*/
|
@PreAuthorize("@ss.hasRole('admin')")
|
@GetMapping("/syncStatus")
|
public AjaxResult syncStatus() {
|
sysInvoiceService.syncStatusFromLegacySystem();
|
return AjaxResult.success("同步任务已触发");
|
}
|
|
/**
|
* 同步单个发票到旧系统
|
* @param invoiceId 发票ID
|
*/
|
@PreAuthorize("@ss.hasPermi('system:invoice:edit')")
|
@Log(title = "发票申请", businessType = BusinessType.UPDATE)
|
@PostMapping("/syncToLegacy/{invoiceId}")
|
public AjaxResult syncToLegacy(@PathVariable Long invoiceId) {
|
SysInvoice invoice = sysInvoiceService.selectSysInvoiceByInvoiceId(invoiceId);
|
if (invoice == null) {
|
return AjaxResult.error("发票不存在");
|
}
|
if (invoice.getStatus() != 1) {
|
return AjaxResult.error("只有审核通过的发票才能同步");
|
}
|
|
try {
|
sysInvoiceService.syncToLegacySystem(invoice.getInvoiceId());
|
return AjaxResult.success("同步成功");
|
} catch (Exception e) {
|
return AjaxResult.error("同步失败: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 检查任务是否已申请发票
|
* @param taskId 任务ID
|
*/
|
@GetMapping("/checkTaskInvoice/{taskId}")
|
public AjaxResult checkTaskInvoice(@PathVariable Long taskId) {
|
SysInvoice query = new SysInvoice();
|
query.setServiceOrderId(taskId);
|
List<SysInvoice> list = sysInvoiceService.selectSysInvoiceList(query);
|
|
if (list != null && !list.isEmpty()) {
|
// 只返回最新的一条记录
|
SysInvoice invoice = list.get(0);
|
Map<String, Object> result = new HashMap<>();
|
result.put("hasApplied", true);
|
result.put("status", invoice.getStatus());
|
result.put("invoiceId", invoice.getInvoiceId());
|
return AjaxResult.success(result);
|
}
|
|
return AjaxResult.success(null);
|
}
|
|
/**
|
* App端查看我的某条发票详情（无需后台权限，但只能查看自己的发票）
|
*/
|
@GetMapping("/myDetail/{invoiceId}")
|
public AjaxResult myDetail(@PathVariable("invoiceId") Long invoiceId)
|
{
|
Long currentUserId = SecurityUtils.getUserId();
|
SysInvoice invoice = sysInvoiceService.selectSysInvoiceByInvoiceId(invoiceId);
|
if (invoice == null) {
|
return AjaxResult.error("发票不存在");
|
}
|
if (!currentUserId.equals(invoice.getApplyUserId())) {
|
return AjaxResult.error("无权限查看该发票");
|
}
|
return AjaxResult.success(invoice);
|
}
|
|
/**
|
* App端用户编辑自己的发票申请（仅待审核/已驳回可编辑，不可更改关联任务）
|
*/
|
@Log(title = "发票申请自助修改", businessType = BusinessType.UPDATE)
|
@PutMapping("/myEdit")
|
public AjaxResult myEdit(@RequestBody SysInvoice sysInvoice)
|
{
|
Long currentUserId = SecurityUtils.getUserId();
|
if (sysInvoice.getInvoiceId() == null) {
|
return AjaxResult.error("发票ID不能为空");
|
}
|
SysInvoice exist = sysInvoiceService.selectSysInvoiceByInvoiceId(sysInvoice.getInvoiceId());
|
if (exist == null) {
|
return AjaxResult.error("发票不存在");
|
}
|
if (!currentUserId.equals(exist.getApplyUserId())) {
|
return AjaxResult.error("无权限修改该发票");
|
}
|
if (exist.getStatus() != 0 && exist.getStatus() != 2) {
|
return AjaxResult.error("只有待审核或已驳回的发票可以修改");
|
}
|
Long taskId = exist.getServiceOrderId();
|
Long legacyServiceOrdId = exist.getLegacyServiceOrderId();
|
if(LongUtil.isNotEmpty(taskId) && LongUtil.isEmpty(legacyServiceOrdId)){
|
SysTaskEmergency taskEmergency= sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
|
if(taskEmergency!=null){
|
legacyServiceOrdId=taskEmergency.getLegacyServiceOrdId();
|
}
|
|
}
|
// 保持关联任务信息不变，只更新发票内容字段
|
sysInvoice.setServiceOrderId(exist.getServiceOrderId());
|
sysInvoice.setLegacyServiceOrderId(legacyServiceOrdId);
|
sysInvoice.setApplyUserId(exist.getApplyUserId());
|
sysInvoice.setApplyTime(exist.getApplyTime());
|
sysInvoice.setStatus(0); // 重新置为待审核
|
int rows = sysInvoiceService.updateSysInvoice(sysInvoice);
|
|
if (rows > 0) {
|
// 异步同步到旧系统，失败不影响主流程
|
try {
|
sysInvoiceService.syncUpdateToLegacySystem(sysInvoice.getInvoiceId());
|
} catch (Exception e) {
|
log.warn("发票编辑同步旧系统失败，不影响保存结果: {}", e.getMessage());
|
}
|
}
|
return toAjax(rows);
|
}
|
|
/**
|
* 获取可申请发票的任务列表
|
* @param searchKeyword 搜索关键词（支持taskCode、serviceCode、legacyServiceOrdNo）
|
* @param serviceOrdClass 分公司代码（可选，默认使用用户所属分公司）
|
*/
|
@GetMapping("/selectableTasks")
|
public AjaxResult getSelectableTasks(
|
@RequestParam(required = false) String searchKeyword,
|
@RequestParam(required = false) String serviceOrdClass
|
)
|
{
|
Long userId = SecurityUtils.getUserId();
|
// 去除搜索关键词的空格
|
if (StringUtils.isNotBlank(searchKeyword)) {
|
searchKeyword = searchKeyword.trim();
|
}
|
|
// 如果未指定分公司，自动获取用户所属分公司
|
if (StringUtils.isBlank(serviceOrdClass)) {
|
try {
|
Long deptId = SecurityUtils.getLoginUser().getUser().getDeptId();
|
if (deptId != null) {
|
SysDept dept = sysDeptService.selectDeptById(deptId);
|
if (dept != null) {
|
// 判断是否为分公司（parent_id = 100）
|
if (dept.getParentId() != null && dept.getParentId() == 100) {
|
serviceOrdClass = dept.getServiceOrderClass();
|
} else if (dept.getAncestors() != null) {
|
// 从 ancestors 解析分公司ID
|
String[] ancestorIds = dept.getAncestors().split(",");
|
for (int i = 0; i < ancestorIds.length; i++) {
|
if ("100".equals(ancestorIds[i]) && i + 1 < ancestorIds.length) {
|
Long branchId = Long.parseLong(ancestorIds[i + 1]);
|
SysDept branchDept = sysDeptService.selectDeptById(branchId);
|
if (branchDept != null) {
|
serviceOrdClass = branchDept.getServiceOrderClass();
|
}
|
break;
|
}
|
}
|
}
|
}
|
}
|
} catch (Exception e) {
|
// 获取失败不影响查询，只是不过滤分公司
|
}
|
}
|
|
return AjaxResult.success(sysInvoiceService.selectSelectableTasks(userId, searchKeyword, serviceOrdClass));
|
}
|
}
|
