优化后,可运行版本

master
anthonywj 4 years ago
parent bd81c60c9e
commit a3256cda2a

@ -1,5 +1,7 @@
package com.glxp.api.admin.controller.basic; package com.glxp.api.admin.controller.basic;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.entity.basic.UdiInfoEntity; import com.glxp.api.admin.entity.basic.UdiInfoEntity;
import com.glxp.api.admin.entity.basic.UdiRelevanceEntity; import com.glxp.api.admin.entity.basic.UdiRelevanceEntity;
@ -8,18 +10,22 @@ import com.glxp.api.admin.entity.inout.WarehouseEntity;
import com.glxp.api.admin.httpclient.UdiDlHttpClient; import com.glxp.api.admin.httpclient.UdiDlHttpClient;
import com.glxp.api.admin.req.basic.CombineRequest; import com.glxp.api.admin.req.basic.CombineRequest;
import com.glxp.api.admin.req.basic.FilterUdiInfoRequest; import com.glxp.api.admin.req.basic.FilterUdiInfoRequest;
import com.glxp.api.admin.req.basic.PostSmpUdiInfoRequest;
import com.glxp.api.admin.req.inout.DeleteRequest; import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.res.PageSimpleResponse; import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.basic.UdiRelevanceResponse; import com.glxp.api.admin.res.basic.UdiRelevanceResponse;
import com.glxp.api.admin.res.inout.WarehouseResponse;
import com.glxp.api.admin.service.basic.UdiInfoService; import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService; import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.info.SystemParamConfigService; import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.CodesService; import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.thread.BasicUpdateproductService; import com.glxp.api.admin.thread.BasicUpdateproductService;
import com.glxp.api.admin.util.DateUtil; import com.glxp.api.admin.util.DateUtil;
import com.glxp.api.admin.util.HttpClient;
import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils; import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.validation.BindingResult; import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
@ -28,7 +34,9 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
@RestController @RestController
public class UdiRelevanceController { public class UdiRelevanceController {
@ -224,5 +232,51 @@ public class UdiRelevanceController {
return ResultVOUtils.success("添加成功"); return ResultVOUtils.success("添加成功");
} }
//上传产品信息至供应商管理平台
@PostMapping("/udiwms/smp/udirl/upload")
public BaseResponse uploadSMP(@RequestBody CombineRequest combineRequest) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_uploadProduct_url");
String postUrl;
if (systemParamConfigEntity == null)
return ResultVOUtils.error(500, "上传供应商平台接口地址未定义");
else
postUrl = systemParamConfigEntity.getParamValue();
List<String> ids = combineRequest.getKeys();
if (ids != null && ids.size() > 0) {
List<UdiRelevanceResponse> udiRelevanceResponses = new ArrayList<>();
List<PostSmpUdiInfoRequest> postSmpUdiInfoRequests = new ArrayList<>();
for (int i = 0; i < ids.size(); i++) {
FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest();
filterUdiInfoRequest.setId(ids.get(i));
List<UdiRelevanceResponse> temps = udiRelevanceService.filterUdiRelevance(filterUdiInfoRequest);
if (temps != null && temps.size() > 0) {
udiRelevanceResponses.addAll(temps);
}
}
List<PostSmpUdiInfoRequest> postDatas = udiRelevanceResponses.stream().map(item ->
{
PostSmpUdiInfoRequest postSmpUdiInfoRequest = new PostSmpUdiInfoRequest();
BeanUtils.copyProperties(item, postSmpUdiInfoRequest);
postSmpUdiInfoRequest.setErpId(item.getThirdId());
postSmpUdiInfoRequest.setErpName(item.getThirdName());
return postSmpUdiInfoRequest;
}).collect(Collectors.toList());
String response = HttpClient.uCloudPost(postUrl, postDatas);
BaseResponse baseResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse>() {
});
if (baseResponse.getCode() == 20000) {
return ResultVOUtils.success("上传成功!");
} else {
return ResultVOUtils.error(baseResponse.getCode(), baseResponse.getMessage());
}
}else {
return ResultVOUtils.error(500,"未选择产品信息");
}
}
} }

@ -1,39 +0,0 @@
package com.glxp.api.admin.controller.info;
import com.glxp.api.admin.entity.info.SetupEntity;
import com.glxp.api.admin.req.info.FilterSetupRequest;
import com.glxp.api.admin.service.info.SetupService;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
@RestController
public class SetupController {
@Resource
private SetupService setupService;
@GetMapping("/udi/info/setup")
public BaseResponse getCompanyInfo(FilterSetupRequest filterSetupRequest) {
filterSetupRequest.setId(1);
SetupEntity setupEntity = setupService.findSetup(filterSetupRequest);
if (setupEntity != null) {
return ResultVOUtils.success(setupEntity);
}
return ResultVOUtils.error(500, "设置信息为空");
}
@PostMapping("/udi/info/setup/modify")
public BaseResponse modifyCompany(@RequestBody SetupEntity setupEntity) {
setupEntity.setId(1);
setupService.modifySetup(setupEntity);
return ResultVOUtils.success("修改成功");
}
}

@ -51,13 +51,9 @@ public class OrderController {
@Resource @Resource
private SystemParamConfigService systemParamConfigService; private SystemParamConfigService systemParamConfigService;
@Value("${UCLOD_SERVER_URL}")
private String ucloudUrl;
@GetMapping("udiwms/inout/order/status")
@GetMapping("udiwms/inout/order/error")
public BaseResponse listOrderError(OrderFilterRequest orderFilterRequest) { public BaseResponse listOrderError(OrderFilterRequest orderFilterRequest) {
orderFilterRequest.setStatus(ConstantStatus.ORDER_STATUS_FAIL);
List<OrderEntity> orderEntityList = orderService.filterList(orderFilterRequest); List<OrderEntity> orderEntityList = orderService.filterList(orderFilterRequest);
PageInfo<OrderEntity> pageInfo; PageInfo<OrderEntity> pageInfo;
pageInfo = new PageInfo<>(orderEntityList); pageInfo = new PageInfo<>(orderEntityList);
@ -99,15 +95,8 @@ public class OrderController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
} }
boolean b = orderService.updateUnit(orderEntity); orderService.updateUnit(orderEntity);
if (!b) { warehouseService.updateUnit(orderEntity.getId(), orderEntity.getFromCorpId(), orderEntity.getFromCorp());
return ResultVOUtils.error(ResultEnum.NOT_NETWORK);
}
b = warehouseService.updateUnit(orderEntity.getId(), orderEntity.getFromCorpId(), orderEntity.getFromCorp());
if (!b) {
return ResultVOUtils.error(ResultEnum.NOT_NETWORK);
}
return ResultVOUtils.success("添加成功"); return ResultVOUtils.success("添加成功");
} }
@ -202,7 +191,11 @@ public class OrderController {
} }
mainOrderEntity.setErpFk(docidStr); mainOrderEntity.setErpFk(docidStr);
orderService.updateOrder(mainOrderEntity); orderService.updateOrder(mainOrderEntity);
List<ErpOrderEntity> erpOrderEntities = new ErpOrderClient(ucloudUrl).getErpOrder(docids, mainOrderEntity.getAction()); SystemParamConfigEntity erpEntity = systemParamConfigService.selectByParamKey("erp_order_query");
if (erpEntity == null) {
return ResultVOUtils.error(500, "ERP出入库单据查询接口地址未定义");
}
List<ErpOrderEntity> erpOrderEntities = new ErpOrderClient(erpEntity.getParamValue()).getErpOrder(docids, mainOrderEntity.getAction());
if (erpOrderEntities != null && erpOrderEntities.size() > 0) { if (erpOrderEntities != null && erpOrderEntities.size() > 0) {
List<ErpOrderEntity> returnOrders = new ContrastErpUtil().transErp(erpOrderEntities, udiRelevanceService, mainOrder); List<ErpOrderEntity> returnOrders = new ContrastErpUtil().transErp(erpOrderEntities, udiRelevanceService, mainOrder);
myErpOrderService.insertErpOrders(returnOrders); myErpOrderService.insertErpOrders(returnOrders);

@ -18,7 +18,6 @@ import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.OrderDetailService; import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.OrderService; import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.service.inout.CodesService; import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.thread.InvDlErpStockService;
import com.glxp.api.admin.thread.IoTransInoutService; import com.glxp.api.admin.thread.IoTransInoutService;
import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.res.BaseResponse;
@ -49,8 +48,6 @@ public class OrderDetailController {
OrderService orderService; OrderService orderService;
@Resource @Resource
private UdiRelevanceService udiRelevanceService; private UdiRelevanceService udiRelevanceService;
@Resource
private InvDlErpStockService dlErpStockService;
@Resource @Resource
@ -175,7 +172,7 @@ public class OrderDetailController {
@GetMapping("/warehouse/dlErpStock1") @GetMapping("/warehouse/dlErpStock1")
public BaseResponse dlErpStock() { public BaseResponse dlErpStock() {
dlErpStockService.dlErpStock(); // dlErpStockService.dlErpStock();
return ResultVOUtils.success("后台已自动更新,请稍后刷新查看!"); return ResultVOUtils.success("后台已自动更新,请稍后刷新查看!");
} }

@ -132,7 +132,7 @@ public class WareHouseController {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
} }
transInoutService.repeatCommit(commitRequest); transInoutService.repeatCommit(commitRequest);
return ResultVOUtils.success("提交成功"); return ResultVOUtils.success("提交成功,后台已开启重码校验,请稍后刷新查看!");
} }
} }

