道闸开闸 发送营销信息

java110-bean/src/main/java/com/java110/dto/owner/OwnerCarDto.java

@@ -90,6 +90,7 @@ public class OwnerCarDto extends PageDto implements Serializable {
     private String oweAmount;
 
     private String leaseType;
+    private String[] leaseTypes;
 
     private String leaseTypeName;
 
@@ -462,4 +463,12 @@ public class OwnerCarDto extends PageDto implements Serializable {
     public void setCarTypeCdName(String carTypeCdName) {
         this.carTypeCdName = carTypeCdName;
     }
+
+    public String[] getLeaseTypes() {
+        return leaseTypes;
+    }
+
+    public void setLeaseTypes(String[] leaseTypes) {
+        this.leaseTypes = leaseTypes;
+    }
 }

java110-db/src/main/resources/mapper/user/OwnerCarV1ServiceDaoImplMapper.xml

@@ -44,6 +44,12 @@
         <if test="leaseType !=null and leaseType != ''">
             and t.lease_type= #{leaseType}
         </if>
+        <if test="leaseTypes !=null ">
+            and t.lease_type in
+            <foreach collection="leaseTypes" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
         <if test="carTypeCd !=null and carTypeCd != ''">
             and t.car_type_cd= #{carTypeCd}
         </if>
@@ -168,6 +174,12 @@
         <if test="leaseType !=null and leaseType != ''">
             and t.lease_type= #{leaseType}
         </if>
+        <if test="leaseTypes !=null ">
+            and t.lease_type in
+            <foreach collection="leaseTypes" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
         <if test="carTypeCd !=null and carTypeCd != ''">
             and t.car_type_cd= #{carTypeCd}
         </if>

service-job/src/main/java/com/java110/job/adapt/market/CarInSendMarketInfoAdapt.java

@@ -0,0 +1,162 @@
+package com.java110.job.adapt.market;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.dto.machine.CarInoutDetailDto;
+import com.java110.dto.marketRuleCommunity.MarketRuleCommunityDto;
+import com.java110.dto.marketRuleObj.MarketRuleObjDto;
+import com.java110.dto.marketRuleWay.MarketRuleWayDto;
+import com.java110.dto.marketText.MarketTextDto;
+import com.java110.dto.owner.OwnerCarDto;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.entity.order.Business;
+import com.java110.intf.common.IMarketRuleCommunityV1InnerServiceSMO;
+import com.java110.intf.common.IMarketRuleObjV1InnerServiceSMO;
+import com.java110.intf.common.IMarketRuleWayV1InnerServiceSMO;
+import com.java110.intf.common.IMarketTextV1InnerServiceSMO;
+import com.java110.intf.user.IOwnerCarV1InnerServiceSMO;
+import com.java110.intf.user.IOwnerV1InnerServiceSMO;
+import com.java110.job.adapt.DatabusAdaptImpl;
+import com.java110.po.car.CarInoutDetailPo;
+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 = "carInSendMarketInfoAdapt")
+public class CarInSendMarketInfoAdapt extends DatabusAdaptImpl {
+
+    @Autowired
+    private IMarketRuleCommunityV1InnerServiceSMO marketRuleCommunityV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketTextV1InnerServiceSMO marketTextV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleObjV1InnerServiceSMO marketRuleObjV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleWayV1InnerServiceSMO marketRuleWayV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerCarV1InnerServiceSMO ownerCarV1InnerServiceSMOImpl;
+
+
+    @Autowired
+    private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
+
+    @Override
+    public void execute(Business business, List<Business> businesses) {
+        JSONObject data = business.getData();
+        JSONArray businessCarInoutDetailPos = new JSONArray();
+
+        if (data instanceof JSONObject) {
+            businessCarInoutDetailPos.add(data);
+        }
+
+        //JSONObject businessCarBlackWhite = data.getJSONObject("businessCarBlackWhite");
+        for (int bCarInoutDetailPoIndex = 0; bCarInoutDetailPoIndex < businessCarInoutDetailPos.size(); bCarInoutDetailPoIndex++) {
+            JSONObject businessCarInoutDetailPo = businessCarInoutDetailPos.getJSONObject(bCarInoutDetailPoIndex);
+            doSendMarket(business, businessCarInoutDetailPo);
+        }
+    }
+
+    /**
+     * 发送营销信息
+     *
+     * @param business
+     * @param businessCarInoutDetailPo 开门记录信息
+     */
+    private void doSendMarket(Business business, JSONObject businessCarInoutDetailPo) {
+        CarInoutDetailPo carInoutDetailPo = BeanConvertUtil.covertBean(businessCarInoutDetailPo,CarInoutDetailPo.class);
+
+        //没有手机号 说明  没法发送营销信息 所以 放弃 不推送
+        if(StringUtil.isEmpty(carInoutDetailPo.getCarNum())){
+            return ;
+        }
+
+        String communityId = carInoutDetailPo.getCommunityId();
+
+        OwnerCarDto ownerCarDto = new OwnerCarDto();
+        ownerCarDto.setCarNum(carInoutDetailPo.getCarNum());
+        ownerCarDto.setCommunityId(communityId);
+        ownerCarDto.setLeaseTypes(new String[]{OwnerCarDto.LEASE_TYPE_INNER,
+                OwnerCarDto.LEASE_TYPE_MONTH,
+                OwnerCarDto.LEASE_TYPE_NO_MONEY,
+                OwnerCarDto.LEASE_TYPE_SALE});
+        List<OwnerCarDto> ownerCarDtos = ownerCarV1InnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
+
+        if(ownerCarDtos == null || ownerCarDtos.size()<1){
+            return ;
+        }
+
+        OwnerDto ownerDto = new OwnerDto();
+        ownerDto.setMemberId(ownerCarDtos.get(0).getOwnerId());
+        ownerDto.setCommunityId(communityId);
+        List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
+        if(ownerDtos == null || ownerDtos.size()<1){
+            return ;
+        }
+
+        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_BARRIER);
+        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),ownerDtos.get(0).getLink(),communityId,marketRuleCommunityDtos.get(0).getCommunityName());
+
+
+
+    }
+}

service-job/src/main/java/com/java110/job/adapt/market/SendMarketInfoAdapt.java

@@ -14,6 +14,7 @@ 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;
@@ -25,7 +26,8 @@ import java.util.List;
  *
  *
  */
-public class SendMarketInfoAdapt extends DatabusAdaptImpl {
+@Component(value = "personInSendMarketInfoAdapt")
+public class PersonInSendMarketInfoAdapt extends DatabusAdaptImpl {
 
     @Autowired
     private IMarketRuleCommunityV1InnerServiceSMO marketRuleCommunityV1InnerServiceSMOImpl;