| | |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.core.annotation.Java110Cmd; |
| | | import com.java110.core.annotation.Java110Transactional; |
| | | import com.java110.core.context.ICmdDataFlowContext; |
| | | import com.java110.core.event.cmd.AbstractServiceCmdListener; |
| | | import com.java110.core.event.cmd.CmdEvent; |
| | |
| | | import com.java110.utils.cache.CommonCache; |
| | | import com.java110.utils.exception.CmdException; |
| | | import com.java110.utils.util.BeanConvertUtil; |
| | | import com.java110.utils.util.StringUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.ResponseEntity; |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | @Java110Transactional |
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
| | | String paramIn = CommonCache.getAndRemoveValue("getTempCarFeeOrder" + reqJson.getString("oId")); |
| | | String paramIn = CommonCache.getAndRemoveValue("queryTempCarFeeOrder" + reqJson.getString("oId")); |
| | | if (StringUtil.isEmpty(paramIn)) { |
| | | throw new CmdException("已经处理过了 再不处理"); |
| | | } |
| | | JSONObject paramObj = JSONObject.parseObject(paramIn); |
| | | System.out.println("获取到内存中的数据了++++++++++++==》"+paramObj.toJSONString()); |
| | | modifyCouponUser(paramObj); |
| | |
| | | couponUserDetailPo.setUserId(couponUser.getUserId()); |
| | | couponUserDetailPo.setCouponName(couponUser.getCouponName()); |
| | | couponUserDetailPo.setUserName(couponUser.getUserName()); |
| | | couponUserDetailPo.setObjId(paramObj.getString("feeId")); |
| | | couponUserDetailPo.setObjType(paramObj.getString("feeTypeCd")); |
| | | couponUserDetailPo.setObjId(paramObj.getString("carNum")); |
| | | couponUserDetailPo.setObjType("车辆"); |
| | | couponUserDetailPo.setOrderId(paramObj.getString("oId")); |
| | | fage = couponUserDetailV1InnerServiceSMOImpl.saveCouponUserDetail(couponUserDetailPo); |
| | | if (fage < 1) { |