CZT
2023-09-06 71c4fa1e27f75ae4b765c95c67a3069c84dc72ba
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package com.ld.igds.sh.service;
 
import com.alibaba.fastjson.JSONObject;
import com.ld.igds.constant.RedisConst;
import com.ld.igds.log.service.InteStatusLogService;
import com.ld.igds.models.DrugLog;
import com.ld.igds.models.InteStatusLog;
import com.ld.igds.sh.dto.ApiResponse;
import com.ld.igds.sh.dto.Dto1404;
import com.ld.igds.sh.param.ApiRequest;
import com.ld.igds.sh.param.BaseParam;
import com.ld.igds.sh.service.impl.HApiShServiceImpl;
import com.ld.igds.sh.util.ApiShConst;
import com.ld.igds.sh.util.RespCodeEnum;
import com.ld.igds.sh.util.RespUtil;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.util.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
 
/**
 * 熏蒸作业接口
 *
 * @author chen
 */
@Slf4j
@Service
public class ApiShServiceImpl1404 implements ApiShService {
 
    @Autowired
    private HApiShServiceImpl hApiShServiceImpl;
    @Autowired
    private InteStatusLogService inteStatusLogService;
    @Autowired
    private RedisUtil redisUtil;
 
    @Override
    public String getInterfaceId() {
        return ApiShConst.API_SH_1404;
    }
 
    @SuppressWarnings("unchecked")
    @Override
    public ApiResponse<Object> execute(ApiRequest<Object> request) {
        //获取参数信息
        String deptId = request.getDeptId();
        BaseParam param = JSONObject.parseObject(JSONObject.toJSONString(request.getData()), BaseParam.class);
 
        String companyId = ContextUtil.getDefaultCompanyId();
 
        String key = RedisConst.buildKey(companyId, ApiShConst.API_SH_1404);
        Date startTime = (Date) redisUtil.get(key);
        if (null == startTime) {
            startTime = DateUtils.addDays(param.getEndTime(), -30);
        }
        redisUtil.set(key, param.getEndTime());
 
        //查询熏蒸作业信息
        List<DrugLog> dataList = hApiShServiceImpl.listDrugLog(companyId,
                param.getDepotId(), startTime, param.getEndTime());
 
        //响应数据为空则直接返回响应码2000
        if (dataList == null || dataList.isEmpty()) {
            return RespUtil.error(RespCodeEnum.CODE_2000.getCode(), request);
        }
 
        List<Dto1404> list = new ArrayList<>();
        Dto1404 dto;
        InteStatusLog log;
        InteStatusLog addLog;
        //封装数据信息
        for (DrugLog data : dataList) {
            dto = new Dto1404();
            dto.setXzzybm(data.getDepotId().substring(0, 25) + data.getId());
            dto.setCfdm(data.getDepotId().substring(0, 25));
            dto.setXzkssj(DateFormatUtils.format(data.getStart() == null ? (new Date()) : data.getStart(), "yyyy-MM-dd"));
            dto.setXzjssj(DateFormatUtils.format(data.getEnd() == null ? (new Date()) : data.getEnd(), "yyyy-MM-dd"));
            dto.setHcjcdh(StringUtils.isEmpty(data.getPestBatchId()) ? "0" : data.getPestBatchId());
            dto.setDjcxz(data.getNum() == null ? "0" : data.getNum() + "");
            dto.setCgxzfs(StringUtils.isEmpty(data.getMode()) ? "0" : data.getMode());
            dto.setHlxzfs(StringUtils.isEmpty(data.getRecirMode()) ? "0" : data.getRecirMode());
            dto.setYjmc(StringUtils.isEmpty(data.getDrugName()) ? "0" : data.getDrugName());
            dto.setNd(data.getConcentration() == null ? "0" : data.getConcentration() + "");
            dto.setLddwyyl(data.getGrainDose() == null ? "0" : data.getGrainDose() + "");
            dto.setKjdwyyl(data.getSpaceDose() == null ? "0" : data.getSpaceDose() + "");
            dto.setZyyl(data.getDose() == null ? "0" : data.getDose() + "");
            dto.setSqrq(DateFormatUtils.format(data.getVentilateTime() == null ? (new Date()) : data.getVentilateTime(), "yyyy-MM-dd"));
            dto.setSqff(StringUtils.isEmpty(data.getVentilateMethod()) ? "0" : data.getVentilateMethod());
            dto.setSqjsslhqnd(data.getAfterPh3() == null ? "0.0" : data.getAfterPh3() + "");
            dto.setXzxgpj(StringUtils.isEmpty(data.getEvaluate()) ? "0" : data.getEvaluate());
            dto.setCzsjff(StringUtils.isEmpty(data.getCzsjff()) ? "0" : data.getCzsjff());
            dto.setCzclcs(StringUtils.isEmpty(data.getCzclcs()) ? "0" : data.getCzclcs());
//            dto.setXzzyry(StringUtils.isEmpty(data.getUser())?"0":data.getUser());
 
            dto.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
            //查询日志状态表,设置操作标志
            log = inteStatusLogService.getLogByBizId(companyId, ApiShConst.API_SH_1404 + "_" + data.getId());
            if (null == log) {
                addLog = new InteStatusLog();
                addLog.setBizId(ApiShConst.API_SH_1404 + "_" + data.getId());
                addLog.setCompanyId(companyId);
                addLog.setBizType(ApiShConst.API_SH_TYPE_TASK);
                addLog.setInterfaceId(ApiShConst.API_SH_1404);
                addLog.setInterfaceType(ApiShConst.API_SH_TYPE_TASK);
                addLog.setStatus(ApiShConst.API_SH_STATUS_SUCCESS);
 
                inteStatusLogService.addInteStatusLog(addLog);
            } else {
                dto.setCzbz(ApiShConst.API_SH_U);
            }
            list.add(dto);
        }
 
        //响应数据为空则直接返回响应码2000
        if (list.isEmpty()) {
            return RespUtil.error(RespCodeEnum.CODE_2000.getCode(), request);
        }
 
        return RespUtil.success(list, request);
    }
}