解决并发问题

master
lzy 3 years ago
parent 81c2922b03
commit ff2595dd7e

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

Loading…
Cancel
Save