package com.xzx.gc.order.service;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import com.xzx.gc.common.Result;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.dto.gdmap.FindTraceDto;
|
import com.xzx.gc.common.dto.gdmap.TrackDto;
|
import com.xzx.gc.common.dto.gdmap.UploadTraceLocationDto;
|
import com.xzx.gc.common.utils.gdmap.GdTraceUtil;
|
import com.xzx.gc.entity.CityPartner;
|
import com.xzx.gc.entity.CoreUser;
|
import com.xzx.gc.entity.OrderInfo;
|
import com.xzx.gc.model.admin.*;
|
import com.xzx.gc.order.mapper.*;
|
import com.xzx.gc.util.DoubleUtil;
|
import com.xzx.gc.util.SessionUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@Service
|
@Transactional
|
@Slf4j
|
public class CityPartnerService {
|
|
|
@Autowired
|
private CityPartnerMapper cityPartnerMapper;
|
|
@Autowired
|
private SessionUtil platformService;
|
|
@Autowired
|
private PlatformAccountInfoMapper platformAccountInfoMapper;
|
@Autowired
|
private AccountLogMapper accountLogMapper;
|
@Autowired
|
private OtherUserMapper otherUserMapper;
|
|
@Autowired
|
private PlatformAccountLogMapper platformAccountLogMapper;
|
|
@Autowired
|
private OrderMapper orderMapper;
|
|
@Autowired
|
private AccountMapper accountMapper;
|
|
|
@Autowired
|
private FenceMapper fenceMapper;
|
|
|
@Autowired
|
private PartnerAccountMapper partnerAccountMapper;
|
|
|
public CityPartner findByuserId(String userid,String partnerType){
|
CityPartner cityPartner=new CityPartner();
|
cityPartner.setDelFlag(0);
|
cityPartner.setProhibit(false);
|
cityPartner.setUserId(userid);
|
cityPartner.setPartnerType(partnerType);
|
return cityPartnerMapper.selectOne(cityPartner);
|
}
|
|
public List<CityPartner> findByTypeWithDel(String type){
|
CityPartner cityPartner=new CityPartner();
|
cityPartner.setPartnerType(type);
|
return cityPartnerMapper.select(cityPartner);
|
}
|
|
|
public CityPartner findById(Integer id){
|
return cityPartnerMapper.selectByPrimaryKey(id);
|
}
|
|
/**
|
* 根据类型查找 分合伙人和打包站
|
* @param type
|
* @return
|
*/
|
public List<CityPartner> findByType(String type){
|
CityPartner cityPartner=new CityPartner();
|
cityPartner.setDelFlag(Constants.DEL_NOT_FLAG);
|
cityPartner.setPartnerType(type);
|
return cityPartnerMapper.select(cityPartner);
|
}
|
|
|
|
|
|
|
public AreaModel queryAreaLongiLati(AreaModel model) {
|
return cityPartnerMapper.queryAreaLongiLati(model);
|
}
|
|
|
|
|
|
|
|
public List<String> queryPackageIdList(String partnerId) {
|
return cityPartnerMapper.queryPackageIdList(partnerId);
|
}
|
|
|
|
public void insertPartnerLogByPartner(PartnerAccountModel accountModel, String type, String money, String payOrderId,CityPartner partner,String newMoney) {
|
//写入日志
|
PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
|
partnerLog.setAccountId(accountModel.getAccount());
|
partnerLog.setType(type);
|
partnerLog.setCreateTime(DateUtil.now());
|
partnerLog.setRoleName("城市合伙人");
|
partnerLog.setUserName(partner.getPartnerName());
|
partnerLog.setUserPhone(partner.getMobilePhone());
|
if(type.equals("13")){
|
BigDecimal subMoney = new BigDecimal(money).multiply(new BigDecimal("-1")) ;
|
partnerLog.setMoney(DoubleUtil.roundTwo(subMoney.toString()));
|
|
}else{
|
partnerLog.setMoney(money);
|
|
}
|
partnerLog.setAccountMoney(accountModel.getHbb());
|
partnerLog.setHbb(newMoney);
|
partnerLog.setFlowNo(payOrderId);
|
partnerLog.setApproverStatus("1");
|
partnerLog.setDelFlag(0);
|
partnerAccountMapper.addPartnerAccountLog(partnerLog);
|
}
|
|
|
|
public List<String> queryPartnerByCurrent() {
|
//查询合伙人列表
|
List<String> partnerIds = new ArrayList<>();
|
CoreUser user = platformService.getCurrentUser();
|
//CoreUser user = cityPartnerMapper.queryCoreUser();
|
if (user.getId() == 1) {
|
//如果是超管 显示全部投诉订单信息
|
partnerIds = null;
|
} else {
|
//如果是运营管理员 显示
|
if (user.getOrgId() == 10) {
|
partnerIds = null;
|
} else {
|
//合伙人显示 该合伙人和名下合伙人的所有订单。
|
CityPartner partner = cityPartnerMapper.selectByPrimaryKey(user.getId());
|
if(null!=partner){
|
partnerIds.add(user.getId() + "");
|
|
}else{
|
partnerIds = null;
|
}
|
//多级合伙人带拓展
|
//List<String> childPartnerIds = xzxOrderComplaintDao.queryChildPids(user.getId()+"");
|
}
|
|
}
|
return partnerIds;
|
}
|
|
|
|
|
|
|
|
public int addPayInfo1(PayInfoModel model) {
|
return cityPartnerMapper.addPayInfo1(model);
|
}
|
|
|
public void updateAccountPartner(UserAccountModel accountModel) {
|
cityPartnerMapper.updateAccountPartner(accountModel);
|
//return null
|
}
|
|
public void updatePartnerAccount(PartnerAccountModel partnerAccountModel) {
|
partnerAccountMapper.updatePartnerAccount(partnerAccountModel);
|
}
|
|
|
public void insertAccountLogByPartner(UserAccountModel accountModel, String type, BigDecimal money, String payOrderId) {
|
//写入日志
|
AccountLogModel log = new AccountLogModel();
|
log.setAccountId(accountModel.getAccountId());
|
log.setChannelType(type);
|
log.setCreateTime(DateUtil.now());
|
log.setCreateUserId(accountModel.getUserId());
|
log.setNewFixedLimit(DoubleUtil.roundTwo("0"));
|
log.setNewLimit(DoubleUtil.roundTwo("0"));
|
log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getMoney()).add(money).toString()));
|
log.setOldFixedLimit(DoubleUtil.roundTwo("0"));
|
log.setOldLimit(DoubleUtil.roundTwo("0"));
|
log.setOldMoney(DoubleUtil.roundTwo(accountModel.getMoney() + ""));
|
log.setOrderId(payOrderId);
|
accountLogMapper.insertAccountLog(log);
|
}
|
|
|
public void insertAccountLogByHsy(UserAccountModel accountModel, String type, BigDecimal money, String payOrderId) {
|
//写入日志
|
AccountLogModel log = new AccountLogModel();
|
log.setAccountId(accountModel.getAccountId());
|
log.setChannelType(type);
|
log.setCreateTime(DateUtil.now());
|
log.setCreateUserId(accountModel.getUserId());
|
log.setNewFixedLimit(DoubleUtil.roundTwo("0"));
|
log.setNewLimit(DoubleUtil.roundTwo("0"));
|
log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getMoney()).subtract(money).toString()));
|
log.setOldFixedLimit(DoubleUtil.roundTwo("0"));
|
log.setOldLimit(DoubleUtil.roundTwo("0"));
|
log.setOldMoney(DoubleUtil.roundTwo(accountModel.getMoney() + ""));
|
log.setOrderId(payOrderId);
|
accountLogMapper.insertAccountLog(log);
|
}
|
public void insertPartnerAccountLog(PartnerAccountModel accountModel, String type, BigDecimal money, String payOrderId, String packageType) {
|
//写入日志
|
AccountLogModel log = new AccountLogModel();
|
boolean flag = true;
|
if(null!=accountModel.getAddType()&&!"".equals(accountModel.getAddType())){
|
log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getHbb()).add(money).toString()));
|
|
}else{
|
flag = false;
|
log.setNewMoney(DoubleUtil.roundTwo(new BigDecimal(accountModel.getHbb()).subtract(money).toString()));
|
|
}
|
CityPartner partner = cityPartnerMapper.queryEntityByUserIds(accountModel.getUserId());
|
PartnerAccountLogModel partnerLog = new PartnerAccountLogModel();
|
partnerLog.setFlowNo(payOrderId);
|
partnerLog.setCreateTime(DateUtil.now());
|
partnerLog.setApproverStatus("1");
|
if(type.equals("14")){
|
if(!flag){
|
partnerLog.setMoney(DoubleUtil.roundTwo(money.multiply(new BigDecimal("-1")).toString()));
|
|
}else{
|
partnerLog.setMoney(DoubleUtil.roundTwo(money.toString()));
|
|
}
|
|
}else{
|
if(!flag){
|
partnerLog.setMoney(DoubleUtil.roundTwo(money.multiply(new BigDecimal("-1")).toString()));
|
|
}else{
|
partnerLog.setMoney(DoubleUtil.roundTwo(money.toString()));
|
|
}
|
}
|
partnerLog.setHbb(log.getNewMoney());
|
partnerLog.setDelFlag(0);
|
partnerLog.setAccountId(accountModel.getAccount());
|
partnerLog.setAccountMoney(DoubleUtil.roundTwo(accountModel.getHbb() + ""));
|
partnerLog.setUserName(partner.getPartnerName());
|
if (null != packageType) {
|
partnerLog.setType(packageType);
|
|
} else {
|
if(type.equals("9")){
|
partnerLog.setType("12");
|
}else if(type.equals("8")){
|
partnerLog.setType("7");
|
}else{
|
partnerLog.setType("1");
|
}
|
}
|
partnerLog.setUserPhone(partner.getMobilePhone());
|
partnerLog.setRoleName("城市合伙人");
|
partnerAccountMapper.addPartnerAccountLog(partnerLog);
|
|
}
|
|
public String queryAccountByAdminId() {
|
return cityPartnerMapper.queryAccountByAdminId();
|
}
|
|
public int updatePlatformHbb(String hbb) {
|
return platformAccountInfoMapper.updatePlatformHbb(hbb);
|
}
|
public int updatePlatformMoney(String money) {
|
return platformAccountInfoMapper.updatePlatformMoney(money);
|
}
|
public void insertPlatFormLog(PlatformAccountLogModel model) {
|
platformAccountLogMapper.insertPlatFormLog(model);
|
}
|
|
|
|
public List<XzxElectronicFenceModel> queryPartnerFenceList(XzxCityPartnerModel model) {
|
CoreUser user = platformService.getCurrentUser();
|
model.setId(user.getId() + "");
|
List<XzxElectronicFenceModel> list = fenceMapper.queryPartnerFenceList(model);
|
return list;
|
}
|
|
public List<XzxElectronicFenceModel> queryPartnerFenceListByUser(XzxCityPartnerModel model) {
|
CoreUser user = platformService.getCurrentUser();
|
List<String> partnerIds = queryPartnerByCurrent();
|
if (user.getId() == 1) {
|
model.setId(null);
|
} else {
|
model.setId(user.getId() + "");
|
}
|
|
if (null != partnerIds && partnerIds.size() > 0) {
|
model.setPartnerIds(partnerIds.get(0));
|
}
|
List<XzxElectronicFenceModel> list = fenceMapper.queryPartnerFenceListByUser(model);
|
return list;
|
}
|
|
|
public UserAccountModel queryPartnerAccountByUserId(String userId) {
|
return accountMapper.getAccountByUserId(userId);
|
}
|
|
|
public String querySidByPid(String partnerId, String serviceType) {
|
return cityPartnerMapper.querySidByPid(partnerId, serviceType);
|
}
|
|
public List<String> queryTownIdsByPartnerId(String partnerId) {
|
return cityPartnerMapper.queryTownIdsByPartnerId(partnerId);
|
}
|
|
|
public List<Map<String, Object>> queryGaodeByUserId(XzxCityPartnerModel model) {
|
List<Map<String, Object>> list1 = new ArrayList<>();
|
CoreUser user = platformService.getCurrentUser();
|
List<String> partnerIds = queryPartnerByCurrent();
|
CityPartner partner = cityPartnerMapper.queryPartnerById(user.getId());
|
String key = "";
|
if (null != model.getOrderId() && !"".equals(model.getOrderId())) {
|
partner = cityPartnerMapper.queryPartnerKeyByOrder(model.getOrderId());
|
key = partner.getPartnerKey();
|
model.setUserType("2");
|
} else {
|
model.setUserType("6");
|
}
|
if (null != partner) {
|
key = partner.getPartnerKey();
|
} else {
|
UserModel userModel = otherUserMapper.queryUserOtherById(model.getUserId());
|
String partnerId = userModel.getPartnerId();
|
partner = queryById(partnerId);
|
if (null != partner) {
|
key = partner.getPartnerKey();
|
} else {
|
return null;
|
}
|
|
}
|
|
UserModel userModel = cityPartnerMapper.queryUserModelbyPartnerId(partnerIds, model.getUserType(), model.getUserId(), model.getOrderId());
|
if (null != model.getDayTime() && !"".equals(model.getDayTime())) {
|
if (null != model.getDateTime() && !"".equals(model.getDateTime())) {
|
String[] ss = model.getDateTime().split("-");
|
model.setStartTime(model.getDayTime() + " " + ss[0] + ":00");
|
model.setEndTime(model.getDayTime() + " " + ss[1] + ":59");
|
}
|
}
|
Map<String, Object> objMap = new HashMap<>();
|
String terminalId = userModel.getTerminalId();
|
Map map1 = new HashMap();
|
String url = "";
|
String type = null;
|
if (userModel.getUserType().equals("2")) {
|
type = "1";
|
map1.put("tid", terminalId);
|
} else if (userModel.getUserType().equals("6")) {
|
type = "2";
|
}
|
String sid = cityPartnerMapper.querySidByPartnerId(partner.getId() + "", type);
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
map1.put("key", key);
|
map1.put("sid", sid);
|
|
String result1 = "";
|
if (userModel.getUserType().equals("2")) {
|
if (null != model.getOrderId()) {
|
String trid = cityPartnerMapper.queryOrderById(model.getOrderId(), userModel.getUserId(), model.getStartTime(), model.getEndTime());
|
map1.put("trid", trid);
|
FindTraceDto findTraceDto = BeanUtil.mapToBean(map1, FindTraceDto.class, true);
|
Result<List<TrackDto>> trace = GdTraceUtil.findTrace(findTraceDto);
|
if (trace.getCode()==0) {
|
List<TrackDto> dataArr = trace.getData();
|
|
TrackDto mm = dataArr.get(0);
|
objMap.put("distance", mm.getDistance());
|
objMap.put("totalTime", mm.getTime() / (1000 * 60));
|
objMap.put("counts", mm.getCounts());
|
List<UploadTraceLocationDto> pointsList = mm.getPoints();
|
if (null != pointsList && pointsList.size() > 0) {
|
List<Map<String, Object>> propData = new ArrayList<>();
|
String address = "";
|
long t = 0;
|
long tt1 = 0;
|
for (UploadTraceLocationDto pp : pointsList) {
|
Map<String, Object> propMap = new HashMap<>();
|
JSONObject jsonObject = JSONUtil.parseObj(pp.getProps());
|
String addressGD=jsonObject.getStr("address");
|
if (!"".equals(address)) {
|
if (address.equals(addressGD)) {
|
if (tt1 == 0) {
|
tt1 = pp.getLocatetime() - t;
|
} else {
|
tt1 = tt1 + (pp.getLocatetime() - t);
|
}
|
continue;
|
} else {
|
propMap.put("stopTime", tt1 / (1000 * 60));
|
}
|
}
|
|
address = addressGD;
|
propMap.put("address", address);
|
t = pp.getLocatetime();
|
Date date = new Date(t);
|
SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String tt = sdf1.format(date);
|
propMap.put("time", tt);
|
propData.add(propMap);
|
}
|
objMap.put("counts", propData.size());
|
objMap.put("propData", propData);
|
}
|
}
|
} else {
|
|
// List<String> trids = cityPartnerMapper.queryOrderByIds(userModel.getUserId(), model.getStartTime(), model.getEndTime());
|
// for (int i = 0; i < trids.size(); i++) {
|
// map1.put("trid", trids.get(i));
|
// String r1 = HttpClientUtils.doGet(url, map1);
|
// if (i == 0) {
|
// result1 = i + ":" + r1;
|
// } else {
|
// result1 = result1 + " " + i + ":" + r1;
|
// }
|
// }
|
|
}
|
} else if (userModel.getUserType().equals("6")) {
|
try {
|
|
Date date1 = simpleDateFormat.parse(model.getStartTime());
|
Date date2 = simpleDateFormat.parse(model.getEndTime());
|
long ts1 = date1.getTime();
|
long ts2 = date2.getTime();
|
map1.put("starttime", ts1 + "");
|
map1.put("endtime", ts2 + "");
|
map1.put("tid", terminalId);
|
FindTraceDto findTraceDto = BeanUtil.mapToBean(map1, FindTraceDto.class, true);
|
Result<List<TrackDto>> trace = GdTraceUtil.findTrace(findTraceDto);
|
if (trace.getCode()==0) {
|
List<TrackDto> dataArr = trace.getData();
|
TrackDto mm = dataArr.get(0);
|
objMap.put("distance", mm.getDistance());
|
objMap.put("totalTime", mm.getTime() / (1000 * 60));
|
objMap.put("counts", mm.getCounts());
|
List<UploadTraceLocationDto> pointsList = mm.getPoints();
|
if (null != pointsList && pointsList.size() > 0) {
|
List<Map<String, Object>> propData = new ArrayList<>();
|
String address = "";
|
long t = 0;
|
long tt1 = 0;
|
for (UploadTraceLocationDto pp : pointsList) {
|
Map<String, Object> propMap = new HashMap<>();
|
JSONObject jsonObject = JSONUtil.parseObj(pp.getProps());
|
String addressGD=jsonObject.getStr("address");
|
if (!"".equals(address)) {
|
if (address.equals(addressGD)) {
|
if (tt1 == 0) {
|
tt1 = pp.getLocatetime() - t;
|
} else {
|
tt1 = tt1 + (pp.getLocatetime() - t);
|
}
|
continue;
|
} else {
|
propMap.put("stopTime", tt1 / (1000 * 60));
|
}
|
}
|
|
address = addressGD;
|
propMap.put("address", address);
|
t = pp.getLocatetime();
|
Date date = new Date(t);
|
SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String tt = sdf1.format(date);
|
propMap.put("time", tt);
|
propData.add(propMap);
|
}
|
objMap.put("counts", propData.size());
|
objMap.put("propData", propData);
|
}
|
|
}
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
objMap.put("userModel", userModel);
|
list1.add(objMap);
|
|
|
return list1;
|
}
|
|
public CityPartner queryById(String partnerId) {
|
|
return cityPartnerMapper.selectByPrimaryKey(partnerId);
|
}
|
|
|
public List<Map<String, String>> queryOrderByHsy(XzxCityPartnerModel model) {
|
if (null != model.getDayTime() && !"".equals(model.getDayTime())) {
|
if (null != model.getDateTime() && !"".equals(model.getDateTime())) {
|
String[] ss = model.getDateTime().split("-");
|
model.setStartTime(model.getDayTime() + " " + ss[0] + ":00");
|
model.setEndTime(model.getDayTime() + " " + ss[1] + ":59");
|
} else {
|
model.setStartTime(model.getDayTime() + " 00:00:00");
|
model.setEndTime(model.getDayTime() + " 23:59:59");
|
}
|
} else {
|
String t = DateUtil.now();
|
String[] tl = t.split(" ");
|
|
model.setStartTime(tl[0] + " 00:00:00");
|
model.setEndTime(tl[0] + " 23:59:59");
|
}
|
List<Map<String, String>> list = cityPartnerMapper.queryOrderByHsy(model);
|
|
return list;
|
}
|
|
public PartnerAccountModel queryAccountIdByUserId(String userId) {
|
return partnerAccountMapper.queryAccountIdByUserId(userId);
|
}
|
|
|
|
public int deleteUserByPartnerId(String id, String accountId) {
|
cityPartnerMapper.deleteAccount(accountId);
|
return cityPartnerMapper.deleteUserByPartnerId(id);
|
|
}
|
|
public boolean update(CityPartner partner) {
|
return cityPartnerMapper.updateByPrimaryKeySelective(partner)>0?true:false;
|
}
|
|
|
public CityPartner queryById(Long id) {
|
return cityPartnerMapper.selectByPrimaryKey(id);
|
}
|
|
public CityPartner queryPartnerById(long l) {
|
return cityPartnerMapper.queryPartnerById(l);
|
}
|
|
|
public String queryPidByTownId(String orderId) {
|
OrderInfo info = orderMapper.findById(orderId);
|
return cityPartnerMapper.queryPidByTownId(info.getTownId());
|
}
|
|
|
|
|
|
}
|