@ -103,6 +103,7 @@ public class ContrastErpUtil {
} else { } else {
orderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS); orderEntity.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS);
} }
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_SUCCESS);
orderService.updateOrder(orderEntity); orderService.updateOrder(orderEntity);
if (errorData.size() > 0) { if (errorData.size() > 0) {
new InoutUtils(udiUrl).generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, errorData); new InoutUtils(udiUrl).generateConstrastDetail(udiInfoService, udiRelevanceService, myErpOrderService, errorData);

@ -4,12 +4,17 @@ import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference; import com.alibaba.fastjson.TypeReference;
import com.glxp.api.admin.entity.basic.UdiRelevanceEntity; import com.glxp.api.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.api.admin.entity.basic.UdiEntity; import com.glxp.api.admin.entity.basic.UdiEntity;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.httpclient.ErpInvClient;
import com.glxp.api.admin.req.basic.FilterUdiInfoRequest; import com.glxp.api.admin.req.basic.FilterUdiInfoRequest;
import com.glxp.api.admin.req.basic.UOnhandQueryRequest; import com.glxp.api.admin.req.basic.UOnhandQueryRequest;
import com.glxp.api.admin.req.inventory.ErpOnhandRequest;
import com.glxp.api.admin.res.PageSimpleResponse; import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.basic.UOnhandQueryResponse; import com.glxp.api.admin.res.basic.UOnhandQueryResponse;
import com.glxp.api.admin.res.basic.UdiRelevanceResponse; import com.glxp.api.admin.res.basic.UdiRelevanceResponse;
import com.glxp.api.admin.res.inventory.ErpOnHandResponse;
import com.glxp.api.admin.service.basic.UdiRelevanceService; import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.util.FilterUdiUtils; import com.glxp.api.admin.util.FilterUdiUtils;
import com.glxp.api.admin.util.HttpClient; import com.glxp.api.admin.util.HttpClient;
import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.enums.ResultEnum;
@ -28,15 +33,14 @@ import java.util.Map;
@RestController @RestController
public class InvErpOnhandController { public class InvErpOnhandController {
@Value("${UCLOD_SERVER_URL}")
private String ucloudUrl;
@Resource @Resource
UdiRelevanceService udiRelevanceService; UdiRelevanceService udiRelevanceService;
@Resource
private SystemParamConfigService systemParamConfigService;
@GetMapping("/udiwms/inv/getOnHand")
@GetMapping("/warehouse/ucloud/onHand") public BaseResponse getOnhand(ErpOnhandRequest onhandQueryRequest,
public BaseResponse getOnhand(UOnhandQueryRequest onhandQueryRequest,
BindingResult bindingResult) { BindingResult bindingResult) {
if (bindingResult.hasErrors()) { if (bindingResult.hasErrors()) {
@ -48,8 +52,8 @@ public class InvErpOnhandController {
UdiRelevanceResponse udiRelevanceResponse = findByNamecode(udiEntity.getUdi()); UdiRelevanceResponse udiRelevanceResponse = findByNamecode(udiEntity.getUdi());
if (udiRelevanceResponse != null) { if (udiRelevanceResponse != null) {
String thirdId = udiRelevanceResponse.getThirdId(); String thirdId = udiRelevanceResponse.getThirdId();
onhandQueryRequest.setInventory(thirdId); onhandQueryRequest.setNameCode(thirdId);
onhandQueryRequest.setBatchcode(udiEntity.getBatchNo()); onhandQueryRequest.setBatchNo(udiEntity.getBatchNo());
} else { } else {
return ResultVOUtils.error(500, "产品信息未维护!"); return ResultVOUtils.error(500, "产品信息未维护!");
@ -61,41 +65,16 @@ public class InvErpOnhandController {
} }
} else if (onhandQueryRequest.getNameCode() != null) { } else if (onhandQueryRequest.getNameCode() != null) {
UdiRelevanceResponse udiRelevanceResponse = findByNamecode(onhandQueryRequest.getNameCode()); UdiRelevanceResponse udiRelevanceResponse = findByNamecode(onhandQueryRequest.getNameCode());
onhandQueryRequest.setInventory(udiRelevanceResponse.getThirdId()); onhandQueryRequest.setInventoryCode(udiRelevanceResponse.getThirdId());
}
Map<String, Object> paramMap = new HashMap<>(16);
if (onhandQueryRequest.getBatchcode() != null && !onhandQueryRequest.getBatchcode().equals(""))
paramMap.put("batchcode", onhandQueryRequest.getBatchcode());
if (onhandQueryRequest.getWarehouse() != null && !onhandQueryRequest.getWarehouse().equals(""))
paramMap.put("warehouse", onhandQueryRequest.getWarehouse());
if (onhandQueryRequest.getIsGroupByBatchcode() != null && !onhandQueryRequest.getIsGroupByBatchcode().equals(""))
paramMap.put("isGroupByBatchcode", onhandQueryRequest.getIsGroupByBatchcode());
if (onhandQueryRequest.getNumcondition() != null && !onhandQueryRequest.getNumcondition().equals(""))
paramMap.put("numcondition", onhandQueryRequest.getNumcondition());
paramMap.put("inventory", onhandQueryRequest.getInventory());
String response = HttpClient.mipsGet(ucloudUrl + "/uclooud/basic/onhandQuery", paramMap);
try {
BaseResponse<PageSimpleResponse<UOnhandQueryResponse>> onHandsResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<UOnhandQueryResponse>>>() {
});
List<UOnhandQueryResponse> invmandocResponses = onHandsResponse.getData().getList();
for (UOnhandQueryResponse invmandocResponse : invmandocResponses) {
UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectByThirdId(invmandocResponse.getCinventory_code());
if (udiRelevanceEntity != null) {
invmandocResponse.setChecked(true);
} else {
invmandocResponse.setChecked(false);
}
}
return onHandsResponse;
} catch (Exception e) {
e.printStackTrace();
return ResultVOUtils.error(500, "连接U8云下载服务出错");
} }
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_onhand_query");
String onHandUrl;
if (systemParamConfigEntity == null)
return ResultVOUtils.error(500, "ERP现存量接口地址未定义");
else
onHandUrl = systemParamConfigEntity.getParamValue();
BaseResponse<PageSimpleResponse<ErpOnHandResponse>> responseBaseResponse = new ErpInvClient().getOnHandResponse(onhandQueryRequest, onHandUrl);
return responseBaseResponse;
} }
@ -111,5 +90,4 @@ public class InvErpOnhandController {
} }
} }

@ -4,19 +4,14 @@ import com.github.pagehelper.PageInfo;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity; import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.httpclient.ErpInvClient; import com.glxp.api.admin.httpclient.ErpInvClient;
import com.glxp.api.admin.req.inventory.ErpOnhandRequest; import com.glxp.api.admin.req.inventory.ErpOnhandRequest;
import com.glxp.api.admin.res.inout.PurchaseinResponse; import com.glxp.api.admin.entity.inventory.StockPrintEntity;
import com.glxp.api.admin.entity.basic.ErpStockEntity;
import com.glxp.api.admin.entity.basic.StockPrintEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest; import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import com.glxp.api.admin.req.basic.UpdatePrintStatusRequest; import com.glxp.api.admin.req.basic.UpdatePrintStatusRequest;
import com.glxp.api.admin.req.inout.DeleteRequest; import com.glxp.api.admin.req.inout.DeleteRequest;
import com.glxp.api.admin.req.inout.ImportErpOrderRequest;
import com.glxp.api.admin.res.PageSimpleResponse; import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.inventory.ErpOnHandResponse; import com.glxp.api.admin.res.inventory.ErpOnHandResponse;
import com.glxp.api.admin.service.inventory.InvErpStockService;
import com.glxp.api.admin.service.inventory.InvStockPrintService; import com.glxp.api.admin.service.inventory.InvStockPrintService;
import com.glxp.api.admin.service.info.SystemParamConfigService; import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.thread.InvDlErpStockService;
import com.glxp.api.admin.thread.InvImportStockService; import com.glxp.api.admin.thread.InvImportStockService;
import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.enums.ResultEnum;
import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.res.BaseResponse;
@ -25,7 +20,6 @@ import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List; import java.util.List;
@RestController @RestController
@ -35,10 +29,6 @@ public class InvPrintController {
@Resource @Resource
InvImportStockService importStockService; InvImportStockService importStockService;
@Resource @Resource
private InvDlErpStockService dlErpStockService;
@Resource
private InvErpStockService erpStockService;
@Resource
private SystemParamConfigService systemParamConfigService; private SystemParamConfigService systemParamConfigService;
@PostMapping("/udiwarehouse/stockPrint/filter") @PostMapping("/udiwarehouse/stockPrint/filter")
@ -172,37 +162,28 @@ public class InvPrintController {
} }
@PostMapping("/warehouse/stockPrint/importErpStock")
public BaseResponse importErpStock(@RequestBody ImportErpOrderRequest importErpOrderRequest, BindingResult bindingResult) {
if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
}
List<PurchaseinResponse> docids = importErpOrderRequest.getPurchaseinResponses();
if (docids != null && docids.size() > 0) {
for (PurchaseinResponse purchaseinResponse : docids) {
List<ErpStockEntity> stockEntities = new ArrayList<>();
for (PurchaseinResponse.SubPurchase subPurchase : purchaseinResponse.getSubPurchases()) {
ErpStockEntity erpStockEntity = new ErpStockEntity();
erpStockEntity.setOrderId(purchaseinResponse.getVbillcode());
erpStockEntity.setExpirationDate(subPurchase.getDvalidate());
erpStockEntity.setCode(subPurchase.getInventory_code());
erpStockEntity.setBatchNo(subPurchase.getVbatchcode());
erpStockEntity.setName(subPurchase.getInventory_name());
erpStockEntity.setCount(subPurchase.getDtlgoodsqty() + "");
stockEntities.add(erpStockEntity);
}
erpStockService.insertErpStocks(stockEntities);
}
}
return ResultVOUtils.success("导入成功");
}
@GetMapping("/warehouse/stockPrint/dlErpStock") @GetMapping("/warehouse/stockPrint/dlErpStock")
public BaseResponse dlErpStock() { public BaseResponse dlErpStock() {
dlErpStockService.dlErpStock(); // dlErpStockService.dlErpStock();
return ResultVOUtils.success("后台已自动更新,请稍后刷新查看!"); return ResultVOUtils.success("后台已自动更新,请稍后刷新查看!");
} }
@GetMapping("/udiwarehouse/stockPrint/importBycode")
public BaseResponse importBycode(FilterStockprintRequest stockprintRequest) {
if (stockprintRequest.getThirdId() == null || stockprintRequest.getThirdId().equals("")) {
return ResultVOUtils.error(500, "存货编码不能为空");
}
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_inv_product_query");
String url;
if (systemParamConfigEntity == null)
return ResultVOUtils.error(500, "ERP库存产品信息查询接口地址未定义");
else url = systemParamConfigEntity.getParamValue();
importStockService.updateByCode(stockprintRequest.getThirdId(),url);
return ResultVOUtils.success("后台已开始自动更新,请稍后刷新查看");
}
} }

@ -1,7 +1,7 @@
package com.glxp.api.admin.dao.info; package com.glxp.api.admin.dao.info;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
@Mapper @Mapper

@ -1,24 +0,0 @@
package com.glxp.api.admin.dao.inventory;
import com.glxp.api.admin.entity.basic.ErpStockEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface InvErpStockDao {
ErpStockEntity findByCode(@Param("code") String code, @Param("batchNo") String batchNo);
boolean insertErpStock(ErpStockEntity stockPrintEntity);
boolean insertErpStocks(@Param("erpStockEntities") List<ErpStockEntity> erpStockEntities);
boolean updateErpStock(ErpStockEntity udiInfoEntity);
boolean deleteById(@Param("id") String id);
}

@ -1,8 +1,6 @@
package com.glxp.api.admin.dao.inventory; package com.glxp.api.admin.dao.inventory;
import com.glxp.api.admin.entity.basic.StockPrintEntity;
import com.glxp.api.admin.entity.inout.StockCheckEntity; import com.glxp.api.admin.entity.inout.StockCheckEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import com.glxp.api.admin.req.inout.FilterStockCheckRequest; import com.glxp.api.admin.req.inout.FilterStockCheckRequest;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;

@ -1,9 +1,7 @@
package com.glxp.api.admin.dao.inventory; package com.glxp.api.admin.dao.inventory;
import com.glxp.api.admin.entity.basic.StockPrintEntity; import com.glxp.api.admin.entity.inventory.StockPrintEntity;
import com.glxp.api.admin.entity.basic.UdiInfoEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest; import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import com.glxp.api.admin.req.basic.FilterUdiInfoRequest;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;

@ -1,4 +1,4 @@
package com.glxp.api.admin.entity.basic; package com.glxp.api.admin.entity.inventory;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package com.glxp.api.admin.entity.basic; package com.glxp.api.admin.entity.inventory;
import lombok.Data; import lombok.Data;

@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference; import com.alibaba.fastjson.TypeReference;
import com.glxp.api.admin.req.inventory.ErpOnhandRequest; import com.glxp.api.admin.req.inventory.ErpOnhandRequest;
import com.glxp.api.admin.res.PageSimpleResponse; import com.glxp.api.admin.res.PageSimpleResponse;
import com.glxp.api.admin.res.inventory.ErpInvProductResponse;
import com.glxp.api.admin.res.inventory.ErpOnHandResponse; import com.glxp.api.admin.res.inventory.ErpOnHandResponse;
import com.glxp.api.admin.util.HttpClient; import com.glxp.api.admin.util.HttpClient;
import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.res.BaseResponse;
@ -17,6 +18,13 @@ public class ErpInvClient {
public List<ErpOnHandResponse> getOnHand(ErpOnhandRequest onhandRequest, String url) { public List<ErpOnHandResponse> getOnHand(ErpOnhandRequest onhandRequest, String url) {
BaseResponse<PageSimpleResponse<ErpOnHandResponse>> onHandsResponse = getOnHandResponse(onhandRequest, url);
List<ErpOnHandResponse> erpOnHandResponses = onHandsResponse.getData().getList();
return erpOnHandResponses;
}
public BaseResponse<PageSimpleResponse<ErpOnHandResponse>> getOnHandResponse(ErpOnhandRequest onhandRequest, String url) {
Map<String, Object> paramMap = new HashMap<>(16); Map<String, Object> paramMap = new HashMap<>(16);
if (onhandRequest.getBatchNo() != null && !onhandRequest.getBatchNo().equals("")) if (onhandRequest.getBatchNo() != null && !onhandRequest.getBatchNo().equals(""))
paramMap.put("batchNo", onhandRequest.getBatchNo()); paramMap.put("batchNo", onhandRequest.getBatchNo());
@ -29,11 +37,37 @@ public class ErpInvClient {
BaseResponse<PageSimpleResponse<ErpOnHandResponse>> onHandsResponse = BaseResponse<PageSimpleResponse<ErpOnHandResponse>> onHandsResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpOnHandResponse>>>() { JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpOnHandResponse>>>() {
}); });
List<ErpOnHandResponse> erpOnHandResponses = onHandsResponse.getData().getList(); return onHandsResponse;
return erpOnHandResponses; } catch (Exception e) {
e.printStackTrace();
}
return null;
}
public BaseResponse<PageSimpleResponse<ErpInvProductResponse>> getInvPrdoductResponse(ErpOnhandRequest onhandRequest, String url) {
Map<String, Object> paramMap = new HashMap<>(16);
if (onhandRequest.getBatchNo() != null && !onhandRequest.getBatchNo().equals(""))
paramMap.put("batchNo", onhandRequest.getBatchNo());
if (onhandRequest.getWarehouseCode() != null && !onhandRequest.getWarehouseCode().equals(""))
paramMap.put("warehouseCode", onhandRequest.getWarehouseCode());
if (onhandRequest.getInventoryCode() != null && !onhandRequest.getInventoryCode().equals(""))
paramMap.put("inventoryCode", onhandRequest.getInventoryCode());
String response = HttpClient.mipsGet(url, paramMap);
try {
BaseResponse<PageSimpleResponse<ErpInvProductResponse>> onHandsResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<ErpInvProductResponse>>>() {
});
return onHandsResponse;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
return null; return null;
} }
public List<ErpInvProductResponse> getInvPrdoduct(ErpOnhandRequest onhandRequest, String url) {
BaseResponse<PageSimpleResponse<ErpInvProductResponse>> responseBaseResponse = getInvPrdoductResponse(onhandRequest, url);
List<ErpInvProductResponse> responseList = responseBaseResponse.getData().getList();
return responseList;
}
} }

