package com.xzx.gc.user.service;
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.RedisKeyConstant;
|
import com.xzx.gc.common.constant.UserEnum;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.utils.RedisUtil;
|
import com.xzx.gc.common.utils.TokenUtil;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.user.UserGatherListParDTO;
|
import com.xzx.gc.model.user.UserInfoVo;
|
import com.xzx.gc.user.mapper.UserGatherInfoMapper;
|
import org.apache.tomcat.jni.Address;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
|
@Service
|
@Transactional
|
public class UserGatherInfoService {
|
|
@Autowired
|
private UserGatherInfoMapper userGatherInfoMapper;
|
|
@Autowired
|
private UserService userService;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Autowired
|
private TokenUtil tokenUtil;
|
|
@Autowired
|
private AddressService addressService;
|
|
@Autowired
|
private OrderService orderService;
|
|
public void add(UserGatherInfo userGatherInfo) {
|
userGatherInfo.setRegistTime(DateUtil.now());
|
userGatherInfo.setDelFlag(Constants.DEL_NOT_FLAG);
|
userGatherInfo.setIsProhibit(false);
|
userGatherInfo.setUserType(CommonEnum.集货员.getValue());
|
userGatherInfo.setRegistType(Convert.toShort(CommonEnum.正常注册用户.getValue()));
|
userGatherInfoMapper.insertSelective(userGatherInfo);
|
}
|
|
public UserGatherInfo findById(String id){
|
return userGatherInfoMapper.selectByPrimaryKey(id);
|
}
|
|
public void updateById(UserGatherInfo userGatherInfo){
|
userGatherInfoMapper.updateByPrimaryKeySelective(userGatherInfo);
|
}
|
|
public UserGatherInfo findByMobileForBidden(String mobile) {
|
UserGatherInfo otherUserInfo=new UserGatherInfo();
|
otherUserInfo.setDelFlag(Constants.DEL_NOT_FLAG);
|
otherUserInfo.setMobilePhone(mobile);
|
return userGatherInfoMapper.selectOne(otherUserInfo);
|
}
|
|
/**
|
* 根据经纬度查找最近500米的集货员
|
* @param lon
|
* @param lat
|
* @return
|
*/
|
public UserGatherInfo findNearestByLocation(String lon,String lat){
|
return userGatherInfoMapper.findNearestByLocation(lon,lat);
|
}
|
|
public List<UserGatherInfo> list(UserGatherListParDTO userGatherListParDTO) {
|
//注意申请表会出现多条记录 需要根据时间排序后取第一条
|
return userGatherInfoMapper.list(userGatherListParDTO);
|
}
|
|
public void deleteById(String id) {
|
|
//删除集货员前判断是否有单
|
int fwzNum = orderService.findFwzNum(id);
|
if(fwzNum>0){
|
throw new RestException("还有未完成的订单");
|
}
|
|
UserGatherInfo userGatherInfo=new UserGatherInfo();
|
userGatherInfo.setUserId(id);
|
userGatherInfo.setDelFlag(Constants.DEL_FLAG);
|
userGatherInfoMapper.updateByPrimaryKeySelective(userGatherInfo);
|
|
UserInfo userInfo=new UserInfo();
|
userInfo.setUserId(id);
|
userInfo.setUserType(CommonEnum.普通用户.getValue());
|
userService.updateById(userInfo);
|
|
//拿货地址是用来判断是否集货员地址的标识
|
List<AddressInfo> allByUserId = addressService.findAllByUserId(id);
|
for (AddressInfo addressInfo : allByUserId) {
|
if(StrUtil.isNotBlank(addressInfo.getReceiveAddress())){
|
addressInfo.setReceiveAddress(null);
|
addressService.updateAllById(addressInfo);
|
}
|
}
|
|
//更新缓存
|
redisUtil.del(RedisKeyConstant.TOKEN+id);
|
|
|
}
|
}
|
