Commit e9c3e34a by admin

修改提交,测试

parent 2f4a588c
......@@ -7,11 +7,15 @@ import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.stereotype.Component;
@Component
public class ServerClient extends Thread {
private final static Log log = LogFactory.getLog(ServerClient.class);
public ServerClient() {
this.start();
}
......@@ -34,13 +38,12 @@ public class ServerClient extends Thread {
// BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
// System.out.println("Client:" + in.readLine());
line = in.readLine();
System.out.println(line);
// line = br.readLine();
if (line != null && line.equals("result")) {
writer.println("result:end");
writer.flush();
WechatReadAndWrite.needsend = true;
System.out.println("收到result");
log.info("收到result:" + WechatReadAndWrite.needsend);
} else if (line != null) {
writer.println("无效" + line);
writer.flush();
......
......@@ -138,6 +138,7 @@ public class WechatReadAndWrite {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
while (true) {
if (RwController.weChatList.size() > 0) {
needsend = false;
try {
e = RwController.weChatList.get(0);
if (e != null) {
......@@ -146,9 +147,9 @@ public class WechatReadAndWrite {
List<ReadWechat> list = ReadExcel.getExcel(e.getUrl());
log.info("数据入库");
m.insertReadWechat(list);// 存储
needsend = false;
while (true) {
Thread.sleep(1000 * 30);
log.info("执行中。。。。" + needsend);
if (needsend) {
break;
}
......
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