From 3b2b82e249f7937c381b13ca276c73dea36f413e Mon Sep 17 00:00:00 2001
From: hdka <823267011@qq.com>
Date: Fri, 21 Mar 2025 11:28:09 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A6=96=E9=A1=B5=E6=95=B0=E6=8D=AE=E4=BF=AE?=
 =?UTF-8?q?=E6=AD=A3=EF=BC=8C=E6=B7=BB=E5=8A=A0=E5=A4=96=E5=87=BA=E8=AE=B0?=
 =?UTF-8?q?=E5=BD=95=E6=A8=A1=E5=BF=AB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../workflow/WfProcessController.java         |  8 ++
 .../oa/controller/SysOaFinanceController.java |  4 +-
 .../oa/controller/SysOaProjectController.java |  3 +-
 .../ruoyi/oa/domain/vo/SysOaFinanceVo.java    |  5 ++
 .../ruoyi/oa/domain/vo/SysOaProjectVo.java    |  7 ++
 .../ruoyi/oa/mapper/SysOaFinanceMapper.java   |  2 +-
 .../oa/service/ISysOaFinanceService.java      |  2 +-
 .../service/impl/SysOaFinanceServiceImpl.java |  4 +-
 .../service/impl/SysOaProjectServiceImpl.java |  1 -
 .../impl/SysOaWarehouseMasterServiceImpl.java |  1 +
 .../mapper/oa/SysOaFinanceMapper.xml          | 23 ++++--
 .../mapper/oa/SysOaProjectMapper.xml          | 30 +++++--
 .../workflow/service/IWfProcessService.java   |  1 +
 .../service/impl/WfProcessServiceImpl.java    | 79 +++++++++++++++++++
 14 files changed, 149 insertions(+), 21 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/workflow/WfProcessController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/workflow/WfProcessController.java
index d25aa6d..14fabae 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/workflow/WfProcessController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/workflow/WfProcessController.java
@@ -60,6 +60,14 @@ public class WfProcessController extends BaseController {
         return processService.selectPageOwnProcessList(processQuery, pageQuery);
     }
 
+    /**
+     * 我拥有的流程
+     */
+    @GetMapping(value = "/trip-absence")
+    public TableDataInfo<WfTaskVo> selectPageTripAndAbsenceProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
+        return processService.selectPageTripAndAbsenceProcessList(processQuery, pageQuery);
+    }
+
     /**
      * 获取待办列表
      */
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaFinanceController.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaFinanceController.java
index fd7219c..c7b2949 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaFinanceController.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaFinanceController.java
@@ -65,9 +65,9 @@ public class SysOaFinanceController extends BaseController {
     }
 
 
-    @GetMapping("/pieData")
+    @GetMapping("/barData")
     public R<List<SysOaFinanceVo>> pieData(SysOaFinanceBo bo) {
-        List<SysOaFinanceVo> sysOaFinanceList = iSysOaFinanceService.getPieData(bo);
+        List<SysOaFinanceVo> sysOaFinanceList = iSysOaFinanceService.getBarData(bo);
         return R.ok(sysOaFinanceList);
     }
 
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaProjectController.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaProjectController.java
index 5a85c94..a35dc4b 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaProjectController.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/controller/SysOaProjectController.java
@@ -85,6 +85,8 @@ public class SysOaProjectController extends BaseController {
         return R.ok(iSysOaProjectService.getProjectDataByMonth(date));
     }
 
+
+
     /**
      * 获取项目管理详细信息
      *
@@ -103,7 +105,6 @@ public class SysOaProjectController extends BaseController {
     @RepeatSubmit()
     @PostMapping()
     public R<Void> add(@Validated(AddGroup.class) @RequestBody SysOaProjectBo bo) {
-        System.out.println("date=====" + bo);
         return toAjax(iSysOaProjectService.insertByBo(bo));
     }
 
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaFinanceVo.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaFinanceVo.java
index 6603d28..aa46d03 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaFinanceVo.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaFinanceVo.java
@@ -144,5 +144,10 @@ public class SysOaFinanceVo extends SysOaFinance {
      */
     private Double outMoney;
 
