diff --git a/src/main/java/com/docus/bgts/handler/TBasicWebService.java b/src/main/java/com/docus/bgts/handler/TBasicWebService.java index 5fe79a8..0a098cd 100644 --- a/src/main/java/com/docus/bgts/handler/TBasicWebService.java +++ b/src/main/java/com/docus/bgts/handler/TBasicWebService.java @@ -25,6 +25,8 @@ import java.io.ByteArrayInputStream; import java.io.StringReader; import java.io.UnsupportedEncodingException; import java.util.*; +import java.util.concurrent.locks.Lock; +import java.util.concurrent.locks.ReentrantLock; @WebService public class TBasicWebService implements ITBasicWebService { @@ -35,6 +37,7 @@ public class TBasicWebService implements ITBasicWebService { @Autowired IMrReportErrorService mrReportErrorService; + private Object lock = new Object(); private final Logger logger = LoggerFactory.getLogger(getClass()); @@ -147,7 +150,9 @@ public class TBasicWebService implements ITBasicWebService { reportDownDto.setScanfiles(reportDownDtoArr); } //插入文件af_collect_task表数据 - afCollectTaskService.insert(reportDownDto); + synchronized (lock) { + afCollectTaskService.insert(reportDownDto); + } String post = ""; logger.info("--------执行上传功能----------"); Map params = JSON.parseObject(JSON.toJSONString(reportDownDto), Map.class); @@ -191,8 +196,8 @@ public class TBasicWebService implements ITBasicWebService { try { XmlUtils xmlUtils = new XmlUtils(new ByteArrayInputStream(downurl.getBytes("UTF-8"))); if (null != xmlUtils) { - url=downurl; - List urlReplaces=(List) FileUtils.getJsonByName("urlReplace"); + url = downurl; + List urlReplaces = (List) FileUtils.getJsonByName("urlReplace"); for (String urlReplace : urlReplaces) { url = url.replaceAll(urlReplace, ""); }