Commit 10806ffb authored by Allen Chen's avatar Allen Chen

commit

parent 91b8e2e4
...@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject; ...@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletRequest; import jakarta.servlet.http.HttpServletRequest;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
...@@ -15,6 +16,9 @@ import org.ta.pddserver.model.api.response.*; ...@@ -15,6 +16,9 @@ import org.ta.pddserver.model.api.response.*;
import org.ta.pddserver.model.enums.ErrorEnum; import org.ta.pddserver.model.enums.ErrorEnum;
import org.ta.pddserver.model.enums.StatusEnum; import org.ta.pddserver.model.enums.StatusEnum;
import org.ta.pddserver.model.pddjy.request.*; import org.ta.pddserver.model.pddjy.request.*;
import org.ta.pddserver.model.pddlg.common.TraceObject;
import org.ta.pddserver.model.pddlg.request.PddLogisticsCoTrackNotifyRequest;
import org.ta.pddserver.model.pddlg.response.PddLogisticsCoTrackNotifyResponse;
import org.ta.pddserver.service.impl.*; import org.ta.pddserver.service.impl.*;
import org.ta.pddserver.utils.*; import org.ta.pddserver.utils.*;
...@@ -56,6 +60,10 @@ public class PddLocalController { ...@@ -56,6 +60,10 @@ public class PddLocalController {
@Resource @Resource
private CollectOrderImpl collectOrderImpl; private CollectOrderImpl collectOrderImpl;
@Autowired
private CollectOrderDetailImpl collectOrderDetailImpl;
@Autowired
private TraceObjectImpl traceObjectImpl;
/*集运单列表*/ /*集运单列表*/
@PostMapping("/logOrderList") @PostMapping("/logOrderList")
...@@ -86,13 +94,12 @@ public class PddLocalController { ...@@ -86,13 +94,12 @@ public class PddLocalController {
/*待拆包查询*/ /*待拆包查询*/
@PostMapping("/packageScan") @PostMapping("/packageScan")
public Map<String, Object> packageScan(HttpServletRequest request, @RequestBody MailNoRequest mailNoRequest) { public Map<String, Object> packageScan(HttpServletRequest request, @RequestBody MailNoRequest mailNoRequest) {
LogOrderMailDetailEntity mailDetailEntity = logOrderMailDetailImpl.getByMailNo(mailNoRequest.getMailNo()); List<LogOrderMailDetailEntity> list = logOrderMailDetailImpl.getListByCode(mailNoRequest.getMailNo());
if (mailDetailEntity == null) { if (list.isEmpty()) {
return JsonResponse.generateLocalCommonFailedResponse("-1", "信息获取失败,请检查上传信息"); return JsonResponse.generateLocalCommonFailedResponse("-1", "信息获取失败,请检查上传信息");
} }
LogOrderEntity logOrderEntity = logOrderImpl.getByOrderCode(mailDetailEntity.getLogisticsOrderCode()); LogOrderEntity logOrderEntity = logOrderImpl.getByOrderCode(list.get(0).getLogisticsOrderCode());
List<LogOrderMailDetailEntity> list = logOrderMailDetailImpl.getListByCode(logOrderEntity.getLogisticsOrderCode());
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
map.put("logOrder", logOrderEntity); map.put("logOrder", logOrderEntity);
...@@ -101,6 +108,59 @@ public class PddLocalController { ...@@ -101,6 +108,59 @@ public class PddLocalController {
return JsonResponse.generateLocalCommonSuccessResponse(map); return JsonResponse.generateLocalCommonSuccessResponse(map);
} }
/*待拆包列表*/
@PostMapping("/traceObject")
public JSONObject traceObject(HttpServletRequest request, @RequestBody TraceObjectRequest traceObjectRequest) {
TraceObjectEntity traceObject = new TraceObjectEntity();
traceObject.setTrackingNumber(traceObjectRequest.getTrackingNumber());
traceObject.setTrackingOrderNo(traceObjectRequest.getTrackingOrderNo());
traceObject.setId(traceObjectRequest.getId());
traceObject.setStatusCode(traceObjectRequest.getStatusCode());
traceObject.setDescription(traceObjectRequest.getDescription());
traceObject.setOperationTime(traceObjectRequest.getOperationTime());
traceObject.setTransferFlag(traceObjectRequest.getTransferFlag());
traceObject.setTransferNo(traceObjectRequest.getTransferNo());
traceObject.setTransferPartnerId(traceObjectRequest.getTransferPartnerId());
traceObject.setTimeZone(traceObjectRequest.getTimeZone());
traceObject.setSiteName(traceObjectRequest.getSiteName());
traceObject.setSiteType(traceObjectRequest.getSiteType());
traceObject.setSiteNo(traceObjectRequest.getSiteNo());
traceObject.setNextSiteName(traceObjectRequest.getNextSiteName());
traceObject.setNextSiteNo(traceObjectRequest.getNextSiteNo());
traceObject.setFailReason(traceObjectRequest.getFailReason());
traceObject.setWeight(traceObjectRequest.getWeight());
traceObject.setCountry(traceObjectRequest.getCountry());
traceObject.setCity(traceObjectRequest.getCity());
traceObject.setProvince(traceObjectRequest.getProvince());
traceObject.setDistrict(traceObjectRequest.getDistrict());
traceObject.setContact(traceObjectRequest.getContact());
traceObject.setContactInfo(traceObjectRequest.getContactInfo());
traceObject.setSignerName(traceObjectRequest.getSignerName());
traceObject.setAddress(traceObjectRequest.getAddress());
traceObject.setRemark(traceObjectRequest.getRemark());
traceObjectImpl.save(traceObject);
//推送pdd
PddLogisticsCoTrackNotifyRequest requests = new PddLogisticsCoTrackNotifyRequest();
requests.setClient_id(PddAPIConfig.CLIENT_ID);
requests.setShip_id(PddAPIConfig.SHIP_ID);
requests.setTarget_client_id(PddAPIConfig.CLIENT_ID);
requests.setTimestamp(System.currentTimeMillis() / 1000);
PddLogisticsCoTrackNotifyRequest.DataObject dataObject = getDataObject(traceObjectRequest.getTrackingNumber());
requests.setDataObject(dataObject);
requests.encodeData();
requests.setSign(PddSignTool.generateSign(requests, PddAPIConfig.CLIENT_SECRET));
log.info("requestModel:{}", JSON.toJSONString(requests));
String resp = PddHttpTool.sendJsonPost(requests);
log.info("resp = {}", resp);
PddLogisticsCoTrackNotifyResponse response = JSON.parseObject(resp, PddLogisticsCoTrackNotifyResponse.class);
log.info("response = {}", JSON.toJSONString(response));
return JsonResponse.generateLocalCommonSuccessResponse(true);
}
/*出库列表*/ /*出库列表*/
@PostMapping("/collectMailDetailList") @PostMapping("/collectMailDetailList")
public JSONObject collectMailDetailList(HttpServletRequest request, @RequestBody CollectMailDetailListRequest collectMailDetailListRequest) { public JSONObject collectMailDetailList(HttpServletRequest request, @RequestBody CollectMailDetailListRequest collectMailDetailListRequest) {
...@@ -108,6 +168,21 @@ public class PddLocalController { ...@@ -108,6 +168,21 @@ public class PddLocalController {
return JsonResponse.generateLocalCommonSuccessResponse(collectMailDetailImpl.getList(collectMailDetailListRequest)); return JsonResponse.generateLocalCommonSuccessResponse(collectMailDetailImpl.getList(collectMailDetailListRequest));
} }
/*出库详情*/
@PostMapping("/collectOrderInfo")
public JSONObject collectOrderInfo(HttpServletRequest request, @RequestBody CollectOrderRequest collectOrderRequest) {
Map<String, Object> map = new HashMap<>();
CollectOrderInfoResponse collectOrderInfoResponse = collectOrderImpl.getInfoByOrderCode(collectOrderRequest.getOrderCode());
List<CollectOrderDetailResponse> list = collectOrderDetailImpl.getListByOrderCode(collectOrderRequest.getOrderCode());
CollectReceiverDetailResponse collectOrderReceiverDetailResponse = collectReceiverDetailImpl.getByOrderCode(collectOrderRequest.getOrderCode());
map.put("info", collectOrderInfoResponse);
map.put("detail", list);
map.put("receiver", collectOrderReceiverDetailResponse);
return JsonResponse.generateLocalCommonSuccessResponse(map);
}
/*待拣货列表*/ /*待拣货列表*/
@PostMapping("/collectOrderList") @PostMapping("/collectOrderList")
public JSONObject collectOrderList(HttpServletRequest request, @RequestBody CollectOrderListRequest collectOrderListRequest) { public JSONObject collectOrderList(HttpServletRequest request, @RequestBody CollectOrderListRequest collectOrderListRequest) {
...@@ -128,7 +203,7 @@ public class PddLocalController { ...@@ -128,7 +203,7 @@ public class PddLocalController {
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
CollectOrderResponse collectOrderResponse = collectOrderImpl.getInfoByOrderCode(collectOrderScanRequest.getOrderCode()); CollectOrderResponse collectOrderResponse = collectOrderImpl.getByOrderCode(collectOrderScanRequest.getOrderCode());
List<CollectOutMailDetailResponse> list = collectOutMailDetailImpl.getListByOrderCode(collectOrderScanRequest.getOrderCode()); List<CollectOutMailDetailResponse> list = collectOutMailDetailImpl.getListByOrderCode(collectOrderScanRequest.getOrderCode());
map.put("collectOrder", collectOrderResponse); map.put("collectOrder", collectOrderResponse);
...@@ -164,24 +239,14 @@ public class PddLocalController { ...@@ -164,24 +239,14 @@ public class PddLocalController {
@PostMapping("/mailNoSelectAll") @PostMapping("/mailNoSelectAll")
public Map<String, Object> mailNoSelectAll(HttpServletRequest request, @RequestBody MailNoRequest mailNoRequest) { public Map<String, Object> mailNoSelectAll(HttpServletRequest request, @RequestBody MailNoRequest mailNoRequest) {
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
CollectMailDetailEntity collectMailDetail = collectMailDetailImpl.getByMailNo(mailNoRequest.getMailNo());
if (collectMailDetail == null) {
return JsonResponse.generateLocalCommonFailedResponse("-1", "该包裹不存在出库信息");
}
List<CollectMailDetailEntity> list = collectMailDetailImpl.getListByOrderCode(collectMailDetail.getOrderCode());
CollectOrderResponse collectOrderResponse = collectOrderImpl.getByOrderCode(collectMailDetail.getOrderCode());
map.put("collectMailDetail", collectMailDetail);
map.put("list", list);
map.put("collectOrder", collectOrderResponse);
// CollectOutMailDetailEntity collectOutMailDetail = collectOutMailDetailImpl.getInfoByMailNo(mailNoRequest.getMailNo()); CollectOutMailDetailEntity collectOutMailDetail = collectOutMailDetailImpl.getInfoByMailNo(mailNoRequest.getMailNo());
// List<CollectOutMailDetailResponse> list = collectOutMailDetailImpl.getListByOrderCode(collectOutMailDetail.getOrderCode()); List<CollectOutMailDetailResponse> list = collectOutMailDetailImpl.getListByOrderCode(collectOutMailDetail.getOrderCode());
// CollectOrderResponse collectOrderResponse = collectOrderImpl.getByOrderCode(collectOutMailDetail.getOrderCode()); CollectOrderResponse collectOrderResponse = collectOrderImpl.getByOrderCode(collectOutMailDetail.getOrderCode());
// map.put("list", list); map.put("list", list);
// map.put("collectOutMailDetail", collectOutMailDetail); map.put("collectOutMailDetail", collectOutMailDetail);
return JsonResponse.generateLocalCommonSuccessResponse(map); return JsonResponse.generateLocalCommonSuccessResponse(map);
} }
...@@ -220,7 +285,7 @@ public class PddLocalController { ...@@ -220,7 +285,7 @@ public class PddLocalController {
notifyRequest.setPackageInfo(new PddServiceConsoFirstBizActionNotifyRequest.PackageInfo()); notifyRequest.setPackageInfo(new PddServiceConsoFirstBizActionNotifyRequest.PackageInfo());
notifyRequest.getPackageInfo().setWeight(receiveRequest.getWeight()); notifyRequest.getPackageInfo().setWeight(receiveRequest.getWeight());
notifyRequest.getPackageInfo().setActualWeight(receiveRequest.getWeight()); notifyRequest.getPackageInfo().setActualWeight(receiveRequest.getActualWeight());
notifyRequest.getPackageInfo().setLength(receiveRequest.getLength()); notifyRequest.getPackageInfo().setLength(receiveRequest.getLength());
notifyRequest.getPackageInfo().setWidth(receiveRequest.getWidth()); notifyRequest.getPackageInfo().setWidth(receiveRequest.getWidth());
notifyRequest.getPackageInfo().setHeight(receiveRequest.getHeight()); notifyRequest.getPackageInfo().setHeight(receiveRequest.getHeight());
...@@ -311,7 +376,7 @@ public class PddLocalController { ...@@ -311,7 +376,7 @@ public class PddLocalController {
notifyRequest.getPackageInfo().setHeight(inBoundRequest.getHeight()); notifyRequest.getPackageInfo().setHeight(inBoundRequest.getHeight());
notifyRequest.getPackageInfo().setWeight(inBoundRequest.getWeight()); notifyRequest.getPackageInfo().setWeight(inBoundRequest.getWeight());
notifyRequest.getPackageInfo().setActualWeight((long) PddJYPriceTool.calculateWeight(inBoundRequest.getLength().intValue(), inBoundRequest.getWidth().intValue(), inBoundRequest.getHeight().intValue(), inBoundRequest.getWeight().intValue(), true)); notifyRequest.getPackageInfo().setActualWeight((long) PddJYPriceTool.calculateWeight(inBoundRequest.getLength().intValue(), inBoundRequest.getWidth().intValue(), inBoundRequest.getHeight().intValue(), inBoundRequest.getWeight().intValue(), true));
notifyRequest.getPackageInfo().setGoodsType(inBoundRequest.getGoodsType()); notifyRequest.getPackageInfo().setGoodsType("NORMAL");
notifyRequest.setResult(new PddServiceConsoInboundRequest.Result()); notifyRequest.setResult(new PddServiceConsoInboundRequest.Result());
notifyRequest.getResult().setCode(0); notifyRequest.getResult().setCode(0);
...@@ -484,7 +549,11 @@ public class PddLocalController { ...@@ -484,7 +549,11 @@ public class PddLocalController {
} else if (("finish_unpack").equals(finishUnpackRequest.getAction())) { } else if (("finish_unpack").equals(finishUnpackRequest.getAction())) {
PackageNoticeEntity packageNoticeEntity = packageNoticeImpl.getByOrderCode(finishUnpackRequest.getOrderCode());
if (packageNoticeEntity == null) {
return JsonResponse.generateLocalCommonFailedResponse("-1", "未查到拆包信息,请检查参数");
}
LogOrderEntity logOrderEntity = logOrderImpl.getByOrderCode(finishUnpackRequest.getOrderCode()); LogOrderEntity logOrderEntity = logOrderImpl.getByOrderCode(finishUnpackRequest.getOrderCode());
...@@ -526,13 +595,8 @@ public class PddLocalController { ...@@ -526,13 +595,8 @@ public class PddLocalController {
logOrderEntity.setStatus(logOrderMailDetailIoEntity.getStatus()); logOrderEntity.setStatus(logOrderMailDetailIoEntity.getStatus());
logOrderImpl.updateById(logOrderEntity); logOrderImpl.updateById(logOrderEntity);
PackageNoticeEntity packageNoticeEntity = packageNoticeImpl.getByOrderCode(finishUnpackRequest.getOrderCode()); packageNoticeEntity.setStatus("" + logOrderMailDetailIoEntity.getStatus());
packageNoticeImpl.updateById(packageNoticeEntity);
if (packageNoticeEntity != null) {
packageNoticeEntity.setStatus("" + logOrderMailDetailIoEntity.getStatus());
packageNoticeImpl.updateById(packageNoticeEntity);
}
} }
} }
notifyRequest.setResult(new PddServiceConsoCoBizActionNotifyRequest.Result()); notifyRequest.setResult(new PddServiceConsoCoBizActionNotifyRequest.Result());
...@@ -611,8 +675,8 @@ public class PddLocalController { ...@@ -611,8 +675,8 @@ public class PddLocalController {
notifyRequest.setBizActionDesc("开始拣货"); notifyRequest.setBizActionDesc("开始拣货");
notifyResult.setCode(0); notifyResult.setCode(0);
} } else if (action.equals("finish_pick")) {
else if (action.equals("finish_pick")) {
collectOrderEntity = collectOrderImpl.getAllInfoByOrderCode(finishUnpackRequest.getOrderCode()); collectOrderEntity = collectOrderImpl.getAllInfoByOrderCode(finishUnpackRequest.getOrderCode());
if (collectOrderEntity == null) { if (collectOrderEntity == null) {
...@@ -623,12 +687,21 @@ public class PddLocalController { ...@@ -623,12 +687,21 @@ public class PddLocalController {
notifyRequest.setBizActionDesc("拣货完成"); notifyRequest.setBizActionDesc("拣货完成");
notifyResult.setCode(0); notifyResult.setCode(0);
} } else if (action.equals("finish_unpack")) {
else if (action.equals("finish_unpack")) {
PackageNoticeEntity packageNoticeEntity = packageNoticeImpl.getByOrderCode(finishUnpackRequest.getOrderCode());
if (packageNoticeEntity == null) {
return JsonResponse.generateLocalCommonFailedResponse("-1", "未查到拆包信息,请检查参数");
}
LogOrderEntity logOrderEntity = logOrderImpl.getByOrderCode(finishUnpackRequest.getOrderCode()); LogOrderEntity logOrderEntity = logOrderImpl.getByOrderCode(finishUnpackRequest.getOrderCode());
if (logOrderEntity == null) { if (logOrderEntity == null) {
return JsonResponse.generateLocalCommonFailedResponse("-1", "未查到集运单信息,请检查参数"); return JsonResponse.generateLocalCommonFailedResponse("-1", "未查到集运单信息,请检查参数");
} }
logOrderMailDetailIoEntity.setStatus(StatusEnum.FINISHUNPACK.getCode()); logOrderMailDetailIoEntity.setStatus(StatusEnum.FINISHUNPACK.getCode());
notifyRequest.setBizActionDesc("拆包完成"); notifyRequest.setBizActionDesc("拆包完成");
...@@ -665,13 +738,8 @@ public class PddLocalController { ...@@ -665,13 +738,8 @@ public class PddLocalController {
logOrderEntity.setStatus(logOrderMailDetailIoEntity.getStatus()); logOrderEntity.setStatus(logOrderMailDetailIoEntity.getStatus());
logOrderImpl.updateById(logOrderEntity); logOrderImpl.updateById(logOrderEntity);
PackageNoticeEntity packageNoticeEntity = packageNoticeImpl.getByOrderCode(finishUnpackRequest.getOrderCode()); packageNoticeEntity.setStatus("" + logOrderMailDetailIoEntity.getStatus());
packageNoticeImpl.updateById(packageNoticeEntity);
if (packageNoticeEntity != null) {
packageNoticeEntity.setStatus("" + logOrderMailDetailIoEntity.getStatus());
packageNoticeImpl.updateById(packageNoticeEntity);
}
} }
...@@ -796,16 +864,16 @@ public class PddLocalController { ...@@ -796,16 +864,16 @@ public class PddLocalController {
// TODO 此处异常,需要处理 // TODO 此处异常,需要处理
//获取所有可出库订单 //获取所有可出库订单
List<CollectMailDetailEntity> list = collectMailDetailImpl.getListByOrderCode(outBoundRequest.getOrderCode()); List<CollectOutMailDetailResponse> list = collectOutMailDetailImpl.getListByOrderCode(outBoundRequest.getOrderCode());
if (list != null && !list.isEmpty()) { if (list != null && !list.isEmpty()) {
// 拆单操作 // 拆单操作
// 存储需要删除的元素 // 存储需要删除的元素
List<CollectMailDetailEntity> toRemoveList = new ArrayList<>(); List<CollectOutMailDetailResponse> toRemoveList = new ArrayList<>();
List<OutBoundRequest.OutBoundList> toRemoveOutBound = new ArrayList<>(); List<OutBoundRequest.OutBoundList> toRemoveOutBound = new ArrayList<>();
for (CollectMailDetailEntity lists : list) { for (CollectOutMailDetailResponse lists : list) {
for (OutBoundRequest.OutBoundList outBoundLists : outBoundList) { for (OutBoundRequest.OutBoundList outBoundLists : outBoundList) {
if (lists.getMailNo().equals(outBoundLists.getMailNo())) { if (lists.getMailNo().equals(outBoundLists.getMailNo())) {
toRemoveList.add(lists); toRemoveList.add(lists);
...@@ -838,19 +906,16 @@ public class PddLocalController { ...@@ -838,19 +906,16 @@ public class PddLocalController {
notifyRequest.setIsSplitOut("N"); notifyRequest.setIsSplitOut("N");
notifyRequest.setPackageInfos(new ArrayList<>()); notifyRequest.setPackageInfos(new ArrayList<>());
PddServiceConsoOutboundRequest.PackageInfo packageInfo = new PddServiceConsoOutboundRequest.PackageInfo();
for (OutBoundRequest.OutPackage outPackage : outBoundRequest.getOutPackageList()) { notifyRequest.getPackageInfos().add(packageInfo);
PddServiceConsoOutboundRequest.PackageInfo packageInfo = new PddServiceConsoOutboundRequest.PackageInfo(); // packageInfo.setOutboundMailNo(outBoundRequest.getMailNo());
notifyRequest.getPackageInfos().add(packageInfo); // packageInfo.setExpressCode(outBoundRequest.getExpressCode());
packageInfo.setOutboundMailNo(outPackage.getMailNo()); // packageInfo.setPackageType(outBoundRequest.getPackageType());
packageInfo.setExpressCode(outPackage.getExpressCode()); // packageInfo.setLength(outBoundRequest.getLength());
packageInfo.setPackageType(outPackage.getPackageType()); // packageInfo.setWidth(outBoundRequest.getWidth());
packageInfo.setLength(outPackage.getLength()); // packageInfo.setHeight(outBoundRequest.getHeight());
packageInfo.setWidth(outPackage.getWidth()); // packageInfo.setWeight(outBoundRequest.getWeight());
packageInfo.setHeight(outPackage.getHeight());
packageInfo.setWeight(outPackage.getWeight());
}
notifyRequest.setSenderDetail(new PddServiceConsoOutboundRequest.SenderDetail()); notifyRequest.setSenderDetail(new PddServiceConsoOutboundRequest.SenderDetail());
...@@ -866,7 +931,7 @@ public class PddLocalController { ...@@ -866,7 +931,7 @@ public class PddLocalController {
notifyRequest.getSenderDetail().setDetailAddress(collectOrderSendEntity.getDetailAddress()); notifyRequest.getSenderDetail().setDetailAddress(collectOrderSendEntity.getDetailAddress());
CollectReceiverDetailEntity collectReceiverDetailEntity = collectReceiverDetailImpl.getInfoByMailNo(outBoundRequest.getOrderCode()); CollectReceiverDetailEntity collectReceiverDetailEntity = collectReceiverDetailImpl.getInfoByOrderCode(outBoundRequest.getOrderCode());
notifyRequest.setReceiverDetail(new PddServiceConsoOutboundRequest.ReceiverDetail()); notifyRequest.setReceiverDetail(new PddServiceConsoOutboundRequest.ReceiverDetail());
notifyRequest.getReceiverDetail().setName(collectReceiverDetailEntity.getName()); notifyRequest.getReceiverDetail().setName(collectReceiverDetailEntity.getName());
notifyRequest.getReceiverDetail().setTelePhone(collectReceiverDetailEntity.getTelePhone()); notifyRequest.getReceiverDetail().setTelePhone(collectReceiverDetailEntity.getTelePhone());
...@@ -892,26 +957,21 @@ public class PddLocalController { ...@@ -892,26 +957,21 @@ public class PddLocalController {
requestModel.setSign(PddSignTool.generateSign(requestModel, PddAPIConfig.CLIENT_SECRET)); requestModel.setSign(PddSignTool.generateSign(requestModel, PddAPIConfig.CLIENT_SECRET));
String resp = PddHttpTool.sendJsonPost(requestModel); String resp = PddHttpTool.sendJsonPost(requestModel);
for (OutBoundRequest.OutPackage outPackage : outBoundRequest.getOutPackageList()) { LogOrderMailDetailIoEntity logOrderMailDetailIoEntity = new LogOrderMailDetailIoEntity();
LogOrderMailDetailIoEntity logOrderMailDetailIoEntity = new LogOrderMailDetailIoEntity(); // logOrderMailDetailIoEntity.setMailNo(outBoundRequest.getMailNo());
logOrderMailDetailIoEntity.setMailNo(outPackage.getMailNo()); // logOrderMailDetailIoEntity.setExpressCode(outBoundRequest.getExpressCode());
logOrderMailDetailIoEntity.setExpressCode(outPackage.getExpressCode()); // logOrderMailDetailIoEntity.setLogisticsOrderCode(outBoundRequest.getOrderCode());
logOrderMailDetailIoEntity.setLogisticsOrderCode(outBoundRequest.getOrderCode()); // logOrderMailDetailIoEntity.setExpressCode(outBoundRequest.getExpressCode());
logOrderMailDetailIoEntity.setExpressCode(outPackage.getExpressCode()); logOrderMailDetailIoEntity.setStatus(StatusEnum.FINISHOUTBOUND.getCode());
logOrderMailDetailIoEntity.setStatus(StatusEnum.FINISHOUTBOUND.getCode()); logOrderMailDetailIoEntity.setReq(JSON.toJSONString(requestModel));
logOrderMailDetailIoEntity.setReq(JSON.toJSONString(requestModel)); logOrderMailDetailIoEntity.setResp(resp);
logOrderMailDetailIoEntity.setResp(resp);
logOrderMailDetailIoImpl.save(logOrderMailDetailIoEntity); logOrderMailDetailIoImpl.save(logOrderMailDetailIoEntity);
//更新collect_mail_detail //更新collect_mail_detail
for (CollectMailDetailEntity lists : list) { for (CollectOutMailDetailResponse lists : list) {
Boolean result = collectMailDetailImpl.updateByMailNo(lists.getMailNo(), logOrderMailDetailIoEntity.getStatus()); Boolean result = collectMailDetailImpl.updateByMailNo(lists.getMailNo(), logOrderMailDetailIoEntity.getStatus());
}
} }
return JsonResponse.generateLocalCommonSuccessResponse(true); return JsonResponse.generateLocalCommonSuccessResponse(true);
} }
...@@ -922,4 +982,17 @@ public class PddLocalController { ...@@ -922,4 +982,17 @@ public class PddLocalController {
return JsonResponse.generateLocalCommonSuccessResponse(logOrderMailDetailIoImpl.getListByRequest(param)); return JsonResponse.generateLocalCommonSuccessResponse(logOrderMailDetailIoImpl.getListByRequest(param));
} }
private PddLogisticsCoTrackNotifyRequest.DataObject getDataObject(String code) {
PddLogisticsCoTrackNotifyRequest.DataObject dataObjects = new PddLogisticsCoTrackNotifyRequest.DataObject();
dataObjects.setTraces(new ArrayList<>());
List<TraceObjectEntity> list = traceObjectImpl.selectByTrackingNumber(code);
List<org.ta.pddserver.model.pddlg.common.TraceObject> traceObjects = new ArrayList<>();
for (TraceObjectEntity traceObjectEntity : list) {
dataObjects.getTraces().add(TraceObject.createFromTraceEntity(traceObjectEntity));
}
return dataObjects;
}
} }
...@@ -6,10 +6,13 @@ import org.apache.ibatis.annotations.Param; ...@@ -6,10 +6,13 @@ import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import org.ta.pddserver.entity.CollectOrderDetailEntity; import org.ta.pddserver.entity.CollectOrderDetailEntity;
import org.ta.pddserver.entity.CollectOutMailDetailEntity; import org.ta.pddserver.entity.CollectOutMailDetailEntity;
import org.ta.pddserver.model.api.response.CollectOrderDetailResponse;
import java.util.List;
@Mapper @Mapper
public interface CollectOrderDetailMapper extends BaseMapper<CollectOrderDetailEntity> { public interface CollectOrderDetailMapper extends BaseMapper<CollectOrderDetailEntity> {
@Select("SELECT * FROM `collect_out_mail_detail` WHERE `mailNo` = #{mailNo} AND `state` > 0") @Select("SELECT `uid`, `orderCode`, `orderSn`, `logisticsOrderCode`, `itemId`, `itemName`, `categoryName`, `itemQuantity`, `weightTotal`, `actualAmount`, `productName`, `exportDecAmount` FROM `collect_order_detail` WHERE `orderCode` = #{orderCode}; ")
CollectOutMailDetailEntity getInfoByMailNo(@Param("mailNo") String mailNo); List<CollectOrderDetailResponse> getListByOrderCode(String orderCode);
} }
...@@ -9,6 +9,7 @@ import org.ta.pddserver.entity.CollectOrderEntity; ...@@ -9,6 +9,7 @@ import org.ta.pddserver.entity.CollectOrderEntity;
import org.ta.pddserver.model.api.request.CollectMailDetailListRequest; import org.ta.pddserver.model.api.request.CollectMailDetailListRequest;
import org.ta.pddserver.model.api.request.CollectOrderListRequest; import org.ta.pddserver.model.api.request.CollectOrderListRequest;
import org.ta.pddserver.model.api.response.CollectMailDetailListResponse; import org.ta.pddserver.model.api.response.CollectMailDetailListResponse;
import org.ta.pddserver.model.api.response.CollectOrderInfoResponse;
import org.ta.pddserver.model.api.response.CollectOrderListResponse; import org.ta.pddserver.model.api.response.CollectOrderListResponse;
import org.ta.pddserver.model.api.response.CollectOrderResponse; import org.ta.pddserver.model.api.response.CollectOrderResponse;
...@@ -17,7 +18,7 @@ import java.util.List; ...@@ -17,7 +18,7 @@ import java.util.List;
@Mapper @Mapper
public interface CollectOrderMapper extends BaseMapper<CollectOrderEntity> { public interface CollectOrderMapper extends BaseMapper<CollectOrderEntity> {
@Select("SELECT `uid`,`orderCode`, `itemQuantityTotal`, `segmentCode` FROM `collect_order` WHERE `orderCode` = #{orderCode};") @Select("SELECT `uid`,`orderCode`, `itemQuantityTotal`, `segmentCode`, `consoType` FROM `collect_order` WHERE `orderCode` = #{orderCode};")
CollectOrderResponse findByOrderCode(String orderCode); CollectOrderResponse findByOrderCode(String orderCode);
@Update("UPDATE `collect_order` SET `status` = #{status} WHERE `uid` = #{uid};") @Update("UPDATE `collect_order` SET `status` = #{status} WHERE `uid` = #{uid};")
...@@ -26,8 +27,8 @@ public interface CollectOrderMapper extends BaseMapper<CollectOrderEntity> { ...@@ -26,8 +27,8 @@ public interface CollectOrderMapper extends BaseMapper<CollectOrderEntity> {
@Select("SELECT `uid`, `orderCode`, `itemQuantityTotal`, `segmentCode`, `consoType` FROM `collect_order` WHERE `orderCode` = #{orderCode} AND `status` = ${status}") @Select("SELECT `uid`, `orderCode`, `itemQuantityTotal`, `segmentCode`, `consoType` FROM `collect_order` WHERE `orderCode` = #{orderCode} AND `status` = ${status}")
List<CollectOrderListResponse> getList(@Param("orderCode") String orderCode, @Param("status") int status); List<CollectOrderListResponse> getList(@Param("orderCode") String orderCode, @Param("status") int status);
@Select("SELECT `uid`, `orderCode`, `itemQuantityTotal`, `segmentCode`, `consoType` FROM `collect_order` WHERE `orderCode` = #{orderCode};") @Select("SELECT `uid`, `orderCode`, `itemQuantityTotal`, `tradeOrderActualAmountTotal`,`segmentCode`, `consoType`, `deliveryType` FROM `collect_order` WHERE `orderCode` = #{orderCode};")
CollectOrderResponse getInfoByOrderCode(@Param("orderCode") String orderCode); CollectOrderInfoResponse getInfoByOrderCode(@Param("orderCode") String orderCode);
@Select("SELECT COUNT(*) FROM (SELECT a.`uid` FROM `collect_order` a LEFT JOIN `collect_mail_detail` b ON a.`orderCode` = b.`orderCode` WHERE a.`orderCode` LIKE '%${orderCode}%' AND a.`status` LIKE '%${status}%' GROUP BY a.`uid`) t; ") @Select("SELECT COUNT(*) FROM (SELECT a.`uid` FROM `collect_order` a LEFT JOIN `collect_mail_detail` b ON a.`orderCode` = b.`orderCode` WHERE a.`orderCode` LIKE '%${orderCode}%' AND a.`status` LIKE '%${status}%' GROUP BY a.`uid`) t; ")
Integer countUsable(CollectOrderListRequest param); Integer countUsable(CollectOrderListRequest param);
......
...@@ -5,9 +5,13 @@ import org.apache.ibatis.annotations.Mapper; ...@@ -5,9 +5,13 @@ import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import org.ta.pddserver.entity.CollectReceiverDetailEntity; import org.ta.pddserver.entity.CollectReceiverDetailEntity;
import org.ta.pddserver.model.api.response.CollectReceiverDetailResponse;
@Mapper @Mapper
public interface CollectReceiverDetailMapper extends BaseMapper<CollectReceiverDetailEntity> { public interface CollectReceiverDetailMapper extends BaseMapper<CollectReceiverDetailEntity> {
@Select("SELECT * FROM `collect_order_receiver_detail` WHERE `orderCode` = #{orderCode} AND `state` > 0") @Select("SELECT * FROM `collect_order_receiver_detail` WHERE `orderCode` = #{orderCode} AND `state` > 0")
CollectReceiverDetailEntity getInfoByMailNo(@Param("orderCode") String orderCode); CollectReceiverDetailEntity getInfoByOrderCode(@Param("orderCode") String orderCode);
@Select("SELECT `uid`, `name`, `idNumber`, `telePhone`, `country`, `province`, `city`, `district`, `detailAddress`, `postCode` FROM `collect_order_receiver_detail` WHERE `orderCode` = #{orderCode} AND `state` > 0")
CollectReceiverDetailResponse getByOrderCode(@Param("orderCode") String orderCode);
} }
...@@ -8,4 +8,6 @@ public class CollectMailDetailRequest extends PageTool { ...@@ -8,4 +8,6 @@ public class CollectMailDetailRequest extends PageTool {
private String mailNo; private String mailNo;
private String orderCode;
} }
package org.ta.pddserver.model.api.request;
import lombok.Data;
import org.ta.pddserver.model.common.PageTool;
@Data
public class CollectOrderRequest extends PageTool {
private String orderCode;
private int status;
}
package org.ta.pddserver.model.api.request;
import lombok.Data;
import org.ta.pddserver.model.common.PageTool;
@Data
public class TraceObjectRequest extends PageTool {
private String trackingNumber;
private String trackingOrderNo;
private String id;
private String statusCode;
private String description;
private String operationTime;
private int transferFlag;
private String transferNo;
private String transferPartnerId;
private String timeZone;
private String siteName;
private int siteType;
private String siteNo;
private String nextSiteName;
private int nextSiteType;
private String nextSiteNo;
private String failReason;
private double weight;
private String country;
private String province;
private String city;
private String district;
private String contact;
private String contactInfo;
private String signerName;
private String address;
private String remark;
}
package org.ta.pddserver.model.api.response;
import lombok.Data;
@Data
public class CollectOrderDetailResponse {
private String uid;
private String orderCode;
private String orderSn;
private String logisticsOrderCode;
private String itemId;
private String itemName;
private String categoryName;
private int itemQuantity;
private int weightTotal;
private int actualAmount;
private String productName;
private int exportDecAmount;
}
package org.ta.pddserver.model.api.response;
import lombok.Data;
@Data
public class CollectOrderInfoResponse {
private String uid;
private String orderCode;
private int tradeOrderActualAmountTotal;
private int itemQuantityTotal;
private String segmentCode;
private String consoType;
private String deliveryType;
}
...@@ -13,4 +13,6 @@ public class CollectOrderResponse { ...@@ -13,4 +13,6 @@ public class CollectOrderResponse {
private String segmentCode; private String segmentCode;
private String consoType;
} }
package org.ta.pddserver.model.api.response;
import lombok.Data;
@Data
public class CollectReceiverDetailResponse {
private String uid;
private String name;
private String idNumber;
private String telePhone;
private String country;
private String province;
private String city;
private String district;
private String detailAddress;
private String postCode;
}
...@@ -5,10 +5,16 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; ...@@ -5,10 +5,16 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.ta.pddserver.entity.CollectOrderDetailEntity; import org.ta.pddserver.entity.CollectOrderDetailEntity;
import org.ta.pddserver.mapper.CollectOrderDetailMapper; import org.ta.pddserver.mapper.CollectOrderDetailMapper;
import org.ta.pddserver.model.api.response.CollectOrderDetailResponse;
import org.ta.pddserver.service.CollectOrderDetailService; import org.ta.pddserver.service.CollectOrderDetailService;
import java.util.List;
@Service @Service
public class CollectOrderDetailImpl extends ServiceImpl<CollectOrderDetailMapper, CollectOrderDetailEntity> implements CollectOrderDetailService { public class CollectOrderDetailImpl extends ServiceImpl<CollectOrderDetailMapper, CollectOrderDetailEntity> implements CollectOrderDetailService {
public List<CollectOrderDetailResponse> getListByOrderCode(String orderCode) {
return baseMapper.getListByOrderCode(orderCode);
}
} }
\ No newline at end of file
...@@ -7,6 +7,7 @@ import org.ta.pddserver.entity.CollectOrderEntity; ...@@ -7,6 +7,7 @@ import org.ta.pddserver.entity.CollectOrderEntity;
import org.ta.pddserver.mapper.CollectOrderMapper; import org.ta.pddserver.mapper.CollectOrderMapper;
import org.ta.pddserver.model.api.request.CollectOrderListRequest; import org.ta.pddserver.model.api.request.CollectOrderListRequest;
import org.ta.pddserver.model.api.response.CollectMailDetailListResponse; import org.ta.pddserver.model.api.response.CollectMailDetailListResponse;
import org.ta.pddserver.model.api.response.CollectOrderInfoResponse;
import org.ta.pddserver.model.api.response.CollectOrderListResponse; import org.ta.pddserver.model.api.response.CollectOrderListResponse;
import org.ta.pddserver.model.api.response.CollectOrderResponse; import org.ta.pddserver.model.api.response.CollectOrderResponse;
import org.ta.pddserver.service.CollectOrderService; import org.ta.pddserver.service.CollectOrderService;
...@@ -38,7 +39,7 @@ public class CollectOrderImpl extends ServiceImpl<CollectOrderMapper, CollectOrd ...@@ -38,7 +39,7 @@ public class CollectOrderImpl extends ServiceImpl<CollectOrderMapper, CollectOrd
return map; return map;
} }
public CollectOrderResponse getInfoByOrderCode(String orderCode) { public CollectOrderInfoResponse getInfoByOrderCode(String orderCode) {
return baseMapper.getInfoByOrderCode(orderCode); return baseMapper.getInfoByOrderCode(orderCode);
} }
......
...@@ -5,13 +5,18 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; ...@@ -5,13 +5,18 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.ta.pddserver.entity.CollectReceiverDetailEntity; import org.ta.pddserver.entity.CollectReceiverDetailEntity;
import org.ta.pddserver.mapper.CollectReceiverDetailMapper; import org.ta.pddserver.mapper.CollectReceiverDetailMapper;
import org.ta.pddserver.model.api.response.CollectReceiverDetailResponse;
import org.ta.pddserver.service.CollectReceiverDetailService; import org.ta.pddserver.service.CollectReceiverDetailService;
@Service @Service
public class CollectReceiverDetailImpl extends ServiceImpl<CollectReceiverDetailMapper, CollectReceiverDetailEntity> implements CollectReceiverDetailService { public class CollectReceiverDetailImpl extends ServiceImpl<CollectReceiverDetailMapper, CollectReceiverDetailEntity> implements CollectReceiverDetailService {
public CollectReceiverDetailEntity getInfoByMailNo(String orderCode) { public CollectReceiverDetailEntity getInfoByOrderCode(String orderCode) {
return baseMapper.getInfoByMailNo(orderCode); return baseMapper.getInfoByOrderCode(orderCode);
}
public CollectReceiverDetailResponse getByOrderCode(String orderCode) {
return baseMapper.getByOrderCode(orderCode);
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment