| | |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.utils.util.BeanConvertUtil; |
| | | import com.java110.utils.util.DateUtil; |
| | | import com.java110.utils.util.ListUtil; |
| | | import com.java110.vo.ResultVo; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.ResponseEntity; |
| | |
| | | if (!reqJson.containsKey("userId")) { |
| | | reqJson.put("userId", context.getReqHeaders().get("user-id")); |
| | | } |
| | | |
| | | } |
| | | |
| | | @Override |
| | |
| | | feeAttrDto.setSpecCd(FeeAttrDto.SPEC_CD_REPAIR); |
| | | feeAttrDto.setValue(reqJson.getString("repairId")); |
| | | List<FeeAttrDto> feeAttrDtos = feeAttrInnerServiceSMOImpl.queryFeeAttrs(feeAttrDto); |
| | | if (feeAttrDtos != null && feeAttrDtos.size() > 0) { |
| | | if (!ListUtil.isNull(feeAttrDtos)) { |
| | | FeeDto feeDto = new FeeDto(); |
| | | feeDto.setCommunityId(reqJson.getString("communityId")); |
| | | feeDto.setFeeId(feeAttrDtos.get(0).getFeeId()); |
| | |
| | | RepairUserDto repairUserDto = new RepairUserDto(); |
| | | repairUserDto.setRepairId(reqJson.getString("repairId")); |
| | | repairUserDto.setCommunityId(reqJson.getString("communityId")); |
| | | repairUserDto.setState(RepairUserDto.STATE_DOING); |
| | | //todo 这里考虑带评价 |
| | | repairUserDto.setStates(new String[]{RepairUserDto.STATE_DOING,RepairUserDto.STATE_EVALUATE}); |
| | | repairUserDto.setStaffId(reqJson.getString("userId")); |
| | | List<RepairUserDto> repairUserDtos = repairUserInnerServiceSMOImpl.queryRepairUsers(repairUserDto); |
| | | if (repairUserDtos != null && repairUserDtos.size() != 1) { |
| | | if (!ListUtil.isNull(repairUserDtos)) { |
| | | ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_BUSINESS_VERIFICATION, "当前用户没有需要处理订单!"); |
| | | context.setResponseEntity(responseEntity); |
| | | return; |
| | | } |
| | | // String ruId = repairUserDtos.get(0).getRuId(); |
| | | // RepairUserPo repairUserPo = new RepairUserPo(); |
| | | // repairUserPo.setRuId(repairUserDtos.get(0).getRuId()); |
| | | // repairUserPo.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); |
| | | // repairUserPo.setState(RepairUserDto.STATE_BACK); |
| | | // repairUserPo.setContext(reqJson.getString("context")); |
| | | // repairUserInnerServiceSMOImpl.updateRepairUser(repairUserPo); |
| | | //处理人信息 |
| | | // repairUserPo = new RepairUserPo(); |
| | | // repairUserPo.setRuId("-1"); |
| | | // repairUserPo.setState(RepairUserDto.STATE_DOING); |
| | | // repairUserPo.setRepairId(reqJson.getString("repairId")); |
| | | // repairUserPo.setStaffId(reqJson.getString("staffId")); |
| | | // repairUserPo.setStaffName(reqJson.getString("staffName")); |
| | | RepairUserDto repair = new RepairUserDto(); |
| | | repair.setRepairId(reqJson.getString("repairId")); |
| | | repair.setStaffId(reqJson.getString("staffId")); |
| | | repair.setCommunityId(reqJson.getString("communityId")); |
| | | // repair.setRuId(repairUserDtos.get(0).getPreRuId()); |
| | | repair.setStates(new String[]{RepairUserDto.STATE_TRANSFER, RepairUserDto.STATE_CLOSE, RepairUserDto.STATE_STOP}); //转单、结单、暂停 |
| | | repair.setStates(new String[]{RepairUserDto.STATE_TRANSFER, RepairUserDto.STATE_CLOSE, RepairUserDto.STATE_STOP,RepairUserDto.STATE_EVALUATE}); |
| | | List<RepairUserDto> repairUsers = repairUserInnerServiceSMOImpl.queryRepairUsers(repair); |
| | | if (repairUsers == null || repairUsers.size() < 1) { //指派的不能退单 |
| | | if (ListUtil.isNull(repairUsers)) { //指派的不能退单 |
| | | if (RepairDto.REPAIR_WAY_GRABBING.equals(repairDtos.get(0).getRepairWay()) |
| | | || RepairDto.REPAIR_WAY_TRAINING.equals(repairDtos.get(0).getRepairWay())) { //抢单、轮训 |
| | | modifyBusinessRepairDispatch(reqJson, RepairDto.STATE_WAIT);//维修单变成未派单 |