+    private Double totalOut;
+
+    private Double totalIn;
+
+    private String month;
 
 }
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaProjectVo.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaProjectVo.java
index 192c6f6..689c973 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaProjectVo.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/domain/vo/SysOaProjectVo.java
@@ -98,6 +98,13 @@ public class SysOaProjectVo {
     @ExcelProperty(value = "项目介绍")
     private String introduction;
 
+
+    /**
+     * 当月支出
+     */
+    @ExcelProperty(value = "当月支出")
+    private Double totalPrice;
+
     /**
      * 优先级
      */
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/mapper/SysOaFinanceMapper.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/mapper/SysOaFinanceMapper.java
index 84bb8ea..88a5fa4 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/mapper/SysOaFinanceMapper.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/mapper/SysOaFinanceMapper.java
@@ -70,7 +70,7 @@ public interface SysOaFinanceMapper extends BaseMapperPlus<SysOaFinanceMapper, S
      * @param bo
      * @return
      */
-    List<SysOaFinanceVo> getPieData(SysOaFinanceBo bo);
+    List<SysOaFinanceVo> getBarData(SysOaFinanceBo bo);
 
 
     /**
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/ISysOaFinanceService.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/ISysOaFinanceService.java
index 17610fb..ce932b5 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/ISysOaFinanceService.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/ISysOaFinanceService.java
@@ -90,5 +90,5 @@ public interface ISysOaFinanceService {
      */
     Boolean deleteSysOaFinanceById(Long financeId);
 
-    List<SysOaFinanceVo> getPieData(SysOaFinanceBo bo);
+    List<SysOaFinanceVo> getBarData(SysOaFinanceBo bo);
 }
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaFinanceServiceImpl.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaFinanceServiceImpl.java
index 529c2ca..53d27be 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaFinanceServiceImpl.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaFinanceServiceImpl.java
@@ -269,9 +269,9 @@ public class SysOaFinanceServiceImpl implements ISysOaFinanceService {
      * @return
      */
     @Override
-    public List<SysOaFinanceVo> getPieData(SysOaFinanceBo bo) {
+    public List<SysOaFinanceVo> getBarData(SysOaFinanceBo bo) {
 
-        return  baseMapper.getPieData(bo);
+        return  baseMapper.getBarData(bo);
     }
 
     /**
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaProjectServiceImpl.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaProjectServiceImpl.java
index a85045a..9d60f10 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaProjectServiceImpl.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaProjectServiceImpl.java
@@ -134,7 +134,6 @@ public class SysOaProjectServiceImpl implements ISysOaProjectService {
      */
     @Override
     public List<SysOaProjectVo> getProjectDataByMonth(Date date) {
-        System.out.println(date);
         if (date==null){
             date = new Date();
         }
diff --git a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaWarehouseMasterServiceImpl.java b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaWarehouseMasterServiceImpl.java
index 76bd0e2..1c78d24 100644
--- a/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaWarehouseMasterServiceImpl.java
+++ b/ruoyi-oa/src/main/java/com/ruoyi/oa/service/impl/SysOaWarehouseMasterServiceImpl.java
@@ -129,6 +129,7 @@ public class SysOaWarehouseMasterServiceImpl implements ISysOaWarehouseMasterSer
      */
     @Override
     public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
+        System.out.println(ids);
         if(isValid){
             //TODO 做一些业务上的校验,判断是否需要校验
         }
diff --git a/ruoyi-oa/src/main/resources/mapper/oa/SysOaFinanceMapper.xml b/ruoyi-oa/src/main/resources/mapper/oa/SysOaFinanceMapper.xml
index 6bccc2e..6d85500 100644
--- a/ruoyi-oa/src/main/resources/mapper/oa/SysOaFinanceMapper.xml
+++ b/ruoyi-oa/src/main/resources/mapper/oa/SysOaFinanceMapper.xml
@@ -24,6 +24,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="updateTime" column="update_time"/>
         <result property="outType" column="out_type"/>
         <result property="outMoney" column="out_money"/>
+        <result property="totalOut" column="total_out"/>
+        <result property="totalIn" column="total_in"/>
+        <result property="month" column="month"/>
 
         <result property="receiveAccountId" column="receive_account_id"/>
         <result property="receiveAccountName" column="receive_account_name"/>
@@ -173,13 +176,19 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         and date_format(a.finance_time,'%Y-%m-%d %H:%i:%s') &lt;= date_format(#{endTime},'%Y-%m-%d %H:%i:%s')
     </select>
 
-    <select id="getPieData" resultMap="SysOaFinanceResult">
-        select
-            sum(b.price) as out_money,a.out_type
-        from sys_oa_finance a
-                 left join sys_oa_detail b on a.finance_id = b.finance_id
-        where a.finance_type = '0' AND YEAR(a.create_time) = YEAR(NOW()) and a.project_id = '0'
-        group by a.out_type
+    <select id="getBarData" resultMap="SysOaFinanceResult">
+        SELECT
+        DATE_FORMAT(a.create_time, '%Y-%m') AS month,
+        SUM(CASE WHEN a.finance_type = '0' THEN b.price ELSE 0 END) AS total_out,
+        SUM(CASE WHEN a.finance_type = '1' THEN b.price ELSE 0 END) AS total_in
+        FROM sys_oa_finance a
+        LEFT JOIN sys_oa_detail b
+        ON a.finance_id = b.finance_id
+        AND a.create_time >= DATE_FORMAT(DATE_SUB(NOW(), INTERVAL 5 MONTH), '%Y-%m-01')
+        AND DATE_ADD(DATE_FORMAT(NOW(), '%Y-%m-01'), INTERVAL 1 MONTH) > a.create_time
+        GROUP BY DATE_FORMAT(a.create_time, '%Y-%m')
+        ORDER BY month;
+
     </select>
 
     <!--项目进出账查询-->
diff --git a/ruoyi-oa/src/main/resources/mapper/oa/SysOaProjectMapper.xml b/ruoyi-oa/src/main/resources/mapper/oa/SysOaProjectMapper.xml
index 0f7abdf..43b5b96 100644
--- a/ruoyi-oa/src/main/resources/mapper/oa/SysOaProjectMapper.xml
+++ b/ruoyi-oa/src/main/resources/mapper/oa/SysOaProjectMapper.xml
@@ -96,12 +96,30 @@
     </select>
 
     <select id="getProjectDataByMonth" resultType="com.ruoyi.oa.domain.vo.SysOaProjectVo">
-        select sum(soa.day_length + soa.hour / 8) as labor_cost, color, sop.project_name
-        from sys_oa_project sop
-                 left join sys_oa_attendance soa on sop.project_id = soa.project_id
-        where soa.create_time between #{firstDay} and #{lastDay}
-          and soa.del_flag = '0'
-        group by sop.project_id
+        SELECT sop.project_id,
+               sop.project_name,
+               sop.color,
+               COALESCE(SUM(soa.day_length + soa.hour / 9),1) AS labor_cost,
+               SUM(
+                       CASE
+                           WHEN sof.finance_type = 0 THEN sod.price
+                           ELSE 0
+                           END
+               )   AS total_price
+        FROM sys_oa_project AS sop
+                 LEFT JOIN sys_oa_attendance AS soa
+                           ON sop.project_id = soa.project_id
+                               AND soa.create_time BETWEEN #{firstDay} AND #{lastDay}
+                               AND soa.del_flag = '0'
+                 LEFT JOIN sys_oa_finance AS sof
+                           ON sop.project_id = sof.project_id
+                               AND sof.create_time BETWEEN #{firstDay} AND #{lastDay}
+                 LEFT JOIN sys_oa_detail AS sod
+                           ON sof.finance_id = sod.finance_id
+                               AND sod.create_time BETWEEN #{firstDay} AND #{lastDay}
+        GROUP BY sop.project_id,
+                 sop.project_name,
+                 sop.color
     </select>
 
     <select id="getProjectDataByMonthAndDate" resultType="com.ruoyi.oa.domain.vo.SysOaProjectVo">
diff --git a/ruoyi-system/src/main/java/com/ruoyi/workflow/service/IWfProcessService.java b/ruoyi-system/src/main/java/com/ruoyi/workflow/service/IWfProcessService.java
index 9046e0c..35c86bc 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/workflow/service/IWfProcessService.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/workflow/service/IWfProcessService.java
@@ -130,4 +130,5 @@ public interface IWfProcessService {
      */
     String commonStart(String category);
 
+    TableDataInfo<WfTaskVo> selectPageTripAndAbsenceProcessList(ProcessQuery processQuery, PageQuery pageQuery);
 }
diff --git a/ruoyi-system/src/main/java/com/ruoyi/workflow/service/impl/WfProcessServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/workflow/service/impl/WfProcessServiceImpl.java
index 12590e1..ed8549a 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/workflow/service/impl/WfProcessServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/workflow/service/impl/WfProcessServiceImpl.java
@@ -233,6 +233,85 @@ public class WfProcessServiceImpl extends FlowServiceFactory implements IWfProce
         return TableDataInfo.build(page);
     }
 
+
+    @Override
+    public TableDataInfo<WfTaskVo> selectPageTripAndAbsenceProcessList(ProcessQuery processQuery, PageQuery pageQuery) {
+//        System.out.println("process====" + processQuery);
+        Page<WfTaskVo> page = new Page<>();
+        HistoricProcessInstanceQuery historicProcessInstanceQuery = historyService.createHistoricProcessInstanceQuery()
+                .processDefinitionCategory("trip")
+                .or()
+                .processDefinitionCategory("absence")
+                .orderByProcessInstanceStartTime()
+                .desc();
+        // 构建搜索条件
+        ProcessUtils.buildProcessSearch(historicProcessInstanceQuery, processQuery);
+        int offset = pageQuery.getPageSize() * (pageQuery.getPageNum() - 1);
+        List<HistoricProcessInstance> historicProcessInstances = historicProcessInstanceQuery
+                .listPage(offset, pageQuery.getPageSize());
+        page.setTotal(historicProcessInstanceQuery.count());
+
+        List<WfTaskVo> taskVoList = new ArrayList<>();
+
+        for (HistoricProcessInstance hisIns : historicProcessInstances) {
+            WfTaskVo taskVo = new WfTaskVo();
+            // 获取流程状态
+            HistoricVariableInstance processStatusVariable = historyService.createHistoricVariableInstanceQuery()
+                    .processInstanceId(hisIns.getId())
+                    .variableName(ProcessConstants.PROCESS_STATUS_KEY)
+                    .singleResult();
+            String processStatus = null;
+            if (ObjectUtil.isNotNull(processStatusVariable)) {
+                processStatus = Convert.toStr(processStatusVariable.getValue());
+            }
+            // 兼容旧流程
+            if (processStatus == null) {
+                processStatus = ObjectUtil.isNull(hisIns.getEndTime()) ? ProcessStatus.RUNNING.getStatus() : ProcessStatus.COMPLETED.getStatus();
+            }
+            taskVo.setProcessStatus(processStatus);
+            taskVo.setCreateTime(hisIns.getStartTime());
+            taskVo.setFinishTime(hisIns.getEndTime());
+            taskVo.setProcInsId(hisIns.getId());
+
+            // 计算耗时
+            if (Objects.nonNull(hisIns.getEndTime())) {
+                taskVo.setDuration(DateUtils.getDatePoor(hisIns.getEndTime(), hisIns.getStartTime()));
+            } else {
+                taskVo.setDuration(DateUtils.getDatePoor(DateUtils.getNowDate(), hisIns.getStartTime()));
+            }
+            // 流程部署实例信息
+            Deployment deployment = repositoryService.createDeploymentQuery()
+                    .deploymentId(hisIns.getDeploymentId()).singleResult();
+            taskVo.setDeployId(hisIns.getDeploymentId());
+            taskVo.setProcDefId(hisIns.getProcessDefinitionId());
+            taskVo.setProcDefName(hisIns.getProcessDefinitionName());
+            taskVo.setProcDefVersion(hisIns.getProcessDefinitionVersion());
+            taskVo.setCategory(deployment.getCategory());
+
+            // 当前所处流程
+            List<Task> taskList = taskService.createTaskQuery().processInstanceId(hisIns.getId()).includeIdentityLinks().list();
+            if (CollUtil.isNotEmpty(taskList)) {
+                taskVo.setTaskName(taskList.stream().map(Task::getName).filter(StringUtils::isNotEmpty).collect(Collectors.joining(",")));
+            }
+            //taskVo.setProcVars(hisIns.getProcessVariables());
+            // 查询任务节点参数，并转换成Map，目的是获取流程标题(新增于2024年2月29日)
+            List<HistoricVariableInstance> collectors = historyService.createHistoricVariableInstanceQuery().processInstanceId(hisIns.getId()).list();
+            if(CollUtil.isNotEmpty(collectors)){
+//                taskVo.setProcVars(collectors.stream().collect(Collectors.toMap(HistoricVariableInstance::getVariableName, HistoricVariableInstance::getValue)));
+                // 遍历表单属性并获取值
+                collectors.stream().forEach(historicVariableInstance -> {
+                    if (historicVariableInstance.getVariableName().equals("description")) {
+                        taskVo.setProcVars(historicVariableInstance.getValue());
+                    }
+                });
+            }
+            taskVoList.add(taskVo);
+        }
+        page.setRecords(taskVoList);
+        return TableDataInfo.build(page);
+    }
+
+
     @Override
     public List<WfTaskVo> selectOwnProcessList(ProcessQuery processQuery) {
         HistoricProcessInstanceQuery historicProcessInstanceQuery = historyService.createHistoricProcessInstanceQuery()