【易探】【定制需求立项 下载功能 修改为不按照负责人条件对接，条件改为 宋总同意、类型为 微波定制立项，排序也由创建时间改为最后更新时间】

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

@@ -37,28 +37,39 @@ public class YITCustomNeedProjectTask {
     public void syncCustomNeedProject() {
         String Master ="YIT.";
         try {
-            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);
 
-                List<CrmQueryReq.Filters> filtersList = new ArrayList<>();
                 CrmQueryReq.Filters filters = new CrmQueryReq.Filters();
-                filters.setField_name("create_time");
+                filters.setField_name("last_modified_time");
                 filters.setField_values(field_values);
                 filters.setOperator("GT");
                 filtersList.add(filters);
 
-                CrmQueryReq.Filters filters2 = new CrmQueryReq.Filters();
                 List<String> field_values2 = new ArrayList<>();
                 field_values2.add("option1");
 
+                CrmQueryReq.Filters filters2 = new CrmQueryReq.Filters();
                 filters2.setField_name("field_6F2bW__c");
                 filters2.setField_values(field_values2);
                 filters2.setOperator("EQ");
                 filtersList.add(filters2);
-                CrmQueryResult crmQueryResult = commonManager.multiQueryCommon(filtersList, "create_time", true, 100, "object_eg97x__c", true);
+
+                List<String> field_values3 = new ArrayList<>();
+                field_values3.add("option1");
+
+                CrmQueryReq.Filters filters3 = new CrmQueryReq.Filters();
+                filters3.setField_name("field_a22Ex__c");
+                filters3.setField_values(field_values3);
+                filters3.setOperator("EQ");
+                filtersList.add(filters3);
+                CrmQueryResult crmQueryResult = commonManager.multiQueryCommon(filtersList, "last_modified_time", true, 100, "object_eg97x__c", true);
                 int errorCode = crmQueryResult.getErrorCode();
                 if(errorCode == 0){
                     Map<String, Object> data = crmQueryResult.getData();
@@ -67,7 +78,7 @@ public class YITCustomNeedProjectTask {
                     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 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");
@@ -76,12 +87,13 @@ public class YITCustomNeedProjectTask {
                             Map<String,Object> owner__r = (Map<String,Object>) dataList.get(i).get("owner__r");
                             //负责人姓名
                             String owner = owner__r==null ? "" : owner__r.get("name").toString();
-                            if(!baseDao.checkIf(Master+"employee","nvl(em_statuscode,' ')='AUDITED' and nvl(em_name,' ')= '"+owner+"'")){
+                            //不按照负责人条件对接
+                            /*if(!baseDao.checkIf(Master+"employee","nvl(em_statuscode,' ')='AUDITED' and nvl(em_name,' ')= '"+owner+"'")){
                                 k++;
                                 continue;
-                            }
+                            }*/
 
-                            if(baseDao.checkIf(Master+"CustomNeedProject", "cnp_name='" + name + "'")){
+                            if(baseDao.checkIf(Master+"CustomNeedProject", "cnp_fxxkId='" + _id + "'")){
                                 baseDao.execute("insert into "+Master+"FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values("+Master+"FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'定制需求立项已存在','定制需求立项下载','"+name+"')");
                                 logger.info("异常信息：定制需求立项已存在");
                                 n++;
@@ -164,7 +176,7 @@ public class YITCustomNeedProjectTask {
                                 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()+"','定制需求立项下载','')");