@ -24,7 +24,6 @@ public class ErpOrderClient {
private String url; private String url;
public ErpOrderClient() { public ErpOrderClient() {
} }
public ErpOrderClient(String url) { public ErpOrderClient(String url) {
@ -35,9 +34,9 @@ public class ErpOrderClient {
List<ErpOrderEntity> erpOrderEntities = new ArrayList<>(); List<ErpOrderEntity> erpOrderEntities = new ArrayList<>();
if (billCodes != null && billCodes.size() > 0) { if (billCodes != null && billCodes.size() > 0) {
for (int i = 0; i < billCodes.size(); i++) { for (int i = 0; i < billCodes.size(); i++) {
ErpOrderEntity erpOrderEntity = getErpOrder(billCodes.get(i), action); List<ErpOrderEntity> erpOrderEntitys = getErpOrder(billCodes.get(i), action);
if (erpOrderEntity != null) { if (erpOrderEntitys != null) {
erpOrderEntities.add(erpOrderEntity); erpOrderEntities.addAll(erpOrderEntitys);
} }
} }
} }
@ -111,17 +110,17 @@ public class ErpOrderClient {
return null; return null;
} }
public ErpOrderEntity getErpOrder(String billCode, String action) { public List<ErpOrderEntity> getErpOrder(String billCode, String action) {
FilterOrderRequest filterOrderRequest = new FilterOrderRequest(); FilterOrderRequest filterOrderRequest = new FilterOrderRequest();
filterOrderRequest.setPage(1); filterOrderRequest.setPage(1);
filterOrderRequest.setLimit(1); filterOrderRequest.setLimit(1);
filterOrderRequest.setBillAction(action); filterOrderRequest.setBillAction(action);
filterOrderRequest.setBillNo(billCode); filterOrderRequest.setBillNo(billCode);
List<ErpOrderEntity> erpOrderEntities = getErpOrder(filterOrderRequest); List<ErpOrderEntity> erpOrderEntities = getErpOrder(filterOrderRequest);
if (erpOrderEntities != null && erpOrderEntities.size() > 0) { // if (erpOrderEntities != null && erpOrderEntities.size() > 0) {
return erpOrderEntities.get(0); // return erpOrderEntities.get(0);
} // }
return null; return erpOrderEntities;
} }
public BaseResponse postBill(Map<String, List<ErpOrderEntity>> postMap, String billAction, String uploadUrl) { public BaseResponse postBill(Map<String, List<ErpOrderEntity>> postMap, String billAction, String uploadUrl) {

@ -12,5 +12,6 @@ public class FilterUdiInfoRequest extends ListPageRequest {
private String uuid; private String uuid;
private String ggxh; private String ggxh;
private String thirdId; private String thirdId;
private String id;
} }

@ -0,0 +1,228 @@
package com.glxp.api.admin.req.basic;
public class PostSmpUdiInfoRequest {
/**
* nameCode : 321
* packLevel :
* bhxjsl : 0
* bhzxxsbzsl : 0
* zxxsbzbhsydysl : 0
* bhxjcpbm :
* bzcj :
* deviceRecordKey :
* cpmctymc :
* cplb :
* flbm :
* ggxh :
* qxlb :
* tyshxydm :
* ylqxzcrbarmc :
* zczbhhzbapzbh :
* sjcpbm :
* versionNumber : 0
* diType : 0
* erpId :
* erpName :
* uuid : 123
*/
private String nameCode;
private String packLevel;
private int bhxjsl;
private int bhzxxsbzsl;
private int zxxsbzbhsydysl;
private String bhxjcpbm;
private String bzcj;
private String deviceRecordKey;
private String cpmctymc;
private String cplb;
private String flbm;
private String ggxh;
private String qxlb;
private String tyshxydm;
private String ylqxzcrbarmc;
private String zczbhhzbapzbh;
private String sjcpbm;
private int versionNumber;
private int diType;
private String erpId;
private String erpName;
private String uuid;
public String getNameCode() {
return nameCode;
}
public void setNameCode(String nameCode) {
this.nameCode = nameCode;
}
public String getPackLevel() {
return packLevel;
}
public void setPackLevel(String packLevel) {
this.packLevel = packLevel;
}
public int getBhxjsl() {
return bhxjsl;
}
public void setBhxjsl(int bhxjsl) {
this.bhxjsl = bhxjsl;
}
public int getBhzxxsbzsl() {
return bhzxxsbzsl;
}
public void setBhzxxsbzsl(int bhzxxsbzsl) {
this.bhzxxsbzsl = bhzxxsbzsl;
}
public int getZxxsbzbhsydysl() {
return zxxsbzbhsydysl;
}
public void setZxxsbzbhsydysl(int zxxsbzbhsydysl) {
this.zxxsbzbhsydysl = zxxsbzbhsydysl;
}
public String getBhxjcpbm() {
return bhxjcpbm;
}
public void setBhxjcpbm(String bhxjcpbm) {
this.bhxjcpbm = bhxjcpbm;
}
public String getBzcj() {
return bzcj;
}
public void setBzcj(String bzcj) {
this.bzcj = bzcj;
}
public String getDeviceRecordKey() {
return deviceRecordKey;
}
public void setDeviceRecordKey(String deviceRecordKey) {
this.deviceRecordKey = deviceRecordKey;
}
public String getCpmctymc() {
return cpmctymc;
}
public void setCpmctymc(String cpmctymc) {
this.cpmctymc = cpmctymc;
}
public String getCplb() {
return cplb;
}
public void setCplb(String cplb) {
this.cplb = cplb;
}
public String getFlbm() {
return flbm;
}
public void setFlbm(String flbm) {
this.flbm = flbm;
}
public String getGgxh() {
return ggxh;
}
public void setGgxh(String ggxh) {
this.ggxh = ggxh;
}
public String getQxlb() {
return qxlb;
}
public void setQxlb(String qxlb) {
this.qxlb = qxlb;
}
public String getTyshxydm() {
return tyshxydm;
}
public void setTyshxydm(String tyshxydm) {
this.tyshxydm = tyshxydm;
}
public String getYlqxzcrbarmc() {
return ylqxzcrbarmc;
}
public void setYlqxzcrbarmc(String ylqxzcrbarmc) {
this.ylqxzcrbarmc = ylqxzcrbarmc;
}
public String getZczbhhzbapzbh() {
return zczbhhzbapzbh;
}
public void setZczbhhzbapzbh(String zczbhhzbapzbh) {
this.zczbhhzbapzbh = zczbhhzbapzbh;
}
public String getSjcpbm() {
return sjcpbm;
}
public void setSjcpbm(String sjcpbm) {
this.sjcpbm = sjcpbm;
}
public int getVersionNumber() {
return versionNumber;
}
public void setVersionNumber(int versionNumber) {
this.versionNumber = versionNumber;
}
public int getDiType() {
return diType;
}
public void setDiType(int diType) {
this.diType = diType;
}
public String getErpId() {
return erpId;
}
public void setErpId(String erpId) {
this.erpId = erpId;
}
public String getErpName() {
return erpName;
}
public void setErpName(String erpName) {
this.erpName = erpName;
}
public String getUuid() {
return uuid;
}
public void setUuid(String uuid) {
this.uuid = uuid;
}
}

@ -1,4 +1,4 @@
package com.glxp.api.admin.req.udid; package com.glxp.api.admin.req.info;
import lombok.Data; import lombok.Data;

@ -11,4 +11,7 @@ public class ErpOnhandRequest {
private String warehouseCode; private String warehouseCode;
private String inventoryCode; private String inventoryCode;
private List<String> inventoryCodes; private List<String> inventoryCodes;
private String udiCode;
private String nameCode;
} }

@ -0,0 +1,15 @@
package com.glxp.api.admin.res.inventory;
import lombok.Data;
@Data
public class ErpInvProductResponse {
private String code;
private String batchNo;
private String manufacturingDate;
private String expirationDate;
private String warehouseCode;
private String warehouseName;
private String count;
}

@ -23,8 +23,11 @@ public class UdiRelevanceServiceImpl implements UdiRelevanceService {
if (filterUdiInfoRequest == null) { if (filterUdiInfoRequest == null) {
return Collections.emptyList(); return Collections.emptyList();
} }
int offset = (filterUdiInfoRequest.getPage() - 1) * filterUdiInfoRequest.getLimit(); if(filterUdiInfoRequest.getPage()!=null){
PageHelper.offsetPage(offset, filterUdiInfoRequest.getLimit()); int offset = (filterUdiInfoRequest.getPage() - 1) * filterUdiInfoRequest.getLimit();
PageHelper.offsetPage(offset, filterUdiInfoRequest.getLimit());
}
List<UdiRelevanceResponse> data = udiRelevanceDao.filterUdiRelevance(filterUdiInfoRequest); List<UdiRelevanceResponse> data = udiRelevanceDao.filterUdiRelevance(filterUdiInfoRequest);
return data; return data;
} }

@ -1,19 +0,0 @@
package com.glxp.api.admin.service.info;
import com.glxp.api.admin.entity.info.SetupEntity;
import com.glxp.api.admin.req.info.FilterSetupRequest;
import lombok.Data;
import java.util.List;
public interface SetupService {
SetupEntity selectSetup();
SetupEntity findSetup(FilterSetupRequest filterSetupRequest);
boolean modifySetup(SetupEntity setupEntity);
boolean insertSetup(SetupEntity setupEntity);
}

@ -1,40 +0,0 @@
package com.glxp.api.admin.service.info.impl;
import com.glxp.api.admin.dao.info.SetupDao;
import com.glxp.api.admin.entity.info.SetupEntity;
import com.glxp.api.admin.req.info.FilterSetupRequest;
import com.glxp.api.admin.service.info.SetupService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
@Service
public class SetupServiceImpl implements SetupService {
@Resource
SetupDao setupDao;
@Override
public SetupEntity selectSetup() {
FilterSetupRequest filterSetupRequest = new FilterSetupRequest();
filterSetupRequest.setId(1);
return setupDao.findSetup(filterSetupRequest);
}
@Override
public SetupEntity findSetup(FilterSetupRequest filterSetupRequest) {
return setupDao.findSetup(filterSetupRequest);
}
@Override
public boolean modifySetup(SetupEntity setupEntity) {
return setupDao.modifySetup(setupEntity);
}
@Override
public boolean insertSetup(SetupEntity setupEntity) {
return setupDao.insertSetup(setupEntity);
}
}

@ -1,21 +0,0 @@
package com.glxp.api.admin.service.inventory;
import com.glxp.api.admin.entity.basic.ErpStockEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import java.util.List;
public interface InvErpStockService {
ErpStockEntity findByCode(String nameCode,String batchNo);
boolean insertErpStock(ErpStockEntity stockPrintEntity);
boolean insertErpStocks(List<ErpStockEntity> stockPrintEntities);
boolean updateErpStock(ErpStockEntity udiInfoEntity);
boolean deleteById(String id);
}

@ -1,6 +1,6 @@
package com.glxp.api.admin.service.inventory; package com.glxp.api.admin.service.inventory;
import com.glxp.api.admin.entity.basic.StockPrintEntity; import com.glxp.api.admin.entity.inventory.StockPrintEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest; import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import java.util.List; import java.util.List;

@ -1,41 +0,0 @@
package com.glxp.api.admin.service.inventory.impl;
import com.glxp.api.admin.dao.inventory.InvErpStockDao;
import com.glxp.api.admin.entity.basic.ErpStockEntity;
import com.glxp.api.admin.service.inventory.InvErpStockService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
@Service
public class InvErpStockServiceImpl implements InvErpStockService {
@Resource
InvErpStockDao erpStockDao;
@Override
public ErpStockEntity findByCode(String nameCode, String batchNo) {
return erpStockDao.findByCode(nameCode, batchNo);
}
@Override
public boolean insertErpStock(ErpStockEntity erpStockEntity) {
return erpStockDao.insertErpStock(erpStockEntity);
}
@Override
public boolean insertErpStocks(List<ErpStockEntity> erpStockEntities) {
return erpStockDao.insertErpStocks(erpStockEntities);
}
@Override
public boolean updateErpStock(ErpStockEntity erpStockEntity) {
return erpStockDao.updateErpStock(erpStockEntity);
}
@Override
public boolean deleteById(String id) {
return erpStockDao.deleteById(id);
}
}

@ -2,7 +2,7 @@ package com.glxp.api.admin.service.inventory.impl;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.glxp.api.admin.dao.inventory.InvStockPrintDao; import com.glxp.api.admin.dao.inventory.InvStockPrintDao;
import com.glxp.api.admin.entity.basic.StockPrintEntity; import com.glxp.api.admin.entity.inventory.StockPrintEntity;
import com.glxp.api.admin.req.basic.FilterStockprintRequest; import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import com.glxp.api.admin.service.inventory.InvStockPrintService; import com.glxp.api.admin.service.inventory.InvStockPrintService;
import com.glxp.api.admin.util.FilterUdiUtils; import com.glxp.api.admin.util.FilterUdiUtils;

@ -2,10 +2,8 @@ package com.glxp.api.admin.thread;
import com.glxp.api.admin.dao.info.ScheduledDao; import com.glxp.api.admin.dao.info.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.entity.info.SetupEntity;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity; import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import com.glxp.api.admin.service.info.SetupService;
import com.glxp.api.admin.service.info.SystemParamConfigService; import com.glxp.api.admin.service.info.SystemParamConfigService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;

@ -1,108 +0,0 @@
package com.glxp.api.admin.thread;
import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.entity.inout.ErpOrderEntity;
import com.glxp.api.admin.httpclient.ErpOrderClient;
import com.glxp.api.admin.req.inout.FilterOrderRequest;
import com.glxp.api.admin.entity.basic.ErpStockEntity;
import com.glxp.api.admin.entity.basic.UdiInfoEntity;
import com.glxp.api.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.api.admin.entity.info.SetupEntity;
import com.glxp.api.admin.entity.inout.WarehouseEntity;
import com.glxp.api.admin.req.inout.WarehouseQueryRequest;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inventory.InvErpStockService;
import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.info.SetupService;
import com.glxp.api.admin.service.inout.CodesService;
import com.glxp.api.admin.util.DateUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@Service
public class InvDlErpStockService {
@Resource
SetupService setupService;
@Resource
InvErpStockService erpStockService;
@Resource
UdiRelevanceService udiRelevanceService;
@Resource
UdiInfoService udiInfoService;
@Resource
CodesService warehouseService;
@Resource
SystemParamConfigService systemParamConfigService;
final Logger logger = LoggerFactory.getLogger(InvDlErpStockService.class);
/**
* ERPERP
*/
@Async
public void dlErpStock() {
SetupEntity setupEntity = setupService.selectSetup();
Integer day = setupEntity.getDlStockErpDay();
Map date = DateUtil.getDayRange(day);
Integer page = 1;
Integer limit = 20;
while (true) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_order_query");
if (systemParamConfigEntity == null) {
logger.error("ERP出入库单据接口未定义");
return;
}
FilterOrderRequest filterOrderRequest = new FilterOrderRequest();
filterOrderRequest.setPage(page);
filterOrderRequest.setLimit(limit);
filterOrderRequest.setStartDate((String)date.get("startDate"));
filterOrderRequest.setEndDate((String)date.get("endDate"));
filterOrderRequest.setBillAction("PurchaseWareHouseIn");
List<ErpOrderEntity> erpOrderEntities = new ErpOrderClient(systemParamConfigEntity.getParamValue()).getErpOrder(filterOrderRequest);
List<ErpStockEntity> erpStockEntities = new ArrayList<>();
if (erpOrderEntities != null && erpOrderEntities.size() > 0) {
page++;
for (ErpOrderEntity erpOrderEntity : erpOrderEntities) {
//ERP数据更新
ErpStockEntity erpStockEntity = new ErpStockEntity();
erpStockEntity.setOrderId(erpOrderEntity.getErpOrderId());
erpStockEntity.setCode(erpOrderEntity.getGoodsid());
erpStockEntity.setBatchNo(erpOrderEntity.getBatchNo());
erpStockEntity.setExpirationDate(erpOrderEntity.getExpireDate());
erpStockEntity.setName(erpOrderEntity.getGoodsname());
erpStockEntity.setCount(erpOrderEntity.getCount() + "");
//本地数据更新
UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectByThirdId(erpStockEntity.getCode());
if (udiRelevanceEntity != null) {
UdiInfoEntity udiInfoEntity = udiInfoService.findByUuid(udiRelevanceEntity.getUuid());
WarehouseQueryRequest warehouseQueryRequest = new WarehouseQueryRequest();
warehouseQueryRequest.setUdi(udiInfoEntity.getNameCode());
warehouseQueryRequest.setBatchNo(erpStockEntity.getBatchNo());
List<WarehouseEntity> warehouseEntities = warehouseService.findByOrderId(warehouseQueryRequest);
if (warehouseEntities != null && warehouseEntities.size() > 0) {
erpStockEntity.setManufacturingDate(warehouseEntities.get(0).getProduceDate());
erpStockEntity.setExpirationDate(warehouseEntities.get(0).getExpireDate());
}
}
erpStockEntities.add(erpStockEntity);
erpStockService.insertErpStocks(erpStockEntities);
}
} else {
break;
}
}
}
}

@ -1,32 +1,32 @@
package com.glxp.api.admin.thread; package com.glxp.api.admin.thread;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.glxp.api.admin.constant.ConstantType; import com.glxp.api.admin.constant.ConstantType;
import com.glxp.api.admin.entity.basic.ErpStockEntity;
import com.glxp.api.admin.entity.basic.StockPrintEntity;
import com.glxp.api.admin.entity.basic.UdiInfoEntity; import com.glxp.api.admin.entity.basic.UdiInfoEntity;
import com.glxp.api.admin.entity.basic.UdiRelevanceEntity; import com.glxp.api.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.api.admin.entity.inout.OrderEntity; import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.entity.inout.ErpOrderEntity; import com.glxp.api.admin.entity.inout.ErpOrderEntity;
import com.glxp.api.admin.entity.inout.FilterErpOrderRequest; import com.glxp.api.admin.entity.inout.FilterErpOrderRequest;
import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.inventory.ErpStockEntity;
import com.glxp.api.admin.entity.inventory.StockPrintEntity;
import com.glxp.api.admin.httpclient.ErpInvClient;
import com.glxp.api.admin.req.basic.FilterStockprintRequest; import com.glxp.api.admin.req.basic.FilterStockprintRequest;
import com.glxp.api.admin.req.basic.FilterUdiInfoRequest; import com.glxp.api.admin.req.basic.FilterUdiInfoRequest;
import com.glxp.api.admin.req.inout.FilterStockCheckRequest; import com.glxp.api.admin.req.inout.FilterStockCheckRequest;
import com.glxp.api.admin.req.inout.OrderFilterRequest; import com.glxp.api.admin.req.inout.OrderFilterRequest;
import com.glxp.api.admin.res.PageSimpleResponse; import com.glxp.api.admin.req.inventory.ErpOnhandRequest;
import com.glxp.api.admin.res.basic.UOnhandQueryResponse;
import com.glxp.api.admin.res.basic.UdiRelevanceResponse; import com.glxp.api.admin.res.basic.UdiRelevanceResponse;
import com.glxp.api.admin.service.inventory.InvErpStockService; import com.glxp.api.admin.res.inventory.ErpInvProductResponse;
import com.glxp.api.admin.service.inventory.InvStockPrintService; import com.glxp.api.admin.res.inventory.ErpOnHandResponse;
import com.glxp.api.admin.service.basic.UdiInfoService; import com.glxp.api.admin.service.basic.UdiInfoService;
import com.glxp.api.admin.service.basic.UdiRelevanceService; import com.glxp.api.admin.service.basic.UdiRelevanceService;
import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.OrderDetailService; import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.OrderService; import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.admin.util.HttpClient; import com.glxp.api.admin.service.inventory.InvStockPrintService;
import com.glxp.api.common.res.BaseResponse; import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -39,9 +39,6 @@ import java.util.stream.Collectors;
@Service @Service
public class InvImportStockService { public class InvImportStockService {
@Value("${UCLOD_SERVER_URL}")
private String ucloudUrl;
@Resource @Resource
private OrderService orderService; private OrderService orderService;
@Resource @Resource
@ -53,7 +50,8 @@ public class InvImportStockService {
@Resource @Resource
private UdiInfoService productInfoService; private UdiInfoService productInfoService;
@Resource @Resource
private InvErpStockService erpStockService; private SystemParamConfigService systemParamConfigService;
final Logger logger = LoggerFactory.getLogger(InvImportStockService.class);
@Async @Async
public void updateStock() { public void updateStock() {
@ -61,101 +59,81 @@ public class InvImportStockService {
int page = 1; int page = 1;
int limit = 1000; int limit = 1000;
FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest(); FilterUdiInfoRequest filterUdiInfoRequest = new FilterUdiInfoRequest();
while (true) { SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_inv_product_query");
filterUdiInfoRequest.setPage(page); String url;
filterUdiInfoRequest.setLimit(limit); if (systemParamConfigEntity != null) {
List<UdiRelevanceResponse> udiRelevanceResponses = udiRelevanceService.filterUdiRelevance(filterUdiInfoRequest); url = systemParamConfigEntity.getParamValue();
if (udiRelevanceResponses != null && udiRelevanceResponses.size() > 0) { while (true) {
List<StockPrintEntity> stockPrintEntities = new ArrayList<>(); filterUdiInfoRequest.setPage(page);
for (UdiRelevanceResponse udiRelevanceResponse : udiRelevanceResponses) { filterUdiInfoRequest.setLimit(limit);
List<UdiRelevanceResponse> udiRelevanceResponses = udiRelevanceService.filterUdiRelevance(filterUdiInfoRequest);
Map<String, Object> paramMap = new HashMap<>(16); if (udiRelevanceResponses != null && udiRelevanceResponses.size() > 0) {
paramMap.put("inventory", udiRelevanceResponse.getThirdId()); List<StockPrintEntity> stockPrintEntities = new ArrayList<>();
String response = HttpClient.mipsGet(ucloudUrl + "/uclooud/basic/onhandQuery", paramMap); for (UdiRelevanceResponse udiRelevanceResponse : udiRelevanceResponses) {
try { ErpOnhandRequest erpOnhandRequest = new ErpOnhandRequest();
BaseResponse<PageSimpleResponse<UOnhandQueryResponse>> onHandsResponse = erpOnhandRequest.setInventoryCode(udiRelevanceResponse.getThirdId());
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<UOnhandQueryResponse>>>() { List<ErpInvProductResponse> uOnhandQueryResponses = new ErpInvClient().getInvPrdoduct(erpOnhandRequest, url);
});
List<UOnhandQueryResponse> uOnhandQueryResponses = onHandsResponse.getData().getList();
if (uOnhandQueryResponses != null && uOnhandQueryResponses.size() > 0) { if (uOnhandQueryResponses != null && uOnhandQueryResponses.size() > 0) {
for (ErpInvProductResponse onhandQueryResponse : uOnhandQueryResponses) {
for (UOnhandQueryResponse onhandQueryResponse : uOnhandQueryResponses) {
StockPrintEntity stockPrintEntity = new StockPrintEntity(); StockPrintEntity stockPrintEntity = new StockPrintEntity();
stockPrintEntity.setBatchNo(onhandQueryResponse.getVbatchcode()); stockPrintEntity.setBatchNo(onhandQueryResponse.getBatchNo());
stockPrintEntity.setNnum(onhandQueryResponse.getNnum() + ""); stockPrintEntity.setNnum(onhandQueryResponse.getCount());
stockPrintEntity.setWarehouseName(onhandQueryResponse.getCwarehouse_name()); stockPrintEntity.setWarehouseName(onhandQueryResponse.getWarehouseName());
stockPrintEntity.setWarehouseCode(onhandQueryResponse.getCwarehouse_code()); stockPrintEntity.setWarehouseCode(onhandQueryResponse.getWarehouseCode());
ErpStockEntity erpStockEntity = erpStockService.findByCode(udiRelevanceResponse.getThirdId(), stockPrintEntity.getBatchNo()); stockPrintEntity.setExpireDate(onhandQueryResponse.getExpirationDate());
if (erpStockEntity != null) { stockPrintEntity.setProduceDate(onhandQueryResponse.getManufacturingDate());
stockPrintEntity.setExpireDate(erpStockEntity.getExpirationDate());
stockPrintEntity.setProduceDate(erpStockEntity.getManufacturingDate());
}
setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities); setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities);
} }
} else { } else {
StockPrintEntity stockPrintEntity = new StockPrintEntity(); StockPrintEntity stockPrintEntity = new StockPrintEntity();
setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities); setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities);
} }
} catch (Exception e) {
e.printStackTrace();
StockPrintEntity stockPrintEntity = new StockPrintEntity();
setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities);
}
} }
stockPrintService.insertStockPrints(stockPrintEntities); stockPrintService.insertStockPrints(stockPrintEntities);
if (udiRelevanceResponses.size() < limit) { if (udiRelevanceResponses.size() < limit) {
break; break;
} else {
page++;
}
} else { } else {
page++; break;
} }
} else {
break;
} }
} else {
logger.error("ERP库存产品信息查询接口地址未定义");
} }
} }
@Async @Async
public void updateByCode(String code) { public void updateByCode(String code, String url) {
UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectByThirdId(code); UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectByThirdId(code);
UdiRelevanceResponse udiRelevanceResponse = new UdiRelevanceResponse(); UdiRelevanceResponse udiRelevanceResponse = new UdiRelevanceResponse();
BeanUtils.copyProperties(udiRelevanceEntity, udiRelevanceResponse); BeanUtils.copyProperties(udiRelevanceEntity, udiRelevanceResponse);
List<StockPrintEntity> stockPrintEntities = new ArrayList<>(); List<StockPrintEntity> stockPrintEntities = new ArrayList<>();
Map<String, Object> paramMap = new HashMap<>(16); ErpOnhandRequest erpOnhandRequest = new ErpOnhandRequest();
paramMap.put("inventory", code); erpOnhandRequest.setInventoryCode(udiRelevanceResponse.getThirdId());
String response = HttpClient.mipsGet(ucloudUrl + "/uclooud/basic/onhandQuery", paramMap); List<ErpInvProductResponse> uOnhandQueryResponses = new ErpInvClient().getInvPrdoduct(erpOnhandRequest, url);
try { if (uOnhandQueryResponses != null && uOnhandQueryResponses.size() > 0) {
BaseResponse<PageSimpleResponse<UOnhandQueryResponse>> onHandsResponse =
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<UOnhandQueryResponse>>>() {
});
List<UOnhandQueryResponse> uOnhandQueryResponses = onHandsResponse.getData().getList();
if (uOnhandQueryResponses != null && uOnhandQueryResponses.size() > 0) {
for (UOnhandQueryResponse onhandQueryResponse : uOnhandQueryResponses) {
StockPrintEntity stockPrintEntity = new StockPrintEntity();
stockPrintEntity.setBatchNo(onhandQueryResponse.getVbatchcode());
stockPrintEntity.setNnum(onhandQueryResponse.getNnum() + "");
stockPrintEntity.setWarehouseName(onhandQueryResponse.getCwarehouse_name());
stockPrintEntity.setWarehouseCode(onhandQueryResponse.getCwarehouse_code());
ErpStockEntity erpStockEntity = erpStockService.findByCode(udiRelevanceResponse.getThirdId(), stockPrintEntity.getBatchNo());
if (erpStockEntity != null) {
stockPrintEntity.setExpireDate(erpStockEntity.getExpirationDate());
stockPrintEntity.setProduceDate(erpStockEntity.getManufacturingDate());
}
setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities);
}
} else { for (ErpInvProductResponse onhandQueryResponse : uOnhandQueryResponses) {
StockPrintEntity stockPrintEntity = new StockPrintEntity(); StockPrintEntity stockPrintEntity = new StockPrintEntity();
stockPrintEntity.setBatchNo(onhandQueryResponse.getBatchNo());
stockPrintEntity.setNnum(onhandQueryResponse.getCount() + "");
stockPrintEntity.setWarehouseName(onhandQueryResponse.getWarehouseName());
stockPrintEntity.setWarehouseCode(onhandQueryResponse.getWarehouseCode());
stockPrintEntity.setExpireDate(onhandQueryResponse.getExpirationDate());
stockPrintEntity.setProduceDate(onhandQueryResponse.getManufacturingDate());
setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities); setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities);
} }
} catch (Exception e) {
e.printStackTrace(); } else {
StockPrintEntity stockPrintEntity = new StockPrintEntity(); StockPrintEntity stockPrintEntity = new StockPrintEntity();
setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities); setCommonparams(stockPrintEntity, udiRelevanceResponse, stockPrintEntities);
} }
} }
public void setCommonparams(StockPrintEntity stockPrintEntity, UdiRelevanceResponse udiRelevanceResponse, List<StockPrintEntity> stockPrintEntities) { public void setCommonparams(StockPrintEntity stockPrintEntity, UdiRelevanceResponse udiRelevanceResponse, List<StockPrintEntity> stockPrintEntities) {
@ -245,53 +223,56 @@ public class InvImportStockService {
@Async @Async
public void checkStock(FilterStockCheckRequest filterStockCheckRequest) { public void checkStock(FilterStockCheckRequest filterStockCheckRequest) {
List<ErpOrderEntity> erpOrderEntitie = getErpOrders(filterStockCheckRequest.getId() + ""); SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_inv_product_query");
if (erpOrderEntitie != null && erpOrderEntitie.size() > 0) { String url;
for (ErpOrderEntity erpOrderEntity : erpOrderEntitie) { if (systemParamConfigEntity != null) {
//获取UUID url = systemParamConfigEntity.getParamValue();
FilterUdiInfoRequest productFilterRequest = new FilterUdiInfoRequest();
productFilterRequest.setNameCode(erpOrderEntity.getNameCode()); List<ErpOrderEntity> erpOrderEntitie = getErpOrders(filterStockCheckRequest.getId() + "");
List<UdiInfoEntity> productInfoEntities = productInfoService.filterAllUdiInfo(productFilterRequest); if (erpOrderEntitie != null && erpOrderEntitie.size() > 0) {
Map<String, List<UdiInfoEntity>> groupBy = productInfoEntities.stream().collect(Collectors.groupingBy(UdiInfoEntity::getUuid)); for (ErpOrderEntity erpOrderEntity : erpOrderEntitie) {
List<String> uuids = new ArrayList<>(); //获取UUID
for (String uuid : groupBy.keySet()) { FilterUdiInfoRequest productFilterRequest = new FilterUdiInfoRequest();
uuids.add(uuid); productFilterRequest.setNameCode(erpOrderEntity.getNameCode());
} List<UdiInfoEntity> productInfoEntities = productInfoService.filterAllUdiInfo(productFilterRequest);
if (uuids.size() == 1) { Map<String, List<UdiInfoEntity>> groupBy = productInfoEntities.stream().collect(Collectors.groupingBy(UdiInfoEntity::getUuid));
List<UdiRelevanceEntity> udiRelevanceEntities = udiRelevanceService.selectByUuid(uuids.get(0)); List<String> uuids = new ArrayList<>();
if (udiRelevanceEntities != null && udiRelevanceEntities.size() == 1) { for (String uuid : groupBy.keySet()) {
Map<String, Object> paramMap = new HashMap<>(16); uuids.add(uuid);
paramMap.put("inventory", udiRelevanceEntities.get(0).getThirdId()); }
String response = HttpClient.mipsGet(ucloudUrl + "/uclooud/basic/onhandQuery", paramMap); if (uuids.size() == 1) {
try { List<UdiRelevanceEntity> udiRelevanceEntities = udiRelevanceService.selectByUuid(uuids.get(0));
BaseResponse<PageSimpleResponse<UOnhandQueryResponse>> onHandsResponse = if (udiRelevanceEntities != null && udiRelevanceEntities.size() == 1) {
JSONObject.parseObject(response, new TypeReference<BaseResponse<PageSimpleResponse<UOnhandQueryResponse>>>() { ErpOnhandRequest erpOnhandRequest = new ErpOnhandRequest();
}); erpOnhandRequest.setInventoryCode(udiRelevanceEntities.get(0).getThirdId());
List<UOnhandQueryResponse> uOnhandQueryResponses = onHandsResponse.getData().getList(); List<ErpOnHandResponse> erpOnHandResponses = new ErpInvClient().getOnHand(erpOnhandRequest, url);
if (uOnhandQueryResponses != null && uOnhandQueryResponses.size() > 0) { if (erpOnHandResponses != null && erpOnHandResponses.size() > 0) {
for (int i = 0; i < uOnhandQueryResponses.size(); i++) { for (int i = 0; i < erpOnHandResponses.size(); i++) {
if (uOnhandQueryResponses.get(i).getVbatchcode().equals(erpOrderEntity.getBatchNo()) if (erpOnHandResponses.get(i).getBatchNo().equals(erpOrderEntity.getBatchNo())
) { ) {
if (erpOrderEntity.getWarehouseCode() != null && uOnhandQueryResponses.get(i).getCwarehouse_code().equals(erpOrderEntity.getWarehouseCode())) if (erpOrderEntity.getWarehouseCode() != null && erpOnHandResponses.get(i).getWarehouseCode().equals(erpOrderEntity.getWarehouseCode()))
erpOrderEntity.setReCount(uOnhandQueryResponses.get(i).getNnum()); erpOrderEntity.setReCount(erpOnHandResponses.get(i).getCount());
else { else {
erpOrderEntity.setReCount(uOnhandQueryResponses.get(i).getNnum()); erpOrderEntity.setReCount(erpOnHandResponses.get(i).getCount());
} }
myErpOrderService.updateErpOrder(erpOrderEntity); myErpOrderService.updateErpOrder(erpOrderEntity);
break;
} }
} }
} }
} catch (Exception e) {
e.printStackTrace();
} }
} }
}
}
} }
} else {
logger.error("ERP库存产品信息查询接口地址未定义");
} }
} }
private List<ErpOrderEntity> getErpOrders(String id) { private List<ErpOrderEntity> getErpOrders(String id) {
List<String> orderIds = getOrderIds(id + ""); List<String> orderIds = getOrderIds(id + "");
List<ErpOrderEntity> erpOrderEntities = new ArrayList<>(); List<ErpOrderEntity> erpOrderEntities = new ArrayList<>();

@ -2,8 +2,7 @@ package com.glxp.api.admin.thread;
import com.glxp.api.admin.dao.info.ScheduledDao; import com.glxp.api.admin.dao.info.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import com.glxp.api.admin.service.info.SetupService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;
@ -24,8 +23,6 @@ public class InvUpdateStock1Task implements SchedulingConfigurer {
private InvImportStockService importStockService; private InvImportStockService importStockService;
@Resource @Resource
protected ScheduledDao scheduledDao; protected ScheduledDao scheduledDao;
@Resource
SetupService setupService;
@Override @Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {

@ -2,8 +2,7 @@ package com.glxp.api.admin.thread;
import com.glxp.api.admin.dao.info.ScheduledDao; import com.glxp.api.admin.dao.info.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import com.glxp.api.admin.service.info.SetupService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;
@ -24,8 +23,6 @@ public class InvUpdateStock2Task implements SchedulingConfigurer {
private InvImportStockService importStockService; private InvImportStockService importStockService;
@Resource @Resource
protected ScheduledDao scheduledDao; protected ScheduledDao scheduledDao;
@Resource
SetupService setupService;
@Override @Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {

@ -2,8 +2,7 @@ package com.glxp.api.admin.thread;
import com.glxp.api.admin.dao.info.ScheduledDao; import com.glxp.api.admin.dao.info.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import com.glxp.api.admin.service.info.SetupService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;
@ -16,19 +15,20 @@ import javax.annotation.Resource;
@Component @Component
@EnableScheduling @EnableScheduling
public class InvDlErpStockTask implements SchedulingConfigurer { public class IoErpCheckTask implements SchedulingConfigurer {
final Logger logger = LoggerFactory.getLogger(IoErpCheckTask.class);
@Resource @Resource
protected ScheduledDao scheduledDao; protected ScheduledDao scheduledDao;
@Resource @Resource
InvDlErpStockService dlErpStockService; private IoTransInoutService ioTransInoutService;
final Logger logger = LoggerFactory.getLogger(IoModifyErpTask.class);
@Override @Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
scheduledTaskRegistrar.addTriggerTask(() -> process(), scheduledTaskRegistrar.addTriggerTask(() -> process(),
triggerContext -> { triggerContext -> {
ScheduledRequest scheduledRequest = new ScheduledRequest(); ScheduledRequest scheduledRequest = new ScheduledRequest();
scheduledRequest.setCronName("dlStockEr"); scheduledRequest.setCronName("erpCheck");
ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest); ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
String cron = scheduledEntity.getCron(); String cron = scheduledEntity.getCron();
if (cron.isEmpty()) { if (cron.isEmpty()) {
@ -39,7 +39,7 @@ public class InvDlErpStockTask implements SchedulingConfigurer {
} }
private void process() { private void process() {
logger.info("定时下载ERP采购订单到入库存"); logger.info("定时校验ERP单");
dlErpStockService.dlErpStock(); ioTransInoutService.checkOrder();
} }
} }

@ -6,21 +6,18 @@ import com.glxp.api.admin.entity.info.SystemParamConfigEntity;
import com.glxp.api.admin.httpclient.ErpOrderClient; import com.glxp.api.admin.httpclient.ErpOrderClient;
import com.glxp.api.admin.dao.info.ScheduledDao; import com.glxp.api.admin.dao.info.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.entity.info.SetupEntity;
import com.glxp.api.admin.entity.inout.OrderEntity; import com.glxp.api.admin.entity.inout.OrderEntity;
import com.glxp.api.admin.entity.inout.ErpOrderEntity; import com.glxp.api.admin.entity.inout.ErpOrderEntity;
import com.glxp.api.admin.entity.inout.FilterErpOrderRequest; import com.glxp.api.admin.entity.inout.FilterErpOrderRequest;
import com.glxp.api.admin.req.inout.OrderFilterRequest; import com.glxp.api.admin.req.inout.OrderFilterRequest;
import com.glxp.api.admin.req.inout.USignRequest; import com.glxp.api.admin.req.inout.USignRequest;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import com.glxp.api.admin.service.info.SetupService;
import com.glxp.api.admin.service.info.SystemParamConfigService; import com.glxp.api.admin.service.info.SystemParamConfigService;
import com.glxp.api.admin.service.inout.OrderDetailService; import com.glxp.api.admin.service.inout.OrderDetailService;
import com.glxp.api.admin.service.inout.OrderService; import com.glxp.api.admin.service.inout.OrderService;
import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.res.BaseResponse;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar; import org.springframework.scheduling.config.ScheduledTaskRegistrar;
@ -32,10 +29,6 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/**
* ali
*/
@Component @Component
@EnableScheduling @EnableScheduling
public class IoModifyErpTask implements SchedulingConfigurer { public class IoModifyErpTask implements SchedulingConfigurer {
@ -45,8 +38,6 @@ public class IoModifyErpTask implements SchedulingConfigurer {
@Resource @Resource
protected ScheduledDao scheduledDao; protected ScheduledDao scheduledDao;
@Resource @Resource
SetupService setupService;
@Resource
private OrderService orderService; private OrderService orderService;
@Resource @Resource
OrderDetailService myErpOrderService; OrderDetailService myErpOrderService;
@ -74,8 +65,11 @@ public class IoModifyErpTask implements SchedulingConfigurer {
} }
public void modifyErp() { public void modifyErp() {
SetupEntity setupEntity = setupService.selectSetup(); SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erpSaleOutModify");
if (setupEntity.isErpPruchaseModify() || setupEntity.isErpSaleOutModify()) { String isErpSaleOutModify = systemParamConfigEntity.getParamValue();
systemParamConfigEntity = systemParamConfigService.selectByParamKey("erpPruchaseModify");
String isErpPruchaseModify = systemParamConfigEntity.getParamValue();
if ("1".equals(isErpSaleOutModify)|| "1".equals(isErpPruchaseModify)) {
OrderFilterRequest orderFilterRequest = new OrderFilterRequest(); OrderFilterRequest orderFilterRequest = new OrderFilterRequest();
orderFilterRequest.setExportStatus(ConstantStatus.ORDER_EXPORT_UN); orderFilterRequest.setExportStatus(ConstantStatus.ORDER_EXPORT_UN);
orderFilterRequest.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS); orderFilterRequest.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS);
@ -87,21 +81,21 @@ public class IoModifyErpTask implements SchedulingConfigurer {
filterErpOrderRequest.setLimit(100); filterErpOrderRequest.setLimit(100);
filterErpOrderRequest.setOrderId(orderEntity.getId()); filterErpOrderRequest.setOrderId(orderEntity.getId());
List<ErpOrderEntity> erpOrderEntities = myErpOrderService.filterMyErpOrder(filterErpOrderRequest); List<ErpOrderEntity> erpOrderEntities = myErpOrderService.filterMyErpOrder(filterErpOrderRequest);
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_order_modify"); SystemParamConfigEntity systemParamConfigEntity1 = systemParamConfigService.selectByParamKey("erp_order_modify");
if (systemParamConfigEntity != null) { if (systemParamConfigEntity1 != null) {
String url = systemParamConfigEntity.getParamValue(); String url = systemParamConfigEntity1.getParamValue();
if (erpOrderEntities != null && !erpOrderEntities.isEmpty()) { if (erpOrderEntities != null && !erpOrderEntities.isEmpty()) {
Map<String, List<ErpOrderEntity>> listMap = erpOrderEntities.stream().collect(Collectors.groupingBy(ErpOrderEntity::getErpOrderId)); Map<String, List<ErpOrderEntity>> listMap = erpOrderEntities.stream().collect(Collectors.groupingBy(ErpOrderEntity::getErpOrderId));
if (orderEntity.getMainAction().equals(ConstantType.TYPE_OUT)) { if (orderEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
if (setupEntity.isErpSaleOutModify()) { if ("1".equals(isErpSaleOutModify)) {
BaseResponse baseResponse = new ErpOrderClient().postBill(listMap, orderEntity.getAction(), url); BaseResponse baseResponse = new ErpOrderClient().postBill(listMap, orderEntity.getAction(), url);
if (baseResponse != null && baseResponse.getCode() == 20000) { if (baseResponse != null && baseResponse.getCode() == 20000) {
orderService.updateExportStatus(orderEntity.getId(), ConstantStatus.ORDER_EXPORT_ED); orderService.updateExportStatus(orderEntity.getId(), ConstantStatus.ORDER_EXPORT_ED);
} }
} }
} else { } else {
if (setupEntity.isErpPruchaseModify()) { if ("1".equals(isErpPruchaseModify)) {
BaseResponse baseResponse = new ErpOrderClient().postBill(listMap, orderEntity.getAction(), url); BaseResponse baseResponse = new ErpOrderClient().postBill(listMap, orderEntity.getAction(), url);
if (baseResponse != null && baseResponse.getCode() == 20000) { if (baseResponse != null && baseResponse.getCode() == 20000) {
orderService.updateExportStatus(orderEntity.getId(), ConstantStatus.ORDER_EXPORT_ED); orderService.updateExportStatus(orderEntity.getId(), ConstantStatus.ORDER_EXPORT_ED);
@ -115,16 +109,14 @@ public class IoModifyErpTask implements SchedulingConfigurer {
} }
} }
OrderFilterRequest signFilterRequest = new OrderFilterRequest(); OrderFilterRequest signFilterRequest = new OrderFilterRequest();
signFilterRequest.setSignStatus(ConstantStatus.ORDER_SIGN_UN); signFilterRequest.setSignStatus(ConstantStatus.ORDER_SIGN_UN);
signFilterRequest.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS); signFilterRequest.setContrastStatus(ConstantStatus.ORDER_CHECK_SUCCESS);
List<OrderEntity> signsOrderEntities = orderService.findAllOrders(signFilterRequest); List<OrderEntity> signsOrderEntities = orderService.findAllOrders(signFilterRequest);
if (signsOrderEntities != null && signsOrderEntities.size() > 0) { if (signsOrderEntities != null && signsOrderEntities.size() > 0) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("erp_order_sign"); SystemParamConfigEntity systemParamConfigEntity2 = systemParamConfigService.selectByParamKey("erp_order_sign");
if(systemParamConfigEntity!=null){ if (systemParamConfigEntity2 != null) {
String url = systemParamConfigEntity.getParamValue(); String url = systemParamConfigEntity2.getParamValue();
for (OrderEntity orderEntity : signsOrderEntities) { for (OrderEntity orderEntity : signsOrderEntities) {
FilterErpOrderRequest filterErpOrderRequest = new FilterErpOrderRequest(); FilterErpOrderRequest filterErpOrderRequest = new FilterErpOrderRequest();
filterErpOrderRequest.setOrderId(orderEntity.getId()); filterErpOrderRequest.setOrderId(orderEntity.getId());
@ -132,7 +124,7 @@ public class IoModifyErpTask implements SchedulingConfigurer {
if (erpOrderEntities != null && !erpOrderEntities.isEmpty()) { if (erpOrderEntities != null && !erpOrderEntities.isEmpty()) {
Map<String, List<ErpOrderEntity>> listMap = erpOrderEntities.stream().collect(Collectors.groupingBy(ErpOrderEntity::getErpOrderId)); Map<String, List<ErpOrderEntity>> listMap = erpOrderEntities.stream().collect(Collectors.groupingBy(ErpOrderEntity::getErpOrderId));
if (orderEntity.getMainAction().equals(ConstantType.TYPE_OUT)) { if (orderEntity.getMainAction().equals(ConstantType.TYPE_OUT)) {
if (setupEntity.isErpSaleOutSign()) { if ("1".equals(isErpSaleOutModify)) {
if (listMap != null && listMap.size() > 0) { if (listMap != null && listMap.size() > 0) {
for (String key : listMap.keySet()) { for (String key : listMap.keySet()) {
USignRequest signRequest = new USignRequest(); USignRequest signRequest = new USignRequest();
@ -146,7 +138,7 @@ public class IoModifyErpTask implements SchedulingConfigurer {
} }
} }
} else { } else {
if (setupEntity.isErpPruchaseSign()) { if ("1".equals(isErpPruchaseModify)) {
if (listMap != null && listMap.size() > 0) { if (listMap != null && listMap.size() > 0) {
for (String key : listMap.keySet()) { for (String key : listMap.keySet()) {
USignRequest signRequest = new USignRequest(); USignRequest signRequest = new USignRequest();
@ -162,14 +154,11 @@ public class IoModifyErpTask implements SchedulingConfigurer {
} }
} }
} }
}else { } else {
logger.error("ERP单据签字接口地址未定义"); logger.error("ERP单据签字接口地址未定义");
} }
} }
} }
} }

@ -2,8 +2,7 @@ package com.glxp.api.admin.thread;
import com.glxp.api.admin.dao.info.ScheduledDao; import com.glxp.api.admin.dao.info.ScheduledDao;
import com.glxp.api.admin.entity.info.ScheduledEntity; import com.glxp.api.admin.entity.info.ScheduledEntity;
import com.glxp.api.admin.req.udid.ScheduledRequest; import com.glxp.api.admin.req.info.ScheduledRequest;
import com.glxp.api.admin.service.info.SetupService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;

@ -2,9 +2,10 @@
server.port=9991 server.port=9991
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.jdbc-url=jdbc:mysql://127.0.0.1:3306/udiwms?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true spring.datasource.jdbc-url=jdbc:mysql://127.0.0.1:3306/udiwms?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
#spring.datasource.jdbc-url=jdbc:mysql://127.0.0.1:3306/udiwms_new?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
spring.datasource.username=root spring.datasource.username=root
spring.datasource.password=123456 spring.datasource.password=123456
#spring.datasource.password=mysql80 #spring.datasource.password=root
server.servlet.context-path= server.servlet.context-path=
logging.level.com.glxp.api.admin.dao=debug logging.level.com.glxp.api.admin.dao=debug
@ -17,10 +18,6 @@ logging.path=output/logs
logging.file=D:/udi.log logging.file=D:/udi.log
#UDI数据下载 #UDI数据下载
UDI_SERVER_URL=https://www.udims.com/UDI_DL_Server UDI_SERVER_URL=https://www.udims.com/UDI_DL_Server
#UDI_SERVER_URL=http://139.9.178.73:8080/UDI_DL_Server
#UCLOD服务
#UCLOD_SERVER_URL=http://127.0.0.1:9997
UCLOD_SERVER_URL=http://127.0.0.1:8080/UDIC_UCLOUD_SERVER

@ -35,6 +35,9 @@
<if test="uuid != '' and uuid != null"> <if test="uuid != '' and uuid != null">
AND uuid = #{uuid} AND uuid = #{uuid}
</if> </if>
<if test="id != '' and id != null">
AND basic_udirel.id = #{id}
</if>
</where> </where>
ORDER BY updateTime DESC ORDER BY updateTime DESC

@ -6,11 +6,11 @@
<select id="findCompany" <select id="findCompany"
resultType="com.glxp.api.admin.entity.info.CompanyEntity"> resultType="com.glxp.api.admin.entity.info.CompanyEntity">
SELECT * FROM company SELECT * FROM auth_company
</select> </select>
<update id="modifyCompany" parameterType="com.glxp.api.admin.entity.info.CompanyEntity"> <update id="modifyCompany" parameterType="com.glxp.api.admin.entity.info.CompanyEntity">
UPDATE company SET UPDATE auth_company SET
name = #{name}, name = #{name},
category = #{category}, category = #{category},
creditCode = #{creditCode}, creditCode = #{creditCode},
@ -22,7 +22,7 @@
</update> </update>
<insert id="insertCompany" parameterType="com.glxp.api.admin.entity.info.CompanyEntity"> <insert id="insertCompany" parameterType="com.glxp.api.admin.entity.info.CompanyEntity">
INSERT INTO company(name,category,creditCode,addr,productAddr,classes,appId,appSecret) values INSERT INTO auth_company(name,category,creditCode,addr,productAddr,classes,appId,appSecret) values
( #{name}, ( #{name},
#{category}, #{category},
#{creditCode}, #{creditCode},

@ -6,7 +6,7 @@
<insert id="insertScheduled" keyProperty="id" <insert id="insertScheduled" keyProperty="id"
parameterType="com.glxp.api.admin.entity.info.ScheduledEntity"> parameterType="com.glxp.api.admin.entity.info.ScheduledEntity">
insert INTO scheduled insert INTO sys_scheduled
(cronName,cron,customerId) (cronName,cron,customerId)
values values
( (
@ -18,13 +18,13 @@
<delete id="deleteScheduled" parameterType="java.lang.String"> <delete id="deleteScheduled" parameterType="java.lang.String">
delete from scheduled where id = #{id} delete from sys_scheduled where id = #{id}
</delete> </delete>
<select id="findScheduled" parameterType="com.glxp.api.admin.req.udid.ScheduledRequest" <select id="findScheduled" parameterType="com.glxp.api.admin.req.info.ScheduledRequest"
resultType="com.glxp.api.admin.entity.info.ScheduledEntity"> resultType="com.glxp.api.admin.entity.info.ScheduledEntity">
select * from scheduled select * from sys_scheduled
<where> <where>
<if test="cronName != null and cronName != ''"> <if test="cronName != null and cronName != ''">
and cronName = #{cronName} and cronName = #{cronName}

@ -1,58 +0,0 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.glxp.api.admin.dao.info.SetupDao">
<select id="findSetup" parameterType="com.glxp.api.admin.req.info.FilterSetupRequest"
resultType="com.glxp.api.admin.entity.info.SetupEntity">
SELECT * FROM system_config WHERE id=#{id}
</select>
<update id="modifySetup" parameterType="com.glxp.api.admin.entity.info.SetupEntity">
UPDATE system_config
<set>
<if test="erpSaleOutModify != null">erpSaleOutModify=#{erpSaleOutModify},</if>
<if test="erpGetSaleOut != null">erpGetSaleOut=#{erpGetSaleOut},</if>
<if test="erpSaleOutSign != null">erpSaleOutSign=#{erpSaleOutSign},</if>
<if test="filterSaleOutSign != null">filterSaleOutSign=#{filterSaleOutSign},</if>
<if test="erpGetSaleOutDay != null">erpGetSaleOutDay=#{erpGetSaleOutDay},</if>
<if test="erpPruchaseModify != null">erpPruchaseModify=#{erpPruchaseModify},</if>
<if test="erpGetPurchaseIn != null">erpGetPurchaseIn=#{erpGetPurchaseIn},</if>
<if test="erpPruchaseSign != null">erpPruchaseSign=#{erpPruchaseSign},</if>
<if test="erpGetPurchaseDay != null">erpGetPurchaseDay=#{erpGetPurchaseDay},</if>
<if test="filterPurchaseSign != null">filterPurchaseSign=#{filterPurchaseSign},</if>
<if test="remark != null">remark=#{remark},</if>
<if test="forbidSameErp != null">forbidSameErp=#{forbidSameErp},</if>
<if test="returnWareHouseOut != null">returnWareHouseOut=#{returnWareHouseOut},</if>
<if test="salesWareHouseOut != null">salesWareHouseOut=#{salesWareHouseOut},</if>
<if test="returnWareHouseIn != null">returnWareHouseIn=#{returnWareHouseIn},</if>
<if test="updateErpData != null">updateErpData=#{updateErpData},</if>
<if test="dlStockErp != null">dlStockErp=#{dlStockErp},</if>
<if test="dlStockErpDay != null">dlStockErpDay=#{dlStockErpDay},</if>
</set>
WHERE id=#{id}
</update>
<insert id="insertSetup" parameterType="com.glxp.api.admin.entity.info.SetupEntity">
insert INTO system_config(erpSaleOutModify,
erpGetSaleOut,erpSaleOutSign,filterSaleOutSign,erpGetSaleOutDay,erpPruchaseModify,
erpGetPurchaseIn,erpPruchaseSign,
erpGetPurchaseDay,filterPurchaseSign,remark,forbidSameErp,
returnWareHouseOut,salesWareHouseOut,returnWareHouseIn,updateErpData,dlStockErp,dlStockErpDay
) values
(
#{erpSaleOutModify},#{erpGetSaleOut}, #{erpSaleOutSign},
#{filterSaleOutSign}, #{erpGetSaleOutDay},#{erpPruchaseModify}, #{erpGetPurchaseIn},
#{erpPruchaseSign},
#{erpGetPurchaseDay}, #{filterPurchaseSign},
#{remark},#{forbidSameErp}
,#{returnWareHouseOut},#{salesWareHouseOut},#{returnWareHouseIn},#{updateErpData},#{dlStockErp},#{dlStockErpDay})
</insert>
</mapper>

@ -6,7 +6,7 @@
<select id="queryPage" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest" <select id="queryPage" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest"
resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
SELECT id,paramName,paramKey,paramValue,paramStatus,paramType,paramExplain SELECT id,paramName,paramKey,paramValue,paramStatus,paramType,paramExplain
FROM system_param_config FROM sys_param_config
<where> <where>
AND `paramStatus` = #{paramStatus} AND `paramStatus` = #{paramStatus}
<if test="paramName != null and '' != paramName"> <if test="paramName != null and '' != paramName">
@ -21,22 +21,22 @@
<select id="findSystemParamConfig" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest" <select id="findSystemParamConfig" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest"
resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
SELECT * FROM system_param_config WHERE id=#{id} SELECT * FROM sys_param_config WHERE id=#{id}
</select> </select>
<select id="selectByParamName" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest" <select id="selectByParamName" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest"
resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
SELECT * FROM system_param_config WHERE paramName=#{paramName} SELECT * FROM sys_param_config WHERE paramName=#{paramName}
</select> </select>
<select id="selectByParamKey" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest" <select id="selectByParamKey" parameterType="com.glxp.api.admin.req.info.SystemParamConfigRequest"
resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> resultType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
SELECT * FROM system_param_config WHERE paramKey=#{paramKey} SELECT * FROM sys_param_config WHERE paramKey=#{paramKey}
</select> </select>
<update id="updateById" parameterType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> <update id="updateById" parameterType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
UPDATE system_param_config UPDATE sys_param_config
<set> <set>
<if test="paramName != null">paramName=#{paramName},</if> <if test="paramName != null">paramName=#{paramName},</if>
<if test="paramKey != null">paramKey=#{paramKey},</if> <if test="paramKey != null">paramKey=#{paramKey},</if>
@ -49,7 +49,7 @@
</update> </update>
<update id="updateParentId" parameterType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> <update id="updateParentId" parameterType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
UPDATE system_param_config UPDATE sys_param_config
<set> <set>
<if test="paramStatus != null">paramStatus=#{paramStatus},</if> <if test="paramStatus != null">paramStatus=#{paramStatus},</if>
</set> </set>
@ -57,7 +57,7 @@
</update> </update>
<insert id="insert" parameterType="com.glxp.api.admin.entity.info.SystemParamConfigEntity"> <insert id="insert" parameterType="com.glxp.api.admin.entity.info.SystemParamConfigEntity">
insert INTO system_param_config(paramName, insert INTO sys_param_config(paramName,
paramKey,paramValue,paramStatus,paramType,paramExplain paramKey,paramValue,paramStatus,paramType,paramExplain
) values ) values
( (

@ -1,71 +0,0 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.glxp.api.admin.dao.inventory.InvErpStockDao">
<select id="findByCode" parameterType="Map"
resultType="com.glxp.api.admin.entity.basic.ErpStockEntity">
SELECT * FROM erpstock WHERE (
code = #{code} and batchNo = #{batchNo}) limit 1
</select>
<insert id="insertErpStock" keyProperty="id" parameterType="com.glxp.api.admin.entity.basic.ErpStockEntity">
replace INTO erpstock
(
orderId,code,batchNo,manufacturingDate,expirationDate,count,remark,name
)
values
(
#{orderId},
#{code},
#{batchNo},
#{manufacturingDate},
#{count},
#{remark},
#{name}
)
</insert>
<insert id="insertErpStocks" keyProperty="id" parameterType="java.util.List">
replace INTO erpstock
(
orderId,code,batchNo,manufacturingDate,expirationDate,count,remark,name
)
values
<foreach collection="erpStockEntities" item="item" index="index"
separator=",">
(
#{item.orderId},
#{item.code},
#{item.batchNo},
#{item.manufacturingDate},
#{item.expirationDate},
#{item.count},
#{item.remark},
#{item.name}
)
</foreach>
</insert>
<delete id="deleteById" parameterType="Map">
DELETE FROM erpstock WHERE id = #{id}
</delete>
<update id="updateErpStock" parameterType="com.glxp.api.admin.entity.basic.ErpStockEntity">
UPDATE erpstock
<set>
<if test="orderId != null">orderId=#{orderId},</if>
<if test="code != null">code=#{code},</if>
<if test="batchNo != null">batchNo=#{batchNo},</if>
<if test="manufacturingDate != null">manufacturingDate=#{manufacturingDate},</if>
<if test="expirationDate != null">expirationDate=#{expirationDate},</if>
<if test="count != null">count=#{count},</if>
<if test="remark != null">remark=#{remark},</if>
<if test="name != null">name=#{name},</if>
</set>
WHERE id = #{id}
</update>
</mapper>

@ -5,7 +5,7 @@
<select id="filterStockCheck" parameterType="com.glxp.api.admin.req.inout.FilterStockCheckRequest" <select id="filterStockCheck" parameterType="com.glxp.api.admin.req.inout.FilterStockCheckRequest"
resultType="com.glxp.api.admin.entity.inout.StockCheckEntity"> resultType="com.glxp.api.admin.entity.inout.StockCheckEntity">
SELECT * FROM stockcheck SELECT * FROM inv_stockcheck
<where> <where>
<if test="id != '' and id != null"> <if test="id != '' and id != null">
AND id = #{id} AND id = #{id}
@ -31,7 +31,7 @@
<insert id="insertStockCheck" keyProperty="id" parameterType="com.glxp.api.admin.entity.inout.StockCheckEntity"> <insert id="insertStockCheck" keyProperty="id" parameterType="com.glxp.api.admin.entity.inout.StockCheckEntity">
insert INTO stockcheck insert INTO inv_stockcheck
( (
action,actDate,status,remark,endTime,whouse,houseCard action,actDate,status,remark,endTime,whouse,houseCard
) )
@ -46,11 +46,11 @@
<delete id="deleteById" parameterType="Map"> <delete id="deleteById" parameterType="Map">
DELETE FROM stockcheck WHERE id = #{id} DELETE FROM inv_stockcheck WHERE id = #{id}
</delete> </delete>
<update id="updateStockCheck" parameterType="com.glxp.api.admin.entity.basic.StockPrintEntity"> <update id="updateStockCheck" parameterType="com.glxp.api.admin.entity.inventory.StockPrintEntity">
UPDATE stockcheck UPDATE inv_stockcheck
<set> <set>
<if test="action != null">action=#{action},</if> <if test="action != null">action=#{action},</if>
<if test="actDate != null">actDate=#{actDate},</if> <if test="actDate != null">actDate=#{actDate},</if>

@ -4,8 +4,8 @@
<mapper namespace="com.glxp.api.admin.dao.inventory.InvStockPrintDao"> <mapper namespace="com.glxp.api.admin.dao.inventory.InvStockPrintDao">
<select id="filterStockPrint" parameterType="com.glxp.api.admin.req.basic.FilterStockprintRequest" <select id="filterStockPrint" parameterType="com.glxp.api.admin.req.basic.FilterStockprintRequest"
resultType="com.glxp.api.admin.entity.basic.StockPrintEntity"> resultType="com.glxp.api.admin.entity.inventory.StockPrintEntity">
SELECT * FROM stockprint SELECT * FROM inv_stockprint
<where> <where>
<if test="nameCode != '' and nameCode != null"> <if test="nameCode != '' and nameCode != null">
@ -32,17 +32,17 @@
<select id="findByNameCode" parameterType="java.lang.String" <select id="findByNameCode" parameterType="java.lang.String"
resultType="com.glxp.api.admin.entity.basic.StockPrintEntity"> resultType="com.glxp.api.admin.entity.inventory.StockPrintEntity">
SELECT * FROM stockprint WHERE ( SELECT * FROM inv_stockprint WHERE (
nameCode = #{nameCode} ) limit 1 nameCode = #{nameCode} ) limit 1
</select> </select>
<select id="findByRlId" parameterType="com.glxp.api.admin.req.basic.FilterStockprintRequest" <select id="findByRlId" parameterType="com.glxp.api.admin.req.basic.FilterStockprintRequest"
resultType="com.glxp.api.admin.entity.basic.StockPrintEntity"> resultType="com.glxp.api.admin.entity.inventory.StockPrintEntity">
SELECT * FROM stockprint WHERE SELECT * FROM inv_stockprint WHERE
udiRlIdFk = #{udiRlIdFk} and batchNo = #{batchNo} and warehouseCode=#{warehouseCode} limit 1 udiRlIdFk = #{udiRlIdFk} and batchNo = #{batchNo} and warehouseCode=#{warehouseCode} limit 1
</select> </select>
<insert id="insertStockPrint" keyProperty="id" parameterType="com.glxp.api.admin.entity.basic.StockPrintEntity"> <insert id="insertStockPrint" keyProperty="id" parameterType="com.glxp.api.admin.entity.inventory.StockPrintEntity">
replace INTO stockprint replace INTO inv_stockprint
( (
udiCode,udiRlIdFk,nameCode,cpmctymc,batchNo, udiCode,udiRlIdFk,nameCode,cpmctymc,batchNo,
produceDate,expireDate,serialNo,codeType,thirdId,thirdName, produceDate,expireDate,serialNo,codeType,thirdId,thirdName,
@ -70,7 +70,7 @@
</insert> </insert>
<insert id="insertStockPrints" keyProperty="id" parameterType="java.util.List"> <insert id="insertStockPrints" keyProperty="id" parameterType="java.util.List">
replace INTO stockprint replace INTO inv_stockprint
( (
udiCode,udiRlIdFk,nameCode,cpmctymc,batchNo, udiCode,udiRlIdFk,nameCode,cpmctymc,batchNo,
produceDate,expireDate,serialNo,codeType,thirdId,thirdName, produceDate,expireDate,serialNo,codeType,thirdId,thirdName,
@ -102,11 +102,11 @@
</insert> </insert>
<delete id="deleteById" parameterType="Map"> <delete id="deleteById" parameterType="Map">
DELETE FROM stockprint WHERE id = #{id} DELETE FROM inv_stockprint WHERE id = #{id}
</delete> </delete>
<update id="updateStockPrint" parameterType="com.glxp.api.admin.entity.basic.StockPrintEntity"> <update id="updateStockPrint" parameterType="com.glxp.api.admin.entity.inventory.StockPrintEntity">
UPDATE stockprint UPDATE inv_stockprint
<set> <set>
<if test="udiCode != null">udiCode=#{udiCode},</if> <if test="udiCode != null">udiCode=#{udiCode},</if>
<if test="udiRlIdFk != null">udiRlIdFk=#{udiRlIdFk},</if> <if test="udiRlIdFk != null">udiRlIdFk=#{udiRlIdFk},</if>
@ -132,7 +132,7 @@
<update id="updatePrintStatus" parameterType="java.util.List"> <update id="updatePrintStatus" parameterType="java.util.List">
update stockprint update inv_stockprint
set printStatus = 1 set printStatus = 1
WHERE id in WHERE id in
<foreach collection="ids" item="item" index="index" open="(" close=")" separator=","> <foreach collection="ids" item="item" index="index" open="(" close=")" separator=",">

@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.glxp.api.admin.httpclient.UdiDlHttpClient; import com.glxp.api.admin.httpclient.UdiDlHttpClient;
import com.glxp.api.admin.entity.basic.UdiInfoEntity; import com.glxp.api.admin.entity.basic.UdiInfoEntity;
import com.glxp.api.admin.entity.udid.*;
import org.junit.Test; import org.junit.Test;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;

@ -1,234 +0,0 @@
/*
Navicat MySQL Data Transfer
Source Server : php
Source Server Version : 50553
Source Host : localhost:3306
Source Database : vue-admin
Target Server Type : MYSQL
Target Server Version : 50553
File Encoding : 65001
Date: 2018-11-20 18:59:57
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for ad
-- ----------------------------
DROP TABLE IF EXISTS `ad`;
CREATE TABLE `ad` (
`ad_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '广告ID',
`title` varchar(255) NOT NULL COMMENT '广告标题',
`describe` varchar(255) NOT NULL DEFAULT '' COMMENT '描述',
`pic` varchar(255) NOT NULL DEFAULT '' COMMENT '图片的地址',
`jump_type` tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '跳转方式0web 页面1APP内链接2小程序',
`jump_url` varchar(255) NOT NULL DEFAULT '' COMMENT '跳转的url路径',
`ios_url` varchar(255) NOT NULL DEFAULT '' COMMENT 'ios 的类名',
`android_url` varchar(255) NOT NULL DEFAULT '' COMMENT 'android 的类名',
`wxa_appid` varchar(50) NOT NULL DEFAULT '' COMMENT '微信小程序的APPID跳转类型为 1 时有效)',
`channel_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '渠道名单类型0不做处理1白名单2黑名单',
`channel_list` varchar(255) NOT NULL DEFAULT '' COMMENT '渠道黑名单',
`android_version_type` tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT 'android 版本名单类型0不做处理1白名单2黑名单',
`android_version_list` varchar(255) NOT NULL DEFAULT '' COMMENT 'android 版本黑名单',
`ios_version_type` tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT 'ios 版本名单类型0不做处理1白名单2黑名单',
`ios_version_list` varchar(255) NOT NULL DEFAULT '' COMMENT 'ios 版本黑名单',
`new_show_start_num` int(11) NOT NULL DEFAULT '0' COMMENT '新用户从第几次开始展示',
`new_show_max_num` int(11) NOT NULL DEFAULT '0' COMMENT '新用户最大展示几次',
`old_show_start_num` int(11) NOT NULL DEFAULT '0' COMMENT '老用户第几次开始展示',
`old_show_max_num` int(11) NOT NULL DEFAULT '0' COMMENT '老用户最大展示几次',
`start_time` datetime DEFAULT NULL COMMENT '开始时间',
`end_time` datetime DEFAULT NULL COMMENT '结束时间',
`event_name` varchar(255) NOT NULL DEFAULT '' COMMENT '统计事件名称',
`status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '广告状态0禁用1正常',
`create_time` datetime NOT NULL COMMENT '创建时间',
`modified_time` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ad_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='广告表';
-- ----------------------------
-- Table structure for ad_site
-- ----------------------------
DROP TABLE IF EXISTS `ad_site`;
CREATE TABLE `ad_site` (
`site_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '广告位id',
`site_name` varchar(255) NOT NULL COMMENT '广告位名称',
`describe` varchar(255) NOT NULL DEFAULT '' COMMENT '广告位描述',
`ad_ids` varchar(255) NOT NULL DEFAULT '' COMMENT '广告位的广告id用 , 隔开)',
`create_time` datetime NOT NULL COMMENT '创建时间',
`modified_time` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`site_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT='广告位';
-- ----------------------------
-- Table structure for auth_admin
-- ----------------------------
DROP TABLE IF EXISTS `auth_admin`;
CREATE TABLE `auth_admin` (
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
`username` varchar(60) NOT NULL DEFAULT '' COMMENT '用户名',
`password` varchar(64) NOT NULL DEFAULT '' COMMENT '登录密码sp_password加密',
`tel` varchar(50) NOT NULL DEFAULT '' COMMENT '用户手机号',
`email` varchar(100) NOT NULL DEFAULT '' COMMENT '登录邮箱',
`avatar` varchar(255) NOT NULL DEFAULT '' COMMENT '用户头像',
`sex` smallint(1) NOT NULL DEFAULT '0' COMMENT '性别0保密12',
`last_login_ip` varchar(16) NOT NULL DEFAULT '' COMMENT '最后登录ip',
`last_login_time` datetime NOT NULL COMMENT '最后登录时间',
`create_time` datetime NOT NULL COMMENT '注册时间',
`status` int(11) NOT NULL DEFAULT '1' COMMENT '用户状态 0禁用 1正常 2未验证',
PRIMARY KEY (`id`),
KEY `user_login_key` (`username`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COMMENT='管理员表';
-- ----------------------------
-- Records of auth_admin
-- ----------------------------
INSERT INTO `auth_admin` VALUES ('1', 'admin', 'c3284d0f94606de1fd2af172aba15bf3', 'admin', 'lmxdawn@gmail.com', 'sssss', '0', '127.0.0.1', '2018-07-06 17:19:00', '2018-07-06 17:19:00', '1');
-- ----------------------------
-- Table structure for auth_permission
-- ----------------------------
DROP TABLE IF EXISTS `auth_permission`;
CREATE TABLE `auth_permission` (
`role_id` int(11) unsigned NOT NULL COMMENT '角色',
`permission_rule_id` int(11) NOT NULL DEFAULT '0' COMMENT '权限id',
`type` varchar(30) DEFAULT NULL COMMENT '权限规则分类,请加应用前缀,如admin_'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='权限授权表';
-- ----------------------------
-- Records of auth_permission
-- ----------------------------
INSERT INTO `auth_permission` VALUES ('1', '4', 'admin');
INSERT INTO `auth_permission` VALUES ('1', '3', 'admin');
INSERT INTO `auth_permission` VALUES ('1', '2', 'admin');
INSERT INTO `auth_permission` VALUES ('1', '1', 'admin');
-- ----------------------------
-- Table structure for auth_permission_rule
-- ----------------------------
DROP TABLE IF EXISTS `auth_permission_rule`;
CREATE TABLE `auth_permission_rule` (
`id` int(8) unsigned NOT NULL AUTO_INCREMENT COMMENT '规则编号',
`pid` int(11) NOT NULL DEFAULT '0' COMMENT '父级id',
`name` char(80) NOT NULL DEFAULT '' COMMENT '规则唯一标识',
`title` char(20) NOT NULL DEFAULT '' COMMENT '规则中文名称',
`status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '状态为1正常为0禁用',
`condition` char(100) NOT NULL DEFAULT '' COMMENT '规则表达式,为空表示存在就验证,不为空表示按照条件验证',
`listorder` int(10) NOT NULL DEFAULT '0' COMMENT '排序,优先级,越小优先级越高',
`create_time` datetime NOT NULL COMMENT '创建时间',
`update_time` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`id`),
UNIQUE KEY `name` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=26 DEFAULT CHARSET=utf8 COMMENT='规则表';
-- ----------------------------
-- Records of auth_permission_rule
-- ----------------------------
INSERT INTO `auth_permission_rule` VALUES ('1', '0', 'user_manage', '用户管理', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('2', '1', 'user_manage/admin_manage', '管理组', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('3', '2', 'admin/auth_admin/index', '管理员管理', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('4', '3', 'admin/auth_admin/save', '添加管理员', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('5', '3', 'admin/auth_admin/edit', '编辑管理员', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('6', '3', 'admin/auth_admin/delete', '删除管理员', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('7', '2', 'admin/auth_role/index', '角色管理', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('8', '7', 'admin/auth_role/save', '添加角色', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('9', '7', 'admin/auth_role/edit', '编辑角色', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('10', '7', 'admin/auth_role/delete', '删除角色', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('11', '7', 'admin/auth_role/auth', '角色授权', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('12', '2', 'admin/auth_permission_rule/index', '权限管理', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('13', '12', 'admin/auth_permission_rule/save', '添加权限', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('14', '12', 'admin/auth_permission_rule/edit', '编辑权限', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('15', '12', 'admin/auth_permission_rule/delete', '删除权限', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('16', '0', 'ad_manage', '广告相关', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('17', '16', 'admin/ad_site/index', '广告位管理', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('18', '17', 'admin/ad_site/save', '广告位添加', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('19', '17', 'admin/ad_site/edit', '广告位编辑', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('20', '17', 'admin/ad_site/delete', '广告位删除', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('21', '16', 'admin/ad/index', '广告管理', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('22', '21', 'admin/ad/save', '广告添加', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('23', '21', 'admin/ad/edit', '广告编辑', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('24', '21', 'admin/ad/delete', '广告删除', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
INSERT INTO `auth_permission_rule` VALUES ('25', '17', 'admin/ad_site/adlist', '广告位选择时的广告列表', '1', '', '999', '2018-07-06 17:19:00', '2018-07-06 17:19:00');
-- ----------------------------
-- Table structure for auth_role
-- ----------------------------
DROP TABLE IF EXISTS `auth_role`;
CREATE TABLE `auth_role` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(20) NOT NULL COMMENT '角色名称',
`pid` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '父角色ID',
`status` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '状态',
`remark` varchar(255) NOT NULL DEFAULT '' COMMENT '备注',
`create_time` datetime NOT NULL COMMENT '创建时间',
`update_time` datetime NOT NULL COMMENT '更新时间',
`listorder` int(3) NOT NULL DEFAULT '0' COMMENT '排序,优先级,越小优先级越高',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COMMENT='角色表';
-- ----------------------------
-- Records of auth_role
-- ----------------------------
INSERT INTO `auth_role` VALUES ('1', '超级管理员', '0', '1', '拥有网站最高管理员权限!', '2018-07-06 17:19:00', '2018-07-06 17:19:00', '0');
-- ----------------------------
-- Table structure for auth_role_admin
-- ----------------------------
DROP TABLE IF EXISTS `auth_role_admin`;
CREATE TABLE `auth_role_admin` (
`role_id` int(11) unsigned DEFAULT '0' COMMENT '角色 id',
`admin_id` int(11) DEFAULT '0' COMMENT '管理员id'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户角色对应表';
-- ----------------------------
-- Records of auth_role_admin
-- ----------------------------
-- ----------------------------
-- Table structure for file_resource
-- ----------------------------
DROP TABLE IF EXISTS `file_resource`;
CREATE TABLE `file_resource` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '资源id',
`tag_id` int(11) NOT NULL DEFAULT '0' COMMENT '资源分组id',
`type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '资源的类型0图片',
`filename` varchar(255) NOT NULL DEFAULT '' COMMENT '资源的原名',
`path` varchar(255) NOT NULL DEFAULT '' COMMENT '资源的路径(不加 域名的地址)',
`size` int(11) NOT NULL DEFAULT '0' COMMENT '大小',
`ext` varchar(10) NOT NULL DEFAULT '' COMMENT '资源的文件后缀',
`create_time` datetime NOT NULL COMMENT '创建时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8 COMMENT='资源表';
-- ----------------------------
-- Records of file_resource
-- ----------------------------
INSERT INTO `file_resource` VALUES ('1', '1', '0', 'Group 5.png', 'resources/image/20180530/854ae62758c585be5128cf344a511242.png', '7539', 'png', '2018-05-30 20:41:54');
INSERT INTO `file_resource` VALUES ('2', '0', '0', '643353_sdfaf123.png', 'resources/image/20180823/c356ca140f631a512f1c3a5e37a15dc1.png', '11507', 'png', '2018-08-23 13:38:42');
INSERT INTO `file_resource` VALUES ('3', '0', '0', '643353_sdfaf123.png', 'resources/image/20180823/4549c39e9c07c35681ee9fa94e0fc07e.png', '11507', 'png', '2018-08-23 14:05:18');
INSERT INTO `file_resource` VALUES ('4', '0', '0', '', '', '0', '', '2018-08-23 15:45:21');
INSERT INTO `file_resource` VALUES ('5', '0', '0', '', '', '2000000', '', '2018-08-23 15:45:21');
INSERT INTO `file_resource` VALUES ('6', '0', '0', '', '', '0', '', '2018-08-23 15:45:21');
INSERT INTO `file_resource` VALUES ('7', '0', '0', '', '', '0', '', '2018-08-23 15:45:21');
INSERT INTO `file_resource` VALUES ('8', '0', '0', '643353_sdfaf123.png', 'resources/image/20180823/0c424412b231eb8cb969377e15dbb812.png', '11507', 'png', '2018-08-23 15:53:32');
INSERT INTO `file_resource` VALUES ('9', '0', '0', '232826334630444283.png', 'FjBRVPOPF9gLeNBCAvK7jbif4yg8', '9668', 'png', '2018-08-23 16:08:13');
INSERT INTO `file_resource` VALUES ('10', '0', '0', '232826334630444283.png', 'FjBRVPOPF9gLeNBCAvK7jbif4yg8', '9668', 'png', '2018-08-23 16:09:07');
INSERT INTO `file_resource` VALUES ('11', '0', '0', '643353_sdfaf123.png', 'resources/image/20180823/52af5f8556a3af84cee696972b61baf4.png', '11507', 'png', '2018-08-23 17:06:05');
-- ----------------------------
-- Table structure for file_resource_tag
-- ----------------------------
DROP TABLE IF EXISTS `file_resource_tag`;
CREATE TABLE `file_resource_tag` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '资源分组的id',
`tag` varchar(255) NOT NULL DEFAULT '' COMMENT '资源分组的tag',
`create_time` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COMMENT='资源的分组表';
-- ----------------------------
-- Records of file_resource_tag
-- ----------------------------
INSERT INTO `file_resource_tag` VALUES ('1', '测试', '2018-05-30 20:41:48');
Loading…
Cancel
Save