|
@@ -4,18 +4,24 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
|
|
import com.baomidou.mybatisplus.plugins.Page;
|
|
|
import com.google.common.collect.Lists;
|
|
|
import com.yh.saas.common.support.util.IdGenerator;
|
|
|
+import com.yh.saas.common.support.util.StringUtils;
|
|
|
+import com.yh.saas.plugin.yiliangyiyun.constant.NumberConstant;
|
|
|
import com.yh.saas.plugin.yiliangyiyun.constant.StatusEnum;
|
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.*;
|
|
|
import com.yh.saas.plugin.yiliangyiyun.entity.view.GoodsSourceView;
|
|
|
+import com.yh.saas.plugin.yiliangyiyun.exception.YException;
|
|
|
+import com.yh.saas.plugin.yiliangyiyun.exception.YExceptionEnum;
|
|
|
import com.yh.saas.plugin.yiliangyiyun.mapper.PublishTaskInfoMapper;
|
|
|
import com.yh.saas.plugin.yiliangyiyun.service.*;
|
|
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
|
|
import com.yh.saas.plugin.yiliangyiyun.util.EntCoordUtil;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
+import java.lang.reflect.Array;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.*;
|
|
|
|
|
@@ -44,14 +50,38 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
private INewsInfoService newsInfoService;
|
|
|
@Autowired
|
|
|
private IRepaymentInfoService repaymentInfoService;
|
|
|
+ @Autowired
|
|
|
+ private IProvinceCityInfoService provinceCityInfoService;
|
|
|
|
|
|
/**
|
|
|
* 地球半径,单位 km
|
|
|
*/
|
|
|
private static final double EARTH_RADIUS = 6378.137;
|
|
|
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 每天0点更新
|
|
|
+ */
|
|
|
+ @Transactional
|
|
|
+ @Scheduled(cron = "0 20 1 * * ?")
|
|
|
+ public void rushTime() {
|
|
|
+ List<PublishTaskInfo> publishTaskInfos = this.selectList(new EntityWrapper<PublishTaskInfo>().eq("delete_flag", "0"));
|
|
|
+ if (!CollectionUtils.isEmpty(publishTaskInfos)) {
|
|
|
+ publishTaskInfos.forEach(publishTaskInfo -> {
|
|
|
+ publishTaskInfo.setRefreshTimes("0");
|
|
|
+ });
|
|
|
+ }
|
|
|
+ List<CargoOwnerInfo> cargoOwnerInfos = cargoOwnerInfoService.selectList(new EntityWrapper<CargoOwnerInfo>().eq("delete_flag", "0"));
|
|
|
+ if (!CollectionUtils.isEmpty(cargoOwnerInfos)) {
|
|
|
+ cargoOwnerInfos.forEach(cargoOwnerInfo -> {
|
|
|
+ cargoOwnerInfo.setRefreshTimes(0L);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 任务列表
|
|
|
+ *
|
|
|
* @param publishTaskInfo
|
|
|
* @return
|
|
|
*/
|
|
@@ -79,17 +109,38 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
|
|
|
/**
|
|
|
* 货源列表
|
|
|
+ *
|
|
|
* @param publishTaskInfo
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public Page<GoodsSourceView> selectGoodsSource(PublishTaskInfo publishTaskInfo) {
|
|
|
+ public Page<PublishTaskInfo> selectGoodsSource(PublishTaskInfo publishTaskInfo) {
|
|
|
Map<String, Object> pageView = new HashMap<>();
|
|
|
pageView.put("startRecord", (publishTaskInfo.getCurrentPage() - 1)
|
|
|
* publishTaskInfo.getPageSize());
|
|
|
+ //自定义装货区
|
|
|
+ if (!StringUtils.isEmpty(publishTaskInfo.getLoadingPlace())) {
|
|
|
+ String loading = publishTaskInfo.getLoadingPlace();
|
|
|
+ boolean loadingt = loading.contains(",");
|
|
|
+ if (loadingt) {
|
|
|
+ List<String> loadingList = Arrays.asList(loading.split(","));
|
|
|
+ pageView.put("loadingList", loadingList);
|
|
|
+ } else {
|
|
|
+ pageView.put("loadingPlace", publishTaskInfo.getLoadingPlace());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //自定义卸货区
|
|
|
+ if (!StringUtils.isEmpty(publishTaskInfo.getUnLoadingPlace())) {
|
|
|
+ String unloading = publishTaskInfo.getUnLoadingPlace();
|
|
|
+ boolean unloadingt = unloading.contains(",");
|
|
|
+ if (unloadingt) {
|
|
|
+ List<String> unloadingList = Arrays.asList(unloading.split(","));
|
|
|
+ pageView.put("unloadingList", unloadingList);
|
|
|
+ } else {
|
|
|
+ pageView.put("unLoadingPlace", publishTaskInfo.getUnLoadingPlace());
|
|
|
+ }
|
|
|
+ }
|
|
|
//用户id
|
|
|
- pageView.put("loadingPlace", publishTaskInfo.getLoadingPlace());
|
|
|
- pageView.put("unLoadingPlace", publishTaskInfo.getUnLoadingPlace());
|
|
|
pageView.put("loadingPlaceCity", publishTaskInfo.getLoadingPlaceCity());
|
|
|
pageView.put("unLoadingPlaceCity", publishTaskInfo.getUnLoadingPlaceCity());
|
|
|
pageView.put("searchKeyWord", publishTaskInfo.getSearchKeyWord());
|
|
@@ -98,28 +149,24 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
pageView.put("currentPage", publishTaskInfo.getCurrentPage());
|
|
|
// 查询货源总数
|
|
|
Integer dataCount = baseMapper.getCounstByCondition(pageView);
|
|
|
- Page<GoodsSourceView> page = new Page<>();
|
|
|
- //货源列表
|
|
|
- List<GoodsSourceView> goodsSourceViews = new ArrayList<>();
|
|
|
- //新增货源对象
|
|
|
- GoodsSourceView goodsSourceView = new GoodsSourceView();
|
|
|
+ Page<PublishTaskInfo> page = new Page<>();
|
|
|
//推荐货源列表
|
|
|
- if("1".equals(publishTaskInfo.getSearchKeyWord())){
|
|
|
+ if ("1".equals(publishTaskInfo.getSearchKeyWord())) {
|
|
|
List<PublishTaskInfo> dataList = baseMapper.getListsByCondition(pageView);
|
|
|
- goodsSourceView.setPublishTaskInfoList(dataList);
|
|
|
+ page.setRecords(dataList == null ? Lists.newArrayList() : dataList);
|
|
|
}
|
|
|
//按时间排序货源列表
|
|
|
- else if("2".equals(publishTaskInfo.getSearchKeyWord())) {
|
|
|
+ else if ("2".equals(publishTaskInfo.getSearchKeyWord())) {
|
|
|
List<PublishTaskInfo> dataList = baseMapper.getListByTimeCondition(pageView);
|
|
|
- goodsSourceView.setPublishTaskInfoList(dataList);
|
|
|
+ page.setRecords(dataList == null ? Lists.newArrayList() : dataList);
|
|
|
}
|
|
|
//按距离排序货源列表
|
|
|
- else{
|
|
|
+ else {
|
|
|
List<PublishTaskInfo> dataList = baseMapper.getListsByDistanceCondition(pageView);
|
|
|
- if("3".equals(publishTaskInfo.getSearchKeyWord())){
|
|
|
- if(!CollectionUtils.isEmpty(dataList)){
|
|
|
+ if ("3".equals(publishTaskInfo.getSearchKeyWord())) {
|
|
|
+ if (!CollectionUtils.isEmpty(dataList)) {
|
|
|
//查询发货地经纬度
|
|
|
- for(int i = 0; i < dataList.size(); i++){
|
|
|
+ for (int i = 0; i < dataList.size(); i++) {
|
|
|
PublishTaskInfo publishTaskInfo1 = dataList.get(i);
|
|
|
//发货地经纬度
|
|
|
double lat2 = Math.toRadians(Double.valueOf(publishTaskInfo1.getSendLatitude()));
|
|
@@ -135,30 +182,86 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
double s = 2 * Math.asin(Math.sqrt(Math.pow(Math.sin(a / 2), 2) +
|
|
|
Math.cos(lat1) * Math.cos(lat2) * Math.pow(Math.sin(b / 2), 2)));
|
|
|
// 弧长乘地球半径, 返回单位: 千米
|
|
|
- s = s * EARTH_RADIUS;
|
|
|
+ s = s * EARTH_RADIUS;
|
|
|
publishTaskInfo1.setCargoDistance(Math.floor(s));
|
|
|
}
|
|
|
dataList.sort(Comparator.comparing(PublishTaskInfo::getCargoDistance));
|
|
|
}
|
|
|
+ page.setRecords(dataList == null ? Lists.newArrayList() : dataList);
|
|
|
}
|
|
|
- //新增货源对象
|
|
|
- goodsSourceView.setPublishTaskInfoList(dataList);
|
|
|
}
|
|
|
+ page.setTotal(dataCount == null ? 0 : dataCount);
|
|
|
+ page.setCurrent(publishTaskInfo.getCurrentPage());
|
|
|
+ page.setSize(publishTaskInfo.getPageSize());
|
|
|
+ return page;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 周边信息列表
|
|
|
+ *
|
|
|
+ * @param publishTaskInfo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Page<PublishTaskInfo> selectPeripheralInfo(PublishTaskInfo publishTaskInfo) {
|
|
|
+ Map<String, Object> pageView = new HashMap<>();
|
|
|
+ pageView.put("startRecord", (publishTaskInfo.getCurrentPage() - 1)
|
|
|
+ * publishTaskInfo.getPageSize());
|
|
|
+ //用户id
|
|
|
+ pageView.put("loadingPlaceCity", publishTaskInfo.getLoadingPlaceCity());
|
|
|
+ pageView.put("searchType", publishTaskInfo.getSearchType());
|
|
|
+ pageView.put("pageSize", publishTaskInfo.getPageSize());
|
|
|
+ pageView.put("currentPage", publishTaskInfo.getCurrentPage());
|
|
|
+ //所有周边信息列表
|
|
|
+ List<PublishTaskInfo> dataList1 = baseMapper.getAllListsByCondition(pageView);
|
|
|
//周边信息列表
|
|
|
List<PublishTaskInfo> publishTaskInfoList = new ArrayList<>();
|
|
|
- //所有货源列表
|
|
|
- List<PublishTaskInfo> dataList1 = baseMapper.getAllListsByCondition(pageView);
|
|
|
- if (!CollectionUtils.isEmpty(dataList1)){
|
|
|
+ if (!CollectionUtils.isEmpty(dataList1)) {
|
|
|
+ if (!StringUtils.isEmpty(publishTaskInfo.getLoadingPlaceCity())) {
|
|
|
//查询发货地经纬度
|
|
|
- for(int i = 0; i < dataList1.size(); i++){
|
|
|
+ for (int i = 0; i < dataList1.size(); i++) {
|
|
|
PublishTaskInfo publishTaskInfo1 = dataList1.get(i);
|
|
|
//发货地经纬度
|
|
|
double lng2 = Math.toRadians(Double.valueOf(publishTaskInfo1.getSendLongitude()));
|
|
|
double lat2 = Math.toRadians(Double.valueOf(publishTaskInfo1.getSendLatitude()));
|
|
|
//根据装货城市获取经纬度
|
|
|
- String str = EntCoordUtil.getCoordinate(publishTaskInfo.getLoadingPlaceCity());
|
|
|
+ String str = EntCoordUtil.getCoordinate(publishTaskInfo.getLoadingPlaceCity());
|
|
|
+ String str1 = str.substring(0, str.indexOf(","));//经度
|
|
|
+ String str2 = str.substring(str1.length() + 1, str.length());//纬度
|
|
|
+
|
|
|
+ //装货地经纬度
|
|
|
+ double lng1 = Math.toRadians(Double.valueOf(str1));
|
|
|
+ double lat1 = Math.toRadians(Double.valueOf(str2));
|
|
|
+ // 纬度之差
|
|
|
+ double a = lat1 - lat2;
|
|
|
+ // 经度之差
|
|
|
+ double b = lng1 - lng2;
|
|
|
+ // 计算两点距离的公式
|
|
|
+ double s = 2 * Math.asin(Math.sqrt(Math.pow(Math.sin(a / 2), 2) +
|
|
|
+ Math.cos(lat1) * Math.cos(lat2) * Math.pow(Math.sin(b / 2), 2)));
|
|
|
+ // 弧长乘地球半径, 返回单位: 千米
|
|
|
+ s = s * EARTH_RADIUS;
|
|
|
+ if (s <= 300) {
|
|
|
+ //货距小于300公里,放入周边信息列表
|
|
|
+ publishTaskInfo1.setCargoDistance(Math.floor(s));
|
|
|
+ publishTaskInfoList.add(publishTaskInfo1);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ //查询发货地经纬度
|
|
|
+ for (int i = 0; i < dataList1.size(); i++) {
|
|
|
+ PublishTaskInfo publishTaskInfo1 = dataList1.get(i);
|
|
|
+ //发货地经纬度
|
|
|
+ double lng2 = Math.toRadians(Double.valueOf(publishTaskInfo1.getSendLongitude()));
|
|
|
+ double lat2 = Math.toRadians(Double.valueOf(publishTaskInfo1.getSendLatitude()));
|
|
|
+ //根据省名查询省会城市
|
|
|
+ ProvinceCityInfo provinceCityInfo = provinceCityInfoService.selectOne(new EntityWrapper<ProvinceCityInfo>()
|
|
|
+ .like("province", publishTaskInfo.getLoadingPlace()));
|
|
|
+ //根据省会城市获取经纬度
|
|
|
+ String str = EntCoordUtil.getCoordinate(provinceCityInfo.getCity());
|
|
|
String str1 = str.substring(0, str.indexOf(","));//经度
|
|
|
- String str2 = str.substring(str1.length()+1, str.length());//纬度
|
|
|
+ String str2 = str.substring(str1.length() + 1, str.length());//纬度
|
|
|
+
|
|
|
//装货地经纬度
|
|
|
double lng1 = Math.toRadians(Double.valueOf(str1));
|
|
|
double lat1 = Math.toRadians(Double.valueOf(str2));
|
|
@@ -170,22 +273,20 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
double s = 2 * Math.asin(Math.sqrt(Math.pow(Math.sin(a / 2), 2) +
|
|
|
Math.cos(lat1) * Math.cos(lat2) * Math.pow(Math.sin(b / 2), 2)));
|
|
|
// 弧长乘地球半径, 返回单位: 千米
|
|
|
- s = s * EARTH_RADIUS;
|
|
|
- if (s <= 300){
|
|
|
+ s = s * EARTH_RADIUS;
|
|
|
+ if (s <= 300) {
|
|
|
//货距小于300公里,放入周边信息列表
|
|
|
publishTaskInfo1.setCargoDistance(Math.floor(s));
|
|
|
publishTaskInfoList.add(publishTaskInfo1);
|
|
|
}
|
|
|
}
|
|
|
- //按货距排序,倒序
|
|
|
- publishTaskInfoList.sort(Comparator.comparing(PublishTaskInfo::getCargoDistance));
|
|
|
- //新增周边信息列表
|
|
|
- goodsSourceView.setPublishTaskInfoLists(publishTaskInfoList);
|
|
|
}
|
|
|
- //将货源对象放入货源列表
|
|
|
- goodsSourceViews.add(goodsSourceView);
|
|
|
- page.setRecords(goodsSourceViews == null ? Lists.newArrayList() : goodsSourceViews);
|
|
|
- page.setTotal(dataCount == null ? publishTaskInfoList.size() : dataCount + publishTaskInfoList.size());
|
|
|
+ //按货距排序,倒序
|
|
|
+ publishTaskInfoList.sort(Comparator.comparing(PublishTaskInfo::getCargoDistance));
|
|
|
+ }
|
|
|
+ Page<PublishTaskInfo> page = new Page<>();
|
|
|
+ page.setRecords(publishTaskInfoList == null ? Lists.newArrayList() : publishTaskInfoList);
|
|
|
+ page.setTotal(publishTaskInfoList.size() == 0 ? 0 : publishTaskInfoList.size());
|
|
|
page.setCurrent(publishTaskInfo.getCurrentPage());
|
|
|
page.setSize(publishTaskInfo.getPageSize());
|
|
|
return page;
|
|
@@ -209,6 +310,7 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
|
|
|
/**
|
|
|
* 发布任务
|
|
|
+ *
|
|
|
* @param publishTaskInfo
|
|
|
* @return
|
|
|
*/
|
|
@@ -222,20 +324,20 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
String date = f.format(new Date(System.currentTimeMillis()));
|
|
|
//查询当天任务集合
|
|
|
List<PublishTaskInfo> publishTaskInfoList = this.selectPublishTaskInfoList();//调用Service中的方法
|
|
|
- if(publishTaskInfoList.size() > 0){
|
|
|
+ if (publishTaskInfoList.size() > 0) {
|
|
|
//取第一条数据的编号
|
|
|
String n = publishTaskInfoList.get(0).getTaskNo();
|
|
|
//截取编号后6位
|
|
|
int intNumber = Integer.parseInt(n.substring(10));
|
|
|
intNumber++;
|
|
|
String number = String.valueOf(intNumber);
|
|
|
- for (int i = 0; i < 6; i++){
|
|
|
+ for (int i = 0; i < 6; i++) {
|
|
|
number = number.length() < 6 ? "0" + number : number;
|
|
|
}
|
|
|
//编号自增
|
|
|
number = "YS" + date + number;
|
|
|
publishTaskInfo.setTaskNo(number);
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
//如果当天数据为空,生成第一条数据
|
|
|
String number = "YS" + date + "000001";
|
|
|
publishTaskInfo.setTaskNo(number);
|
|
@@ -254,22 +356,22 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
|
|
|
/**
|
|
|
* 编辑任务
|
|
|
+ *
|
|
|
* @param publishTaskInfo
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
public String editTask(PublishTaskInfo publishTaskInfo) {
|
|
|
- //查询发布任务
|
|
|
- PublishTaskInfo publishTaskInfo1 = this.selectById(publishTaskInfo.getId());
|
|
|
//除审核中状态其余可编辑
|
|
|
- if(publishTaskInfo1 != null && publishTaskInfo1.getStatusKey() != "1") {
|
|
|
- this.updateById(publishTaskInfo1);
|
|
|
+ if (publishTaskInfo != null) {
|
|
|
+ this.updateById(publishTaskInfo);
|
|
|
}
|
|
|
return "OK";
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 查看任务
|
|
|
+ *
|
|
|
* @param id
|
|
|
* @return
|
|
|
*/
|
|
@@ -279,15 +381,15 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
PublishTaskInfo publishTaskInfo = this.selectById(id);
|
|
|
//查询货主姓名
|
|
|
CargoOwnerInfo cargoOwnerInfo = cargoOwnerInfoService.selectOne(new EntityWrapper<CargoOwnerInfo>()
|
|
|
- .eq("common_id",publishTaskInfo.getCommonId()));
|
|
|
- if (cargoOwnerInfo != null){
|
|
|
+ .eq("common_id", publishTaskInfo.getCommonId()));
|
|
|
+ if (cargoOwnerInfo != null) {
|
|
|
publishTaskInfo.setCargoOwnerName(cargoOwnerInfo.getName());
|
|
|
publishTaskInfo.setCargoOwnerPhone(cargoOwnerInfo.getPhone());
|
|
|
}
|
|
|
//查询货主头像
|
|
|
CommonUser commonUser = commonUserService.selectOne(new EntityWrapper<CommonUser>()
|
|
|
- .eq("id",publishTaskInfo.getCommonId()));
|
|
|
- if (commonUser != null){
|
|
|
+ .eq("id", publishTaskInfo.getCommonId()));
|
|
|
+ if (commonUser != null) {
|
|
|
publishTaskInfo.setCargoOwnerPortrait(commonUser.getAvatarUrl());
|
|
|
}
|
|
|
return publishTaskInfo;
|
|
@@ -295,6 +397,7 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
|
|
|
/**
|
|
|
* 删除任务
|
|
|
+ *
|
|
|
* @param id
|
|
|
* @return
|
|
|
*/
|
|
@@ -306,6 +409,7 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
|
|
|
/**
|
|
|
* 显示隐藏
|
|
|
+ *
|
|
|
* @param id
|
|
|
* @return
|
|
|
*/
|
|
@@ -324,13 +428,44 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 刷新
|
|
|
+ *
|
|
|
+ * @param publishTaskInfo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public String refresh(PublishTaskInfo publishTaskInfo) {
|
|
|
+ //查询发布任务
|
|
|
+ PublishTaskInfo publishTaskInfo1 = this.seeTask(publishTaskInfo.getId());
|
|
|
+ if (publishTaskInfo1 != null) {
|
|
|
+ //将此发布任务刷新次数变为1
|
|
|
+ publishTaskInfo1.setRefreshTimes("1");
|
|
|
+ this.updateById(publishTaskInfo1);
|
|
|
+ }
|
|
|
+ //查询货主
|
|
|
+ CargoOwnerInfo cargoOwnerInfo = cargoOwnerInfoService.selectOne(new EntityWrapper<CargoOwnerInfo>()
|
|
|
+ .eq(CargoOwnerInfo.QueryFiles.COMMON_ID, publishTaskInfo.getCommonId())
|
|
|
+ .eq(CargoOwnerInfo.QueryFiles.DELETE_FLAG, NumberConstant.CONSTANT0));
|
|
|
+ if (cargoOwnerInfo.getRefreshTimes() < 3) {
|
|
|
+ //如果货主今日刷新次数小于3次,次数+1
|
|
|
+ Long number = cargoOwnerInfo.getRefreshTimes() + 1;
|
|
|
+ cargoOwnerInfo.setRefreshTimes(number);
|
|
|
+ cargoOwnerInfoService.updateById(cargoOwnerInfo);
|
|
|
+ } else {
|
|
|
+ throw new YException(YExceptionEnum.REFRESH_TIMES_UPPER_LIMIT);
|
|
|
+ }
|
|
|
+ return "ok";
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 抢单
|
|
|
+ *
|
|
|
* @param publishTaskInfo
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public String addOrder(PublishTaskInfo publishTaskInfo){
|
|
|
+ public String addOrder(PublishTaskInfo publishTaskInfo) {
|
|
|
//新增订单信息
|
|
|
OrderInfo orderInfo = new OrderInfo();
|
|
|
orderInfo.setId(IdGenerator.generateUUID());
|
|
@@ -341,20 +476,20 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
String date = f.format(new Date(System.currentTimeMillis()));
|
|
|
//查询订单集合
|
|
|
List<OrderInfo> orderInfoList = orderInfoService.selectOrderInfoList();//调用Service中的方法
|
|
|
- if(orderInfoList.size() > 0){
|
|
|
+ if (orderInfoList.size() > 0) {
|
|
|
//取第一条数据的编号
|
|
|
String n = orderInfoList.get(0).getOrderNo();
|
|
|
//截取编号后6位
|
|
|
int intNumber = Integer.parseInt(n.substring(10));
|
|
|
intNumber++;
|
|
|
String orderNumber = String.valueOf(intNumber);
|
|
|
- for (int i = 0; i < 6; i++){
|
|
|
- orderNumber = orderNumber.length() < 6 ? "0" + orderNumber : orderNumber;
|
|
|
+ for (int i = 0; i < 6; i++) {
|
|
|
+ orderNumber = orderNumber.length() < 6 ? "0" + orderNumber : orderNumber;
|
|
|
}
|
|
|
- //编号自增
|
|
|
- orderNumber = "CY" + date + orderNumber;
|
|
|
- orderInfo.setOrderNo(orderNumber);
|
|
|
- }else{
|
|
|
+ //编号自增
|
|
|
+ orderNumber = "CY" + date + orderNumber;
|
|
|
+ orderInfo.setOrderNo(orderNumber);
|
|
|
+ } else {
|
|
|
//如果当天数据为空,生成第一条数据
|
|
|
String orderNumber = "CY" + date + "000001";
|
|
|
orderInfo.setOrderNo(orderNumber);
|
|
@@ -380,13 +515,13 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
orderInfo.setOrderStatus(StatusEnum.OWNER_CONFIRMED.getName());
|
|
|
orderInfo.setCargoOwnerStatusKey(StatusEnum.OWNER_PENDING_STATEMENT.getFlag());
|
|
|
orderInfo.setCargoOwnerStatus(StatusEnum.OWNER_PENDING_STATEMENT.getName());
|
|
|
- boolean one = orderInfoService.insert(orderInfo);
|
|
|
+ boolean one = orderInfoService.insert(orderInfo);
|
|
|
|
|
|
// 向货主发送信息
|
|
|
NewsInfo newsInfo = new NewsInfo();
|
|
|
newsInfo.setCrtCommonId(orderInfo.getCommonId());
|
|
|
newsInfo.setReCommonId(orderInfo.getCargoCommonId());
|
|
|
- newsInfo.setNewsContent("司机 "+orderInfo.getDriverName()+"师傅 已接单,订单编号"+orderInfo.getOrderNo()+"。");
|
|
|
+ newsInfo.setNewsContent("司机 " + orderInfo.getDriverName() + "师傅 已接单,订单编号" + orderInfo.getOrderNo() + "。");
|
|
|
newsInfo.setNumber(orderInfo.getOrderNo());
|
|
|
newsInfo.setBussId(orderInfo.getId());
|
|
|
newsInfo.setNewsTypeKey("2");
|
|
@@ -408,7 +543,7 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
repaymentInfo.setId(IdGenerator.generateUUID());
|
|
|
repaymentInfo.setOrderId(orderInfo.getId());
|
|
|
boolean four = repaymentInfoService.insert(repaymentInfo);
|
|
|
- if( one && two && tre && four){
|
|
|
+ if (one && two && tre && four) {
|
|
|
return "ok";
|
|
|
} else {
|
|
|
return "NG";
|
|
@@ -416,8 +551,6 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
-
|
|
|
/**
|
|
|
* 审核
|
|
|
*
|
|
@@ -426,7 +559,7 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
*/
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public String examine(PublishTaskInfo publishTaskInfo){
|
|
|
+ public String examine(PublishTaskInfo publishTaskInfo) {
|
|
|
//查询列表
|
|
|
PublishTaskInfo publishTaskInfo1 = this.selectById(publishTaskInfo.getId());
|
|
|
|
|
@@ -449,7 +582,7 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
// webSocket.sendOneMessage(messageDO);
|
|
|
}
|
|
|
// 驳回
|
|
|
- else if("2".equals(publishTaskInfo.getFlag())){
|
|
|
+ else if ("2".equals(publishTaskInfo.getFlag())) {
|
|
|
publishTaskInfo1.setStatusKey(StatusEnum.IDENTITY_FAILED.getFlag());
|
|
|
publishTaskInfo1.setStatus(StatusEnum.IDENTITY_FAILED.getName());
|
|
|
// geTuiUtils.pushByCid("驳回通知", "您的司机认证申请已被驳回", commonUser.getId());
|
|
@@ -465,7 +598,6 @@ public class PublishTaskInfoServiceImpl extends ServiceImpl<PublishTaskInfoMappe
|
|
|
// messageDO.setPath("XXXXX");
|
|
|
// webSocket.sendOneMessage(messageDO);
|
|
|
}
|
|
|
-
|
|
|
//更改信息
|
|
|
this.updateById(publishTaskInfo1);
|
|
|
return "OK";
|