diff --git a/src/main/java/com/kiisoo/ic/customer/CustomerService.java b/src/main/java/com/kiisoo/ic/customer/CustomerService.java index d833e42..0cdbeb0 100644 --- a/src/main/java/com/kiisoo/ic/customer/CustomerService.java +++ b/src/main/java/com/kiisoo/ic/customer/CustomerService.java @@ -3,8 +3,11 @@ package com.kiisoo.ic.customer; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.kiisoo.ic.customer.entity.OpCustomer; import com.kiisoo.ic.customer.entity.OpSellerCustomerRelation; +import com.kiisoo.ic.customer.entity.OpVip; import com.kiisoo.ic.customer.mapper.OpCustomerDOMapper; import com.kiisoo.ic.customer.mapper.OpSellerCustomerRelationDOMapper; +import com.kiisoo.ic.customer.mapper.OpVipAttrDOMapper; +import com.kiisoo.ic.customer.mapper.OpVipDOMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -25,24 +28,30 @@ public class CustomerService { private final OpSellerCustomerRelationDOMapper opSellerCustomerRelationDOMapper; + private final OpVipDOMapper opVipDOMapper; + + private final OpVipAttrDOMapper opVipAttrDOMapper; + @Autowired - public CustomerService(OpCustomerDOMapper opCustomerDOMapper, OpSellerCustomerRelationDOMapper opSellerCustomerRelationDOMapper) { + public CustomerService(OpCustomerDOMapper opCustomerDOMapper, OpSellerCustomerRelationDOMapper opSellerCustomerRelationDOMapper, OpVipDOMapper opVipDOMapper, OpVipAttrDOMapper opVipAttrDOMapper) { this.opCustomerDOMapper = opCustomerDOMapper; this.opSellerCustomerRelationDOMapper = opSellerCustomerRelationDOMapper; + this.opVipDOMapper = opVipDOMapper; + this.opVipAttrDOMapper = opVipAttrDOMapper; } /** * 绑定客户的关系 - * @param phone 客户手机号 + * @param openId 微信openId * @param sellerId 分享码的导购id * @param shopId 导购所在的店铺id * @Description: 根据客户联系方式查询客户id 1.判断客户是否存在,不存在就添加,存在就进行下一步 2.判断客户id和导购是否绑定了关系如果绑定了就直接下一步,如果没有就绑定 3.判断客户id和vip是否绑定了关系如果绑定了就直接下一步,如果没有就绑定 */ @Transactional(rollbackFor = Exception.class) @Deprecated - public void customerRelation(String phone,long sellerId,long shopId){ + public void customerRelation(String openId,long sellerId,long shopId){ QueryWrapper wrapper = new QueryWrapper<>(); - wrapper.eq("phone",phone).last("limit 1"); + wrapper.eq("wechat_open_id",openId).last("limit 1"); OpCustomer opCustomer = opCustomerDOMapper.selectOne(wrapper); if(null != opCustomer){ //存在--1.处理客户导购关系。2.处理客户和vip关系(待定) @@ -50,11 +59,35 @@ public class CustomerService { }else { //不存在 OpCustomer insertCustomer = new OpCustomer(); - insertCustomer.setPhone(phone); + insertCustomer.setWechatOpenId(openId); opCustomerDOMapper.insert(insertCustomer); } } + /** + * 录入客户信息/绑定客户vip关系(如果是VIP的话) + * @param openId + * @param name + * @param phone + * @param desc + * @param mail + * @param type + */ + @Transactional(rollbackFor = Exception.class) + public void customerVipRelation(String openId,String name,String phone,String desc,String mail,long type){ + OpCustomer opCustomer = new OpCustomer(type,name,phone,desc,mail,new Date(),new Date()); + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("phone",phone).last("limit 1"); + OpVip opVip = opVipDOMapper.selectOne(wrapper); + if(null != opVip){ + //有vip信息就绑定信息 + opCustomer.setMemberId(opVip.getId()); + } + QueryWrapper wrapper1 = new QueryWrapper<>(); + wrapper1.eq("wechat_open_id",openId); + opCustomerDOMapper.update(opCustomer,wrapper1); + } + /** * 处理客户和导购的关系 * @param opCustomer 客户的数据信息 diff --git a/src/main/java/com/kiisoo/ic/customer/entity/OpCustomer.java b/src/main/java/com/kiisoo/ic/customer/entity/OpCustomer.java index db29474..ee22086 100644 --- a/src/main/java/com/kiisoo/ic/customer/entity/OpCustomer.java +++ b/src/main/java/com/kiisoo/ic/customer/entity/OpCustomer.java @@ -15,6 +15,19 @@ import java.util.Date; @TableName ("op_customer") public class OpCustomer { + public OpCustomer() { + } + + public OpCustomer(Long type, String name, String phone, String desc, String mail, Date createTime, Date updateTime) { + this.type = type; + this.name = name; + this.phone = phone; + this.desc = desc; + this.mail = mail; + this.createTime = createTime; + this.updateTime = updateTime; + } + /** * 主键ID */ diff --git a/src/main/java/com/kiisoo/ic/customer/mapper/OpVipAttrDOMapper.java b/src/main/java/com/kiisoo/ic/customer/mapper/OpVipAttrDOMapper.java new file mode 100644 index 0000000..661c192 --- /dev/null +++ b/src/main/java/com/kiisoo/ic/customer/mapper/OpVipAttrDOMapper.java @@ -0,0 +1,13 @@ +package com.kiisoo.ic.customer.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.kiisoo.ic.customer.entity.OpVipAttr; +import org.springframework.stereotype.Repository; + +/** + * 客户vip + */ +@Repository +public interface OpVipAttrDOMapper extends BaseMapper { + +} diff --git a/src/main/java/com/kiisoo/ic/customer/mapper/OpVipDOMapper.java b/src/main/java/com/kiisoo/ic/customer/mapper/OpVipDOMapper.java new file mode 100644 index 0000000..f8d0696 --- /dev/null +++ b/src/main/java/com/kiisoo/ic/customer/mapper/OpVipDOMapper.java @@ -0,0 +1,14 @@ +package com.kiisoo.ic.customer.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.kiisoo.ic.customer.entity.OpVip; +import com.kiisoo.ic.customer.entity.OpVipAttr; +import org.springframework.stereotype.Repository; + +/** + * 客户vip + */ +@Repository +public interface OpVipDOMapper extends BaseMapper { + +}