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
133
134
135
136
 
package com.iailab.module.prod.service.impl;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.iailab.framework.common.constant.Constant;
import com.iailab.common.dto.echarts.BarLineDTO;
import com.iailab.common.enums.CommonConstant;
import com.iailab.framework.common.page.PageData;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.common.utils.CommonUtils;
import com.iailab.framework.common.util.object.ConvertUtils;
import com.iailab.common.utils.HttpsRequest;
import com.iailab.module.data.dto.FeignHttpApiDTO;
import com.iailab.module.data.api.IFeignDataApi;
import com.iailab.module.prod.dao.PrdPlanYearDao;
import com.iailab.module.prod.dto.PrdPlanYearDTO;
import com.iailab.module.prod.entity.PrdPlanYearEntity;
import com.iailab.module.prod.service.PrdPlanYearService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.math.BigDecimal;
import java.util.*;
 
/**
 * @author PanZhibao
 * @Description
 * @createTime 2024年05月14日
 */
@Slf4j
@Service
public class PrdPlanYearServiceImpl extends BaseServiceImpl<PrdPlanYearDao, PrdPlanYearEntity> implements PrdPlanYearService {
 
    private String HTTP_API_CODE = "Prd.YearPEI";
 
    @Resource
    private IFeignDataApi feignDataApi;
 
    @Resource
    private HttpsRequest httpsRequest;
 
    @Override
    public PageData<PrdPlanYearDTO> page(Map<String, Object> params) {
        IPage<PrdPlanYearEntity> page = baseDao.selectPage(
                getPage(params, Constant.CREATE_DATE, false),
                getWrapper(params)
        );
        return getPageData(page, PrdPlanYearDTO.class);
    }
 
    private QueryWrapper<PrdPlanYearEntity> getWrapper(Map<String, Object> params){
        String rq = (String)params.get("rq");
 
        QueryWrapper<PrdPlanYearEntity> wrapper = new QueryWrapper<>();
        wrapper.eq(StringUtils.isNotBlank(rq), "rq", rq)
                .orderByAsc("rq");
 
        return wrapper;
    }
 
    @Override
    public PrdPlanYearDTO get(String id) {
        PrdPlanYearEntity entity = baseDao.selectById(id);
 
        return ConvertUtils.sourceToTarget(entity, PrdPlanYearDTO.class);
    }
 
    @Override
    public void save(PrdPlanYearDTO dto) {
        PrdPlanYearEntity entity = ConvertUtils.sourceToTarget(dto, PrdPlanYearEntity.class);
 
        insert(entity);
    }
 
    @Override
    public void update(PrdPlanYearDTO dto) {
        PrdPlanYearEntity entity = ConvertUtils.sourceToTarget(dto, PrdPlanYearEntity.class);
 
        updateById(entity);
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void delete(String[] ids) {
        baseDao.deleteBatchIds(Arrays.asList(ids));
    }
 
    @Override
    public BarLineDTO barLine(String length) {
        return null;
    }
 
    @Override
    public BigDecimal currentValue() {
        return null;
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void syncData() {
        FeignHttpApiDTO apiDTO = feignDataApi.getHttpApi(HTTP_API_CODE);
        Map<String, String> params = new HashMap<>();
        String responseStr = httpsRequest.doGet(apiDTO.getUrl(), params, "utf-8", "");
 
        JSONObject responseObj = JSON.parseObject(responseStr);
        if (!CommonConstant.STA_TRUE.equals(responseObj.get("sta").toString())) {
            log.info("接口异常");
        }
        JSONObject res = responseObj.getJSONObject(CommonConstant.ZX_RES);
        JSONObject yearData = res.getJSONObject("yearData");
        this.deleteByYear(yearData.get("year").toString());
        PrdPlanYearEntity entity = new PrdPlanYearEntity();
        entity.setId(UUID.randomUUID().toString());
        entity.setRq(yearData.get("year").toString());
        entity.setXxPlan(CommonUtils.getJSONValue(yearData.get("xxPlan")));
        entity.setXxPerformance(CommonUtils.getJSONValue(yearData.get("xxPerformance")));
        entity.setZqPlan(CommonUtils.getJSONValue(yearData.get("zqPlan")));
        entity.setZqPerformance(CommonUtils.getJSONValue(yearData.get("zqPerformance")));
        entity.setCreateDate(new Date());
        entity.setUpdateDate(new Date());
        insert(entity);
 
    }
 
    private void deleteByYear(String rq) {
        QueryWrapper<PrdPlanYearEntity> wrapper = new QueryWrapper<>();
        wrapper.eq(StringUtils.isNotBlank(rq), "rq", rq);
        baseDao.delete(wrapper);
    }
}