优化

java110-bean/src/main/java/com/java110/dto/log/LogSystemErrorDto.java

@@ -19,6 +19,7 @@ public class LogSystemErrorDto extends PageDto implements Serializable {
     public static final String ERR_TYPE_JOB = "JOB";
     public static final String ERR_TYPE_OWE_FEE = "OWE_FEE";
     public static final String ERR_TYPE_NOTICE = "NOTICE";
+    public static final String ERR_TYPE_DATABUS = "DATABUS";
     public static final String ERR_TYPE_COUPON = "COUPON";
     public static final String ERR_TYPE_INTEGRAL = "INTEGRAL";
     public static final String ERR_TYPE_CMD = "CMD";

service-job/src/main/java/com/java110/job/databus/DatabusDataQueue.java

@@ -19,10 +19,7 @@ public class DatabusDataQueue {
      * @param databusQueueDataDto
      */
     public static void addMsg(DatabusQueueDataDto databusQueueDataDto) throws Exception {
-
-
         msgs.offer(databusQueueDataDto, 3, TimeUnit.MILLISECONDS);
-
     }
 
     public static DatabusQueueDataDto getData() throws Exception {

service-job/src/main/java/com/java110/job/smo/impl/DataBusInnerServiceSMOImpl.java

@@ -209,13 +209,11 @@ public class DataBusInnerServiceSMOImpl extends BaseServiceSMO implements IDataB
 //                    databusAdaptImpl.execute(business, businesses);
             } catch (Exception e) {
                 logger.error("执行databus失败", e);
-
                 LogSystemErrorPo logSystemErrorPo = new LogSystemErrorPo();
                 logSystemErrorPo.setErrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_errId));
-                logSystemErrorPo.setErrType(LogSystemErrorDto.ERR_TYPE_NOTICE);
+                logSystemErrorPo.setErrType(LogSystemErrorDto.ERR_TYPE_DATABUS);
                 logSystemErrorPo.setMsg(ExceptionUtil.getStackTrace(e));
                 saveSystemErrorSMOImpl.saveLog(logSystemErrorPo);
-                logger.error("通知异常", e);
             }
         }
     }