Commit d2d48682 by caojingji

修改插入轨迹时使用多线程方法中的bug

parent 81790045
...@@ -561,7 +561,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService { ...@@ -561,7 +561,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService {
idRelation.setSfzh(sfzh); idRelation.setSfzh(sfzh);
idRelation.setJh(jh); idRelation.setJh(jh);
idRelation.setIdcard(idcard); idRelation.setIdcard(idcard);
if (null != cphms || cphms.size() !=0){ if (null != cphms && cphms.size() !=0){
//多线程处理 chent //多线程处理 chent
int limit = 120;//批处理量 int limit = 120;//批处理量
int size = cphms.size(); int size = cphms.size();
...@@ -571,7 +571,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService { ...@@ -571,7 +571,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService {
thread.start(); thread.start();
} }
} }
if(null != sjhms || sjhms.size() !=0){ if(null != sjhms && sjhms.size() !=0){
//多线程处理 chent //多线程处理 chent
int limit = 120;//批处理量 int limit = 120;//批处理量
int size = cphms.size(); int size = cphms.size();
...@@ -613,7 +613,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService { ...@@ -613,7 +613,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService {
phoneRelation.setPhone(phone); phoneRelation.setPhone(phone);
//begin //begin
if (null != qqhms || qqhms.size() !=0) { if (null != qqhms && qqhms.size() !=0) {
ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池 ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池
for (Map<String, Object> qqhm : qqhms) { for (Map<String, Object> qqhm : qqhms) {
//System.out.println(list.get(i)); //System.out.println(list.get(i));
...@@ -645,7 +645,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService { ...@@ -645,7 +645,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService {
//end //end
//begin //begin
if (null != wxhms || wxhms.size() !=0){ if (null != wxhms && wxhms.size() !=0){
ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池 ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池
for (Map<String,Object> wxhm:wxhms){ for (Map<String,Object> wxhm:wxhms){
String wechat = wxhm.get("objValue").toString(); String wechat = wxhm.get("objValue").toString();
...@@ -667,7 +667,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService { ...@@ -667,7 +667,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService {
//end //end
//begin //begin
if (null != imeis || imeis.size() !=0){ if (null != imeis && imeis.size() !=0){
ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池 ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池
for (Map<String,Object> imeihm:imeis){ for (Map<String,Object> imeihm:imeis){
String imei = imeihm.get("objValue").toString(); String imei = imeihm.get("objValue").toString();
...@@ -689,7 +689,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService { ...@@ -689,7 +689,7 @@ public class IphoneTrackServiceImpl implements IphoneTrackService {
//end //end
//begin //begin
if (null != imsis || imsis.size() !=0){ if (null != imsis && imsis.size() !=0){
ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池 ExecutorService pool = Executors.newCachedThreadPool();//newCachedThreadPool可缓存线程池
for (Map<String,Object> imsihm:imsis){ for (Map<String,Object> imsihm:imsis){
String imsi = imsihm.get("objValue").toString(); String imsi = imsihm.get("objValue").toString();
......
\u624B\u673A\u53F7\u7801=001 \u624B\u673A\u53F7\u7801=001
\u624B\u673A\u53F7\u7801=001 \u624B\u673A\u53F7\u7801=001
QQ\u53F7\u7801=002 QQ\u53F7\u7801=002
\u5FAE\u4FE1ID=003 \u5FAE\u4FE1ID=003
\u5FAE\u4FE1\u53F7\u7801=009
\u8EAB\u4EFD\u8BC1\u53F7=004 \u8EAB\u4EFD\u8BC1\u53F7=004
\u8F66\u724C\u53F7=005 \u8F66\u724C\u53F7=005
IMSI=006 IMSI=006
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment