修改-经纪人添加自己的商机,打上标签

yd-api/src/main/java/com/yd/api/practitioner/service/impl/PractitionerServiceImpl.java

@@ -1251,6 +1251,8 @@ public class PractitionerServiceImpl implements com.yd.api.practitioner.service.
         //校验商机号码,手机号码对应的customer是否存在
         //校验商机号码,手机号码对应的customer是否存在
         String mobileNo = requestVO.getMobileNo();
         String mobileNo = requestVO.getMobileNo();
         AclCustomer aclCustomer = aclCustomerDALService.findByMobileNo(mobileNo);
         AclCustomer aclCustomer = aclCustomerDALService.findByMobileNo(mobileNo);
+        Long mdMkCampaignId = systemConfigService.getMdMkCampaignId("leadaddedbypractioner");
+
         //判断是否通过手机号码找到客户
         //判断是否通过手机号码找到客户
         if (aclCustomer!=null){
         if (aclCustomer!=null){
             MktLeadsAssigneds mktLeadsAssigneds = new MktLeadsAssigneds();
             MktLeadsAssigneds mktLeadsAssigneds = new MktLeadsAssigneds();
@@ -1284,6 +1286,7 @@ public class PractitionerServiceImpl implements com.yd.api.practitioner.service.
             aclCustomer.setUpdatedAt(new Date());
             aclCustomer.setUpdatedAt(new Date());
             aclCustomer.setUpdatedBy(-1L);
             aclCustomer.setUpdatedBy(-1L);
             aclCustomer.setChannelReferralRateId(3L);
             aclCustomer.setChannelReferralRateId(3L);
+            aclCustomer.setMktCampaign(String.valueOf(mdMkCampaignId));
             aclCustomerDALService.save(aclCustomer);
             aclCustomerDALService.save(aclCustomer);
         }
         }
         customerId = aclCustomer.getId();
         customerId = aclCustomer.getId();
@@ -1292,6 +1295,7 @@ public class PractitionerServiceImpl implements com.yd.api.practitioner.service.
         if (pool == null){
         if (pool == null){
             //线索池为空时,保存线索池
             //线索池为空时,保存线索池
             pool = new MktLeadsPool();
             pool = new MktLeadsPool();
+            pool.setMktCampaign(String.valueOf(mdMkCampaignId));
             pool.setCustomerId(customerId);
             pool.setCustomerId(customerId);
             pool.setHasAssigned(1);
             pool.setHasAssigned(1);
             pool.setSourceFrom(requestVO.getSourceFrom());
             pool.setSourceFrom(requestVO.getSourceFrom());

yd-api/src/main/java/com/yd/dal/mapper/meta/MdMkCampaignMapper.java

@@ -14,4 +14,6 @@ public interface MdMkCampaignMapper {
     int updateByPrimaryKeySelective(MdMkCampaign record);
     int updateByPrimaryKeySelective(MdMkCampaign record);
 
 
     int updateByPrimaryKey(MdMkCampaign record);
     int updateByPrimaryKey(MdMkCampaign record);
+
+    MdMkCampaign selectByCampaignCode(String campaignCode);
 }
 }
\ No newline at end of file

yd-api/src/main/java/com/yd/dal/service/meta/MdMkCampaignDALService.java

@@ -4,4 +4,6 @@ import com.yd.dal.entity.meta.MdMkCampaign;
 
 
 public interface MdMkCampaignDALService {
 public interface MdMkCampaignDALService {
     MdMkCampaign findByMktCampaignId(Long mktCampaignId);
     MdMkCampaign findByMktCampaignId(Long mktCampaignId);
+
+    MdMkCampaign findByCampaignCode(String campaignCode);
 }
 }

yd-api/src/main/java/com/yd/dal/service/meta/impl/MdMkCampaignDALServiceImpl.java

@@ -16,4 +16,9 @@ public class MdMkCampaignDALServiceImpl implements MdMkCampaignDALService {
     public MdMkCampaign findByMktCampaignId(Long mktCampaignId) {
     public MdMkCampaign findByMktCampaignId(Long mktCampaignId) {
         return mdMkCampaignMapper.selectByPrimaryKey(mktCampaignId);
         return mdMkCampaignMapper.selectByPrimaryKey(mktCampaignId);
     }
     }
+
+    @Override
+    public MdMkCampaign findByCampaignCode(String campaignCode) {
+        return mdMkCampaignMapper.selectByCampaignCode(campaignCode);
+    }
 }
 }

yd-api/src/main/java/com/yd/rmi/cache/SystemConfigService.java

 package com.yd.rmi.cache;
 package com.yd.rmi.cache;
 
 
 import com.yd.dal.entity.meta.MdCode;
 import com.yd.dal.entity.meta.MdCode;
+import com.yd.dal.entity.meta.MdMkCampaign;
 import com.yd.dal.service.meta.MdCodeDALService;
 import com.yd.dal.service.meta.MdCodeDALService;
+import com.yd.dal.service.meta.MdMkCampaignDALService;
 import com.yd.rmi.ali.ossinterf.service.AliOssInterfService;
 import com.yd.rmi.ali.ossinterf.service.AliOssInterfService;
 import com.yd.util.CommonUtil;
 import com.yd.util.CommonUtil;
 import net.sf.ehcache.Cache;
 import net.sf.ehcache.Cache;
@@ -13,6 +15,7 @@ import org.springframework.stereotype.Service;
 import java.util.ArrayList;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Arrays;
 import java.util.List;
 import java.util.List;
+import java.util.Optional;
 
 
 @Service("systemConfigService")
 @Service("systemConfigService")
 @org.springframework.core.annotation.Order(1)
 @org.springframework.core.annotation.Order(1)
@@ -201,4 +204,20 @@ public class SystemConfigService implements CommandLineRunner{
 		SystemConstants.COMMON_SO_TIMEOUT = Integer.parseInt(getSingleConfigValue("COMMON_SO_TIMEOUT"));
 		SystemConstants.COMMON_SO_TIMEOUT = Integer.parseInt(getSingleConfigValue("COMMON_SO_TIMEOUT"));
 		aliOssInterfService.initAttribute();
 		aliOssInterfService.initAttribute();
 	}
 	}
+
+	@Autowired
+	private MdMkCampaignDALService mdMkCampaignDALService;
+    public Long getMdMkCampaignId(String campaignCode) {
+		Long configValue = null;
+		Element element = systemConfigCache.get("campaignCode:"+campaignCode);
+		if(element != null && element.getObjectValue() != null){
+			configValue = (Long)element.getObjectValue();
+		}else{
+			MdMkCampaign mkCampaign = mdMkCampaignDALService.findByCampaignCode(campaignCode);
+			configValue = Optional.ofNullable(mkCampaign).map(c -> c.getId()).orElse(null);
+			element = new Element("campaignCode:"+campaignCode,configValue);
+			systemConfigCache.put(element);
+		}
+		return configValue;
+    }
 }
 }

yd-api/src/main/resources/mapper/meta/MdMkCampaignMapper.xml

@@ -166,4 +166,10 @@
       created_by = #{createdBy,jdbcType=BIGINT}
       created_by = #{createdBy,jdbcType=BIGINT}
     where id = #{id,jdbcType=BIGINT}
     where id = #{id,jdbcType=BIGINT}
   </update>
   </update>
+  <select id="selectByCampaignCode" resultMap="BaseResultMap">
+    select
+    <include refid="Base_Column_List" />
+    from ag_md_mk_campaign
+    where code = #{campaignCode,jdbcType=VARCHAR}
+  </select>
 </mapper>
 </mapper>
\ No newline at end of file