From e42df6bfd9cb5d2182c1082fbad5117543bebd53 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期二, 02 一月 2024 22:04:25 +0800
Subject: [PATCH] 完成工单通知功能

---
 service-oa/src/main/java/com/java110/oa/smo/impl/WorkTaskV1InnerServiceSMOImpl.java |   14 +++++++++++++-
 1 files changed, 13 insertions(+), 1 deletions(-)

diff --git a/service-oa/src/main/java/com/java110/oa/smo/impl/WorkTaskV1InnerServiceSMOImpl.java b/service-oa/src/main/java/com/java110/oa/smo/impl/WorkTaskV1InnerServiceSMOImpl.java
index a2866db..fbd34fb 100644
--- a/service-oa/src/main/java/com/java110/oa/smo/impl/WorkTaskV1InnerServiceSMOImpl.java
+++ b/service-oa/src/main/java/com/java110/oa/smo/impl/WorkTaskV1InnerServiceSMOImpl.java
@@ -16,6 +16,9 @@
 package com.java110.oa.smo.impl;
 
 
+import com.alibaba.fastjson.JSONObject;
+import com.java110.dto.data.DatabusDataDto;
+import com.java110.intf.job.IDataBusInnerServiceSMO;
 import com.java110.oa.dao.IWorkTaskV1ServiceDao;
 import com.java110.intf.oa.IWorkTaskV1InnerServiceSMO;
 import com.java110.dto.workTask.WorkTaskDto;
@@ -45,17 +48,26 @@
     @Autowired
     private IWorkTaskV1ServiceDao workTaskV1ServiceDaoImpl;
 
+    @Autowired
+    private IDataBusInnerServiceSMO dataBusInnerServiceSMOImpl;
+
 
     @Override
     public int saveWorkTask(@RequestBody  WorkTaskPo workTaskPo) {
         int saveFlag = workTaskV1ServiceDaoImpl.saveWorkTaskInfo(BeanConvertUtil.beanCovertMap(workTaskPo));
+        JSONObject reqJson = BeanConvertUtil.beanCovertJson(workTaskPo);
+        dataBusInnerServiceSMOImpl.databusData(new DatabusDataDto(DatabusDataDto.BUSINESS_TYPE_OA_WORK_TASK, reqJson));
+
         return saveFlag;
     }
 
      @Override
     public int updateWorkTask(@RequestBody  WorkTaskPo workTaskPo) {
         int saveFlag = workTaskV1ServiceDaoImpl.updateWorkTaskInfo(BeanConvertUtil.beanCovertMap(workTaskPo));
-        return saveFlag;
+         JSONObject reqJson = BeanConvertUtil.beanCovertJson(workTaskPo);
+         dataBusInnerServiceSMOImpl.databusData(new DatabusDataDto(DatabusDataDto.BUSINESS_TYPE_OA_WORK_TASK, reqJson));
+
+         return saveFlag;
     }
 
      @Override

--
Gitblit v1.8.0