430DNC迁移git初始化

lyh

2026-01-19 6141f0a2140439337dccf8bfe93c4ca83605446d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package com.lxzn.mes.service.impl;
 
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.additional.query.impl.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.lxzn.framework.domain.mes.MesProcedureFinish;
import com.lxzn.framework.domain.mes.ext.MesProcedureFinishReceive;
import com.lxzn.framework.domain.mes.request.MesProcedureFinishRequest;
import com.lxzn.framework.exception.ExceptionCast;
import com.lxzn.framework.model.response.CommonCode;
import com.lxzn.framework.model.response.QueryPageResponseResult;
import com.lxzn.framework.utils.BeanMapper;
import com.lxzn.framework.utils.ValidateUtil;
import com.lxzn.framework.utils.date.DateUtil;
import com.lxzn.mes.dao.MesProcedureFinishMapper;
import com.lxzn.mes.ext.MesResultModel;
import com.lxzn.mes.service.IMesProcedureFinishService;
import lombok.extern.log4j.Log4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.ArrayList;
import java.util.List;
 
/**
 * @author clown
 * * @date 2022/10/31
 */
@Log4j
@Service
public class MesProcedureFinishServiceImpl extends ServiceImpl<MesProcedureFinishMapper,MesProcedureFinish> implements IMesProcedureFinishService {
 
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public MesResultModel saveOrUpdateDis(MesProcedureFinishReceive mesReceives) {
        if (mesReceives == null ) {
            return null;
        }
        MesProcedureFinish task = new MesProcedureFinish();
        MesResultModel model =new MesResultModel();
        model.setSuccFlag("成功");
        MesProcedureFinish mes = findProcedureFromId(mesReceives.getMesId());
        if (mesReceives.getCheckDateLong() != null) {
            mesReceives.setCheckDate(DateUtil.longDateLong(mesReceives.getCheckDateLong()));
        }
        if (mesReceives.getSyncDateLong() != null) {
            mesReceives.setSyncDate(DateUtil.longDateLong(mesReceives.getSyncDateLong()));
        }
        if (mes == null) {
            BeanMapper.copy(mesReceives,task);
            log.error(task.toString());
            boolean b = this.saveOrUpdate(task);
            if (b) {
                return model;
            }
        } else {
            BeanMapper.copy(mesReceives,mes);
 
            boolean b = this.saveOrUpdate(mes);
            if (b) {
                return model;
            }
        }
        return null;
    }
 
    @Override
    public MesProcedureFinish findProcedureFromId(String mesId) {
        List<MesProcedureFinish> tasks = super.lambdaQuery().eq(MesProcedureFinish::getMesId, mesId).list();
        if (tasks == null || tasks.isEmpty()) {
            return null;
        }
        return tasks.get(0);
    }
 
    @Override
    public QueryPageResponseResult<MesProcedureFinish> findPageList(int page, int size,
                                                                    MesProcedureFinishRequest requestParams) {
        if(page < 1 || size < 1) {
            ExceptionCast.cast(CommonCode.INVALID_PAGE);
        }
        IPage<MesProcedureFinish> pageData = new Page<>(page, size);
        LambdaQueryChainWrapper<MesProcedureFinish> lambdaQuery = super.lambdaQuery();
        if(requestParams != null) {
            if(ValidateUtil.validateString(requestParams.getMdsItemCode())) {
                lambdaQuery.eq(MesProcedureFinish::getMdsItemCode, requestParams.getMdsItemCode());
            }
           /* if(ValidateUtil.validateString(requestParams.getMdsEquipmentId())) {
                lambdaQuery.eq(MesProcedureFinish::getMdsEquipmentId, requestParams.getMdsEquipmentId());
            }
            if(ValidateUtil.validateString(requestParams.getMdsWorkcenterId())) {
                lambdaQuery.like(MesProcedureFinish::getMdsWorkcenterId, requestParams.getMdsWorkcenterId());
            }*/
            if(ValidateUtil.validateString(requestParams.getMesRouteId())) {
                lambdaQuery.like(MesProcedureFinish::getMesRouteId, requestParams.getMesRouteId());
            }
            if(ValidateUtil.validateString(requestParams.getEndTime())) {
                String date = DateUtil.format(DateUtil.plusTime(DateUtil.toDate(requestParams.getEndTime(),DateUtil.STR_DATE),1),DateUtil.STR_DATE);
                lambdaQuery.lt(MesProcedureFinish::getCheckDate,date);
            }
            if(ValidateUtil.validateString(requestParams.getStartTime())) {
                lambdaQuery.ge(MesProcedureFinish::getCheckDate,requestParams.getStartTime());
            }
        }
        IPage<MesProcedureFinish> userIPage = lambdaQuery.page(pageData);
        return new QueryPageResponseResult<>(CommonCode.SUCCESS, userIPage);
    }
}