Browse Source

商机下载轮询程序修改。

will.chen 7 years ago
parent
commit
ea13151d42

+ 24 - 9
src/main/java/com/uas/erp/schedular/publicinquiry/task/EnterInquiryTask.java

@@ -40,16 +40,16 @@ public class EnterInquiryTask {
             }
             String res = sendGet(url, params);
             //是否存在商机库
-            Map<String, Object> map = jdbcTemplate.queryForMap("SELECT COUNT(*) COUNT,BD_NAME FROM BUSINESSDATABASE WHERE (BD_NAME like '%公共%' or bd_name like '%公有%') AND BD_PROP='可领取可分配' AND ROWNUM=1 GROUP BY BD_NAME");
+            Map<String, Object> map = jdbcTemplate.queryForMap("SELECT COUNT(*) COUNT,BD_NAME FROM BUSINESSDATABASE WHERE BD_NAME ='平台商机库' AND BD_PROP='管理员分配' AND ROWNUM=1 GROUP BY BD_NAME");
             if(map == null){
                 Map<String, Object> adminMap = jdbcTemplate.queryForMap("SELECT EM_CODE,EN_ADMINNAME FROM ENTERPRISE LEFT JOIN EMPLOYEE ON EN_ADMINUU=EM_UU");
-                jdbcTemplate.execute("INSERT INTO BUSINESSDATABASE(bd_id,bd_name,bd_prop,bd_admin,bd_admincode,bd_overtime) VALUES(BUSINESSDATABASE_SEQ.NEXTVAL,'公共商机库','可领取可分配','"+adminMap.get("EN_ADMINNAME")+"','"+adminMap.get("EM_CODE")+"',30)");
+                jdbcTemplate.execute("INSERT INTO BUSINESSDATABASE(bd_id,bd_name,bd_prop,bd_admin,bd_admincode,bd_overtime) VALUES(BUSINESSDATABASE_SEQ.NEXTVAL,'平台商机库','管理员分配','"+adminMap.get("EN_ADMINNAME")+"','"+adminMap.get("EM_CODE")+"',30)");
                 map = new HashMap<String, Object>();
-                map.put("BD_NAME","公共商机库");
+                map.put("BD_NAME","平台商机库");
             }else if(map != null && "0".equals(map.get("COUNT"))){
                 Map<String, Object> adminMap = jdbcTemplate.queryForMap("SELECT EM_CODE,EN_ADMINNAME FROM ENTERPRISE LEFT JOIN EMPLOYEE ON EN_ADMINUU=EM_UU");
-                jdbcTemplate.execute("INSERT INTO BUSINESSDATABASE(bd_id,bd_name,bd_prop,bd_admin,bd_admincode,bd_overtime) VALUES(BUSINESSDATABASE_SEQ.NEXTVAL,'公共商机库','可领取可分配','"+adminMap.get("EN_ADMINNAME")+"','"+adminMap.get("EM_CODE")+"',30)");
-                map.put("BD_NAME","公共商机库");
+                jdbcTemplate.execute("INSERT INTO BUSINESSDATABASE(bd_id,bd_name,bd_prop,bd_admin,bd_admincode,bd_overtime) VALUES(BUSINESSDATABASE_SEQ.NEXTVAL,'平台商机库','管理员分配','"+adminMap.get("EN_ADMINNAME")+"','"+adminMap.get("EM_CODE")+"',30)");
+                map.put("BD_NAME","平台商机库");
             }
             String sql = "select count(bs_name) count,bs_name from businesschancestage where bs_detno=1 group by bs_name";
             Map<String, Object> bsNameMap= jdbcTemplate.queryForMap(sql);
@@ -73,7 +73,13 @@ public class EnterInquiryTask {
                     try {
                         executeDownload(jsonArray, String.valueOf(bsNameMap.get("BS_NAME")), String.valueOf(map.get("BD_NAME")));
                     }catch (Exception e){
-                        continue;
+                        for(int j = 0; j < jsonArray.size(); j++){
+                            try{
+                                executeDownload(jsonArray.getJSONArray(j), String.valueOf(bsNameMap.get("BS_NAME")), String.valueOf(map.get("BD_NAME")));
+                            }catch (Exception e1){
+                                continue;
+                            }
+                        }
                     }
                 }
             }else{
@@ -94,27 +100,36 @@ public class EnterInquiryTask {
             sb.append("if v_count = 0 then ");
             String code = jdbcTemplate.generateCode("businesschance",2);
             String needQty ="";
+            String inbrand = "";
+            inbrand = json.getString("inbrand");
             needQty = json.getString("needQty");
             if(needQty == null || "null".equals(needQty)){
                 needQty = "";
             }
+            if(inbrand == null || "null".equals(inbrand)){
+                inbrand = "";
+            }
+            //商机名称
             String description = json.getString("prodTitle")+" "+ json.getString("cmpCode")+" ";
             if(json.getString("spec") != null && !"null".equals(json.getString("spec")) && !"".equals(json.getString("spec"))){
                 description += json.getString("spec") +" ";
             }
-            description += json.getString("inbrand");
+            description += inbrand;
             if(needQty != null && !"null".equals(needQty) && !"".equals(needQty)){
                 description += ",需求:"+needQty;
             }
+            //客户编号、客户uu
+            String cuUU = json.getString("enUU");
+            String custCode = jdbcTemplate.getString("select cu_code from customer where cu_uu=?", cuUU);
             Calendar c = Calendar.getInstance();
             c.setTime(new Date(json.getLong("date")));
             c.add(Calendar.MONTH, 2);
             String date = "to_date('" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(c.getTime())+"','YYYY-MM-DD HH24:MI:SS')";
             String endDate = "to_date('"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(json.getLong("endDate")))+"','YYYY-MM-DD HH24:MI:SS')";
             sb.append("insert into businesschance(bc_id,bc_fromid,bc_code,bc_description,bc_from,bc_nichehouse,bc_currentprocess,bc_date7,bc_status,bc_statuscode,bc_recorder,bc_recorddate,"
-                    + "bc_custname,bc_contact,bc_tel,bc_desc7,bc_desc9,bc_desc10,bc_desc11,bc_desc13,bc_date13) values(businesschance_seq.nextval,"+json.getInteger("id")+",'"+code+"','"+description.replaceAll("'","''").replaceAll("&","'||'&'||'")+"','平台商机','"+bdName+"','"+bsName+"',"+date+","
+                    + "bc_custname,bc_contact,bc_tel,bc_desc7,bc_desc9,bc_desc10,bc_desc11,bc_desc13,bc_date13,bc_desc14,bc_custcode) values(businesschance_seq.nextval,"+json.getInteger("id")+",'"+code+"','"+description.replaceAll("'","''").replaceAll("&","'||'&'||'")+"','平台商机','"+bdName+"','"+bsName+"',"+date+","
                     + "'已审核','AUDITED','自动转入',sysdate,'"+json.getString("enName")+"','"+json.getString("userName")+"','"+json.getString("userTel")+"','"+json.getString("prodTitle").replaceAll("'","''").replaceAll("&","'||'&'||'")+"','"+json.getString("spec")+"',"
-                    + "'"+json.getString("cmpCode").replaceAll("&","'||'&'||'")+"','"+json.getString("inbrand")+"','"+needQty+"',"+endDate+");");
+                    + "'"+json.getString("cmpCode").replaceAll("&","'||'&'||'")+"','"+json.getString("inbrand")+"','"+needQty+"',"+endDate+",'"+cuUU+"','"+custCode+"');");
             sb.append(" end if;");
         }
         sb.append(" end;");