|
|
@@ -5,16 +5,24 @@ import cn.hutool.core.date.DateUtil;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.cyksj.common.EnvCommonService;
|
|
|
import com.cyksj.common.constant.TemplateEnum;
|
|
|
+import com.cyksj.common.exception.BusinessRuntimeException;
|
|
|
import com.cyksj.common.util.Jsons;
|
|
|
import com.cyksj.config.WeChatConfig;
|
|
|
+import com.cyksj.mapper.GoodsDonMapper;
|
|
|
+import com.cyksj.mapper.GoodsDonSkuMapper;
|
|
|
+import com.cyksj.mapper.OrderDonTransportMapper;
|
|
|
+import com.cyksj.mapper.UserMapper;
|
|
|
import com.cyksj.mapper.gzh.UserGzhRelationMapper;
|
|
|
import com.cyksj.model.dto.WxMpTemplateData;
|
|
|
import com.cyksj.model.dto.WxMpTemplateMessage;
|
|
|
import com.cyksj.model.entity.*;
|
|
|
+import com.cyksj.model.manage.request.ReqSetLogisticsPost;
|
|
|
+import com.cyksj.model.manage.views.GroupsRelationView;
|
|
|
import com.cyksj.model.views.WxAppTemplateView;
|
|
|
import com.cyksj.service.template.TemplateCommonService;
|
|
|
import com.cyksj.service.wechat.WeChatService;
|
|
|
import com.ejlchina.searcher.BeanSearcher;
|
|
|
+import com.ejlchina.searcher.param.Operator;
|
|
|
import com.ejlchina.searcher.util.MapBuilder;
|
|
|
import com.ejlchina.searcher.util.MapUtils;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
@@ -22,6 +30,7 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
+import java.util.List;
|
|
|
|
|
|
/*
|
|
|
*项目名: netflix
|
|
|
@@ -43,24 +52,34 @@ public class TemplateCommonServiceImpl implements TemplateCommonService {
|
|
|
|
|
|
private final WeChatConfig weChatConfig;
|
|
|
|
|
|
+ private final UserMapper userMapper;
|
|
|
+
|
|
|
+ private final GoodsDonMapper goodsDonMapper;
|
|
|
+
|
|
|
+ private final OrderDonTransportMapper transportMapper;
|
|
|
+
|
|
|
+ private final GoodsDonSkuMapper goodsDonSkuMapper;
|
|
|
+
|
|
|
public void newOderSendMsgByType(OrderDon order, GoodsDon goodsDon, GoodsDonSku sku, User user, String toPeople) throws Exception {
|
|
|
- Long userId = order.getUserId();
|
|
|
- WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.NEW_ORDER_TEMPLATE.getDesc());
|
|
|
- if (wxAppTemplateView != null) {
|
|
|
- WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
|
|
|
- .setToUser(toPeople)
|
|
|
- .setTemplateId(wxAppTemplateView.getTemplateId())
|
|
|
- //TODO
|
|
|
- .setUrl(" ");
|
|
|
- WxMpTemplateMessage.TemplateData data = templateMessage.getData();
|
|
|
- data.setFirst(new WxMpTemplateData("新订单通知！"));
|
|
|
- data.setKeyword1(new WxMpTemplateData(order.getOrderNo()));
|
|
|
- data.setKeyword2(new WxMpTemplateData(String.format("%s,%s", goodsDon.getTitle(), sku.getSpecVal())));
|
|
|
- data.setKeyword3(new WxMpTemplateData(user == null ? "推广未登录用户" : user.getNickname()));
|
|
|
- data.setKeyword4(new WxMpTemplateData(order.getMoney().divide(BigDecimal.valueOf(100)).toString()));
|
|
|
- data.setKeyword5(new WxMpTemplateData(DateUtil.format(order.getCreatedTime(), "yyyy-MM-dd HH:mm:ss")));
|
|
|
- data.setRemark(new WxMpTemplateData("点击查看详情"));
|
|
|
- weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
|
|
|
+ if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
|
|
|
+ Long userId = order.getUserId();
|
|
|
+ WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.NEW_ORDER_TEMPLATE.getDesc());
|
|
|
+ if (wxAppTemplateView != null) {
|
|
|
+ WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
|
|
|
+ .setToUser(toPeople)
|
|
|
+ .setTemplateId(wxAppTemplateView.getTemplateId())
|
|
|
+ //TODO
|
|
|
+ .setUrl(" ");
|
|
|
+ WxMpTemplateMessage.TemplateData data = templateMessage.getData();
|
|
|
+ data.setFirst(new WxMpTemplateData("新订单通知！"));
|
|
|
+ data.setKeyword1(new WxMpTemplateData(order.getOrderNo()));
|
|
|
+ data.setKeyword2(new WxMpTemplateData(String.format("%s,%s", goodsDon.getTitle(), sku.getSpecVal())));
|
|
|
+ data.setKeyword3(new WxMpTemplateData(user == null ? "推广未登录用户" : user.getNickname()));
|
|
|
+ data.setKeyword4(new WxMpTemplateData(order.getMoney().divide(BigDecimal.valueOf(100)).toString()));
|
|
|
+ data.setKeyword5(new WxMpTemplateData(DateUtil.format(order.getCreatedTime(), "yyyy-MM-dd HH:mm:ss")));
|
|
|
+ data.setRemark(new WxMpTemplateData("点击查看详情"));
|
|
|
+ weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -87,8 +106,8 @@ public class TemplateCommonServiceImpl implements TemplateCommonService {
|
|
|
|
|
|
@Override
|
|
|
public void sendWxGzhQrCodeSuccessMsg(User user) throws Exception {
|
|
|
- Long userId = user.getId();
|
|
|
- if (EnvCommonService.active.equals(envCommonService.getEnv())) {
|
|
|
+ if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
|
|
|
+ Long userId = user.getId();
|
|
|
WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.WX_GZH_QR_CODE_LOGIN.getDesc());
|
|
|
String url = String.format("%sauth/weChat?url=%s", envCommonService.getHost(), envCommonService.getDomain() + "yinhe/web/");
|
|
|
WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
|
|
|
@@ -103,4 +122,97 @@ public class TemplateCommonServiceImpl implements TemplateCommonService {
|
|
|
weChatService.sendTemplateMessage(weChatService.getAccessToken(), Jsons.toJson(templateMessage));
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void sendTransportMsgNotify(OrderDon orderDon, ReqSetLogisticsPost reqSetLogisticsPost) throws Exception {
|
|
|
+ if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
|
|
|
+ Long userId = orderDon.getUserId();
|
|
|
+ WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.ORDER_TRANSPORT_TEMPLATE.getDesc());
|
|
|
+ if (wxAppTemplateView != null) {
|
|
|
+ String openId = orderDon.getOpenId();
|
|
|
+ if (openId == null) {
|
|
|
+ User u = userMapper.selectById(orderDon.getUserId());
|
|
|
+ if (u == null) {
|
|
|
+ throw BusinessRuntimeException.getInstance("用户不存在");
|
|
|
+ }
|
|
|
+ openId = u.getOpenId();
|
|
|
+ }
|
|
|
+ WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
|
|
|
+ .setToUser(openId)
|
|
|
+ .setTemplateId(wxAppTemplateView.getTemplateId())
|
|
|
+ //TODO
|
|
|
+ .setUrl(" ");
|
|
|
+ GoodsDon goodsDon = goodsDonMapper.selectById(orderDon.getGoodsId());
|
|
|
+ OrderDonTransport transport = transportMapper.selectOne(Wrappers.lambdaQuery(OrderDonTransport.class).eq(OrderDonTransport::getOrderId, reqSetLogisticsPost.getOrderId()).last("limit 1"));
|
|
|
+ WxMpTemplateMessage.TemplateData data = templateMessage.getData();
|
|
|
+ data.setFirst(new WxMpTemplateData("订单发货通知"));
|
|
|
+ data.setKeyword1(new WxMpTemplateData(orderDon.getOrderNo()));
|
|
|
+ data.setKeyword2(new WxMpTemplateData(goodsDon.getTitle()));
|
|
|
+ data.setKeyword3(new WxMpTemplateData(reqSetLogisticsPost.getCodeCn()));
|
|
|
+ data.setKeyword4(new WxMpTemplateData(reqSetLogisticsPost.getTrackingNumber()));
|
|
|
+ data.setKeyword5(new WxMpTemplateData(String.format("%s%s%s%s", transport.getProvince(), transport.getCity(), transport.getDistrict(), transport.getAddress())));
|
|
|
+ data.setRemark(new WxMpTemplateData("可复制运单编号查询物流信息"));
|
|
|
+ weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void emptySendMsgNotify(OrderDon orderDon, String toPeople) throws Exception {
|
|
|
+ if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
|
|
|
+ Long userId = orderDon.getUserId();
|
|
|
+ WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.EMPTY_TEMPLATE.getDesc());
|
|
|
+ if (wxAppTemplateView != null) {
|
|
|
+ User u = userMapper.selectById(orderDon.getUserId());
|
|
|
+ WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
|
|
|
+ .setToUser(toPeople)
|
|
|
+ .setTemplateId(wxAppTemplateView.getTemplateId())
|
|
|
+ //TODO
|
|
|
+ .setUrl(" ");
|
|
|
+ GoodsDon goodsDon = goodsDonMapper.selectById(orderDon.getGoodsId());
|
|
|
+ GoodsDonSku goodsDonSku = goodsDonSkuMapper.selectById(orderDon.getSkuId());
|
|
|
+ WxMpTemplateMessage.TemplateData data = templateMessage.getData();
|
|
|
+ data.setFirst(new WxMpTemplateData("空车位通知！"));
|
|
|
+ data.setKeyword1(new WxMpTemplateData(orderDon.getOrderNo()));
|
|
|
+ data.setKeyword2(new WxMpTemplateData(String.format("%s,%s", goodsDon.getTitle(), goodsDonSku.getSpecVal())));
|
|
|
+ data.setKeyword3(new WxMpTemplateData((u == null ? " " : u.getNickname())));
|
|
|
+ data.setKeyword4(new WxMpTemplateData(orderDon.getMoney().divide(BigDecimal.valueOf(100)).toString()));
|
|
|
+ data.setKeyword5(new WxMpTemplateData(DateUtil.format(orderDon.getCreatedTime(), "yyyy-MM-dd HH:mm:ss")));
|
|
|
+ data.setRemark(new WxMpTemplateData("请尽快关联账号信息"));
|
|
|
+ weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void sendAccountTemplateMsg(Account account) throws Exception {
|
|
|
+ if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
|
|
|
+ List<GroupsRelationView> relations = beanSearcher.searchList(GroupsRelationView.class, MapUtils.builder()
|
|
|
+ .field(GroupsRelationView::getAccountId, account.getId()).op(Operator.Equal)
|
|
|
+ .field(GroupsRelationView::getStatus, "validity").op(Operator.Equal)
|
|
|
+ .build());
|
|
|
+ String url = String.format("%sauth/weChat?url=%syinhe/web/ticket", envCommonService.getHost(), envCommonService.getDomain());
|
|
|
+ log.info("开始发送账号修改密码模板消息,大小:{}", relations.size());
|
|
|
+ for (GroupsRelationView relation : relations) {
|
|
|
+ Long userId = relation.getUserId();
|
|
|
+ WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.PLAT_ACCOUNT_UPDATE_TEMPLATE.getDesc());
|
|
|
+ if (wxAppTemplateView != null) {
|
|
|
+ User user = userMapper.selectById(relation.getUserId());
|
|
|
+ if (user != null) {
|
|
|
+ WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
|
|
|
+ .setToUser(user.getOpenId())
|
|
|
+ .setTemplateId(wxAppTemplateView.getTemplateId())
|
|
|
+ .setUrl(url);
|
|
|
+ WxMpTemplateMessage.TemplateData data = templateMessage.getData();
|
|
|
+ data.setFirst(new WxMpTemplateData(String.format("%s账号密码更改提醒", relation.getTitle())));
|
|
|
+ data.setKeyword1(new WxMpTemplateData(relation.getTripsAccount()));
|
|
|
+ data.setKeyword2(new WxMpTemplateData(DateTime.now().toString("YYYY-MM-mm HH:mm:ss")));
|
|
|
+ data.setRemark(new WxMpTemplateData("您的账号密码已经更新，请到我的车票查看，长期用户请选择拼车/年付。\n" +
|
|
|
+ "如您不是在公众号购买，请在浏览器登录查看我的车票"));
|
|
|
+ weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
zoujiajian