UDI
/
udi-wms-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 定时设置结合业务

Browse Source
dev_no_inv
chenhc 1 year ago
parent 0b32274b65
commit 9fd7db20d7
7 changed files with 142 additions and 12 deletions
Show Stats Download Patch File Download Diff File

4
src/main/java/com/glxp/api/controller/collect/IoCollectSetController.java
Unescape Escape View File

@ -35,8 +35,8 @@ public class IoCollectSetController extends BaseController {
@GetMapping("/udiwms/ioSplit/collect/getSet")
public BaseResponse getSet() {
List<IoCollectSet> collectSets = collectSetService.list();
return ResultVOUtils.success(collectSets.get(0));
IoCollectSet collectSet = collectSetService.getSet();
return ResultVOUtils.success(collectSet);
}

8
src/main/java/com/glxp/api/entity/collect/IoCollectSet.java
Unescape Escape View File

@ -63,5 +63,13 @@ public class IoCollectSet implements Serializable {
@ApiModelProperty(value = "是否自动上传已完成单据")
private Boolean autoUploadOrder;
/**
* 起始上传时间
*/
@TableField(value = "startUploadTime")
@ApiModelProperty(value = "起始上传时间")
private Date startUploadTime;
private static final long serialVersionUID = 1L;
}

8
src/main/java/com/glxp/api/service/collect/IoCollectOrderService.java
Unescape Escape View File

@ -131,6 +131,8 @@ public class IoCollectOrderService extends ServiceImpl<IoCollectOrderMapper, IoC
@Resource
IoCollectOrderBackupService ioCollectOrderBackupService;
@Resource
IoCollectSetService collectSetService;
public IoCollectOrder getByBillNo(String billNo) {
return collectOrderMapper.selectOne(new LambdaQueryWrapper<IoCollectOrder>().eq(IoCollectOrder::getBillNo, billNo).last("limit 1"));
@ -471,6 +473,9 @@ public class IoCollectOrderService extends ServiceImpl<IoCollectOrderMapper, IoC
if (CollUtil.isNotEmpty(ioCollectOrderList)) {
//是否自动转成待处理单据
Boolean autoDealOrder = collectSetService.getSet().getAutoDealOrder();
List<IoCollectOrder> allotCollects = new ArrayList<>();
List<IoCollectOrderBiz> allotCollectBizs = new ArrayList<>();
for (IoCollectOrder collectOrder : ioCollectOrderList) {
@ -542,12 +547,13 @@ public class IoCollectOrderService extends ServiceImpl<IoCollectOrderMapper, IoC
collectOrderBizOriginService.saveBatch(ioCollectOrderBizOrigins);
}
if (!collectOrder.getTagStatus().equals(4)) {
if (!collectOrder.getTagStatus().equals(4) && autoDealOrder) {//没出现耗材不匹配 且 开启了自动转成待处理单据
collectOrder.setTagStatus(1);
allotCollects.add(collectOrder);
allotCollectBizs.addAll(bizList);
}
}
if (CollUtil.isNotEmpty(allotCollects)) {
saveBatch(allotCollects);
collectOrderBizService.saveBatch(allotCollectBizs);

4
src/main/java/com/glxp/api/service/collect/IoCollectSetService.java
Unescape Escape View File

@ -9,4 +9,8 @@ import com.glxp.api.dao.collect.IoCollectSetMapper;
@Service
public class IoCollectSetService extends ServiceImpl<IoCollectSetMapper, IoCollectSet> {
public IoCollectSet getSet() {
List<IoCollectSet> collectSets = this.list();
return collectSets.get(0);
}
}

25
src/main/java/com/glxp/api/task/AsyncIoCollectOrderDownloadTask.java
Unescape Escape View File

@ -6,6 +6,7 @@ import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import com.glxp.api.dao.basic.SysWorkplaceDocumentDao;
import com.glxp.api.dao.schedule.ScheduledDao;
import com.glxp.api.entity.collect.IoCollectSet;
import com.glxp.api.entity.inv.InvProductRationEntity;
import com.glxp.api.entity.system.ScheduledEntity;
import com.glxp.api.entity.system.SystemParamConfigEntity;
@ -15,6 +16,7 @@ import com.glxp.api.req.system.ScheduledRequest;
import com.glxp.api.req.system.SysParamConfigSaveRequest;
import com.glxp.api.res.basic.SysWorkplaceDocumentResponse;
import com.glxp.api.service.collect.IoCollectOriginService;
import com.glxp.api.service.collect.IoCollectSetService;
import com.glxp.api.service.inv.InvProductRationService;
import com.glxp.api.service.system.SystemParamConfigService;
import com.glxp.api.util.MsDateUtil;
@ -28,6 +30,7 @@ import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@ -46,8 +49,7 @@ public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
@Resource
IoCollectOriginService collectOriginService;
@Resource
SystemParamConfigService systemParamConfigService;
IoCollectSetService collectSetService;
@Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
scheduledTaskRegistrar.addTriggerTask(() -> process(),
@ -66,10 +68,14 @@ public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
private void process() {
ThreadUtil.execAsync(() -> {
//获取下载的起始时间
SystemParamConfigEntity startDownloadTime = systemParamConfigService.selectByParamKey("startDownloadTime");
if (startDownloadTime != null && StrUtil.isNotBlank(startDownloadTime.getParamValue() )){
IoCollectSet ioCollectSet = collectSetService.getSet();
Date startDownloadTime = ioCollectSet.getStartDownloadTime();
String startDownloadTimes = MsDateUtil.formatDateTime(startDownloadTime);
Boolean autoDownload = ioCollectSet.getAutoDownload();
if (StrUtil.isNotBlank(startDownloadTimes) && autoDownload){
//获取当前时间
String paramValue = startDownloadTime.getParamValue();
String paramValue = startDownloadTimes;
String nowTime = MsDateUtil.getDateTime();
CollectOrderRequest collectOrderRequest = new CollectOrderRequest();
@ -85,11 +91,12 @@ public class AsyncIoCollectOrderDownloadTask implements SchedulingConfigurer {
collectOriginService.downloadOrderV2(collectOrderRequest);
}
}
startDownloadTime.setParamValue(nowTime);
SysParamConfigSaveRequest sysParamConfigSaveRequest = new SysParamConfigSaveRequest();
BeanUtil.copyProperties(startDownloadTime,sysParamConfigSaveRequest);
systemParamConfigService.updateById(sysParamConfigSaveRequest);
ioCollectSet.setStartDownloadTime(MsDateUtil.parseDate(nowTime));
collectSetService.updateById(ioCollectSet);
}
});
}

95
src/main/java/com/glxp/api/task/AsyncIoCollectOrderUploadTask.java
Unescape Escape View File

@ -0,0 +1,95 @@
package com.glxp.api.task;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import com.glxp.api.dao.basic.SysWorkplaceDocumentDao;
import com.glxp.api.dao.schedule.ScheduledDao;
import com.glxp.api.entity.collect.IoCollectSet;
import com.glxp.api.entity.system.ScheduledEntity;
import com.glxp.api.req.basic.WorkBindBusTypeRequest;
import com.glxp.api.req.collect.CollectOrderRequest;
import com.glxp.api.req.system.ScheduledRequest;
import com.glxp.api.res.basic.SysWorkplaceDocumentResponse;
import com.glxp.api.res.collect.IoCollectCodeResponse;
import com.glxp.api.res.collect.IoCollectOrderResponse;
import com.glxp.api.service.collect.*;
import com.glxp.api.util.MsDateUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
@Component
@EnableScheduling
public class AsyncIoCollectOrderUploadTask implements SchedulingConfigurer {
final Logger logger = LoggerFactory.getLogger(AsyncIoCollectOrderUploadTask.class);
@Resource
private ScheduledDao scheduledDao;
@Resource
IoCollectSetService collectSetService;
@Resource
IoCollectCodeService collectCodeService;
@Resource
IoCollectOrderBackupService ioCollectOrderBackupService;
@Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
scheduledTaskRegistrar.addTriggerTask(() -> process(),
triggerContext -> {
ScheduledRequest scheduledRequest = new ScheduledRequest();
scheduledRequest.setCronName("ioCollectOrderUploadTask");
ScheduledEntity scheduledEntity = scheduledDao.findScheduled(scheduledRequest);
String cron = scheduledEntity != null ? scheduledEntity.getCron() : "0 */10 * * * ?";
if (cron.isEmpty()) {
logger.error("cron is null");
}
return new CronTrigger(cron).nextExecutionTime(triggerContext);
});
}
private void process() {
ThreadUtil.execAsync(() -> {
//获取下载的起始时间
IoCollectSet ioCollectSet = collectSetService.getSet();
Date startUploadTime = ioCollectSet.getStartUploadTime();
String startUploadTimes = MsDateUtil.formatDateTime(startUploadTime);
Boolean autoUploadOrder = ioCollectSet.getAutoUploadOrder();
if (StrUtil.isNotBlank(startUploadTimes) && autoUploadOrder){
//获取当前时间
String paramValue = startUploadTimes;
String nowTime = MsDateUtil.getDateTime();
CollectOrderRequest collectOrderRequest = new CollectOrderRequest();
collectOrderRequest.setStartTime(paramValue);
collectOrderRequest.setEndTime(nowTime);
collectOrderRequest.setUploadStatus(1); //未上传
//调用上传单据
List<IoCollectOrderResponse> orderResponses = ioCollectOrderBackupService.filterList(collectOrderRequest);
if (CollUtil.isNotEmpty(orderResponses)){
orderResponses.forEach( item -> {
ioCollectOrderBackupService.orderUpload(item.getBillNo());
});
}
ioCollectSet.setStartUploadTime(MsDateUtil.parseDate(nowTime));
collectSetService.updateById(ioCollectSet);
}
});
}
}

10
src/main/resources/mybatis/mapper/collect/IoCollectOrderBackupMapper.xml
Unescape Escape View File

@ -117,6 +117,16 @@
<if test="fromCorpName != '' and fromCorpName != null">
AND icob.fromCorpName LIKE concat('%', #{fromCorpName}, '%')
</if>
<if test="startTime != null">
<![CDATA[
and icob.finishTime >= DATE_FORMAT(#{startTime}, '%Y-%m-%d %H:%i:%S')
]]>
</if>
<if test="endTime != null">
<![CDATA[
and icob.finishTime <= DATE_FORMAT(#{endTime}, '%Y-%m-%d %H:%i:%S')
]]>
</if>
</where>
GROUP BY
icob.billNo

Write Preview
Loading…
Cancel
Save