Просмотр исходного кода

Merge remote-tracking branch 'origin/master'

master
qiubh 2 месяцев назад
Родитель
Сommit
812da24bfa

+ 1
- 2
gly-base-core/src/main/java/cn/com/taiji/core/entity/msgw/MsgwAlarmConfig.java Просмотреть файл

@Size(max = 100) @Size(max = 100)
@Column(name = "MESSAGE_CLIENT_ID") @Column(name = "MESSAGE_CLIENT_ID")
private String messageClientId;//消息客户端id private String messageClientId;//消息客户端id
@NotBlank
@Size(max = 100)
@NotNull
@Column(name = "MESSAGE_TYPE") @Column(name = "MESSAGE_TYPE")
@Enumerated(EnumType.STRING) @Enumerated(EnumType.STRING)
private MessageType messageType;//发送客户端类型 private MessageType messageType;//发送客户端类型

+ 0
- 1
gly-base-core/src/main/java/cn/com/taiji/core/entity/msgw/MsgwAlarmLog.java Просмотреть файл

@Size(max = 255) @Size(max = 255)
@Column(name = "MESSAGE_ID") @Column(name = "MESSAGE_ID")
private String messageId;//主表id private String messageId;//主表id
@Size(max = 100)
@Column(name = "MESSAGE_TYPE") @Column(name = "MESSAGE_TYPE")
@Enumerated(EnumType.STRING) @Enumerated(EnumType.STRING)
private MessageType messageType;//消息类型 private MessageType messageType;//消息类型

+ 1
- 2
gly-base-core/src/main/java/cn/com/taiji/core/entity/msgw/MsgwClient.java Просмотреть файл

@Size(max = 50) @Size(max = 50)
@Column(name = "CLIENT_CODE") @Column(name = "CLIENT_CODE")
private String clientCode;//客户端唯一标识 private String clientCode;//客户端唯一标识
@NotBlank
@Size(max = 50)
@NotNull
@Column(name = "MESSAGE_TYPE") @Column(name = "MESSAGE_TYPE")
@Enumerated(EnumType.STRING) @Enumerated(EnumType.STRING)
private MessageType messageType;//客户端id private MessageType messageType;//客户端id

+ 1
- 2
gly-base-core/src/main/java/cn/com/taiji/core/entity/msgw/MsgwSendApply.java Просмотреть файл

@Size(max = 50) @Size(max = 50)
@Column(name = "MODEL_ID") @Column(name = "MODEL_ID")
private String modelId;//模板id private String modelId;//模板id
@NotBlank
@Size(max = 20)
@NotNull
@Column(name = "MESSAGE_TYPE") @Column(name = "MESSAGE_TYPE")
@Enumerated(EnumType.STRING) @Enumerated(EnumType.STRING)
private MessageType messageType;//发送客户端类型 private MessageType messageType;//发送客户端类型

+ 2
- 6
gly-base-core/src/main/java/cn/com/taiji/core/entity/msgw/MsgwSendDetails.java Просмотреть файл

import java.time.LocalDateTime; import java.time.LocalDateTime;


import javax.persistence.*; import javax.persistence.*;
import javax.validation.constraints.Digits;
import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import javax.validation.constraints.Size; import javax.validation.constraints.Size;
@Size(max = 50) @Size(max = 50)
@Column(name = "MODEL_ID") @Column(name = "MODEL_ID")
private String modelId;//模板id private String modelId;//模板id
@NotBlank
@Size(max = 20)
@NotNull
@Column(name = "MESSAGE_TYPE") @Column(name = "MESSAGE_TYPE")
@Enumerated(EnumType.STRING) @Enumerated(EnumType.STRING)
private MessageType messageType;//发送客户端类型 private MessageType messageType;//发送客户端类型
@Size(max = 100) @Size(max = 100)
@Column(name = "RECEIVER_ID") @Column(name = "RECEIVER_ID")
private String receiverId;//接收人id private String receiverId;//接收人id
@NotBlank
@Size(max = 64) @Size(max = 64)
@Column(name = "REQUEST_CLASS_NAME") @Column(name = "REQUEST_CLASS_NAME")
private String requestClassName;//发送类名 private String requestClassName;//发送类名
@NotBlank
@Size(max = 255)
@NotNull
@Column(name = "SEND_RESULT") @Column(name = "SEND_RESULT")
@Enumerated(EnumType.STRING) @Enumerated(EnumType.STRING)
private MessageResult sendResult;//发送结果 private MessageResult sendResult;//发送结果

