package zy.cloud.wms.manager.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.annotations.ManagerAuth;
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.core.common.SnowflakeIdWorker;
|
import com.core.exception.CoolException;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import zy.cloud.wms.common.entity.Parameter;
|
import zy.cloud.wms.common.model.BillDto;
|
import zy.cloud.wms.common.service.erp.ErpService;
|
import zy.cloud.wms.common.web.BaseController;
|
import zy.cloud.wms.manager.entity.WrkLocSync;
|
import zy.cloud.wms.manager.service.LocSyncService;
|
import zy.cloud.wms.manager.service.WrkLocSyncService;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@RestController
|
@Slf4j
|
public class LocSyncController extends BaseController {
|
@Autowired
|
private LocSyncService locSyncService;
|
@Autowired
|
private WrkLocSyncService wrkLocSyncService;
|
@Autowired
|
private ErpService erpService;
|
@Autowired
|
private SnowflakeIdWorker snowflakeIdWorker;
|
|
@RequestMapping(value = "/locSync/queryLocSum")
|
@ManagerAuth(memo = "获取总库存清单")
|
public R queryLocSum() {
|
return R.ok(locSyncService.queryLocSum());
|
}
|
|
@RequestMapping(value = "/locSync/syncLocWrkCount")
|
@ManagerAuth(memo = "获取库存同步上传清单数量")
|
public R getSyncLocWrkCount() {
|
return R.ok(wrkLocSyncService.getSyncLocWrkCount());
|
}
|
|
|
@RequestMapping(value = "/locSync/insertWrklocSync")
|
@ManagerAuth(memo = "同步上传清单数据插入")
|
public R insertWrklocSync(@RequestBody JSONObject param) {
|
List<WrkLocSync> list = JSONObject.parseArray(param.getJSONArray("list").toJSONString(), WrkLocSync.class);
|
// 插入创建人员和创建时间
|
if (list.size() > 0) {
|
for (WrkLocSync elist : list) {
|
elist.setCreateBy(getUserId());
|
elist.setCreateTime(new Date());
|
}
|
}
|
Integer result = 0;
|
result = wrkLocSyncService.insertWrkLocSync(list);
|
return R.ok(result);
|
}
|
|
|
@RequestMapping(value = "/locSync/updateWrklocSync")
|
@ManagerAuth(memo = "清空同步上传清单数据，并插入")
|
public R updateWrklocSync(@RequestBody JSONObject param) {
|
// 清空同步上传清单数据
|
if (!wrkLocSyncService.clearWrkLocSync()) {
|
throw new CoolException("同步上传清单数据清空失败，请联系管理员");
|
}
|
;
|
List<WrkLocSync> list = JSONObject.parseArray(param.getJSONArray("list").toJSONString(), WrkLocSync.class);
|
// 插入创建人员和创建时间
|
if (list.size() > 0) {
|
for (WrkLocSync elist : list) {
|
elist.setCreateBy(getUserId());
|
elist.setCreateTime(new Date());
|
}
|
}
|
Integer result = 0;
|
result = wrkLocSyncService.insertWrkLocSync(list);
|
return R.ok(result);
|
}
|
|
/* 同步上传erp[uploadBill] 单据上传 */
|
@Scheduled(cron = "0/2 * * * * ? ")
|
public void execute() {
|
if (!Cools.isEmpty(Parameter.get().getSyncSwitch()) && Parameter.get().getSyncSwitch().equals("Y")) {
|
List<String> orderList = new ArrayList<>();
|
orderList.add("state");
|
orderList.add("create_time");
|
List<WrkLocSync> syncList = wrkLocSyncService.selectList(new EntityWrapper<WrkLocSync>()
|
.eq("state", "N").orderDesc(orderList));
|
// 同步上传清单处理，取第一条
|
if (!Cools.isEmpty(syncList)) {
|
WrkLocSync executeData = syncList.get(0);
|
// 订单号
|
String docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);
|
// 订单类型 34采购单
|
Integer docId = 34;
|
List<BillDto> dtos = new ArrayList<BillDto>();
|
BillDto res = new BillDto();
|
res.setMatnr(executeData.getMatnr());
|
res.setQty(executeData.getQty());
|
dtos.add(res);
|
if (erpService.uploadBill(dtos, docId, docNum)) {
|
// 成功后删除任务
|
if (!wrkLocSyncService.delete(new EntityWrapper<WrkLocSync>().eq("matnr", executeData.getMatnr()))) {
|
log.info("库存同步删除任务失败,任务matnr=" + executeData.getMatnr() + "时间=" + new Date());
|
}
|
} else {
|
// 失败后将任务状态state更新为N
|
executeData.setState("X");
|
executeData.setUpdateBy(9527L);
|
executeData.setCreateTime(new Date());
|
if(!wrkLocSyncService.update(executeData, new EntityWrapper<WrkLocSync>().eq("matnr", executeData.getMatnr()))) {
|
log.info("库存同步更新任务失败,任务matnr=" + executeData.getMatnr() + "时间=" + new Date());
|
}
|
}
|
}
|
}
|
|
}
|
}
|
