【易探】【客户资料下载 由根据创建时间排序下载改为根据最后更新时间排序下载】

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

@@ -1,5 +1,6 @@
 package com.uas.eis.task;
 
+import com.uas.eis.beans.req.CrmQueryReq;
 import com.uas.eis.beans.result.BaseResult;
 import com.uas.eis.beans.result.CrmQueryResult;
 import com.uas.eis.beans.result.Customer;
@@ -41,12 +42,35 @@ public class YITCustomerTask {
     public void syncCustomers() {
         String Master ="YIT.";
         try {
-            List<String> field_values = new ArrayList<>();
+            //List<String> field_values = new ArrayList<>();
             SqlRowList rs = baseDao.queryForRowSet("select ml_syncTime from (select * from "+Master+"FXXKDockingErrorlog where nvl(ML_TYPE,' ')='客户资料下载' and ML_SYNCTIME is not null order by ml_date desc) where rownum=1");
             if(rs.next()){
+                List<CrmQueryReq.Filters> filtersList = new ArrayList<>();
+
+                List<String> field_values = new ArrayList<>();
                 String ml_syncTime = rs.getGeneralString("ml_syncTime");
                 field_values.add(ml_syncTime);
-                CrmQueryResult crmQueryResult = customerManager.queryCustomer(field_values);
+
+                CrmQueryReq.Filters filters = new CrmQueryReq.Filters();
+                filters.setField_name("last_modified_time");
+                filters.setField_values(field_values);
+                filters.setOperator("GT");
+                filtersList.add(filters);
+
+                List<String> field_values2 = new ArrayList<>();
+                field_values2.add("广东奥莱敏控技术有限公司");
+
+                CrmQueryReq.Filters filters2 = new CrmQueryReq.Filters();
+                filters2.setField_name("name");
+                filters2.setField_values(field_values2);
+                filters2.setOperator("EQ");
+                //filtersList.add(filters2);
+                //isCustom 参数应该为false
+                CrmQueryResult crmQueryResult = commonManager.multiQueryCommon(filtersList, "last_modified_time", true, 100, "AccountObj", false);
+
+                /*String ml_syncTime = rs.getGeneralString("ml_syncTime");
+                field_values.add(ml_syncTime);
+                CrmQueryResult crmQueryResult = customerManager.queryCustomer(field_values);*/
                 int errorCode = crmQueryResult.getErrorCode();
                 if(errorCode == 0){
                     Map<String, Object> data = crmQueryResult.getData();
@@ -55,7 +79,8 @@ public class YITCustomerTask {
                     int m=0,n=0,k=0;
                     if(dataList.size()>0){
                         //最后(即最近)一次同步时间
-                        Long create_time_Last = Long.parseLong(new BigDecimal(dataList.get(dataList.size()-1).get("create_time").toString()).toPlainString());
+                        //Long create_time_Last = Long.parseLong(new BigDecimal(dataList.get(dataList.size()-1).get("create_time").toString()).toPlainString());
+                        Long last_modified_time_sync = Long.parseLong(new BigDecimal(dataList.get(dataList.size()-1).get("last_modified_time").toString()).toPlainString());
                         for (int i = 0; i < dataList.size(); i++) {
                             Object _id = dataList.get(i).get("_id");
                             Object name = dataList.get(i).get("name");
@@ -118,7 +143,7 @@ public class YITCustomerTask {
                                 n++;
                             }
                         }
-                        baseDao.execute("insert into "+Master+"FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_syncTime) values("+Master+"FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'下载记录"+dataList.size()+"条，成功"+m+"条，失败"+n+"条，非易探客户"+k+"条','客户资料下载','"+create_time_Last+"')");
+                        baseDao.execute("insert into "+Master+"FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_syncTime) values("+Master+"FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'下载记录"+dataList.size()+"条，成功"+m+"条，失败"+n+"条，非易探客户"+k+"条','客户资料下载','"+last_modified_time_sync+"')");
                     }
                 }else{
                     baseDao.execute("insert into "+Master+"FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values("+Master+"FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+crmQueryResult.getErrorMessage()+"','客户资料下载','')");