+ 2
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ias/IasServiceType.java Просмотреть файл

import cn.com.taiji.core.model.comm.protocol.SignServiceSystem; import cn.com.taiji.core.model.comm.protocol.SignServiceSystem;
import cn.com.taiji.core.model.comm.protocol.SignServiceType; import cn.com.taiji.core.model.comm.protocol.SignServiceType;
import cn.com.taiji.core.model.comm.protocol.ias.bill.BillServiceCmd; import cn.com.taiji.core.model.comm.protocol.ias.bill.BillServiceCmd;
import cn.com.taiji.core.model.comm.protocol.ias.message.ChannelServiceCmd;
import cn.com.taiji.core.model.comm.protocol.ias.order.OrderServiceCmd; import cn.com.taiji.core.model.comm.protocol.ias.order.OrderServiceCmd;
import cn.com.taiji.core.model.comm.protocol.ias.portal.PortalServiceCmd; import cn.com.taiji.core.model.comm.protocol.ias.portal.PortalServiceCmd;
import cn.com.taiji.core.model.comm.protocol.ias.province.ProvinceCmd; import cn.com.taiji.core.model.comm.protocol.ias.province.ProvinceCmd;
PORTAL("统一认证", "^PORTAL_\\S+\\.json$", PortalServiceCmd.values()), PORTAL("统一认证", "^PORTAL_\\S+\\.json$", PortalServiceCmd.values()),
ORDER("发行接口", "^ORDER_\\S+\\.json$", OrderServiceCmd.values()), ORDER("发行接口", "^ORDER_\\S+\\.json$", OrderServiceCmd.values()),
VALID("校验接口", "^VALID_\\S+\\.json$", ValidServiceCmd.values()), VALID("校验接口", "^VALID_\\S+\\.json$", ValidServiceCmd.values()),
NOTICE("消息发送", "^NOTICE\\S+\\.json$", ChannelServiceCmd.values()),
; ;


@Getter @Getter

+ 1
- 1
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/ias/message/ChannelServiceCmd.java Просмотреть файл



@Override @Override
public SignServiceType getServiceType() { public SignServiceType getServiceType() {
return IasServiceType.PORTAL;
return IasServiceType.NOTICE;
} }


