package com.hx.phip.service.market.impl;
|
|
import com.hx.common.service.CommonService;
|
import com.hx.exception.TipsException;
|
import com.hx.guide.util.CommonQueryUtil;
|
import com.hx.guide.util.mp.WeiXinCorpMpUtil;
|
import com.hx.mybatisTool.SqlSentence;
|
import com.hx.phiappt.common.OperatorConstants;
|
import com.hx.phiappt.constants.tool.CouponTool;
|
import com.hx.phiappt.constants.tool.SendMessageTool;
|
import com.hx.phiappt.constants.tool.employee.EmployeeTool;
|
import com.hx.phiappt.constants.tool.model.MessageTemplate;
|
import com.hx.phiappt.constants.tool.shop.ShopTool;
|
import com.hx.phiappt.dao.mapper.*;
|
import com.hx.phiappt.model.BaseEntity;
|
import com.hx.phiappt.model.Employee;
|
import com.hx.phiappt.model.Shop;
|
import com.hx.phiappt.model.User;
|
import com.hx.phiappt.model.coupon.Coupon;
|
import com.hx.phiappt.model.coupon.CouponReleaseRecordItem;
|
import com.hx.phiappt.model.market.*;
|
import com.hx.phip.config.GlobalExceptionHandler;
|
import com.hx.phip.config.ProcessBean;
|
import com.hx.phip.service.market.MarketActivityService;
|
import com.hx.resultTool.Result;
|
import com.hx.util.DateUtil;
|
import com.hz.his.dto.marketing.common.*;
|
import com.hz.his.feign.service.marketing.MCommonService;
|
import lombok.extern.slf4j.Slf4j;
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import com.hx.phip.config.CustomParameter;
|
import javax.annotation.Resource;
|
import java.util.*;
|
|
|
@Slf4j
|
@Transactional
|
@Service
|
public class MarketActivityServiceImpl implements MarketActivityService {
|
|
@Resource
|
private CommonService commonService;
|
@Resource
|
private MCommonService mCommonService;
|
@Resource
|
private ProcessBean processBean;
|
@Resource
|
private CustomParameter customParameter;
|
|
/** 领取优惠券 */
|
@Override
|
public void receiveCoupon(MarketActivity marketActivity, List<MarketActivityItem> list, User user
|
, MarketActivityJoinRecord joinRecord, MarketActivityReceiveRecord receiveRecord) {
|
|
//优惠券操作人类型，默认员工
|
int couponOpType = OperatorConstants.changeCouponOpType(receiveRecord.getOpType());
|
|
//拼接用户数据
|
JSONArray userArr = new JSONArray();
|
JSONObject json = new JSONObject();
|
json.put("id", user.getId());
|
json.put("amount", 1);
|
userArr.add(json);
|
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
//领取记录子项list
|
MarketActivityReceiveRecordItem recordItem = null;
|
List<MarketActivityReceiveRecordItem> recordItemList = new ArrayList<>();
|
|
//遍历领取
|
String couponName = "";
|
Integer isApprove = BaseEntity.NO;
|
for(MarketActivityItem activityCoupon : list)
|
{
|
//新增
|
recordItem = new MarketActivityReceiveRecordItem(activityCoupon);
|
recordItemList.add(recordItem);
|
//获取优惠券名称
|
couponName = activityCoupon.getCommonName();
|
//判断是否需要审批，如果需要审批先跳过不发放优惠券
|
if(activityCoupon.getIsApprove() == BaseEntity.YES){
|
isApprove = activityCoupon.getIsApprove();
|
continue;
|
}
|
|
//发放优惠券
|
try{
|
sendCoupon(couponOpType, userArr, receiveRecord, recordItem);
|
}catch (Exception e){
|
log.error("参数：{}", JSONObject.fromObject(activityCoupon));
|
log.error("遍历发放优惠券失败：{}", GlobalExceptionHandler.getExceptionInformation(e));
|
//统一提示
|
throw new TipsException("活动爆满【"+activityCoupon.getCommonName()+"】已领取完，请联系活动负责人"+marketActivity.getManagerName()+"咨询情况");
|
}
|
|
}
|
|
//处理参与记录--------------------------------------------------------------------------------
|
if(StringUtils.isEmpty(joinRecord.getId())){
|
if(commonService.insert(MarketActivityJoinRecordMapper.class, joinRecord) != 1){
|
throw new TipsException("新增活动参与记录失败！");
|
}
|
}else{
|
values.clear();
|
values.put("id", joinRecord.getId());
|
values.put("couponNum", list.size());
|
sqlSentence.setSqlSentence(" couponNum = couponNum + #{m.couponNum}, receiveNum = receiveNum + 1, editTime = now() where id = #{m.id} ");
|
if(commonService.updateWhere(MarketActivityJoinRecordMapper.class, sqlSentence) != 1){
|
throw new TipsException("更新活动参与记录失败！");
|
}
|
}
|
|
//处理领取记录---------------------------------------------------------------------------------
|
|
receiveRecord.setJoinRecordId(joinRecord.getId());
|
if(commonService.insert(MarketActivityReceiveRecordMapper.class, receiveRecord) != 1){
|
throw new TipsException("新增领取记录失败1！");
|
}
|
|
//遍历新增子项
|
for(MarketActivityReceiveRecordItem receiveRecordItem : recordItemList){
|
receiveRecordItem.setReceiveRecordId(receiveRecord.getId());
|
if(commonService.insert(MarketActivityReceiveRecordItemMapper.class, receiveRecordItem) != 1){
|
throw new TipsException("新增领取记录失败2！");
|
}
|
|
//如果状态是待审核的，创建营销助手审批记录
|
// if(receiveRecordItem.getApproveStatus() == MarketActivityReceiveRecordItem.APPROVE_STATUS_WAIT){
|
// handleApprove(joinRecord, receiveRecord, receiveRecordItem);
|
// }
|
}
|
|
//发送审批通知给活动负责人-------------------------------------------------------------------------------------
|
// if(isApprove == BaseEntity.YES) {
|
try {
|
String empUserId;
|
Shop shop = commonService.selectOneByKey(ShopMapper.class, receiveRecord.getOpShopId());
|
//正式环境发给对应的负责人 测试服发给彭程
|
if ("prod".equals(customParameter.getPlatformPattern())) {
|
//查询员工数据
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, marketActivity.getManagerId());
|
if (employee == null) {
|
throw new TipsException("找不到活动负责人！");
|
}
|
empUserId = employee.getUserId();
|
} else {
|
empUserId = "18023612893";
|
}
|
|
String sendDate = MessageTemplate.receiveCouponSendToManager(isApprove,empUserId, user.getName(), receiveRecord.getOpName(), shop.getName(), marketActivity.getTitle(), couponName, customParameter.getCorpMpAppId());
|
log.info("小程序营销活动领取优惠券通知活动负责人，userId为:{}", empUserId);
|
String token = WeiXinCorpMpUtil.getApplicationAccessToken(commonService, customParameter.getCorpAppId(), customParameter.getCorpMpSecret());
|
SendMessageTool.sendMessge(sendDate, token);
|
} catch (Exception e) {
|
log.info("小程序用户营销活动发送通知失败");
|
log.info(GlobalExceptionHandler.getExceptionInformation(e));
|
}
|
// }
|
//-------------------------------------------------------------------------------------------
|
}
|
|
/** 更新查看记录 */
|
@Override
|
public void updateViewRecord(String marketActivityId, String platformType, User user) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
values.put("userId", user.getId());
|
values.put("marketActivityId", marketActivityId);
|
sqlSentence.setSqlSentence(" select id from market_activity_view_record where isDel = 0 and userId = #{m.userId} and marketActivityId = #{m.marketActivityId} ");
|
Map<String, Object> map = commonService.selectOneMap(MarketActivityViewRecordMapper.class, sqlSentence);
|
if(map != null && map.get("id") != null){
|
//更新查看次数和时间
|
values.clear();
|
values.put("id", map.get("id"));
|
sqlSentence.setSqlSentence(" viewNum = viewNum + 1, editTime = now() where id = #{m.id} ");
|
if(commonService.updateWhere(MarketActivityViewRecordMapper.class, sqlSentence) != 1){
|
throw new TipsException("更新营销活动查看记录的查看次数和时间失败！");
|
}
|
}else{
|
//新增查看记录
|
MarketActivityViewRecord viewRecord = new MarketActivityViewRecord();
|
viewRecord.setMarketActivityId(marketActivityId);
|
viewRecord.setPlatformType(platformType);
|
viewRecord.setViewNum(1);
|
//用户信息
|
viewRecord.setUserId(user.getId());
|
viewRecord.setUserName(user.getName());
|
viewRecord.setCIQ(user.getCIQ());
|
viewRecord.setUserLevel(user.getUserLevel());
|
viewRecord.setUserStatus(user.getUserStatus());
|
viewRecord.setUserConsultantId(user.getHisCorpUserId());
|
viewRecord.setUserConsultantName(EmployeeTool.getCnName(viewRecord.getUserConsultantId(), commonService));
|
viewRecord.setUserShopId(user.getShopId());
|
viewRecord.setUserShopName(ShopTool.getShopName(viewRecord.getUserShopId(), commonService));
|
if(commonService.insert(MarketActivityViewRecordMapper.class, viewRecord) != 1){
|
throw new TipsException("新增营销活动查看记录失败！");
|
}
|
}
|
}
|
|
|
/** 营销助手审批回调处理 */
|
@Override
|
public void receiveApproveHandle(MarketActivityJoinRecord joinRecord, MarketActivityReceiveRecord receiveRecord
|
, MarketActivityReceiveRecordItem recordItem) {
|
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
String result = "";
|
|
//审批成功
|
if(recordItem.getApproveStatus() == MarketActivityReceiveRecordItem.APPROVE_STATUS_SUC){
|
|
//优惠券操作人类型，默认员工
|
int couponOpType = OperatorConstants.changeCouponOpType(receiveRecord.getOpType());
|
|
//拼接用户数据
|
JSONArray userArr = new JSONArray();
|
JSONObject json = new JSONObject();
|
json.put("id", receiveRecord.getUserId());
|
json.put("amount", 1);
|
userArr.add(json);
|
|
//发放优惠券
|
try{
|
sendCoupon(couponOpType, userArr, receiveRecord, recordItem);
|
}catch (Exception e){
|
log.error("参数：{}", JSONObject.fromObject(recordItem));
|
log.error("营销助手审批回调处理,发放优惠券失败：{}", GlobalExceptionHandler.getExceptionInformation(e));
|
//统一提示
|
throw new TipsException("营销助手审批回调处理,发放优惠券失败，" + e.getMessage());
|
}
|
|
//更新状态
|
values.put("approveStatus", recordItem.getApproveStatus());
|
values.put("approveRemark", recordItem.getApproveRemark());
|
values.put("id", recordItem.getId());
|
sqlSentence.setSqlSentence(" approveStatus = #{m.approveStatus}, approveRemark = #{m.approveRemark}, editTime = now() where id = #{m.id} ");
|
if(commonService.updateWhere(MarketActivityReceiveRecordItemMapper.class, sqlSentence) != 1){
|
throw new TipsException("更新领取记录审批状态失败！");
|
}
|
result = "通过";
|
}
|
//审批失败-------------------------------------------------------------------------------------
|
else if(recordItem.getApproveStatus() == MarketActivityReceiveRecordItem.APPROVE_STATUS_FAIL){
|
//更新状态和删除状态
|
values.put("approveStatus", recordItem.getApproveStatus());
|
values.put("approveRemark", recordItem.getApproveRemark());
|
values.put("id", recordItem.getId());
|
sqlSentence.setSqlSentence(" approveStatus = #{m.approveStatus}, approveRemark = #{m.approveRemark}, isDel = 2, editTime = now() where id = #{m.id} ");
|
if(commonService.updateWhere(MarketActivityReceiveRecordItemMapper.class, sqlSentence) != 1){
|
throw new TipsException("更新领取记录审批状态失败！");
|
}
|
|
//更新减少用户参与记录领取优惠券数量
|
values.clear();
|
values.put("couponNum", joinRecord.getCouponNum());
|
values.put("id", joinRecord.getId());
|
sqlSentence.setSqlSentence(" couponNum = couponNum - 1 where id = #{m.id} and couponNum = #{m.couponNum} ");
|
if(commonService.updateWhere(MarketActivityJoinRecordMapper.class, sqlSentence) != 1){
|
throw new TipsException("更新活动参与记录信息失败！");
|
}
|
|
result = "拒绝";
|
}
|
|
//发送审批结果通知-------------------------------------------------------------------------------------
|
MarketActivity activity = commonService.selectOneByKey(MarketActivityMapper.class,receiveRecord.getMarketActivityId());
|
if(activity == null){
|
throw new TipsException("找不到活动！");
|
}
|
|
//查询员工数据
|
String empUserId;
|
//正式环境发给对应的 测试服发给彭程
|
if("prod".equals(customParameter.getPlatformPattern())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class,receiveRecord.getOpId());
|
if(employee == null){
|
throw new TipsException("找不到活动负责人！");
|
}
|
empUserId = employee.getUserId();
|
}else {
|
empUserId = "18023612893";
|
}
|
|
String sendDate = MessageTemplate.receiveResultSendToAdvice(activity.getManagerName(), empUserId, activity.getTitle(), recordItem.getCommonName(),result, customParameter.getCorpMpAppId());
|
log.info("小程序营销活动领取优惠券审核结果通知，userId为:{}", empUserId);
|
String token = WeiXinCorpMpUtil.getApplicationAccessToken(commonService, customParameter.getCorpAppId(), customParameter.getCorpMpSecret());
|
SendMessageTool.sendMessge(sendDate, token);
|
}
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
/** 统一发送优惠券逻辑 */
|
private void sendCoupon(Integer couponOpType, JSONArray userArr, MarketActivityReceiveRecord receiveRecord, MarketActivityReceiveRecordItem recordItem){
|
|
Coupon coupon = commonService.selectOneByKeyBlob(CouponMapper.class, recordItem.getCommonId());
|
if(coupon!=null && BaseEntity.YES==coupon.getIsBirthday()){
|
for(int i=0;i<userArr.size();i++){
|
JSONObject object = userArr.getJSONObject(i);
|
object.put("startTime", DateUtil.formatDate_2(new Date()));
|
object.put("endTime", DateUtil.formatDate_2(DateUtil.addMonth(new Date(),1)));
|
}
|
}
|
|
CouponReleaseRecordItem couponReleaseRecordItem = new CouponReleaseRecordItem();
|
couponReleaseRecordItem.setCouponId(recordItem.getCommonId());
|
couponReleaseRecordItem.setCommonType(CouponReleaseRecordItem.TYPE_COMMON_MARKET_ACTIVITY);
|
couponReleaseRecordItem.setCommonId(recordItem.getMarketActivityId());
|
couponReleaseRecordItem.setCommonItemId(recordItem.getActivityItemId());
|
couponReleaseRecordItem.setRecordName("门店助手热门活动领取");
|
//调用方法优惠券方法
|
CouponTool.sendCoupon(couponReleaseRecordItem, receiveRecord.getOpId(),receiveRecord.getOpName()
|
, couponOpType,receiveRecord.getOpRoleId(),userArr
|
, receiveRecord.getPlatformType(),commonService);
|
|
}
|
|
/** 处理营销助手申请 */
|
private void handleApprove(MarketActivityJoinRecord joinRecord, MarketActivityReceiveRecord receiveRecord, MarketActivityReceiveRecordItem recordItem){
|
MarketingTotalDto marketingTotalDto = new MarketingTotalDto();
|
marketingTotalDto.setTitle(processBean.getMarcaTitle());
|
marketingTotalDto.setTypeStr(processBean.getMarcaTypeStr());
|
marketingTotalDto.setType(processBean.getMarcaWorkflowCode());
|
marketingTotalDto.setUniqueId(recordItem.getId());
|
marketingTotalDto.setOperatorId(receiveRecord.getOpId());
|
marketingTotalDto.setOpName(receiveRecord.getOpName());
|
marketingTotalDto.setShopId(receiveRecord.getOpShopId());
|
marketingTotalDto.setShopName(CommonQueryUtil.getShopName(marketingTotalDto.getShopId(), commonService));
|
marketingTotalDto.setRoleId(CommonQueryUtil.getEmployeeRoleTypeId(receiveRecord.getOpRoleStr(), commonService));
|
marketingTotalDto.setRoleUniqueStr(receiveRecord.getOpRoleStr());
|
marketingTotalDto.setUserId(receiveRecord.getUserId());
|
marketingTotalDto.setRemark("领取申请");
|
marketingTotalDto.setCallbackUrl(processBean.getMarcaNotifyUrl());
|
|
//---审核信息组拼
|
MarketingContentDto marketingContentDto = new MarketingContentDto();
|
List<MarketingMsgItemDto> contentList = new ArrayList<>();
|
|
MarketingMsgItemDto marketingMsgItemDto = new MarketingMsgItemDto();
|
marketingMsgItemDto.setKey("审核类型");
|
marketingMsgItemDto.setValue("营销活动领取优惠券");
|
contentList.add(marketingMsgItemDto);
|
|
marketingMsgItemDto = new MarketingMsgItemDto();
|
marketingMsgItemDto.setKey("优惠券");
|
marketingMsgItemDto.setValue(recordItem.getCommonName());
|
contentList.add(marketingMsgItemDto);
|
|
marketingContentDto.setContentList(contentList);
|
marketingTotalDto.setMarketingContentDto(marketingContentDto);
|
//审核信息组拼结束
|
|
//---企业微信信息组拼
|
MarketingMsgDto marketingMsgDto = new MarketingMsgDto();
|
marketingMsgDto.setEmphasisFirstItem(true);
|
List<MarketingMsgItemDto> contentItem = new ArrayList<>();
|
contentItem.addAll(contentList);
|
marketingMsgDto.setContentItem(contentItem);
|
marketingTotalDto.setMarketingMsgDto(marketingMsgDto);
|
//---企业微信信息结束
|
|
log.info("请求创建审批记录参数：{}", com.alibaba.fastjson.JSONObject.toJSONString(marketingTotalDto));
|
Result result = mCommonService.commonApply(marketingTotalDto);
|
log.info("请求创建审批记录返回结果：{}", com.alibaba.fastjson.JSONObject.toJSONString(result));
|
if(!result.checkCode()){
|
log.info("领取优惠券失败，新增领取审批记录失败，返回结果:{}", JSONObject.fromObject(result));
|
throw new TipsException("领取优惠券失败，新增领取审批记录失败！");
|
}
|
|
//获取返回值，判断是否直接审核通过
|
MarketingResultDto marketingResultDto = result.getObject(result.getData(),MarketingResultDto.class);
|
if(marketingResultDto == null){
|
throw new TipsException("创建审批记录返回信息为空！");
|
}
|
|
//如果这里发券失败，目前会对应记录都没有创建，但是营销助手会有一条记录的情况
|
if(marketingResultDto != null && marketingResultDto.getIsPass() == 1){
|
recordItem.setApproveStatus(MarketActivityReceiveRecordItem.APPROVE_STATUS_SUC);
|
recordItem.setApproveRemark("审批直接通过");
|
receiveApproveHandle(joinRecord, receiveRecord, recordItem);
|
}
|
|
}
|
|
|
}
|
