wechat/wxhelper
5
0
Fork 0
mirror of https://github.com/ttttupup/wxhelper.git synced 2024-11-22 18:29:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #162 from sglmsn/sgssxln

Browse Source 
逻辑优化,注释更新
This commit is contained in:
ttttupup 2023-06-02 14:11:02 +08:00 committed by GitHub
commit 777faa5673
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
java_client/src/main/java/com/example/wxhk/msg/WxMsgHandle.java
View File

@ -148,6 +148,7 @@ public class WxMsgHandle {
String substring = monery.substring(1); String substring = monery.substring(1);
BigDecimal decimal = new BigDecimal(substring); BigDecimal decimal = new BigDecimal(substring);
log.info("扫码收款:{},付款人:{},付款备注:{}", decimal.stripTrailingZeros().toPlainString(), next.getValue(), remark); log.info("扫码收款:{},付款人:{},付款备注:{}", decimal.stripTrailingZeros().toPlainString(), next.getValue(), remark);
HttpSendUtil.发送文本(next.getValue(), StrUtil.format("扫码收款:{},备注:{}", decimal.stripTrailingZeros().toPlainString(), remark));
iterator.remove(); iterator.remove();
return false; return false;
} }
@ -182,6 +183,7 @@ public class WxMsgHandle {
String substring = monery.substring(1); String substring = monery.substring(1);
BigDecimal decimal = new BigDecimal(substring); BigDecimal decimal = new BigDecimal(substring);
log.info("收款:{},付款人:{},付款备注:{}", decimal.stripTrailingZeros().toPlainString(), receiver_username, remark); log.info("收款:{},付款人:{},付款备注:{}", decimal.stripTrailingZeros().toPlainString(), receiver_username, remark);
HttpSendUtil.发送文本(receiver_username, StrUtil.format("收到款项:{},备注:{}", decimal.stripTrailingZeros().toPlainString(), remark));
return false; return false;
} }
} }
@ -204,7 +206,11 @@ public class WxMsgHandle {
try { try {
String content = chatMsg.getContent(); String content = chatMsg.getContent();
Document document = XmlUtil.parseXml(content); Document document = XmlUtil.parseXml(content);
Node paysubtype = document.getElementsByTagName("paysubtype").item(0); NodeList paysubtype1 = document.getElementsByTagName("paysubtype");
if(paysubtype1.getLength()==0){
return true;
}
Node paysubtype = paysubtype1.item(0);
if ("1".equals(paysubtype.getTextContent().trim())) { if ("1".equals(paysubtype.getTextContent().trim())) {
// 手机发出去的 // 手机发出去的
String textContent = document.getElementsByTagName("receiver_username").item(0).getTextContent(); String textContent = document.getElementsByTagName("receiver_username").item(0).getTextContent();

9
java_client/src/main/java/com/example/wxhk/tcp/vertx/ArrHandle.java
View File

@ -22,6 +22,9 @@ import java.util.concurrent.TimeUnit;
@Component @Component
public class ArrHandle { public class ArrHandle {
/**
* 线程处理消息队列,但是必须保证核心数大于2,其中必定要有一个线程可以单独处理交易队列信息
*/
public static final ThreadPoolExecutor sub = new ThreadPoolExecutor(4, 10, 30, TimeUnit.MINUTES, new LinkedBlockingQueue<>(), new NamedThreadFactory("sub", false)); public static final ThreadPoolExecutor sub = new ThreadPoolExecutor(4, 10, 30, TimeUnit.MINUTES, new LinkedBlockingQueue<>(), new NamedThreadFactory("sub", false));
public static final ThreadLocal<PrivateChatMsg> chatMsgThreadLocal = new InheritableThreadLocal<>(); public static final ThreadLocal<PrivateChatMsg> chatMsgThreadLocal = new InheritableThreadLocal<>();
protected static final Log log = Log.get(); protected static final Log log = Log.get();
@ -51,9 +54,10 @@ public class ArrHandle {
continue; continue;
} }
WxMsgHandle.exec(privateChatMsg); WxMsgHandle.exec(privateChatMsg);
chatMsgThreadLocal.remove();
} catch (Exception e) { } catch (Exception e) {
log.error(e); log.error(e);
}finally {
chatMsgThreadLocal.remove();
} }
} }
log.error("退出线程了"); log.error("退出线程了");
@ -72,9 +76,10 @@ public class ArrHandle {
continue; continue;
} }
WxMsgHandle.exec(privateChatMsg); WxMsgHandle.exec(privateChatMsg);
chatMsgThreadLocal.remove();
} catch (Exception e) { } catch (Exception e) {
log.error(e); log.error(e);
}finally {
chatMsgThreadLocal.remove();
} }
} }
log.error("退出线程了"); log.error("退出线程了");