public static ChannelServiceCmd fromIfCode(String ifCode) { public static ChannelServiceCmd fromIfCode(String ifCode) {

+ 4
- 0
zhywpt-service-ias/src/main/java/cn/com/taiji/ias/manager/MyCommHandleManager.java Просмотреть файл

import cn.com.taiji.core.model.comm.protocol.ias.IasServiceSystem; import cn.com.taiji.core.model.comm.protocol.ias.IasServiceSystem;
import cn.com.taiji.core.model.comm.protocol.ias.IasServiceType; import cn.com.taiji.core.model.comm.protocol.ias.IasServiceType;
import cn.com.taiji.ias.manager.handler.BillServiceHandler; import cn.com.taiji.ias.manager.handler.BillServiceHandler;
import cn.com.taiji.ias.manager.handler.ChannelSendHandler;
import cn.com.taiji.ias.manager.handler.PortalServiceHandler; import cn.com.taiji.ias.manager.handler.PortalServiceHandler;
import cn.com.taiji.ias.manager.handler.ProvinceHandler; import cn.com.taiji.ias.manager.handler.ProvinceHandler;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
private PortalServiceHandler portalServiceHandler; private PortalServiceHandler portalServiceHandler;
@Autowired @Autowired
private ProvinceHandler provinceHandler; private ProvinceHandler provinceHandler;
@Autowired
private ChannelSendHandler channelSendHandler;


public MyCommHandleManager() { public MyCommHandleManager() {
super(IasServiceSystem.ISSUES); super(IasServiceSystem.ISSUES);
registerJsonService(billServiceHandler); registerJsonService(billServiceHandler);
registerJsonService(portalServiceHandler); registerJsonService(portalServiceHandler);
registerJsonService(provinceHandler); registerJsonService(provinceHandler);
registerJsonService(channelSendHandler);
} }


@Override @Override

+ 14
- 12
zhywpt-service-ods/src/main/java/cn/com/taiji/ods/manager/ois/issue/OrderSaveManagerImpl.java Просмотреть файл

etcOrderVehicleInfo.setEngineNum(vehicle.getEngineNum()); etcOrderVehicleInfo.setEngineNum(vehicle.getEngineNum());
etcOrderVehicleInfo.setType(vehicle.getType()); etcOrderVehicleInfo.setType(vehicle.getType());
etcOrderVehicleInfo.setUseCharacter(vehicle.getUseCharacter()); etcOrderVehicleInfo.setUseCharacter(vehicle.getUseCharacter());
etcOrderVehicleInfo.setRegisterDate(vehicle.getRegisterDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
etcOrderVehicleInfo.setIssueDate(vehicle.getRegisterDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
etcOrderVehicleInfo.setRegisterDate(vehicle.getRegisterDate());
etcOrderVehicleInfo.setIssueDate(vehicle.getRegisterDate());
etcOrderVehicleInfo.setFileNum(vehicle.getFileNum()); etcOrderVehicleInfo.setFileNum(vehicle.getFileNum());
etcOrderVehicleInfo.setApprovedCount(vehicle.getApprovedCount()); etcOrderVehicleInfo.setApprovedCount(vehicle.getApprovedCount());
etcOrderVehicleInfo.setTotalMass(vehicle.getTotalMass().intValue()); etcOrderVehicleInfo.setTotalMass(vehicle.getTotalMass().intValue());
etcOrderVehicleInfo.setPermittedTowWeight(vehicle.getPermittedTowWeight().intValue()); etcOrderVehicleInfo.setPermittedTowWeight(vehicle.getPermittedTowWeight().intValue());
etcOrderVehicleInfo.setAxleDistance(vehicle.getAxleDistance()); etcOrderVehicleInfo.setAxleDistance(vehicle.getAxleDistance());
etcOrderVehicleInfo.setTestRecord(vehicle.getTestRecord()); etcOrderVehicleInfo.setTestRecord(vehicle.getTestRecord());
// etcOrderVehicleInfo.setWheelCount(vehicle.getWheelCount());
etcOrderVehicleInfo.setWheelCount(vehicle.getVehicleWheelCount());
etcOrderVehicleInfo.setAxisType(vehicle.getAxisType()); etcOrderVehicleInfo.setAxisType(vehicle.getAxisType());
// etcOrderVehicleInfo.setOwnerIdNum(vehicle.getOwnerIdNum());
// etcOrderVehicleInfo.setOwnerIdType(vehicle.getOwnerIdType());
etcOrderVehicleInfo.setOwnerIdNum(vehicle.getOwnerIdNum());
etcOrderVehicleInfo.setOwnerIdType(vehicle.getOwnerIdType().getCode());
etcOrderVehicleInfo.setOwnerTel(vehicle.getOwnerTel()); etcOrderVehicleInfo.setOwnerTel(vehicle.getOwnerTel());
// etcOrderVehicleInfo.setTransportIdNum(vehicle.getTransportIdNum());
etcOrderVehicleInfo.setTransportIdNum(vehicle.getTransportIdNum());
// etcOrderVehicleInfo.setRoadTransCertUrl(vehicle.getRoadTransportPermitPicUrl()); // etcOrderVehicleInfo.setRoadTransCertUrl(vehicle.getRoadTransportPermitPicUrl());
} }
etcOrderVehicleInfo.setCustomerType(order.getUserType().getCode()); etcOrderVehicleInfo.setCustomerType(order.getUserType().getCode());
etcOrderUserInfo.setIdentNo(order.getCustomerIdNum()); etcOrderUserInfo.setIdentNo(order.getCustomerIdNum());
etcOrderUserInfo.setIdentType(order.getCustomerIdType().getCode()); etcOrderUserInfo.setIdentType(order.getCustomerIdType().getCode());
etcOrderUserInfo.setUserMobile(order.getCustomerTel()); etcOrderUserInfo.setUserMobile(order.getCustomerTel());
// etcOrderUserInfo.setAddress(ext.getCustomerAddress());
// etcOrderUserInfo.setDepartment(ext.getCustomerDepartment());
etcOrderUserInfo.setAddress(ext.getCustomerAddress());
etcOrderUserInfo.setDepartment(ext.getCustomerDepartment());
etcOrderUserInfo.setAgentName(order.getAgentName()); etcOrderUserInfo.setAgentName(order.getAgentName());
etcOrderUserInfo.setAgentIdType(order.getAgentIdType().getCode()); etcOrderUserInfo.setAgentIdType(order.getAgentIdType().getCode());
etcOrderUserInfo.setAgentIdNum(order.getAgentIdNum()); etcOrderUserInfo.setAgentIdNum(order.getAgentIdNum());
etcApplyOrder.setOrgcode(order.getAccountId()); etcApplyOrder.setOrgcode(order.getAccountId());
if (order.getOrderStatus() == IssueOrderStatus.CANCEL) { if (order.getOrderStatus() == IssueOrderStatus.CANCEL) {
//需要判断退货还是撤销 //需要判断退货还是撤销
if (ShippingStatus.RECEIVED.name().equals(order.getShippingStatus())) {
if (ShippingStatus.RECEIVED.equals(order.getShippingStatus())) {
etcApplyOrder.setOrderstatus(-3); etcApplyOrder.setOrderstatus(-3);
} else { } else {
etcApplyOrder.setOrderstatus(-2); etcApplyOrder.setOrderstatus(-2);
} }
} else if (order.getOrderStep().equals("7")) {
} else if (order.getOrderStep().getCode().equals(7)) {
etcApplyOrder.setOrderstatus(-1); etcApplyOrder.setOrderstatus(-1);
} else { } else {
//判断审核之后 //判断审核之后
etcApplyOrder.setReviewer(order.getAuditOpId()); etcApplyOrder.setReviewer(order.getAuditOpId());
etcApplyOrder.setReviewopinion(ext.getAuditFailureCase()); etcApplyOrder.setReviewopinion(ext.getAuditFailureCase());
etcApplyOrder.setReviewstatus(order.getArtificialStatus() == 0?0:1); etcApplyOrder.setReviewstatus(order.getArtificialStatus() == 0?0:1);
etcApplyOrder.setDeliverystatus(ShippingStatus.RECEIVED.name().equals(order.getShippingStatus())?1:0);
etcApplyOrder.setDeliverystatus(ShippingStatus.RECEIVED.equals(order.getShippingStatus())?1:0);
etcApplyOrder.setCardid(order.getCardId()); etcApplyOrder.setCardid(order.getCardId());
etcApplyOrder.setObuid(order.getObuId()); etcApplyOrder.setObuid(order.getObuId());
etcApplyOrder.setPromoterchannelnum(order.getAccountId()); etcApplyOrder.setPromoterchannelnum(order.getAccountId());
etcApplyOrder.setOpencardtime(order.getCardEnableTime()); etcApplyOrder.setOpencardtime(order.getCardEnableTime());
etcApplyOrder.setOpenobutime(order.getObuEnableTime()); etcApplyOrder.setOpenobutime(order.getObuEnableTime());
etcApplyOrder.setActivetime(order.getActivationTime()); etcApplyOrder.setActivetime(order.getActivationTime());
// etcApplyOrder.setCanceltime(ext.getCancelTime());
etcApplyOrder.setCanceltime(order.getCancelTime());
etcApplyOrder.setCancelreason(ext.getCancelReason()); etcApplyOrder.setCancelreason(ext.getCancelReason());
etcApplyOrder.setReturngoodstime(order.getReturnGoodsTime()); etcApplyOrder.setReturngoodstime(order.getReturnGoodsTime());
etcApplyOrder.setDeliverytime(order.getDeliveryTime()); etcApplyOrder.setDeliverytime(order.getDeliveryTime());
etcApplyOrder.setApplysourcetype(6); etcApplyOrder.setApplysourcetype(6);
} else if (SourceType.SERVICE_HALL.equals(order.getOrderSource())) { } else if (SourceType.SERVICE_HALL.equals(order.getOrderSource())) {
etcApplyOrder.setApplysourcetype(1); etcApplyOrder.setApplysourcetype(1);
}else if (SourceType.CHANNEL.equals(order.getOrderSource())) {
etcApplyOrder.setApplysourcetype(7);
} }
etcApplyOrder.setCreatetime(order.getInsertTime()); etcApplyOrder.setCreatetime(order.getInsertTime());
etcApplyOrder.setUpdatetime(order.getUpdateTime()); etcApplyOrder.setUpdatetime(order.getUpdateTime());

Загрузка…
Отмена
Сохранить