| | |
| | | import com.baomidou.mybatisplus.service.impl.ServiceImpl; |
| | | import com.supersavedriving.user.core.util.ToolUtil; |
| | | import com.supersavedriving.user.modular.system.dao.OrderMapper; |
| | | import com.supersavedriving.user.modular.system.dao.TCompanyMapper; |
| | | import com.supersavedriving.user.modular.system.model.*; |
| | | import com.supersavedriving.user.modular.system.service.*; |
| | | import com.supersavedriving.user.modular.system.util.*; |
| | |
| | | import com.supersavedriving.user.modular.system.util.qianyuntong.OrderUtil; |
| | | import com.supersavedriving.user.modular.system.util.qianyuntong.model.*; |
| | | import com.supersavedriving.user.modular.system.warpper.*; |
| | | import org.redisson.api.RLock; |
| | | import org.redisson.api.RedissonClient; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | |
| | | import java.math.BigDecimal; |
| | | import java.math.RoundingMode; |
| | | import java.text.SimpleDateFormat; |
| | | import java.time.LocalDate; |
| | | import java.time.LocalDateTime; |
| | | import java.time.format.DateTimeFormatter; |
| | | import java.util.*; |
| | | import java.util.concurrent.LinkedBlockingQueue; |
| | | import java.util.concurrent.ThreadPoolExecutor; |
| | |
| | | private IRevenueService revenueService; |
| | | |
| | | @Autowired |
| | | private IAgentService agentService; |
| | | |
| | | @Autowired |
| | | private IPlatformRechargeRecordService platformRechargeRecordService; |
| | | |
| | | @Autowired |
| | | private IDivisionRecordService divisionRecordService; |
| | | |
| | | @Autowired |
| | |
| | | |
| | | @Value("${callbackPath}") |
| | | private String callbackPath;//支付回调网关地址 |
| | | |
| | | @Autowired |
| | | private TCompanyMapper companyMapper; |
| | | |
| | | |
| | | |
| | |
| | | boolean insert = this.insert(order); |
| | | if(null != order.getDriverId()){ |
| | | Driver driver = driverService.selectById(order.getDriverId()); |
| | | TCompany company = companyMapper.selectById(order.getDriverId()); |
| | | BranchOffice branchOffice = branchOfficeService.selectById(order.getBranchOfficeId()); |
| | | //调三方订单中心创建行程单 |
| | | CreateTravelItineraryRequest request = new CreateTravelItineraryRequest(); |
| | | request.setOrderNo("DJ" + order.getId()); |
| | | request.setCustomerId(appUser.getOnconUUID()); |
| | | request.setDriverId(driver.getEmpId().toString()); |
| | | request.setSupplierShopId(company.getEnterCode()); |
| | | request.setSupplierShopId(branchOffice.getEnterCode()); |
| | | request.setServiceType(2); |
| | | String travelItinerary = OrderUtil.createTravelItinerary(request); |
| | | order.setTravelId(travelItinerary); |
| | |
| | | ModifyTravelItineraryRequest request = new ModifyTravelItineraryRequest(); |
| | | request.setOrderId(order.getTravelId()); |
| | | request.setStatus(getState(order.getState())); |
| | | TCompany company = companyMapper.selectById(driver.getBranchOfficeId()); |
| | | BranchOffice branchOffice = branchOfficeService.selectById(order.getBranchOfficeId()); |
| | | request.setDriverId(driver.getEmpId().toString()); |
| | | request.setSupplierShopId(company.getEnterCode()); |
| | | request.setSupplierShopId(branchOffice.getEnterCode()); |
| | | OrderUtil.modifyTravelItinerary(request); |
| | | } |
| | | |
| | |
| | | ModifyTravelItineraryRequest request = new ModifyTravelItineraryRequest(); |
| | | request.setOrderId(order.getTravelId()); |
| | | request.setStatus(getState(order.getState())); |
| | | TCompany company = companyMapper.selectById(driver.getBranchOfficeId()); |
| | | BranchOffice branchOffice = branchOfficeService.selectById(order.getBranchOfficeId()); |
| | | request.setDriverId(driver.getEmpId().toString()); |
| | | request.setSupplierShopId(company.getEnterCode()); |
| | | request.setSupplierShopId(branchOffice.getEnterCode()); |
| | | OrderUtil.modifyTravelItinerary(request); |
| | | } |
| | | |