package com.stylefeng.guns.modular.system.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.system.dao.UserUserMapper;
|
import com.stylefeng.guns.modular.system.model.UserInfo;
|
import com.stylefeng.guns.modular.system.model.UserTaxiCard;
|
import com.stylefeng.guns.modular.system.model.UserUser;
|
import com.stylefeng.guns.modular.system.service.IUserInfoService;
|
import com.stylefeng.guns.modular.system.service.IUserTaxiCardService;
|
import com.stylefeng.guns.modular.system.service.IUserUserService;
|
import com.stylefeng.guns.modular.system.util.ResultUtil;
|
import com.stylefeng.guns.modular.system.warpper.BaseWarpper;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class UserUserServiceImpl extends ServiceImpl<UserUserMapper, UserUser> implements IUserUserService {
|
|
@Autowired
|
private IUserInfoService userInfoService;
|
|
@Autowired
|
private IUserTaxiCardService userTaxiCardService;
|
|
@Override
|
public List<BaseWarpper> getUserUserList(Integer uid) throws Exception {
|
List<UserUser> userUsers = this.selectList(new EntityWrapper<UserUser>().eq("userId", uid).orderBy("id"));
|
List<BaseWarpper> list = new ArrayList<>();
|
userUsers.forEach(userUser -> {
|
BaseWarpper baseWarpper = new BaseWarpper();
|
baseWarpper.setId(userUser.getId());
|
baseWarpper.setName(userUser.getCallName());
|
baseWarpper.setContent(userUser.getPhone());
|
list.add(baseWarpper);
|
});
|
return list;
|
}
|
|
@Override
|
public ResultUtil addUserUser(Integer uid, String content) throws Exception {
|
int nu = userTaxiCardService.selectCount(new EntityWrapper<UserTaxiCard>().eq("userId", uid));
|
if(nu == 0){
|
return ResultUtil.error("您暂未购买打车卡");
|
}
|
if(ToolUtil.isNotEmpty(content)){
|
JSONArray jsonArray = JSON.parseArray(content);
|
int num = 0;
|
for(int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
Integer id = jsonObject.getInteger("id");
|
if(null == id){
|
num++;
|
}
|
}
|
int number = this.selectCount(new EntityWrapper<UserUser>().eq("userId", uid));
|
int n = 15 - number;
|
if(n > 0 && n < num){
|
return ResultUtil.error("您还能添加" + n + "个亲密账户");
|
}
|
if(n == 0){
|
return ResultUtil.error("您已超出绑定上限15人");
|
}
|
|
for(int i = 0; i < jsonArray.size(); i++){
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
Integer id = jsonObject.getInteger("id");
|
String phone = jsonObject.getString("phone");
|
String name = jsonObject.getString("name");
|
UserInfo userInfo = userInfoService.selectOne(new EntityWrapper<UserInfo>().eq("phone", phone).ne("flag", 3));
|
if(null != userInfo && userInfo.getId().compareTo(uid) == 0){
|
return ResultUtil.error("不能绑定自己");
|
}
|
if(null == id){
|
if(null != userInfo){
|
int i1 = this.selectCount(new EntityWrapper<UserUser>().eq("userId", uid).eq("bindUserId", userInfo.getId()));
|
if(i1 > 0){
|
return ResultUtil.error(phone + "号码已经绑定了");
|
}
|
}
|
if(null == userInfo){
|
return ResultUtil.error(phone + "该手机还未注册账户");
|
}
|
|
UserUser userUser = new UserUser();
|
userUser.setUserId(uid);
|
userUser.setBindUserId(userInfo.getId());
|
userUser.setCallName(name);
|
userUser.setPhone(phone);
|
this.insert(userUser);
|
}else{
|
UserUser userUser = this.selectById(id);
|
userUser.setPhone(phone);
|
userUser.setCallName(name);
|
this.updateById(userUser);
|
}
|
}
|
}
|
return ResultUtil.success();
|
}
|
|
@Override
|
public ResultUtil unbundleUserUser(Integer id) throws Exception {
|
this.deleteById(id);
|
return ResultUtil.success();
|
}
|
}
|
