|
@@ -5,6 +5,7 @@ import cn.hutool.core.util.CharsetUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import cn.hutool.core.util.XmlUtil;
|
|
import cn.hutool.core.util.XmlUtil;
|
|
|
import com.kym.common.utils.CommUtil;
|
|
import com.kym.common.utils.CommUtil;
|
|
|
|
|
+import com.kym.entity.FaultSubscriber;
|
|
|
import com.kym.entity.MpMsgTemplate;
|
|
import com.kym.entity.MpMsgTemplate;
|
|
|
import com.kym.service.FaultSubscriberService;
|
|
import com.kym.service.FaultSubscriberService;
|
|
|
import com.kym.service.MpMsgTemplateService;
|
|
import com.kym.service.MpMsgTemplateService;
|
|
@@ -213,6 +214,20 @@ public class WeixinMPServiceImpl implements WeixinMPService {
|
|
|
var result = faultSubscriberService.toggleSubscription(mpOpenid, stationId);
|
|
var result = faultSubscriberService.toggleSubscription(mpOpenid, stationId);
|
|
|
log.info("故障通知订阅操作: openid={}, stationId={}, result={}", mpOpenid, stationId, result);
|
|
log.info("故障通知订阅操作: openid={}, stationId={}, result={}", mpOpenid, stationId, result);
|
|
|
|
|
|
|
|
|
|
+ // 绑定成功时更新微信昵称
|
|
|
|
|
+ if ("绑定成功".equals(result)) {
|
|
|
|
|
+ try {
|
|
|
|
|
+ var mpUser = wxMpService.getUserService().userInfo(mpOpenid, "zh_CN");
|
|
|
|
|
+ faultSubscriberService.lambdaUpdate()
|
|
|
|
|
+ .set(FaultSubscriber::getNickname, mpUser.getNickname())
|
|
|
|
|
+ .eq(FaultSubscriber::getOpenid, mpOpenid)
|
|
|
|
|
+ .eq(FaultSubscriber::getStationId, stationId)
|
|
|
|
|
+ .update();
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ log.warn("获取微信昵称失败: mpOpenid={}", mpOpenid, e);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
var stationName = com.kym.service.cache.KymCache.INSTANCE.getStationNameById(stationId);
|
|
var stationName = com.kym.service.cache.KymCache.INSTANCE.getStationNameById(stationId);
|
|
|
var displayName = stationName != null ? stationName : stationId;
|
|
var displayName = stationName != null ? stationName : stationId;
|
|
|
|
|
|