9.06 修改控制台输出情况

sp-service/async-server/src/main/java/com/pj/task/HtByteTask.java

@@ -79,21 +79,7 @@ public class HtByteTask {
      */
     @Autowired
     private HtTradeSettlementMapper htTradeSettlementMapper;
-    /**
-     * 边民购买记录(主表:ht_trade_settlement)
-     */
-    @Autowired
-    private HtBordersListMapper htBordersListMapper;
-    /**
-     * 边民购买商品信息表(主表:ht_trade_settlement)
-     */
-    @Autowired
-    private HtBorderBuyGoodsListMapper htBorderBuyGoodsListMapper;
-    /**
-     * 商铺卖货物信息表(主表:ht_trade_settlement)
-     */
-    @Autowired
-    private HtSellGoodsListMapper htSellGoodsListMapper;
+
 
     /**
      * 启动定时任务
@@ -117,7 +103,7 @@ public class HtByteTask {
         List<HtByte> byteList = htByteMapper.selectList(new LambdaQueryWrapper<HtByte>().eq(HtByte::getFinishStatus, FinishStatus.FINISH_STATUS_ZERO.getCode()));
         //判断是否有任务,没有则返回
         if (byteList.size() == 0) {
-            System.out.println("\n  ---  暂无待处理任务。" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "\n");
+            System.err.println("\n  ---  暂无待处理任务。" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "\n");
             return;
         }
         //执行任务处理流程
@@ -139,9 +125,9 @@ public class HtByteTask {
                     flag = FeignFactory.levelOneServerInterface.peopleDto(peopleDto);
                     methodHtByteTask.updateHtByteInfo(flag, item, dataDto);
                     if (!flag) {
-                        System.out.println("\n边民信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n边民信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                        System.out.println("\n边民信息处理成功。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n边民信息处理成功。 messageId = " + item.getMessageId() + "\n");
                     }
                     break;
                 case "002":
@@ -151,9 +137,9 @@ public class HtByteTask {
                     flag = FeignFactory.levelOneServerInterface.shopDto(shopDto);
                     methodHtByteTask.updateHtByteInfo(flag, item, dataDto);
                     if (!flag) {
-                        System.out.println("\n店铺信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n店铺信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                        System.out.println("\n店铺信息处理完成。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n店铺信息处理完成。 messageId = " + item.getMessageId() + "\n");
                     }
                     break;
                 case "003":
@@ -163,9 +149,9 @@ public class HtByteTask {
                     flag = FeignFactory.levelOneServerInterface.groupDto(groupDto);
                     methodHtByteTask.updateHtByteInfo(flag, item, dataDto);
                     if (!flag) {
-                        System.out.println("\n互助组信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n互助组信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                        System.out.println("\n互助组信息处理完成。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n互助组信息处理完成。 messageId = " + item.getMessageId() + "\n");
                     }
                     break;
                 case "004":
@@ -175,9 +161,9 @@ public class HtByteTask {
                     flag = FeignFactory.levelOneServerInterface.cooperativeDto(cooperativeDto);
                     methodHtByteTask.updateHtByteInfo(flag, item, dataDto);
                     if (!flag) {
-                        System.out.println("\n边民合作社信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n边民合作社信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                        System.out.println("\n边民合作社信息处理完成。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n边民合作社信息处理完成。 messageId = " + item.getMessageId() + "\n");
                     }
                     break;
                 case "005":
@@ -187,9 +173,9 @@ public class HtByteTask {
                     flag = FeignFactory.levelOneServerInterface.goodsDto(goodsDto);
                     methodHtByteTask.updateHtByteInfo(flag, item, dataDto);
                     if (!flag) {
-                        System.out.println("\n海关监管商品信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n海关监管商品信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                    System.out.println("\n海关监管商品信息处理完成。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n海关监管商品信息处理完成。 messageId = " + item.getMessageId() + "\n");
                     }
                     break;
                 case "006":
@@ -218,12 +204,12 @@ public class HtByteTask {
                         tradeSettlementDto.setBorderBuyGoodsListDtoList(buyGoodsList);
                         boolean b = FeignFactory.levelOneServerInterface.tradeSettlementDto(tradeSettlementDto);
                         if(!b)throw new ServiceException("添加错误;");
-                        System.out.println("\n交易结算信息处理成功。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n交易结算信息处理成功。 messageId = " + item.getMessageId() + "\n");
                         break;
                     }
                     //保存航通监听记录
                     methodHtByteTask.updateHtByteInfo(false,item,dataDto);
-                    System.out.println("\n交易结算信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                    System.err.println("\n交易结算信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     break;
                 case "007":
                     //放行记录（过卡记录）
@@ -234,9 +220,9 @@ public class HtByteTask {
                     int insert1 = htPassCardRecordMapper.insert(htPassCardRecord);
                     methodHtByteTask.updateHtByteInfo(true,item,dataDto);
                     if(insert1 == 1){
-                        System.out.println("\n放行记录（过卡记录）信息处理成功。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n放行记录（过卡记录）信息处理成功。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                        System.out.println("\n放行记录（过卡记录）信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n放行记录（过卡记录）信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }
 
                     //系统接收到航通过卡记录且卡口类型为'3卡'：车辆已出一级市场, 修改相对应的一级市场订单状态
@@ -253,9 +239,9 @@ public class HtByteTask {
                     int insert2 = htImportDeclarePeopleMapper.insert(htImportDeclarePeople);
                     methodHtByteTask.updateHtByteInfo(insert2 == 1,item,dataDto);
                     if(insert2 == 1){
-                        System.out.println("\n进口申报单边民确认信息处理成功。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n进口申报单边民确认信息处理成功。 messageId = " + item.getMessageId() + "\n");
                     }else {
-                        System.out.println("\n进口申报单边民确认信息处理失败。 messageId = " + item.getMessageId() + "\n");
+                        System.err.println("\n进口申报单边民确认信息处理失败。 messageId = " + item.getMessageId() + "\n");
                     }
                     break;
                 default:

sp-service/level-one-server/src/main/java/com/pj/tb_shop/TbShopService.java

@@ -228,7 +228,7 @@ public class TbShopService extends ServiceImpl<TbShopMapper, TbShop> implements
         //关闭输出流
         fos.close();
         workbook.close();
-        System.out.println("\n数据导出完成!共导出 " + count + " 条数据。");
+        System.err.println("\n数据导出完成!共导出 " + count + " 条数据。");
         return "数据导出完成!共导出 " + count + " 条数据。";
     }