yhlxj/netflix-service/src/main/java/com/cyksj/service/template/impl/TemplateCommonServiceImpl.java

package com.cyksj.service.template.impl;

import cn.hutool.core.date.DateTime;
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;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.List;
import java.util.Optional;

/*
 *项目名: netflix
 *文件名: TemplateCommonServiceImpl
 *创建者: JavaZou
 *创建时间:2023/1/11 9:59
 */
@Service
@RequiredArgsConstructor
@Slf4j
public class TemplateCommonServiceImpl implements TemplateCommonService {
	private final EnvCommonService envCommonService;

	private final WeChatService weChatService;

	private final BeanSearcher beanSearcher;

	private final UserGzhRelationMapper userGzhRelationMapper;

	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, Boolean isCustomer) throws Exception {
		if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
			Long userId = order.getUserId();
			String openId = toPeople;
			WxAppTemplateView wxAppTemplateView = null;
			if (isCustomer) {
				wxAppTemplateView = this.getCustomerTemplateView(TemplateEnum.NEW_ORDER_TEMPLATE.getDesc());
			} else {
				wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.NEW_ORDER_TEMPLATE.getDesc());
			}
			if (wxAppTemplateView != null) {
				WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
						.setToUser(Optional.ofNullable(wxAppTemplateView.getOpenId()).orElse(openId))
						.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服务", goodsDon.getTitle())));
				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(goodsDon.getType() == 1 && goodsDon.getSecondType() == 1 ? "需要联系客服邀请才可使用，请联系客服" : "点击查看详情"));
				weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
			}
		}
	}

	@Override
	public WxAppTemplateView getWxAppByUserId(Long userId, String templateMark) {
		UserGzhRelation userGzhRelation = null;
		if (!TemplateEnum.WX_GZH_QR_CODE_LOGIN.getDesc().equals(templateMark)) {
			userGzhRelation = userGzhRelationMapper.selectOne(Wrappers.lambdaQuery(UserGzhRelation.class)
					.eq(UserGzhRelation::getUserId, userId).orderByAsc(UserGzhRelation::getWxAppId).last("limit 1"));
		}
		MapBuilder builder = MapUtils.builder()
				.field(WxAppTemplateView::getRemark, templateMark);
		if (userGzhRelation == null) {
			builder.field(WxAppTemplateView::getAppId, weChatConfig.getAppid());
		}else {
			builder.field(WxAppTemplateView::getWxAppId, userGzhRelation.getWxAppId());
		}
		String type;
		if (EnvCommonService.active.equals(envCommonService.getEnv())) {
			type = EnvCommonService.active;
		} else {
			type = EnvCommonService.active_prd;
		}
		builder.field(WxAppTemplateView::getType, type);
		WxAppTemplateView wxAppTemplateView = beanSearcher.searchFirst(WxAppTemplateView.class, builder.build());
		if (userGzhRelation != null) {
			final String openId = userGzhRelation.getOpenId();
			Optional.ofNullable(wxAppTemplateView).ifPresent((templateView) -> templateView.setOpenId(openId));
		}
		return wxAppTemplateView;
	}

	public WxAppTemplateView getCustomerTemplateView(String templateMark) {
		WxAppTemplateView wxAppTemplateView = beanSearcher.searchFirst(WxAppTemplateView.class, MapUtils.builder()
				.field(WxAppTemplateView::getRemark, templateMark)
				.field(WxAppTemplateView::getAppId, weChatConfig.getAppid())
				.field(WxAppTemplateView::getType, EnvCommonService.active_prd).build());
		return wxAppTemplateView;
	}

	@Override
	public void sendWxGzhQrCodeSuccessMsg(User user) throws Exception {
		if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
			Long userId = user.getId();
			String openId = user.getOpenId();
			WxAppTemplateView wxAppTemplateView = this.getWxAppByUserId(userId, TemplateEnum.WX_GZH_QR_CODE_LOGIN.getDesc());
			if (wxAppTemplateView != null) {
				String url = String.format("%sauth/weChat?url=%s", envCommonService.getHost(), envCommonService.getDomain() + "yinhe/web/");
				WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
						.setToUser(Optional.ofNullable(wxAppTemplateView.getOpenId()).orElse(openId))
						.setTemplateId(wxAppTemplateView.getTemplateId())
						.setUrl(url);
				WxMpTemplateMessage.TemplateData data = templateMessage.getData();
				data.setFirst(new WxMpTemplateData("您已登录成功"));
				data.setKeyword1(new WxMpTemplateData("银河录像局"));
				data.setKeyword2(new WxMpTemplateData(DateUtil.format(DateTime.now(), "yyyy-MM-dd HH:mm:ss")));
				data.setRemark(new WxMpTemplateData("欢迎使用银河录像局"));
				weChatService.sendTemplateMessage(weChatService.getAccessToken(), Jsons.toJson(templateMessage));
			}
		}
	}

	@Override
	public void sendTransportMsgNotify(OrderDon orderDon, ReqSetLogisticsPost reqSetLogisticsPost, Boolean isReceiveAll) 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();
				}
				String url = String.format("%s%s", envCommonService.getDomain(), "order");
				WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
						.setToUser(Optional.ofNullable(wxAppTemplateView.getOpenId()).orElse(openId))
						.setTemplateId(wxAppTemplateView.getTemplateId())
						.setUrl(url);
				String msg = isReceiveAll ? "家庭套餐特权已生效，可在我的车票中查看" : "存在待领取权益，点击查看详情";
				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(String.format("可复制运单编号查询物流信息\n%s", msg)));
				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())) {
			String openId = toPeople;
			WxAppTemplateView wxAppTemplateView = this.getCustomerTemplateView(TemplateEnum.EMPTY_TEMPLATE.getDesc());
			if (wxAppTemplateView != null) {
				User u = userMapper.selectById(orderDon.getUserId());
				WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
						.setToUser(openId)
						.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());
			log.info("开始发送账号修改密码模板消息,大小:{}", relations.size());
			for (GroupsRelationView relation : relations) {
				sendUpdateAccountMsg(relation);
			}
		}
	}

	@Override
	public void sendUpdateAccountMsgNotify(GroupsRelationView relation) throws Exception {
		if (!EnvCommonService.active.equals(envCommonService.getEnv())) {
			sendUpdateAccountMsg(relation);
		}
	}

	public void sendUpdateAccountMsg(GroupsRelationView relation) throws Exception {
		String url = String.format("%sauth/weChat?url=%syinhe/web/ticket", envCommonService.getHost(), envCommonService.getDomain());
		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) {
				String openId = user.getOpenId();
				WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
						.setToUser(Optional.ofNullable(wxAppTemplateView.getOpenId()).orElse(openId))
						.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));
			}
		}
	}
}