|
@@ -1,6 +1,9 @@
|
|
package com.steerinfo.dil.controller;
|
|
package com.steerinfo.dil.controller;
|
|
|
|
|
|
import com.steerinfo.dil.feign.ColumnDataFeign;
|
|
import com.steerinfo.dil.feign.ColumnDataFeign;
|
|
|
|
+import com.steerinfo.dil.feign.ESFeign;
|
|
|
|
+import com.steerinfo.dil.mapper.AmsDispatchSaleOrderMapper;
|
|
|
|
+import com.steerinfo.dil.mapper.AmsSaleOrderMapper;
|
|
import com.steerinfo.dil.model.AmsDispatchSaleOrder;
|
|
import com.steerinfo.dil.model.AmsDispatchSaleOrder;
|
|
import com.steerinfo.dil.model.AmsSaleOrder;
|
|
import com.steerinfo.dil.model.AmsSaleOrder;
|
|
import com.steerinfo.dil.service.IAmsSaleOrderService;
|
|
import com.steerinfo.dil.service.IAmsSaleOrderService;
|
|
@@ -8,6 +11,7 @@ import com.steerinfo.dil.service.impl.AmsDispatchSaleOrderServiceImpl;
|
|
import com.steerinfo.dil.service.impl.AmsSaleOrderMaterialServiceImpl;
|
|
import com.steerinfo.dil.service.impl.AmsSaleOrderMaterialServiceImpl;
|
|
import com.steerinfo.dil.util.BaseRESTfulController;
|
|
import com.steerinfo.dil.util.BaseRESTfulController;
|
|
import com.steerinfo.dil.util.ColumnDataUtil;
|
|
import com.steerinfo.dil.util.ColumnDataUtil;
|
|
|
|
+import com.steerinfo.dil.util.DataChange;
|
|
import com.steerinfo.dil.util.PageListAdd;
|
|
import com.steerinfo.dil.util.PageListAdd;
|
|
import com.steerinfo.framework.controller.RESTfulResult;
|
|
import com.steerinfo.framework.controller.RESTfulResult;
|
|
import com.steerinfo.framework.service.pagehelper.PageHelper;
|
|
import com.steerinfo.framework.service.pagehelper.PageHelper;
|
|
@@ -49,9 +53,12 @@ public class AmsSaleOrderController extends BaseRESTfulController {
|
|
AmsDispatchSaleOrderServiceImpl amsDispatchSaleOrderService;
|
|
AmsDispatchSaleOrderServiceImpl amsDispatchSaleOrderService;
|
|
@Autowired
|
|
@Autowired
|
|
ColumnDataFeign columnDataFeign;
|
|
ColumnDataFeign columnDataFeign;
|
|
-
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ AmsDispatchSaleOrderMapper amsDispatchSaleOrderMapper;
|
|
@Autowired
|
|
@Autowired
|
|
ColumnDataUtil columnDataUtil;
|
|
ColumnDataUtil columnDataUtil;
|
|
|
|
+ @Autowired
|
|
|
|
+ ESFeign esFeign;
|
|
|
|
|
|
@ApiOperation(value="查询未上报销售订单信息")
|
|
@ApiOperation(value="查询未上报销售订单信息")
|
|
@ApiImplicitParams({
|
|
@ApiImplicitParams({
|
|
@@ -276,13 +283,45 @@ public class AmsSaleOrderController extends BaseRESTfulController {
|
|
public RESTfulResult getSaleOrderList(@RequestBody(required = false) Map<String,Object> mapValue,
|
|
public RESTfulResult getSaleOrderList(@RequestBody(required = false) Map<String,Object> mapValue,
|
|
Integer pageNum,
|
|
Integer pageNum,
|
|
Integer pageSize,
|
|
Integer pageSize,
|
|
- Integer apiId) {
|
|
|
|
- List<Map<String, Object>> list = amsSaleOrderService.getSaleOrderList(mapValue);
|
|
|
|
- PageHelper.startPage(pageNum, pageSize);
|
|
|
|
- //分页查询数据
|
|
|
|
- List<Map<String, Object>> columnList = amsSaleOrderService.getSaleOrderList(mapValue);
|
|
|
|
- PageListAdd data = columnDataUtil.tableColumnData(apiId, list, columnList);
|
|
|
|
- return success(data);
|
|
|
|
|
|
+ Integer apiId,
|
|
|
|
+ Integer status,
|
|
|
|
+ String con) {
|
|
|
|
+ int count=0;
|
|
|
|
+ if (status!=null){
|
|
|
|
+ mapValue.put("status",status);
|
|
|
|
+ count++;
|
|
|
|
+ }
|
|
|
|
+ if(con != null){
|
|
|
|
+ if(!"undefined".equals(con)){
|
|
|
|
+ String index="get_sale_orderlist";//设置要查询的索引名称
|
|
|
|
+ return success(esFeign.getConResult(mapValue,index,apiId,pageNum,pageSize,con));//获取查询结果
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ //不分页筛选数据
|
|
|
|
+ List<Map<String, Object>> allSaleOrderList = null;
|
|
|
|
+ //如果有条件查询则跳过初始化,和创建索引
|
|
|
|
+ if(mapValue.size() == count){
|
|
|
|
+ //将查询结果存入索引中
|
|
|
|
+ allSaleOrderList = amsSaleOrderService.getSaleOrderList(mapValue);
|
|
|
|
+ Map<String, Object> map1 = new HashMap<>();
|
|
|
|
+ //添加索引
|
|
|
|
+ map1.put("index","get_sale_orderlist");
|
|
|
|
+ //添加id
|
|
|
|
+ map1.put("indexId","saleOrderId");
|
|
|
|
+ allSaleOrderList.add(map1);
|
|
|
|
+ //新建索引
|
|
|
|
+ esFeign.insertIndex(allSaleOrderList);
|
|
|
|
+ //删除
|
|
|
|
+ allSaleOrderList.remove(allSaleOrderList.size()-1);
|
|
|
|
+ }
|
|
|
|
+ if(allSaleOrderList== null)
|
|
|
|
+ allSaleOrderList = amsSaleOrderService.getSaleOrderList(mapValue);
|
|
|
|
+ PageHelper.startPage(pageNum,pageSize);
|
|
|
|
+ //分页数据
|
|
|
|
+ List<Map<String, Object>> saleOrderList = amsSaleOrderService.getSaleOrderList(mapValue);
|
|
|
|
+ PageListAdd pageList = columnDataUtil.tableColumnData(apiId, allSaleOrderList,saleOrderList);
|
|
|
|
+ return success(pageList);
|
|
|
|
+
|
|
}
|
|
}
|
|
/**
|
|
/**
|
|
* 固定派单:通过车序号查询收货地址,截取收货地址的区域,去资源管理中查询对应的承运商,将车序号与承运商绑定
|
|
* 固定派单:通过车序号查询收货地址,截取收货地址的区域,去资源管理中查询对应的承运商,将车序号与承运商绑定
|
|
@@ -294,28 +333,29 @@ public class AmsSaleOrderController extends BaseRESTfulController {
|
|
}
|
|
}
|
|
for (Map<String,Object> m:mapValue
|
|
for (Map<String,Object> m:mapValue
|
|
) {
|
|
) {
|
|
-//Integer id=amsSaleOrderMaterialService.selectByCxh(m);
|
|
|
|
- Integer id=Integer.parseInt(m.get("orderMaterialId").toString()) ;
|
|
|
|
|
|
+ //Integer id=amsSaleOrderMaterialService.selectByCxh(m);
|
|
|
|
+ Integer id = Integer.parseInt(m.get("orderMaterialId").toString()) ;
|
|
System.out.println(id);
|
|
System.out.println(id);
|
|
//通过主键Id获取地址id
|
|
//通过主键Id获取地址id
|
|
Integer a=amsSaleOrderMaterialService.selectById(new BigDecimal(id));
|
|
Integer a=amsSaleOrderMaterialService.selectById(new BigDecimal(id));
|
|
//通过地址id查询承运商id
|
|
//通过地址id查询承运商id
|
|
List<Integer> carriers = amsSaleOrderService.getCarrier(a);
|
|
List<Integer> carriers = amsSaleOrderService.getCarrier(a);
|
|
//判断是否只有一个承运商
|
|
//判断是否只有一个承运商
|
|
|
|
+ //如果收货地区为成都重庆,则有多个一个地区对应多个承运商
|
|
if(carriers.size()==1) {
|
|
if(carriers.size()==1) {
|
|
//新增固定派单
|
|
//新增固定派单
|
|
AmsDispatchSaleOrder ad = new AmsDispatchSaleOrder();
|
|
AmsDispatchSaleOrder ad = new AmsDispatchSaleOrder();
|
|
- ad.setDispatchId(amsDispatchSaleOrderService.selectMaxId());
|
|
|
|
|
|
+ ad.setDispatchId(DataChange.dataToBigDecimal(m.get("dispatchId")));
|
|
ad.setSaleOrderMaterialId(new BigDecimal(id));
|
|
ad.setSaleOrderMaterialId(new BigDecimal(id));
|
|
ad.setCarrierId(new BigDecimal(carriers.get(0)));
|
|
ad.setCarrierId(new BigDecimal(carriers.get(0)));
|
|
ad.setDispatchDealTime(new Date());
|
|
ad.setDispatchDealTime(new Date());
|
|
ad.setDispatchTime(new Date());
|
|
ad.setDispatchTime(new Date());
|
|
//成交类型(0:定向派单;1:公开抢单)
|
|
//成交类型(0:定向派单;1:公开抢单)
|
|
ad.setDispatchType(new BigDecimal(0));
|
|
ad.setDispatchType(new BigDecimal(0));
|
|
- //销售订单车序号状态(0:自由;1:锁定)
|
|
|
|
- ad.setDispatchStatus(new BigDecimal(1));
|
|
|
|
- amsDispatchSaleOrderService.insert(ad);
|
|
|
|
- return success("插入成功");
|
|
|
|
|
|
+ //销售订单车序号状态(0:已下发;1:未下发)
|
|
|
|
+ ad.setDispatchStatus(new BigDecimal(0));
|
|
|
|
+ int i = amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(ad);
|
|
|
|
+ return success(i);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return success();
|
|
return success();
|
|
@@ -333,7 +373,9 @@ public class AmsSaleOrderController extends BaseRESTfulController {
|
|
public RESTfulResult getAmsSaleOrderMaterial(@RequestBody(required = false) Map<String,Object> mapValue,
|
|
public RESTfulResult getAmsSaleOrderMaterial(@RequestBody(required = false) Map<String,Object> mapValue,
|
|
Integer pageNum,
|
|
Integer pageNum,
|
|
Integer pageSize,
|
|
Integer pageSize,
|
|
- Integer apiId) {
|
|
|
|
|
|
+ Integer apiId,
|
|
|
|
+ Integer status) {
|
|
|
|
+ mapValue.put("status",status);
|
|
List<Map<String, Object>> list = amsSaleOrderMaterialService.getSaleMaterial(mapValue);
|
|
List<Map<String, Object>> list = amsSaleOrderMaterialService.getSaleMaterial(mapValue);
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
//分页查询数据
|
|
//分页查询数据
|
|
@@ -345,21 +387,23 @@ public class AmsSaleOrderController extends BaseRESTfulController {
|
|
/**
|
|
/**
|
|
* 公开派单:新增公开派单
|
|
* 公开派单:新增公开派单
|
|
*/
|
|
*/
|
|
- @PostMapping("/addOpenAmsDispatchSaleOrder/{saleOrderMaterialId}")
|
|
|
|
- public RESTfulResult addOpenAmsDispatchSaleOrder(@PathVariable("saleOrderMaterialId") BigDecimal saleOrderMaterialId){
|
|
|
|
- if(saleOrderMaterialId==null){
|
|
|
|
|
|
+ @PostMapping("/addOpenAmsDispatchSaleOrder/{orderMaterialId}")
|
|
|
|
+ public RESTfulResult addOpenAmsDispatchSaleOrder(@PathVariable("orderMaterialId") BigDecimal orderMaterialId){
|
|
|
|
+ if(orderMaterialId==null){
|
|
return failed();
|
|
return failed();
|
|
}
|
|
}
|
|
//新增公开派单
|
|
//新增公开派单
|
|
AmsDispatchSaleOrder ad = new AmsDispatchSaleOrder();
|
|
AmsDispatchSaleOrder ad = new AmsDispatchSaleOrder();
|
|
- ad.setDispatchId(amsDispatchSaleOrderService.selectMaxId());
|
|
|
|
- ad.setSaleOrderMaterialId(saleOrderMaterialId);
|
|
|
|
|
|
+ Integer id = amsDispatchSaleOrderMapper.selectDispatchIdBySaleOrderMaterialId(orderMaterialId.intValue());
|
|
|
|
+ ad.setDispatchId(DataChange.dataToBigDecimal(id));
|
|
|
|
+ ad.setSaleOrderMaterialId(orderMaterialId);
|
|
//成交类型(0:定向派单;1:公开抢单)
|
|
//成交类型(0:定向派单;1:公开抢单)
|
|
ad.setDispatchType(new BigDecimal(1));
|
|
ad.setDispatchType(new BigDecimal(1));
|
|
- //销售订单车序号状态(0:自由;1:锁定)
|
|
|
|
- ad.setDispatchStatus(new BigDecimal(0));
|
|
|
|
- amsDispatchSaleOrderService.insert(ad);
|
|
|
|
- return success("插入成功");
|
|
|
|
|
|
+ //销售订单车序号状态(0:已下发;1:未下发)
|
|
|
|
+ ad.setDispatchStatus(new BigDecimal(1));
|
|
|
|
+ //更新公开派单状态
|
|
|
|
+ amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(ad);
|
|
|
|
+ return success("更新成功");
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|