ZnddYuAnServiceImpl.java
2.27 KB
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
package com.bsth.service.zndd.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.bsth.common.ResponseCode;
import com.bsth.entity.zndd.ZnddYuAn;
import com.bsth.repository.zndd.ZnddYuAnRepository;
import com.bsth.service.impl.BaseServiceImpl;
import com.bsth.service.zndd.ZnddYuAnService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service
public class ZnddYuAnServiceImpl extends BaseServiceImpl<ZnddYuAn, Integer> implements ZnddYuAnService {
Logger logger = LoggerFactory.getLogger(this.getClass());
@Autowired
ZnddYuAnRepository znddYuAnRepository;
@Override
@Transactional
public Map<String, Object> addMap(Map<String, Object> params){
Map<String, Object> rs = new HashMap<>();
try {
List<Map> list = JSON.parseArray(params.get("data").toString(), Map.class);
List<Map> listlineks = JSON.parseArray(params.get("links").toString(), Map.class);
znddYuAnRepository.deleteType(params.get("type").toString());
for (Map m : list){
ZnddYuAn zya = new ZnddYuAn();
String s = JSONObject.toJSONString(m);
zya.setType(params.get("type").toString());
zya.setJsonDate(s);
zya.setTypes("0");
znddYuAnRepository.save(zya);
}
for (Map m : listlineks) {
ZnddYuAn zya = new ZnddYuAn();
String s = JSONObject.toJSONString(m);
zya.setType(params.get("type").toString());
zya.setJsonDate(s);
zya.setTypes("1");
znddYuAnRepository.save(zya);
}
rs.put("status", ResponseCode.SUCCESS);
}catch (Exception e){
logger.info("调度预案添加-"+e);
rs.put("ERROR", "操作失败,请检查数据是否有误！");
}
return rs;
}
public List<ZnddYuAn> yuanList(String type,String types){
return znddYuAnRepository.yuanlist(type, types);
}
}