*

lsh

2024-10-29 80f5bd729e3147f3b62bb701c045e6183dff87e3

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
130
131
132
package com.zy.asrs.task.handler;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.core.exception.CoolException;
import com.zy.asrs.entity.BasJar;
import com.zy.asrs.entity.BasJarMast;
import com.zy.asrs.mapper.BasJarMapper;
import com.zy.asrs.service.*;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.ArrayList;
import java.util.List;
 
/**
 * Created by Monkey D. Luffy on 2024.07.20
 * 亳州煜星..............以下.............亳州煜星.............上传开式冷却信号
 */
@Slf4j
@Service
@Transactional
public class JarBurialEscalationHandler extends AbstractHandler<String> {
 
//    private static final Integer jarMaxLoc = 7;
    private static Integer jarMaxLoc = 0;
 
    @Autowired
    private ApiLogService apiLogService;
    @Autowired
    private BasJarMastService basJarMastService;
    @Autowired
    private BasJarMapper basJarMapper;
 
//    @Value("${srHangJia.url}")
    private String erpUrl = "10.10.11.100:8580";
//    @Value("${srHangJia.reportOutPath}")
    private String reportOutPath = "mes/wms-service/boxWeight";
 
    public ReturnT<String> start(int jarNo,Integer souStatus,Integer endStatus) {
        try{
            List<BasJarMast> basJarMastList = basJarMastService.getJarMastByJarIdAndStatusList(jarNo, new ArrayList<Integer>() {{
                add(souStatus);//硫化完成
            }});
            BasJar basJar = basJarMapper.selectById(jarNo);
            jarMaxLoc = basJar.getJarCount();
            if (jarMaxLoc == 0) {
                return FAIL;
            }
            if (basJarMastList.size() != jarMaxLoc){
                return FAIL;
            } else {
//                    ReturnT<String> result = postMesData(reportOutPath,1);
//                    if (result.getCode()==200){
                    Integer integer = basJarMastService.updateStatus(jarNo, souStatus, endStatus);
                    if (basJarMastList.size()!=integer){
                        log.error("{}号硫化罐硫化完成后开门完成修改硫化档案状态结果数量不一致！！！查询资料数量={}，更新返回数量={}",jarNo,basJarMastList.size(),integer);
                        return FAIL;
                    }
                    return SUCCESS;
//                    }else {
//                        log.error("1楼翻转重量信息上传失败");
//                    }
            }
        }catch (Exception e){
            log.error("异常！！！"+e);
            return FAIL;
        }
    }
 
    private ReturnT<String> postMesData(String erpPath,Object combParam){
        if(combParam != null){
            String response = "";
            boolean success = false;
            try {
                response = new HttpHandler.Builder()
                        .setUri(erpUrl)
                        .setPath(erpPath)
                        .setJson(JSON.toJSONString(combParam))
                        .build()
                        .doPost();
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.getInteger("Code")==200) {
                    success = true;
                } else {
                    log.error("1楼翻转重量信息上传请求接口失败！！！url：{}；request：{}；response：{}"+erpUrl+erpPath, JSON.toJSONString(combParam), response);
                    throw new CoolException("上报mes系统失败");
                }
            } catch (Exception e) {
                log.error("fail", e);
//                      TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                return FAIL.setMsg(e.getMessage());
            } finally {
                try {
                    // 保存接口日志
                    apiLogService.save(
                            "上报MES系统",
                            erpUrl + erpPath,
                            null,
                            erpUrl,
                            JSON.toJSONString(combParam),
                            response,
                            success
                    );
                } catch (Exception e) { log.error("", e); }
            }
        }
        return SUCCESS;
    }
 
    public Integer getStaOther(Integer staNo){
        switch (staNo){
            case 118:
                return 119;
            case 119:
                return 118;
            case 120:
                return 121;
            case 121:
                return 120;
            default:
                return 0;
        }
    }
 
 
}