iidi
/
bocloud.sms
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

统计代办总数

develop
guyuliang 2024-08-26 16:49:29 +08:00
parent c53a32c1ba
commit b3f4c0b185
3 changed files with 57 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bocloud.sms.booter/src/main/java/com/bocloud/sms/booter/controller/IndexDataController.java
View File

@ -30,7 +30,13 @@ public class IndexDataController {
@GetMapping("/doneWorkOrder")
@Operation(summary = "待办工单列表")
public GeneralResult list(Pager pager, @Value(Common.REQ_CONTEXT) RequestContext requestContext) {
public GeneralResult doneWorkOrder(Pager pager, @Value(Common.REQ_CONTEXT) RequestContext requestContext) {
return indexService.doneWorkOrder(pager, requestContext);
}
@GetMapping("/workOrder/stattic")
@Operation(summary = "待办工单列表")
public GeneralResult workOrderStatic(Pager pager, @Value(Common.REQ_CONTEXT) RequestContext requestContext) {
return indexService.workOrderStatic(requestContext);
}
}

2
bocloud.sms.service/src/main/java/com/bocloud/sms/interfaces/IndexService.java
View File

@ -9,4 +9,6 @@ import java.util.List;
public interface IndexService {
GeneralResult doneWorkOrder(Pager pager, RequestContext requestContext);
GeneralResult workOrderStatic(RequestContext requestContext);
}

55
bocloud.sms.service/src/main/java/com/bocloud/sms/service/IndexServiceImpl.java
View File

@ -14,6 +14,10 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service("IndexService")
@Slf4j
public class IndexServiceImpl implements IndexService {
@ -28,16 +32,53 @@ public class IndexServiceImpl implements IndexService {
try {
JSONObject param = new JSONObject();
User user = userRepository.query(requestContext.getTarget());
param.put("userId","1111");
param.put("page",pager.getPage());
param.put("limit",pager.getRows());
param.put("userId", "1111");
param.put("page", pager.getPage());
param.put("limit", pager.getRows());
String result = ykUtil.call(YkInfo.getTaskList, param, JSONArray.class);
log.info("result");
log.info("result:" + result);
JSONObject jsonObject = JSONArray.parseObject(result, JSONObject.class);
return new GeneralResult(true, jsonObject,"查询成功");
return new GeneralResult(true, jsonObject, "查询成功");
} catch (Exception e) {
log.info("查询失败",e);
log.info("查询失败", e);
return new GeneralResult(false, "查询失败");
}
}
@Override
public GeneralResult workOrderStatic(RequestContext requestContext) {
try {
JSONObject param = new JSONObject();
User user = userRepository.query(requestContext.getTarget());
param.put("userId", "1111");
param.put("page",1);
param.put("limit", Integer.MAX_VALUE);
String result = ykUtil.call(YkInfo.getTaskList, param, JSONArray.class);
log.info("result:" + result);
JSONObject jsonObject = JSONArray.parseObject(result, JSONObject.class);
Integer total = jsonObject.getInteger("total");
Map<String,Object> resultMap = new HashMap<>();
resultMap.put("orderTotal",total);
List<JSONObject> data = JSONObject.parseObject(jsonObject.getString("data"), List.class);
Integer waitDoneTotal = 0;
Integer doneTotal = 0;
for (JSONObject obj : data) {
if("0".equals(obj.getString("approve_status"))){
waitDoneTotal++;
}else {
doneTotal++;
}
}
resultMap.put("waitDoneTotal",waitDoneTotal);
resultMap.put("doneTotal",doneTotal);
return new GeneralResult(true, "查询成功");
} catch (Exception e) {
log.info("查询失败", e);
return new GeneralResult(false, "查询失败");
}
}