新宝对接-增加日志

src/main/java/com/uas/eis/task/InventoryTask.java

@@ -29,10 +29,12 @@ public class InventoryTask extends BaseTask{
     private final Logger logger = LoggerFactory.getLogger(this.getClass());
     public void execute() {
         Object ob=baseDao.getFieldDataByCondition("DOCKING_XB_WH_CHANGE","max(ID_)","NVL(DEALSTATE,0)=0");
+        int n=0;
         if(ob!=null){
             try{
                 String Sql = "select * from DOCKING_Inventory where YM_VIEW_PARAM.SET_ID_("+ob+")<="+ob+" order by WAREHOUSENO, MATERIALNO";
                 SqlRowList rs = baseDao.queryForRowSet(Sql);
+                n=rs.size();
                 while (rs.next()) {
                     JSONObject jsonobj=new JSONObject();
                     jsonobj.put("supplyCode", donlimConfig.getSupplyCode());
@@ -62,7 +64,10 @@ public class InventoryTask extends BaseTask{
                 baseDao.execute("update DOCKING_XB_WH_CHANGE set dealdate_=sysdate ,DEALSTATE=1 where  ID_<="+ob+" and NVL(DEALSTATE,0)=0");
             } catch (Exception e) {
                 e.printStackTrace();
+                baseDao.execute("insert into dockinglog(id_,date_,type_,result_,Info_) " +
+                        " values(dockinglog_seq.nextval,sysdate,'Inventory','FAILED','"+ e.getMessage()+"')");
             }
+            baseDao.execute("insert into dockinglog(id_,date_,type_,result_,Info_) values(dockinglog_seq.nextval,sysdate,'SALEOUT','SUCCEED','条数：'"+n+")");
         }
         /*else{
             logger.info("InventoryTask 无数据变更，无须对接 ");

src/main/java/com/uas/eis/task/SaleDownLoadTask.java

@@ -62,11 +62,15 @@ public class SaleDownLoadTask extends BaseTask {
             //对接数据转入正式表
             baseDao.procedure("dockingToSale", new Object[] { req.getTimeStamp()});
             logger.info("SaleDownLoad turnSale end");
+            baseDao.execute("insert into dockinglog(id_,date_,type_,result_,Info_) values(dockinglog_seq.nextval,sysdate,'SALE','SUCCEED','条数：'"+downLoadDTOS.size()+")");
         } catch (Exception e) {
             if(errsqls.size()>0){
                 baseDao.execute(errsqls);
             }
             e.printStackTrace();
+            baseDao.execute("insert into dockinglog(id_,date_,type_,result_,Info_) " +
+                    " values(dockinglog_seq.nextval,sysdate,'SALE','FAILED','"+ e.getMessage()+"')");
+
         }
     }
 }

src/main/java/com/uas/eis/task/SaleOutTask.java

@@ -63,9 +63,15 @@ public class SaleOutTask extends BaseTask{
             //对接数据转入正式表
             baseDao.procedure("dockingToSaleOut", new Object[] { req.getTimeStamp()});
             logger.info("SaleDownLoad turnSaleOut end");
+            baseDao.execute("insert into dockinglog(id_,date_,type_,result_,Info_) values(dockinglog_seq.nextval,sysdate,'SALEOUT','SUCCEED','条数：'"+saleOutDTOS.size()+")");
 
         } catch (Exception e) {
+            if(errsqls.size()>0){
+                baseDao.execute(errsqls);
+            }
             e.printStackTrace();
+            baseDao.execute("insert into dockinglog(id_,date_,type_,result_,Info_) " +
+                    " values(dockinglog_seq.nextval,sysdate,'SALEOUT','FAILED','"+ e.getMessage()+"')");
         }
     }
 }