From 23308b03a51def5c943ca32846b22b07c137340f Mon Sep 17 00:00:00 2001 From: haozq <1611483981@qq.com> Date: Sun, 28 Sep 2025 09:34:45 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=A5=E5=BF=97=E8=AE=B0?= =?UTF-8?q?=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bonus/emergencyrap/mapper/LogsMapper.java | 14 ++ .../bonus/emergencyrap/service/LogsUtils.java | 42 +++--- .../bonus/emergencyrap/vo/TaskProcessVo.java | 8 +- src/main/resources/application.yml | 5 +- src/main/resources/db/emergency_rpa.db | Bin 49152 -> 65536 bytes src/main/resources/logback-spring.xml | 126 ++++++++++++++++++ src/main/resources/mapper/LogsMapper.xml | 11 ++ 7 files changed, 175 insertions(+), 31 deletions(-) create mode 100644 src/main/java/com/bonus/emergencyrap/mapper/LogsMapper.java create mode 100644 src/main/resources/logback-spring.xml create mode 100644 src/main/resources/mapper/LogsMapper.xml diff --git a/src/main/java/com/bonus/emergencyrap/mapper/LogsMapper.java b/src/main/java/com/bonus/emergencyrap/mapper/LogsMapper.java new file mode 100644 index 0000000..f2b18b1 --- /dev/null +++ b/src/main/java/com/bonus/emergencyrap/mapper/LogsMapper.java @@ -0,0 +1,14 @@ +package com.bonus.emergencyrap.mapper; + +import com.bonus.emergencyrap.vo.TaskMessageVo; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface LogsMapper { + + /** + * 添加日志数据 + * @param logs + */ + void addLogs(TaskMessageVo logs); +} diff --git a/src/main/java/com/bonus/emergencyrap/service/LogsUtils.java b/src/main/java/com/bonus/emergencyrap/service/LogsUtils.java index 4113b71..3135589 100644 --- a/src/main/java/com/bonus/emergencyrap/service/LogsUtils.java +++ b/src/main/java/com/bonus/emergencyrap/service/LogsUtils.java @@ -2,6 +2,7 @@ package com.bonus.emergencyrap.service; import com.alibaba.fastjson2.JSON; import com.bonus.emergencyrap.constant.TextConstants; +import com.bonus.emergencyrap.mapper.LogsMapper; import com.bonus.emergencyrap.utils.DateTimeHelper; import com.bonus.emergencyrap.utils.TextFileUtils; import com.bonus.emergencyrap.utils.UploadFile; @@ -9,6 +10,7 @@ import com.bonus.emergencyrap.vo.TaskMessageVo; import com.bonus.emergencyrap.vo.TaskProcessVo; import com.bonus.emergencyrap.vo.TaskVo; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.UUID; @@ -17,48 +19,36 @@ import java.util.UUID; @Slf4j public class LogsUtils { + @Autowired + private LogsMapper mapper; + + public final static String SUCCESS="1"; + + public final static String FAIL="0"; /** * 执行日志添加 * @param vo * @param processVo - * @param success + * @param success 1成功 2失败 * @param message */ public void addLogs(TaskVo vo, TaskProcessVo processVo,String success,String message) { try{ - String day=DateTimeHelper.getNowYMD(); - String filePtah= UploadFile.getFilePath(TextConstants.LOGS+day); - boolean isCz=TextFileUtils.exists(filePtah); TaskMessageVo logs=new TaskMessageVo(); - String uuid=UUID.randomUUID().toString(); logs.setTaskId(vo.getTaskId()); - logs.setId(uuid); - logs.setTaskName(vo.getTaskName()); - logs.setDay(day); + logs.setId(UUID.randomUUID().toString()); logs.setCreateTime(DateTimeHelper.getNowTime()); + //记录失败的 操作元素 + if(FAIL.equals(success)){ + logs.setErrId(processVo.getId()); + } + logs.setStatus(success); logs.setMessage(message); - appendToFile(filePtah, JSON.toJSONString(logs),uuid,!isCz); + mapper.addLogs(logs); }catch (Exception e){ log.error(e.getMessage(),e); } } - /** - * 添加数据 - * @param filePath - * @param content - * @param id - * @param append - */ - public void appendToFile(String filePath,String content,String id,boolean append){ - if(append){ - TextFileUtils.createFile(filePath); - }else{ - TextFileUtils.appendToFile(filePath,"\n"); - } - TextFileUtils.appendToFile(filePath,id); - TextFileUtils.appendToFile(filePath,"="); - TextFileUtils.appendToFile(filePath,content); - } } diff --git a/src/main/java/com/bonus/emergencyrap/vo/TaskProcessVo.java b/src/main/java/com/bonus/emergencyrap/vo/TaskProcessVo.java index 7486b10..600200f 100644 --- a/src/main/java/com/bonus/emergencyrap/vo/TaskProcessVo.java +++ b/src/main/java/com/bonus/emergencyrap/vo/TaskProcessVo.java @@ -4,9 +4,13 @@ import lombok.Data; @Data public class TaskProcessVo { - + /** + * 任务id + */ private String taskId; - + /** + * id + */ private String id; /** diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 4a17489..b03633e 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -21,9 +21,7 @@ server: # 日志配置 logging: - level: - com.bonus: debug - org.springframework: warn + config: classpath:logback-spring.xml # Spring配置 @@ -75,6 +73,7 @@ task: seconds: 60 + mybatis: mapper-locations: classpath:mapper/*Mapper.xml diff --git a/src/main/resources/db/emergency_rpa.db b/src/main/resources/db/emergency_rpa.db index 15a8046aaf304de55f78933d590f23e4e85cba6d..279625733e54228e6fa9546a00901c7850d47f16 100644 GIT binary patch literal 65536 zcmeI*TZ|i583*vO_u|Bkce33FD~h68TdlI&aJF;5EJ7uu5h_hDlvpT;$~rSX(^~Pa zgY8Yyhf3_WP1;mZD@3GL2tg}KKuFyb5}_yv5Q1kO=?gDaz1@fhUf>BH_-5>JyjfeB zl#p%0--&N?{myUBIWs#xbLJagKT>UpVo+}^@>Wroc1x+0^yOkvlG3kB5`C4VEIrfo zoTTR{J>y3z{xJNVmNDXvt(elbI-aOuYn>h6B;e$sH z7mptN%8|px>F&_!;%q)!q^~q#xmuYnw#4bytYypx|BvET1s=eSY2v~=S5>yRl7@Sh-SUE z+^P%GCwXGLV#Hop6?#|MePR+F9^t5J z;u)&Va&y`DMf2tn0k77|OUsJ`lCvBJ98dYn7L&$-PRpnp`n-Qzfh)dKzFJJ~lZu?_CGsJwN{N3RwTHL)m` zT3gF|XLz}+%2h~SR{NEA z<^GYXZO`uE|8K2qYP@i8@2xgcynST(MQKNf^!Vg>;W>NQY`u-UskT)I4$iOe@l0WE zF17knTr9i$#c(e``J(SzW=qlR8=0VR4&C9N;LYZ#dL!Ps-`GPo>NPR21V+24zM|Qi zW%DknTNJ*S8819NH;ij@BBR34m#!Tvhek7n2OmtWmNo!f~sB}hjHYcKZ>)+mN1jSt^Owj??n znjpzrj^nyjYWLt}OSLEHxQmk6>>XS6HuZEkDy-|b%(KO1Hm>dmW)C)Ui$WMCEy@?+ zhwu;Ss1UxC$`tnPORYQ^5lFj!qzH= zYP5gy;l}0n4bF962%QO6ahYM8HuD1EF|Mn2U~)guTsv%o$Y`u)6;*9PvlcX+n5uV$ z>TrtEv~!Q7tBT<{6uDqtMXxZ!ROyq?Rc4xj9(bA}6vtVA?XC8?9}S2%YTPgXQCS@1)=V-;>hvW0L%seDVHCAW{MW z2tWV=5P$##AOHafKmY;|xbp(vPLG%NKO*an=Gm&@YAo<{&J3TL8F1GNe~7mYYAfKX zrt7a?d1GVkLi_5k+HYP`Pn|k7@6y9@=w;roFRJ~&(3=aozMwl4@7Vrtj?gM*WL>j_ z>1#SQIWT>L8H%ScE>w@&FIb9Z>$E7(>tBTyuHtyDRtuM|+_ZFSL2=2>a`w4RlSTs~G4K z2k!ZFvcPhfXWMk{z}HRd~>%Y{a zZuwl-5-D2Co|%H9@W2*9g$e42fEpDDpSh+8sAYj=RRZ6xC}yID2c4C4+6Hu16|Jdr z{r{RIe}v!v;|+{=2tWV=5P$##AOHafKmY;|fWS5jgunkMIq#6(KT_J6}L)3b76dKmY;|fB*y_009U< z00Izz00i!yK=}KACifRfZcc1Wd@KLQyt?Z+eZ>O;5P$##AOHafKmY;|xOW6rCNsO} z^5H2qrB2Q4%qym*3B^|!bsbK(2={%?xJ?%=yG}*bDkfI~%Qh6-po@up=G%_P42Lc> z_DoBmyNbK2uX%>)sapH|h4$HNmFmfEALFmS{ORQ%x4-)vRhc*Y2W|X%t^M0q*56+1 z4m|T}`-7`1hsG(UnVADoOeI?t4i^UXU2ZCZ83A40%uSm!%hMdquyx_vbWODx7+eo; zy>3(7h7vGOa6wmGI~EUU9^cT`FI-wb|H1XMXRrU@3`N%YpzHJf@lc3KBILH~@rvp) z$9Jj2G@rV1cLQH#w(Ze1-d2TEPwp$b$0FHID)NRf9U~ALb5w^Sqz>Gfry87@0rx80 zH66>>lH8zum~4`;SEfe8koIJ6tDSM<#FsmC|N_2_=^HW_lmQ(S|B5*0g1N_!#c zmX!pv{nk%6ZSLGi7**ksDRU~H%5%%4pft)}j-rK|QfE966{b1dQhm<|JiFqEz|}44 zHs7!unnoAYb)Dy!)Vsaz8-ng}Z>UBussjgZ3hKatfmk%%+iN2$JJQ|FW{1%j)GwYd zgwE)qdY2it8D=rzF|Mn2U~)guT>G}7xha-`ktoVMg_2&$rn;MpLfM(OoxpSrQ)h~% z2b6N^s?QZcz$`;Ih2_}P)4zLLp{S~oEE zB8311AOHafKmY;|fB*y_009Ve1j0+^lbrv`gcBw?DK#EWnB=_ASU6#lvoWLLgh@`2 zME(CKId>6V|DWW{LiqPTuK!0_fdB*`009U<00Izz00bZa0SMgR0%80AvFsIT;&1uC z?)r1?5A+ca2tWV=5P$##AOHafe7*!$vtyH`IjQte>IqxjqssD*lAfgbdZ$_JC)cjE z&%NuqN$#Wla54V(XqK^{-tYz8-|J+R-kLtI2^Mg_Rd0MrnYTL&U%&F^#>Lm#@BFOW z1pdk!8*3M?|NO)Dx$cnmyT4dJ_kL&M&hYkI=Rdu8Nl}t?*R3g<$*9G$W))R?L9rJM zdo?>cS(=&LgpsJ-d=y#-Lrrv}vY6uG;{P5aNhjz17}kR6EEvjaZe+5we=|ms=J)+M zL*Fiq&ZP@mvxcgC1`T_`bXRlfEgDH${`YHWs5vzs(1Rwwb2tWV=5P$##AOHafK;SM3{0C|!9?Ad! delta 199 zcmZo@U}+!BVQuF7jFii9*;Y( zHdiE%1jhz0h0THjdK{ZKaI9pMYqsHF7nhc1Z1XQkOv*_uNs2E?EY5~foRcrHbWYA= z|2KIWhZLJGC!4sV^khR`X+DsectfZvuFdW|yM#A0HvH$`bbv)*GfTrCd<;e|uu=d` CmN{Mk diff --git a/src/main/resources/logback-spring.xml b/src/main/resources/logback-spring.xml new file mode 100644 index 0000000..23faeba --- /dev/null +++ b/src/main/resources/logback-spring.xml @@ -0,0 +1,126 @@ + + + + + + + ${LOG_CONTEXT_NAME} + + + + + %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %highlight(%-5level) %cyan(%logger{50}:%L) - %msg%n + utf-8 + + + INFO + + + + + + + + + + + + + + + + INFO + + + ${CONSOLE_LOG_PATTERN} + + UTF-8 + + + + + + true + + + ${LOG_HOME}/%d{yyyy-MM-dd}/info/info.%d{yyyy-MM-dd-HH}.%i.log + + 30 + + + 10MB + + + + + %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{56}.%method:%L - %msg%n + utf-8 + + + + INFO + ACCEPT + DENY + + + + + + + true + + + ${LOG_HOME}/%d{yyyy-MM-dd}/error/error.%d{yyyy-MM-dd}.%i.log + + 30 + + + 10MB + + + + + %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{56}.%method:%L - %msg%n + utf-8 + + + + ERROR + ACCEPT + DENY + + + + + + true + + ${LOG_HOME}/%d{yyyy-MM-dd}/warn/warn.%d{yyyy-MM-dd}.%i.log + + 30 + + + 10MB + + + + + %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{56}.%method:%L - %msg%n + utf-8 + + + + WARN + ACCEPT + DENY + + + + + + + + + + + diff --git a/src/main/resources/mapper/LogsMapper.xml b/src/main/resources/mapper/LogsMapper.xml new file mode 100644 index 0000000..e15e4e0 --- /dev/null +++ b/src/main/resources/mapper/LogsMapper.xml @@ -0,0 +1,11 @@ + + + + + + + insert into tb_logs(id,task_id,status,err_reason,err_id,create_time )values + (#{id},#{taskId},#{status},#{message},#{errId},#{createTime}) + +