Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit
| | |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage()); |
| | | } |
| | | |
| | | if(Objects.nonNull(bookings.getId())){ |
| | | return; |
| | | } |
| | | |
| | | SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | SimpleDateFormat format1 = new SimpleDateFormat("yyyy-MM-dd"); |
| | | String gsDate = format1.format(bookings.getStartTime()); |
| | |
| | | if(dbBookings.getStatus().equals(MeetConstants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "æ¬æ¬¡æä½å¤±è´¥,é¢çº¦ç¶æå·²æµè½¬"); |
| | | } |
| | | Rooms rooms = roomsMapper.selectById(dbBookings.getRoomId()); |
| | | if(rooms==null ){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对ä¸èµ·ï¼è¯¥ä¼è®®å®¤ææ¶æ æ³é¢çº¦"); |
| | | } |
| | | bookings.setRoomName(rooms.getName()); |
| | | LoginUserInfo user = bookings.getLoginUserInfo(); |
| | | isCreateParamValid(bookings, user); |
| | | bookings.setEditDate(new Date()); |
| | | bookings.setEditor(user.getId()); |
| | | bookingsMapper.updateById(bookings); |
| | | bookings.setManagerInfo(user.getRealname()); |
| | | bookings.setCreator(dbBookings.getCreator()); |
| | | //æ´æ°ä¼è®®å®¤é¢å®æ¶é´æ®µ |
| | | updateBookingTimes(bookings, user); |
| | | //æ·»å 管ç人å |
| | |
| | | //åéä¼è®®éç¥ |
| | | if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){ |
| | | this.sendNotice(bookings, MeetConstants.TWO); |
| | | SystemUser systemUser = systemUserMapper.selectById(bookings.getUserId()); |
| | | SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator()); |
| | | this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ZERO); |
| | | } |
| | | } |
| | |
| | | } |
| | | bookingsMapper.updateById(bookings); |
| | | //åæ¶ä¼è®® åéåæ¶éç¥ |
| | | // if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){ |
| | | if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){ |
| | | // this.sendNotice(bookings, 3); |
| | | // } |
| | | SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator()); |
| | | bookings.setManagerInfo(systemUser.getRealname()); |
| | | this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ONE); |
| | | |
| | | } |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | } |
| | | } |
| | | //ç»å建人åéçä¿¡ä¿¡æ¯ |
| | | SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator()); |
| | | if(Objects.nonNull(systemUser)){ |
| | | if(userRelList.stream().filter(i->Constants.equalsInteger(i.getUserId(),systemUser.getId())).collect(Collectors.toList()).size()==Constants.ZERO){ |
| | | if (smsConfig!=null && Constants.equalsInteger(smsConfig.getStatus(),Constants.ZERO)){ |
| | | SmsEmail smsEmail = new SmsEmail(); |
| | | //{åä¼äººåå§å}ï¼æ¨å¥½ï¼æ¨æä¸ä¸ªæ°çä¼è®®ï¼ä¼è®®ä¸»é¢ï¼{ä¼è®®ä¸»é¢}ï¼ä¼è®®å°ç¹ï¼{ä¼è®®å®¤åç§°}ï¼ä¼è®®æ¶é´ï¼{ä¼è®®æ¶é´æ®µ}ï¼è¯·ææ¶åå |
| | | String timeInfo =DateUtil.getFomartDate( bookings.getStartTime(),"MM/dd HH:mm")+"-" |
| | | +DateUtil.getFomartDate( bookings.getEndTime(),"HH:mm"); |
| | | smsEmail.setPhone(systemUser.getMobile()); |
| | | smsEmail.setRemark("çå¾
åé"); |
| | | smsEmail.setStatus(Constants.TWO);// |
| | | smsEmail.setIsdeleted(Constants.ZERO); |
| | | smsEmail.setType(Constants.ZERO); |
| | | smsEmail.setObjId(bookings.getId()); |
| | | smsEmail.setCreateDate(new Date()); |
| | | smsEmail.setTitle("ä¼è®®å®¤ç³è¯·åä¼éç¥"); |
| | | smsEmail.setContent(StringUtils.defaultString(smsConfig.getContent(),"") |
| | | .replace("{åä¼äººåå§å}",StringUtils.defaultString(systemUser.getRealname(),"")) |
| | | .replace("{ä¼è®®ä¸»é¢}",StringUtils.defaultString(bookings.getName(),"")) |
| | | .replace("{ä¼è®®å®¤åç§°}",StringUtils.defaultString(bookings.getRoomName(),"")) |
| | | .replace("{ä¼è®®æ¶é´æ®µ}",StringUtils.defaultString(timeInfo,""))); |
| | | smsEmailList.add(smsEmail); |
| | | } |
| | | } |
| | | } |
| | | //ç»åä¼äººåæå
¥ |
| | | Notices notices = new Notices(noticeObjectType,bookings.getId(),noticeObjectType.getInfo(),bookings.getCreator(), Constants.ZERO); |
| | | noticeList.add(notices); |
| | |
| | | queryDto.setDeleted(Boolean.FALSE); |
| | | SystemDict dictData = systemDictService.findOne(queryDto); |
| | | if (dictData == null) { |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "æ°æ®å¼ä¸åå¨"); |
| | | return new SystemDictData(); |
| | | // throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "æ°æ®å¼ä¸åå¨"); |
| | | } |
| | | SystemDictData data = new SystemDictData(); |
| | | data.setDictId(dictData.getId()); |
| | |
| | | @Autowired |
| | | private RedisTemplate<String,Object> redisTemplate; |
| | | @Autowired |
| | | private JwtProperties jwtProperties; |
| | | @Autowired |
| | | private SystemUserService systemUserService; |
| | | @Autowired |
| | | private JwtProperties jwtProperties; |
| | | |
| | | @Autowired |
| | | private SystemUserRoleService systemUserRoleService; |
| | |
| | | return ApiResponse.success(result); |
| | | } |
| | | @PreventRepeat |
| | | @ApiOperation("ãæµ·åº·ãä¿ææµ·åº·ç¨æ·ç»å®openid") |
| | | @ApiOperation("ãæµ·åº·ãä¿åæµ·åº·ç¨æ·ç»å®openid") |
| | | @PostMapping("/saveHkUserOpenid") |
| | | public ApiResponse syncHkUserOpenid( @RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | | String result = hkSyncOrgUserToHKService.syncHkUserOpenid(this.getLoginUser(token).getId()); |
| | | return ApiResponse.success(result); |
| | | } |
| | | @PreventRepeat |
| | | @ApiOperation("ãæµ·åº·ãæ¸
ç©ºæµ·åº·ç¨æ·ç»å®openid") |
| | | @PostMapping("/delHkUserOpenid") |
| | | @LoginNoRequired |
| | | public ApiResponse delHkUserOpenid( @RequestBody UserOpenidSaveRequest param){ |
| | | String result = hkSyncOrgUserToHKService.delHkUserOpenid(param); |
| | | return ApiResponse.success(result); |
| | | } |
| | | @PreventRepeat |
| | | @ApiOperation("ãæµ·åº·ãè·åç»ä»¶ææç»å½å°åæ¥å£") |
| | | @PostMapping("/getServiceUrl") |
| | | public ApiResponse getServiceUrl(@RequestBody HKGetServiceLoginUrlRequest param,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){ |
| | |
| | | import com.doumee.dao.web.response.platformReport.*; |
| | | import io.swagger.annotations.*; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | | import org.springframework.web.bind.annotation.RequestParam; |
| | |
| | | String[] fireMonitorData= new String[]{"/api/v2/monitor/fireMonitorData","å页æ¥è¯¢è®¾å¤çæµå岿°æ®"};//å页æ¥è¯¢è®¾å¤çæµå岿°æ® |
| | | |
| | | String[] userOpenidSave= new String[]{"/api/v1/oa/userOpenId/saveV2","ä¿åç¨æ·åopenIdç»å®ä¿¡æ¯å¾®ä¿¡å
¬ä¼å·"};//ä¿åç¨æ·åopenIdç»å®ä¿¡æ¯å¾®ä¿¡å
¬ä¼å· |
| | | String[] userOpenidDel= new String[]{"/api/v1/oa/userOpenId/delete","éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯"};//éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯ |
| | | String[] temperatureHumidityDataStatistic= new String[]{"/api/v2/public/monitor/sensor/list","æ¶é²çæ¿-4温湿度ç»è®¡"};//æ¶é²çæ¿-温湿度 |
| | | String[] regionDataRanking= new String[]{"/api/ecm/v1/energy/regionDataRanking","æ¶é²çæ¿-4è·ååºåç¨éæå-è½èçæ¿"};//æ¶é²çæ¿-è·ååºåç¨éæå - è½èçæ¿ |
| | | String[] energyTotal= new String[]{"/api/ecm/v1/energy/energyTotal","æ¶é²çæ¿-4æ ¹æ®æ¶é´åæ¶é´ç»´åº¦è·åååºè½èæ°æ®"};//æ¶é²çæ¿-æ ¹æ®æ¶é´åæ¶é´ç»´åº¦è·åååºè½èæ°æ® |
| | |
| | | saveInterfaceLog(JSONObject.toJSONString(body),result,path,pathStr[1]); |
| | | return result; |
| | | } |
| | | public static String startDoGetStringArtemis(String[] pathStr,Map<String,String> querys ,Map<String, String> header ){ |
| | | Map<String, String> path = getPath(pathStr[0]); |
| | | String result = ArtemisHttpUtil.doGetArtemis(path, querys, null, null, header); |
| | | saveInterfaceLog(JSONObject.toJSONString(querys),result,path,pathStr[1]); |
| | | return result; |
| | | } |
| | | public static String startDoGetStringArtemisJson(String[] pathStr,Map<String,String> body ){ |
| | | Map<String, String> path = getPath(pathStr[0]); |
| | | Map<String, String> header = new HashMap<>(); |
| | |
| | | return startDoPostStringArtemis(HKConstants.InterfacePath.userOpenidSave,null,header,body); |
| | | } |
| | | /** |
| | | *éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯ |
| | | * @param param |
| | | * @return |
| | | */ |
| | | public static String userOpenidDel(Map<String,String> param) { |
| | | Map<String,String> header = new HashMap<>(); |
| | | header.put("userId","admin"); |
| | | return startDoGetStringArtemis(HKConstants.InterfacePath.userOpenidDel,param,header); |
| | | } |
| | | /** |
| | | *å页æ¥è¯¢è®¾å¤çæµå岿°æ® |
| | | * @param body |
| | | * @return |
| | |
| | | private String oaId;// String false atwl |
| | | private String platformName ;//String false 宿³°ç©æµååº |
| | | private String operateTime ;//String false 2024-12-09T15:49:04-07:00 |
| | | |
| | | |
| | | } |
| | |
| | | return null; |
| | | } |
| | | /** |
| | | *éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯ |
| | | * @return |
| | | */ |
| | | public static BaseResponse userOpenidDel(UserOpenidSaveRequest param){ |
| | | log.info("ãæµ·åº·éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯ã================å¼å§===="+JSONObject.toJSONString(param)); |
| | | try { |
| | | String res = HKTools.userOpenidDel(toMap(param)); |
| | | TypeReference typeReference = |
| | | new TypeReference< BaseResponse >(){}; |
| | | BaseResponse<Integer> result = JSONObject.parseObject(res, typeReference.getType()); |
| | | logResult(result,"海康éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯"); |
| | | return result; |
| | | }catch (Exception e){ |
| | | log.error("ãæµ·åº·éè¿openIdæuserNameçå é¤ç»å®ä¿¡æ¯ã================失败====ï¼\n"+ e.getMessage()); |
| | | } |
| | | return null; |
| | | } |
| | | /** |
| | | *å页æ¥è¯¢è®¾å¤çæµå岿°æ® |
| | | * @return |
| | | */ |
| | |
| | | String[] getInboundOutbound = new String[]{"/tms/zhyt/getInboundOutbound", "ãTMSãåºå
¥åºè®°å½æ¥è¯¢"};//TMSåºå
¥åºè®°å½æ¥è¯¢æ¥å£å°å |
| | | String[] getIntransitDetails = new String[]{"/tms/zhyt/getIntransitDetails", "ãTMSãå¨éæç»å表"};//TMSå¨éæç»å表æ¥å£å°å |
| | | String[] getOrderList = new String[]{"/tms/zhyt/getOrderList", "ãTMSãååå表æ¥è¯¢"};//TMSååå表æ¥è¯¢æ¥å£å°å |
| | | String[] getTotalAndReportVehicleQty = new String[]{"/tms/zhyt/getTotalAndReportVehicleQty", "ãTMSãæ¥è¯¢5个åçè¿åèµæºå©ç¨æ
åµã"};//æ¥è¯¢5个åçè¿åèµæºå©ç¨æ
åµã |
| | | String[] getElecByContractNumberList = new String[]{"/tms/zhyt/getElecByContractNumberList", "ãTMSãååä¸éç¶æ"};//TMSååä¸éç¶ææ¥å£å°å |
| | | String[] getOrderDetailByContractNumber = new String[]{"/tms/zhyt/getOrderDetailByContractNumber", "ãTMSãåå详æ
"};//TMSåå详æ
æ¥å£å°å |
| | | String[] getGis = new String[]{"/tms/zhyt/getGis", "ãTMSãæ ¹æ®è¿è¾åå·æ¥è¯¢gis轨"};//TMSæ ¹æ®è¿è¾åå·æ¥è¯¢gis轨æ¥å£å°å |
| | | String[] getOrderStatusByContractNumber = new String[]{"/tms/zhyt/getOrderStatusByContractNumber", "ãTMSãåçå½å¨æ"};//3.8订åçå½å¨æ |
| | | String[] getOutQtyAndVehicleQty = new String[]{"/tms/zhyt/getOutQtyAndVehicleQty", "ãTMSãæå®æ¶é´èå´å
累计åºåºé"};//3.8æå®æ¶é´èå´å
累计åºåºé |
| | | } |
| | | |
| | | public enum TopStatusLevel { |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.request; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsçåéå请æ±åæ°") |
| | | public class TmsFacrotyCodeListRequest { |
| | | |
| | | private List<String> facrotyCodeList;//æ¯ éå çåéå |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.request; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæå®æ¶é´èå´å
累计åºåºé请æ±åæ°") |
| | | public class TmsOutQtyAndVehicleQtyRequest { |
| | | private String dateStart;// å符串 å¼å§æ¥æ 2024-12-19 |
| | | private String dateEnd ;// å符串 ç»ææ¥æ 2024-12-19 |
| | | private List<String> facrotyCodeList;//æ¯ éå çåéå |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.math.BigDecimal; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmså
¨å½å°è´§å°å叿¥è¯¢è¿ååæ°") |
| | | public class TmsDistributionOfDeliveryLocResponse { |
| | | |
| | | @ApiModelProperty(value = "å°è´§å°ç份åç§°" ) |
| | | private String toProvinceName; // å符串 //å°è´§å°ç份åç§° |
| | | @ApiModelProperty(value = "å°è´§å°çä»½è¡æ¿ç¼ç " ) |
| | | private String toProvinceCode ; //å符串 å°è´§å°çä»½è¡æ¿ç¼ç |
| | | @ApiModelProperty(value = "åºè´§å°ç份åç§°" ) |
| | | private String fromProvinceName; // å符串 åºè´§å°ç份åç§° |
| | | @ApiModelProperty(value = "åºè´§å°çä»½è¡æ¿ç¼ç " ) |
| | | private String fromProvinceCode; // å符串 åºè´§å°çä»½è¡æ¿ç¼ç |
| | | @ApiModelProperty(value = "æ¬å¹´ç´¯è®¡åå¾å°è´§å°çåºåºé" ) |
| | | private BigDecimal yearOutboundQuantity; // æ°å æ¬å¹´ç´¯è®¡åå¾å°è´§å°çåºåºé |
| | | @ApiModelProperty(value = "æ¬æç´¯è®¡åæ¾å°è´§å°çåºåºé" ) |
| | | private BigDecimal monthOutboundQuantity; //æ°å æ¬æç´¯è®¡åæ¾å°è´§å°çåºåºé |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.math.BigDecimal; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tms宿¶åºåæ¥è¯¢è¿ååæ°") |
| | | public class TmsInventoryListResponse { |
| | | |
| | | @ApiModelProperty(value = "ç¼ç " ) |
| | | private String id; // å符串 |
| | | @ApiModelProperty(value = "åè§ç¼ç " ) |
| | | private String brandCode; // å符串 åè§ç¼ç |
| | | @ApiModelProperty(value = "åè§åç§°" ) |
| | | private String productName; // å符串 åè§åç§° |
| | | @ApiModelProperty(value = "å·¥åç¼å·" ) |
| | | private String factoryCode ; // å符串 å·¥åç¼å· |
| | | @ApiModelProperty(value = "ä»åºç¼å·" ) |
| | | private String repertotyCode ; // å符串 ä»åºç¼å· |
| | | @ApiModelProperty(value = "åºåç»ç»ç¼ç " ) |
| | | private String productAreaCode ; // å符串 åºåç»ç»ç¼ç |
| | | @ApiModelProperty(value = "åºåç»ç»åç§°" ) |
| | | private String productAreaName ; // å符串 åºåç»ç»åç§° |
| | | @ApiModelProperty(value = "åºåæ è¯" ) |
| | | private String inventoryId ; // å符串 åºåæ è¯ |
| | | @ApiModelProperty(value = "çååç§°,产å°" ) |
| | | private String factoryName ; // å符串 çååç§°,äº§å° |
| | | @ApiModelProperty(value = "æå¨ä»åºåç§°" ) |
| | | private String repertoryName ; // å符串 æå¨ä»åºåç§° |
| | | @ApiModelProperty(value = "åºåæ°é" ) |
| | | private BigDecimal stockQty ; // å符串 åºåæ°é |
| | | @ApiModelProperty(value = "çåç¼ç " ) |
| | | private String versionCode; // å符串 çåç¼ç |
| | | @ApiModelProperty(value = "çååç§°" ) |
| | | private String versionName ; // å符串 çååç§° |
| | | @ApiModelProperty(value = "ç®±å" ) |
| | | private String vbatchCode ; // å符串 ç®±å |
| | | @ApiModelProperty(value = "åè§åç§°" ) |
| | | private String proName ; // å符串 åè§åç§° |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | import org.apache.commons.math3.fraction.BigFraction; |
| | | |
| | | import java.math.BigDecimal; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæå®æ¶é´èå´å
累计åºåºéè¿ååæ°") |
| | | public class TmsOutQtyAndVehicleQtyResponse { |
| | | |
| | | @ApiModelProperty(value = "累计åºåºé") |
| | | private BigDecimal totalOutQty;//æ°å 累计åºåºé |
| | | @ApiModelProperty(value = "çå¤ç´¯è®¡åºåºé") |
| | | private String outSideProvinceOutQty;// æ°å çå¤ç´¯è®¡åºåºé |
| | | @ApiModelProperty(value = "çå
累计åºåºé") |
| | | private String inSideProvinceOutQty;// æ°å çå
累计åºåºé |
| | | @ApiModelProperty(value = "累计åºåºè½¦æ¬¡") |
| | | private BigDecimal vehicleQty;//æ°å 累计åºåºè½¦æ¬¡ |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.math.BigDecimal; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsè¿åèµæºå©ç¨çè¿ååæ°") |
| | | public class TmsTotalAndReportVehicleQtyResponse { |
| | | |
| | | @ApiModelProperty(value = "å·¥åç¼ç " ) |
| | | private String factoryCode;// å符串 å·¥åç¼ç |
| | | @ApiModelProperty(value = "å·¥ååç§°" ) |
| | | private String factoryName;// å符串 å·¥ååç§° |
| | | @ApiModelProperty(value = "ææ¥è¿åæ°" ) |
| | | private String reportQty;// æ°å ææ¥è¿åæ° |
| | | @ApiModelProperty(value = "æ»è¿åæ°" ) |
| | | private String totalQty;// æ°å æ»è¿åæ° |
| | | } |
| | |
| | | paramMap.put("touser", openId); |
| | | paramMap.put("data", dataMap); |
| | | String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap)); |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯ï¼{}", JSONObject.toJSONString(paramMap)); |
| | | if(StringUtils.isBlank(response)){ |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯ï¼{}·--++==·", "失败"); |
| | | }else{ |
| | |
| | | @ApiModelProperty(value = "ç³è¯·äººçµè¯") |
| | | @TableField(exist = false) |
| | | private String memberMobile; |
| | | @ApiModelProperty(value = "éç¥æè¿°") |
| | | @TableField(exist = false) |
| | | private String info; |
| | | @ApiModelProperty(value = "审æ¹ä¿¡æ¯æ°æ®") |
| | | @TableField(exist = false) |
| | | private ApproveDataVO approveDateVO; |
| | |
| | | @ExcelColumn(name="å
¥ååå ",index = 1,width = 12) |
| | | private String inReason; |
| | | |
| | | |
| | | |
| | | @ApiModelProperty(value = "å
¥ååå 主é®") |
| | | private Integer reasonId; |
| | | |
| | |
| | | @TableField(exist = false) |
| | | private String auditTime; |
| | | |
| | | @ApiModelProperty(value = "éç¥æè¿°") |
| | | @TableField(exist = false) |
| | | private String info; |
| | | |
| | | |
| | | @ApiModelProperty(value = "审æ¹ä¿¡æ¯æ°æ®") |
| | | @TableField(exist = false) |
| | | private ApproveDataVO approveDateVO; |
| | |
| | | @TableField(exist = false) |
| | | private LoginUserInfo loginUserInfo; |
| | | |
| | | @ApiModelProperty(value = "éç¥æè¿°") |
| | | @TableField(exist = false) |
| | | private String info; |
| | | |
| | | @ApiModelProperty(value = "审æ¹ä¿¡æ¯æ°æ®") |
| | | @TableField(exist = false) |
| | | private ApproveDataVO approveDateVO; |
| | |
| | | String dealPlatformCarsEvent(EventPlatformCarsRequest param, HttpServletResponse response); |
| | | |
| | | String syncHkUserOpenid(Integer id); |
| | | String delHkUserOpenid(UserOpenidSaveRequest param); |
| | | } |
| | |
| | | approveList.add(approve); |
| | | } |
| | | model.setApproveDateVO(approveDataVO); |
| | | |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda() |
| | | .eq(Notices::getObjId,id) |
| | | .eq(Notices::getType,Constants.noticesObjectType.useCar) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .orderByDesc(Notices::getId).last(" limit 1 ")); |
| | | if(Objects.nonNull(notices)){ |
| | | if(Constants.equalsInteger(notices.getStatus(),Constants.ZERO)){ |
| | | model.setInfo("å¾
æå¤ç"); |
| | | }else{ |
| | | model.setInfo(notices.getInfo()); |
| | | } |
| | | } |
| | | |
| | | |
| | | return model; |
| | | } |
| | | |
| | |
| | | |
| | | import com.doumee.dao.system.SystemUserMapper; |
| | | import com.doumee.dao.system.join.NoticesJoinMapper; |
| | | import com.doumee.dao.system.model.Notices; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.dao.web.reqeust.PlatformBooksApplyDTO; |
| | | import com.doumee.dao.web.reqeust.PlatformBooksCheckNumDTO; |
| | |
| | | approve.setCheckDate(model.getCancelTime()); |
| | | approveList.add(approve); |
| | | } |
| | | |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda() |
| | | .eq(Notices::getObjId,id) |
| | | .eq(Notices::getType,Constants.noticesObjectType.reason) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .orderByDesc(Notices::getId).last(" limit 1 ")); |
| | | if(Objects.nonNull(notices)){ |
| | | if(Constants.equalsInteger(notices.getStatus(),Constants.ZERO)){ |
| | | model.setInfo("å¾
æå¤ç"); |
| | | }else{ |
| | | model.setInfo(notices.getInfo()); |
| | | } |
| | | } |
| | | return model; |
| | | } |
| | | |
| | |
| | | result.setBusinessStatus(result.getStatus()); |
| | | } |
| | | |
| | | |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda() |
| | | .eq(Notices::getObjId,id) |
| | | .eq(Notices::getType,Constants.equalsInteger(result.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .orderByDesc(Notices::getId).last(" limit 1 ")); |
| | | if(Objects.nonNull(notices)){ |
| | | if(Constants.equalsInteger(notices.getStatus(),Constants.ZERO)){ |
| | | result.setInfo("å¾
æå¤ç"); |
| | | }else{ |
| | | result.setInfo(notices.getInfo()); |
| | | } |
| | | } |
| | | |
| | | |
| | | return result; |
| | | } |
| | | |
| | |
| | | memberId) |
| | | ); |
| | | // } |
| | | if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)||Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck)){ |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda().eq(Notices::getObjId,visits.getId()) |
| | | |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda() |
| | | .eq(Notices::getObjId,id) |
| | | .eq(Notices::getType,Constants.equalsInteger(visits.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .last(" limit 1 ") |
| | | ); |
| | | visitDetailVO.setInfoStatus(1); |
| | | .orderByDesc(Notices::getId).last(" limit 1 ")); |
| | | if(Objects.nonNull(notices)){ |
| | | if(Constants.equalsInteger(notices.getStatus(),Constants.ZERO)){ |
| | | visitDetailVO.setInfo("å¾
æå¤ç"); |
| | | }else{ |
| | | visitDetailVO.setInfo(notices.getInfo()); |
| | | }else{ |
| | | visitDetailVO.setInfo("ææ "); |
| | | } |
| | | }else if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.noPass)){ |
| | | visitDetailVO.setInfoStatus(Constants.VisitStatus.noPass); |
| | | visitDetailVO.setInfo("å®¡æ¹æªéè¿"); |
| | | } |
| | | |
| | | }else if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.cancel)){ |
| | | visitDetailVO.setInfoStatus(Constants.VisitStatus.cancel); |
| | | visitDetailVO.setInfo("已忶"); |
| | | }else{ |
| | | visitDetailVO.setInfoStatus(Constants.VisitStatus.pass); |
| | | visitDetailVO.setInfo("审æ¹å·²éè¿"); |
| | | } |
| | | return visitDetailVO; |
| | | } |
| | | |
| | |
| | | return null; |
| | | } |
| | | @Override |
| | | public String delHkUserOpenid(UserOpenidSaveRequest param){ |
| | | return null; |
| | | } |
| | | @Override |
| | | public String dealAcsEvent(EventAcsRequest param, HttpServletResponse response){ |
| | | return null; |
| | | } |
| | |
| | | systemUserMapper.updateById(user); |
| | | return "æå"; |
| | | } |
| | | @Override |
| | | public String delHkUserOpenid(UserOpenidSaveRequest param){ |
| | | UserOpenidSaveRequest request = new UserOpenidSaveRequest(); |
| | | request.setUserName(param.getUserName()); |
| | | request.setAppKey(systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_APPID).getCode()); |
| | | BaseResponse response = HKService.userOpenidDel(request); |
| | | if(response!=null &&response.getCode().equals(HKConstants.RESPONSE_SUCCEE)){ |
| | | } |
| | | request.setUserName(null); |
| | | request.setOpenId(param.getOpenId()); |
| | | request.setAppKey(systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_APPID).getCode()); |
| | | response = HKService.userOpenidDel(request); |
| | | if(response!=null &&response.getCode().equals(HKConstants.RESPONSE_SUCCEE)){ |
| | | } |
| | | return "æå"; |
| | | } |
| | | |
| | | /** |
| | | * åæ¥æµ·åº·ç»ç»ä¿¡æ¯,æ ¹æ®erp忥ç»ç»ç»æï¼å®æ¶æ£æ¥éè¦ä¸åå°æµ·åº·çç»ç»ä¿¡æ¯ |
| | |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.fastjson.TypeReference; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.core.tms.model.TMSContants; |
| | | import com.doumee.core.tms.model.request.*; |
| | |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.DateUtil; |
| | | import com.doumee.core.utils.HttpsUtil; |
| | | import com.doumee.core.wms.model.request.*; |
| | | import com.doumee.core.wms.model.response.WmsBaseDataResponse; |
| | | import com.doumee.core.wms.model.response.WmsBaseResponse; |
| | | import com.doumee.core.wms.model.response.WmsInventoryDataResponse; |
| | | import com.doumee.dao.business.*; |
| | | import com.doumee.dao.business.dao.SmsEmailMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.service.business.impl.SmsEmailServiceImpl; |
| | | import com.doumee.service.business.third.TmsService; |
| | | import com.doumee.service.business.third.WmsService; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import io.swagger.models.auth.In; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.*; |
| | | |
| | |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getOrderDetailByContractNumber[0]; |
| | | TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderDetailByContractNumber[1],param.getContractNumber() |
| | | TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderDetailByContractNumber[1] |
| | | ,param.getContractNumber() |
| | | ,new TypeReference< TmsBaseResponse<TmsOrderInfoResponse>>(){}); |
| | | if(response!=null && response.getData()!=null){ |
| | | result =response.getData(); |
| | |
| | | result.setCicleStatusList(getCicleStatusList(p1)); |
| | | return result; |
| | | } |
| | | /** |
| | | * å
¨å½å°è´§å°å叿¥è¯¢æ¥è¯¢ |
| | | * @param param åæ° |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public List<TmsDistributionOfDeliveryLocResponse> getDistributionOfDeliveryLocations(TmsFacrotyCodeListRequest param){ |
| | | List<TmsDistributionOfDeliveryLocResponse> result = new ArrayList<>(); |
| | | if( param.getFacrotyCodeList() == null || param.getFacrotyCodeList().size() == 0){ |
| | | param.setFacrotyCodeList(new ArrayList<>()); |
| | | param.getFacrotyCodeList().add("0"); |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getDistributionOfDeliveryLocations[0]; |
| | | TmsBaseResponse< List<TmsDistributionOfDeliveryLocResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getDistributionOfDeliveryLocations[1], |
| | | JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse< List<TmsDistributionOfDeliveryLocResponse>>>(){}); |
| | | if(response!=null && response.getData()!=null){ |
| | | result =response.getData(); |
| | | } |
| | | |
| | | return result; |
| | | } |
| | | /** |
| | | * 宿¶åºåæ¥è¯¢ |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public List<TmsInventoryListResponse> getRealTimeInventory( ){ |
| | | List<TmsInventoryListResponse> result = new ArrayList<>(); |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getRealTimeInventory[0]; |
| | | TmsBaseResponse< List<TmsInventoryListResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getRealTimeInventory[1] |
| | | ,"{}" |
| | | ,new TypeReference< TmsBaseResponse< List<TmsInventoryListResponse>>>(){}); |
| | | if(response!=null && response.getData()!=null){ |
| | | result =response.getData(); |
| | | } |
| | | |
| | | return result; |
| | | } |
| | | /** |
| | | * æ¥è¯¢5个åçè¿åèµæºå©ç¨æ
åµ |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public List<TmsTotalAndReportVehicleQtyResponse> getTotalAndReportVehicleQty( ){ |
| | | List<TmsTotalAndReportVehicleQtyResponse> result = new ArrayList<>(); |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getTotalAndReportVehicleQty[0]; |
| | | TmsBaseResponse< List<TmsTotalAndReportVehicleQtyResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getTotalAndReportVehicleQty[1] |
| | | ,"{}" |
| | | ,new TypeReference< TmsBaseResponse< List<TmsTotalAndReportVehicleQtyResponse>>>(){}); |
| | | if(response!=null && response.getData()!=null){ |
| | | result =response.getData(); |
| | | } |
| | | |
| | | return result; |
| | | } |
| | | /** |
| | | * æå®æ¶é´èå´å
累计åºåºé |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public List<TmsOutQtyAndVehicleQtyResponse> getOutQtyAndVehicleQty(TmsOutQtyAndVehicleQtyRequest param ){ |
| | | List<TmsOutQtyAndVehicleQtyResponse> result = new ArrayList<>(); |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getOutQtyAndVehicleQty[0]; |
| | | TmsBaseResponse< List<TmsOutQtyAndVehicleQtyResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getOutQtyAndVehicleQty[1] |
| | | ,JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse< List<TmsOutQtyAndVehicleQtyResponse>>>(){}); |
| | | if(response!=null && response.getData()!=null){ |
| | | result =response.getData(); |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | /** |
| | | * åèµ· tmsæ¥å£è¯·æ± |
| | |
| | | return returnFailReuslt("请æ±åæ°ä¸æ£ç¡®ï¼åæ°ä¸è½ä¸ºç©º"); |
| | | } |
| | | List<PlatformJob> jobList = new ArrayList<>(); |
| | | List<Integer> jobIdList = new ArrayList<>(); |
| | | List<PlatformWmsDetail> details = new ArrayList<>(); |
| | | List<String> iocodeList = new ArrayList<>(); |
| | | for(WmsInboundNoticeRequest param : list.getData()){ |
| | |
| | | platformWmsJobMapper.insert(job); |
| | | jobList.add(model); |
| | | } |
| | | jobIdList.add(job.getId()); |
| | | if(param.getDetails()!=null && param.getDetails().size()>0){ |
| | | for(WmsInboundDetailRequest d :param.getDetails()){ |
| | | PlatformWmsDetail entity = new PlatformWmsDetail(); |
| | |
| | | platformWmsDetailMapper.insert(details); |
| | | } |
| | | if(jobList.size()>0){ |
| | | list.setJobIdList(jobIdList); |
| | | startEndNoticeToDriver(jobList); |
| | | } |
| | | }catch (Exception e){ |
| | |
| | | |
| | | import com.doumee.core.tms.model.request.*; |
| | | import com.doumee.core.tms.model.response.*; |
| | | import com.doumee.core.wms.model.request.WmsActionNoticeRequest; |
| | | import com.doumee.core.wms.model.request.WmsBaseRequest; |
| | | import com.doumee.core.wms.model.request.WmsInboundNoticeRequest; |
| | | import com.doumee.core.wms.model.request.WmsOutboundNoticeRequest; |
| | | import com.doumee.core.wms.model.response.WmsBaseResponse; |
| | | import com.doumee.dao.business.model.PlatformJob; |
| | | |
| | | import java.util.List; |
| | | |
| | |
| | | TmsOrderInfoResponse orderInfo(TmsOrderInfoRequest param); |
| | | void saveInterfaceLog(String url,String name,String param,Integer success,String respone,int type); |
| | | |
| | | /** |
| | | * å
¨å½å°è´§å°å叿¥è¯¢æ¥è¯¢ |
| | | * @param param åæ° |
| | | * @return TmsBaseResponse |
| | | */ |
| | | List<TmsDistributionOfDeliveryLocResponse> getDistributionOfDeliveryLocations(TmsFacrotyCodeListRequest param); |
| | | |
| | | /** |
| | | * 宿¶ååºæ¥è¯¢ |
| | | * @return |
| | | */ |
| | | List<TmsInventoryListResponse> getRealTimeInventory( ); |
| | | /** |
| | | * æ¥è¯¢5个åçè¿åèµæºå©ç¨æ
åµ |
| | | * @return TmsBaseResponse |
| | | */ |
| | | List<TmsTotalAndReportVehicleQtyResponse> getTotalAndReportVehicleQty( ); |
| | | |
| | | /** |
| | | * æå®æ¶é´èå´å
累计åºåºé |
| | | * @param param |
| | | * @return |
| | | */ |
| | | |
| | | List<TmsOutQtyAndVehicleQtyResponse> getOutQtyAndVehicleQty(TmsOutQtyAndVehicleQtyRequest param ); |
| | | } |