package com.java110.job.adapt.market;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.dto.market.MarketRuleCommunityDto;
|
import com.java110.dto.market.MarketRuleObjDto;
|
import com.java110.dto.market.MarketRuleWayDto;
|
import com.java110.dto.market.MarketTextDto;
|
import com.java110.dto.system.Business;
|
import com.java110.intf.common.*;
|
import com.java110.job.adapt.DatabusAdaptImpl;
|
import com.java110.po.machine.MachineRecordPo;
|
import com.java110.utils.factory.ApplicationContextFactory;
|
import com.java110.utils.util.BeanConvertUtil;
|
import com.java110.utils.util.StringUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 人员进场发送营销信息
|
*
|
* 根据 admin账户下 营销配置 发送
|
*
|
*
|
*/
|
@Component(value = "personInSendMarketInfoAdapt")
|
public class PersonInSendMarketInfoAdapt extends DatabusAdaptImpl {
|
|
@Autowired
|
private IMarketRuleCommunityV1InnerServiceSMO marketRuleCommunityV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IMarketTextV1InnerServiceSMO marketTextV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IMarketRuleObjV1InnerServiceSMO marketRuleObjV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IMarketRuleWayV1InnerServiceSMO marketRuleWayV1InnerServiceSMOImpl;
|
|
|
|
@Override
|
public void execute(Business business, List<Business> businesses) {
|
JSONObject data = business.getData();
|
JSONArray businessMachineRecordPos = new JSONArray();
|
|
if (data instanceof JSONObject) {
|
businessMachineRecordPos.add(data);
|
}
|
|
//JSONObject businessCarBlackWhite = data.getJSONObject("businessCarBlackWhite");
|
for (int bMachineRecordPoIndex = 0; bMachineRecordPoIndex < businessMachineRecordPos.size(); bMachineRecordPoIndex++) {
|
JSONObject businessMachineRecordPo = businessMachineRecordPos.getJSONObject(bMachineRecordPoIndex);
|
doSendMarket(business, businessMachineRecordPo);
|
}
|
}
|
|
/**
|
* 发送营销信息
|
*
|
* @param business
|
* @param businessMachineRecordPo 开门记录信息
|
*/
|
private void doSendMarket(Business business, JSONObject businessMachineRecordPo) {
|
MachineRecordPo machineRecordPo = BeanConvertUtil.covertBean(businessMachineRecordPo,MachineRecordPo.class);
|
|
//没有手机号 说明 没法发送营销信息 所以 放弃 不推送
|
if(StringUtil.isEmpty(machineRecordPo.getTel()) || "-1".equals(machineRecordPo.getTel())){
|
return ;
|
}
|
|
String communityId = machineRecordPo.getCommunityId();
|
|
|
MarketRuleCommunityDto marketRuleCommunityDto = new MarketRuleCommunityDto();
|
marketRuleCommunityDto.setCommunityId(communityId);
|
List<MarketRuleCommunityDto> marketRuleCommunityDtos = marketRuleCommunityV1InnerServiceSMOImpl.queryMarketRuleCommunitys(marketRuleCommunityDto);
|
|
if(marketRuleCommunityDtos == null || marketRuleCommunityDtos.size()<1){
|
return;
|
}
|
|
List<String> ruleIds = new ArrayList<>();
|
for(MarketRuleCommunityDto tmpMarketRuleCommunityDto: marketRuleCommunityDtos){
|
ruleIds.add(tmpMarketRuleCommunityDto.getRuleId());
|
}
|
|
MarketRuleObjDto marketRuleObjDto = new MarketRuleObjDto();
|
marketRuleObjDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
|
marketRuleObjDto.setObjType(MarketRuleObjDto.OBJ_TYPE_ACCESS_CONTROL);
|
long count = marketRuleObjV1InnerServiceSMOImpl.queryMarketRuleObjsCount(marketRuleObjDto);
|
|
if(count <1){
|
return ;
|
}
|
|
|
MarketRuleWayDto marketRuleWayDto = new MarketRuleWayDto();
|
marketRuleWayDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
|
marketRuleWayDto.setWayType(MarketRuleWayDto.WAY_TYPE_TEXT);
|
List<MarketRuleWayDto> marketRuleWayDtos = marketRuleWayV1InnerServiceSMOImpl.queryMarketRuleWays(marketRuleWayDto);
|
|
if(marketRuleWayDtos == null || marketRuleWayDtos.size()<1){
|
return;
|
}
|
|
MarketTextDto marketTextDto = new MarketTextDto();
|
marketTextDto.setTextId(marketRuleWayDto.getWayObjId());
|
List<MarketTextDto> marketTextDtos = marketTextV1InnerServiceSMOImpl.queryMarketTexts(marketTextDto);
|
|
if(marketTextDtos == null || marketTextDtos.size()<1){
|
return ;
|
}
|
|
|
|
ISendExecutor sendExecuter = ApplicationContextFactory.getBean("sendExecutor"+marketTextDtos.get(0).getSmsType(),ISendExecutor.class);
|
marketTextDtos.get(0).setRuleId(ruleIds.get(0));
|
sendExecuter.send(marketTextDtos.get(0),machineRecordPo.getTel(),communityId,marketRuleCommunityDtos.get(0).getCommunityName());
|
|
|
|
}
|
}
|
