From af64620166923b16331c72cf449847d434698648 Mon Sep 17 00:00:00 2001 From: bupengxiang Date: Tue, 25 Apr 2023 21:05:37 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=96=B0=E5=A2=9E]=20=E6=9D=83=E9=99=90?= =?UTF-8?q?=E7=94=B3=E8=AF=B7=E6=B5=81=E7=A8=8B=20=E5=8F=8A=20=E5=B7=A5?= =?UTF-8?q?=E4=BD=9C=E5=8F=B0=E7=9A=84=E6=8E=A5=E5=8F=A3=20=E5=BC=80?= =?UTF-8?q?=E5=8F=91=E5=AE=8C=E6=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../da/report/dao/mysql/PowerApplyActDao.java | 1 + .../da/report/dao/mysql/PowerApplyDao.java | 3 + .../java/com/adc/da/report/eo/PowerApply.java | 6 +- .../com/adc/da/report/eo/PowerApplyAct.java | 7 +- .../service/impl/IReportServiceImpl.java | 28 +++++-- .../adc/da/report/vo/PowerApplyActPageVO.java | 79 ++++++++++++++++++ .../com/adc/da/report/vo/ReportQueryVo.java | 2 + .../mapper/mysql/PowerApplyActMapper.xml | 7 ++ .../mybatis/mapper/mysql/PowerApplyMapper.xml | 8 ++ .../mapper/mysql/ReportManageMapper.xml | 49 +++++++++-- .../service/impl/IReportServiceImpl.class | Bin 18692 -> 19254 bytes .../mapper/mysql/ReportManageMapper.xml | 49 +++++++++-- .../com/adc/da/sys/dao/mysql/RoleEODao.java | 13 +-- .../mybatis/mapper/sys/mysql/RoleEOMapper.xml | 6 ++ .../define/ActivitDefineController.java | 2 +- .../service/ActivitDefineService.java | 5 ++ .../task/TodoTaskController.java | 69 +++++++++------ .../business_main/entity/BusProcessNew.java | 5 ++ .../mapper/BusProcessApproveMapper.java | 4 +- .../mapper/BusProcessNewMapper.java | 2 +- .../service/IBusProcessApproveService.java | 3 +- .../service/IBusProcessNewService.java | 2 +- .../impl/BusProcessApproveServiceImpl.java | 6 +- .../impl/BusProcessNameServiceImpl.java | 17 +++- .../impl/BusProcessNewServiceImpl.java | 4 +- .../business_main/vo/BusProcessNewVO.java | 4 +- .../da/wkflow/listener/powerApply/aid1.java | 3 + .../da/wkflow/listener/powerApply/aid2.java | 4 +- .../da/wkflow/listener/powerApply/aid3.java | 10 ++- .../da/wkflow/listener/powerApply/aid4.java | 4 +- .../mapper/mysql/BusProcessApproveMapper.xml | 3 +- .../mapper/mysql/BusProcessNewMapper.xml | 3 +- 32 files changed, 325 insertions(+), 83 deletions(-) diff --git a/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyActDao.java b/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyActDao.java index 57de55e..f9ed445 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyActDao.java +++ b/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyActDao.java @@ -45,4 +45,5 @@ public interface PowerApplyActDao extends BaseMapper { int batchInsert(@Param("list")List powerApplyActs); + List selectListBydataId(@Param("dataId")String dataId); } diff --git a/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyDao.java b/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyDao.java index f55ef5a..f4f30fd 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyDao.java +++ b/adc-da-report/src/main/java/com/adc/da/report/dao/mysql/PowerApplyDao.java @@ -1,6 +1,7 @@ package com.adc.da.report.dao.mysql; import com.adc.da.report.eo.PowerApply; +import com.adc.da.report.eo.PowerApplyAct; import com.adc.da.report.vo.PowerApplyPageVO; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -41,4 +42,6 @@ public interface PowerApplyDao extends BaseMapper { * @description 列表查询 */ List queryList(@Param("pageVO") PowerApplyPageVO powerApplyPageVO); + + int saveBatch(@Param("list") List powerApplies); } diff --git a/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApply.java b/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApply.java index 58dfd9e..2784e97 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApply.java +++ b/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApply.java @@ -6,6 +6,8 @@ import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; +import java.util.Date; + /** * @author bu * @version 1.0 @@ -64,13 +66,13 @@ public class PowerApply { * 创建时间 */ @TableField("create_date") - private String createDate; + private Date createDate; /** * 修改时间 */ @TableField("update_date") - private String updateDate; + private Date updateDate = new Date(); /** diff --git a/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApplyAct.java b/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApplyAct.java index 6da68cc..d2974ed 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApplyAct.java +++ b/adc-da-report/src/main/java/com/adc/da/report/eo/PowerApplyAct.java @@ -6,6 +6,9 @@ import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; +import java.util.Date; + + /** * @author bu * @version 1.0 @@ -76,13 +79,13 @@ public class PowerApplyAct { * 创建时间 */ @TableField("create_date") - private String createDate; + private Date createDate; /** * 修改时间 */ @TableField("update_date") - private String updateDate; + private Date updateDate = new Date(); /** diff --git a/adc-da-report/src/main/java/com/adc/da/report/service/impl/IReportServiceImpl.java b/adc-da-report/src/main/java/com/adc/da/report/service/impl/IReportServiceImpl.java index 06df52a..751275c 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/service/impl/IReportServiceImpl.java +++ b/adc-da-report/src/main/java/com/adc/da/report/service/impl/IReportServiceImpl.java @@ -1,6 +1,7 @@ package com.adc.da.report.service.impl; import com.adc.da.login.util.CommonUtils; +import com.adc.da.login.util.UserUtils; import com.adc.da.report.constant.ReportConstants; import com.adc.da.report.dao.mysql.FileDao; import com.adc.da.report.dao.mysql.ReportDao; @@ -16,6 +17,8 @@ import com.adc.da.report.service.ITreeLabelService; import com.adc.da.report.util.*; import com.adc.da.report.vo.ReportQueryVo; import com.adc.da.report.vo.ReportVo; +import com.adc.da.sys.dao.mysql.RoleEODao; +import com.adc.da.sys.entity.RoleEO; import com.adc.da.util.utils.FileUtil; import com.adc.da.util.utils.StringUtils; import com.adc.da.util.utils.UUID; @@ -84,6 +87,9 @@ public class IReportServiceImpl extends ServiceImpl @Autowired private ObsBootUtil obsBootUtil; + @Autowired + private RoleEODao roleEODao; + /** * 新增或编辑报告 * @@ -347,16 +353,20 @@ public class IReportServiceImpl extends ServiceImpl IPage page = new Page<>(); page.setCurrent(vo.getPageNo()); page.setSize(vo.getPageSize()); - //判断是不是管理员 -// boolean admin = CommonUtils.isAdmin(); -// if (admin) { -// vo.setUsid(null); -// } else { -// vo.setUsid(CommonUtils.getUserId()); -// } - - vo.setUsid(CommonUtils.getUserId()); + boolean admin = false; + List roleEOList = roleEODao.selectByuserId(UserUtils.getUserId()); + for (RoleEO roleEO : roleEOList) { + if ("管理员".equals(roleEO.getName())){ + admin= !admin; + } + } + if (admin) { + vo.setUsid(null); + } else { + vo.setUsid(UserUtils.getUserId()); + } +// vo.setUsid(CommonUtils.getUserId()); IPage list = reportDao.getAddReportPage(page, vo); return list; diff --git a/adc-da-report/src/main/java/com/adc/da/report/vo/PowerApplyActPageVO.java b/adc-da-report/src/main/java/com/adc/da/report/vo/PowerApplyActPageVO.java index fde698b..e460e29 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/vo/PowerApplyActPageVO.java +++ b/adc-da-report/src/main/java/com/adc/da/report/vo/PowerApplyActPageVO.java @@ -3,6 +3,8 @@ package com.adc.da.report.vo; import lombok.Data; import lombok.EqualsAndHashCode; +import java.util.List; + /** * @author bu * @version 1.0 @@ -24,6 +26,7 @@ public class PowerApplyActPageVO extends BasePageVO { */ private String taskId; + private String userId; /** * 数据id */ @@ -58,4 +61,80 @@ public class PowerApplyActPageVO extends BasePageVO { * 报告类别 */ private String reportType; + + private String reportId; + /** + * 原因 + */ + private String applyReason; + /** + * 权限 + */ + private String power; + /** + * 关键字 + */ + private String keyContent; + + /** + * 主要内容 + */ + private String mainContent; + + /** + * 部门 + */ + private String department; + + /** + * 年 + */ + private String year; + + /** + * 文件id + */ + private String fileId; + + /** + * 文件名称 + */ + private String fileName; + + /** + * 文件类型 + */ + private String fileType; + + /** + * 创建时间 + */ + private String createDate; + + /** + * 报告用户id + */ + private List reportUserIdList; + + /** + * 报告涉密等级 + */ + private String confidentialLevel; + + /** + * 隐私等级 + */ + private String privacyLevel; + + /** + * 关联的标签id集合 + */ + private List labelList; + + /** + * 文件大小 + */ + private String fileSize; + + private String name; } diff --git a/adc-da-report/src/main/java/com/adc/da/report/vo/ReportQueryVo.java b/adc-da-report/src/main/java/com/adc/da/report/vo/ReportQueryVo.java index 3802e53..18d359f 100644 --- a/adc-da-report/src/main/java/com/adc/da/report/vo/ReportQueryVo.java +++ b/adc-da-report/src/main/java/com/adc/da/report/vo/ReportQueryVo.java @@ -47,5 +47,7 @@ public class ReportQueryVo { private String usid; private List ids; +// +// private List noIds; } diff --git a/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyActMapper.xml b/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyActMapper.xml index 9833eaf..90d99dc 100644 --- a/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyActMapper.xml +++ b/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyActMapper.xml @@ -92,4 +92,11 @@ ORDER BY create_time DESC + diff --git a/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyMapper.xml b/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyMapper.xml index 824ca73..30761a0 100644 --- a/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyMapper.xml +++ b/adc-da-report/src/main/resources/mybatis/mapper/mysql/PowerApplyMapper.xml @@ -44,6 +44,14 @@ + + insert into power_apply (id,data_id, report_id, power, apply_reason, user_id, create_user_id, create_date, update_date, update_user_id, del_flag) + values + + (#{item.id}, #{item.dataId}, #{item.reportId}, #{item.power}, #{item.applyReason}, #{item.userId}, #{item.createUserId}, #{item.createDate}, #{item.updateDate}, #{item.updateUserId}, #{item.delFlag}) + + + - SELECT a.* - from ( - select * from TT_REPORT_MANAGE eo - LEFT JOIN tr_report_user ru on eo.id = ru.reportId - WHERE eo.DEL_FLAG = 0 and ru.userId != #{pageVO.usid} + SELECT + eo.id, + eo.NAME, + eo.keycontent, + eo.maincontent, + eo.DEPARTMENT, + eo.YEAR, + eo.fileid, + eo.confidentialLevel, + eo.privacyLevel, + pa.report_id, + pa.user_id + FROM + TT_REPORT_MANAGE eo + LEFT JOIN tr_report_user ru ON eo.id = ru.reportId + LEFT JOIN power_apply pa ON pa.report_id = eo.id + WHERE + eo.DEL_FLAG = 0 + + and ru.userId != #{pageVO.usid} + + + and eo.id not in ( + SELECT tt.report_id from power_apply tt WHERE tt.user_id = #{pageVO.usid} + ) + and name like CONCAT(CONCAT('%',#{pageVO.name}),'%') @@ -186,11 +207,21 @@ #{year} - ) a - LEFT JOIN power_apply pa on pa.report_id = a.id - where - pa.user_id is null or pa.user_id != #{pageVO.usid} + + and eo.id in + + #{id} + + + GROUP BY + eo.id + ORDER BY + eo.updateDate DESC + + + + diff --git a/adc-da-report/target/classes/com/adc/da/report/service/impl/IReportServiceImpl.class b/adc-da-report/target/classes/com/adc/da/report/service/impl/IReportServiceImpl.class index c824f9aa3902daf48d307450ca24b6a53a84cb6b..e97a2ca6bb8daed263ee6fb12df7ffddd58b8aec 100644 GIT binary patch delta 7808 zcmbVQ33ydSvaYI=n{#q*XW=Fgk`N$>APFIa-9$iEK{gQ)aSH(=L;?X4Ko-5IxF9IV znE?S8P$VdhfYFc;7j$Oag>e+uaT^zOWX92PW0UvSxydESoArJWWJBtg$Y=&5Lbb;_$UD318>ZWgK>SDPQmM4Sb^xm)U%iOL4qd5pLF* zTU@@Cmn(Fe!z;93sm<+ibb#*&@+w}f!#hJnye>!+_^uE!uhUH%LZER^ILP<%eTukA zw`{igewQ+NvBM8&zs2SUgS?fiLS*qe#dyf(hl9MG9|=(muM1It@6i)>*u2xFY;eZA z_^}{Y^WzFVp-_z;w_As`HrKh-ErPYj<$4Z3sa!o}^V2T%=EWh3+yr~{3QZQ$yF&2PChlo#vvw}bo+zpKrAHovcA{^rsM z{vgO7@<)pBagf3j_>&L?`ST!u!3VYZGRR-?KV1Hr4=MCdoB!qTH!hvY|JI|wwfQ@T z|6}v_E?uF9xPpIh_(#>jPdfNn&pGV!5k9KWF^7)_`4>Kcy#g+e2nR*PvL(imKpce+ zNUSS1FAs_%akjXQ1YMfVJ8+;F-4qWpk`RXNGO*;L=KXn{<@3wCSXKvt7xN z&aUK27j5!f=_>iIbd&C`^pKv8^m3%Pf_=0(+mQlS3dQK)97pW&C``gbW{w<;XObX2^7yOiCTOTG3~y@2$3_%%y#5@O?5Y1uJLxoFX2M3OTxWjiD8N_o;vlylG){RD=#RX zR>Bk;Ig+XMug@!)RasiOu;H*mCO3jPvb3U-sq4tAi{}^T&8sXe%hQ>2{_oxW3T;^k z2X?&=6RrnKpeZ$sKI_Bjj_Y5DEB}T4Q<6mbaEK6;< z-pCCy(8!Ilgel?V;e(4SOAI@*%*ai$#Fm?l+@g55Djs(=vRp~shK4?(k8N3DSY)M< z+qoZ8(!lca%8JUl#j{71R8B9ST9FtlcO=QG!bDqEC+WsJWsMO}eus(Q8(AyslIR%V zyNs-t4Yq7Fa<|-LqND*Uz?c}NB_6?jP*XLyHG(nc&a@~~{T zWxkO|)XAP&wb4LEi z{lM;@lK3*6{WIX_LGn3WecIy|Et6l67vYUYUQ#Y!mRFcMc&`UDywUN&QHBoEmtav1 z{;HAJILF97<#WIMB}rB$#!*3%yl&*L@`f#M8aW_u8F^dYvE^MO@5%eN{LRP*@}ZHB zSj%4gowEe4PLT%c*rHF8ir<4ZL3KK;#>uhbg8tfyZ28*AAvgf{RbKunh@@{+53hKmQ`5)LVLD>Vzis)}$akE>)aqBUdP?jt z#T|Tf^TE|Oe|{(Y=07Ue_ws|Gujn7P{K(V>dT8#oO>|vDU(+EYKgmFEQ)*_P@97Xz zVETgc$rXlvq@Qg0*~nozf~YMnD=n|U?057ZTaFqzCP$1MSMh$4?cR~p;eAgS3-_&)Ptr6;08)LP#vW(TvI)h1OOlGpW&X{bh_OOR_ zrlNI_C5Zv6W0G|iywvJstZXaCSe>n0!`ZNx)di6BR&QEhxKyC##m35mHh^&8Yq|V+&gaR-v~lGu=91o#Q={xf6X~uc-AvbHGB@vF6U3 z#Z>0y$ESFcG8`{#xAYEWW>*K>7>+$)^=HcUE@+?O^=UgIbig_nH;pxb$(~kHIl6de ziMOZiQ?UgWbbbyfbn>=l9mb|XOga8=U%R(39L#j#DfB-)qb-;iQqArA#$4H^iMN)O zPb-}j$>ZZIO6HD7La$(I*97Cg+&##`6(waQQz{28oQI9Wr@|{s=FBTD^9s+}U!B}( zYE0}tUako-KR(mjnC@0@$=$(yh8pWUYlPu>Jj-yUHWhr8;n@n!)TRVOYos;G@MNB1 zcoGr{U&@zxEAo2snCfTqZseE?)HY+gW_l(0ox=y{ZDM+d5-42*8JSBox-s_w;8^q@ z`g6$sr_CW_pEidyciJ3M^=Wg+SUMLzV}1r>?0SPj{E~jSQA4N?4NyMk)M7wmx3{FSG320k%ykq2eNk)@A9|&f>w_s>P{!n zng{~$bdFirq8Q!GyD0#O=vY0;MDIwq<6+%P@p~ zD3#M#noGsB2%|79rPZ{G?xYR0hPIJMyU_2Zwe$kr3;S(`cDF*XI-i&9$axLC;AD>B zfY0ACj%9l)bmr1`>~I`Xo(nc2%mCmBqs4MMtL*rKT?i^gRKP7b6-r$}3EYxxn1N`2RM`ET z#_13i=Y=_gTS3_Nw4F1#HCZ@l6}REGU~n6C1gov^xKai50J#X^tSI4jAPgd)aRz8a zcD9f1JQF)rQAuPSr>-`4;MikSY;#9G3$rm`UH=jG>q{${k~xK1a|`g6N<+9MUOZ`ZC1=pp;B*0J(lSV)-qsJi4WSmWYiD2l)luzPO5Nk7} z%(uCl&E5U~9)zgr;yVXq%#F&}6Hd?zGO81d>+`HHV=s!wdNyRtp+w-OaTmN%^JpM< zrQw`U7Ly4kMce(pA0>J2W5rdPBlE>V_REs|_Z1M&;j$ zT^jlhXq*jM5%Gz%nG3kEiLXZ%8+|=fC2UW2ql6Ie9Qh zA&r`YYk<4tp^?M@crhrd)mD1T3)_aRe&BLuEzPQ?h7vxI7N~=BAQ5y@ z=zONVG`k=+G$$>#hUV5##d?a*+(33r6~$Qns!qI-xt@YKTtoR)2fZG&&@!@l+jF{N%OdzmhfEo zLuJ$}$51Mt2McNfS{c>F%4h;w){uYNA$}wIrz_|V*9fHL(4(J!!i~WQm(>lLY$9mq zN6{LSO((KX(Af>KI6{+7Vlqri$6XupyL4;-|CNh$LcsAY`x z|0LjR-59V^qXL(9DK{u!Zl zzG0KCzEzZv6S_;ydUyXb!t0$)vS;k3vHEZgZP&=v@T#TQhHUsq6-^2)*SQ*cbOR-ZZfk(olgSBPUPD0W zAG)at!p%()cK8UbLo1q2?(`?)azeWR$}f>Wzb3svhvEG&77vF>^exKl?@&(vfco-B zx&=w{c0}1GSmG)4dvVpji2MF67WxSNXDHrJ;1blbS<5ZIpyog{JOX?!aMW01?IKWUHcf)7~0-Hu@F`qoUWr){&?YH~r}_fmeX1vT z69(n?{L^UI?av!%EaUFLF~v3Xynl;KfjgAyz5jyHV^ng|i;6-odQS~X&3H*GfR`<* zqSn7!f5rP|P}<2FQ!%u*r-!HuJ&f1XBUDI#p!4ZbD#4p+I_)eg~JQ3c-RyMr2ikzW-dC(;})<*Ugm^i7Os#R;4c@J%|y z&wXWR377PcBQR!qqwZspl3-dq-&Hef&Pxx!IvRn{H@A*nJ4NdWeg?cBZ;S`5fOX9GPFVl70k;$_v-zKP-8w10Fi3=*iJ zzvRLeuWMX_oxh&Kj$gn+We(kiL)PN~y8(}gjZN6fin5gzWh;v>_t|n#-p)Y*bqZS% zC%5rUL;3PP8Iqjv{HT)_4!z;Y&_3Z)yaFy%6nZm~PU>iyz~aqx3)p_Cv+pFk5Lblf z^ep@$cWDPa7l>{^y9|Z?Ehu7dr3+Ak&7hUQx(!e56>x{!eM$5w7)O(R2M}O(;`1Uk za5+Lq{X?VV+Nhw{Mg;X8AdciGngwgepK57*w^8x_UrR5BT9?4m*EUhOY>mq`LOhYCT#r{OKY(`Kl)82%eN9fEQAi!(p%M3qS=Q1(x>s73^aUd zSisj{O?YABH!5C)D(QU8xy05mYqT{S&b0>Pm9UWq7yBKGptTLq`UYqt-_0{OHcW1d zF8?9A{3vhaXYgL%%g^$2D02SPfcpx++5r6p6;y=$8-OCXZ#KdGJAcZb`51d;qFnkv DV1ZYH delta 7282 zcmbVR33wI7vaYJh$xP;SlEVoh1V~5#K@yS>_C-Kc5JkA+hKPs(LO_-P2_TCeHW5Sw z9hFrDMZq13h6E776&1vNxn6fcal>7a?fo_9B*Npq?|q-ZnXc}xuCC>;?wXA|xjda` zC^ggJ>$JUIACUyw%d>(!o9AeEZkUJ{25BJQ6ei|{y6EOGWGsmUc`4tjjJN3$&*s}* z%HVMh-=XcDHZKeEa$XT8ix(=#Dw|ga`7XXYOmVz0OaWe^JFK<&UYBy98Q;h2f_y(e zpwxP$Ht2Q_YWE?VA9krtlgZ`P42eN^k%ox1CmAaCVu zVY2xd)pdu8-5Dl_pAW+wc(_;wtzNQumrK2QoGyPk$gl9L`q*vr9u@PNOMQ87kYDFF zl;O=FMF#R)VG8nlL4Kb<(8s@n{2~9x<&XGdr9QFwQ-?ou=`{XaxBkNBFCE@z^M03x zXds60R}O!zJ~*JAZ*-q;UH*>0SLz3c4+i;1{z=#Vti!(q`B(nU=HDIuBgm22{HO9A z3i4kn`>=M7xHN%}+I-BVGM=C##~mT4AdHTPE0)AL63|Y(E4DaTAPLIgIudlmIFjf{ zk|W8EgdC}3OW39PfRv<2U45kL(t56>MWntf>C!+S4P9v@8LnhXV^^{y+mR-YG*z;h zK2CF_xhpM%wR5^7Ew#;YBv;#34)4)6&yjpv3LI(e(mlFiA>1Nuq^+7XPN{YnllHcB zP<1;-9O>jpXGZ}43DOmCmor@HCf#+mha+b?(o+|lrPF6Cb&krMsGtNMjGT)gNgtg! z&xK9rE7ccamJ5Q?kKcsHrN1lxk_&Zq0DLbOIdZW}W8@OVMLJ*V$YshtP!TrAmdjn* zrD5GAgY;zMy`=Dwv070PV$Y6mlCF=Yl@~66-+K4 zJ+|PSqVi(HB&9|sNQo^IjZ9L$GUemeM#@#xWIX5t`nN4p4E-fjja5 zPb!+wuef|v>4>uAc$pTG>0Og;nGw>3GvzuX*GmKgvy9A^IU)KL^jstJ)oE<7{&3iMZ%A^J1Jo}h_gOfL1Ns28TFN>j_p8(g zWWAw}=wn+p7y5*98PT~>~uw=%LvUNf>+UT4Z4UOKLzXvFY> z5k&=)6o%f?#GrR|O1yVZTGj<`$eUP@XXGu#%-eX-JM^wC?`W9bHS`v}&1Cj%-t^Vh zCHoevIj~}#E$geNQdwPSqa@fcb9SRgpm@sylk)z=LEQUfFRMi4SsF$YiF!@tg>w6t>qXi!E%iiv@}b{3}dodj~QmH zM7YpOQnq9%Ne)<{kW~i=w8F+pvFaKt)v9N>30!QYfs&?*mf?m63!*d9SoHxa?!jG* zl`hkf$*~yiU-jhvJ2x7ufeLPDHDXHL_vrF{t2caEwfMm5SzkXeJH|o3SQ*}c%v7(n zN$|eOccEdXYSb7Ot#5dFLYA?zttOhzpM|@6XE&P78QylcVMQQg9a~MUX5J&24XnM^ zY2M438__oRW;Q+xZHtPXjmtQGuXQ?8p4T&w=apo44)3*E;xM*ynCz0`^8Q8RioK$o zRPS{+95mkDO%6doE2iAqp%kFugW*f~Qo|P^mH7hh=Y80^J$I_8Q#hC7Iy0T-tu4&(o@&!7vX|Z zW^lmLpL7T<(_eI$;^?=E{_PSuqRf|3DxSko>3w zfS)^HqNuMx}*AQ(a*qakEOS2n6$ znSqt+s1R94skP0S9Djt0Y;Me17>$DhW4MuO7GQ=0VouA3<8Zh^li$2fo!0se%7?Rw z4Ql*EO5r5Rgi$T9rWec@%qesgr_wdhek!NYJm{{D=nma_Q9U}s&3yBh)|$VRPxE2y z&;o7_Hwk6ZB;QRIwE(6Nf4tAA%~@m(g@MYJUc&~XV{F_4Y-(U8$#E*6c$-hRxuwlH zHs|{PS`kp4?}Gz2o>psP9zc)}8x;hbJMZ*u?0~a_psNGEWQb1Z)A4rHlFs5BI*)Vd zQqBX;@@WXq{(g>$RP3!Tx|*FiB&{4eZ#A+_QG)SWM) zo_sOla7it$lBlikYoS)qLw#)lZx(k26^BSzdJ>%II)un!oA_z&u7bGI7L z0UFRQrF-;XK<80NRA{yLzCR-?k_#tQQlYBa3c8N7sDIu@%vz-9WK`q9@Yt19mxoXm zmmoVvQCq&o*Eo9CwXfBreQo;Z#j?LGa!xZndeqf}<__tcW;Ny_n9RUr7B-7|^uJ^+ zYs~?T;9U6>tpkgGg~sEdaH-G^n$T}64H>kVuEOBNN*da#k|v?4q+$KHQrV!q%~akc z4s(;kQz~id3Q7Tetumz-##Pd^_0-6pobFGCK+o_eF*lRD1VCTcC0;t%>G73xz328g zClc{FORNs|dMZkf56|-Z1LL$m0R7p1|J;D~d!j$b?{|#Xej)mE{eBBu``PHv^ZRLz z_UoX3gWtD9SdeNz1mED#^U+2zb8|{1dOOO(B4z29Wp$a;BfkNxYwXBHaZl?BTQhv?}E1_#Ey9 z+>ORonqbjOC5OVtsGrTf{S)`x`p0O1PqpM^|4(9Ga&lT)*R-@ll*Uc=?6>b9Pea>KWw=e^dmX~c8Z&=T<8 z9=@ZJ?p#50K`#q0_vxviSA;4$!V0N5E1f86V*aTVRSl_o@x#_KBSeobmk zyef)cLBU+EqzBg1)#151R!JLHQgV1+j9x(|H+-ef&?6icBe<2X{n8>8pSdJ2S}sH9E0rlOLbge8r( zQU;XI3^#^JPgPRZ4$7{kN}+1HkWol&CQwyERdi`JU8cv@!2Y>;l~nx%To&gaw^vX- zEw?|#wf`APw9iqZ?V}z5W*?N*15i(2P2Zx5_>LygL6mAg(v2vB7X$2TQ0P95b_a@r zT_|?n#U1hq+AncyA4g#sho@F9{&~$cg)t(){c#^L_WLT99uZV@xSo#34r~psKZ5(( z@`HOiB^=R`t9P1{=F|<~Q}Tf0V6y!C8;R1J1Vb8p98_9=^$!uEkJp@N^l@*Y%*9k< zZjL%?Gi|A)t?C0&A4E_b>+DA;i$C^t);j~-H7QMre6i|WBmQEDclA{YY_C=b##^blT69-*1I(wEWWzCBu+ zUV|cU5Q>BVR`ua403S`t<+To6?iUyu^yz+qfisaN@?c!?R>Ti+7R4RM4go);_{xa7 z^C~=1Msv5n5X=TK-_wy$2%*JWZOr#$v8V2ZROmaXifp(h&}uWi*dOW9Ew7qhIw=-O z{<*jsMf_cO0lQoEk3V9Dd5F-fnypZ0_ett#g^29C73IZk*u=vt;_WEY@9_N^Ep)PL)yl3_ zE1UcKYB?yYhw}(ziQ+z{RuudA01#CRQ_$SVbnrp|S>W?mOH(?VGBRxM!TpTr-v^Qh>j3WcK|JHR8n zw~Ah`pkh6l*gyMguGB#6Wpy-4Y(nuorsgwGgva9gZHqyd*ebL-T5SNidFbDa*xdl& z%}3?5AVw{UQH%K&UK|@+Svz}A?d%%NK7nI;6Ibw){1jKlc%SC&G3r^ANh-a?e0~9B Vl=;OInBV4i_+6i6lk}3_{{v;z2BiQ1 diff --git a/adc-da-report/target/classes/mybatis/mapper/mysql/ReportManageMapper.xml b/adc-da-report/target/classes/mybatis/mapper/mysql/ReportManageMapper.xml index 3173934..d877337 100644 --- a/adc-da-report/target/classes/mybatis/mapper/mysql/ReportManageMapper.xml +++ b/adc-da-report/target/classes/mybatis/mapper/mysql/ReportManageMapper.xml @@ -170,12 +170,33 @@ diff --git a/adc-da-sys/src/main/java/com/adc/da/sys/dao/mysql/RoleEODao.java b/adc-da-sys/src/main/java/com/adc/da/sys/dao/mysql/RoleEODao.java index d4fb191..7115c19 100644 --- a/adc-da-sys/src/main/java/com/adc/da/sys/dao/mysql/RoleEODao.java +++ b/adc-da-sys/src/main/java/com/adc/da/sys/dao/mysql/RoleEODao.java @@ -1,14 +1,13 @@ package com.adc.da.sys.dao.mysql; -import java.util.List; - -import com.adc.da.sys.vo.UserRoleVO; -import com.baomidou.mybatisplus.core.metadata.IPage; -import org.apache.ibatis.annotations.Param; - import com.adc.da.base.dao.BaseDao; import com.adc.da.sys.entity.RoleEO; import com.adc.da.sys.entity.UserRoleEO; +import com.adc.da.sys.vo.UserRoleVO; +import com.baomidou.mybatisplus.core.metadata.IPage; +import org.apache.ibatis.annotations.Param; + +import java.util.List; /** *
@@ -116,4 +115,6 @@ public interface RoleEODao extends BaseDao { IPage getUserInfoPageByRoleId(IPage page,String roleId); Long getUserCountByRoleId(@Param("roleId") String roleId); + + List selectByuserId(@Param("userId") String userId); } diff --git a/adc-da-sys/src/main/resources/mybatis/mapper/sys/mysql/RoleEOMapper.xml b/adc-da-sys/src/main/resources/mybatis/mapper/sys/mysql/RoleEOMapper.xml index 63d55c6..a523c03 100644 --- a/adc-da-sys/src/main/resources/mybatis/mapper/sys/mysql/RoleEOMapper.xml +++ b/adc-da-sys/src/main/resources/mybatis/mapper/sys/mysql/RoleEOMapper.xml @@ -316,6 +316,12 @@ + diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/define/ActivitDefineController.java b/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/define/ActivitDefineController.java index 144764e..a92fb55 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/define/ActivitDefineController.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/define/ActivitDefineController.java @@ -218,7 +218,7 @@ public class ActivitDefineController { } BusProcessApprove busProcessApprove = new BusProcessApprove(); - busProcessApprove.setFromValsJson(approveData.toString()); + busProcessApprove.setFromValsJson(JSON.toJSONString(approveData)); busProcessApprove.setTaskId(task.getId()); busProcessApprove.setCreateDate(new Date()); busProcessApprove.setPrcId(pi.getId()); diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/service/ActivitDefineService.java b/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/service/ActivitDefineService.java index 821df22..9a82313 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/service/ActivitDefineService.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/service/ActivitDefineService.java @@ -9,6 +9,7 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.util.Date; import java.util.List; import java.util.UUID; @@ -27,12 +28,16 @@ public class ActivitDefineService { String dataId = UUID.randomUUID().toString().replaceAll("-",""); if ("1".equals(prcType)){ List powerApplyActs = JSONObject.parseArray(dataJson, PowerApplyAct.class); +// LambdaQueryWrapper powerWrapper = new LambdaQueryWrapper<>(); +// powerWrapper.eq(PowerApplyAct::getPrcId,prcId); +// powerApplyActDao.delete(powerWrapper); for (PowerApplyAct powerApplyAct : powerApplyActs) { powerApplyAct.setId(UUID.randomUUID().toString().replaceAll("-","")); powerApplyAct.setDataId(dataId); powerApplyAct.setTaskId(taskId); powerApplyAct.setPrcId(prcId); powerApplyAct.setDelFlag(0); + powerApplyAct.setCreateDate(new Date()); } powerApplyActDao.batchInsert(powerApplyActs); } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/task/TodoTaskController.java b/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/task/TodoTaskController.java index cc44180..6f075d7 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/task/TodoTaskController.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_activiti/task/TodoTaskController.java @@ -3,7 +3,7 @@ package com.adc.da.wkflow.business_activiti.task; import cn.hutool.core.util.StrUtil; import com.adc.da.login.util.UserUtils; import com.adc.da.report.dao.mysql.PowerApplyActDao; -import com.adc.da.report.eo.PowerApplyAct; +import com.adc.da.report.vo.PowerApplyActPageVO; import com.adc.da.sys.service.iservice.IUserEoService; import com.adc.da.sys.vo.UserVO; import com.adc.da.util.exception.AdcDaBaseException; @@ -30,10 +30,8 @@ import com.adc.da.wkflow.util.activiti.ActivitiTools; import com.adc.da.wkflow.util.date.DateTools; import com.adc.da.wkflow.util.wrapper.WrapMapper; import com.adc.da.wkflow.util.wrapper.Wrapper; -import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; @@ -132,6 +130,10 @@ public class TodoTaskController { NativeTaskQuery nativeTaskQuery = taskTodoService.createSql(taskCommonQuery); List list = nativeTaskQuery.list(); List listPage = this.startPage(list, taskCommonQuery.getCurrent(), taskCommonQuery.getSize()); + if (list.size() == 0){ + page.setCount(0L); + return Result.success(page); + } List> listEnd = ActivitiTools.turnTasks(listPage); for (Map map : listEnd) { ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(map.get("processDefinitionId") + "").singleResult(); @@ -360,24 +362,26 @@ public class TodoTaskController { /** * - * @param taskId + * @param prcId * @param prcType */ @ApiOperation(value = "详情") @GetMapping("/queryDetail") - public ResponseMessage queryDetail(@RequestParam("taskId") String taskId,@RequestParam("prcType")String prcType) { - BusProcessNew busProcessNew = iBusProcessNewService.selectEOByTaskId(taskId); - if (busProcessNew == null) { + public ResponseMessage queryDetail(@RequestParam("prcId") String prcId,@RequestParam("prcType")String prcType) { + List busProcessNews = iBusProcessNewService.selectEOByTaskId(prcId); + if (busProcessNews.size() == 0) { return null; } + BusProcessNew busProcessNew = busProcessNews.get(0); // 查找详细业务数据 BusProcessNewVO busProcessNewVO = this.queryDetailDate(busProcessNew, prcType); //审批数据 - BusProcessApprove busProcessApprove = busProcessApproveMapper.selectEoByPrcIdAndTask(busProcessNewVO.getPId(), - busProcessNewVO.getTaskId()); - String approveJson = JSON.toJSONString(busProcessApprove); - busProcessNewVO.setApproveJson(approveJson); - return Result.success(busProcessApprove); + List busProcessApproves = + busProcessApproveMapper.selectEoByPrcIdAndTask(busProcessNewVO.getPId()); + BusProcessApprove busProcessApprove = busProcessApproves.get(0); + String approveJson = busProcessApprove.getFromValsJson(); + busProcessNewVO.setSubmitJson(approveJson); + return Result.success(busProcessNewVO); } private BusProcessNewVO queryDetailDate(BusProcessNew busProcessNew, String prcType) { @@ -385,16 +389,12 @@ public class TodoTaskController { BeanUtils.copyProperties(busProcessNew,busProcessNewVO); String dataId = busProcessNew.getDataId(); if ("1".equals(prcType)){ - LambdaQueryWrapper powerWrapper = new LambdaQueryWrapper<>(); - powerWrapper.eq(PowerApplyAct::getDataId,dataId); - List powerApplyActs = powerApplyActDao.selectList(powerWrapper); + List powerApplyActs = powerApplyActDao.selectListBydataId(dataId); String string = JSONArray.toJSONString(powerApplyActs); //去对应的 数据表查数据 - busProcessNewVO.setDateMesg(string); + busProcessNewVO.setDataJson(string); } - - return busProcessNewVO; } @@ -691,7 +691,17 @@ public class TodoTaskController { busProcessName.setTaskId(task.getTaskId()); } }); - + //获取 审批结果 +// if (StringUtils.isNotEmpty(busProcessName.getTaskId())) { +// List busProcessApproves = iBusProcessApproveService.selectEoByPrcIdAndTask(busProcessName.getPrcId()); +// if(busProcessApproves.size() != 0){ +// BusProcessApprove busProcessApprove = busProcessApproves.get(0); +// JSONObject dataJson = JSONObject.parseObject(busProcessApprove.getFromValsJson()); +// if (StringUtils.isNotEmpty(dataJson.getString("flag"))) { +// busProcessName.setStatus(dataJson.getString("flag")); +// } +// } +// } Date createTime = null; Date endTime = null; try { @@ -850,15 +860,14 @@ public class TodoTaskController { userTask.forEach(task->{ if (StringUtils.equals(task.getAssignee(),userId)) { busProcessName.setTaskId(task.getTaskId()); + busProcessName.setTaskDefinitionKey(task.getActivityId()); } }); - //获取 审批结果 // if (StringUtils.isNotEmpty(busProcessName.getTaskId())) { -// BusProcessApprove busProcessApprove = -// iBusProcessApproveService.selectEoByPrcIdAndTask(busProcessName.getPrcId(), -// busProcessName.getTaskId()); -// if(busProcessApprove != null){ +// List busProcessApproves = iBusProcessApproveService.selectEoByPrcIdAndTask(busProcessName.getPrcId()); +// if(busProcessApproves.size() != 0){ +// BusProcessApprove busProcessApprove = busProcessApproves.get(0); // JSONObject dataJson = JSONObject.parseObject(busProcessApprove.getFromValsJson()); // if (StringUtils.isNotEmpty(dataJson.getString("flag"))) { // busProcessName.setStatus(dataJson.getString("flag")); @@ -1015,7 +1024,17 @@ public class TodoTaskController { } else { busProcessName.setTaskBackAssignee(""); } - + //获取 审批结果 +// if (StringUtils.isNotEmpty(busProcessName.getPrcId())) { +// List busProcessApproves = iBusProcessApproveService.selectEoByPrcIdAndTask(busProcessName.getPrcId()); +// if(busProcessApproves.size() != 0){ +// BusProcessApprove busProcessApprove = busProcessApproves.get(0); +// JSONObject dataJson = JSONObject.parseObject(busProcessApprove.getFromValsJson()); +// if (StringUtils.isNotEmpty(dataJson.getString("flag"))) { +// busProcessName.setStatus(dataJson.getString("flag")); +// } +// } +// } Date createTime = null; Date endTime = null; try { diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/entity/BusProcessNew.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/entity/BusProcessNew.java index a166393..5edef6f 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/entity/BusProcessNew.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/entity/BusProcessNew.java @@ -11,6 +11,7 @@ import lombok.EqualsAndHashCode; import lombok.experimental.Accessors; import java.io.Serializable; +import java.util.Date; /** *

@@ -53,4 +54,8 @@ public class BusProcessNew implements Serializable { @TableField("P_ID") private String pId; + @ApiModelProperty(value = "创建时间") + @TableField("CREATE_DATE") + private Date createDate =new Date(System.currentTimeMillis()); + } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessApproveMapper.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessApproveMapper.java index 887bd98..442102d 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessApproveMapper.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessApproveMapper.java @@ -4,6 +4,8 @@ import com.adc.da.wkflow.business_main.entity.BusProcessApprove; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Param; +import java.util.List; + /** *

* Mapper 接口 @@ -15,6 +17,6 @@ import org.apache.ibatis.annotations.Param; public interface BusProcessApproveMapper extends BaseMapper { - BusProcessApprove selectEoByPrcIdAndTask(@Param("prcId") String prcId,@Param("taskId") String taskId); + List selectEoByPrcIdAndTask(@Param("prcId") String prcId); } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessNewMapper.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessNewMapper.java index 385ff63..d66b67f 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessNewMapper.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/mapper/BusProcessNewMapper.java @@ -25,7 +25,7 @@ public interface BusProcessNewMapper extends BaseMapper { List findNoExecuteBusProcessNewForEnd(@Param("taskIds")List taskIds); - BusProcessNew selectEOByTaskId(@Param("taskId") String taskId); + List selectEOByTaskId(@Param("prcId") String prcId); // String queryTaskName(@Param("id")String id); } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessApproveService.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessApproveService.java index 101afa1..41b06fe 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessApproveService.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessApproveService.java @@ -3,12 +3,13 @@ package com.adc.da.wkflow.business_main.service; import com.adc.da.wkflow.business_main.entity.BusProcessApprove; import com.baomidou.mybatisplus.extension.service.IService; +import java.util.List; /** * 审批历史业务类 * 用于审批历史的查询的存取 */ public interface IBusProcessApproveService extends IService { - BusProcessApprove selectEoByPrcIdAndTask(String prcId, String taskId); + List selectEoByPrcIdAndTask(String prcId); } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessNewService.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessNewService.java index 2e1e244..e38826f 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessNewService.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/IBusProcessNewService.java @@ -29,5 +29,5 @@ public interface IBusProcessNewService extends IService { List findNoExecuteBusProcessNewForEnd(List taskIdList); - BusProcessNew selectEOByTaskId(String taskId); + List selectEOByTaskId(String prcId); } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessApproveServiceImpl.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessApproveServiceImpl.java index af37144..e7afbe8 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessApproveServiceImpl.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessApproveServiceImpl.java @@ -6,6 +6,8 @@ import com.adc.da.wkflow.business_main.service.IBusProcessApproveService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.stereotype.Service; +import java.util.List; + /** *

* 服务实现类 @@ -20,8 +22,8 @@ public class BusProcessApproveServiceImpl extends ServiceImpl selectEoByPrcIdAndTask(String prcId) { - return baseMapper.selectEoByPrcIdAndTask(prcId,taskId); + return baseMapper.selectEoByPrcIdAndTask(prcId); } } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNameServiceImpl.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNameServiceImpl.java index 11317f9..f09c20e 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNameServiceImpl.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNameServiceImpl.java @@ -5,6 +5,7 @@ import com.adc.da.wkflow.business_main.mapper.BusProcessNameMapper; import com.adc.da.wkflow.business_main.service.IBusProcessNameService; import com.adc.da.wkflow.enums.FlowTypeEnum; import com.adc.da.wkflow.util.ImpulseSenderUtils; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.activiti.engine.ActivitiException; import org.apache.commons.lang3.StringUtils; @@ -50,8 +51,20 @@ public class BusProcessNameServiceImpl extends ServiceImpl queryByPrcNum = new QueryWrapper<>(); + queryByPrcNum.lambda().like(BusProcessName::getPrcNum,prcNum + currentDay); + queryByPrcNum.orderByDesc("CREAT_TIME"); + List busNum = this.list(queryByPrcNum); + if(busNum.size()>0){ + String currenBusNum = busNum.get(0).getPrcNum(); + String substring = currenBusNum.substring(currenBusNum.length()-4, currenBusNum.length()); + Long num = Long.parseLong(substring) + 1; + prcNum = prcNum + currentDay + String.format("%04d", num); + }else { + prcNum = prcNum + currentDay + numberByFlowType; + } + result.put("prcName",prcName); result.put("prcNum",prcNum); return result; diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNewServiceImpl.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNewServiceImpl.java index d3838e8..78e28a5 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNewServiceImpl.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/service/impl/BusProcessNewServiceImpl.java @@ -70,7 +70,7 @@ public class BusProcessNewServiceImpl extends ServiceImpl selectEOByTaskId(String prcId) { + return baseMapper.selectEOByTaskId(prcId); } } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/business_main/vo/BusProcessNewVO.java b/report-activity/src/main/java/com/adc/da/wkflow/business_main/vo/BusProcessNewVO.java index 6734e44..f799689 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/business_main/vo/BusProcessNewVO.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/business_main/vo/BusProcessNewVO.java @@ -22,10 +22,10 @@ public class BusProcessNewVO { private String dataId; @ApiModelProperty(value = "具体的业务数据") - private String dateMesg; + private String dataJson; @ApiModelProperty(value = "具体的审批数据") - private String approveJson; + private String submitJson; @ApiModelProperty(value = "节点信息") private String taskInfo; diff --git a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid1.java b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid1.java index 2ce0431..1a06f3b 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid1.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid1.java @@ -50,7 +50,10 @@ public class aid1 implements TaskListener { List list = approveService.list(approveWrapper); String fromValsJson = list.get(0).getFromValsJson(); JSONObject object = JSONObject.parseObject(fromValsJson); + //审批人 delegateTask.setVariable("oneApprove",object.getString("oneApprove")); delegateTask.setVariable("twoApprove",object.getString("twoApprove")); + //发起人 + delegateTask.setVariable("userId",object.getString("userId")); } } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid2.java b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid2.java index 9f4c024..c2ecee3 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid2.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid2.java @@ -48,8 +48,8 @@ public class aid2 implements TaskListener { //审批结果 LambdaQueryWrapper approveWrapper = new LambdaQueryWrapper<>(); approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId()); - BusProcessApprove one = approveService.getOne(approveWrapper); - String fromValsJson = one.getFromValsJson(); + List list = approveService.list(approveWrapper); + String fromValsJson = list.get(0).getFromValsJson(); JSONObject object = JSONObject.parseObject(fromValsJson); String s = object.getString("flag") == "" || object.getString("flag") == null ? FlagEnum.AGREE.getValue() : object.getString("flag"); // 1: 同意 2：退回 diff --git a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid3.java b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid3.java index 5a05e81..e567043 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid3.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid3.java @@ -2,6 +2,7 @@ package com.adc.da.wkflow.listener.powerApply; import com.adc.da.login.util.UserUtils; import com.adc.da.report.dao.mysql.PowerApplyActDao; +import com.adc.da.report.dao.mysql.PowerApplyDao; import com.adc.da.report.eo.PowerApplyAct; import com.adc.da.wkflow.business_main.entity.BusProcessApprove; import com.adc.da.wkflow.business_main.entity.BusProcessNew; @@ -24,6 +25,7 @@ public class aid3 implements TaskListener { @Override public void notify(DelegateTask delegateTask) { PowerApplyActDao powerApplyActDao = SpringContextUtil.getBean(PowerApplyActDao.class); + PowerApplyDao powerApplyDao = SpringContextUtil.getBean(PowerApplyDao.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessApproveService approveService = SpringContextUtil.getBean(IBusProcessApproveService.class); //查询task任务 @@ -48,11 +50,15 @@ public class aid3 implements TaskListener { //审批结果 LambdaQueryWrapper approveWrapper = new LambdaQueryWrapper<>(); approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId()); - BusProcessApprove one = approveService.getOne(approveWrapper); - String fromValsJson = one.getFromValsJson(); + List list = approveService.list(approveWrapper); + String fromValsJson = list.get(0).getFromValsJson(); JSONObject object = JSONObject.parseObject(fromValsJson); String s = object.getString("flag") == "" || object.getString("flag") == null ? FlagEnum.AGREE.getValue() : object.getString("flag"); // 1: 同意 2：退回 delegateTask.setVariable("flag",s); + if ("1".equals(s)){ + powerApplyDao.saveBatch(powerApplyActs); + } + } } diff --git a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid4.java b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid4.java index 3b5bfb4..f3c18ed 100644 --- a/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid4.java +++ b/report-activity/src/main/java/com/adc/da/wkflow/listener/powerApply/aid4.java @@ -47,8 +47,8 @@ public class aid4 implements TaskListener { //审批结果 LambdaQueryWrapper approveWrapper = new LambdaQueryWrapper<>(); approveWrapper.eq(BusProcessApprove::getTaskId, delegateTask.getId()); - BusProcessApprove one = approveService.getOne(approveWrapper); - String fromValsJson = one.getFromValsJson(); + List list = approveService.list(approveWrapper); + String fromValsJson = list.get(0).getFromValsJson(); JSONObject object = JSONObject.parseObject(fromValsJson); delegateTask.setVariable("oneApprove",object.getString("oneApprove")); diff --git a/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessApproveMapper.xml b/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessApproveMapper.xml index 48fb446..f4d9a4f 100644 --- a/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessApproveMapper.xml +++ b/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessApproveMapper.xml @@ -3,6 +3,7 @@ diff --git a/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessNewMapper.xml b/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessNewMapper.xml index 3e9115c..54cbe4e 100644 --- a/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessNewMapper.xml +++ b/report-activity/src/main/resources/mybatis/mapper/mysql/BusProcessNewMapper.xml @@ -30,6 +30,7 @@