【易探】纷享销客 雷达特价申请 下载

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

@@ -0,0 +1,144 @@
+package com.uas.eis.task;
+
+import com.uas.eis.beans.result.CrmQueryResult;
+import com.uas.eis.dao.BaseDao;
+import com.uas.eis.dao.SqlRowList;
+import com.uas.eis.manager.CommonManager;
+import com.uas.eis.utils.Constant;
+import com.uas.eis.utils.DateUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@Component
+@EnableAsync
+@EnableScheduling
+public class YITRadarApplyTask {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    private BaseDao baseDao;
+    @Autowired
+    private CommonManager commonManager;
+
+    @Scheduled(cron = "0 0/5 * * * ?")
+    public void syncRadarSpecialofferApply() {
+        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()){
+                String ml_syncTime = rs.getGeneralString("ml_syncTime");
+                field_values.add(ml_syncTime);
+                CrmQueryResult crmQueryResult = commonManager.queryCommon("create_time", field_values, "GT", "create_time", true, 100, "object_XC82g__c", true);
+                int errorCode = crmQueryResult.getErrorCode();
+                if(errorCode == 0){
+                    Map<String, Object> data = crmQueryResult.getData();
+                    List<Map<String, Object>> dataList = (List<Map<String,Object>>) data.get("dataList");
+                    //m:成功条数 n:失败条数
+                    int m=0,n=0;
+                    if(dataList.size()>0){
+                        //最后(即最近)一次同步时间
+                        Long create_time_Last = Long.parseLong(new BigDecimal(dataList.get(dataList.size()-1).get("create_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");
+                            SimpleDateFormat sdf = new SimpleDateFormat(Constant.YMD_HMS);
+                            //CRM负责人名称字段：owner__r
+                            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+"RadarSpecialofferApply", "rsa_code='" + name + "'")){
+                                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++;
+                                continue;
+                            }
+                            try {
+                                Object cu_code = baseDao.getFieldDataByCondition(Master+"customer", "max(cu_code) cu_code", "cu_name='" + dataList.get(i).get("field_WycdH__c__r") + "'");
+                                String cuCode = cu_code == null ? "" : cu_code.toString();
+                                Object owner_code = baseDao.getFieldDataByCondition(Master+"employee", "max(em_code) em_code", "em_name='" + owner + "'");
+                                String ownerCode = owner_code == null ? "" : owner_code.toString();
+                                Long create_time = Long.parseLong(new BigDecimal(dataList.get(i).get("create_time").toString()).toPlainString());
+                                Long last_modified_time = Long.parseLong(new BigDecimal(dataList.get(i).get("last_modified_time").toString()).toPlainString());
+                                String record_type = getDisplayField(dataList, i, "record_type", "业务类型");
+                                String life_status = getDisplayField(dataList, i, "life_status", "生命状态");
+                                String field_aaPUk__c = getDisplayField(dataList, i, "field_aaPUk__c", "宋总审批结果");
+                                //创建人编号、名称
+                                Map<String,Object> created_by__r =(Map<String,Object>) dataList.get(i).get("created_by__r");
+                                //最后更新人编号、名称
+                                Map<String,Object> last_modified_by__r =(Map<String,Object>) dataList.get(i).get("last_modified_by__r");
+                                //data_own_department__r deptName
+                                Map<String,Object> data_own_department__r =(Map<String,Object>) dataList.get(i).get("data_own_department__r");
+                                String data_own_department = data_own_department__r==null ? "" : data_own_department__r.get("deptName").toString();
+
+                                String sql="insert into "+Master+"RadarSpecialofferApply(RSA_ID,RSA_CODE,RSA_OWNERCODE,RSA_OWNER,RSA_CUSTCODE,RSA_CUSTNAME,RSA_APPLYDESCRIBE," +
+                                        "RSA_CUSTMONTHUSAGE,RSA_RADARTYPE,RSA_ENDINGPRICE,RSA_EXPECTPRICE,RSA_SZAPPROVALRESULT,RSA_LOCKSTATUS,RSA_OWNERDEPARTMENT," +
+                                        "RSA_RECORDTYPE,RSA_LIFESTATUS,RSA_OUTOWNER,RSA_DATAOWNDEPARTMENT,RSA_RECORDMAN,RSA_RECORDDATE,RSA_LASTUPDATEMAN,RSA_LASTUPDATEDATE," +
+                                        "RSA_FXXKID)" +
+                                        "values("+Master+"RADARSPECIALOFFERAPPLY_seq.nextval,'"+name+"','"+ownerCode+"','"+owner+"','"+cuCode+"','"+getNotNull(dataList,i,"field_WycdH__c__r")+
+                                        "','"+getNotNull(dataList,i,"field_saYFn__c")+"','"+getNotNull(dataList,i,"field_8yKdc__c")+"','"+getNotNull(dataList,i,"field_372mv__c")+
+                                        "','"+getNotNull(dataList,i,"field_4t01W__c")+"','"+getNotNull(dataList,i,"field_BlP8a__c")+"','"+field_aaPUk__c+
+                                        "','"+getNotNull(dataList,i,"lock_status")+"','" +getNotNull(dataList,i,"owner_department")+"','"+record_type+"','"+life_status+"'," +
+                                        "'"+getNotNull(dataList,i,"out_owner")+"','"+data_own_department+"','"+created_by__r.get("name")+"',"+
+                                        DateUtil.parseDateToOracleString(Constant.YMD_HMS,sdf.parse(sdf.format(create_time)))+",'"+last_modified_by__r.get("name")+"',"+
+                                        DateUtil.parseDateToOracleString(Constant.YMD_HMS,sdf.parse(sdf.format(last_modified_time)))+",'"+_id+"')";
+                                baseDao.execute(sql);
+                                m++;
+                            }catch (Exception e){
+                                baseDao.execute("insert into "+Master+"FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values("+Master+"FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+crmQueryResult.getErrorMessage()+"','雷达申请下载','"+name+"')");
+                                logger.info("异常信息："+e);
+                                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+"条','雷达申请下载','"+create_time_Last+"')");
+                    }
+                }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()+"','雷达申请下载','')");
+                    logger.info("异常信息："+crmQueryResult.getErrorMessage());
+                }
+            }
+        }catch (Exception e){
+            baseDao.execute("insert into "+Master+"FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values("+Master+"FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+e.getMessage()+"','雷达申请下载','')");
+            logger.info("异常信息："+e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
+    private String getDisplayField(List<Map<String, Object>> dataList, int i, String Field, String APINAME){
+        String Master ="YIT.";
+        String ValueField ="";
+        Object account_type = dataList.get(i).get(Field);
+        if(account_type !=null && !"".equals(account_type.toString())){
+            Object DISPLAYFIELD = baseDao.getFieldDataByCondition(Master+"comboData", "DISPLAYFIELD", "VALUEFIELD='" + account_type + "' and APINAME='"+APINAME+"' and MODULEAPINAME='客户资料'");
+            ValueField= DISPLAYFIELD==null? "" :DISPLAYFIELD.toString();
+        }
+        return ValueField;
+    }
+
+    private String getValueField(String MODULEAPINAME, String APINAME, String DISPLAYFIELD){
+        String Master ="YIT.";
+        String result ="";
+        if(DISPLAYFIELD !=null && !"".equals(DISPLAYFIELD)){
+            Object VALUEFIELD = baseDao.getFieldDataByCondition(Master+"comboData", "VALUEFIELD", "MODULEAPINAME='" + MODULEAPINAME + "' and APINAME='"+APINAME+"' and DISPLAYFIELD='"+DISPLAYFIELD+"'");
+            result = VALUEFIELD==null? "" :VALUEFIELD.toString();
+        }
+        return result;
+    }
+
+    private String getNotNull(List<Map<String, Object>> dataList, int i, String Field){
+        return (dataList.get(i).get(Field)==null?"":dataList.get(i).get(Field)).toString();
+    }
+}