[add]工单同步代码

zhanghl

2025-04-17 f366db113cb6f26f418f42d0098d9aa1c52a61b7

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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
package com.aps.job.service.impl;
 
import java.util.ArrayList;
import java.util.List;
 
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aps.common.core.utils.DateUtils;
import com.aps.common.core.utils.StringUtils;
import jakarta.annotation.Resource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import com.aps.job.mapper.ApsWorkOrderJobMapper;
import com.aps.job.domain.ApsWorkOrderJob;
import com.aps.job.service.IApsWorkOrderJobService;
import org.springframework.web.client.RestTemplate;
 
/**
 * 工单同步Service业务层处理
 * 
 * @author zhl
 * @date 2025-04-17
 */
@Service
public class ApsWorkOrderJobServiceImpl implements IApsWorkOrderJobService 
{
    @Autowired
    private ApsWorkOrderJobMapper apsWorkOrderJobMapper;
 
    /**
     * 获取订单接口
     * */
    @Value("${u9.workOrderJobUrl}")
    private String getWorkOrderUrl;
 
    @Autowired
    private RestTemplate restTemplate;
 
 
    /**
     * 查询工单同步
     * 
     * @param id 工单同步主键
     * @return 工单同步
     */
    @Override
    public ApsWorkOrderJob selectApsWorkOrderJobById(Long id)
    {
        return apsWorkOrderJobMapper.selectApsWorkOrderJobById(id);
    }
 
    /**
     * 查询工单同步列表
     * 
     * @param apsWorkOrderJob 工单同步
     * @return 工单同步
     */
    @Override
    public List<ApsWorkOrderJob> selectApsWorkOrderJobList(ApsWorkOrderJob apsWorkOrderJob)
    {
        return apsWorkOrderJobMapper.selectApsWorkOrderJobList(apsWorkOrderJob);
    }
 
    /**
     * 新增工单同步
     * 
     * @param apsWorkOrderJob 工单同步
     * @return 结果
     */
    @Override
    public int insertApsWorkOrderJob(ApsWorkOrderJob apsWorkOrderJob)
    {
        apsWorkOrderJob.setCreateTime(DateUtils.getNowDate());
        return apsWorkOrderJobMapper.insertApsWorkOrderJob(apsWorkOrderJob);
    }
 
    /**
     * 修改工单同步
     * 
     * @param apsWorkOrderJob 工单同步
     * @return 结果
     */
    @Override
    public int updateApsWorkOrderJob(ApsWorkOrderJob apsWorkOrderJob)
    {
        apsWorkOrderJob.setUpdateTime(DateUtils.getNowDate());
        return apsWorkOrderJobMapper.updateApsWorkOrderJob(apsWorkOrderJob);
    }
 
    /**
     * 批量删除工单同步
     * 
     * @param ids 需要删除的工单同步主键
     * @return 结果
     */
    @Override
    public int deleteApsWorkOrderJobByIds(Long[] ids)
    {
        return apsWorkOrderJobMapper.deleteApsWorkOrderJobByIds(ids);
    }
 
    /**
     * 删除工单同步信息
     * 
     * @param id 工单同步主键
     * @return 结果
     */
    @Override
    public int deleteApsWorkOrderJobById(Long id)
    {
        return apsWorkOrderJobMapper.deleteApsWorkOrderJobById(id);
    }
 
 
    @Override
    public void batchInsertApsWorkOrderJob() {
 
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        Integer PageIndex=1;
        Integer PageSize=10;
        Boolean continueFlag=true;
      /*  while (continueFlag){*/
            JSONObject requestBody = new JSONObject();
            requestBody.put("PageIndex", PageIndex);
            requestBody.put("PageSize", PageSize);
            HttpEntity<String> request = new HttpEntity<>(requestBody.toJSONString(), headers);
            ResponseEntity<String> response = restTemplate.postForEntity(getWorkOrderUrl, request, String.class);
            if (response.getStatusCode().is2xxSuccessful()) {
                String responseBody = response.getBody();
                if(StringUtils.isNotEmpty(responseBody)){
                    JSONObject responseBodyJson = JSONObject.parseObject(responseBody);
                    if("200".equals(responseBodyJson.getString("status"))){
                        JSONArray result = responseBodyJson.getJSONArray("data");
                        List<ApsWorkOrderJob> jobs = new ArrayList<>();
                        if (result!=null){
                            for (int i = 0; i < result.size(); i++) {
                                ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class);
                                jobs.add(order);
                            }
                        }
                        apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs);
                    }
                }
            }
       /* }*/
    }
}